MongoDB 聚合管道用法详解：实现复杂查询-JavaScript中文网-JavaScript教程资源分享门户

前言

MongoDB 是一款非关系型数据库，以其高效的读写性能、灵活的数据模型和强大的聚合管道功能而备受前端开发者的喜爱。聚合管道是 MongoDB 中的一种数据处理方式，可以用于实现复杂的查询和数据聚合操作。本文将详细介绍 MongoDB 聚合管道的用法，包括聚合管道的基本概念、常用操作符、常见用法和示例代码。希望能够为前端开发者提供一些指导和帮助。

聚合管道的基本概念

聚合管道是 MongoDB 中用于数据处理的一种方式，它可以将多个操作组合在一起，从而实现复杂的数据查询和聚合操作。聚合管道由多个操作阶段组成，每个阶段都会对输入数据进行处理，然后将处理结果传递给下一个阶段，最终得到最终的输出结果。

在 MongoDB 中，聚合管道的基本语法如下：

db.collection.aggregate(pipeline, options)

其中，db.collection 表示要进行聚合操作的集合，pipeline 是一个由多个操作阶段组成的数组，options 是一个可选参数，用于指定聚合操作的一些选项。

常用操作符

MongoDB 聚合管道中常用的操作符有很多，这里只列举一些常见的操作符和用法。

`$match`

$match 操作符用于筛选输入数据，只保留符合条件的文档。它的语法如下：

{
  $match: {
    <query>
  }
}

其中，<query> 表示一个查询条件，可以使用 MongoDB 的查询语法进行定义。

例如，以下代码将从 orders 集合中筛选出所有价格大于 100 的订单：

db.orders.aggregate([
  { $match: { price: { $gt: 100 } } }
])

`$group`

$group 操作符用于对输入数据进行分组聚合操作。它的语法如下：

{
  $group: {
    _id: <expression>,
    <field1>: { <accumulator1>: <expression1> },
    ...
  }
}

其中，_id 表示分组字段，<expression> 表示分组字段的值，可以是任意有效的表达式。<field> 表示聚合结果中的字段名，<accumulator> 表示聚合操作，<expression> 表示要进行聚合操作的表达式。

例如，以下代码将从 orders 集合中按照 status 字段进行分组，计算每个分组的订单总数和平均价格：

// www.javascriptcn.com code example
db.orders.aggregate([
  {
    $group: {
      _id: "$status",
      count: { $sum: 1 },
      avgPrice: { $avg: "$price" }
    }
  }
])

`$project`

$project 操作符用于对输入数据进行投影操作，只保留需要的字段。它的语法如下：

{
  $project: {
    <field1>: <expression1>,
    ...
  }
}

其中，<field> 表示要保留的字段名，<expression> 表示要进行投影操作的表达式。如果 <expression> 为 1，则表示保留该字段；如果 <expression> 为 0，则表示排除该字段。

例如，以下代码将从 orders 集合中只保留 _id、price 和 status 字段：

// www.javascriptcn.com code example
db.orders.aggregate([
  {
    $project: {
      _id: 1,
      price: 1,
      status: 1
    }
  }
])

`$sort`

$sort 操作符用于对输入数据进行排序操作，按照指定的字段和顺序进行排序。它的语法如下：

{
  $sort: {
    <field1>: <sortOrder1>,
    ...
  }
}

其中，<field> 表示要排序的字段名，<sortOrder> 表示排序的顺序，可以是 1（升序）或 -1（降序）。

例如，以下代码将从 orders 集合中按照价格从高到低进行排序：

db.orders.aggregate([
  {
    $sort: {
      price: -1
    }
  }
])

常见用法

多个操作阶段的组合

聚合管道可以由多个操作阶段组合而成，每个阶段都可以使用不同的操作符和参数，从而实现复杂的数据处理操作。以下代码展示了一个由三个操作阶段组成的聚合管道，它将从 orders 集合中筛选出价格大于 100 的订单，按照状态进行分组，并计算每个分组的订单总数和平均价格：

// www.javascriptcn.com code example
db.orders.aggregate([
  { $match: { price: { $gt: 100 } } },
  {
    $group: {
      _id: "$status",
      count: { $sum: 1 },
      avgPrice: { $avg: "$price" }
    }
  }
])

管道输出到新的集合

聚合管道的输出结果也可以保存到新的集合中，以便后续的数据分析和处理。以下代码展示了如何将聚合管道的输出结果保存到新的 orders_summary 集合中：

// www.javascriptcn.com code example
db.orders.aggregate([
  {
    $group: {
      _id: "$status",
      count: { $sum: 1 },
      avgPrice: { $avg: "$price" }
    }
  },
  { $out: "orders_summary" }
])

示例代码

以下代码展示了一个完整的 MongoDB 聚合管道示例，它包含了多个操作阶段和常用操作符的使用：

// www.javascriptcn.com code example
db.orders.aggregate([
  { $match: { price: { $gt: 100 } } },
  { $sort: { price: -1 } },
  {
    $group: {
      _id: "$status",
      count: { $sum: 1 },
      avgPrice: { $avg: "$price" }
    }
  },
  {
    $project: {
      _id: 0,
      status: "$_id",
      count: 1,
      avgPrice: 1
    }
  },
  { $out: "orders_summary" }
])

以上代码将从 orders 集合中筛选出价格大于 100 的订单，按照价格从高到低进行排序，再按照状态进行分组，计算每个分组的订单总数和平均价格，最后将结果保存到新的 orders_summary 集合中。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/67d104a4a941bf7134233036

MongoDB 聚合管道用法详解：实现复杂查询

前言