一篇文章带你搞定 MongoDB 中的管道操作符（$group、$unwind、$sort、$limit、$skip）

曾经终败给现在 2022-11-30 12:48 271阅读 0赞

上篇文章中我们已经学习了MongoDB中几个基本的管道操作符，本文我们再来看看其他的管道操作符。

### 文章目录 ###

*   *  一、$group
     *   *  1. 基本操作
         *  2. 算术操作符
         *  3. 极值操作符
     *  二、$unwind
     *  三、其他操作符：sort/limit/skip
     *  四、总结

## 一、$group ##

### 1. 基本操作 ###

`$group`可以用来对文档进行分组，比如我想将订单按照城市进行分组，并统计出每个城市的订单数量：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",count:{ $sum:1}}})

我们将要分组的字段传递给$group函数的\_id字段，然后每当查到一个，就给count加1，这样就可以统计出每个城市的订单数量。

### 2. 算术操作符 ###

通过算术操作符我们可以对分组后的文档进行求和或者求平均数。比如我想计算每个城市订单运费总和，如下：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",totalFreight:{ $sum:"$freight"}}})

先按地址分组，再求和。这里贴出部分查询结果，如下：

{ 
        "_id" : "HaiKou",
        "totalFreight" : 20.0
    }
    { 
        "_id" : "HangZhou",
        "totalFreight" : 10.0
    }

也可以计算每个城市运费的平均数，如下：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",avgFreight:{ $avg:"$freight"}}})

先按地址分组，然后再计算平均数。

### 3. 极值操作符 ###

极值操作符用来获取分组后数据集的边缘值，比如获取每个城市最贵的运费，如下：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",maxFreight:{ $max:"$freight"}}})

查询每个城市最便宜的运费：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",minFreight:{ $min:"$freight"}}})

按城市分组之后，获取该城市第一个运费单：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",firstFreight:{ $first:"$freight"}}})

获取分组后的最后一个运费单：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",lastFreight:{ $last:"$freight"}}})

数据操作符  
`$addToSet`可以将分组后的某一个字段放到一个数组中，但是重复的元素将只出现一次，而且元素加入到数组中的顺序是无规律的，比如将分组后的每个城市的运费放到一个数组中，如下：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",freights:{ $addToSet:"$freight"}}})

重复的freight将不会被添加进来。

$push则对重复的数据不做限制，都可以添加进来，如下：

db.sang_collect.aggregate({ $group:{ _id:"$orderAddressL",freights:{ $push:"$freight"}}})

## 二、$unwind ##

`$unwind`用来实现对文档的拆分,可以将文档中的值拆分为单独的文档，比如我的数据如下：

{ 
        "_id" : ObjectId("59f93c8b8523cfae4cf4ba86"),
        "name" : "鲁迅",
        "books" : [ 
            { 
                "name" : "呐喊",
                "publisher" : "花城出版社"
            }, 
            { 
                "name" : "彷徨",
                "publisher" : "南海出版出"
            }
        ]
    }

使用`$unwind`命令将其拆分为独立文档，如下：

db.sang_books.aggregate({ $unwind:"$books"})

拆分结果如下：

{ 
        "_id" : ObjectId("59f93c8b8523cfae4cf4ba86"),
        "name" : "鲁迅",
        "books" : { 
            "name" : "呐喊",
            "publisher" : "花城出版社"
        }
    }
    { 
        "_id" : ObjectId("59f93c8b8523cfae4cf4ba86"),
        "name" : "鲁迅",
        "books" : { 
            "name" : "彷徨",
            "publisher" : "南海出版出"
        }
    }

## 三、其他操作符：sort/limit/skip ##

`$sort`操作可以对文档进行排序，如下：

db.sang_collect.aggregate({ $sort:{ orderAddressL:1}})

用法和我们之前介绍普通搜索中的一致，可以按照存在的字段排序，也可以按照重命名的字段排序，如下：

db.sang_collect.aggregate({ $project:{ oa:"$orderAddressL"}},{ $sort:{ oa:-1}})

1表示升序、-1表示降序。

`$limit`返回结果中的前n个文档，如下表示返回结果中的前三个文档：

db.sang_collect.aggregate({ $project:{ oa:"$orderAddressL"}},{ $limit:3})

`$skip`表示跳过前n个文档，比如跳过前5个文档，如下：

db.sang_collect.aggregate({ $project:{ oa:"$orderAddressL"}},{ $skip:5})

`$skip`的效率低，要慎用。

## 四、总结 ##