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配合错误判断来实现：

<span style="color:blue;">func</span> updateUser(tx *sql.Tx, userID <span style="color:blue;">int</span>, name <span style="color:blue;">string</span>) <span style="color:blue;">error</span> {
    _, err := tx.Exec(<span style="color:#a31515;">"UPDATE users SET name = ? WHERE id = ?"</span>, name, userID)
    <span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
        <span style="color:blue;">return</span> err
    }
    <span style="color:blue;">return</span> <span style="color:blue;">nil</span>
}

<span style="color:blue;">func</span> updateWithTransaction(db *sql.DB) <span style="color:blue;">error</span> {
    tx, err := db.Begin()
    <span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
        <span style="color:blue;">return</span> err
    }

    <span style="color:green;">// 确保事务结束时能回滚（如果未提交）</span>
    defer func() {
        <span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
            tx.Rollback()
        } <span style="color:blue;">else</span> {
            tx.Commit()
        }
    }()

    err = updateUser(tx, 1, <span style="color:#a31515;">"Alice"</span>)
    <span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
        <span style="color:blue;">return</span> err <span style="color:green;">// 触发defer中的Rollback</span>
    }

    <span style="color:blue;">return</span> <span style="color:blue;">nil</span> <span style="color:green;">// 正常返回，触发Commit</span>
}

上面的写法利用闭包捕获err变量，在defer中根据错误状态决定是提交还是回滚。注意：这种方式要求所有可能出错的地方都要给外部err赋值，才能正确触发回滚。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

立即学习“go语言免费学习笔记（深入）”；

更安全的回滚方式：独立调用Rollback

有时事务已经提交，再调用Rollback()会报错。为避免这种情况，可以将Rollback包装在defer中，并忽略已提交的情况：

tx, err := db.Begin()
<span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
    <span style="color:blue;">return</span> err
}
<span style="color:green;">// 单独defer Rollback，即使后面Commit了也没关系</span>
<span style="color:blue;">defer</span> tx.Rollback() <span style="color:green;">// 如果已Commit，Rollback会返回sql.ErrTxDone，可忽略</span>

<span style="color:green;">// 执行操作...</span>
_, err = tx.Exec(<span style="color:#a31515;">"..."</span>)
<span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
    <span style="color:blue;">return</span> err
}

err = tx.Commit()
<span style="color:blue;">if</span> err != <span style="color:blue;">nil</span> {
    <span style="color:blue;">return</span> err
}
<span style="color:green;">// Commit成功后，defer的Rollback不会产生实际影响</span>

这种模式更简洁，tx.Rollback()在Commit之后调用会返回sql.ErrTxDone，但不影响程序逻辑，适合大多数场景。

基本上就这些。只要记得开启事务后用defer安排好清理工作，就能有效防止忘记回滚的问题。