fix: close mysql connection after create database

Signed-off-by: Fabian Kramm <[email protected]>
loft-sh · Nov 12, 2024 · 4a698dd · 4a698dd
1 parent 810f408
commit 4a698dd
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/drivers/mysql/mysql.go b/pkg/drivers/mysql/mysql.go
@@ -176,6 +176,7 @@ func createDBIfNotExist(dataSourceName string) error {
 	if err != nil {
 		return err
 	}
+	defer db.Close()
 
 	var exists bool
 	err = db.QueryRow("SELECT 1 FROM information_schema.SCHEMATA WHERE schema_name = ?", dbName).Scan(&exists)
@@ -195,6 +196,7 @@ func createDBIfNotExist(dataSourceName string) error {
 			if err != nil {
 				return err
 			}
+			defer db.Close()
 			if _, err = db.Exec(stmt); err != nil {
 				return err
 			}