Share several methods of mongodb encapsulation

The content of this article is about sharing several methods of mongodb encapsulation. It has certain reference value. Now I share it with everyone. Friends in need can refer to it.

This is php5 I wrote .6, but this is not the case for php7 and above. If you have the encapsulation class of php7mongodb, you can send me the link. I will take a look

<?php/**
 * Created by sublime.
 * User: yuepeng
 * Date: 2017/12/1
 * Time: 15:44
 */namespace Lib;use MongoClient;//下面是驱动类，现在没有用到，我的版本php5.5，如果是php7就要用到这些类use MongoDB\BSON\ObjectID;use MongoDB\Driver\BulkWrite;use MongoDB\Driver\Command;use MongoDB\Driver\Cursor;use MongoDB\Driver\Exception\AuthenticationException;use MongoDB\Driver\Exception\BulkWriteException;use MongoDB\Driver\Exception\ConnectionException;use MongoDB\Driver\Exception\InvalidArgumentException;use MongoDB\Driver\Exception\RuntimeException;use MongoDB\Driver\Manager;use MongoDB\Driver\Query as MongoQuery;use MongoDB\Driver\ReadPreference;use MongoDB\Driver\WriteConcern;/**
 * PHP操作mongodb数据库操作类
 */class MongoDb {
    protected $database    = &#39;&#39;;    protected $mo;    /**
     * 构造方法
     */
    public function __construct() {
        $database = DBNAME;        $mongo = $this->getConnect(DBSERVER, DBUSER, DBPASS, DBPORT);        $this->database = $mongo->$database;
    }    /**
     * 数据库单例方法
     * @param $server
     * @param $user
     * @param $password
     * @param $port
     * test 测试
     * @return Mongo
     */
    /*public function getConnect($server, $user, $password, $port)
    {
        // echo "mongodb://{$server}:{$port}";die;
        // $mongo = new MongoClient("mongodb://{$server}:{$port}");
        $mongo = new MongoClient("mongodb://{$server}:{$port}");
        return $mongo;
    }*/
    /**
     * 数据库单例方法
     * @param $server
     * @param $user
     * @param $password
     * @param $port
     * @return Mongo
     */
    public function getConnect($server, $user, $password, $port) {
        if (isset($this->mo)) {            return $this->mo;
        } else {            if (!empty($server)) {                if (!empty($port)) {                    if (!empty($user) && !empty($password)) {                        $this->mo = new MongoClient("mongodb://{$user}:{$password}@{$server}:{$port}");
                    } else {                        $this->mo = new MongoClient("mongodb://{$server}:{$port}");
                    }
                } else {                    $this->mo = new MongoClient("mongodb://{$server}");
                }
            } else {                $this->mo = new MongoClient();
            }            return $this->mo;
        }
    }    /**
     * 查询表中所有数据
     * @param $table
     * @param array $where
     * @param array $sort
     * @param string $limit
     * @param string $skip
     * @return array|int
     */
    public function getAll($table, $where = array(), $sort = array(), $limit = &#39;&#39;, $skip = &#39;&#39;) {
        if (!empty($where)) {            $data = $this->database->$table->find($where);
        } else {            $data = $this->database->$table->find();
        }        if (!empty($sort)) {            $data = $data->sort($sort);
        }        if (!empty($limit)) {            $data = $data->limit($limit);
        }        if (!empty($skip)) {            $data = $data->skip($skip);
        }        $newData = array();        while ($data->hasNext()) {            $newData[] = $data->getNext();
        }        if (count($newData) == 0) {            return 0;
        }        return $newData;
    }    /**
     * 查询表中所有数据，将_id 对象变成数组
     * @param $table
     * @param array $where
     * @param array $sort
     * @param string $limit
     * @param string $skip
     * @return array
     */
    public function getAllArray($table, $where = array(), $sort = array(), $limit = &#39;&#39;, $skip = &#39;&#39;) {
        if (!empty($where)) {            $data = $this->database->$table->find($where);
        } else {            $data = $this->database->$table->find();
        }        if (!empty($sort)) {            $data = $data->sort($sort);
        }        if (!empty($limit)) {            $data = $data->limit($limit);
        }        if (!empty($skip)) {            $data = $data->skip($skip);
        }        $newData = array();        while ($data->hasNext()) {            $newData[] = $data->getNext();
        }        if (count($newData) == 0) {            return 0;
        }        foreach ($newData as $key => $val) {            $id = $val[&#39;_id&#39;]->{&#39;$id&#39;};            $newData[$key][&#39;_id&#39;] = $id;
        }        return $newData;
    }    /**
     * 查询指定一条数据
     * @param $table
     * @param array $where
     * @return int
     */
    public function getOne($table, $where = array()) {
        if (!empty($where)) {            $data = $this->database->$table->findOne($where);
        } else {            $data = $this->database->$table->findOne();
        }        return $data;
    }    /**
     * 统计个数
     * @param $table
     * @param array $where
     * @return mixed
     */
    public function getCount($table, $where = array()) {
        if (!empty($where)) {            $data = $this->database->$table->find($where)->count();
        } else {            $data = $this->database->$table->find()->count();
        }        return $data;
    }    /**
     * 直接执行mongo命令
     * @param $sql
     * @return array
     */
    public function toExcute($sql) {
        $result = $this->database->execute($sql);        return $result;
    }    /**
     * 分组统计个数
     * @param $table
     * @param $where
     * @param $field
     */
    public function groupCount($table, $where, $field) {
        $cond = array(            array(                &#39;$match&#39; => $where,
            ),            array(                &#39;$group&#39; => array(                    &#39;_id&#39; => &#39;$&#39; . $field,                    &#39;count&#39; => array(&#39;$sum&#39; => 1),
                ),
            ),            array(                &#39;$sort&#39; => array("count" => -1),
            ),
        );        $this->database->$table->aggregate($cond);
    }    /**
     * 删除数据
     * @param $table
     * @param $where
     * @return array|bool
     */
    public function toDelete($table, $where) {
        $re = $this->database->$table->remove($where);        return $re;
    }    /**
     * 插入数据
     * @param $table
     * @param $data
     * @return array|bool
     */
    public function toInsert($table, $data) {
        $re = $this->database->$table->insert($data);        return $re;
    }    /**
     * 更新数据
     * @param $table
     * @param $where
     * @param $data
     * @return bool
     */
    public function toUpdate($table, $where, $data) {
        $re = $this->database->$table->update($where, array(&#39;$set&#39; => $data));        return $re;
    }    /**
     * 获取唯一数据
     * @param $table
     * @param $key
     * @return array
     */
    public function distinctData($table, $key, $query = array()) {
        if (!empty($query)) {            $where = array(&#39;distinct&#39; => $table, &#39;key&#39; => $key, &#39;query&#39; => $query);
        } else {            $where = array(&#39;distinct&#39; => $table, &#39;key&#39; => $key);
        }        $data = $this->database->command($where);        return $data[&#39;values&#39;];
    }
}?>

Related recommendations:

php- How to use mongodb extension

The above is the detailed content of Share several methods of mongodb encapsulation. For more information, please follow other related articles on the PHP Chinese website!