在Go语言的后端开发中，数据库操作是非常核心的场景，而SQL连接的管理直接关系到程序的性能和稳定性。Go标准库提供的database_sql包已经封装了完善的连接管理机制，开发者不需要手动维护连接的共享和生命周期，只需要遵循惯用模式即可。
Go中SQL连接的惯用共享模式
Go语言中SQL连接的共享不需要开发者自己实现连接池，database_sql包的sql.DB类型本身就是线程安全的连接池抽象，它的设计目标就是被多个goroutine共享使用。惯用的使用模式如下：
package main
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql" // 导入MySQL驱动，初始化注册
)
func main() {
// 打开数据库连接，返回的是连接池对象，不是单个连接
db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/test_db")
if err != nil {
panic(err)
}
// 程序退出时关闭连接池，释放所有资源
defer db.Close()
// 多个goroutine可以直接共享这个db对象
// 不需要每个goroutine单独创建连接
// 连接池会自动分配空闲连接，没有空闲时按需创建新连接
}
这里需要注意，sql.Open并不会立即建立数据库连接，它只是初始化连接池对象，真正的连接会在第一次执行数据库操作时建立。因此不需要担心程序启动时创建大量无用连接的问题。
连接池的常用配置
默认的sql.DB连接池配置不一定符合所有业务场景，开发者可以通过对应的方法调整参数：
- SetMaxOpenConns：设置连接池最多同时打开的连接数，默认值是0，表示不限制。如果数据库有连接数上限，需要设置这个值避免超出限制。
- SetMaxIdleConns：设置连接池中最多保留的空闲连接数，默认值是2。空闲连接是指没有被使用的连接，保留空闲连接可以减少新建连接的开销。
- SetConnMaxLifetime：设置单个连接的最大存活时间，超过这个时间后连接会被关闭。可以避免使用过期的数据库连接。
- SetConnMaxIdleTime：设置空闲连接的最大存活时间，超过这个时间没有被使用的空闲连接会被关闭，释放资源。
示例配置代码如下：
func initDB() (*sql.DB, error) {
db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/test_db")
if err != nil {
return nil, err
}
// 最多同时打开10个连接
db.SetMaxOpenConns(10)
// 最多保留5个空闲连接
db.SetMaxIdleConns(5)
// 单个连接最多存活30分钟
db.SetConnMaxLifetime(30 * time.Minute)
// 空闲连接最多存活10分钟
db.SetConnMaxIdleTime(10 * time.Minute)
return db, nil
}
SQL连接的并发安全实现
sql.DB本身是并发安全的，多个goroutine同时调用它的方法不会出现数据竞争问题，但是开发者在编写数据库操作代码时还是需要注意一些细节，避免并发场景下的错误。
避免连接泄漏
连接泄漏是最常见的并发问题之一，通常是因为获取了连接但是没有正确释放。使用Query方法查询数据时，返回的sql.Rows对象需要调用Close方法释放连接，否则连接会一直被占用，最终导致连接池耗尽。
正确的查询代码示例如下：
func queryUser(db *sql.DB, id int) (string, error) {
// 执行查询，获取结果集
rows, err := db.Query("SELECT name FROM user WHERE id = ?", id)
if err != nil {
return "", err
}
// 函数退出前关闭结果集，释放连接
defer rows.Close()
var name string
if rows.Next() {
err = rows.Scan(&name)
if err != nil {
return "", err
}
}
// 检查遍历过程中是否有错误
if err = rows.Err(); err != nil {
return "", err
}
return name, nil
}
同样，使用QueryRow方法查询单行数据时，虽然不需要手动关闭Rows，但是也需要调用Scan方法才能释放连接，否则也会出现连接泄漏：
func queryUserSingle(db *sql.DB, id int) (string, error) {
var name string
// 必须调用Scan方法，否则连接不会被释放
err := db.QueryRow("SELECT name FROM user WHERE id = ?", id).Scan(&name)
if err != nil {
return "", err
}
return name, nil
}
事务的并发安全
事务操作需要保证同一个事务内的所有操作使用同一个连接，database_sql包的事务对象是sql.Tx，它也是并发安全的，但是不建议在多个goroutine之间共享同一个sql.Tx对象，否则容易出现操作混乱的问题。
正确的事务使用模式是在单个goroutine内完成事务的所有操作：
func transferMoney(db *sql.DB, fromID, toID int, amount float64) error {
// 开启事务，会从连接池获取一个连接，事务内所有操作都使用这个连接
tx, err := db.Begin()
if err != nil {
return err
}
// 事务失败时回滚
defer func() {
if p := recover(); p != nil {
tx.Rollback()
panic(p)
} else if err != nil {
tx.Rollback()
}
}()
// 扣减转出账户余额
_, err = tx.Exec("UPDATE account SET balance = balance - ? WHERE id = ?", amount, fromID)
if err != nil {
return err
}
// 增加转入账户余额
_, err = tx.Exec("UPDATE account SET balance = balance + ? WHERE id = ?", amount, toID)
if err != nil {
return err
}
// 提交事务
err = tx.Commit()
return err
}
预处理语句的并发使用
预处理语句sql.Stmt是并发安全的，可以被多个goroutine同时使用，它内部会正确处理连接的分配和释放，不需要开发者额外加锁。如果某个SQL语句会被多次执行，建议使用预处理语句减少SQL解析的开销。
func initStmt(db *sql.DB) (*sql.Stmt, error) {
// 创建预处理语句，会被缓存，多个goroutine可以共享使用
stmt, err := db.Prepare("INSERT INTO user (name, age) VALUES (?, ?)")
if err != nil {
return nil, err
}
return stmt, nil
}
// 多个goroutine可以调用这个方法执行预处理语句
func insertUser(stmt *sql.Stmt, name string, age int) error {
_, err := stmt.Exec(name, age)
return err
}
常见误区说明
很多开发者会尝试自己手动实现连接池，或者每个请求创建一个sql.DB对象，这些都是不符合惯用模式的。手动实现连接池不仅工作量大，还容易出现并发安全问题，而每个请求创建sql.DB会导致连接无法复用，性能下降，还可能超出数据库的连接限制。
另外，不需要对sql.DB的方法调用加锁，因为它内部已经实现了完善的并发控制逻辑，额外加锁反而会降低性能，甚至导致死锁。
最后，程序退出时一定要调用db.Close()方法关闭连接池，否则可能会导致部分连接没有正确释放，出现资源泄漏的问题。
GoSQL连接并发安全database_sql连接池修改时间：2026-07-03 22:15:37