MongoDB 集合間關聯查詢後通過$filter進行篩選

MongoDB · 發表 2019-02-19 12:51:00

摘要：在前面的分享中，有講解 “詳解MongoDB中的多表關聯查詢（$lookup） ” 一節，其內容涵蓋了常見的集合管理的需求。我們知道文件的選擇都是通過$match進行匹配刷選。但這是文件間的匹配篩選，並沒有對單個新生成的文件進行內嵌子文件進行篩選。那麼什麼是$lookup後...

在前面的分享中，有講解 “詳解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"的資料（子文件）。

本文版權歸作者所有，未經作者同意不得轉載, 謝謝配合！！！

MongoDB 集合間關聯查詢後通過$filter進行篩選

您可能也會喜歡…