Mongoose中如何关联填充MongoDB的嵌套字段？

问题根源 #

你当前的unreadMessages字段存储的是**CustomerMessages文档中messages数组内的子文档ID**，但Schema里将ref指定为"CustomerMessages"（对应整个文档的集合）。Mongoose的populate方法只会去CustomerMessages集合中查找顶级文档的_id，而这些子文档ID并不属于顶级文档，因此返回空数组。

解决方案 #

方案1：调整数据结构（推荐） #

将单个消息抽离为独立的Message模型，这样User的unreadMessages可以直接存储Message文档的_id，使用标准populate即可：

// Message模型定义
const messageSchema = new Schema({
  message: String,
  refrenceName: String,
  customer: { type: Schema.Types.ObjectId, ref: "CustomerMessages" }
});
const Message = mongoose.model("Message", messageSchema);

// 修改User的Schema
const userSchema = new Schema({
  email: { type: String, required: true },
  password: { type: String, required: true },
  name: { type: String, required: true },
  unreadMessages: [{ type: Schema.Types.ObjectId, ref: "Message" }]
});

// 正常使用populate
User.find().populate('unreadMessages').exec((err, users) => {
  // 处理查询结果
});

这种方式符合Mongoose的关联设计，代码简洁且性能更优。

方案2：使用聚合查询（适配现有结构） #

如果无法修改数据结构，可通过MongoDB的聚合管道实现关联查询：

User.aggregate([
  {
    $lookup: {
      from: "customermessages", // 注意集合名要和实际数据库中的一致（通常是模型名复数）
      let: { msgIds: "$unreadMessages" },
      pipeline: [
        { $unwind: "$messages" }, // 展开messages数组
        { $match: { $expr: { $in: ["$messages._id", "$$msgIds"] } } }, // 筛选匹配的子文档
        { $replaceRoot: { newRoot: "$messages" } } // 将子文档作为根文档返回
      ],
      as: "unreadMessages" // 替换原unreadMessages字段
    }
  }
])
.then(users => {
  console.log(users); // 此时unreadMessages已填充为对应的消息对象
})
.catch(err => {
  console.error(err);
});

方案3：手动查询（不推荐，仅小数据量场景） #

遍历用户的unreadMessages，逐个去CustomerMessages中查找匹配的子文档：

User.findById("6260267ce449a8c74cf77ef7")
.then(user => {
  return Promise.all(
    user.unreadMessages.map(msgId => {
      return CustomerMessages.findOne(
        { "messages._id": msgId },
        { "messages.$": 1 } // 只返回匹配的第一个子文档
      );
    })
  )
  .then(results => {
    // 提取嵌套的消息对象
    user.unreadMessages = results.map(doc => doc?.messages[0] || null);
    return user;
  });
})
.then(user => {
  console.log(user.unreadMessages);
})
.catch(err => {
  console.error(err);
});

这种方法需要多次查询数据库，数据量大时性能较差，仅适合临时场景。

内容的提问来源于stack exchange，提问作者Mohamed A.Ismaiel