mongodb中group分组。

港控/mmm° 2024-02-18 19:46 47阅读 0赞

group做的聚合有些复杂。先选定分组所依据的键，此后MongoDB就会将集合依据选定键值的不同分成若干组。然后可以通过聚合每一组内的文档，产生一个结果文档。  
和数据库一样group常常用于统计。MongoDB的group还有很多限制，如：返回结果集不能超过16M， group操作不会处理超过10000个唯一键，好像还不能利用索引\[不很确定\]。

Group大约需要一下几个参数。

*  key：用来分组文档的字段。和keyf两者必须有一个
 *  keyf：可以接受一个javascript函数。用来动态的确定分组文档的字段。和key两者必须有一个
 *  initial：reduce中使用变量的初始化
 *  reduce：执行的reduce函数。函数需要返回值。
 *  cond：执行过滤的条件。
 *  finallize：在reduce执行完成，结果集返回之前对结果集最终执行的函数。可选的。

下面介绍一个实例：  
先插入测试数据：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>for</code> 
      <code>(var i=1; i&lt;20; i++){ </code> 
     </div> 
     <div> 
      <code>var num=i%6;</code> 
     </div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.insert({_id:i,name:</code> 
      <code>"user_"</code> 
      <code>+i,age:num});</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 普通分组查询 ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.group({ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>key:{age:</code> 
      <code>true</code> 
      <code>},</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev){ </code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>prev.num++</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code> 
      <code>});</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>db.runCommand({group:</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>ns:</code> 
      <code>"test"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>key:{age:</code> 
      <code>true</code> 
      <code>},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev)</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>prev.num++</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 筛选后再分组 ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.group({ </code> 
     </div> 
     <div> 
      <code>key:{age:</code> 
      <code>true</code> 
      <code>},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev)</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>prev.num++</code> 
     </div> 
     <div> 
      <code>},</code> 
     </div> 
     <div> 
      <code>condition:{age:{$gt:2}}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>db.runCommand({group:</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>ns:</code> 
      <code>"test"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>key:{age:</code> 
      <code>true</code> 
      <code>},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev)</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>prev.num++},</code> 
     </div> 
     <div> 
      <code>condition:{age:{$gt:2}}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 普通的$where查询 ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.</code> 
      <code>find</code> 
      <code>({$where:</code> 
      <code>function</code> 
      <code>(){ </code> 
     </div> 
     <div> 
      <code>return</code> 
      <code> this.age&gt;2;</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## group联合$where查询 ##

## 使用函数返回值分组 ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>//</code> 
      <code>注意，$keyf指定的函数一定要返回一个对象</code> 
     </div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.group({ </code> 
     </div> 
     <div> 
      <code>$keyf:</code> 
      <code>function</code> 
      <code>(doc){ </code> 
      <code>return</code> 
      <code>{age:doc.age};},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev){ </code> 
     </div> 
     <div> 
      <code>prev.num++</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>db.runCommand({group:</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>ns:</code> 
      <code>"test"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>$keyf:</code> 
      <code>function</code> 
      <code>(doc){ </code> 
      <code>return</code> 
      <code>{age:doc.age};},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev){ </code> 
     </div> 
     <div> 
      <code>prev.num++}</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 使用终结器 ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.group({ </code> 
     </div> 
     <div> 
      <code>$keyf:</code> 
      <code>function</code> 
      <code>(doc){ </code> 
      <code>return</code> 
      <code>{age:doc.age};},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev){ </code> 
     </div> 
     <div> 
      <code>prev.num++</code> 
     </div> 
     <div> 
      <code>},</code> 
     </div> 
     <div> 
      <code>finalize: </code> 
      <code>function</code> 
      <code>(doc){ doc.count=doc.num;delete doc.num; }</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>db.runCommand({group:</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>ns:</code> 
      <code>"test"</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>$keyf:</code> 
      <code>function</code> 
      <code>(doc){ </code> 
      <code>return</code> 
      <code>{age:doc.age};},</code> 
     </div> 
     <div> 
      <code>initial:{num:0},</code> 
     </div> 
     <div> 
      <code>$reduce:</code> 
      <code>function</code> 
      <code>(doc,prev){ </code> 
     </div> 
     <div> 
      <code>prev.num++},</code> 
     </div> 
     <div> 
      <code>finalize: </code> 
      <code>function</code> 
      <code>(doc){ doc.count=doc.num;delete doc.num; }</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 有关MapReduce    ##

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>//</code> 
      <code>首先插入测试数据</code> 
     </div> 
     <div> 
      <code>for</code> 
      <code>(var i=1;i&lt;21;i++)</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>db.</code> 
      <code>test</code> 
      <code>.insert({_id:i,name:</code> 
      <code>'mm'</code> 
      <code>+i});</code> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
     <div> 
      <code>//</code> 
      <code>进行mapreduce</code> 
     </div> 
     <div> 
      <code>db.runCommand(</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>mapreduce:</code> 
      <code>'test'</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>map:</code> 
      <code>function</code> 
      <code>(){emit(this.name.substr(0,3),this);},</code> 
     </div> 
     <div> 
      <code>reduce:</code> 
      <code>function</code> 
      <code>(key,vals){ </code> 
      <code>return</code> 
      <code>vals[0];}, </code> 
      <code>//</code> 
      <code>注意：vals是一个Object对象而不是数组</code> 
     </div> 
     <div> 
      <code>out:</code> 
      <code>'wq'</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

## 注意 ##

1.mapreduce是根据map函数里调用的emit函数的第一个参数来进行分组的  
2.仅当根据分组键分组后一个键匹配多个文档，才会将key和文档集合交由reduce函数处理。例如：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.runCommand(</code> 
     </div> 
     <div> 
      <code>{ </code> 
     </div> 
     <div> 
      <code>mapreduce:</code> 
      <code>'test'</code> 
      <code>,</code> 
     </div> 
     <div> 
      <code>map:</code> 
      <code>function</code> 
      <code>(){emit(this.name.substr(0,3),this);},</code> 
     </div> 
     <div> 
      <code>reduce:</code> 
      <code>function</code> 
      <code>(key,vals){ </code> 
      <code>return</code> 
      <code>'wq'</code> 
      <code>;},</code> 
     </div> 
     <div> 
      <code>out:</code> 
      <code>'wq'</code> 
     </div> 
     <div> 
      <code>});</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

执行mapreduce命令后，再查看wq表数据：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div> 
     <div> 
      <code>db.wq.</code> 
      <code>find</code> 
      <code>()</code> 
     </div> 
     <div>
       &nbsp; 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm1"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: </code> 
      <code>"wq"</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm2"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: </code> 
      <code>"wq"</code> 
      <code>}</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm3"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 3, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm3"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm4"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 4, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm4"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm5"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 5, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm5"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm6"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 6, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm6"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm7"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 7, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm7"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm8"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 8, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm8"</code> 
      <code> } }</code> 
     </div> 
     <div> 
      <code>{ </code> 
      <code>"_id"</code> 
      <code>: </code> 
      <code>"mm9"</code> 
      <code>, </code> 
      <code>"value"</code> 
      <code>: { </code> 
      <code>"_id"</code> 
      <code>: 9, </code> 
      <code>"name"</code> 
      <code>: </code> 
      <code>"mm9"</code> 
      <code> } }</code> 
     </div> 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

以上所述就是本文的全部内容了，希望大家能够喜欢。

转载：[http://www.jb51.net/article/65934.htm][http_www.jb51.net_article_65934.htm]

[http_www.jb51.net_article_65934.htm]: http://www.jb51.net/article/65934.htm