How to use MongoDB for data storage in Workerman

How to use MongoDB for data storage in Workerman

Workerman is a high-performance network programming framework based on PHP, which provides rich functions and flexible extensions features, making it easier for developers to build high-performance network applications. MongoDB is a non-relational database known for its high performance, high scalability and flexible data model, and is widely used in large-scale data storage and processing.

In this article, we will introduce how to use MongoDB for data storage in Workerman and provide specific code examples.

Step 1: Install the MongoDB driver
First, make sure that the PHP MongoDB extension driver is installed. You can use the following command to install:

pecl install mongodb

After the installation is complete, you need to enable the MongoDB extension in the php.ini file. You can use the following command to edit the php.ini file:

vim /etc/php.ini

Add the following line of configuration in the php.ini file:

extension=mongodb.so

Save and exit, restart the PHP service to make it effective:

service php-fpm restart

Step 2: Create a database connection
Before using MongoDB in an application, you need to create a database connection. You can create a connection in the Workerman startup function and save it using global variables in the application:

// 引入MongoDB驱动
require_once __DIR__ . '/mongodb/autoload.php';

use MongoDBClient;

// 创建MongoDB连接
$GLOBALS['mongo'] = new Client('mongodb://localhost:27017');

Step 3: Insert data
After you have a database connection, you can insert data. The following is a simple example to insert a piece of data into the user collection of the database named test:

// 获取MongoDB的连接
$mongo = $GLOBALS['mongo'];

// 选择数据库
$db = $mongo->test;

// 选择集合
$collection = $db->user;

// 插入一条数据
$collection->insertOne([
    'name' => 'John',
    'age' => 25,
    'email' => 'john@example.com'
]);

Step 4: Query data
In addition to inserting data, you can also perform data query operations. The following is a simple example to query all users whose age is less than 30 from the user collection of the database named test:

// 获取MongoDB的连接
$mongo = $GLOBALS['mongo'];

// 选择数据库
$db = $mongo->test;

// 选择集合
$collection = $db->user;

// 查询数据
$cursor = $collection->find([
    'age' => ['$lt' => 30]
]);

// 遍历查询结果
foreach ($cursor as $document) {
    var_dump($document);
}

Step 5: Update data
In MongoDB, you can use the updateOne() method to update a piece of data. The following is a simple example to update the mailbox of a user whose age is equal to 25 in the user collection of the database named test:

// 获取MongoDB的连接
$mongo = $GLOBALS['mongo'];

// 选择数据库
$db = $mongo->test;

// 选择集合
$collection = $db->user;

// 更新数据
$collection->updateOne(
    ['age' => 25],
    ['$set' => ['email' => 'updated@example.com']]
);

Step 6: Delete data
Finally, you can use the deleteOne() method to delete a piece of data. The following is a simple example to delete the user named John from the user collection of the database named test:

// 获取MongoDB的连接
$mongo = $GLOBALS['mongo'];

// 选择数据库
$db = $mongo->test;

// 选择集合
$collection = $db->user;

// 删除数据
$collection->deleteOne(['name' => 'John']);

Through the introduction of the above steps and specific code examples, I believe readers can successfully use it in Workerman MongoDB performs data storage. I hope this article is helpful to developers, thank you for reading!

The above is the detailed content of How to use MongoDB for data storage in Workerman. For more information, please follow other related articles on the PHP Chinese website!