Transakcja Knex z obietnicami

Question

Otrzymuję prawidłowy wynik, i rzeczywiście, te dwie operacje są traktowane jako pojedyncza jednostka transakcyjna; gdzie, jeśli się nie uda, oba zawodzą.

W tym przykładzie kodu: Ja dokonuję transakcji

(1) wstawić (2) zaktualizuj

Sposób, w jaki podejście to jest gniazdo moje operacje db wewnątrz .Następnie. Moje pytanie brzmi, czy ten kod jest poprawny przez przypadek? Jestem nowy w obietnicach i knex.

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

To działa, ale mam wrażenie, że wciąż coś robię źle. Szukam komentarzy.

Answer 1

Musisz zwrócić obietnicę z wewnętrznego zapytania, aby łańcuch zewnętrzny był połączony z tym łańcuchem.

Połkniesz również wszystkie błędy, ponieważ ich nie powtarzasz - lepiej z tego powodu używać .catch(), ponieważ dzięki temu staje się on bardziej przejrzysty, co się dzieje - tak by się stało z normalną instrukcją try-catch.

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

Aby zrozumieć lepiej, oto synchroniczny wersja, która jest "emulować":

try { 
    var t = knex.transaction(); 
    try { 
     knex("foo") 
      .transacting(t) 
      .insert({id:"asdfk", username:"barry", email:"barry@bar.com"}); 
     knex("foo") 
      .where('username','=','bob') 
      .update({email:"bob@foo.com"}); 
     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 
}