我找不到一些可以执行以下三项操作的示例：
1)在golang中允许原始sql事务.
2)使用准备好的陈述.
3)回滚查询失败.
我想做这样的事情,但准备好的陈述.
stmt,stmt_err := db.Prepare(`
BEGIN TRANSACTION;
-- Insert record into first table.
INSERT INTO table_1 (
thing_1,whatever)
VALUES($1,$2);
-- Inert record into second table.
INSERT INTO table_2 (
thing_2,whatever)
VALUES($3,$4);
END TRANSACTION;
`)
if stmt_err != nil {
return stmt_err
}
res,res_err := stmt.Exec(
thing_1,whatever,thing_2,whatever)
当我运行它时,我收到此错误：
pq：无法将多个命令插入到预准备语句中
是什么赋予了？是否可以在golang中进行符合ACID的交易？我找不到一个例子.
编辑
没有例子here.
是Go有一个很好的sql
transactions实现.我们用
db.Begin开始交易,如果一切顺利,我们可以用
tx.Commit结束,如果出错,我们可以用
tx.Rollback结束.
type Tx struct { }
Tx is an in-progress database transaction.
A transaction must end with a call to Commit or Rollback.
After a call to Commit or Rollback,all operations on the transaction fail with ErrTxDone.
The statements prepared for a transaction by calling the transaction’s Prepare or Stmt methods are closed by the call to Commit or Rollback.
另请注意,我们使用事务变量tx.Prepare(…)准备查询
您的功能可能如下所示：
func doubleInsert(db *sql.DB) error { tx,err := db.Begin() if err != nil { return err } { stmt,err := tx.Prepare(`INSERT INTO table_1 (thing_1,whatever) VALUES($1,$2);`) if err != nil { tx.Rollback() return err } defer stmt.Close() if _,err := stmt.Exec(thing_1,whatever); err != nil { tx.Rollback() // return an error too,we may want to wrap them return err } } { stmt,err := tx.Prepare(`INSERT INTO table_2 (thing_2,err := stmt.Exec(thing_2,we may want to wrap them return err } } return tx.Commit() }
我有一个完整的例子here
