本文介绍如何在 go 中通过依赖注入和配置抽象避免硬编码数据库连接字符串，推荐使用单例 db 实例 + 配置结构体的方式，兼顾安全性、可维护性与并发安全。
本文介绍如何在 go 中通过依赖注入和配置抽象避免硬编码数据库连接字符串，推荐使用单例 db 实例 + 配置结构体的方式，兼顾安全性、可维护性与并发安全。
在 Go 应用开发中，将数据库连接参数（如驱动名、DSN）重复写入每个数据访问函数不仅违反 DRY 原则，还大幅降低可维护性——一旦密码或地址变更，需全局搜索修改。真正的解决方案不是简单导出全局字符串常量（如 const GlobalDB = ...），而是采用配置抽象 + 连接初始化封装 + 依赖传递三位一体的设计。
✅ 推荐实践：配置结构体 + 惰性初始化单例 DB
首先，定义清晰、可扩展的数据库配置结构，并在 database.go 中集中管理：
// database/database.go
package database
import (
"database/sql"
"fmt"
"log"
_ "github.com/go-sql-driver/mysql" // MySQL 驱动
)
// DBConfig 封装数据库连接所需参数，支持环境变量或配置文件注入
type DBConfig struct {
Driver string
User string
Pass string
Host string
Port string
Name string
}
// 全局配置实例（可由 main 或配置加载器初始化）
var Config DBConfig
// 全局 *sql.DB 实例（线程安全，复用连接池）
var db *sql.DB
// Init 初始化数据库连接，应仅在应用启动时调用一次
func Init() (*sql.DB, error) {
if db != nil {
return db, nil
}
dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?parseTime=true&loc=Local",
Config.User, Config.Pass, Config.Host, Config.Port, Config.Name)
var err error
db, err = sql.Open(Config.Driver, dsn)
if err != nil {
return nil, fmt.Errorf("failed to open DB: %w", err)
}
// 可选：设置连接池参数（提升生产稳定性）
db.SetMaxOpenConns(25)
db.SetMaxIdleConns(10)
db.SetConnMaxLifetime(5 * 60 * time.Second)
// 验证连接是否可用
if err = db.Ping(); err != nil {
return nil, fmt.Errorf("failed to ping DB: %w", err)
}
log.Println("✅ Database initialized successfully")
return db, nil
}
// GetDB 返回已初始化的 *sql.DB 实例（安全并发使用）
func GetDB() *sql.DB {
return db
}
然后在 main.go 中统一初始化配置与连接：
Go语言（Golang）1.26.0
下载
Go语言（Golang）1.26.0版本提供 Go 官方 Windows amd64 MSI 安装包下载入口，版本号 1.26.0，可用于旧项目维护、兼容性测试和指定版本开发环境配置。
// main.go
package main
import (
"log"
"your-app/database"
)
func main() {
// 方式1：硬编码（仅用于演示）
database.Config = database.DBConfig{
Driver: "mysql",
User: "user",
Pass: "password",
Host: "127.0.0.1",
Port: "3306",
Name: "hello",
}
// 方式2（推荐）：从环境变量加载
// database.Config = database.LoadFromEnv()
_, err := database.Init()
if err != nil {
log.Fatal("❌ Failed to initialize database:", err)
}
ReadAll()
}
最后，在业务逻辑中直接使用 database.GetDB()，无需每次 sql.Open 和 defer db.Close()：
// readall.go
package main
import (
"database/sql"
"log"
"your-app/database"
)
func ReadAll() {
db := database.GetDB()
if db == nil {
log.Fatal("⚠️ Database not initialized")
}
rows, err := db.Query("SELECT id, name FROM users")
if err != nil {
log.Fatal("❌ Query failed:", err)
}
defer rows.Close()
for rows.Next() {
var id int
var name string
if err := rows.Scan(&id, &name); err != nil {
log.Fatal("❌ Scan failed:", err)
}
log.Printf("User: %d - %s", id, name)
}
}
⚠️ 关键注意事项
- sql.Open 不建立真实连接，它只返回一个可复用的连接池句柄；真正校验连接请调用 db.Ping()。
- 永远不要在每个函数内调用 sql.Open + defer db.Close() —— Close() 会销毁整个连接池，导致后续调用失败。
- *`sql.DB` 是并发安全的**，官方明确推荐作为全局单例复用（见 database/sql 文档）。
- 若需进一步解耦（如单元测试模拟 DB），可将 *sql.DB 作为参数传入函数或方法，实现显式依赖注入：
func ReadAll(db *sql.DB) error { rows, err := db.Query("SELECT ...") // ... }
通过这种结构化方式，你不仅实现了“一处修改、全局生效”的配置管理，更遵循了 Go 的最佳实践：轻量、明确、安全、可测试。
