From c88cec603827c2654172ec03afc1e3074cb37ff3 Mon Sep 17 00:00:00 2001
From: vipg <vipg@vipg.com>
Date: Tue, 11 Nov 2025 15:26:11 +0800
Subject: [PATCH] add

---
 backend/user/src/db/postgres.go | 18 +++++++++++-------
 backend/user/src/main.go        |  1 +
 2 files changed, 12 insertions(+), 7 deletions(-)

diff --git a/backend/user/src/db/postgres.go b/backend/user/src/db/postgres.go
index e4553c8..29f8d3d 100644
--- a/backend/user/src/db/postgres.go
+++ b/backend/user/src/db/postgres.go
@@ -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("✅ 数据库连接验证成功")
-}
+}
\ No newline at end of file
diff --git a/backend/user/src/main.go b/backend/user/src/main.go
index 36f2efc..3f6ad04 100644
--- a/backend/user/src/main.go
+++ b/backend/user/src/main.go
@@ -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)