pgpromise事务注释t.batch后插入查询仍执行，如何保障事务预期执行？

为什么注释t.batch后查询仍会执行？ #

在pg-promise的事务上下文t中，调用t.none()（或其他查询方法）会立即返回一个已开始执行的Promise——只要调用了这个方法，查询就会发送到数据库执行，和你是否将它传入t.batch无关。你注释掉return t.batch(...)只是没让事务等待所有查询完成，也没让事务统一处理提交/回滚，但单个查询已经触发了。

正确的事务批量处理方式 #

要确保所有查询在事务中按预期执行（要么全部成功提交，要么失败回滚），必须做到两点：

• 将所有查询Promise传入t.batch（并行执行）或t.sequence（顺序执行）
• 从事务回调中返回这个批量操作的Promise，让pg-promise跟踪事务状态

修正后的代码示例：

db.tx((t) => {
  // 用map生成查询Promise数组，同时改用参数化查询避免SQL注入
  const insertQueries = queryInfo.map(info => 
    t.none(`INSERT INTO test (name) VALUES ($1)`, [info.name])
  );
  
  // 返回batch执行结果，事务会等待所有查询完成后提交，任意失败则回滚
  return t.batch(insertQueries);
})
.then(() => {
  console.log("批量插入成功，事务已提交");
})
.catch(err => {
  console.error("批量插入失败，事务已回滚:", err);
});

额外说明 #

• 如果需要查询按顺序执行（比如依赖前一个查询的结果），替换t.batch为t.sequence(insertQueries)
• 事务回调必须返回Promise，否则pg-promise无法判断事务何时完成，可能导致事务泄漏或意外提交
• 永远使用参数化查询（$1占位符），不要直接拼接字符串到SQL语句中，防止SQL注入

内容的提问来源于stack exchange，提问作者insivika