如何在forEach循环执行后返回数组？MongoDB查询返回空数组问题

你遇到的这个问题，核心是异步操作的执行顺序没处理好——你在forEach里调用的projects.findOne()是异步Promise操作，循环会同步跑完，但这些数据库查询还没来得及返回结果，你就尝试返回projectInfo了，所以数组是空的。

最优解决方案：用Promise.all批量处理异步查询 #

推荐用Promise.all来并行处理所有项目ID的查询，这样既能保证所有异步操作完成后再拿到完整结果，还能提升查询效率。修改后的代码如下：

users.post('/retrieveProjects', async function(user, res, next) {
  try {
    // 用await替代回调式的数据库连接
    const db = await MongoClient.connect(url);
    const dbo = db.db("EMWorks");
    
    // 等待用户查询完成
    const userDoc = await dbo.collection("users").findOne({_id: user.body.userid});
    
    if (!userDoc) {
      console.log("No Projects created yet...!");
      return res.send([]);
    }

    // 把每个项目ID转换成对应的查询Promise
    const projectQueries = userDoc.project.map(projectId => 
      dbo.collection("projects").findOne({_id: projectId})
    );

    // 等待所有查询完成，直接得到结果数组
    const projectInfo = await Promise.all(projectQueries);
    console.log(projectInfo);
    
    // 返回结果给客户端
    res.send(projectInfo);
    // 关闭数据库连接
    db.close();
  } catch (err) {
    // 捕获并处理错误
    console.error("Error fetching projects:", err);
    res.status(500).send("Failed to retrieve projects");
  }
});

关键修改点说明 #

• 把路由处理函数标记为async，这样就能在内部用await等待异步操作完成，避免嵌套回调的混乱
• 用await替代原来的.then()链式调用，让代码逻辑更线性、易读
• 用map把用户的每个项目ID转换成一个数据库查询Promise，再通过Promise.all等待所有查询完成，一次性拿到所有结果
• 增加了try/catch块来捕获所有可能的错误（比如数据库连接失败、查询异常等），给客户端返回合理的错误响应
• 确保操作完成后关闭数据库连接，也可以考虑使用MongoDB连接池来优化连接管理

为什么原来的代码会返回空数组？ #

原来的forEach是同步执行的，它会快速遍历完所有项目ID，但里面的findOne()是异步的——每个查询都要等数据库返回结果才会触发.then()里的push操作。当你在循环结束后查看projectInfo时，所有的push都还没执行，所以数组自然是空的。

内容的提问来源于stack exchange，提问作者Swati Dhadekar