PHP7 mongoDB扩展使用的方法分享

首先需要安装mongoDB扩展,具体请参照官方文档.

extension=openssl
extension=mongodb

此时此刻呢,重启PHP服务以生效.

$manager = new MongoDB\Driver\Manager('mongodb://localhost:27017');

连接成功之后,我们可以进行以下基本操作：

插入数据

$bulk = new MongoDB\Driver\BulkWrite;
$doc = ['name' => 'John', 'age' => 30];
$bulk->insert($doc);
$manager->executeBulkWrite('test.users', $bulk);
echo '插入成功';

上面代码中,我们使用bulkWrite进行数据插入操作.

更新数据

$bulk = new MongoDB\Driver\BulkWrite;
$bulk->update(['name' => 'John'], ['$set' => ['age' => 31]]);
$manager->executeBulkWrite('test.users', $bulk);
echo '更新成功';

上面代码中,我们使用bulkWrite进行数据更新操作.

删除数据

$bulk = new MongoDB\Driver\BulkWrite;
$bulk->delete(['name' => 'John']);
$manager->executeBulkWrite('test.users', $bulk);
echo '删除成功';

上面代码中,我们使用bulkWrite进行数据删除操作.

在使用mongoDB扩展时,还可以使用MongoDB对象进行操作,以下是两个示例：

查询数据

$collection = (new MongoDB\Client)->test->users;
$user = $collection->findOne(['name' => 'John']);
var_dump($user);

上面代码中,我们使用MongoDB对象中的find方法进行查询.

聚合操作

$collection = (new MongoDB\Client)->test->users;
$pipeline = [
['$group' => ['_id' => '$gender', 'count' => ['$sum' => 1]]],
];
$result = $collection->aggregate($pipeline);
var_dump($result);

上面代码中,我们使用MongoDB对象中的aggregate方法进行聚合操作.

以上就是土嘎嘎小编大虾米为大家整理的相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用，就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！