Mongoose关联查询问题：获取关联Job含指定用户的A集合文档

我有两个MongoDB集合：

• Reports集合（对应代码中的Reports模型），文档结构：

{
  "_id": ObjectId('637cb32dfc225ac6c1f491e9'),
  "job": ObjectId('636cb6f85ad34855281448db'),
  "publicUrl": "22e0c7ef-d58b-44b7-93d1-7989b6f1bb2c",
  "active": true
}

• Job集合，文档结构：

{
  "_id": ObjectId('636cb6f85ad34855281448db'),
  "name": "Intern",
  "users": [
    ObjectId("626a4d697586ac8cac88425a"),
    ObjectId("63c0099f41053d5dc529f1b9")
  ]
}

我需要查询所有active为true，且关联的Job文档中users数组包含指定用户ID的Reports文档，但当前实现代码返回0条记录：

const userId= mongoose.Types.ObjectId(req.user.userId);
const reports= await Reports.find({ active: true,'job.users._id': { $in: [ userId ] }}).populate({ path: 'status', select: 'name position' }) .populate({ path: 'job', select: 'name users' });

请问代码哪里出错了？

错误原因 #

查询条件'job.users._id'完全错误。Reports集合中的job字段只是一个ObjectId引用，指向Job集合的文档，并非嵌入的完整Job文档。MongoDB无法直接在Reports的查询语句中跨集合访问关联Job的users数组，所以这个条件匹配不到任何数据。

解决方案 #

提供两种可行的实现方式：

方式一：分两次查询（逻辑清晰，适配mongoose的populate） #

先查询出所有包含指定用户的Job的ID列表，再用这些ID筛选符合条件的Reports：

const userId = mongoose.Types.ObjectId(req.user.userId);

// 第一步：获取包含该用户的所有Job的ID
const targetJobIds = await Job.find({ users: userId }, '_id')
  .lean()
  .map(job => job._id);

// 第二步：查询active为true且关联Job在目标列表中的Reports
const reports = await Reports.find({ 
  active: true, 
  job: { $in: targetJobIds } 
})
.populate({ path: 'status', select: 'name position' })
.populate({ path: 'job', select: 'name users' });

方式二：使用MongoDB聚合查询（一次完成操作） #

通过$lookup关联两个集合，再进行筛选：

const userId = mongoose.Types.ObjectId(req.user.userId);

const reports = await Reports.aggregate([
  // 先筛选active为true的Reports
  { $match: { active: true } },
  // 关联Job集合，获取对应的Job文档
  {
    $lookup: {
      from: 'jobs', // 注意这里是Job集合的实际名称（mongoose默认是模型名小写复数）
      localField: 'job',
      foreignField: '_id',
      as: 'job'
    }
  },
  // 将$lookup返回的数组转为单个对象
  { $unwind: '$job' },
  // 筛选Job的users数组包含指定用户ID的文档
  { $match: { 'job.users': userId } },
  // 关联status集合（替代populate操作）
  {
    $lookup: {
      from: 'statuses', // status集合的实际名称
      localField: 'status',
      foreignField: '_id',
      as: 'status'
    }
  },
  { $unwind: '$status' },
  // 选择需要返回的字段
  {
    $project: {
      _id: 1,
      publicUrl: 1,
      'job.name': 1,
      'job.users': 1,
      'status.name': 1,
      'status.position': 1
    }
  }
]);

两种方式对比 #

• 方式一逻辑简单易懂，能直接使用mongoose的populate功能，后续维护成本低，适合大部分场景。
• 方式二通过聚合一次性完成所有操作，减少了数据库请求次数，但需要手动处理关联和字段选择，代码复杂度略高。

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