Sequelize 模型创建回调未同步运行？

Question

我在我的node.js 应用程序中使用Sequelize 和PostgreSQL。我有两个具有一对一关系的表 - Customers 和 Users。

Customers 表中有外键 UserId。所以，我首先插入Users 表，然后然后 插入Customers，最后插入UserId。这是我的控制器代码：

var self = this;

async.each(data, function(row, callback) {
    var userData = {
        name: row.name,
        /** **/
    }
    // self.User is User model
    self.User.create(userData).then(function(user) {
      console.log("[User.create] succeeded");
      /** **/
      // self.Model is Customer model
      self.Model.create(cusData).then(function(customer) {
          console.log("[Customer.create] succeeded");
          /** **/
      }).catch(function(err) {
          throw err;
      }); // EOL self.Model.create
    }).catch(function(err) {
          throw err;
    }); // EOL self.User.create
    callback();
}, function(err){
    if (err) {
        throw err;
    }
}

我正在使用async.each() 同步循环 2 条记录的数组。当我插入两条记录时，控制台输出为：

[User.create] succeeded
[User.create] succeeded
[Customer.create] succeeded
[Customer.create] succeeded

我的预期是：

[User.create] succeeded
[Customer.create] succeeded
[User.create] succeeded    
[Customer.create] succeeded

我认为这可能是异步编程中同步流的问题。我错了什么？我认为我正确地使用了回调。

Answer 1

您正在异步启动两个插入操作，因此您无法保证后续查询的顺序。据您所知，根据锁，您可以获得当前或预期的结果。

要强制排序，将迭代从 within 内部回调向前移动：

  self.Model.create(cusData).then(function(customer) {
      console.log("[Customer.create] succeeded");
      /** move the iterator forward here, using e.g. recursion **/
  })