查询MongoDb聚合连接两个集合

在MongoDB中，可以使用聚合管道（aggregation pipeline）来连接两个集合。聚合管道是一系列的阶段操作，可以对数据进行处理和转换。

下面是一个示例，展示了如何使用聚合管道连接两个集合：

首先，假设有两个集合：orders 和 customers。orders 集合包含订单信息，customers 集合包含用户信息。

1. 创建 orders 集合并插入数据：

db.orders.insertMany([
  { orderId: 1, customerId: 1, totalAmount: 100 },
  { orderId: 2, customerId: 2, totalAmount: 200 },
  { orderId: 3, customerId: 1, totalAmount: 150 },
  { orderId: 4, customerId: 3, totalAmount: 300 }
])

2. 创建 customers 集合并插入数据：

db.customers.insertMany([
  { customerId: 1, name: "Alice" },
  { customerId: 2, name: "Bob" },
  { customerId: 3, name: "Charlie" }
])

3. 使用聚合管道连接两个集合：

db.orders.aggregate([
  {
    $lookup: {
      from: "customers",
      localField: "customerId",
      foreignField: "customerId",
      as: "customerInfo"
    }
  }
])

在上面的聚合管道中，$lookup 是用于连接两个集合的操作。它有以下参数：

• from: 指定要连接的集合名称（customers）。
• localField: 指定当前集合（orders）中用于连接的字段（customerId）。
• foreignField: 指定要连接的集合（customers）中用于连接的字段（customerId）。
• as: 指定连接后生成的字段，用于保存连接的结果（customerInfo）。

执行上述聚合管道后，会将 orders 集合和 customers 集合连接，并将连接结果保存在 customerInfo 字段中。连接结果将包含匹配的订单和用户信息。

注意：在实际使用中，可以根据具体需求在聚合管道中添加其他的阶段操作，如 $match、$project 等，以进一步处理和转换数据。