Node.js + Express API中async/await在循环内未等待数据库查询的问题及正确实现方式问询

这个问题我之前开发Node.js API时也踩过坑！核心原因是**forEach不会等待你传入的异步回调函数执行完成**——它只是遍历数组，把每个异步任务启动后就立刻继续执行后续代码，完全不管这些任务什么时候结束。所以你的res.json(users)会在所有订单查询完成前就发送给客户端，导致部分用户的orders字段缺失或为空。

下面给你两种靠谱的解决方案，根据你的需求选择：

方案一：使用for...of循环（顺序执行） #

这种方式最直观，适合需要按顺序处理每个用户的场景（比如依赖前一个用户的处理结果），它会等待每次循环内的异步操作完成后，再进入下一次循环：

app.get("/users-with-orders", async (req, res) => {
  try {
    const users = await getUsers(); // 返回用户数组
    // 用for...of替代forEach，确保每个异步操作完成后再处理下一个用户
    for (const user of users) {
      const orders = await getOrdersByUserId(user.id);
      user.orders = orders;
    }
    // 所有订单查询完成后才发送响应
    res.json(users);
  } catch (err) {
    res.status(500).json({ error: "Something went wrong" });
  }
});

方案二：使用Promise.all并行执行（效率更高） #

如果不需要顺序处理用户，推荐用这种方式——它会同时发起所有订单查询请求，等待全部完成后再继续执行，能大幅提升接口响应速度：

app.get("/users-with-orders", async (req, res) => {
  try {
    const users = await getUsers();
    // 把每个用户的订单查询转换成Promise，并存入数组
    const userPromises = users.map(async (user) => {
      user.orders = await getOrdersByUserId(user.id);
      return user;
    });
    // 等待所有Promise执行完成
    await Promise.all(userPromises);
    // 所有数据准备完毕，发送响应
    res.json(users);
  } catch (err) {
    res.status(500).json({ error: "Something went wrong" });
  }
});

注意事项 #

• 如果你的数据库对并发查询有数量限制（比如连接池大小有限），并行太多请求可能会触发错误，这时候可以考虑分批处理或者调整方案一的顺序执行。
• 两种方案都要确保getUsers()和getOrdersByUserId()返回的Promise能正确resolve/reject，否则try/catch能捕获到错误并返回500响应。

内容的提问来源于stack exchange，提问作者Ehan Siddique