基于MEAN栈MongoDB3.4：aggregate与$lookup关联ObjectId问题

嘿，我来帮你搞定这个关联查询的问题！首先先理清楚你的Schema结构——看起来你的Follow Schema写到一半中断了，我先帮你补全成符合常见关注关系逻辑的版本（毕竟用ObjectId关联User的话，字段名得语义化一点，原来的username作为ObjectId字段名有点容易混淆）：

完整的Schema定义 #

User Schema（你的原代码，格式化后） #

const mongoose = require('mongoose');

var userSchema = new mongoose.Schema({
  email: { 
    type: String, 
    unique: true, 
    required: true, 
    trim: true 
  },
  username: { 
    type: String, 
    unique: true, 
    required: true, 
    trim: true 
  },
  password: { 
    type: String, 
    required: true 
  }
}, { collection: 'users'} );

module.exports = mongoose.model('User', userSchema);

补全后的Follow Schema #

const mongoose = require('mongoose');

var followSchema = new mongoose.Schema({
  // 存储当前用户的ObjectId，语义更清晰，替换你原来的`username`字段（用ObjectId的话不该叫username）
  userId: { 
    type: mongoose.Schema.Types.ObjectId, 
    ref: 'User',
    required: true
  },
  // 存储关注当前用户的人的ObjectId数组
  followers: [{ 
    type: mongoose.Schema.Types.ObjectId, 
    ref: 'User' 
  }],
  // 存储当前用户关注的人的ObjectId数组
  following: [{ 
    type: mongoose.Schema.Types.ObjectId, 
    ref: 'User' 
  }]
}, { collection: 'follows' });

module.exports = mongoose.model('Follow', followSchema);

核心：用Aggregate + $lookup实现关联查询 #

下面给你两个最常见场景的实现代码，直接就能用：

场景1：查询某个用户的所有关注者详情 #

把followers数组里的ObjectId转换成完整的User文档，同时过滤掉敏感的password字段：

const Follow = require('./models/Follow'); // 替换成你的Follow模型路径
const mongoose = require('mongoose');

// 假设要查询的用户ID是这个字符串，记得转成ObjectId类型
const targetUserId = "60d21b4667d0d8992e610c85";

Follow.aggregate([
  // 第一步：匹配目标用户的关注记录
  { $match: { userId: mongoose.Types.ObjectId(targetUserId) } },
  // 第二步：关联users集合，把followers数组的ObjectId映射为User文档
  {
    $lookup: {
      from: "users", // 必须是MongoDB实际的集合名，和User Schema里的collection一致
      localField: "followers", // Follow集合里存User ObjectId的数组字段
      foreignField: "_id", // User集合的主键
      as: "followersDetails" // 关联后生成的新字段名，存完整的用户详情
    }
  },
  // 第三步：过滤字段，只返回需要的内容，千万不要返回password！
  {
    $project: {
      _id: 0,
      userId: 1,
      followersDetails: {
        _id: 1,
        username: 1,
        email: 1
      }
    }
  }
])
.then(result => {
  console.log("目标用户的关注者详情：", result);
  // 这里可以把result返回给前端
})
.catch(err => {
  console.error("查询失败：", err);
});

场景2：查询某个用户关注的所有人的详情 #

和上面逻辑一致，只是把localField改成following即可：

Follow.aggregate([
  { $match: { userId: mongoose.Types.ObjectId(targetUserId) } },
  {
    $lookup: {
      from: "users",
      localField: "following",
      foreignField: "_id",
      as: "followingDetails"
    }
  },
  {
    $project: {
      _id: 0,
      userId: 1,
      followingDetails: {
        _id: 1,
        username: 1,
        email: 1
      }
    }
  }
])
.then(result => {
  console.log("目标用户关注的人详情：", result);
})
.catch(err => {
  console.error("查询失败：", err);
});

几个关键注意事项 #

• 集合名称要准确：$lookup的from参数必须是MongoDB中实际存在的集合名，不是Mongoose的模型名！比如你的User Schema指定了collection: 'users'，那这里就写"users"，不能写"User"。
• ObjectId类型必须匹配：$match里的userId一定要用mongoose.Types.ObjectId()把字符串转成ObjectId类型，否则MongoDB会匹配不到文档。
• 敏感字段必须过滤：关联User的时候，一定要用$project把password字段排除掉，绝对不能把密码泄露给前端。
• 如果你的Follow Schema确实用username字符串关联：要是你原来的Follow Schema里username存的是用户名字符串（不是ObjectId），那$lookup的localField就写"username"，foreignField写User的"username"字段，但这种方式的查询效率远不如用ObjectId关联，强烈建议改成ObjectId关联。

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