NodeJS - 循环内的承诺

Question

我今天的问题与循环内的承诺有关。在这里，我将放置我的代码，如您所见，它做了一些事情。首先，它在我的所有事件中循环，并将在其中找到的日期拆分为 3 个字段，以将其插入 SQL 数据库。

我总共填写了两张表，一张是日期，一张是实际事件。问题是，当这段代码被执行时，它会一直循环到最后，一次完成所有日期分配，然后开始释放承诺。这使得我的函数插入 x 次相同的日期和事件（其中 x 是我的事件数组的长度）。

现在，为什么会发生这种情况？我为这个问题研究并实现了承诺，但它似乎仍然存在。有人可以向我解释我做错了什么吗？另外，你觉得这段代码有点像“末日金字塔”吗？提前非常感谢！

events.forEach(function (event) {
        // Simple date formatting
        dayFormatted = event.day.split("_");
        year = dayFormatted[0];
        month = dayFormatted[1];
        day = dayFormatted[2];

        // Check if the row already exists ...
        SQLCheckTableRow(`day`, year.toString(), month.toString(), day.toString()).then(function (skip) {
            // ... if not it skips all this part
            if (!skip) {
                // Create, if it doesn't exist already, a date table that is going to be connected to all the events and fill it
                SQLFillTable(`date, `null, "${year}" , "${month}" , "${day}", null`).then(function () {
                    let values = []
                    event.ons.forEach(function (on) {
                        on.states.forEach(function (event) {
                            values = [];
                            values.push(Object.keys(event.data).map(function (key) {
                                return event.data[key];
                            }));

                            SQLFillTable(`event`, values).then();
                        })
                    })
                })
            }
        })
    })

Answer 1

当您在 forEach 循环中进行异步调用时，它不会等到调用完成。如果您想一个接一个地触发异步调用，则应使用“for of”循环。如果你想并行运行它们，你可以将 Promise 推送到一个数组中，然后你可以使用 Promise.all(arrayOfPromises).then((result) => {}) 获取 Promise 调用的结果。这里的结果将是异步调用的数组，与 promise 数组的顺序相同。

如果您想让您的代码更易于阅读，而不是陷入末日金字塔，那么请习惯使用 async..await。在这里，我使用 for..of 循环稍微重构了您的代码。正如我上面所说，如果你想并行运行异步调用，请使用 Promise.all。

async function queryTable() {
  for (let event of events) {
    // Simple date formatting
    let dayFormatted = event.day.split("_");
    let year = dayFormatted[0];
    let month = dayFormatted[1];
    let day = dayFormatted[2];

    try{
      let skip = await SQLCheckTableRow(`day`, year.toString(), month.toString(), day.toString());
      if (!skip) {
        // Create, if it doesn't exist already, a date table that is going to be connected to all the events and fill it
        await SQLFillTable('date', null, year, month , day, null);

        for (let on of event.ons) {
          const values = [];
          values.push(Object.keys(on.data).map(key => on.data[key]));

          await SQLFillTable('event', values);
        }
      }
    } catch(err) {
      console.error(err);
    }
  }
}