应全局复用*sql.DB实例,调用sql.Open仅初始化连接池配置,通过SetMaxOpenConns和SetMaxIdleConns控制池大小,避免在handler中重复Open导致连接泄漏与性能下降。
database/sql 复用连接池,别手动 Open 又 Close
Go 的 database/sql 自带连接池,但很多人误以为每次查询都要 sql.Open 再 db.Close。这会导致频繁建连、端口耗尽、TLS 握手开销飙升。
sql.Open 只是初始化驱动和连接池配置,不真正拨号;真正建连发生在第一次 Query 或 Exec
*sql.DB 实例,设置 SetMaxOpenConns 和 SetMaxIdleConns 控制池大小sql.Open —— 这会绕过池,还泄漏 goroutinedb, err := sql.Open("postgres", "user=app dbname=test sslmode=disable")
if err != nil {
log.Fatal(err)
}
db.SetMaxOpenConns(20)
db.SetMaxIdleConns(10)
// 后续所有查询都用这个 db,不 Close
INSERT ... VALUES (...), (...),别循环 Exec
逐行 db.Exec("INSERT INTO t(x) VALUES (?)", x) 是最常见性能杀手:每条语句都走一次 round-trip、参数解析、计划缓存查找。
strings.Builder 拼接 values,避免 fmt.Sprintf 多次内存分配var b strings.Builder
b.WriteString("INSERT INTO users(name, email) VALUES ")
for i, u := range users {
if i > 0 {
b.WriteString(", ")
}
b.WriteString
("(?, ?)")
}
_, err := db.Exec(b.String(), args...) // args 是扁平化的 []interface{}
QueryRow,避免 Query + Next + Scan 手动控制Query 返回 *sql.Rows,必须显式调用 rows.Next() 和 rows.Close(),漏掉任一环节都会导致连接卡在池中(idle but not reusable)或内存泄漏。
QueryRow 内部自动处理单行逻辑,返回后连接立即归还池Query —— 驱动无法推断意图,不会提前释放连接defer rows.Close(),且确保在所有 return 路径前执行var name string
err := db.QueryRow("SELECT name FROM users WHERE id = $1", 123).Scan(&name)
if err != nil {
if err == sql.ErrNoRows {
// 处理未找到
} else {
log.Fatal(err)
}
}
EXPLAIN 一下再上线Go 层面优化再猛,也救不了全表扫描。很多慢查询根本原因不是 Go 代码,而是缺失索引或索引失效。
立即学习“go语言免费学习笔记(深入)”;
EXPLAIN (ANALYZE, BUFFERS) 查看实际执行计划和 I/O 开销WHERE id = '123'(id 是 int),会导致索引失效WHERE a = ? AND b > ? ORDER BY c 最佳索引是 (a, b, c),不是 (a, c, b)
线上加索引建议用 CONCURRENTLY(PG)或 ALGORITHM=INPLACE(MySQL),避免锁表。