jen/epusdt
1
0
Fork 0
mirror of https://github.com/GMWalletApp/epusdt.git synced 2026-07-07 10:16:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

修改数据库连接失败挂起的逻辑为10s后重试

Browse Source
This commit is contained in:
noreply
2024-10-14 20:14:10 +08:00
parent b697409ec0
commit 392c922130
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/model/dao/mdb_mysql.go
+13 -3
View File
@@ -25,7 +25,11 @@ func MysqlInit() {
Logger: logger.Default.LogMode(logger.Error), Logger: logger.Default.LogMode(logger.Error),
}) })
if err != nil { if err != nil {
panic(err) color.Red.Printf("[store_db] mysql open DB,err=%s\n", err)
// panic(err)
time.Sleep(10 * time.Second)
MysqlInit()
return
} }
if config.AppDebug { if config.AppDebug {
Mdb = Mdb.Debug() Mdb = Mdb.Debug()
@@ -33,7 +37,10 @@ func MysqlInit() {
sqlDB, err := Mdb.DB() sqlDB, err := Mdb.DB()
if err != nil { if err != nil {
color.Red.Printf("[store_db] mysql get DB,err=%s\n", err) color.Red.Printf("[store_db] mysql get DB,err=%s\n", err)
panic(err) // panic(err)
time.Sleep(10 * time.Second)
MysqlInit()
return
} }
sqlDB.SetMaxIdleConns(viper.GetInt("mysql_max_idle_conns")) sqlDB.SetMaxIdleConns(viper.GetInt("mysql_max_idle_conns"))
sqlDB.SetMaxOpenConns(viper.GetInt("mysql_max_open_conns")) sqlDB.SetMaxOpenConns(viper.GetInt("mysql_max_open_conns"))
@@ -41,7 +48,10 @@ func MysqlInit() {
err = sqlDB.Ping() err = sqlDB.Ping()
if err != nil { if err != nil {
color.Red.Printf("[store_db] mysql connDB err:%s", err.Error()) color.Red.Printf("[store_db] mysql connDB err:%s", err.Error())
panic(err) // panic(err)
time.Sleep(10 * time.Second)
MysqlInit()
return
} }
log.Sugar.Debug("[store_db] mysql connDB success") log.Sugar.Debug("[store_db] mysql connDB success")
} }