升级PHP7操作MongoDB

前言

使用 PHP+MongoDB 的用户很多，因为 MongoDB 对非结构化数据的存储很方便。在 PHP5 及以前，官方提供了两个扩展，Mongo 和 MongoDB，其中 Mongo 是对以 MongoClient 等几个核心类为基础的类群进行操作，封装得很方便，所以基本上都会选择 Mongo 扩展。

详情请见官方手册：http://php.net/manual/zh/book...

但是随着 PHP5 升级到 PHP7，官方不再支持 Mongo 扩展，只支持 MongoDB，而 PHP7 的性能提升巨大，让人无法割舍，所以怎么把 Mongo 替换成 MongoDB 成为了一个亟待解决的问题。MongoDB 引入了命名空间，但是功能封装非常差，如果非要用原生的扩展，几乎意味着写原生的 Mongo 语句。这种想法很违背 ORM 简化 DB IO 操作带来的语法问题而专注逻辑优化的思路。

详情也可参见官方手册：http://php.net/manual/zh/set....

在这种情况之下，MongoDB 官方忍不住了，为了方便使用，增加市场占有率，推出了基于MongoDB 扩展的库：https://github.com/mongodb/mo...

该库的详细文档见：https://docs.mongodb.com/php-...

MongoDB 驱动

如果使用原驱动的话，大致语法如下：

&lt;?php

use MongoDB\Driver\Manager;

use MongoDB\Driver\BulkWrite;

use MongoDB\Driver\WriteConcern;

use MongoDB\Driver\Query;

use MongoDB\Driver\Command;

class MongoDb {

    protected $mongodb;

    protected $database;

    protected $collection;

    protected $bulk;

    protected $writeConcern;

    protected $defaultConfig

        = [

            'hostname' =&gt; 'localhost',

            'port' =&gt; '27017',

            'username' =&gt; '',

            'password' =&gt; '',

            'database' =&gt; 'test'

        ];

    public function __construct($config) {

        $config = array_merge($this-&gt;defaultConfig, $config);

        $mongoServer = "mongodb://";

        if ($config['username']) {

            $mongoServer .= $config['username'] . ':' . $config['password'] . '@';

        }

        $mongoServer .= $config['hostname'];

        if ($config['port']) {

            $mongoServer .= ':' . $config['port'];

        }

        $mongoServer .= '/' . $config['database'];

        $this-&gt;mongodb = new Manager($mongoServer);

        $this-&gt;database = $config['database'];

        $this-&gt;collection = $config['collection'];

        $this-&gt;bulk = new BulkWrite();

        $this-&gt;writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);

    }

    public function query($where = [], $option = []) {

        $query = new Query($where, $option);

        $result = $this-&gt;mongodb-&gt;executeQuery("$this-&gt;database.$this-&gt;collection", $query);

        return json_encode($result);

    }

    public function count($where = []) {

        $command = new Command(['count' =&gt; $this-&gt;collection, 'query' =&gt; $where]);

        $result = $this-&gt;mongodb-&gt;executeCommand($this-&gt;database, $command);

        $res = $result-&gt;toArray();

        $count = 0;

        if ($res) {

            $count = $res[0]-&gt;n;

        }

        return $count;

    }

    public function update($where = [], $update = [], $upsert = false) {

        $this-&gt;bulk-&gt;update($where, ['$set' =&gt; $update], ['multi' =&gt; true, 'upsert' =&gt; $upsert]);

        $result = $this-&gt;mongodb-&gt;executeBulkWrite("$this-&gt;database.$this-&gt;collection", $this-&gt;bulk, $this-&gt;writeConcern);

        return $result-&gt;getModifiedCount();

    }

    public function insert($data = []) {

        $this-&gt;bulk-&gt;insert($data);

        $result = $this-&gt;mongodb-&gt;executeBulkWrite("$this-&gt;database.$this-&gt;collection", $this-&gt;bulk, $this-&gt;writeConcern);

        return $result-&gt;getInsertedCount();

    }

    public function delete($where = [], $limit = 1) {

        $this-&gt;bulk-&gt;delete($where, ['limit' =&gt; $limit]);

        $result = $this-&gt;mongodb-&gt;executeBulkWrite("$this-&gt;database.$this-&gt;collection", $this-&gt;bulk, $this-&gt;writeConcern);

        return $result-&gt;getDeletedCount();

    }

}

这样的语法和之前差异太大，改动不方便，换 PHP MongoDB 库

MongoDB 库

1.连接

new MongoClient();

new MongoDB\Client();

2.新增

$collention-&gt;insert($array, $options);

$resultOne = $collention-&gt;insertOne($array, $options);//单

$lastId = $resultOne-&gt;getInsertedId();

$resultMany = $collention-&gt;insertMany($array, $options);//多

$count = $resultMany-&gt;getInsertedCount();

3.修改

$collention-&gt;update($condition, [

    '$set' =&gt; $values

,[

    'multiple' =&gt; true//多条，单条false

]);

$collection-&gt;updateOne(

    ['state' =&gt; 'ny'],

    ['$set' =&gt; ['country' =&gt; 'us']]

);

$updateResult = $collection-&gt;updateMany(

    ['state' =&gt; 'ny'],

    ['$set' =&gt; ['country' =&gt; 'us']]

);

$count = $updateResult-&gt;getModifiedCount();

4.查询

$cursor = $collection-&gt;find($condition, [

    'name' =&gt; true//指定字段

]);

$cursor-&gt;skip(5);

$cursor-&gt;limit(5);

$cursor-&gt;sort([

    'time' =&gt; -1

]);

$cursor = $collection-&gt;find($condition, [

    'skip' =&gt; 5,

    'limit' =&gt; 5,

    'sort' =&gt; [

        'time' =&gt; -1

    ],//排序

    'projection' =&gt; [

        'name' =&gt; 1//指定字段

    ]

]);

5.删除

$collention-&gt;remove($condition, [

    'justOne' =&gt; false//删单条

]);

$collention-&gt;remove([]);//删所有

$result = $collention-&gt;deleteOne($condition, $options);

$collention-&gt;deleteMany($condition, $options);

$result-&gt;getDeletedCount();

补充

有些人可能习惯以类似 MySQL 的自增 ID 来处理数据，以前可能使用 findAndModify() 方法来查询并修改：

$collention-&gt;findAndModify([

    '_id' =&gt; $tableName//我在自增表中用其它的表名作主键

], [

    '$inc' =&gt; ['id' =&gt; 1]//自增

], [

    '_id' =&gt; 0

], [

    'new' =&gt; 1//返回修改后的结果，默认是修改前的

]);

现在使用 MongoDB 库的话需要修改为：

$collention-&gt;findOneAndUpdate([

    '_id' =&gt; $tableName

], [

    '$inc' =&gt; ['id' =&gt; 1]

], [

    'projection' =&gt; ['id' =&gt; 1],

    'returnDocument' =&gt; MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER

]);

类似的还有 findOneAndDelete() findOneAndReplace()，更多内容可见文档

原文地址：https://segmentfault.com/a/1190000015738271

巴特西