集装成类（抛砖引玉）

<?php
/**
 * @filesource  :  mongodb.php
 * @Author      :  GLS
 * @copyright   :  Copyright (C) 2010-2012 GLS IT Studio NY
 * @access      :  gotodiscuss@gmail.com
 * @version     :  Created on Dec 6, 2010 10:12:19 AM
 * @Github      :  https://github.com/phpish``````````````````````````````````````````````````
 *
 */

defined('BASEPATH') or die('Restricted access');

include_once rtrim(dirname(__FILE__), '/').'/vendor/autoload.php';

class Mongodb
{
    private $host;
    private $port = 27017;
    private $username;
    private $password;
    private $dbname;
    private $table;
    private $client;
    private $collection;
    private $mongodb_link;

    function __construct($info = array())
    {
        $this->host         = $info['host']     ?? false;
        $this->port         = $info['port']     ?? 27017;
        $this->username     = $info['username'] ?? false;
        $this->password     = $info['password'] ?? false;
        $this->dbname       = $info['dbname']   ?? false;
        $this->table        = $info['table']    ?? false;
        $this->mongodb_link = $info['link']     ?? false;

        if(($this->host AND $this->username AND $this->username) OR $this->mongodb_link)
        {
            //连接本地服务
            $mongodb_link = $info['link'] ?? $this->username.':'.$this->password.'@'.$this->host.':'.$this->port;
            $this->client = new MongoDB\Client('mongodb://'.str_ireplace('mongodb://', '', $mongodb_link));
        }

        return $this;
    }

    function collection($table = '', $dbname = '')
    {
        if($table)  $this->table  = $table;
        if($dbname) $this->dbname = $dbname;

        //选择数据库和集合
        if($this->dbname AND $this->table) $this->collection = $this->client->{$this->dbname}->{$this->table};
        return $this;
    }

    function get()
    {
        return $this->collection;
    }

    function client()
    {
        return $this->client;
    }

    // $data = array('name'=>'justcode','sex'=>'male');
    function insert($data = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($data)
        {
            $rv = array_filter($data,'is_array');
            if(count($rv)>0) $output = $this->multi_insert($data, $table, $dbname);
            else
            {
                $result = $this->collection->insertOne($data);
                $output = $result->getInsertedId();
            }
        }

        return $output;
    }

    // $data = array(array('name'=>'justcode','sex'=>'male'),array('name'=>'DullCat','sex'=>'male'));
    function multi_insert($data = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($data)
        {
            $result = $this->collection->insertMany($data);
//        $ids_info = $result->getInsertedIds();
//        foreach($ids_info as $value){
//            $ids [] = $value->__toString();
//        }
            //拿到插入的个数
            $output = $result->getInsertedCount();
        }

        return $output;
    }

    //如果没有找到,返回值为null
    //返回值是一个对象,这里我们可以将他强制类型转换`$info = (array)$info`
    function find_by_id($id = '', $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($id)
        {
            $mongo_id = new MongoDB\BSON\ObjectId($id);
            $output = $this->collection->findOne(array('_id'=>$mongo_id));
        }

        return $output;
    }

    // $data = array('name'=>'DullCat')
    //第一个数组的查询条件要注意下`$gt`这是查询选择器,表示大于
    //第二个数组的选项意义为:`skip`跳过0条数据,`limit`查询10条数据,`sort`按age字段正序排序(1为正序,-1为倒序)
    // $data = array('name'=>'justcode','age'=>array('$gt'=>'1')),array('skip'=>0,'limit'=>10,'sort'=>array('age'=>1))
    //多个查询有两个数组参数,第一个是查询的条件,第二个是选项
    function find($where = array(), $options = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $info   = $this->collection->find($where, $options);
        $output = $info->toArray();

        return $output;
    }

    //计算合计 MongoDB\Collection::count
    //function count($filter = [], array $options = []): integer
    function count($where = array(), $options = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);
        return $this->collection->count($where, $options);
    }

    //update方法有三个数组参数
    //第一个数组是查询条件
    //第二数组是更新操作符,例如下面的`array('$set'=>array('age'=>'23'))`,意义为:更改age字段为23
    //第三个数组是选项,可以选择各种参数,例如下面的`array('upsert'=>true)`,意义为当能查询到就进行更改,如果没有查询到就进行新增操作
    /**
    原生语句
    db.user.updateOne(
    { "name": "dullcat" },
    {$set: { "age": "123" }},
    { upsert: true }
    )
     */
    function update($where = array(), $data = array(), $options = array(),  $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($where AND $data) $output = $this->collection->updateOne($where, $data, $options);

        return $output;
    }

    function multi_update($where = array(), $data = array(), $options = array(),  $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($where AND $data) $output = $this->collection->updateMany($where, $data, $options);

        return $output;
    }

//    单个删除deleteOne
//    原生语句:db.users.deleteOne( { name: "justcode" } )
//    多个删除deleteMany
//    原生语句:db.users.deleteMany( { name: "justcode" } )
//    单个删除和多个删除的用法一模一样,只是单个删除只删除查询到的第一条数据,而多个删除则删除匹配到的所有数据
    function delete($where = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($where) $output = $this->collection->deleteOne($where);

        return $output;
    }

    function multi_delete($where = array(), $table = '', $dbname = '')
    {
        if($table OR $dbname) $this->collection($table, $dbname);

        $output = false;

        if($where) $output = $this->collection->deleteMany($where);

        return $output;
    }
}

用法：

#方法一，引用自定义方法
$mongo = new Mongodb(array('link' => 'mongodb://username:password@host:port'));
$mongo->collection('table_name', 'db_name');
$data = $mongo->find([], ['limit'=>10]);

#方法二， 引用collection
$mongo = new Mongodb(array('link' => 'mongodb://username:password@host:port'));
$db = $mongo->collection('table_name', 'db_name')->get();
$data = $db->find(); // 可以调用任何原生方法

Query Selectors

Projection Operators