Postgresql 捕获事务错误和回滚

Question

我正在使用 pg-promise 来运行我的 SQL 查询。查询本身存储在外部 .sql 文件中。

当我执行事务时，如果发生错误（如预期的那样），Postgres 将中止事务。我遇到的问题是我在事务中止后尝试运行的任何单独查询都没有运行，而是收到以下消息： “当前事务被中止，命令被忽略，直到事务块结束”。如果查询是在 psql 控制台中运行的，我可以通过在查询失败后发出 ROLLBACK 来解决这个问题。我不认为这是一个选项，因为我的应用程序使用的 SQL 位于外部文件中。我也不认为保存点是一种选择，因为如果出现故障，整个事务都应该被丢弃。

如果发生此错误，我将如何回滚 SQL 文件？

这是供参考的 SQL：

BEGIN;

DELETE 
FROM tournament_tossup_values
WHERE tournament_id = $1 AND
NOT EXISTS
(
    SELECT id
    FROM tournament_match
    WHERE tournament_id = $1
);

UPDATE tournament
SET bonus_point_value = $5, parts_per_bonus = $6
WHERE id = $1 AND NOT EXISTS (
    SELECT id 
    FROM tournament_match
    WHERE tournament_id = $1
)
RETURNING bonus_point_value, parts_per_bonus; <-- Any subsequent accesses to the database by the application fail if this transaction fails

COMMIT;  <-- I want to rollback everything if this fails

提前谢谢你！

Answer 1

在外部 SQL 文件中实现事务时，您需要为COMMIT 和ROLLBACK 提供所有适当的处理。如果您不这样做，事务状态可能会在您的服务器端代码中变得不可预测，并导致您遇到的错误类型。

这可能有点棘手，说起来容易做起来难。这就是为什么最好的解决方案是根本不这样做。

您已经在使用的模块pg-promise 通过tx 方法为事务提供可靠的处理，这是您应该使用的。

来自tx 方法文档：

将回调函数作为事务执行 (...)

事务将常规任务包装到附加查询中：

它在调用回调函数之前执行BEGIN

它执行COMMIT，如果回调没有抛出任何错误或返回一个 被拒绝的承诺，它执行ROLLBACK，如果回调确实抛出了一个 错误或返回被拒绝的承诺

它执行相应的 SAVEPOINT 递归调用方法时的命令。

为此，将您的 SQL 文件拆分为两个文件 - 一个包含您的 DELETE 操作，另一个包含您的 UPDATE 操作，然后在事务中将它们作为两个查询执行：

await db.tx(async t => {
    await t.none('DELETE...');
    await t.any('UPDATE...');
});