MongoDB聚合中用$set/$setField构造DBRef无法匹配lookup问题

问题描述 #

尝试在MongoDB聚合管道中构造DBRef用于后续$lookup操作匹配目标文档，但执行后返回空结果集。若将lookup中的$$dbref替换为聚合外手动构造的DBRef，则能正常匹配。原聚合代码如下：

db.getCollection("something").aggregate([
    // 构建DBRef
    {
        $set: {
            dbref: {},
        }
    },
    {
        $set: {
            dbref: {
                $setField: {
                    input: "$dbref",
                    field: {
                        $literal: "$ref",
                    },
                    value: "ports"
                }
            },
        }
    },
    {
        $set: {
            dbref: {
                $setField: {
                    input: "$dbref",
                    field: "cls",
                    value: "Port"
                }
            },
        }
    },
    {
        $set: {
            dbref: {
                $setField: {
                    input: "$dbref",
                    field: {
                        $literal: "$id",
                    },
                    value: "$_id"
                }
            },
        }
    },
    // 使用DBRef匹配包含DBRef列表的ancestorIds字段
    {
        $lookup: {
            from: "tags",
            "let": {
                dbref: "$dbref",
            },
            pipeline: [
                {
                    $match: {
                        ancestorIds: "$$dbref",
                    }
                },
                {
                    $limit: 1,
                }
            ],
            as: "__tags",
        }
    },
    {
        $unwind: "$__tags",
    },
])

错误原因 #

核心问题是DBRef字段名构造错误：

• 使用$literal: "$ref"和$literal: "$id"会将字段名设置为字符串"$ref"和"$id"，但MongoDB的标准DBRef要求字段名为特殊标识$ref、$id（不是带引号的字符串键）。
• 你当前构造的dbref对象结构与tags集合中ancestorIds里的标准DBRef结构不匹配，导致$match无法命中目标文档。

修正方案 #

直接在$set中一步构造符合标准的DBRef对象，无需多次调用$setField：

db.getCollection("something").aggregate([
    // 一步构造正确的DBRef对象
    {
        $set: {
            dbref: {
                $ref: "ports",
                cls: "Port",
                $id: "$_id"
            }
        }
    },
    // 使用DBRef匹配包含DBRef列表的ancestorIds字段
    {
        $lookup: {
            from: "tags",
            let: {
                dbref: "$dbref",
            },
            pipeline: [
                {
                    $match: {
                        ancestorIds: "$$dbref",
                    }
                },
                {
                    $limit: 1,
                }
            ],
            as: "__tags",
        }
    },
    {
        $unwind: "$__tags",
    },
])

补充说明 #

• 聚合管道会自动识别$ref、$id这类MongoDB特殊字段名，无需额外转义，直接构造对象即可生成标准DBRef。
• 若坚持使用$setField方式，需去掉$literal，直接指定字段名（不推荐，多步骤冗余）：

{
    $set: {
        dbref: {
            $setField: {
                input: {},
                field: "$ref",
                value: "ports"
            },
            $setField: {
                input: "$$CURRENT",
                field: "$id",
                value: "$_id"
            },
            cls: "Port"
        }
    }
}

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