Mongoose跨关联文档查询实现：如何按关联字段条件查询学生数据

Mongoose 中的关联字段默认仅存储关联文档的 ObjectId，没有嵌入完整文档结构，所以不能直接通过嵌套属性语法查询关联文档的字段，可通过分步查询或聚合管道$lookup关联两种方式实现需求，以下是对应查询的具体实现：

前置说明 #

注意你给出的 ChannelSchema 中存储渠道名称的字段是 title 不是 name，以下代码均基于你定义的Schema字段编写。

1. 查询渠道名称为 channelName 的学生 #

方法1：分步查询（适合简单关联场景）

// 第一步：查询符合条件的渠道ID列表
const targetChannels = await Channels.find({ title: 'channelName' }).select('_id');
const channelIds = targetChannels.map(item => item._id);
// 第二步：查询关联了对应渠道的学生
const students = await Students.find({ channel: { $in: channelIds } });

方法2：聚合管道关联查询（适合复杂场景，效率更高）

const students = await Students.aggregate([
  // 关联渠道集合
  {
    $lookup: {
      from: 'channels', // MongoDB中实际存储的集合名，默认是模型名小写复数
      localField: 'channel',
      foreignField: '_id',
      as: 'channelInfo'
    }
  },
  // 展开关联返回的数组
  { $unwind: '$channelInfo' },
  // 过滤符合渠道名称条件的记录
  { $match: { 'channelInfo.title': 'channelName' } }
]);

2. 查询所属部门主管姓名为 directorName 的学生 #

属于两层关联场景，推荐用聚合管道实现：

const students = await Students.aggregate([
  // 第一层关联：关联部门集合
  {
    $lookup: {
      from: 'departments',
      localField: 'department',
      foreignField: '_id',
      as: 'deptInfo'
    }
  },
  { $unwind: '$deptInfo' },
  // 第二层关联：关联员工集合查询主管信息
  {
    $lookup: {
      from: 'employees',
      localField: 'deptInfo.director',
      foreignField: '_id',
      as: 'directorInfo'
    }
  },
  { $unwind: '$directorInfo' },
  // 过滤主管姓名符合条件的记录
  { $match: { 'directorInfo.name': 'directorName' } }
]);

如果用分步查询需要三次查询，代码如下：

// 1.查符合条件的主管ID
const targetDirectors = await Employees.find({ name: 'directorName' }).select('_id');
const directorIds = targetDirectors.map(item => item._id);
// 2.查对应主管管辖的部门ID
const targetDepts = await Departments.find({ director: { $in: directorIds } }).select('_id');
const deptIds = targetDepts.map(item => item._id);
// 3.查对应部门下的学生
const students = await Students.find({ department: { $in: deptIds } });

3. 查询所属部门联系邮箱为 emailDirector 的学生 #

部门的contact是嵌入式子文档，不需要二次关联，只要先查符合条件的部门ID再查学生即可：

// 分步查询实现
const targetDepts = await Departments.find({ 'contact.email': 'emailDirector' }).select('_id');
const deptIds = targetDepts.map(item => item._id);
const students = await Students.find({ department: { $in: deptIds } });

聚合实现：

const students = await Students.aggregate([
  {
    $lookup: {
      from: 'departments',
      localField: 'department',
      foreignField: '_id',
      as: 'deptInfo'
    }
  },
  { $unwind: '$deptInfo' },
  { $match: { 'deptInfo.contact.email': 'emailDirector' } }
]);

注意事项 #

• $lookup的from参数要和MongoDB中实际存储的集合名一致，如果自定义了集合名需要替换为对应值
• 如果关联字段可能为空，$unwind可以加{ preserveNullAndEmptyArrays: true }参数避免过滤掉关联为空的记录
• 小数据量场景也可以用populate+match实现，但populate是先查主表再关联过滤，大数据量下效率低于聚合管道。

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