knex事务在nodejs中不起作用

Question

我在环回中使用 knex 进行 mysql 的 DB 操作。 我的任务是使用事务更新 2 表。 当我在一个表中输入新条目时，我想使用该条目的 id 进行第二次查询操作。

但是当事务抛出错误时，如果第二个表条目抛出错误，它不会回滚数据/删除第一个表条目。但在我的情况下，事务总是提交而不是回滚我把我的示例代码放在下面：

addTest : (data) => {
  return new promise(function(resolve, reject) {
    knex.transaction(function(t) {
       return knex('foo')
       .transacting(t)
       .insert({
          foo_id: data.foo_id ? data.foo_id : null,
          foo_name: data.foo_name ? data.foo_name : null,
          date_entered : new Date()
        })
       .then(function() {
          return knex('bar')
          .transacting(t)
          .insert({
            bar_id: data.bar_id ? data.bar_id : null,
            bar_name : data.bar_name ? data.bar_name : null
          })

       })
       .then(t.commit) 
        .catch(function(e) {
          t.rollback();
          throw e;
        })      
    })
    .then(function() {
     // it worked
     // resolve('sucess');
     console.log('success');
    })
    .catch(function(e) {
     // it failed
     console.log('error'+e);
    }); 
  });
}

请给我合适的建议。 谢谢你

Answer 1

您可以避免自己致电t.commit 或t.rollback。见the docs。

让你的代码在事务函数中像这样

return t.insert({}).into('foo').returning('id') .then( function(idArray) { return t.insert({fooId: idArray[0]}).into('bar') })

这让 knex 根据该承诺的结果自行处理提交和回滚。另外，请注意我是如何获得插入的fooId 并将其应用于insertion 的bar 对象。问题中提到了这一点。