Sequelizeでのトランザクションでのループと約定の使用

Question

現在、Nodejs、Express、Sequelize（PostgreSQL）アプリケーションを構築中です。トランザクションとループと共に約束を使用する際にいくつかの問題があります。

私はトランザクションでforループを使用する方法を理解しようとしています。私は、メンバーのリストをループし、それぞれのデータベースの新しいユーザーを作成しようとしています。

私は次のコードが間違っていることを知っていますが、私がしようとしていることを示しています。

誰でも正しい方向に向けることができますか？私はそれが取引上のキャッチにフォーマットするための

申し訳ありませんが飛び出すと思うよう

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

Answer 1

あなたは、私は信じていません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); 
    }); 

あなたはsequelize取引内catchする必要が使用する必要があります。モバイル上。

すべての約束は返却（または失敗）するためPromise.allが.thenを実行する前に待機します、と.thenコールバックはあなたがループ構造で構築を使用する必要があり、各配列

Answer 2

からすべての約束のデータになりますブルーバードの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 

Answer 3

まず：https://caolan.github.io/async/docs.html

ので、簡単に：

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