MongoDB中利用对象数组高效查询更多对象的最优方案

现有Node.js控制器代码如下：

const Review = require('../models/review')
const Launch = require('../models/launch')

async function getReviewsByUserId (req, res) {
  const { userId } = req.params

  const reviews = await Review.find({ userId }).lean() || []

  return res.status(200).send(reviews.reverse())
}

现在需要通过返回的reviews数组查询对应的Launch对象，当前实现是循环遍历reviews，逐个调用Launch.find({launchId: review.launchId})收集结果，代码如下：

async function getReviewsByUserId (req, res) {
  const { userId } = req.params

  const reviews = await Review.find({ userId }).lean() || []

  let launches = []
  for (review in reviews) {
    let launch = await Launch.find({launchId: review.launchId})
    launches.push(launch)
  }

  return res.status(200).send(launches.reverse())
}

核心疑问： #

这种循环逐个查询的方式是否高效？有没有更快速的实现方案？

这种实现非常不高效，核心问题在于：

• 循环内的await是串行执行的，每一次Launch查询都要等待上一个请求完成才能发起，IO耗时会随reviews数量线性增长，数据量大时性能会急剧下降。
• 重复的数据库请求会额外增加数据库连接开销和服务端压力。

推荐两种高效优化方案：

方案1：并行批量查询（应用层快速改造） #

先提取所有不重复的launchId，再用Promise.all并行发起查询，既减少请求次数，又能并行处理IO：

async function getReviewsByUserId (req, res) {
  const { userId } = req.params

  const reviews = await Review.find({ userId }).lean() || []
  // 提取并去重所有launchId
  const uniqueLaunchIds = [...new Set(reviews.map(review => review.launchId))]
  
  // 并行查询所有对应Launch（用findOne而非find，因为每个launchId对应唯一Launch）
  const launchesMap = new Map(
    (await Promise.all(
      uniqueLaunchIds.map(id => Launch.findOne({ launchId: id }).lean())
    )).map(launch => [launch?.launchId, launch])
  )

  // 将reviews与对应的Launch关联
  const reviewsWithLaunches = reviews.map(review => ({
    ...review,
    launch: launchesMap.get(review.launchId)
  }))

  return res.status(200).send(reviewsWithLaunches.reverse())
}

方案2：数据库层面关联查询（最优性能方案） #

利用MongoDB的$lookup聚合操作，直接在数据库完成关联查询，仅需一次数据库请求，性能最优：

async function getReviewsByUserId (req, res) {
  const { userId } = req.params

  // 聚合管道：匹配用户评论 → 关联Launch集合 → 整理结果
  const reviewsWithLaunches = await Review.aggregate([
    { $match: { userId } },
    {
      $lookup: {
        from: 'launches', // 填写Launch集合的实际名称（通常是模型名小写复数）
        localField: 'launchId', // Review中关联的字段
        foreignField: 'launchId', // Launch中对应的字段
        as: 'launch' // 关联结果的存储字段
      }
    },
    { $unwind: '$launch' }, // 将数组格式的launch转为单个对象
    { $sort: { _id: -1 } }, // 按评论创建时间倒序，替代reverse()
    { $project: { /* 可选：指定需要返回的字段，排除不需要的字段 */ } }
  ])

  return res.status(200).send(reviewsWithLaunches)
}

方案对比： #

• 方案1适合快速改造，代码改动小，无需深入数据库聚合语法。
• 方案2是性能最优解，所有逻辑在数据库层面完成，彻底消除多次请求的开销。

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