MongoDB同集合Lookup聚合返回空数组，需查询关联用户名称

你的聚合查询返回空数组的核心原因是：requests数组的实际存储结构与你预期不符。根据你提供的Schema定义，requests被错误定义为对象数组（每个元素包含ref和type字段），而非直接的ObjectId数组，导致$lookup中的$in无法匹配目标文档的_id。

快速修复：适配现有数据的聚合查询 #

无需修改Schema和历史数据，调整聚合管道先提取requests中的实际用户ID，再执行关联查询：

let requests = await User.aggregate([
    {
        $match: { _id: new mongoose.Types.ObjectId(userId) }
    },
    // 将requests数组转换为纯ObjectId数组（提取每个元素的type字段）
    {
        $addFields: {
            requestIds: { $map: { input: "$requests", as: "req", in: "$$req.type" } }
        }
    },
    {
        $lookup: {
            from: "users",
            let: { requestIds: "$requestIds" },
            pipeline: [
                { $match: { $expr: { $in: ["$_id", "$$requestIds"] } } }
            ],
            as: "requestsData"
        }
    },
    // 可选：移除临时生成的requestIds字段
    { $project: { requestIds: 0 } }
]);

根源修复：修正Schema并迁移数据 #

如果希望彻底解决问题，先修正mongoose Schema的正确写法：

const userSchema = new mongoose.Schema({
    _id: mongoose.Schema.Types.ObjectId,
    name: String,
    requests: [{
        type: mongoose.Schema.Types.ObjectId,
        ref: 'users',
        default: null
    }]
});

然后迁移现有数据，将requests中的对象转换为纯ObjectId：

await User.updateMany(
    {},
    [
        {
            $set: {
                requests: { $map: { input: "$requests", as: "req", in: "$$req.type" } }
            }
        }
    ]
);

迁移完成后，你最初编写的聚合查询就能正常返回结果。

验证问题的小技巧 #

可以先查询目标用户的requests字段，确认实际存储结构：

const targetUser = await User.findById(userId);
console.log(targetUser.requests);

如果输出为[{ ref: 'users', type: ObjectId('xxx') }, ...]，即可确认是Schema定义错误导致的存储结构问题。

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