MongoDB 聚合管道

阳光穿透心脏的1/2处 2022-12-27 02:20 163阅读 0赞

# MongoDB 聚合管道 #

MongoDB 中聚合(aggregate)主要用于处理数据(诸如统计平均值，求和等)，并返回计算后的数据结果。

有点类似 **SQL** 语句中的 **count(\*)**。

官网参考为准：https://mongodb.net.cn/manual/reference/method/

<table> 
 <thead> 
 <tr> 
 <th align="left">名称</th> 
 <th align="left">描述</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td align="left"><a href="https://mongodb.net.cn/manual/reference/method/db.collection.aggregate/#db.collection.aggregate" rel="nofollow"><code>db.collection.aggregate()</code></a></td> 
 <td align="left">提供对<a href="https://mongodb.net.cn/manual/core/aggregation-pipeline/" rel="nofollow">聚合管道的</a>访问。</td> 
 </tr> 
 </tbody> 
</table>

>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDcyODc3_size_16_color_FFFFFF_t_70]

<table> 
 <thead> 
 <tr> 
 <th align="left">表达式</th> 
 <th align="left">描述</th> 
 <th align="left">实例</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td align="left">$sum</td> 
 <td align="left">计算总和。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", num_tutorial : { s u m : " sum : " sum:"likes"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$avg</td> 
 <td align="left">计算平均值</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", num_tutorial : { a v g : " avg : " avg:"likes"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$min</td> 
 <td align="left">获取集合中所有文档对应值得最小值。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", num_tutorial : { m i n : " min : " min:"likes"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$max</td> 
 <td align="left">获取集合中所有文档对应值得最大值。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", num_tutorial : { m a x : " max : " max:"likes"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$push</td> 
 <td align="left">在结果文档中插入值到一个数组中。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", url : { p u s h : " push: " push:"url"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$addToSet</td> 
 <td align="left">在结果文档中插入值到一个数组中，但不创建副本。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", url : { a d d T o S e t : " addToSet : " addToSet:"url"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$first</td> 
 <td align="left">根据资源文档的排序获取第一个文档数据。</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", first_url : { f i r s t : " first : " first:"url"}}}])</td> 
 </tr> 
 <tr> 
 <td align="left">$last</td> 
 <td align="left">根据资源文档的排序获取最后一个文档数据</td> 
 <td align="left">db.mycol.aggregate([{ KaTeX parse error: Expected '}', got 'EOF' at end of input: …roup : {_id : "by_user", last_url : { l a s t : " last : " last:"url"}}}])</td> 
 </tr> 
 </tbody> 
</table>

**管道**在Unix和Linux中一般用于将当前命令的输出结果作为下一个命令的参数。

MongoDB的聚合管道将MongoDB文档在一个管道处理完毕后将结果传递给下一个管道处理。管道操作是可以重复的。

*  $project：修改输入文档的结构。可以用来重命名、增加或删除域，也可以用于创建计算结果以及嵌套文档。
 *   m a t c h ： 用 于 过 滤 数 据 ， 只 输 出 符 合 条 件 的 文 档 。 match：用于过滤数据，只输出符合条件的文档。 match：用于过滤数据，只输出符合条件的文档。match使用MongoDB的标准查询操作。
 *  $limit：用来限制MongoDB聚合管道返回的文档数。
 *  $skip：在聚合管道中跳过指定数量的文档，并返回余下的文档。
 *  $unwind：将文档中的某一个数组类型字段拆分成多条，每条包含数组中的一个值。
 *  $group：将集合中的文档分组，可用于统计结果。
 *  $sort：将输入文档排序后输出。
 *  $geoNear：输出接近某一地理位置的有序文档。

### 管道操作符实例 ###

1、$project实例

db.article.aggregate(
        { $project : {
            title : 1 ,
            author : 1 ,
        }}
     );

这样的话结果中就只还有\_id,tilte和author三个字段了，默认情况下\_id字段是被包含的，如果要想不包含\_id话可以这样:

db.article.aggregate(
        { $project : {
            _id : 0 ,
            title : 1 ,
            author : 1
        }});

2.$match实例

db.articles.aggregate( [
                            { $match : { score : { $gt : 70, $lte : 90 } } },
                            { $group: { _id: null, count: { $sum: 1 } } }
                           ] );

m a t c h 用 于 获 取 分 数 大 于 70 小 于 或 等 于 90 记 录 ， 然 后 将 符 合 条 件 的 记 录 送 到 下 一 阶 段 match用于获取分数大于70小于或等于90记录，然后将符合条件的记录送到下一阶段 match用于获取分数大于70小于或等于90记录，然后将符合条件的记录送到下一阶段group管道操作符进行处理。

3.$skip实例

db.article.aggregate(
        { $skip : 5 });

经过$skip管道操作符处理后，前五个文档被"过滤"掉。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNDcyODc3_size_16_color_FFFFFF_t_70]: /images/20221120/429ec770b02141388fe545ce705cdd56.png