add
This commit is contained in:
@@ -21,10 +21,10 @@ func Init() {
|
||||
dbName := os.Getenv("DB_NAME")
|
||||
zap.L().Info(
|
||||
"💡 读取数据库配置",
|
||||
zap.String("host", dbHost), // key: "host", value: dbHost(string类型)
|
||||
zap.String("port", dbPort), // key: "port", value: dbPort(string类型)
|
||||
zap.String("user", dbUser), // key: "user", value: dbUser(string类型)
|
||||
zap.String("dbname", dbName), // key: "dbname", value: dbName(string类型)
|
||||
zap.String("host", dbHost),
|
||||
zap.String("port", dbPort),
|
||||
zap.String("user", dbUser),
|
||||
zap.String("dbname", dbName),
|
||||
)
|
||||
|
||||
// 构建数据库连接字符串
|
||||
@@ -38,12 +38,16 @@ func Init() {
|
||||
if err != nil {
|
||||
zap.L().Panic("❌ 无法连接数据库", zap.Error(err))
|
||||
}
|
||||
defer DB.Close()
|
||||
zap.L().Info("✅ 数据库连接对象创建成功")
|
||||
|
||||
// 设置连接池参数
|
||||
DB.SetMaxOpenConns(100) // 最大打开连接数
|
||||
DB.SetMaxIdleConns(20) // 最大空闲连接数
|
||||
DB.SetConnMaxLifetime(time.Hour) // 连接最大存活时间
|
||||
|
||||
// 验证数据库连接
|
||||
if err := DB.Ping(); err != nil {
|
||||
zap.L().Panic("❌ 数据库连接失败", zap.Error(err))
|
||||
}
|
||||
|
||||
zap.L().Info("✅ 数据库连接验证成功")
|
||||
}
|
||||
}
|
||||
@@ -15,6 +15,7 @@ func main() {
|
||||
zap.L().Info("🚀 用户服务初始化")
|
||||
zap.L().Info("⌛️ 数据库初始化开始")
|
||||
db.Init()
|
||||
defer db.DB.Close() // 应用退出时关闭连接
|
||||
zap.L().Info("✅ 数据库初始化成功")
|
||||
|
||||
gin.SetMode(gin.ReleaseMode)
|
||||
|
||||
Reference in New Issue
Block a user