MongoDB聚合管道查询如何进行数据合并

在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"
    }
  }
])

这个查询将会执行以下操作：

1. 对于orders集合中的每个文档，检查customers集合中是否存在具有相同customer_id的文档。
2. 如果存在匹配的文档，则使用$merge阶段的whenMatched选项（在这里是"replace"）替换该文档。
3. 如果不存在匹配的文档，则使用$merge阶段的whenNotMatched选项（在这里是"insert"）插入新文档。

执行此查询后，我们将得到一个包含合并后的数据的customers集合：

{
  "_id": 1,
  "name": "Alice",
  "email": "alice@example.com",
  "orders": [
    {
      "_id": 1,
      "customer_id": 1,
      "amount": 100
    }
  ]
}

注意，$merge阶段不会保留输入集合的排序和索引。如果需要保留这些信息，可以在$merge阶段之前使用$sort和$indexStats等阶段。