php mongodb manager 查数据的各种姿势

来源：https://www.cnblogs.com/tujia/p/8134002.html

连接 mongodb 数据库

以下操作默认都是以上面操作为前提（已连接成功）而做的操作

通过主键_id来查询

注意：_id 不是直接用字符串来表示，要用 new \MongoDB\BSON\ObjectId 对象

// mysql: SELECT * FROM appDownloadRecord WHERE _id='5a2b9aaf96b4a97efbe31a91';
$id      = new \MongoDB\BSON\ObjectId("5a2b9aaf96b4a97efbe31a91");
$filter  = ['_id' => $id];
$options = [];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

查询指定字段

_id 默认是返回的，如果不想返回，要设置 _id =>0

// mysql: SELECT `source`,`ip` FROM appDownloadRecord WHERE _id='5a2b9aaf96b4a97efbe31a91';
$id      = new \MongoDB\BSON\ObjectId("5a2b9aaf96b4a97efbe31a91");
$filter  = ['_id' => $id];
$options = [
    'projection' => ['_id'=>0, 'source'=>1, 'ip'=>1]
];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

普通条件查询

// mysql: SELECT * FROM appDownloadRecord WHERE source='bdsem1' LIMIT 10;
$filter  = ['source' => 'bdsem1'];
$options = ['limit'=>10];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

范围查询（between）

// mysql: SELECT * FROM appDownloadRecord WHERE (source='bdsem1') AND (createTime BEWTEEN '2017-12-21 00:00:00' AND '2017-12-28 00:00:00') LIMIT 10;
// mysql: SELECT * FROM appDownloadRecord WHERE (source='bdsem1') AND (createTime>='2017-12-21 00:00:00' AND createTime<'2017-12-28 00:00:00') LIMIT 10;
$startTime = new \MongoDB\BSON\UTCDateTime(strtotime('2017-12-21 00:00:00')*1000);
$endTime   = new \MongoDB\BSON\UTCDateTime(strtotime('2017-12-28 00:00:00')*1000);
$filter  = [
    'source' => 'bdsem1',
    'createTime' => [
        '$gte' => $startTime,
        '$lt'  => $endTime,
    ],
];
$options = ['limit'=>10];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

in 查询

// mysql: SELECT * FROM appDownloadRecord WHERE (source IN ('bdsem1', 'besem2', 'besem3')) LIMIT 10;
$filter  = [
    'source' => [
        '$in' => ['bdsem1', 'bdsem2', 'bdsem3']
    ],
];
$options = ['limit'=>10];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

or 操作

// mysql: SELECT * FROM appDownloadRecord WHERE source='bdsem1' AND (sys='ios' OR sys='other') LIMIT 10;
$filter  = [
    'source' => 'bdsem1',
    '$or' => [
        ['sys'=>'ios'],
        ['sys'=>'other']
    ]
];
$options = ['limit'=>10];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

group （聚合）操作

// mysql: SELECT sys,sum(*) as total FROM appDownloadRecord WHERE source='bdsem1' GROUP BY sys;
$document = [
    'aggregate' => 'appDownloadRecord',
    'pipeline' => [
        [
            '$match' => [
                'source' => 'bdsem1'
            ]
        ],
        [
            '$group' => [
                '_id' => '$sys',
                'total' => ['$sum'=>1]
            ]
        ]
    ],
    'allowDiskUse' => false,
];
$command = new \MongoDB\Driver\Command($document);
$rows    = $mongo->executeCommand('promotion-prod', $command)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

group having

// mysql: SELECT sys,sum(*) as total FROM appDownloadRecord WHERE source='bdsem1' GROUP BY sys HAVING total>1000;
$document = [
    'aggregate' => 'appDownloadRecord',
    'pipeline' => [
        [
            '$match' => [
                'source' => 'bdsem1'
            ]
        ],
        [
            '$group' => [
                '_id'   => '$sys',
                'total' => ['$sum'=>1]
            ]
        ],
        [
            '$match' => [
                'total' => ['$gt'=>1000]
            ]
        ]
    ],
    'allowDiskUse' => false,
];
$command = new \MongoDB\Driver\Command($document);
$rows    = $mongo->executeCommand('promotion-prod', $command)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

排序 sort

// mysql: SELECT * FROM appDownloadRecord WHERE source='bdsem1' ORDER BY createTime desc LIMIT 10;
$filter  = ['source' => 'bdsem1'];
$options = [
    'sort'       => ['createTime'=>-1],
    'limit'      => 10
];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

limit 分页

// mysql: SELECT * FROM appDownloadRecord WHERE source='bdsem1' LIMIT 10;
$filter  = ['source' => 'bdsem1'];
$options = [
    'limit' => 10
];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;

// mysql: SELECT * FROM appDownloadRecord WHERE source='bdsem1' LIMIT 10,10;
$filter  = ['source' => 'bdsem1'];
$options = [
    'skip'  => 10,
    'limit' => 10
];
$query   = new \MongoDB\Driver\Query($filter, $options);
$rows    = $mongo->executeQuery('promotion-prod.appDownloadRecord', $query)->toArray();
echo '<pre>';print_r($rows);echo '</pre>';exit;