Knex Transaction with Promises

Question

Sto ottenendo l'output corretto, e infatti, queste due operazioni vengono trattate come una singola unità transazionale; dove se uno fallisce, entrambi falliscono.

In questo esempio di codice: sto facendo una transazione di

(1) Inserire (2) Aggiornamento

Il modo in cui mi avvicino è quello di nido mie operazioni db all'interno del .then. La mia domanda è se questo codice è corretto per caso? Sono nuovo alle promesse e al 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 
}); 

Questo funziona, ma sento che sto ancora facendo qualcosa di sbagliato. Alla ricerca di commenti.

Answer 1

È necessario restituire una promessa dalla query interna affinché la catena esterna sia concatenata con quella.

È inoltre possibile ingoiare gli errori perché non li si rilancia: è preferibile utilizzare .catch() per questo motivo perché rende più chiaro cosa sta succedendo, ovvero cosa succederebbe con la normale istruzione 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 
}); 

Per capire meglio, ecco la versione sincrona che viene "emulato":

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 
}