当前位置：首页 > 文章列表 > Golang > Go教程 > Go database/sql 事务里怎么区分 Commit 和 Rollback 错误

Go database/sql 事务里怎么区分 Commit 和 Rollback 错误

来源：17golang原创 2026-09-08 21:00:40 0浏览收藏

Go 的 database/sql 事务里，业务语句失败、Rollback 失败和 Commit 失败不是同一种问题。最稳妥的处理顺序是：业务语句出错时先回滚并保留两份错误；提交出错时把事务结果视为“需要核对”，不要因为回滚返回成功就认定数据一定没有写入。

要点速览

ExecContext 等业务操作失败，主错误是业务错误，Rollback 错误要作为附加原因记录。
defer tx.Rollback() 适合做兜底清理，但不能替代显式错误分支。
Commit 返回错误后不要盲目重试，先按业务唯一键、订单号或对账记录核对状态。

先把三类错误分开：业务、回滚、提交

sql.Tx 里至少有三个需要单独命名的错误边界。第一类是 SQL 执行或扫描失败，例如约束冲突、连接中断或参数错误；第二类是调用 Rollback 时清理事务失败；第三类是 Commit 阶段失败。它们对应的补救动作不同，日志也不应只写一条“事务失败”。

Go database/sql 事务中 BeginTx、业务语句、业务错误、Rollback、Commit 与提交状态的错误边界关系图 — 图1：把业务执行错误、Rollback 错误和 Commit 错误放在不同边界里，日志才不会把原因混在一起。

错误位置	优先动作	日志重点
BeginTx	直接返回，不进入业务分支	连接、上下文和事务参数
业务语句	Rollback，并保留回滚结果	原始 SQL 操作与业务主键
Rollback	追加记录，不覆盖业务错误	rollback_error
Commit	停止盲目重试，核对最终状态	commit_error 与幂等键

用显式分支保留真实错误来源

业务分支里要先保存原始错误，再调用回滚。Go 1.20 及以后可以用 errors.Join 把两份原因交给上层；如果项目还要兼容更早版本，也可以用结构化日志分别记录，不要用回滚错误覆盖业务错误。

func changeStatus(ctx context.Context, db *sql.DB, id int64) (err error) {
	// BeginTx 失败时没有事务可回滚，直接返回初始化错误。
	tx, err := db.BeginTx(ctx, nil)
	if err != nil {
		return fmt.Errorf("begin transaction: %w", err)
	}

	// 兜底清理只负责收尾；显式失败分支仍要单独处理回滚错误。
	defer func() {
		if rollbackErr := tx.Rollback(); rollbackErr != nil && !errors.Is(rollbackErr, sql.ErrTxDone) && err == nil {
			err = fmt.Errorf("rollback: %w", rollbackErr)
		}
	}()

	if _, err = tx.ExecContext(ctx,
		"UPDATE account SET status = ? WHERE id = ?", "active", id); err != nil {
		// 这里的 err 是业务操作错误，不能被 Rollback 的结果替换。
		rollbackErr := tx.Rollback()
		if rollbackErr != nil && !errors.Is(rollbackErr, sql.ErrTxDone) {
			return errors.Join(
				fmt.Errorf("update account: %w", err),
				fmt.Errorf("rollback: %w", rollbackErr),
			)
		}
		return fmt.Errorf("update account: %w", err)
	}

	if err = tx.Commit(); err != nil {
		// 提交失败可能处于未知状态，交给上层按幂等键核对。
		return fmt.Errorf("commit: %w", err)
	}
	return nil
}

这个示例里有一个容易忽略的细节：显式失败分支已经调用过 Rollback，随后 defer 再调用一次通常只会得到 sql.ErrTxDone，因此被忽略。生产代码也可以把回滚封装成一个小函数，统一输出 operation_error 和 rollback_error 两个字段。