MongoDB PHP 扩展是用于在 PHP 环境中操作 MongoDB 数据库的官方驱动。它提供了一组简洁的 API，使得 PHP 开发者能够轻松地执行 CRUD（创建、读取、更新、删除）操作、聚合查询、事务处理等功能，接下来我会详细介绍如何在 PHP 中使用 MongoDB。

1. 安装 MongoDB PHP 扩展

通过 Composer 安装

在 PHP 项目中，使用 Composer 安装 MongoDB 驱动是最简单的方法。你只需要在你的项目目录中运行以下命令：

composer require mongodb/mongodb

Composer 会自动安装 MongoDB PHP 扩展，并将其添加到 composer.json 文件中。

通过 PECL 安装

你也可以通过 PECL 来安装 MongoDB 扩展：

pecl install mongodb

安装完成后，你需要在 php.ini 文件中启用该扩展：

extension=mongodb.so

然后，重启 PHP 服务。

2. 连接到 MongoDB 数据库

安装完成后，你就可以通过 MongoDB PHP 驱动连接到 MongoDB 数据库。以下是一个简单的连接示例：

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

// 创建 MongoDB 客户端连接
$client = new MongoDB\Client("mongodb://localhost:27017");  // 连接到 MongoDB 服务器

// 选择数据库和集合
$database = $client->test;  // 选择 test 数据库
$collection = $database->users;  // 选择 users 集合
?>

3. 基本的 CRUD 操作

插入文档

向 MongoDB 中插入一个文档：

<?php
$document = ['name' => 'Alice', 'age' => 25, 'city' => 'New York'];
$result = $collection->insertOne($document);

echo "Inserted with Object ID: " . $result->getInsertedId();
?>

查询文档

从集合中查询单个文档：

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

查询多个文档：

<?php
$cursor = $collection->find(['age' => ['$gte' => 18]]);  // 查找年龄大于等于 18 的文档
foreach ($cursor as $document) {
    echo 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";
?>

4. 聚合查询

MongoDB 的聚合框架允许你进行复杂的查询，例如分组、排序、过滤等。以下是一个聚合查询的示例：

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

$aggregation = $collection->aggregate($pipeline);

foreach ($aggregation as $result) {
    echo json_encode($result) . "\n";
}
?>

5. 索引操作

你可以为集合创建索引，以提高查询性能。例如，创建一个基于 name 字段的升序索引：

<?php
$indexResult = $collection->createIndex(['name' => 1]);  // 1 表示升序
echo "Index created: " . json_encode($indexResult);
?>

6. 事务操作

MongoDB 支持多文档事务，可以确保多个操作的原子性。以下是一个简单的事务操作示例：

<?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";
}
?>

7. 使用过滤器

MongoDB PHP 扩展允许你使用强大的过滤器来构建查询。你可以使用比较操作符（如 $gt, $lt, $eq 等）进行条件查询：

<?php
// 使用过滤器查找年龄大于 18 的用户
$cursor = $collection->find(['age' => ['$gt' => 18]]);
foreach ($cursor as $document) {
    echo json_encode($document) . "\n";
}
?>

8. 使用正则表达式查询

MongoDB PHP 扩展也支持正则表达式查询：

<?php
$cursor = $collection->find(['name' => new MongoDB\BSON\Regex('^A')]);
foreach ($cursor as $document) {
    echo json_encode($document) . "\n";
}
?>

9. 错误处理

MongoDB PHP 扩展提供了详细的异常处理机制。你可以捕获 MongoDB 异常并进行相应处理：

<?php
try {
    $collection->insertOne(['name' => 'Alice', 'age' => 'invalid_age']);
} catch (MongoDB\Driver\Exception\InvalidArgumentException $e) {
    echo "Error: " . $e->getMessage();
}
?>

10. 总结

MongoDB PHP 扩展为 PHP 开发者提供了强大的功能，可以与 MongoDB 数据库进行各种操作。通过使用 MongoDB PHP 驱动，你可以轻松地进行数据插入、查询、更新、删除、聚合以及事务处理等操作。更多详细内容请关注其他相关文章！