PHP使用mongo-php-library操作MongoDB数据库的方法

欢迎大家来到IT世界,在知识的湖畔探索吧!

1. 介绍

1.1 介绍

福哥今天带着大家学习一下使用PHP操作MongoDB数据库的方法，虽然我们的TFLinux早就安装了MongoDB数据库了，但是还没有应用用到MongoDB数据库，福哥打算先给TFPHP框架增加操作MongoDB数据库的支持。

PHP操作MongoDB数据库有两个库，最早直接使用mongo扩展就可以操作MongoDB了，但是最新版本的MongoDB使用mongo扩展驱动不起来；另外一个就是mongodb扩展，这个mongodb扩展可以驱动最新版本的MongoDB数据库，但是需要借助一个官方的驱动库实现对MongoDB的操作，这个库就是mongo-php-library。

2. 安装

2.1 安装

MongoDB官方的PHP驱动库可以从github上面获取，地址如下：

https://github.com/mongodb/mongo-php-library

2.2 解压缩

下载完mongo-php-library-master.zip解开它，可以得到如下的内容。

欢迎大家来到IT世界,在知识的湖畔探索吧!

3. 使用

3.1 自动加载

因为MongoDB的驱动库是一套PHP代码，所以如果要使用里面众多的对象需要建立一个自动加载的机制，这里面福哥使用的是PHP的spl_autoload_register函数实现对象的自动加载的，代码如下：

include_once (FRAMEWORK_ROOT_PATH . "Extends/Driver/MongoDB/functions.php"); function MongoDB_Autoload(string $class):bool {     if(substr($class,0,8) == "MongoDB\\") {         $classPath = FRAMEWORK_ROOT_PATH . "Extends/Driver/" . str_replace("\\", "/", $class) . ".php";         if (file_exists($classPath)) {             include_once($classPath);             return true;         }     }     return false; } spl_autoload_register("MongoDB_Autoload");

欢迎大家来到IT世界,在知识的湖畔探索吧!

使用这个自动加载非常简单，只要包含这个PHP程序文件即可。

欢迎大家来到IT世界,在知识的湖畔探索吧!include_once (FRAMEWORK_ROOT_PATH . "Extends/Driver/MongoDB_Autoload.inc.php");

3.2 连接

首先我们来编写连接MongoDB数据库的代码，利用MongoDB\Client对象。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin");

初始化Client并不会触发异常，因为此时驱动不会真的去连接MongoDB数据库的。

3.3 查看数据库列表

可以使用Client::listDatabases方法获取数据库列表，当然连接账号也得有这个权限才行。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); $dbs = $client->listDatabases(); print_r($dbs);

3.4 查看数据表列表

可以使用Database::listCollections方法获取集合对象数组，或者使用Database::listCollectionNames方法获取集合名称数组。

为了测试发布，福哥先建立了两个集合a和b。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 测试查看集合列表 $collections = array(); foreach ($db->listCollections() as $collection){     $collections[] = $collection->getName(); } print_r($collections); $collectionNames = array(); foreach ($db->listCollectionNames() as $collectionName){     $collectionNames[] = $collectionName; } print_r($collectionNames);

3.5 插入数据

3.5.1 选择集合

插入新记录需要通过Collection对象，要得到Collection对象可以通过Client::selectCollection方法获取，也可以通过Database::selectCollection方法获取。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); $collectionA = $client->selectCollection("test", "a"); $collectionB = $db->selectCollection("b");

3.5.2 插入单行数据

插入单行数据通过Collection::insertOne方法，传入一个数组参数即可。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 插入数据 $collection = $db->selectCollection("a"); $collection->insertOne(array(     "id"=>35,     "name"=>"福哥",     "lang"=>"PHP" ));

3.5.3 插入多行数据

插入多行数据通过Collection::insertMany方法，传入一个二维的数组参数，每一个子元素都是一行数据。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 插入数据 $collection = $db->selectCollection("a"); $collection->insertMany(array(     array(         "id"=>35,         "name"=>"福哥",         "lang"=>"C/C++"     ),     array(         "id"=>35,         "name"=>"福哥",         "lang"=>"Java"     ),     array(         "id"=>35,         "name"=>"福哥",         "lang"=>"Python"     ), ));

3.6 更新数据

更新数据需要知道记录ID，福哥通过终端把前面插入的数据列表查询出来了，下面讲解更新数据的时候会用到。

3.6.1 更新单行数据

更新单行数据通过Collection::updateOne方法，使用“$set”关键字进行更新。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 更新数据 $collection = $db->selectCollection("a"); $collection->updateOne(     array(         "_id"=>new \MongoDB\BSON\ObjectId("60a60b0f25fc35405c6994d4")     ),     array(         '$set'=>array(             "lang"=>"PHP7.4"         )     ) );

3.6.2 更新多行数据

更新多行数据通过Collection::updateMany方法，使用“$set”关键字进行更新。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 更新数据 $collection = $db->selectCollection("a"); $collection->updateMany(     array(         "id"=>35     ),     array(         '$set'=>array(             "lang"=>"PHP, C/C++, Java, Python"         )     ) );

3.7 删除数据

3.7.1 删除单行数据

删除单行数据通过Collection::deleteOne方法实现。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 删除数据 $collection = $db->selectCollection("a"); $collection->deleteOne(     array(         "_id"=>new \MongoDB\BSON\ObjectId("60a60b0f25fc35405c6994d4")     ) );

3.7.2 删除多行数据

删除多行数据通过Collection::deleteMany方法实现。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 删除数据 $collection = $db->selectCollection("a"); $collection->deleteMany(     array(         "id"=>35     ) );

3.8 查询数据

前面测试删除数据功能已经把数据全部删除了，福哥有重新插入了几条数据以供后面测试查询数据功能使用。

3.8.1 查询单行数据

查询单行数据通过Collection::findOne方法实现。

$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 查询数据 $collection = $db->selectCollection("a"); $row = $collection->findOne(     array(         "_id"=>new \MongoDB\BSON\ObjectId("60ae505be4e08ae")     ) ); print_r($row);

3.8.2 查询多行数据

查询多行数据通过Collection::find方法实现。

欢迎大家来到IT世界,在知识的湖畔探索吧!$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin"); // 选择数据库 $db = $client->selectDatabase("test"); // 查询数据 $collection = $db->selectCollection("a"); $cursor = $collection->find(     array(         "id"=>35     ) ); foreach ($cursor as $row) {     print_r($row); }

4. 总结

今天福哥带着童鞋们系统地学习了mongo-php-library驱动库的使用方法，mongo-php-library驱动库是官方提供的用来操作MongoDB数据库的专用库。

mongo-php-library驱动库的功能非常强大，我们今后会逐步将这些功能讲解给大家，敬请期待~~

https://m.tongfu.net/home/35/blog/513315.html