MongoDB聚合仅过滤第二集合条件同时返回第一集合全部文档实现方案

现有集合结构 #

• Books集合存储书籍基础信息，核心字段：BOOK_ID、BOOK_NAME、BOOK_DESC
• Scores集合存储书籍分类对应评分，核心字段：BOOK_ID、BOOK_CATEGORY、BOOK_SCORE

需求逻辑 #

实现左连接查询效果：

1. 保留Books集合全部文档
2. 关联匹配Scores集合中BOOK_CATEGORY="Kids"且BOOK_SCORE="6"的记录
3. 匹配成功的书籍，将对应BOOK_CATEGORY、BOOK_SCORE字段追加到书籍文档根层级；未匹配成功的书籍正常返回，不追加额外字段

现有写法问题 #

你当前编写的$lookup语法没有报错，但存在几个缺陷：

1. 关联匹配到的结果会全部存入临时数组字段SCORES，没有拆解合并到根文档
2. 写法同时使用localField/foreignField和嵌套pipeline仅支持MongoDB 5.0及以上版本，低版本运行会报错
3. 示例数据中BOOK_ID=100的分类值为小写kids，和你写的匹配值大写Kids大小写不一致，默认规则下会匹配失败

可用聚合管道（PyMongo 兼容） #

from pymongo import MongoClient

# 替换为你的MongoDB连接配置
client = MongoClient("mongodb://localhost:27017/")
db = client["your_db_name"]

pipeline = [
    {
        "$lookup": {
            "from": "Scores",
            "let": {"ref_book_id": "$BOOK_ID"},
            "pipeline": [
                {
                    "$match": {
                        "$expr": {"$eq": ["$BOOK_ID", "$$ref_book_id"]},
                        "BOOK_CATEGORY": "Kids",
                        # 如需不区分大小写匹配分类，替换为下面的写法
                        # "BOOK_CATEGORY": {"$regex": "^kids$", "$options": "i"},
                        "BOOK_SCORE": "6"
                    }
                },
                {"$project": {"BOOK_CATEGORY": 1, "BOOK_SCORE": 1, "_id": 0}}
            ],
            "as": "matched_score"
        }
    },
    {
        "$unwind": {
            "path": "$matched_score",
            "preserveNullAndEmptyArrays": True
        }
    },
    {
        "$replaceRoot": {
            "newRoot": {
                "$mergeObjects": [
                    "$$ROOT",
                    "$matched_score",
                    # 把字符串类型的分数转为数字，和期望输出格式一致，不需要可删除
                    {"BOOK_SCORE": {"$toInt": "$matched_score.BOOK_SCORE"}}
                ]
            }
        }
    },
    {
        "$project": {
            "matched_score": 0
        }
    }
]

# 执行查询获取结果
result = list(db.Books.aggregate(pipeline))

关键参数说明 #

• $lookup阶段通过let定义关联变量，在嵌套pipeline中用$expr做关联条件，兼容MongoDB 3.6及以上所有版本
• $unwind阶段必须设置preserveNullAndEmptyArrays: True，否则未匹配到评分的书籍会被过滤，不符合全量返回Books的要求
• $replaceRoot阶段用$mergeObjects把匹配到的评分字段合并到原书籍文档，没有匹配评分的书籍会直接保留原结构
• 最后通过$project删除临时生成的关联数组字段，输出结构和给出的期望示例完全一致

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