PHP + MongoDB 数据库 - CRUD 教程

本教程将向您介绍如何使用 PHP 编程语言对 MongoDB 数据库执行 CRUD 操作(创建、读取、更新、删除)。

发布于

本教程将向您介绍如何使用 PHP 编程语言对 MongoDB 数据库执行 CRUD 操作(创建、读取、更新、删除)。我们将从介绍数据库和编程语言开始,然后逐步指导您完成连接和操作 MongoDB 数据库的步骤。最后,我们将提供一个简单的示例,以便您更好地理解如何应用这些概念。

先决条件

为了连接 MongoDB 数据库,需要具备以下先决条件:

  1. PHP 安装:确保您已成功安装 PHP 编程语言。您可以从 PHP 官方网站下载适用于您的操作系统的 PHP 安装程序。

  2. MongoDB 数据库:确保您已安装并配置了 MongoDB 数据库,并且知道如何连接到它。

  3. MongoDB 扩展:在 PHP 中连接 MongoDB 数据库需要 MongoDB 扩展。确保您已在 PHP 中启用了这个扩展。

  4. 文本编辑器:使用文本编辑器如 Visual Studio Code 来编写 PHP 代码。

连接 MongoDB 数据库

在开始执行 CRUD 操作之前,我们需要建立与 MongoDB 数据库的连接。以下是连接到 MongoDB 数据库的步骤:

步骤:建立数据库连接

使用以下 PHP 代码建立与 MongoDB 数据库的连接:

$server = "mongodb://localhost:27017";
$username = "YourUsername";
$password = "YourPassword";
$database = "YourDatabaseName";

$mongoClient = new MongoDB\Driver\Manager($server);

if ($mongoClient) {
    echo "成功连接到MongoDB数据库";
} else {
    die("连接失败");
}

确保替换以下信息:

  • mongodb://localhost:27017:MongoDB 服务器名称或 IP 地址以及端口。
  • YourUsername:数据库用户名。
  • YourPassword:数据库密码。
  • YourDatabaseName:要连接的数据库名称。

执行 CRUD 操作

现在,我们已经建立了与 MongoDB 数据库的连接,让我们继续执行 CRUD 操作。

创建记录

要创建新的记录,使用以下 PHP 代码:

$collection = 'user';
$username = 'john_doe';
$email = '[email protected]';

$document = [
    'username' => $username,
    'email' => $email,
];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->insert($document);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录创建成功";

读取记录

要读取记录,使用以下 PHP 代码:

$collection = 'user';

$filter = [];

$query = new MongoDB\Driver\Query($filter);

$cursor = $mongoClient->executeQuery("$database.$collection", $query);

foreach ($cursor as $document) {
    echo "Username: " . $document->username . ", Email: " . $document->email . "<br>";
}

更新记录

要更新记录,使用以下 PHP 代码:

$collection = 'user';
$username = 'john_doe';

$filter = ['username' => $username];

$update = ['$set' => ['email' => '[email protected]']];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->update($filter, $update);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录更新成功";

删除记录

要删除记录,使用以下 PHP 代码:

$collection = 'user';
$username = 'john_doe';

$filter = ['username' => $username];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->delete($filter);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录删除成功";

简单示例

以下是一个简单的示例,演示如何创建、读取、更新和删除用户记录:

$server = "mongodb://localhost:27017";
$username = "YourUsername";
$password = "YourPassword";
$database = "YourDatabaseName";

$mongoClient = new MongoDB\Driver\Manager($server);

if ($mongoClient) {
    echo "成功连接到MongoDB数据库";
} else {
    die("连接失败");
}

// 创建记录
$collection = 'user';
$username = 'john_doe';
$email = '[email protected]';

$document = [
    'username' => $username,
    'email' => $email,
];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->insert($document);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录创建成功";

// 读取记录
$filter = [];

$query = new MongoDB\Driver\Query($filter);

$cursor = $mongoClient->executeQuery("$database.$collection", $query);

foreach ($cursor as $document) {
    echo "Username: " . $document->username . ", Email: " . $document->email . "<br>";
}

// 更新记录
$username = 'john_doe';

$filter = ['username' => $username];

$update = ['$set' => ['email' => '[email protected]']];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->update($filter, $update);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录更新成功";

// 删除记录
$filter = ['username' => $username];

$bulkWrite = new MongoDB\Driver\BulkWrite;
$bulkWrite->delete($filter);

$mongoClient->executeBulkWrite("$database.$collection", $bulkWrite);

echo "记录删除成功";

总结

通过本教程,您已经学会了如何使用 PHP 编程语言连接 MongoDB 数据库并

执行 CRUD 操作。这些基本的数据库操作是构建更复杂应用程序的基础,希望本文能够帮助您在 PHP 中使用 MongoDB 数据库时更加自信和熟练。如果您希望进行更高级的操作,还可以研究 MongoDB 数据库的更多功能和 API。