在前面的分享中,有讲解 “详解MongoDB中的多表关联查询($lookup)” 一节,其内容涵盖了常见的集合管理的需求。我们知道文档的选择都是通过$match进行匹配刷选。但这是文档间的匹配筛选,并没有对单个新生成的文档进行内嵌子文档进行筛选。
那么什么是$lookup后新文档的内嵌子文档呢?
假设有以下2个集合,一个是商品库存集合 inventory,存储的测试数据 如下:
db.inventory.insert([ { "_id" : 1, "sku" : "almonds", product: "product 1", "instock" : 120 }, { "_id" : 2, "sku" : "bread1", product: "product 2", "instock" : 80 }, { "_id" : 3, "sku" : "bread2", product: "product 2", "instock" : 80 }, { "_id" : 4, "sku" : "pecans1", product: "product 4", "instock" : 70 }, { "_id" : 5, "sku" : "pecans2", product: "product 4", "instock" : 70 }, ])
一个是商品对应的原料集合product,存储的测试数据,如下。
db.product.insert([ { "_id" : 1, product: "product 1", description: "金玉满堂1" }, { "_id" : 2, product: "product 2", description: "招财进宝"}, { "_id" : 3, product: "product 4", description: "杨柳依依"}, ])
两个集合都包含有product 字段,如果 需求是按原料名称统计每个原料对应的商品情况。
可以根据字段product进行集合关联,并且product集合的文档与inventory 集合的文档是 一对多 的关系。
执行关联脚本查询的脚本如下:
db.product.aggregate([ { $lookup: { from: "inventory", localField: "product", foreignField: "product", as: "inventory_docs" } } ])
新生成的聚合集合的文档如下:
/* 1 */ { "_id" : 1, "product" : "product 1", "description" : "金玉满堂1", "inventory_docs" : [ { "_id" : 1, "sku" : "almonds", "product" : "product 1", "instock" : 120, "state" : "OK" } ] }, /* 2 */ { "_id" : 2, "product" : "product 2", "description" : "招财进宝", "inventory_docs" : [ { "_id" : 2, "sku" : "bread1", "product" : "product 2", "instock" : 80, "state" : "OK" }, { "_id" : 3, "sku" : "bread2", "product" : "product 2", "instock" : 80, "state" : "Simple" } ] }, /* 3 */ { "_id" : 3, "product" : "product 4", "description" : "杨柳依依", "inventory_docs" : [ { "_id" : 4, "sku" : "pecans1", "product" : "product 4", "instock" : 70, "state" : "OK" }, { "_id" : 5, "sku" : "pecans2", "product" : "product 4", "instock" : 70, "state" : "Simple" } ] }
从返回结果可以看出,
(1) 返回的文档数量和.aggreate的集合文档数量一样(即外面的那个集合,而不是新字段的From的那个集合)。
(2)关联的主要功能是将每个输入待处理的文档,经过$lookup 阶段的处理,输出的新文档中会包含一个新生成的数组列(户名可根据需要命名新key的名字 )。数组列存放的数据 是 来自 被Join 集合的适配文档,如果没有,集合为空(即 为[ ])。
注意新的字段的类型是数组的形式,一对多的时候,新字段就是就是明显的内嵌子文档。
我们看到新文档的字段 inventory_docs ,它由两个 内嵌 子文档组成,
"inventory_docs" : [ { "_id" : 4, "sku" : "pecans1", "product" : "product 4", "instock" : 70, "state" : "OK" }, { "_id" : 5, "sku" : "pecans2", "product" : "product 4", "instock" : 70, "state" : "Simple" } ]
那么如何根据要求筛选符合要求的子文档呢?$match是不可以的,这时候可以通过$filter。
代码如下:
db.product.aggregate([ { $lookup: { from: "inventory", localField: "product", foreignField: "product", as: "inventory_docs" } } , { $project: { inventory_docs: { $filter: { input: "$inventory_docs", as: "item", cond: { $eq: [ "$$item.state", "OK" ] } } } } } ])
结果显示如下:
/* 1 */ { "_id" : 1, "inventory_docs" : [ { "_id" : 1, "sku" : "almonds", "product" : "product 1", "instock" : 120, "state" : "OK" } ] }, /* 2 */ { "_id" : 2, "inventory_docs" : [ { "_id" : 2, "sku" : "bread1", "product" : "product 2", "instock" : 80, "state" : "OK" } ] }, /* 3 */ { "_id" : 3, "inventory_docs" : [ { "_id" : 4, "sku" : "pecans1", "product" : "product 4", "instock" : 70, "state" : "OK" } ] }
从结果可以看出,数组子文档 没有了state:"Simple"的数据(子文档)。
本文版权归作者所有,未经作者同意不得转载,谢谢配合!!!
原文地址:https://www.cnblogs.com/xuliuzai/p/10400368.html