事务
提交和回滚
事务 是 CoddyKit 上的免费 Go Academy 课时。 这是第 4 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Go Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。
为什么需要事务
事务会将多个语句组合起来,使它们要么全部成功,要么全部失败。这样可以保持数据一致,例如在两个账户之间转账时,不会在中途丢失资金。
- 原子性:要么全部完成,要么全部不完成
- 状态一致
- 与其他事务隔离
db.Begin
Begin 会启动一个事务并返回 *sql.Tx。您应在 Tx 上而不是连接池上运行语句,这样它们会共享同一个连接和同一个事务。
tx, err := db.Begin()
if err != nil {
log.Fatal(err)
}Tx 上的语句
调用 tx.Exec 和 tx.Query 的方式与在数据库连接池上调用一样,但在提交或回滚之前,所有操作都会在事务内部运行。
_, err = tx.Exec("UPDATE accounts SET balance = balance - $1 WHERE id = $2", 100, 1)Commit
tx.Commit() 会使所有更改永久保存,并对其他事务可见。如果它返回错误,则事务未被应用。
if err := tx.Commit(); err != nil {
log.Fatal(err)
}Rollback
如果任何步骤失败,请调用 tx.Rollback(),以丢弃自 Begin 以来的所有更改。数据库会恢复到之前的状态,就像什么都没有发生过一样。
if err != nil {
tx.Rollback()
return err
}defer Rollback 模式
一种可靠的惯用模式是在 Begin 后立即延迟调用 Rollback。成功 Commit 后调用 Rollback 只是无害的空操作,因此无论哪条错误路径都能确保完成清理。
tx, err := db.Begin()
if err != nil { return err }
defer tx.Rollback()
// ... do work ...
return tx.Commit()原子转账示例
两次更新组成一个逻辑操作:从一个账户扣除金额,再向另一个账户增加金额。两次更新必须一起提交,否则就都不应生效。
可运行的事务模拟
真正的事务需要数据库。这个可运行示例使用内存映射模拟开始事务、两次更新以及提交或回滚。
package main
import (
"errors"
"fmt"
)
func transfer(bal map[string]int, from, to string, amt int) error {
if bal[from] < amt {
return errors.New("insufficient funds")
}
snapshot := map[string]int{from: bal[from], to: bal[to]}
bal[from] -= amt
bal[to] += amt
if bal[from] < 0 {
bal[from], bal[to] = snapshot[from], snapshot[to]
return errors.New("rolled back")
}
return nil
}
func main() {
bal := map[string]int{"alice": 100, "bob": 20}
if err := transfer(bal, "alice", "bob", 30); err != nil {
fmt.Println("error:", err)
} else {
fmt.Println("committed:", bal)
}
}隔离级别
db.BeginTx 接受包括隔离级别在内的选项,例如 sql.LevelSerializable。更高的隔离级别可以防止更多异常,但可能降低并发能力。
tx, err := db.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelSerializable})保持事务简短
事务会占用一个连接,并且可能持有锁。请快速完成所有 SQL 操作,避免在事务中进行网络调用或读取用户输入,并及时提交以减少争用。
切勿混用 db 和 tx
在事务内部,只能使用 tx 运行语句。在那里调用 db.Exec 会使用事务外的另一个连接,因此这些更改不属于该事务,也不会回滚。
快速检查
请测试您对事务的了解。
总结
您已经学会了事务:
- Begin 返回一个 *sql.Tx;在其上运行语句
- Commit 持久化更改;Rollback 丢弃所有更改
- defer tx.Rollback() 可确保在发生错误时完成清理
- BeginTx 设置隔离级别;保持事务简短
- 同一个事务中切勿混用 db 和 tx
常见问题解答
「事务」课时是免费的吗?
是的 — 「事务」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Go Academy 课程的其余内容,请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。
「事务」这节课中我会学到什么?
提交和回滚 你通过在浏览器中直接运行的动手代码来练习 Go Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Go Academy 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 4 节课,共 4 节。
「事务」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Go Academy 课中编写并运行代码吗?
能。每节 Go Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。