目录

MongoDB聚合操作

聚合操作的基本语法

 常用的聚合操作

管道命令之$group 

按照某个字段进行分组

详解 

计算集合中某个字段的平均值 

常用表达式

管道命令之$match 

示例 

管道命令之$sort

管道命令之$skip 和 $limit 

管道命令之$project

---

MongoDB聚合操作

在MongoDB中，聚合操作是对文档进行数据处理和转换的强大工具。它允许你通过多个阶段的管道将多个操作链接在一起，以便对文档进行复杂的数据处理，主要用于处理多个文档(诸如统计平均值，求和等)，并返回计算后的数据结果。

• 对多个文档进行分组
• 对分组的文档执行操作并返回单个结果
• 分析数据变化

聚合操作的基本语法

db.collection.aggregate([pipeline])

db.collection是要进行聚合操作的集合，pipeline是一个由多个聚合阶段组成的数组。每个聚合阶段都代表一个数据处理操作，按照在数组中的顺序依次执行。

 常用的聚合操作

1. $match：过滤文档，只输出符合指定条件的文档。
2. $project：选择需要输出的字段，并可以进行计算、重命名等操作。
3. $group：将文档分组，并可以对分组进行聚合计算。
4. $sort：对文档进行排序。
5. $limit：限制输出结果的数量。
6. $skip：跳过指定数量的文档。
7. $unwind：展开数组字段，将每个数组元素拆分成独立的文档。
8. $lookup：在不同的集合之间执行类似关联操作。

管道命令之$group 

按照某个字段进行分组

db.stu.aggregate(
   {$group:
     {
      _id:"$country",
      counter:{$sum:1}
     }
   }
)

详解 

• db.db_name.aggregate是语法，所有的管道命令都需要写在其中
• _id 表示分组的依据，按照哪个字段进行分组，例如：需要使用$gender表示选择这个字段进行分组
• $sum:1 表示把每条数据作为1进行统计，统计的是该分组下面数据的条数

计算集合中某个字段的平均值 

db.sales.aggregate([
  {
    $group: {
      _id: null,
      avgAmount: { $avg: "$amount" }
    }
  }
])

$group阶段按照null分组（即所有文档都属于同一组），然后使用$avg操作符计算amount字段的平均值，并将结果输出为avgAmount字段。 

常用表达式

表达式：处理输⼊⽂档并输出 语法：表达式:'$列名' 常⽤表达式: 

• $sum： 计算总和， $sum:1 表示以⼀倍计数
• $avg： 计算平均值
• $min： 获取最⼩值
• $max： 获取最⼤值
• $push： 在结果⽂档中插⼊值到⼀个数组中

管道命令之$match 

$match用于进行数据的过滤，是在能够在聚合操作中使用的命令，和find区别在于$match 操作可以把结果交给下一个管道处理，而find不行。

示例 

查询年龄大于20的人

db.person.aggregate([
   {$match:{age:{$gt:20}}}
   ])

查询年龄大于20的魏国的人数

db.person.aggregate([
   {$match:{age:{$gt:20}}},
   {$group:{_id:"$country",counter:{$sum:1}}}
   ])

管道命令之$sort

$sort用于将输入的文档排序后输出

使用示例如下：

1. 查询人物，按照年龄升序

   db.person.aggregate([{$sort:{age:1}}])

2. 查询每个国家的人数，并排序

   db.person.aggregate([
      {$group:{_id:"$country",counter:{$sum:1}}},
      {$sort:{counter:-1}}
   ])
   

管道命令之$skip 和 $limit 

• $limit限制返回数据的条数
• $skip 跳过指定的文档数，并返回剩下的文档数

注意

同时使用时先使用skip在使用limit

使用示例如下：

1. 查询2条信息

   db.person.aggregate([
      {$limit:2}
   ])
   

2. 查询从第三条开始的信息

   db.person.aggregate([
      {$skip:3}
   ])
   

3. 查询每个国家的人数，按照人数升序，返回第二条数据

   db.person.aggregate([
      {$group:{_id:"$country",counter:{$sum:1}}},
      {$sort:{counter:-1}},
      {$skip:1},
      {$limit:1}
   ])
   

管道命令之$project

$project用于修改文档的输入输出结构

字段值：0不显示，1显示

使用示例如下：

1. 查询人物的姓名、年龄，不显示ID

db.person.aggregate([
   {$project:{_id:0,name:1,age:1}}
   ])

1. 查询每个国家的人数，只显示数量

db.person.aggregate([
   {$group:{_id:"$country",counter:{$sum:1}}},
   {$project:{_id:0,counter:1}}
   ])

注意

• _id与其他字段共同设置时，0只能设置在_id上
• 设置字段时，除了_id字段，其他默认取反