Knex Transaktion mit Promises

Question

Ich bekomme die richtige Ausgabe, und tatsächlich werden diese beiden Operationen als eine einzige Transaktionseinheit behandelt; wo, wenn einer versagt, beide versagen.

In diesem Codebeispiel: i eine Transaktion von

tue

(1) einfügen (2) aktualisiert

So wie ich es Ansatz zu nisten im Inneren des .then meine db ist Operationen. Meine Frage ist, ob dieser Code zufällig ist? Ich bin neu zu Versprechen und 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 
}); 

Das funktioniert, aber ich fühle mich, als würde ich immer noch etwas falsch machen. Auf der Suche nach Kommentaren.

Answer 1

Sie müssen ein Versprechen aus der inneren Abfrage zurückgeben, damit die äußere Kette damit verkettet wird.

Sie schlucken auch alle Fehler, weil Sie sie nicht wiederholen - es ist besser, .catch() aus diesem Grund zu verwenden, weil es klarer macht, was passiert - das ist, was mit normalen try-catch Aussage passieren würde.

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 
}); 

es Um besser zu verstehen, hier ist die synchrone Version, die "emuliert" wird:

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 
}