OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

fix: 数据库链接失败退出程序

Browse Source
This commit is contained in:
TsMask
2025-02-20 16:52:37 +08:00
parent 1f67bf6259
commit 8a6bf6d90d
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/framework/database/db/db.go
View File

@@ -87,17 +87,17 @@ func Connect() {
// 创建连接 // 创建连接
db, err := gorm.Open(info.dialectic, opts) db, err := gorm.Open(info.dialectic, opts)
if err != nil { if err != nil {
logger.Errorf("failed error db connect: %s", err) logger.Fatalf("failed error db connect: %s", err)
} }
// 获取底层 SQL 数据库连接 // 获取底层 SQL 数据库连接
sqlDB, err := db.DB() sqlDB, err := db.DB()
if err != nil { if err != nil {
logger.Errorf("failed error underlying SQL database: %v", err) logger.Fatalf("failed error underlying SQL database: %v", err)
} }
// 测试数据库连接 // 测试数据库连接
err = sqlDB.Ping() err = sqlDB.Ping()
if err != nil { if err != nil {
logger.Errorf("failed error ping database: %v", err) logger.Fatalf("failed error ping database: %v", err)
} }
// SetMaxIdleConns 用于设置连接池中空闲连接的最大数量。 // SetMaxIdleConns 用于设置连接池中空闲连接的最大数量。
sqlDB.SetMaxIdleConns(10) sqlDB.SetMaxIdleConns(10)

2
src/framework/database/redis/redis.go
View File

@@ -33,7 +33,7 @@ func Connect() {
// 测试数据库连接 // 测试数据库连接
pong, err := rdb.Ping(ctx).Result() pong, err := rdb.Ping(ctx).Result()
if err != nil { if err != nil {
logger.Errorf("failed error redis connect: %s is %v", k, err) logger.Fatalf("failed error redis connect: %s is %v", k, err)
} }
logger.Infof("redis %s %d %s connection is successful.", k, client["db"].(int), pong) logger.Infof("redis %s %d %s connection is successful.", k, client["db"].(int), pong)
rdbMap[k] = rdb rdbMap[k] = rdb