Go中操作数据库事务需确保错误时自动回滚,使用database/sql包的Begin()开启事务,Exec/Query执行操作,Commit提交或Rollback回滚。推荐defer tx.Rollback()并结合错误判断,在函数退出时根据err状态决定提交或回滚,即使已提交,后续Rollback调用返回sql.ErrTxDone可忽略,保证资源安全释放。

在Go语言中操作数据库时,事务的正确使用对数据一致性至关重要。一旦事务执行过程中发生错误,必须及时回滚,避免脏数据写入数据库。Golang通过database/sql包提供了事务支持,回滚机制依赖于sql.Tx对象的Rollback()方法。
事务的基本流程
一个典型的事务处理包括开始事务、执行SQL操作、提交或回滚三个阶段:
- 调用
db.Begin()开启事务,返回*sql.Tx - 使用
tx.Exec()或tx.Query()等方法执行数据库操作 - 操作成功则调用
tx.Commit()提交事务 - 出现错误则调用
tx.Rollback()回滚变更
如何确保错误时自动回滚
关键在于无论函数因何种原因退出,都必须保证Rollback()被调用。推荐使用defer配合错误判断来实现:
func updateUser(tx *sql.Tx, userID int, name string) error { _, err := tx.Exec("UPDATE users SET name = ? WHERE id = ?", name, userID) if err != nil { return err } return nil } func updateWithTransaction(db *sql.DB) error { tx, err := db.Begin() if err != nil { return err } // 确保事务结束时能回滚(如果未提交) defer func() { if err != nil { tx.Rollback() } else { tx.Commit() } }() err = updateUser(tx, 1, "Alice") if err != nil { return err // 触发defer中的Rollback } return nil // 正常返回,触发Commit }
上面的写法利用闭包捕获err变量,在defer中根据错误状态决定是提交还是回滚。注意:这种方式要求所有可能出错的地方都要给外部err赋值,才能正确触发回滚。
立即学习“go语言免费学习笔记(深入)”;
更安全的回滚方式:独立调用Rollback
有时事务已经提交,再调用Rollback()会报错。为避免这种情况,可以将Rollback包装在defer中,并忽略已提交的情况:
tx, err := db.Begin() if err != nil { return err } // 单独defer Rollback,即使后面Commit了也没关系 defer tx.Rollback() // 如果已Commit,Rollback会返回sql.ErrTxDone,可忽略 // 执行操作... _, err = tx.Exec("...") if err != nil { return err } err = tx.Commit() if err != nil { return err } // Commit成功后,defer的Rollback不会产生实际影响
这种模式更简洁,tx.Rollback()在Commit之后调用会返回sql.ErrTxDone,但不影响程序逻辑,适合大多数场景。
基本上就这些。只要记得开启事务后用defer安排好清理工作,就能有效防止忘记回滚的问题。










