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