include pk + len(columns)

Shopify · Aug 8, 2018 · 933f5c8 · 933f5c8
1 parent 311f0d0
commit 933f5c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/compression_verifier.go b/compression_verifier.go
@@ -77,7 +77,7 @@ func (c *CompressionVerifier) GetCompressedHashes(db *sql.DB, schema, table, pkC
 	// Decompress applicable columns and hash the resulting column values for comparison
 	resultSet := make(map[uint64][]byte)
 	for rows.Next() {
-		rowData, err := ScanByteRow(rows, len(columns))
+		rowData, err := ScanByteRow(rows, len(columns)+1)
 		if err != nil {
 			return nil, err
 		}