Die Verwendung von Schleifen und verspricht in Transaktionen in Sequelize

Ich bin derzeit am Aufbau eines Nodejs, Express, Sequelize (w. PostgreSQL) app, und haben, laufen Sie in ein paar Probleme mit mit verspricht zusammen mit den Transaktionen und Schleifen.

Ich versuche herauszufinden, wie Sie mit der for-Schleifen in einer Transaktion. Ich versuche eine Schleife durch eine Liste der Mitglieder und erstellen Sie einen neuen Benutzer in der Datenbank für jeden von Ihnen.

Ich weiß, der folgende code ist falsch, aber es zeigt, was ich zu tun versuche.

Kann jemand mich in die richtige Richtung?

        var members = req.body.members;
        models.sequelize.transaction(function (t) {
            for (var i = 0; i < members.length; i++) {
                return models.User.create({'firstname':members[i], 'email':members[i], 'pending':true}, {transaction: t}).then(function(user) {
                    return user.addInvitations([group], {transaction: t}).then(function(){}).catch(function(err){return next(err);});
                })
            };
        }).then(function (result) {
            console.log("YAY");
        }).catch(function (err) {
            console.log("NO!!!");
            return next(err);
        });
InformationsquelleAutor ReturnToZero | 2016-02-29
  1. 29

    Sollten Sie eine Promise.all

        var members = req.body.members;
    models.sequelize.transaction(function (t) {
        var promises = []
        for (var i = 0; i < members.length; i++) {
            var newPromise = models.User.create({'firstname':members[i], 'email':members[i], 'pending':true}, {transaction: t});
           promises.push(newPromise);
        };
        return Promise.all(promises).then(function(users) {
            var userPromises = [];
            for (var i = 0; i < users.length; i++) {
                userPromises.push(users[i].addInvitations([group], {transaction: t});
            }
            return Promise.all(userPromises);
        });
    }).then(function (result) {
        console.log("YAY");
    }).catch(function (err) {
        console.log("NO!!!");
        return next(err);
    });

    Ich glaube nicht, dass Sie brauchen, um catch innerhalb sequelize Transaktionen, wie ich denke, es springt in den catch auf die Transaktion

    Sorry für die Formatierung. Auf mobile.

    Versprechen.alle warten darauf, dass alle Versprechungen zur Rückkehr (oder nicht) vor dem ausführen des .dann, und das .then callback werden alle Versprechen, Daten von jedem array

    • Danke für die Antwort, aber ich bekomme eine Fehlermeldung sagt mir, dass ich brauchen, um wieder ein Versprechen an die Kette an der Transaktion. Versucht, indem Sie "return" vor jedem Versprechen.alle, aber dann bekomme ich "Unbehandelte Ablehnung commit aufgerufen wurde bei dieser Transaktion(fc7be023-1980-455e-9934-7816420daa2b), können Sie nicht mehr nutzen",
    • Ja, es fehlt ein zurück-und nichts ist jemals geschoben, um userPromises.
    • vielen Dank, ich habe diese auf mobile gestern und bekam nie eine chance, wieder zu kommen und überprüfen Sie es über ich werde aktualisieren, wenn ich kann
    InformationsquelleAutor Datsik
  2. 5

    Müssen Sie mit der eingebauten Schleifen-Konstrukten von bluebird, die Schiffe mit sequelize:

    var members = req.body.members;
models.sequelize.transaction(t => 
  Promise.map(members, m => //create all users
    models.User.create({firstname: m, email: m, 'pending':true}, {transaction: t})
  ).map(user => //then for each user add the invitation
     user.addInvitations([group], {transaction: t}) //add invitations
)).nodeify(err); //convert to node err-back syntax for express
    • Auch arbeiten und sehr eleganten code. Konnte nicht die .nodeify(err); zu funktionieren aber. Es sagt err nicht definiert. Nicht benutzt haben nodeify vor, also ich bin wahrscheinlich etwas fehlt.
    • Sollte nodeify(weiter) - sorry
    InformationsquelleAutor Benjamin Gruenbaum
  3. 1

    Je nach Implementierung der Node.js dies kann helfen. Ich habe das gleiche setup mit express, POSTGRES und sequelize.

    Persönlich würde ich es vorziehen, die async/await (ES6) Umsetzung und dann/fangen, da es leichter zu Lesen ist. Auch die Erstellung einer Funktion, die aufgerufen werden können, extern verbessert die Wiederverwendbarkeit.

    async function createMemeber(req) {
let members = req.body.members;
  for (var i = 0; i < members.length; i++) {
    //Must be defined inside loop but outside the try to reset for each new member;
    let transaction = models.sequelize.transaction();
    try { 
      //Start transaction block.
      let user = await models.User.create({'firstname':members[i],  'email':members[i], 'pending':true}, {transaction});
      await user.addInvitations([group], {transaction}));

      //if successful commit the record. Else in the catch block rollback the record.
      transaction.commit();
      //End transaction block.
      return user;
    } catch (error) { 
      console.log("An unexpected error occurred creating user record: ", error);
      transaction.rollback();
      //Throw the error back to the caller and handle it there. i.e. the called express route.
      throw error;
    }
  }
}
    InformationsquelleAutor Ryan
  4. 0

    Erste: https://caolan.github.io/async/docs.html

    So leicht:

    //requiring...
const async = require('async');

//exports...
createAllAsync: (array, transaction) => {
  return new Promise((resolve, reject) => {
    var results = [];
    async.forEachOf(array, (elem, index, callback) => {
      results.push(models.Model.create(elem, {transaction}));
      callback();
    }, err => {
      if (err) {
        reject(err);
      }
      else {
        resolve(results);
      }
    });
  });
}
    InformationsquelleAutor Eri Jonhson
Schreibe einen Kommentar