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
diff --git a/connection/mysql_utils.go b/connection/mysql_utils.go
index e231ddcf..442a359f 100644
--- a/connection/mysql_utils.go
+++ b/connection/mysql_utils.go
@@ -40,7 +40,7 @@ func mkMysql(dbType string, dbDsn string, maxOpenConns int) (*sql.DB, error) {
 	mysql.SetLogger(oldlog.New(ioutil.Discard, "", 0))
 
 	db.SetMaxOpenConns(maxOpenConns)
-	db.SetMaxIdleConns(0)
+	db.SetMaxIdleConns(maxOpenConns)
 
 	return db, nil
 }