使用php实现对mongodb的增加、删除、修改、查询操作代码示例,供大家学校参考,如果有问题欢迎留言。
PHP操作MongoDB:单条插入
$bulk = new MongoDB\Driver\BulkWrite;
$document = ['_id' => new MongoDB\BSON\ObjectID, 'name' => 'hello word'];
$bulk->insert($document);
$manager = new MongoDB\Driver\Manager("mongodb://192.168.1.50:27017");
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('my.hello', $bulk, $writeConcern);
PHP操作MongoDB:批量插入
$manager = new MongoDB\Driver\Manager("mongodb://192.168.1.50:27017");
$bulk = new MongoDB\Driver\BulkWrite;
$bulk->insert(['id' => 1, 'name'=>'php', 'url' => 'http://php.feishuai.vip']);
$bulk->insert(['id' => 2, 'name'=>'java', 'url' => 'http://java.feishuai.vip']);
$bulk->insert(['id' => 3, 'name'=>'python', 'url' => 'http://python.feishuai.vip']);
$result = $manager->executeBulkWrite('sfjvip.cate', $bulk);
PHP操作MongoDB:查询
$filter=[
'id'=>['$gt'=>1]
];
$options=[
'projection'=>[
'_id'=>0
],
'sort'=>['x'=>-1]
];
$manager = new MongoDB\Driver\Manager("mongodb://192.168.1.50:27017");
$query = new MongoDB\Driver\Query($filter, $options);
$cursor = $manager->executeQuery('sfjvip.cate', $query);
foreach ($cursor as $document) {
echo "<pre>";
print_r($document);
}
PHP操作MongoDB:更新数据
$bulk = new MongoDB\Driver\BulkWrite;
$bulk->update(
['id' => 2],
['$set' => ['name' => 'sfjvip', 'url' => 'test.feishuai.vip']],
['multi' => false, 'upsert' => false]
);
$manager = new MongoDB\Driver\Manager("mongodb://192.168.1.50:27017");
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('sfjvip.cate', $bulk, $writeConcern);
PHP操作MongoDB:删除
$bulk = new MongoDB\Driver\BulkWrite;
$bulk->delete(['id' => 1], ['limit' => 1]); // limit 为 1 时,删除第一条匹配数据
$bulk->delete(['id' => 2], ['limit' => 0]); // limit 为 0 时,删除所有匹配数据
$manager = new MongoDB\Driver\Manager("mongodb://192.168.1.50:27017");
$writeConcern = new MongoDB\Driver\WriteConcern(MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$result = $manager->executeBulkWrite('sfjvip.cate', $bulk, $writeConcern);