php7 mongodb distinct及count方法
关键词: 发布时间:2018-08-17 15:55:15 浏览次数:574
<?php

final class MongoDB
{
    private static $ins = [];

    private static $def = "default";

    private $_conn = null;

    private static $_config = [
        "default" => ["url" => "mongodb://192.168.1.233:27017", "dbName" => "test"],
        "localhost" => ["url" => "mongodb://localhost:27017", "dbName" => "test"],
        "db1" => ["url" => "mongodb://username:password@localhost:27017", "dbName" => "myDb1"],
    ];

    private $_db = null;


    /**
     * 创建实例
     * @param  string $confKey
     * @return \MongoDB
     */
    static function getInstance($confKey = NULL)
    {
        if (!$confKey) {
            $confKey = self::$def;
        }
        if (!isset(self::$ins[$confKey]) && ($conf = self::$_config[$confKey])) {
            $m = new MongoDB($conf);
            self::$ins[$confKey] = $m;
        }
        return self::$ins[$confKey];
    }


    /**
     * 构造方法-单例模式
     * MongoDB constructor.
     * @param array $conf
     */
    private function __construct(array $conf)
    {
        $this->_conn = new \MongoDB\Driver\Manager($conf["url"] . "/{$conf["dbName"]}");
        $this->_db = $conf["dbName"];
    }


    /**
     * 插入数据
     * @param  string $collName
     * @param  array $documents [["name"=>"values", ...], ...]
     * @param  array $writeOps ["ordered"=>boolean,"writeConcern"=>array]
     * @return \MongoDB\Driver\Cursor
     */
    function insert($collName, array $documents, array $writeOps = [])
    {
        $cmd = [
            "insert" => $collName,
            "documents" => $documents,
        ];
        $cmd += $writeOps;
        return $this->command($cmd);
    }


    /**
     * 删除数据
     * @param  string $collName
     * @param  array $deletes [["q"=>query,"limit"=>int], ...]
     * @param  array $writeOps ["ordered"=>boolean,"writeConcern"=>array]
     * @return \MongoDB\Driver\Cursor
     */
    function del($collName, array $deletes, array $writeOps = [])
    {
        foreach ($deletes as &$_) {
            if (isset($_["q"]) && !$_["q"]) {
                $_["q"] = (Object)[];
            }
            if (isset($_["limit"]) && !$_["limit"]) {
                $_["limit"] = 0;
            }
        }
        $cmd = [
            "delete" => $collName,
            "deletes" => $deletes,
        ];
        $cmd += $writeOps;
        return $this->command($cmd);
    }


    /**
     * 更新数据
     * @param  string $collName
     * @param  array $updates [["q"=>query,"u"=>update,"upSet"=>boolean,"multi"=>boolean], ...]
     * @param  array $writeOps ["ordered"=>boolean,"writeConcern"=>array]
     * @return \MongoDB\Driver\Cursor
     */
    function update($collName, array $updates, array $writeOps = [])
    {
        $cmd = [
            "update" => $collName,
            "updates" => $updates,
        ];
        $cmd += $writeOps;
        return $this->command($cmd);
    }

    /**
     * 查询
     * @param  string $collName
     * @param  array $filter [query]
     * @param  array $writeOps
     * @return \MongoDB\Driver\Cursor
     */
    function query($collName, array $filter, array $writeOps = [])
    {
        $cmd = [
            "find" => $collName,
            "filter" => $filter
        ];
        $cmd += $writeOps;
        return $this->command($cmd);
    }

    /**
     * 执行MongoDB命令
     * @param array $param
     * @return \MongoDB\Driver\Cursor
     */
    function command(array $param)
    {
        $cmd = new \MongoDB\Driver\Command($param);
        // print_r($cmd);exit();
        return $this->_conn->executeCommand($this->_db, $cmd);
    }

    /**
     * 获取当前mongoDB Manager
     * @return \MongoDB\Driver\Manager
     */
    function getMongoManager()
    {
        return $this->_conn;
    }

    /**
     * 聚合查询
     * @param $collName
     * @param array $where
     * @param array $group
     * @return \MongoDB\Driver\Cursor
     */
    function aggregate($collName, array $where, array $group)
    {
        $cmd = [
            'aggregate' => $collName,
            'pipeline' => [
                ['$match' => $where],
                ['$group' => $group]
            ]
        ];
        //print_r($cmd);exit();
        $result = $this->command($cmd)->toArray();
        // print_r($result);exit();
        return $result[0]->result;
    }

    /**
     * 同mysql中的distinct功能
     *
     * @param string $collName collection名
     * @param string $key 要进行distinct的字段名
     * @param array $where 条件
     * @return array
     * Array
     * (
     * [0] => 1.0
     * [1] => 1.1
     * )
     */
    function distinct($collName, $key, array $where)
    {
        $result = [];
        $cmd = [
            'distinct' => $collName,
            'key' => $key,
            'query' => $where
        ];
        $arr = $this->command($cmd)->toArray();
        if (!empty($arr)) {
            $result = $arr[0]->values;
        }
        return $result;
    }

    /**
     * 按条件计算个数
     *
     * @param string $collName 集合名
     * @param array $where 条件
     * @return int
     */
    function count($collName, array $where)
    {
        $result = 0;
        $cmd = [
            'count' => $collName,
            'query' => $where
        ];
        $arr = $this->command($cmd)->toArray();
        if (!empty($arr)) {
            $result = $arr[0]->n;
        }
        return $result;
    }


}


赞:(5)
踩:(25)
相关文章
php7中使用mongodb的aggregate进行
php操作mongodb
mongodb学习网址及基础教程
mongodb数据库添加及删除
mongodb集合创建与删除
mongodb文档添加与更新
mongodb文档查询
php7 mongodb操作类
mongodb基础知识
windows10下安装mongodb
热门文章
win7中将文件拷贝到虚拟机linux下
php中用uploadify上传时session丢
laravel页面静态化的方法
centos7.4 64位下swoole安装及配置
centos7.4下php7.25多线程pthreads
微信扫一扫在哪
php-fpm经常卡死
单点登录sso原理及php实现方式及de
phpexcel设置行高及列宽,背景颜色,
一个简单的laravel分表联合查询
好评文章
php7中使用mongodb的aggregate进行
windows下使用MongoDB Compass Com
phpexcel设置行高及列宽,背景颜色,
laravel 中悲观锁 & 乐观锁的使用
laravel整合dingo/api方法步骤:jwt
在php中用curl请求java接口无法获
laravel页面静态化的方法
一个简单的laravel分表联合查询
laravel对具体的路由不采用csrfTok
php7 mongodb distinct及count方法
标签
rabbitmq mysql备份 elasticsearch
站点信息
建站时间:2011年
文章数:500篇
浏览数:253628
粤ICP备18028092号-1  微信:hurong241