MongoDB 提供了一个专门的 PHP 扩展（mongodb），使得 PHP 开发者能够与 MongoDB 数据库进行高效交互。这个扩展是由 MongoDB 官方提供的，支持 MongoDB 4.x 和更高版本。

1. 安装 MongoDB PHP 扩展

在使用 MongoDB 扩展之前，你需要先安装 MongoDB PHP 驱动程序。你可以通过 Composer 或直接从 PECL 安装。

通过 Composer 安装

使用 Composer 安装 MongoDB PHP 扩展的方式最为推荐：

composer require mongodb/mongodb

这将自动下载并安装 MongoDB PHP 扩展以及所有的依赖项。

通过 PECL 安装

你也可以直接从 PECL 安装 MongoDB 扩展：

pecl install mongodb

然后，在你的 PHP 配置文件（通常是 php.ini）中启用该扩展：

extension=mongodb.so

2. 连接到 MongoDB 数据库

安装好扩展后，你可以通过 MongoDB 的 PHP 客户端与数据库进行交互。

基本连接

<?php
require 'vendor/autoload.php';  // 引入 Composer 自动加载文件

$client = new MongoDB\Client("mongodb://localhost:27017");  // 连接到 MongoDB 实例

// 选择数据库
$database = $client->selectDatabase('test');

// 选择集合
$collection = $database->selectCollection('users');
?>

连接 URI

连接字符串支持以下功能：

• mongodb://username:password@host1,host2/?options
• 认证、连接池、SSL 等选项都可以在连接字符串中设置。

3. CRUD 操作

插入文档

<?php
$document = ['name' => 'Alice', 'age' => 25, 'city' => 'New York'];
$insertResult = $collection->insertOne($document);
echo "Inserted with Object ID '{$insertResult->getInsertedId()}'\n";
?>

查询文档

查询一个文档并输出：

<?php
$document = $collection->findOne(['name' => 'Alice']);
echo "Found document: " . json_encode($document) . "\n";
?>

更新文档

更新一个匹配条件的文档：

<?php
$updateResult = $collection->updateOne(
    ['name' => 'Alice'],
    ['$set' => ['age' => 26]]
);
echo "Matched {$updateResult->getMatchedCount()} document(s)\n";
?>

删除文档

删除一个文档：

<?php
$deleteResult = $collection->deleteOne(['name' => 'Alice']);
echo "Deleted {$deleteResult->getDeletedCount()} document(s)\n";
?>

查询多个文档

<?php
$documents = $collection->find(['city' => 'New York']);
foreach ($documents as $document) {
    echo json_encode($document) . "\n";
}
?>

4. 聚合查询

MongoDB PHP 扩展也支持聚合操作。你可以使用聚合管道来执行复杂的查询。

<?php
$pipeline = [
    ['$match' => ['age' => ['$gte' => 20]]],
    ['$group' => ['_id' => null, 'averageAge' => ['$avg' => '$age']]]
];

$aggregation = $collection->aggregate($pipeline);
foreach ($aggregation as $result) {
    echo json_encode($result) . "\n";
}
?>

5. 使用过滤器

MongoDB PHP 扩展提供了强大的过滤器，支持多种条件操作符（如 eq, gt, lt, in, ne, exists 等）。

示例：使用过滤器

<?php
use MongoDB\BSON\Regex;

$cursor = $collection->find(['name' => 'Alice']);
foreach ($cursor as $document) {
    echo json_encode($document) . "\n";
}

// 使用正则表达式查找
$cursor = $collection->find(['name' => new Regex('^A')]);
foreach ($cursor as $document) {
    echo json_encode($document) . "\n";
}
?>

6. 使用索引

MongoDB PHP 扩展允许你在集合上创建索引来提高查询性能。

创建索引

<?php
$collection->createIndex(['name' => 1]);  // 创建一个单字段升序索引
?>

7. 使用事务

MongoDB PHP 扩展支持多文档事务（MongoDB 4.x 引入）。你可以通过 PHP 实现事务来确保数据一致性。

事务示例

<?php
$session = $client->startSession();
$session->startTransaction();

try {
    $collection->insertOne(['name' => 'Bob', 'age' => 30], ['session' => $session]);
    $collection->updateOne(['name' => 'Alice'], ['$set' => ['age' => 26]], ['session' => $session]);

    // 提交事务
    $session->commitTransaction();
    echo "Transaction committed\n";
} catch (Exception $e) {
    // 如果发生异常，回滚事务
    $session->abortTransaction();
    echo "Transaction aborted\n";
}
?>

8. 异步操作

虽然 MongoDB PHP 扩展本身不支持异步操作，但你可以通过 ReactPHP 等库与 MongoDB 配合使用，以实现异步操作。

---

9. 使用 MongoDB PHP 扩展的注意事项

• 性能：在高负载的生产环境中，使用 MongoDB 的连接池功能来管理数据库连接，减少每次查询的连接建立开销。
• 错误处理：MongoDB 扩展提供了完善的异常机制，因此你应该适当捕获 MongoDB\Driver\Exception\RuntimeException 或 MongoDB\Driver\Exception\ConnectionException 等错误。
• 事务支持：多文档事务是 MongoDB 4.x 引入的新特性，使用事务时需要确保 MongoDB 的版本是 4.0 或更高。

---

总结

MongoDB PHP 扩展为 PHP 开发者提供了便捷的接口来与 MongoDB 数据库进行交互。通过该扩展，你可以轻松执行 CRUD 操作、聚合查询、事务等功能，提升了 PHP 开发中对 MongoDB 的支持。更多详细内容请关注其他相关文章！