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安排好清理工作，就能有效防止忘记回滚的问题。
以上就是Golang数据库事务错误如何回滚的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1411374.html
微信扫一扫 
支付宝扫一扫 
