含义
管道是啥？大家都知道，用于承载物体流过的物品，如水管，气体管等连接起来的就是管道。在代码中我们可以理解成链式调用
js 中的管道
let arr = [1,2,3,4,5]; let res =arr.filter(a => a > 1).map(p => ({num: p})) ... 复制代码
上述代码的res的结果是： [{num: 2},{name: 3}, {name: 4}, {name: 5}],上面代码是数组arr经过了filter管道和map管道，最终产出一个结果res
mongo 管道
下面所有的案例都有一个这样的数据集合：
aggregate
语法：db.collection.aggregate(pipeline,options);
1.group得基本用法： 语法： db.test.aggregate([{$group:{_id:'分组得key',test:{操作得事情}}}]);
列如：
- 通过pumber分组，求每组得最小值
db.test.aggregate([{$group:{_id:'$pumber',total:{$min:"$quantity"}}}]);
- 通过pumber分组，求每组的总和
db.test.aggregate([{$group:{_id:'$pumber',total:{$sum:"$quantity"}}]);
- 通过pumber分组，求每组的平均值
db.test.aggregate([{$group:{_id:'$pumber',average:{$avg:'$price'}}}]);
- 通过pumber分组，把每个quantity，放入数组中
db.test.aggregate([{$group:{_id:"$pnumber",quantity:{$push:"$quantity"}}}]);
- 通过pnumber分组，把多个东西放入数组中
db.test.aggregate([{$group:{_id:"$pnumber",suit:{$push:{price:'$price',quantity:'$quantity'}}}}]);
pipeline 类型是Array 语法：db.collection.aggregate( [ { <stage> }, ... ] )
project
$project：可以对输入文档进行添加新字段或删除现有的字段，可以自定哪些字段显示与不显示。
- 求总条数
db.test.aggregate([{$group:{_id:'$pumber',count:{$sum:1}}},{$project:{"_id":0,"count":1}}])
上面这句话的意思是，先用pumber来进行分组，会有两个字段，一个是"_id"和"count",在后一个管道中用1表示显示，0表示不显示
match
$match用于过滤数据，只输出符合条件的文档。$match使用MongoDB的标准查询操作,相当于sql的where.
db.test.aggregate([{$match:{"pumber":'p001'}},{$group:{_id:'$pumber',count:{$sum:'$quantity'}}}]); 相当于sql select sum(quantity) as count from test where pnumber='p001'
limit
$limit ：用来限制MongoDB聚合管道返回的文档数 db.test.aggregate([{$match:{"pumber":'p001'}},{$limit: 1}])
模糊哈希pumber是p001，然后限制查询的条数
skip
$skip :在聚合管道中跳过指定数量的文档，并返回余下的文档。
- 跳两个文件，然后查询限制1条：
db.test.aggregate([{ $skip: 2 },{ $limit: 1 }])
- 限制4条，然后跳过2个文件，得出2个文件
db.test.aggregate([{$limit:4},{$skip:2}]);
注意： $limit、$skip、$sort、$match可以使用在阶段管道，如果使用在$group之前可以过滤掉一些数据，提高性能。
unwind
$unwind :将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。 //把查出来的对象数组，然后把数组的值取出来 db.test.aggregate([{$group:{_id:'$pnumber',array:{$push:'$quantity'}}},{$sort:{"pnumber":1}},{$unwind:"$array"}]);
sample
$sample :使用两种方法之一来获取 N 个随机文档，具体取决于集合的大小，N 的大小以及$sample在管道中的位置。
如果满足以下所有条件，则$sample使用伪随机游标选择文档：
- $sample是管道的第一阶段
- N 小于集合中文档总数的 5％
- collections 包含 100 多个文档
如果不满足上述任何条件，则$sample执行收集扫描，然后进行随机排序以选择 N 个文档。在这种情况下，$sample阶段受排序内存限制约束。 语法： $sample: { size: <positive integer> }
每一次的结果都是不一样的
sort
$sort :将输入文档排序后输出。
1是升序，-1是降序
out
$out :必须为pipeline最后一个阶段管道，因为是将最后计算结果写入到指定的collection中。如果集合不存在，，会自动创建一个新的集合，存在的话就覆盖. db.test.aggregate([{$group:{_id:"$pumber",sku:{$push:{price:"$price",quantity:"$quantity"}}}},{$out:"skus"}]);
