Promise模式-使用Promise.all()

Question

我有一系列函数，用于获取一些JSON数据，然后将数据插入数据库。我想等待所有插入完成，所以我尝试使用Promise.all()。我知道Promise.all()需要一个promise数组（或可迭代的）。

这是我的链：

fetchBody().then(parseBody).then(prepareInserts).then(insertAll).then(function() {
    console.log('done')
}); // Error handling and more stuff here

我的代码挂在prepareInserts函数上：

// Returns an array of promises, which will be iterated over in Promise.all();
const prepareInserts = function (data) {
    return new Promise(function (resolve, reject) {
        const promises = data.map(function (d) {
            return new Promise(function (resolve, reject) {
                connection.query(queryString, [d.a, d.b, d.c, d.d], function (error) {
                    if (error) {
                        reject(error);
                        return;
                    }
                    resolve();
                });
            });
        });
        resolve(promises);
    });
};

---

我想我对应该如何布置prepareInserts函数有一个根本的误解；查询正在那里执行，这不是我想要的。我想把它们插入链中的最后一个函数：

const insertAll = function (promises) {
    return Promise.all(promises);
};

Answer 1

我想这就是你想要的：

const doInserts = data => {
  return Promise.all(data.map(d => 
     new Promise((resolve, reject) => {
       connection.query(queryString, [d.a, d.b, d.c, d.d], error => {
         if (error) {
           reject(error);
           return;
         }
         resolve(/* to what?? */);
       });
     }));
  });
};
fetchBody().then(parseBody).then(doInserts).then(function() {
  console.log('done')
});

您返回一个Promise.all()承诺，该承诺在所有内部承诺都被解析时解析（没有值？）。每个内部promise都是通过将一个数据项（来自data）映射到promise来创建的，该promise将根据查询结果进行解析或拒绝。

如果您可以在该代码之外promisifyconnection.query，则会产生更干净的结果，直接映射到"promisifiedQuery"。