javascript - 无法捕获 knex 交易拒绝

Question

我正在使用带有异步/等待语法的 knex 事务，如以下问题所示:Get Knex.js transactions working with ES7 async/await

我的问题是，当事务失败并调用 trx 回调时，knex 日志

Unhandled rejection error: relation "some_table" doesn't exist // Example error which I used for testing

就在记录器记录的相同错误下，所以日志看起来像这样:

// Removed error stacks...

// Error logged by logger
2019-07-14T23:12:29.606Z [error]: error: insert into "tab1" ("col1", "col2", "col3") values ($1, $2, $3) returning "col3" - relation "tab1" does not exist

// Koa.js error from ctx.throw()
InternalServerError: Internal Server Error

// Error when invoking await trx.rollback(e)
Unhandled rejection error: relation "tab1" does not exist

我想要实现的是调用 trx.rollback(e) 而不抛出未处理的拒绝错误。

导致此问题的代码:

async function create (ctx) {
  const trx = await tools.promisify(knex.transaction.bind(knex))
  try {
    let [var1] = await trx('tab1').insert({...}).returning(['x', 'y'])

    // tab2 doesn't exist to trigger an error
    const [var2] = await trx('tab2').insert({...}).returning('z')

    await trx.commit()
  } catch (e) {
    await trx.rollback(e)
    logger.error(e)
    ctx.throw()
  }
}

Answer 1

您使用错误的交易...试试这个:

async function create (ctx) {
  try {
    const res = await knex.transaction(async trx => {
      let [var1] = await trx('tab1').insert({...}).returning(['x', 'y'])
      // tab2 doesn't exist to trigger an error
      const [var2] = await trx('tab2').insert({...}).returning('z')

      return [var1, var2];
    });
  } catch (e) {
    logger.error(e)
    ctx.throw()
  }
}

此外，如果你真的想要，你可以使用最新的 knex 0.18 和 transactionProvider() ...它是从 knex 文档中找到的...但是在您的情况下，第一种方式效果更好，并且比显式提交更加健壮。

你的问题的真正答案是这条线:

trx = await tools.promisify(knex.transaction.bind(knex))

不将任何处理程序绑定(bind)到 knex.transaction(trx => {...}) 返回的 promise 链打电话，然后当你打电话时.rollback(e)该链拒绝并泄漏该异常。