同福

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

介绍

介绍

福哥今天带着大家学习一下使用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解开它,可以得到如下的内容。

home/topic/2021/0520/14/fc9cdc1a113a13d17ea783016a88eb2f.png

使用

自动加载

因为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);

home/topic/2021/0520/14/46870633a40af3c438c227889fd63b53.png

查看数据表列表

可以使用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);

home/topic/2021/0520/15/bfacec54240fd3c7f432e1ed84a0b517.png

插入数据

选择集合

插入新记录需要通过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,福哥通过终端把前面插入的数据列表查询出来了,下面讲解更新数据的时候会用到。

home/topic/2021/0520/15/108ec0ab4746f370066be8eda5aede31.png

更新单行数据

更新单行数据通过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
    )
);

查询数据

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

home/topic/2021/0520/15/87d33e3b879e0b0a206489061a75b4ac.png

查询单行数据

查询单行数据通过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);

home/topic/2021/0520/15/6b3192b55eaff9c971238cac90b053e9.png

查询多行数据

查询多行数据通过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);
}

home/topic/2021/0520/15/cbeaa4d03ea08cf9d1741c9b9a912e49.png

总结

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

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