[大数据]PHP7以上版本操作mongodb

链接mongo

$config = array(
    'username' => 'admin',
    'password' => '123456'
);
// 连接
$manager = new \MongoDB\Driver\Manager('mongodb://127.0.0.1:27017',$config);

 //MongoDB\Driver\WriteConcern::MAJORITY：抛出网络错误异常、服务器错误异常；并等待一个主服务器完成写操作
 //1000 表示等待时间
$writeConcern = new \MongoDB\Driver\WriteConcern(\MongoDB\Driver\WriteConcern::MAJORITY, 1000);
$bulk = new \MongoDB\Driver\BulkWrite();

插入数据

$bulk->insert(['_id' => 1, 'name'=>'张三', 'age' => '12']);
$bulk->insert(['_id' => 2, 'name'=>'李四', 'age' => '16']);
$bulk->insert(['_id' => 3, 'name'=>'王五', 'age' => '18']);
$bulk->insert(['_id' => 4, 'name'=>'张三-01', 'age' => '22']);
$bulk->insert(['_id' => 5, 'name'=>'李四-02', 'age' => '23']);
$bulk->insert(['_id' => 6, 'name'=>'王五-04', 'age' => '32']);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern); //test.sites 表示 test库里面的 user集合

获取数据

$filter = ['_id'=>['$gt'=>2]];//查询_id大于2的记录
$filter = ['_id'=>['$gt'=>2,'$lt'=>6]];//查询_id大于2，小于6 的记录
$filter = ['name'=>['$regex'=>'^李']];//查询name字段以 李 开头的记录
$filter = ['name'=>['$regex'=>'李']];//查询name字段包含 李 的记录
$filter = ['age'=>['$in'=>["16","12"]]];//查询age字段 在 [16,12]的记录
$filter = ['age'=>['$nin'=>["16","12"]]];//查询age字段 不在 [16,12]的记录
$options = [
     'skip'=>0,//根据条件从第一条数据开始   类似于 mysql 的 sffset 和 limit 可用于分页
     'limit'=>5,//根据条件获取5条数据
     'sort' => ['_id' => -1],//按照_id 倒序
     'projection'=>['age'=>false],//不查询age字段
];
$query = new \MongoDB\Driver\Query($filter,$options);
$list = $manager->executeQuery('test.user', $query)->toArray();//执行query，并将结果转为数组
print_r($list);

根据条件获取某个集合数据条数

$filter = []; //过滤条件
$command = new \MongoDB\Driver\Command(["count"=>"user","query"=>$filter]);//user 表示 集合名称
$count = $manager->executeCommand('test',$command)->toArray()[0]->n; //test表示数据库名称
var_dump($count);

更新数据

$filter = ['_id'=>2];//更新_id=2的数据
$newObj = ['$set'=>['age'=>'16']]; //age：更新的字段，也可以是一个不存在的字段，即新增一个字段
$updateOptions = ['multi' => false, 'upsert' => false];//multi：是否更新所有，upsert:当查询不到指定数据时，是否插入一条新数据
$bulk->update($filter, $newObj, $updateOptions);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern);
var_dump($result);

删除某个文档的某个属性

$filter = ['_id'=>2];//条件
$newObj = ['$unset'=>['age'=>1]]; //age：需要删除的字段
$updateOptions = ['multi' => false, 'upsert' => false];//multi：是否更新所有，upsert:当查询不到指定数据时，是否插入一条新数据
$bulk->update($filter, $newObj, $updateOptions);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern);
var_dump($result);

删除记录

$filter = ['age'=>'12']; //删除条件 为空标识删除所有
$deleteOptions = ['limit'=>0]; //limit 为1 表示删除一条数据，为0 表示删除所有
$bulk->delete($filter, $deleteOptions);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern);
 var_dump($result);

自增

$filter = ['_id' => 2];//条件
$newObj = ['$inc' => ['age' => 2]];//注意，自增时，age字段必须是int 类型，不能是数值型字符串
$updateOptions = ['multi' => false, 'upsert' => false];//multi：是否更新多条数据，upsert:当查询不到指定数据时，是否插入一条新数据
$bulk->update($filter, $newObj, $updateOptions);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern);
var_dump($result);

自减

$filter = ['_id' => 2];//条件
$newObj = ['$inc' => ['age' => -5]];
$updateOptions = ['multi' => false, 'upsert' => false];
$bulk->update($filter, $newObj, $updateOptions);
$result = $manager->executeBulkWrite('test.user', $bulk, $writeConcern);
var_dump($result);