NodeJS同步依赖MySQL查询转异步实现求助

这个问题我之前也碰到过，核心原因就是异步操作的执行顺序——你的forEach循环是同步遍历的，但每个connection.query都是异步回调，还没等所有查询返回结果，后续的console.log就已经执行了，所以数组自然是空的。我们可以用async/await结合Promise来改造代码，确保所有查询完成后再处理结果。

方案一：包装查询为Promise，结合Promise.all等待所有结果 #

首先，我们把回调式的connection.query包装成返回Promise的函数，这样就能用await来等待单个查询的结果；然后用map替代forEach生成所有查询的Promise数组，最后用Promise.all等待所有查询完成。

// 第一步：把connection.query包装成Promise版本
const queryAsync = (sql) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, (error, result) => {
      if (error) {
        reject(error); // 出错时抛出错误
      } else {
        resolve(result); // 成功时返回查询结果
      }
    });
  });
};

// 第二步：用async函数包裹整个逻辑
async function fetchAllPosts() {
  const allPostsWithUsername = [];
  try {
    // 用map生成每个用户查询的Promise，替代同步的forEach
    const queryPromises = namesOfPeopleImFollowing.map(async (username) => {
      // 等待当前用户的查询结果返回
      const userPosts = await queryAsync(`SELECT * FROM user${username}posts`);
      // 把结果存入数组
      allPostsWithUsername.push([{ username }, userPosts]);
    });

    // 等待所有查询都完成后，再执行后续操作
    await Promise.all(queryPromises);

    // 现在数组已经填充完毕，可以正常输出和处理
    console.log(JSON.stringify(allPostsWithUsername));
    // 这里写后续的数据处理逻辑
  } catch (error) {
    // 捕获整个过程中的错误
    console.log("查询出错：", error);
  }
}

// 调用这个异步函数启动查询流程
fetchAllPosts();

方案二：直接通过Promise.all组装结果（更简洁） #

如果不需要分步push数组，我们可以直接在map里返回组装好的数据，然后通过Promise.all的结果直接得到最终数组，代码更简洁：

const queryAsync = (sql) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, (error, result) => {
      if (error) reject(error);
      else resolve(result);
    });
  });
};

async function fetchAllPosts() {
  try {
    // 直接通过Promise.all获取所有组装后的结果数组
    const allPostsWithUsername = await Promise.all(
      namesOfPeopleImFollowing.map(async (username) => {
        const userPosts = await queryAsync(`SELECT * FROM user${username}posts`);
        return [{ username }, userPosts];
      })
    );

    console.log(JSON.stringify(allPostsWithUsername));
    // 后续数据处理逻辑写在这里
  } catch (error) {
    console.log("查询出错：", error);
  }
}

fetchAllPosts();

关键知识点说明 #

• Promise包装：回调式的API无法直接用await，所以我们需要把connection.query转换成Promise形式，让异步操作可以被等待。
• Promise.all：它会接收一个Promise数组，等待所有Promise都成功resolve后，返回一个包含所有结果的数组。这样就能确保所有查询都完成后再执行后续代码。
• async函数：await只能在async标记的函数内部使用，所以我们需要把整个查询逻辑放在async函数里。

内容的提问来源于stack exchange，提问作者Jonathan goel