Postgres.js 事务错误处理机制解析

Postgres.js 是一个流行的 Node.js PostgreSQL 客户端库，以其简洁的 API 和高效的性能受到开发者青睐。然而，近期发现该库在特定场景下存在事务错误处理的问题，值得开发者关注。

问题背景

在数据库操作中，事务的正确处理至关重要。Postgres.js 提供了多种事务处理方式，但在某些情况下会出现错误被"吞掉"的现象，导致开发者无法捕获到预期的错误。

问题重现

场景一：SQL 文件执行

当使用 sql.file() 方法执行包含错误 SQL 的脚本文件时，错误不会被抛出。例如，执行以下包含类型错误的 SQL 文件：

BEGIN;
CREATE TABLE user_permissions (permissions TEXT[] NOT NULL);
-- 错误的 VALUES 语法
INSERT INTO user_permissions (permissions) VALUES (('read', 'write', 'delete'));
COMMIT;

场景二：数组形式的事务

使用 sql.begin() 以数组形式定义事务操作时，错误同样会被忽略：

await sql.begin(sql => [
  sql`CREATE TABLE user_permissions (permissions TEXT[] NOT NULL)`,
  sql`INSERT INTO user_permissions (permissions) VALUES (('read', 'write', 'delete'))`
]);

正确的事务处理方式

唯一能正确抛出错误的写法是使用显式的 await：

await sql.begin(async sql => {
  await sql`CREATE TABLE user_permissions (permissions TEXT[] NOT NULL)`;
  await sql`INSERT INTO user_permissions (permissions) VALUES (('read', 'write', 'delete'))`;
});

问题根源

经过分析，问题的根源在于库内部错误地尝试对简单查询使用重试逻辑（routineRetry），而这本应仅适用于预处理语句。这种错误的处理方式干扰了简单查询的协议预期，导致错误被静默处理。

解决方案

该问题已在最新版本中修复。修复后，所有事务形式都能正确抛出错误，包括：

1. SQL 文件执行中的错误
2. 数组形式定义的事务操作
3. 显式 await 的事务操作

最佳实践建议

1. 对于事务操作，推荐使用显式 await 的写法，这能确保错误被正确捕获
2. 升级到最新版本的 Postgres.js 以获得正确的错误处理行为
3. 在生产环境中，建议对所有数据库操作进行错误处理和日志记录

总结

Postgres.js 的事务错误处理问题提醒我们，在使用任何 ORM 或数据库客户端时，都需要充分理解其事务处理机制，并通过测试验证其错误处理行为是否符合预期。特别是在进行关键数据操作时，确保错误能够被正确捕获和处理是保证系统可靠性的重要一环。