本文详解 Go 标准库 database/sql 中如何正确结合事务（Tx）与预处理语句（Prepared Statements），确保多步数据库操作的原子性、一致性、隔离性和持久性，并支持自动回滚失败操作。
本文详解 go 标准库 `database/sql` 中如何正确结合事务（tx）与预处理语句（prepared statements），确保多步数据库操作的原子性、一致性、隔离性和持久性，并支持自动回滚失败操作。
在 Go 中，无法将多条 SQL 命令（如 BEGIN; INSERT; INSERT; COMMIT;）合并为单个预处理语句——这正是你遇到 pq: cannot insert multiple commands into a prepared statement 错误的根本原因。PostgreSQL（及多数主流驱动）严格禁止在一条预处理语句中执行多个命令，因为预处理机制设计初衷是单语句复用，而非脚本化执行。
真正的 ACID 事务支持并非通过“SQL 字符串拼接”实现，而是依赖 *sql.Tx 类型提供的显式事务控制流。其核心模式是：
- 调用
db.Begin()启动事务，获得*sql.Tx实例； - 所有后续操作（查询、预处理、执行）均通过该
tx对象进行； - 成功则调用
tx.Commit()提交；任意环节出错则立即调用tx.Rollback()回滚； -
预处理必须使用
tx.Prepare()而非db.Prepare()，以确保语句绑定到当前事务上下文。
以下是符合生产实践的完整示例（适配 PostgreSQL/SQLite，使用 lib/pq 或 mattn/go-sqlite3 驱动）：
func insertIntoTwoTables(db *sql.DB, t1Data struct{ Thing1, Whatever string }, t2Data struct{ Thing2, Whatever string }) error {
// 1. 开启事务
tx, err := db.Begin()
if err != nil {
return fmt.Errorf("failed to begin transaction: %w", err)
}
defer func() {
// 确保 tx.Close() 不被遗漏（虽非必需，但显式清理更清晰）
if tx != nil {
tx.Rollback() // 若未 Commit，此行会静默回滚（已提交后调用无副作用）
}
}()
// 2. 为 table_1 准备并执行插入语句
stmt1, err := tx.Prepare(`INSERT INTO table_1 (thing_1, whatever) VALUES ($1, $2)`)
if err != nil {
tx.Rollback()
return fmt.Errorf("failed to prepare table_1 insert: %w", err)
}
defer stmt1.Close()
_, err = stmt1.Exec(t1Data.Thing1, t1Data.Whatever)
if err != nil {
tx.Rollback()
return fmt.Errorf("failed to insert into table_1: %w", err)
}
// 3. 为 table_2 准备并执行插入语句
stmt2, err := tx.Prepare(`INSERT INTO table_2 (thing_2, whatever) VALUES ($1, $2)`)
if err != nil {
tx.Rollback()
return fmt.Errorf("failed to prepare table_2 insert: %w", err)
}
defer stmt2.Close()
_, err = stmt2.Exec(t2Data.Thing2, t2Data.Whatever)
if err != nil {
tx.Rollback()
return fmt.Errorf("failed to insert into table_2: %w", err)
}
// 4. 提交事务
if err = tx.Commit(); err != nil {
return fmt.Errorf("failed to commit transaction: %w", err)
}
return nil
}
✅ 关键要点总结：
- ✅
tx.Prepare()是事务内预处理的唯一正确方式；db.Prepare()创建的语句不参与事务控制，且无法跨事务复用（事务结束后自动失效）。 - ✅ 每个
defer stmt.Close()保证资源释放，但注意：tx.Commit()或tx.Rollback()会自动关闭所有由该事务创建的 Stmt，因此defer属于防御性编码，非强制要求。 - ✅ 回滚逻辑需尽早触发：一旦某步失败，立即
tx.Rollback()并返回错误，避免后续无效操作。 - ✅ 推荐使用
fmt.Errorf("...: %w", err)包装错误，保留原始错误链，便于调试与监控。 - ⚠️ 注意：
tx.Rollback()可安全重复调用（幂等），但tx.Commit()后再调用Rollback()会返回sql.ErrTxDone—— 因此务必确保Commit()和Rollback()仅执行一次。
遵循此模式，即可在 Go 中稳健实现符合 ACID 特性的多表事务操作，兼顾安全性、可维护性与性能。
