在MongoDB中,聚合管道查詢是一種強大的數據處理方式,可以對數據進行各種變換和組合。數據合并是聚合管道中的一個常見操作,可以通過$merge
階段來實現。
$merge
階段可以將多個輸入集合的數據合并到一個輸出集合中。以下是一個簡單的示例:
假設我們有兩個集合:orders
和customers
。我們想要將訂單數據與相應的客戶數據進行合并。
orders集合:
{
"_id": 1,
"customer_id": 1,
"amount": 100
}
customers集合:
{
"_id": 1,
"name": "Alice",
"email": "alice@example.com"
}
我們可以使用以下聚合管道查詢將這兩個集合的數據合并:
db.orders.aggregate([
{
$merge: {
into: "customers",
whenMatched: "replace",
whenNotMatched: "insert"
}
}
])
這個查詢將會執行以下操作:
orders
集合中的每個文檔,檢查customers
集合中是否存在具有相同customer_id
的文檔。$merge
階段的whenMatched
選項(在這里是"replace"
)替換該文檔。$merge
階段的whenNotMatched
選項(在這里是"insert"
)插入新文檔。執行此查詢后,我們將得到一個包含合并后的數據的customers
集合:
{
"_id": 1,
"name": "Alice",
"email": "alice@example.com",
"orders": [
{
"_id": 1,
"customer_id": 1,
"amount": 100
}
]
}
注意,$merge
階段不會保留輸入集合的排序和索引。如果需要保留這些信息,可以在$merge
階段之前使用$sort
和$indexStats
等階段。