Prechádzať zdrojové kódy

update pool max idle time

ls 8 mesiacov pred
rodič
commit
f383ac0b6d
2 zmenil súbory, kde vykonal 8 pridanie a 4 odobranie
  1. 2 1
      db/config.go
  2. 6 3
      db/db.go

+ 2 - 1
db/config.go

@@ -26,7 +26,8 @@ type Config struct {
 	DNS          string
 	MaxOpenConns int
 	MaxIdle      int
-	MaxLifetime  time.Duration
+	MaxIdleTime  time.Duration
+	MaxLifeTime  time.Duration
 }
 
 // Reply db exec return insert/update/delete

+ 6 - 3
db/db.go

@@ -38,7 +38,8 @@ func SetConfig(cfg Config) {
 	config.DNS = cfg.DNS
 	config.MaxOpenConns = cfg.MaxOpenConns
 	config.MaxIdle = cfg.MaxIdle
-	config.MaxLifetime = cfg.MaxLifetime * time.Second
+	config.MaxIdleTime = cfg.MaxIdleTime * time.Second
+	config.MaxLifeTime = cfg.MaxLifeTime * time.Second
 
 	defaultDB = &DB{Driver: config.Driver}
 }
@@ -66,7 +67,8 @@ func NewConfig(config Config) (dbx *DB, err error) {
 
 	dbx.conn.SetMaxOpenConns(config.MaxOpenConns)
 	dbx.conn.SetMaxIdleConns(config.MaxIdle)
-	dbx.conn.SetConnMaxLifetime(config.MaxLifetime)
+	dbx.conn.SetConnMaxIdleTime(config.MaxIdleTime)
+	dbx.conn.SetConnMaxLifetime(config.MaxLifeTime)
 	err = dbx.conn.Ping()
 	return
 }
@@ -87,7 +89,8 @@ func connect() (dbx *sqlx.DB, err error) {
 		}
 		db.DB.SetMaxOpenConns(config.MaxOpenConns)
 		db.DB.SetMaxIdleConns(config.MaxIdle)
-		db.DB.SetConnMaxLifetime(config.MaxLifetime)
+		db.DB.SetConnMaxIdleTime(config.MaxIdleTime)
+		db.DB.SetConnMaxLifetime(config.MaxLifeTime)
 		err = db.Ping()
 		if err != nil {
 			fmt.Println("Connect Ping", err)