介绍
介绍
福哥今天带着大家学习一下使用PHP操作MongoDB数据库的方法，虽然我们的TFLinux早就安装了MongoDB数据库了，但是还没有应用用到MongoDB数据库，福哥打算先给TFPHP框架增加操作MongoDB数据库的支持。
PHP操作MongoDB数据库有两个库，最早直接使用mongo扩展就可以操作MongoDB了，但是最新版本的MongoDB使用mongo扩展驱动不起来；另外一个就是mongodb扩展，这个mongodb扩展可以驱动最新版本的MongoDB数据库，但是需要借助一个官方的驱动库实现对MongoDB的操作，这个库就是mongo-php-library。
安装
安装
MongoDB官方的PHP驱动库可以从github上面获取，地址如下：
https://github.com/mongodb/mongo-php-library
解压缩
下载完mongo-php-library-master.zip解开它，可以得到如下的内容。
使用
自动加载
因为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");使用这个自动加载非常简单，只要包含这个PHP程序文件即可。
include_once (FRAMEWORK_ROOT_PATH . "Extends/Driver/MongoDB_Autoload.inc.php");
连接
首先我们来编写连接MongoDB数据库的代码，利用MongoDB\Client对象。
$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin");初始化Client并不会触发异常，因为此时驱动不会真的去连接MongoDB数据库的。
查看数据库列表
可以使用Client::listDatabases方法获取数据库列表，当然连接账号也得有这个权限才行。
$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin");
$dbs = $client->listDatabases();
print_r($dbs);
查看数据表列表
可以使用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);
插入数据
选择集合
插入新记录需要通过Collection对象，要得到Collection对象可以通过Client::selectCollection方法获取，也可以通过Database::selectCollection方法获取。
$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin");
// 选择数据库
$db = $client->selectDatabase("test");
$collectionA = $client->selectCollection("test", "a");
$collectionB = $db->selectCollection("b");插入单行数据
插入单行数据通过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"
));插入多行数据
插入多行数据通过Collection::insertMany方法，传入一个二维的数组参数，每一个子元素都是一行数据。
$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"
),
));更新数据
更新数据需要知道记录ID，福哥通过终端把前面插入的数据列表查询出来了，下面讲解更新数据的时候会用到。
更新单行数据
更新单行数据通过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"
)
)
);更新多行数据
更新多行数据通过Collection::updateMany方法，使用“$set”关键字进行更新。
$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"
)
)
);删除数据
删除单行数据
删除单行数据通过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")
)
);删除多行数据
删除多行数据通过Collection::deleteMany方法实现。
$client = new \MongoDB\Client("mongodb://root:abcdef@localhost:27017/admin");
// 选择数据库
$db = $client->selectDatabase("test");
// 删除数据
$collection = $db->selectCollection("a");
$collection->deleteMany(
array(
"id"=>35
)
);查询数据
前面测试删除数据功能已经把数据全部删除了，福哥有重新插入了几条数据以供后面测试查询数据功能使用。
查询单行数据
查询单行数据通过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("60a611163066e505be4e08ae")
)
);
print_r($row);
查询多行数据
查询多行数据通过Collection::find方法实现。
$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);
}
总结
今天福哥带着童鞋们系统地学习了mongo-php-library驱动库的使用方法，mongo-php-library驱动库是官方提供的用来操作MongoDB数据库的专用库。
mongo-php-library驱动库的功能非常强大，我们今后会逐步将这些功能讲解给大家，敬请期待~~