colly_wyx
2018-06-13 e4d5467f055ece8cc9dfdc02dd836bcc187034a5
Library/Mongo/Lite.php
@@ -374,6 +374,21 @@
    }
    /**
     * 聚合
     * @param  [type] $colName [description]
     * @param  [type] $params  [description]
     * @return [type]          [description]
     */
    public function aggregate($colName, $params){
        $col = $this->_getCol($colName);
        // 自动处理 '_id' 字段
        //$query = $this->_parseId($query);
        $result = $col->aggregate($params);
        return $result['result'];
    }
    /**
     * 统计文档记录数
     *
     * @param string $colName 集合名
@@ -543,7 +558,12 @@
    // 解析数据组中的'_id'字段(如果有的话)
    private function _parseId($arr){
        if(isset($arr['_id'])){
            $arr['_id'] = new MongoId($arr['_id']);
            try{
                $arr['_id'] = new MongoId($arr['_id']);
            }
            catch(MongoException $ex){
                die('非法的对象id');
            }
        }
        return $arr;
    }