MongoDB 聚合框架详解

### MongoDB 聚合框架详解

---

#### **1. 聚合管道**
- **概念**：
  聚合管道是一种数据处理框架，它允许对集合中的数据进行多阶段转换和聚合。MongoDB 的聚合管道就像一个流水线，数据从一端流入，依次经过一系列的阶段操作（如过滤、投影、分组等），最终从另一端流出，形成最终的查询结果。
  - **优点**：
    - **灵活性**：可以处理各种复杂的数据转换和聚合操作。
    - **高效性**：通过管道式的处理方式，可以在内存中高效地处理大规模数据。
    - **集成性**：可以与 MongoDB 的其他功能（如索引、分片等）无缝集成，提高数据处理的整体性能。

- **使用方法**：
  聚合管道通过 `aggregate()` 方法实现。`aggregate()` 方法接受一个管道操作符数组，每个操作符表示一个阶段。以下是基本的使用语法：
  ```javascript
  db.collection.aggregate([
      { $match: { <query> } },   // 过滤文档
      { $group: { <grouping> } },   // 分组文档
      { $sort: { <sorting> } },   // 排序文档
      { $limit: <number> },   // 限制结果数量
      { $project: { <projection> } }   // 选择字段
  ]);
  ```

#### **2. 常用聚合操作**
- **`$match`**：
  用于过滤文档，类似于 `find()` 方法中的查询条件。
  - **示例**：
    查询年龄大于 30 的用户：
    ```javascript
    db.mycollection.aggregate([
      { $match: { age: { $gt: 30 } } }
    ])
    ```

- **`$group`**：
  用于将文档分组，并对每个组进行聚合操作（如求和、求平均值等）。
  - **示例**：
    按城市分组并计算每个城市的平均年龄：
    ```javascript
    db.mycollection.aggregate([
      {
        $group: {
          _id: "$city",
          avgAge: { $avg: "$age" }
        }
      }
    ])
    ```

- **`$sort`**：
  用于对文档进行排序。
  - **示例**：
    按年龄降序排序：
    ```javascript
    db.mycollection.aggregate([
      { $sort: { age: -1 } }
    ])
    ```

- **`$limit`**：
  用于限制返回结果的数量。
  - **示例**：
    返回前 5 条记录：
    ```javascript
    db.mycollection.aggregate([
      { $limit: 5 }
    ])
    ```

- **`$skip`**：
  用于跳过指定数量的文档。
  - **示例**：
    跳过前 2 条记录：
    ```javascript
    db.mycollection.aggregate([
      { $skip: 2 }
    ])
    ```

- **`$project`**：
  用于选择或排除特定字段。
  - **示例**：
    只返回用户的姓名和年龄字段：
    ```javascript
    db.mycollection.aggregate([
      {
        $project: {
          name: 1,
          age: 1,
          _id: 0
        }
      }
    ])
    ```

#### **3. 复杂聚合示例**
- **多阶段聚合**：
  以下是一个多阶段的聚合示例，展示了如何使用多个管道操作符来实现复杂的数据分析：
  - **示例**：
    查询年龄大于 30 的用户，按城市分组并计算每个城市的平均年龄，按平均年龄排序，并返回前 3 条记录：
    ```javascript
    db.mycollection.aggregate([
      { $match: { age: { $gt: 30 } } },
      {
        $group: {
          _id: "$city",
          avgAge: { $avg: "$age" },
          count: { $sum: 1 }
        }
      },
      { $sort: { avgAge: -1 } },
      { $limit: 3 }
    ])
    ```

- **数据汇总与分析**：
  聚合框架非常适合用于数据汇总和分析任务，例如统计用户购买行为、计算统计数据等。
  - **示例**：
    假设有一个 `orders` 集合，存储了用户的订单信息。可以使用聚合框架来计算每个用户的总订单金额：
    ```javascript
    db.orders.aggregate([
      {
        $group: {
          _id: "$user_id",
          total: { $sum: "$amount" }
        }
      }
    ])
    ```

通过使用 MongoDB 的聚合框架，可以轻松地对数据进行复杂的数据转换和分析，从而满足各种业务需求。