MongoDB聚合查询：用集合文档字段作另一集合查询条件

问题分析 #

你原来的查询出现非预期结果，核心问题有三个：

1. 聚合顺序错误：先执行$lookup再筛选sid，会对collection1所有文档做关联，既低效又可能引入无关结果。
2. $or用法错误：$$search是单个查询对象（比如{"id":{"$in":["a","b","c"]}}），但$or要求传入条件数组，直接传入会导致MongoDB解析错误，最终匹配所有文档。
3. $expr滥用：常规查询操作符（如$in）在$expr中的语法和普通$match不同，不能直接把查询对象塞进$expr。

正确的聚合查询 #

以下查询能精准实现你的需求，支持动态使用collection1中的查询条件匹配collection2：

db.collection1.aggregate([
    // 第一步：先筛选目标sid的查询条件文档，减少后续处理量
    { $match: { sid: "1" } },
    {
        $lookup: {
            from: "collection2",
            let: { search_cond: "$search" },
            pipeline: [
                {
                    $match: {
                        $expr: {
                            // 确保所有查询条件都满足
                            $allElementsTrue: {
                                // 把查询条件对象转换成键值对数组遍历
                                $map: {
                                    input: { $objectToArray: "$$search_cond" },
                                    as: "entry",
                                    in: {
                                        // 处理$in类型的条件
                                        $cond: {
                                            if: { $ne: ["$$entry.v.$in", undefined] },
                                            then: { $in: ["$${entry.k}", "$$entry.v.$in"] },
                                            // 可扩展处理其他操作符（如$gt、$eq等）
                                            else: { $eq: ["$${entry.k}", "$$entry.v"] }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            ],
            as: "matched_docs"
        }
    },
    // 可选：展开匹配结果并转为根文档，返回干净的结果格式
    { $unwind: "$matched_docs" },
    { $replaceRoot: { newRoot: "$matched_docs" } }
])

关键逻辑说明 #

• 先筛后联：先通过$match锁定目标sid的查询条件，避免无效关联。
• 动态解析条件：用$objectToArray把search对象转成键值对数组，再用$map遍历每个条件，针对$in操作符做适配（可根据需求扩展其他操作符）。
• 精准匹配：用$allElementsTrue确保所有查询条件都被满足（多条件$and场景同样适用）。

测试结果 #

• 当sid为"1"时，返回id为a、b的文档；
• 当sid为"2"时，返回id为b、f的文档，完全符合需求。

内容的提问来源于stack exchange，提问作者Vinayak Shantaram Joshi