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解开它，可以得到如下的内容。

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");

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

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方法获取数据库列表，当然连接账号也得有这个权限才行。

$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方法获取。

$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方法，传入一个二维的数组参数，每一个子元素都是一行数据。

$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”关键字进行更新。

$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方法实现。

$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("60a611163066e505be4e08ae")
    )
);
print_r($row);

3.8.2 查询多行数据

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

4. 总结

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

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

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