

新闻资讯
技术学院Go Web事务需手动控制,无自动回滚;必须在HTTP handler中显式Begin/Commit/Rollback,绑定单次请求,避免锁持有和连接池耗尽。
机制Go 标准库 database/sql 不提供声明式事务(比如 Spring 的 @Transactional),所有事务都得显式调用 Begin()、Commit() 或 Rollback()。一旦出错没手动 Rollback(),连接会一直持有锁,甚至导致连接池耗尽。
事务生命周期应严格绑定到单次 HTTP 请求,不能跨请求复用 *sql.Tx。常见错误是把 tx 当*局变量或塞进 context 后忘了清理。
db.Begin(),立即检查 errortx.Query/Exec/Prepare,而非 db.Query/Exec
tx.Commit();任意环节 panic 或 error 都必须触发 tx.Rollback()
defer + 布尔标记避免重复 Rollback()
func transferHandler(w http.ResponseWriter, r *http.Request) {
tx, err := db.Begin()
if err != nil {
http.Error(w, "tx begin failed", http.StatusInternalServerError)
return
}
defer func() {
if r := recover(); r != nil {
tx.Rollback()
panic(r)
}
}()
fromOK := updateBalance(tx, "alice", -100)
toOK := updateBalance(tx, "bob", +100)
if !fromOK || !toOK {
tx.Rollback()
http.Error(w, "balance update failed", http.StatusBadRequest)
return
}
if err := tx.Commit(); err != nil {
http.Error(w, "commit failed", http.StatusInternalServerError)
return
}
}
sqlx 是标准库增强,事务 API 与原生一致,只是多了 struct scan 支持;gorm 提供了 Session 和 Transaction 封装,但默认不自动 rollback——仍需显式处理。
sqlx:用 tx := db.MustBegin() 后,所有 tx.Select/Get/Exec 方法行为同原生gorm:推荐用 db.Transaction(func(tx *gorm.DB) error { ... }),它会在函数返回非 nil error 时自动 Rollback()
gorm.DB.WithContext(ctx).Transaction(...) 中的 ctx 仅控制超时,不影响事务本身PostgreSQL/MySQL 默认隔离级别是 READ COMMITTED,但转账类场景常需 SELECT FOR UPDATE 加行锁。若两个请求按不同顺序更新同一组记录(如 A→B 和 B→A),极易触发死锁。
context.WithTimeout 传给 db.BeginTx,防止事务卡死ERROR 1213 (40001): Deadlock found when trying to get lock 时,应用层需重试(最多 2–3 次)真正难处理的不是语法,而是事务边界和锁粒度——一个 handler 里混着 Redis 更新、消息发送、DB 写入,就很难定义“原子性”。这时候得靠业务拆分或最终一致性补偿,而不是硬塞进一个 SQL 事务里。