Knex执行transaction事务时如何定位具体失败的查询语句

问题根因说明 #

你当前的事务代码将两条插入语句放在同一个try块中捕获错误，因此无法直接区分错误触发的具体位置。另外现有代码存在隐藏问题：knex.transaction传入的异步回调如果未抛出错误而是直接return值，会触发事务提交，你现在catch里直接return error会导致即使执行失败也不会回滚，需要先修正这个逻辑。

你遇到的22P02是PostgreSQL返回的UUID格式非法报错，结合以下方案即可判断是哪条插入语句中的UUID字段不符合格式要求。

解决方案 #

方案1：给每条查询套独立错误捕获，附加自定义标识 #

给每个insert语句单独加try/catch，捕获到错误后给错误对象附加自定义的执行步骤标识，再统一抛出触发事务回滚：

const test = await client.transaction(async (trx) => {
  // 第一条插入：单条记录到table
  try {
    await trx<any>('schema.table')
      .insert({
        id: answers.myId,
        addition: 'some text',
      });
  } catch (error) {
    // 附加自定义标识，说明是第一条插入失败
    error.failStep = 'insert_table1'
    error.failMessage = '主表记录插入失败'
    throw error
  }

  // 处理数组数据
  const insertTable2Data = answers.answers.map((answer) => ({
    id: answer.id,
    my_id: answers.myId,
    offered_answer_id: answer.offered_answer_id,
    value: answer.value !== '' ? answer.value : null,
  }));

  // 第二条插入：数组到table2
  try {
    await trx<any>('schema.table2').insert(insertTable2Data);
  } catch (error) {
    error.failStep = 'insert_table2'
    error.failMessage = '子表答案批量插入失败'
    throw error
  }
});

之后在事务外层的catch逻辑中，就可以通过error.failStep判断是哪一步出错，返回对应的前端友好提示。

方案2：封装通用插入工具，附加查询详情到错误 #

如果需要更详细的调试信息，可以封装通用插入函数，自动将执行的目标表、生成的SQL等信息附加到错误对象中，适合复杂查询的故障排查：

async function insertWithErrorLog(trx, table, data) {
  try {
    return await trx(table).insert(data)
  } catch (err) {
    // 附加执行的SQL、绑定参数、目标表信息到错误对象
    err.executedSql = trx(table).insert(data).toSQL().toNative()
    err.targetTable = table
    throw err
  }
}

// 事务内调用
const test = await client.transaction(async (trx) => {
  await insertWithErrorLog(trx, 'schema.table', {
    id: answers.myId,
    addition: 'some text',
  })
  const insertTable2Data = answers.answers.map(answer => ({
    id: answer.id,
    my_id: answers.myId,
    offered_answer_id: answer.offered_answer_id,
    value: answer.value !== '' ? answer.value : null,
  }))
  await insertWithErrorLog(trx, 'schema.table2', insertTable2Data)
})

Lambda架构适配提示 #

Lambda环境下建议把附加的自定义错误字段打印到运行日志中，方便后续排查线上问题；返回前端响应时只返回failMessage里的友好提示即可，不要泄露数据库表结构、SQL等敏感信息。

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