升级PHP7操作MongoDB的方法介绍

这篇文章主要为大家详细介绍了升级PHP7操作MongoDB的方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。

前言

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

详情请见官方手册:https://www.php.net/manual/zh/book.mongo.php

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

详情也可参见官方手册:https://www.php.net/manual/zh/set.mongodb.php

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

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

MongoDB 驱动

如果使用原驱动的话,大致语法如下:

<?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' => 'localhost',
            'port' => '27017',
            'username' => '',
            'password' => '',
            'database' => 'test'
        ];
    public function __construct($config) {
        $config = array_merge($this->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->mongodb = new Manager($mongoServer);
        $this->database = $config['database'];
        $this->collection = $config['collection'];
        $this->bulk = new BulkWrite();
        $this->writeConcern = new WriteConcern(WriteConcern::MAJORITY, 100);
    }
    public function query($where = [], $option = []) {
        $query = new Query($where, $option);
        $result = $this->mongodb->executeQuery("$this->database.$this->collection", $query);
        return json_encode($result);
    }
    public function count($where = []) {
        $command = new Command(['count' => $this->collection, 'query' => $where]);
        $result = $this->mongodb->executeCommand($this->database, $command);
        $res = $result->toArray();
        $count = 0;
        if ($res) {
            $count = $res[0]->n;
        }
        return $count;
    }
    public function update($where = [], $update = [], $upsert = false) {
        $this->bulk->update($where, ['$set' => $update], ['multi' => true, 'upsert' => $upsert]);
        $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
        return $result->getModifiedCount();
    }
    public function insert($data = []) {
        $this->bulk->insert($data);
        $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
        return $result->getInsertedCount();
    }
    public function delete($where = [], $limit = 1) {
        $this->bulk->delete($where, ['limit' => $limit]);
        $result = $this->mongodb->executeBulkWrite("$this->database.$this->collection", $this->bulk, $this->writeConcern);
        return $result->getDeletedCount();
    }
}

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

MongoDB 库

1.连接

new MongoClient();

new MongoDB\Client();

2.新增

$collention->insert($array, $options);

$resultOne = $collention->insertOne($array, $options);//单
$lastId = $resultOne->getInsertedId();
$resultMany = $collention->insertMany($array, $options);//多
$count = $resultMany->getInsertedCount();

3.修改

$collention->update($condition, [
    '$set' => $values
,[
    'multiple' => true//多条,单条false
]);

$collection->updateOne(
    ['state' => 'ny'],
    ['$set' => ['country' => 'us']]
);
$updateResult = $collection->updateMany(
    ['state' => 'ny'],
    ['$set' => ['country' => 'us']]
);
$count = $updateResult->getModifiedCount();

4.查询

$cursor = $collection->find($condition, [
    'name' => true//指定字段
]);
$cursor->skip(5);
$cursor->limit(5);
$cursor->sort([
    'time' => -1
]);

$cursor = $collection->find($condition, [
    'skip' => 5,
    'limit' => 5,
    'sort' => [
        'time' => -1
    ],//排序
    'projection' => [
        'name' => 1//指定字段
    ]
]);

5.删除

$collention->remove($condition, [
    'justOne' => false//删单条
]);
$collention->remove([]);//删所有

$result = $collention->deleteOne($condition, $options);
$collention->deleteMany($condition, $options);
$result->getDeletedCount();

补充

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

$collention->findAndModify([
    '_id' => $tableName//我在自增表中用其它的表名作主键
], [
    '$inc' => ['id' => 1]//自增
], [
    '_id' => 0
], [
    'new' => 1//返回修改后的结果,默认是修改前的
]);

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

$collention->findOneAndUpdate([
    '_id' => $tableName
], [
    '$inc' => ['id' => 1]
], [
    'projection' => ['id' => 1],
    'returnDocument' => MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
]);

以上就是升级PHP7操作MongoDB方法的简略介绍,当然详细使用上面的不同还得要大家自己使用过才领会。如果想了解更多,欢迎关注网站那些事行业资讯频道哦!

原创文章,作者:PGDUZ,如若转载,请注明出处:https://www.wangzhanshi.com/n/7123.html

(0)
PGDUZ的头像PGDUZ
上一篇 2025年1月1日 16:38:10
下一篇 2025年1月1日 16:38:12

相关推荐

  • php7 mysql如何扩展安装

    php mysql安装方法:首先下载mysql扩展;然后解压并使用phpize工具初始化;接着进行configure,并执行“make && make instal…

    2025年1月1日
  • centos6与centos7安装php7的方法

    centos 7/6都可以 下载链接(当前最新版本是7.4.5) php官网 wget https://www.php.net/distributions/php-7.4…

    2025年1月1日
  • PHP8中Attributes的介绍

    这篇文章将为大家带来有关PHP8中Attributes的介绍,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。 说注解之前,先说说以前的注释,我们经…

    php 2025年1月2日
  • PHP7中有什么新特性

    php是什么语言 php,一个嵌套的缩写名称,是英文超级文本预处理语言(PHP:Hypertext Preprocessor)的缩写。PHP 是一种 HTML 内嵌式的语言,PHP…

    php 2025年1月1日
  • golang如何调用php7

    执行php文件 func Test_exec(t *testing.T) { engine.Initialize() ctx := &engine.Context{ Out…

    php 2025年1月1日
  • 本地Apache服务器怎么添加php7模块

    Apache的一些基础命令 Options:   -D name       &…

    php 2025年1月1日
  • phpstudy无法启动MySQL服务的解决方法

    解决phpstudy无法启动MySQL服务 使用phpstudy的理由: 因为MySQL的服务默认自动打开我的电脑每次重启都需要我去任务管理器中把mysqld删掉然后再用管理员身份…

    2024年12月17日
  • 如何安装php7和php5共存

    安装php7,与php5共存 起步 之前在服务器搭建了lamp环境,想换用性能更强的nginx作为服务器软件,又想将php5升级为php7.安装nginx无需赘述:sudo apt…

    php 2025年1月1日
  • PHP7带来的好处有哪些

    由于php升级乃头等大事,公司近期才打算升级,所以之前一直只能私下欣赏php7带来的快感 PHP7带来的好处 是的,性能上的大幅度提升,可以省机器,可以省钱。 PHP7带来的新东西…

    2025年1月1日
  • PHP7实现daemon守护进程的案例分析

    在一个多任务的计算机操作系统中,守护进程是一种在后台执行的计算机程序。此类程序会被以进程的形式初始化。守护进程程序的名称通常以字母“d”结尾:例如,syslogd就是指管理系统日志…

    php 2025年1月1日

发表回复

登录后才能评论