php mongodb group 整理

• 05, 30, 2016
•  小时候
•  mongodb
• Comment: 1

php 链接mongodb后 可以用group函数

[php]
/*
$keys = array(‘id’ => true);
$initial = array(‘count’=>0);
$reduce = "function (obj, prev) {
//prev.items.push(obj.zrbl);
prev[‘zrbl’] = obj.zrbl;
prev[‘syts’] = obj.syts;
prev[‘count’] += 1;
}";
$cursor = $collection->group($keys, $initial, $reduce);
print_r($cursor[‘retval’]);
*/
[/php]

keys 是group的字段
initial初始字段
reduce 执行的方法

十来万数据的样子，查起来偏慢 , 主要是找了半天没找到怎么order by 然后就改用 aggregate 了

aggregate 同样的结果 返回速度明显提升

[php]
$cond = array(
/*array(
//’$match’ => array(‘_id’ => array(‘$gt’ => 0)),
‘$match’ => array(‘id’ => array(‘$gt’=>0)),
),*/
array(
‘$group’ => array(
‘_id’ => ‘$id’,
‘zrbl’=>array(‘$first’=>’$zrbl’),
‘stime’=>array(‘$first’=>array(‘$dateToString’=>array(‘format’=>’%Y-%m-%d %H:%M:%S’,’date’=>’$eventtime’))),
‘etime’=>array(‘$last’=>array(‘$dateToString’=>array(‘format’=>’%Y-%m-%d %H:%M:%S’,’date’=>’$eventtime’))),
‘count’ => array(‘$sum’ => 1),
),
),
array(
‘$project’=>array(
‘_id’=>1,
‘zrbl’=>1,
‘count’=>1
)
),
array(
‘$sort’ => array("zrbl" => -1),
),
);
$cursor = $collection->aggregate($cond);
print_r($cursor);
[/php]

操作符介绍：
$project：包含、排除、重命名和显示字段
$match：查询，需要同find()一样的参数
$limit：限制结果数量
$skip：忽略结果的数量
$sort：按照给定的字段排序结果
$group：按照给定表达式组合结果
$unwind：分割嵌入数组到自己顶层文件

表达式 描述 实例
$sum 计算总和。 db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$sum : “$likes”}}}])
$avg 计算平均值 db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$avg : “$likes”}}}])
$min 获取集合中所有文档对应值得最小值。 db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$min : “$likes”}}}])
$max 获取集合中所有文档对应值得最大值。 db.mycol.aggregate([{$group : {_id : “$by_user”, num_tutorial : {$max : “$likes”}}}])
$push 在结果文档中插入值到一个数组中。 db.mycol.aggregate([{$group : {_id : “$by_user”, url : {$push: “$url”}}}])
$addToSet 在结果文档中插入值到一个数组中，但不创建副本。 db.mycol.aggregate([{$group : {_id : “$by_user”, url : {$addToSet : “$url”}}}])
$first 根据资源文档的排序获取第一个文档数据。 db.mycol.aggregate([{$group : {_id : “$by_user”, first_url : {$first : “$url”}}}])
$last 根据资源文档的排序获取最后一个文档数据 db.mycol.aggregate([{$group : {_id : “$by_user”, last_url : {$last : “$url”}}}])

注：array(‘$group’ => array(‘_id’ => ‘$id’,’zrbl’=>array(‘$first’=>1),’count’ => array(‘$sum’ => 1),), ), 同一类型操作可以重复进行，按照先后顺序。

管道表达式

管道操作符作为“键”,所对应的“值”叫做管道表达式。例如上面例子中{$match:{status:”A”}}，$match称为管道操作符，而{status:”A”}称为管道表达式，它可以看作是管道操作符的操作数(Operand)，每个管道表达式是一个文档结构，它是由字段名、字段值、和一些表达式操作符组成的，例如上面例子中管道表达式就包含了一个表达式操作符$sum进行累加求和。

每个管道表达式只能作用于处理当前正在处理的文档，而不能进行跨文档的操作。管道表达式对文档的处理都是在内存中进行的。除了能够进行累加计算的管道表达式外，其他的表达式都是无状态的，也就是不会保留上下文的信息。累加性质的表达式操作符通常和$group操作符一起使用，来统计该组内最大值、最小值等，例如上面的例子中我们在$group管道操作符中使用了具有累加的$sum来计算总和。

除了$sum以为，还有以下性质的表达式操作符：

组聚合操作符

Bool类型聚合操作符

比较类型聚合操作符

算术类型聚合操作符

字符串类型聚合操作符

Date Aggregation Operators

条件类型聚合操作符