在Golang中处理数据库事务需确保错误时及时回滚以维持数据一致性。1. 使用db.Begin()开启事务，通过tx.Commit()或tx.Rollback()结束，二者不可重复调用。2. 每个操作后应检查错误，并利用defer tx.Rollback()确保异常时自动回滚，示例中通过将tx置为nil防止已提交事务被误回滚。3. 多数数据库错误需回滚，但如sql.ErrNoRows等特定错误可按业务逻辑决定是否继续。4. 封装事务逻辑至withTransaction函数可减少重复代码，提升可读性与维护性。关键在于始终保证事务终结，合理使用defer和错误判断。
在Golang中使用数据库事务时，正确处理错误是保证数据一致性的关键。一旦事务中的某个操作失败，应当及时回滚，避免脏数据写入数据库。下面介绍常见的处理方式和最佳实践。
理解事务的开始与结束
Go中通过database/sql包提供的Begin方法开启事务，返回一个*sql.Tx对象。事务只能通过调用Commit()或Rollback()来结束。
注意：即使Commit失败，也不能再调用Rollback。同样，一旦调用Rollback，就不能再尝试Commit。
错误发生时立即回滚
在事务执行过程中，任何一步出错都应中断流程并回滚。常见模式是在每个操作后检查错误，并使用defer确保回滚机制存在。
示例代码：
func transferMoney(db *sql.DB, from, to int, amount float64) error {tx, err := db.Begin()
if err != nil {
return err
}
// 确保事务在函数退出时回滚（除非已提交）
defer func() {
tx.Rollback() // Rollback是幂等的，已提交的事务再次回滚无影响
}()
// 扣款
_, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", amount, from)
if err != nil {
return err // 自动触发defer中的Rollback
}
// 入账
_, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", amount, to)
if err != nil {
return err
}
// 提交事务
if err = tx.Commit(); err != nil {
r
eturn err}
// 阻止defer回滚：将tx置为nil
tx = nil
return nil
}
上面的defer技巧利用了tx.Rollback()对已提交事务无效的特性，同时确保出错时自动清理。
区分不同类型的错误
有些错误不需要回滚整个事务，比如查询无结果（sql.ErrNoRows），这取决于业务逻辑。但大多数数据库错误（如约束冲突、连接中断）应触发回滚。
建议做法：
- 遇到Exec或Query返回错误，优先考虑回滚
- 若需忽略特定错误，明确判断后再决定是否继续
- 不要忽略Commit的错误——它可能表示写入未完成
使用闭包简化事务管理
可以封装通用逻辑，避免重复写defer和错误判断：
func withTransaction(db *sql.DB, fn func(*sql.Tx) error) error {tx, err := db.Begin()
if err != nil {
return err
}
defer func() {
tx.Rollback()
}()
if err := fn(tx); err != nil {
return err
}
return tx.Commit()
}
使用方式：
err := withTransaction(db, func(tx *sql.Tx) error {_, err := tx.Exec("INSERT INTO users ...")
if err != nil {
return err
}
return nil
})
这种模式让事务代码更清晰，错误处理集中。
基本上就这些。关键是：每次出错都要确保回滚，别让事务悬着；合理利用defer；必要时封装通用逻辑。不复杂但容易忽略细节。
