从游标访问数据

Overview

在本指南中，您可以学习；了解如何使用MongoDB PHP库从游标访问权限数据。

游标是一种以可迭代批处理方式返回读取操作结果的机制。游标在任何给定时间仅保存文档的子集，而不是一次返回所有文档，从而减少内存消耗和服务器请求数量。

每当MongoDB PHP库使用MongoDB\Collection::find() 方法执行读取操作时，它都会在MongoDB\Driver\Cursor 实例中返回匹配的文档。Cursor 类实现了 PHP 的迭代器接口，该接口提供了对迭代的更多控制，并且与使用可迭代对象的PHP函数具有更高的兼容性。 MongoDB游标仅支持前向迭代，因此您无法倒带游标或多次使用foreach 循环。

样本数据

本指南中的示例使用Atlas示例数据集的sample_restaurants数据库中的restaurants集合。要从PHP应用程序访问权限此集合，请实例化一个连接到Atlas 集群的MongoDB\Client ，并将以下值分配给$collection变量：

$collection = $client->sample_restaurants->restaurants;

要学习；了解如何创建免费的MongoDB Atlas 群集并加载示例数据集，请参阅Atlas入门指南。

以迭代方式访问游标内容

MongoDB\Driver\Cursor类实现了Iterator接口，因此您可以使用foreach循环来遍历其内容。

以下示例使用MongoDB\Collection::find()方法检索name字段值为'Dunkin' Donuts'的所有文档。然后，它会打印find()方法返回的游标中的每个文档：

$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
foreach ($cursor as $doc) {
    echo json_encode($doc), PHP_EOL;
}

{"_id":{"$oid":"..."},..."name":"Dunkin' Donuts","restaurant_id":"40379573"}
{"_id":{"$oid":"..."},..."name":"Dunkin' Donuts","restaurant_id":"40363098"}
{"_id":{"$oid":"..."},..."name":"Dunkin' Donuts","restaurant_id":"40395071"}
...

分别检索文档

要从游标检索单个文档，请在MongoDB\Driver\Cursor实例上调用current()方法。此方法返回游标最初指向的文档。您可以通过调用next()方法继续使游标前进，该方法指示游标点下一个检索到的文档。

以下示例查找其中name字段值为'Dunkin' Donuts'的所有文档。然后，它通过在游标上调用current()方法来打印检索到的第一个文档：

$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
$cursor->rewind();
echo json_encode($cursor->current());

{"_id":{"$oid":"..."},..."name":"Dunkin' Donuts","restaurant_id":"40379573"}

检索所有文档

警告

如果查询返回的文档数量和大小超过可用的应用程序内存，程序就会崩溃。如果需要大型结果集，请以迭代方式访问游标。

要从游标检索所有文档，请使用以下方法之一将游标转换为大量：

MongoDB\ 驱动程序\Cursor::toArray() ：调用MongoDB\Driver\Cursor 对象
iterator_to_array() ：将MongoDB\Driver\Cursor 对象作为参数传递

以下示例对游标调用toArray()方法，将其结果存储在大量中：

$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
$resultArray = $cursor->toArray();

可追加游标

如果希望游标在客户端读取其初始内容后保持打开状态，则可以使用可追加游标。我们建议您使用可追加游标来查询固定大小集合。

不能使用foreach 循环来迭代可追加游标，因为循环在读取游标的初始结果设立后终止。如果使用第二个foreach 循环继续迭代可追加游标，则PHP库会尝试倒带游标，然后生成错误。相反，您必须使用 Iterator 接口中的方法从可追加游标中检索结果。

要创建可追加游标，请在大量中将 cursorType 选项设立为 MongoDB\Operation\Find::TAILABLE。然后，将该大量作为选项参数传递给 MongoDB\Collection::find() 方法。

可追加游标示例

本部分提供以下示例脚本，您可以同时运行这些脚本：

一个生产者脚本，用于创建固定大小集合并向其中插入文档
创建可追加游标以从固定大小集合中读取文档的使用者脚本

创建和填充集合

以下示例创建了一个名为 vegetables 的固定大小集合，并等待 5 秒，然后再将其他文档插入到该集合中：

$db = $client->db;
$db->createCollection(
    'vegetables',
    ['capped' => true, 'size' => 1024 * 1024],
);
$vegetables = [
    ['name' => 'cauliflower', 'createdAt' => new MongoDB\BSON\UTCDateTime()],
    ['name' => 'zucchini', 'createdAt' => new MongoDB\BSON\UTCDateTime()],
];
$collection = $db->vegetables;
$result = $collection->insertMany($vegetables);
sleep(5);
$collection->insertOne(['name' => 'carrot', 'createdAt' => new MongoDB\BSON\UTCDateTime()]);

创建可追加游标

当前面的代码示例运行时，使用以下代码创建可追加游标并检索vegetables集合中的所有文档：

$cursor = $collection->find([], ['cursorType' => MongoDB\Operation\Find::TAILABLE]);
$cursor->rewind();
$docsFound = 0;
while ($docsFound < 3) {
    if ($cursor->valid()) {
        $doc = $cursor->current();
        echo json_encode($doc), PHP_EOL;
        $docsFound++;
    }
    $cursor->next();
}

{"_id":{"$oid":"..."},"name":"cauliflower","createdAt":{"$date":{"$numberLong":"..."}}}
{"_id":{"$oid":"..."},"name":"zucchini","createdAt":{"$date":{"$numberLong":"..."}}}
{"_id":{"$oid":"..."},"name":"carrot","createdAt":{"$date":{"$numberLong":"..."}}}

此代码会打印集合中的两个初始文档，但 while 循环直到收到第三个文档后才会终止。next() 方法确保代码等待其他游标结果。

提示

要学习；了解有关可追加游标的更多信息，请参阅MongoDB Server手册中的可追加游标。