diff --git a/connection/mysql.go b/connection/mysql.go
index 00c53c37..ef5f7d38 100644
--- a/connection/mysql.go
+++ b/connection/mysql.go
@@ -680,6 +680,8 @@ func (dbw *DBWrapper) SqlFetchChecksums(table string, ids []string) (map[string]
 		if err != nil {
 			return nil, err
 		}
+
+		rows.Close()
 	}
 
 	return checksums, nil