Express+MongoDB开发中无法通过关联表ExampleProduct筛选Product数据

你的代码存在三个核心问题：

• Mongoose查询同时用了回调和async/await两种异步处理方式，逻辑混乱
• Promise的resolve放在了循环内的Product查询回调中，第一次Product查询完成就直接触发resolve，后续查询还没执行就已经返回了结果，所以数组只有一个元素
• forEach不支持等待异步操作执行完成，就算给forEach回调加async标记，外层逻辑也不会等所有循环内的异步操作结束

最优解决方案（使用populate关联查询） #

这是MongoDB生态下处理关联字段的标准方案，不需要自己循环查询，性能和可维护性都更好。
首先需要确认你ExampleProduct的Schema中productId字段配置了ref关联Product模型，示例配置如下：

const exampleProductSchema = new mongoose.Schema({
  // 其他字段省略
  productId: {
    type: mongoose.Schema.Types.ObjectId,
    ref: 'Product' // 和你定义Product模型时的命名保持一致
  }
})

配置完成后只需简单查询就能拿到所有关联的Product数据：

async function getRelatedProducts() {
  // 查询所有ExampleProduct并填充关联的Product数据
  const exampleProductList = await ExampleProduct.find().populate('productId')
  // 提取Product数据，同时过滤掉productId无效的空数据
  return exampleProductList.map(item => item.productId).filter(Boolean)
}

手动循环查询的修正方案 #

如果你确实需要手动处理查询逻辑，可以用Promise.all等待所有异步查询完成，修正后的代码如下：

async function getRelatedProducts() {
  // 先查询所有ExampleProduct数据
  const exampleProductList = await ExampleProduct.find()
  // 生成所有Product查询的Promise数组
  const productQueryTasks = exampleProductList.map(item => Product.findById(item.productId))
  // 等待所有查询执行完成
  const productList = await Promise.all(productQueryTasks)
  // 过滤无效空数据后返回
  return productList.filter(Boolean)
}

注意事项 #

• Mongoose的查询方法不传回调时默认返回Promise，可以直接用await获取结果，不需要自己再包裹一层Promise，也不需要混写回调逻辑
• Promise的状态是不可逆的，一旦resolve就不会再更新结果，绝对不要把resolve放在循环逻辑里
• 处理多个并行异步任务时优先使用Promise.all，不要用forEach处理异步逻辑

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