From dd8d043cb88440207670da9604777e994a78e830 Mon Sep 17 00:00:00 2001 From: Yosyp Buchma Date: Wed, 20 Sep 2023 13:13:50 +0300 Subject: [PATCH] moved mysql connection pool config to openConection func --- generator/mysql/mysql_generator.go | 5 +++++ generator/mysql/query_set.go | 4 ---- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/generator/mysql/mysql_generator.go b/generator/mysql/mysql_generator.go index 635bcbc..7495bec 100644 --- a/generator/mysql/mysql_generator.go +++ b/generator/mysql/mysql_generator.go @@ -12,6 +12,8 @@ import ( mysqldr "github.com/go-sql-driver/mysql" ) +const mysqlMaxConns = 10 + // DBConnection contains MySQL connection details type DBConnection struct { Host string @@ -83,6 +85,9 @@ func openConnection(connectionString string) (*sql.DB, error) { return nil, fmt.Errorf("failed to open mysql connection: %w", err) } + db.SetMaxOpenConns(mysqlMaxConns) + db.SetMaxIdleConns(mysqlMaxConns) + err = db.Ping() if err != nil { return nil, fmt.Errorf("failed to ping database: %w", err) diff --git a/generator/mysql/query_set.go b/generator/mysql/query_set.go index b58ff82..80406bd 100644 --- a/generator/mysql/query_set.go +++ b/generator/mysql/query_set.go @@ -28,10 +28,6 @@ ORDER BY table_name; return nil, fmt.Errorf("failed to query %s metadata result: %w", tableType, err) } - const maxConns = 32 - db.SetMaxOpenConns(maxConns) - db.SetMaxIdleConns(maxConns) - wg := errgroup.Group{} for i := 0; i < len(tables); i++ { i := i