From 31fc27eb25b60502466089b07eef0ebf09755144 Mon Sep 17 00:00:00 2001 From: Fabian Kramm Date: Tue, 12 Nov 2024 09:02:33 +0100 Subject: [PATCH] fix: close mysql connection after create database Signed-off-by: Fabian Kramm --- pkg/drivers/mysql/mysql.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/drivers/mysql/mysql.go b/pkg/drivers/mysql/mysql.go index 2cf01b0d..bde3fae8 100644 --- 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 }