本文介绍一种符合 Go 语言惯用法的数据库连接共享方案：通过封装 *sql.DB 并利用结构体嵌入实现全局可复用、线程安全且易于管理的数据库实例，避免重复初始化和资源泄漏。
本文介绍一种符合 go 语言惯用法的数据库连接共享方案：通过封装 `*sql.db` 并利用结构体嵌入实现全局可复用、线程安全且易于管理的数据库实例，避免重复初始化和资源泄漏。
在 Go 应用开发中，将数据库连接（如 *sql.DB）作为全局或包级变量共享是常见需求，但必须兼顾安全性、可维护性与生命周期管理。原始代码存在多个关键问题：dbType.DbConnect() 返回了新实例却未被接收；DbClose() 中误用 defer 导致延迟关闭失效；GetDb() 在未连接时返回 nil，引发运行时 panic；且包名 Database 不符合 Go 小写首字母命名规范。
以下是推荐的工程化实践方案：
✅ 正确做法：封装 + 嵌入 + 单例初始化
首先，创建一个标准化的数据访问包（例如 datastore），*直接嵌入 `sql.DB**，使其自动继承所有sql.DB方法（如Exec、Query、Ping、Close` 等），无需手动代理：
// datastore/db.go
package datastore
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
// DB 封装 *sql.DB，支持直接调用其全部方法
type DB struct {
*sql.DB
}
// NewDB 创建并初始化数据库连接，返回 *DB 实例
func NewDB(dsn string) (*DB, error) {
db, err := sql.Open("mysql", dsn)
if err != nil {
return nil, err
}
// 强制验证连接可用性（可选，但强烈建议）
if err = db.Ping(); err != nil {
db.Close() // 避免泄漏
return nil, err
}
return &DB{db}, nil
}? 提示：sql.Open 本身不建立实际连接，Ping() 才触发首次连接校验，这对早期发现配置错误至关重要。
✅ 主程序中统一初始化与使用
在 main.go 中，只需一次初始化，并将 *datastore.DB 作为包级变量或依赖注入使用：
// main.go
package main
import (
"log"
"myproject/datastore" // 替换为你的模块路径
)
var db *datastore.DB
func main() {
var err error
db, err = datastore.NewDB("user:password@tcp(127.0.0.1:3306)/testdb?parseTime=true")
if err != nil {
log.Fatal("failed to connect to database:", err)
}
defer db.Close() // 程序退出前确保关闭（注意：仅适用于简单 CLI 应用）
if err := deleteTestData(); err != nil {
log.Fatal("failed to delete test data:", err)
}
}
func deleteTestData() error {
_, err := db.Exec("DELETE FROM test;")
return err
}⚠️ 关键注意事项
- defer db.Close() 的作用域：它只在当前函数返回时执行。若 main() 中调用 defer db.Close()，则程序退出时关闭连接——这适用于命令行工具；但在 Web 服务（如 Gin/HTTP server）中，应由应用生命周期管理（如 http.Server.RegisterOnShutdown）。
- 并发安全：*sql.DB 本身是并发安全的，可被多个 goroutine 同时使用，无需额外加锁。
- 连接池管理：sql.DB 内置连接池，可通过 SetMaxOpenConns / SetMaxIdleConns 等方法精细调优，不应自行实现连接复用逻辑。
- 错误处理不可省略：每个 Exec / Query 操作都必须检查 err，切勿忽略（如原代码中注释掉的 db.Exec 若启用却无错误处理，将导致静默失败）。
- 包命名规范：Go 包名应全小写、简洁（如 datastore 而非 Database），便于导入和维护。
✅ 进阶建议（生产环境）
- 使用 sqlx 或 ent 等成熟 ORM/SQL 工具替代裸 database/sql；
- 通过配置文件或环境变量加载 DSN，避免硬编码；
- 结合 context.Context 控制查询超时（如 db.QueryContext(ctx, ...)）；
- 在 init() 函数或依赖注入容器（如 Wire）中完成 DB 初始化，提升可测试性。
通过以上方式，你不仅能安全共享数据库连接，还能获得更好的可观测性、可测试性与长期可维护性。
