与承诺的Knex交易

Question

我得到的输出正确，实际上，这两个操作被视为一个事务单元；如果一个失败，那么两个都会失败。

在此代码示例中：我正在进行以下交易

（1）插入（2）更新

我的处理方式是将数据库操作嵌套在.then内。我的问题是该代码是否偶然正确？我是Promise和Knex的新手。

knex.transaction(function(t) {
   knex('foo')
   .transacting(t)
   .insert({id:"asdfk", username:"barry", email:"[e-mail]"})
   .then(function() {
       knex('foo')
       .where('username','=','bob')
       .update({email:"[e-mail]"})
       .then(t.commit, t.rollback)
   })
})
.then(function() {
 // it worked
},
function() {
 // it failed
});

这行得通，但是我觉得我仍然在做错事。寻找评论。

Answer 1

您需要从内部查询中返回一个Promise，以便将外链与此链接在一起。

您还会吞下任何错误，因为您不会重新抛出它们-最好使用.catch()这个原因，因为这样可以使发生的事情更加清晰-这就是正常try- catch语句会发生的情况。

knex.transaction(function(t) {
   return knex('foo')
   .transacting(t)
   .insert({id:"asdfk", username:"barry", email:"[e-mail]"})
   .then(function() {
        return knex('foo')
           .where('username','=','bob')
           .update({email:"[e-mail]"});
   })
   .then(t.commit)
   .catch(function(e) {
        t.rollback();
        throw e;
   })
})
.then(function() {
 // it worked
})
.catch(function(e) {
 // it failed
});

为了更好地理解它，下面是被“模拟”的同步版本：

try {
    var t = knex.transaction();
    try {
        knex("foo")
            .transacting(t)
            .insert({id:"asdfk", username:"barry", email:"[e-mail]"});
        knex("foo")
            .where('username','=','bob')
            .update({email:"[e-mail]"});
        t.commit();
    }
    catch (e) {
        t.rollback();
        // As you can see, if you don't rethrow here
        // the outer catch is never triggered
        throw e;
    }
    // It worked
}
catch (e) {
    //It failed
}