php - MongoDB PHP 驱动程序 : Query for Distinct records with Limit and Skip

Question

我看到了以前的问题。但它们都不是基于最新的驱动程序。

到目前为止，我的代码如下:

$mongo = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$regex1 = new MongoDB\BSON\Regex("^[A-z]","i");
$filter = ['searchcontent.name' => $regex1];
$options = [
   'limit' => 50,
   'skip' => 0
];

$query = new MongoDB\Driver\Query($filter, $options);
$rows = $mongo->executeQuery('webdb.search', $query);

foreach($rows as $r){    
    echo "<br/>".$r->searchcontent->name."<br/>";
}

此代码返回重复项，因为我的数据库中有重复项。我想对此实现不同的。我阅读了官方文档，但找不到任何东西。

我试过这样:

$options = [
   'limit' => 50,
   'skip' => 0,
'distinct'=>'searchcontent.name'
];

但这对我不起作用。请帮忙。

编辑:

PHP official documentation有一个与 executeCommand() 不同的例子。

但问题是我无法使用此代码限制和跳过。

总结:

我想要一个包含 limit、skip 和 distinct 的查询。

带有 executeCommand() 或带有 executeQuery() 或其他任何东西的解决方案都对我有用。

Answer 1

您可以使用聚合管道并将 $group 用于不同的记录。

$mongo = new MongoDB\Driver\Manager("mongodb://localhost:27017");
$regex1 = new MongoDB\BSON\Regex("^[A-z]","i");

$pipeline = [
    [ '$match' => ['searchcontent.name' => $regex1] ],
    [ '$group' => ['_id' => '$searchcontent.name'] ],
    [ '$limit' => 50 ],
    [ '$skip' => 10 ],
];

$aggregate = new \MongoDB\Driver\Command([
   'aggregate' => 'search', 
   'pipeline' => $pipeline
]);

$cursor = $mongo->executeCommand('webdb', $aggregate);

foreach($cursor as $key => $document) {
    var_dump($document);
}

或者，您应该通过 composer 安装库它提供与旧 api 类似的语法。

$collection = (new MongoDB\Client)->webdb->search;

$cursor = $collection->aggregate([
    [ '$match' => ['searchcontent.name' => $regex1] ],
    [ '$group' => ['_id' => '$searchcontent.name'] ],
    [ '$limit' => 50 ],
    [ '$skip' => 10 ],
]);

foreach($cursor as $key => $document) {
    var_dump($document);
}