pg-promise事务中如何根据查询失败位置返回对应错误消息

核心实现逻辑 #

你当前的代码之所以没法定位失败的查询节点，本质是因为事务内每个查询返回的原生Promise在失败时抛出的是数据库层的通用错误，没有绑定和q1/q2/q3节点的对应关系。最直接的解决方式是在每个查询的Promise链上增加独立的错误捕获，把自定义的节点标识、错误消息和原始错误一起重新抛出，不需要在最外层catch时通过复杂匹配识别节点，同时完全保留pg-promise的事务原子性。

改造后的完整代码示例 #

db.tx(t => {
  // 给每个查询独立绑定错误标识
  const q1 = t.none(query1)
    .catch(err => {
      // 不要吞掉原始错误，将自定义标识和错误信息一并抛出
      throw {
        ...err,
        nodeTag: 'q1',
        tipMessage: 'q1 failed'
      }
    });

  const q2 = t.one(query2)
    .catch(err => {
      throw {
        ...err,
        nodeTag: 'q2',
        tipMessage: 'q2 failed'
      }
    });

  const q3 = t.one(query3)
    .catch(err => {
      // 修正原需求笔误，q3节点对应专属错误提示
      throw {
        ...err,
        nodeTag: 'q3',
        tipMessage: 'q3 failed'
      }
    });

  // 原有batch逻辑完全保留
  return t.batch([q1, q2, q3]);
})
  .then(data => {
    // 事务提交成功后的逻辑
    res.json({ error: false, data })
  })
  .catch(error => {
    // 事务回滚已由pg-promise自动完成，直接返回自定义错误提示即可
    res.json({
      error: true,
      message: error.tipMessage || '事务执行未知异常'
    })
  });

关键注意事项 #

• 这种写法完全不破坏事务的原子性：你在每个查询的catch块中是重新抛出了带标识的错误，Promise链始终保持rejected状态，pg-promise检测到事务流程的Promise为rejected时，会自动执行ROLLBACK逻辑，和原生batch的行为完全一致。
• 绝对禁止在单个查询的catch中吞掉错误（比如写return null代替throw），否则batch会将这个查询判定为执行成功，跳过失败逻辑继续执行后续查询，直接导致事务数据不一致。
• 原始数据库错误（比如唯一约束冲突、字段类型不匹配等）需要随自定义标识一起带出，不能只返回前端提示信息，方便后续排查服务端日志。
• 为了减少重复代码，可以简单封装工具函数简化重复的catch逻辑：

  // 通用查询错误绑定工具
  const wrapQueryError = (queryPromise, tipMessage) => {
    return queryPromise.catch(err => {
      throw { ...err, tipMessage }
    })
  }
  
  // 事务内简化写法
  const q1 = wrapQueryError(t.none(query1), 'q1 failed')
  const q2 = wrapQueryError(t.one(query2), 'q2 failed')
  const q3 = wrapQueryError(t.one(query3), 'q3 failed')
  

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