MongoDB 5：从任意层级与结构的文档中提取指定子文档

MongoDB 5的聚合管道完全能搞定这种嵌套层级不固定的文档提取需求，还能轻松支持分页。下面给你详细拆解实现步骤：

核心思路：递归遍历所有嵌套结构 #

因为你的文档层级是随机的，没法用固定路径去匹配，所以得用递归方式遍历所有可能的嵌套数组和对象，找到包含foo: "bar"的子文档，再把它们单独提取出来。

方案一：用$graphLookup（适合固定数组字段名） #

如果你的嵌套子文档都存在名为children的数组里（就像你示例里那样），用$graphLookup最方便，它是MongoDB专门用来做递归查询的操作符：

db.yourCollection.aggregate([
  // 递归遍历所有嵌套的children数组，捞所有含foo:bar的子文档
  {
    $graphLookup: {
      from: "yourCollection",
      startWith: "$children",
      connectFromField: "children",
      connectToField: "_id",
      as: "allMatchedChildren",
      restrictSearchWithMatch: { "foo": "bar" }
    }
  },
  // 合并两种情况：当前文档本身符合条件，或者从嵌套里找到的子文档
  {
    $project: {
      matchedDocs: {
        $concatArrays: [
          // 检查当前文档是不是本身就是目标子文档
          { $cond: [{ $eq: ["$foo", "bar"] }, [$$ROOT], []] },
          "$allMatchedChildren"
        ]
      }
    }
  },
  // 把数组里的每个子文档拆成单独的文档
  { $unwind: "$matchedDocs" },
  // 把目标子文档变成顶级文档（就是你要的输出格式）
  {
    $replaceRoot: {
      newRoot: {
        $mergeObjects: [
          "$matchedDocs",
          // 可选：去掉子文档里的_id，不需要就删掉这行
          { _id: "$$REMOVE" }
        ]
      }
    }
  },
  // 分页操作：跳过前N条，取M条
  { $skip: 0 },
  { $limit: 10 }
])

方案二：用$function（适合完全随机的结构） #

如果你的嵌套数组字段名不固定（比如有时候叫kids，有时候叫items），那$graphLookup就不够灵活了。这时候可以用MongoDB 4.4+支持的$function写个递归函数，遍历文档里所有的对象和数组：

db.yourCollection.aggregate([
  {
    $addFields: {
      matchedDocs: {
        $function: {
          body: function(doc) {
            const result = [];
            // 递归遍历所有嵌套结构
            function traverse(obj) {
              if (typeof obj === 'object' && obj !== null) {
                // 找到目标子文档就加入结果
                if (obj.foo === 'bar') {
                  result.push(obj);
                }
                // 遍历所有字段，递归处理数组和对象
                for (const key in obj) {
                  if (Array.isArray(obj[key])) {
                    obj[key].forEach(item => traverse(item));
                  } else if (typeof obj[key] === 'object') {
                    traverse(obj[key]);
                  }
                }
              }
            }
            traverse(doc);
            return result;
          },
          args: ["$$ROOT"],
          lang: "js"
        }
      }
    }
  },
  { $unwind: "$matchedDocs" },
  { $replaceRoot: { newRoot: "$matchedDocs" } },
  // 分页
  { $skip: 0 },
  { $limit: 10 }
])

关键步骤解释 #

• 递归遍历：不管用$graphLookup还是$function，核心都是把所有嵌套的子文档都捞出来，筛选出符合foo: "bar"的。
• $unwind + $replaceRoot：这两步是把筛选出来的子文档从数组里拆出来，变成你想要的独立文档格式。
• $skip + $limit：标准的分页操作，调整这两个参数就能实现翻页（比如第一页skip:0, limit:10，第二页skip:10, limit:10）。

测试你的示例数据 #

用你给的两个文档测试上面的管道，会精准输出你要的结果：

{ "foo": "bar", "anotherKey": "anotherValue", "whateverA": 111 }
{ "foo": "bar", "animalKey": "legsValue", "whateverB": 222 }

小提示 #

• 如果集合数据量很大，记得给foo字段建索引，这样匹配速度会快很多：db.yourCollection.createIndex({ "foo": 1 })
• 如果子文档里自带_id，可以根据需求决定要不要保留，调整$replaceRoot里的配置就行。

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