Skip to content

DOCSP-41980: Cursor guide #110

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 12 commits into from
Sep 9, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions snooty.toml
Original file line number Diff line number Diff line change
Expand Up @@ -29,3 +29,4 @@ driver-short = "PHP library"
stable-api = "Stable API"
mdb-server = "MongoDB Server"
api = "https://www.mongodb.com/docs/php-library/current/reference"
php-manual = "https://www.php.net/manual/en"
64 changes: 64 additions & 0 deletions source/includes/read/cursor.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,64 @@
<?php
require 'vendor/autoload.php';

$uri = getenv('MONGODB_URI') ?: throw new RuntimeException('Set the MONGODB_URI variable to your Atlas URI that connects to the sample dataset');
$client = new MongoDB\Client($uri);

// start-db-coll
$collection = $client->sample_restaurants->restaurants;
// end-db-coll

// Iterates over and prints all documents that have a "name" value of "Dunkin' Donuts"
// start-cursor-iterate
$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
foreach ($cursor as $doc) {
echo json_encode($doc) . PHP_EOL;
}
// end-cursor-iterate

// Retrieves and prints the first document stored in the cursor
// start-cursor-first
$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
$cursor->rewind();
echo json_encode($cursor->current());
// end-cursor-first

// Converts the documents stored in a cursor to an array
// start-cursor-array
$cursor = $collection->find(['name' => 'Dunkin\' Donuts']);
$array_results = $cursor->toArray();
// end-cursor-array

// Creates a collection with a maximum size and inserts documents representing vegetables
// start-capped-coll
$db = $client->db;
$create_coll = $db->createCollection(
'vegetables',
['capped' => true, 'size' => 1024 * 1024]
);

$vegetables = [
['name' => 'cauliflower'],
['name' => 'zucchini']
];

$collection = $db->vegetables;
$result = $collection->insertMany($vegetables);
// end-capped-coll

// Iterates over the initial query results and continues iterating until three documents are stored in the cursor
// by using a tailable cursor
// start-tailable
$cursor = $collection->find([], ['cursorType' => MongoDB\Operation\Find::TAILABLE]);
$cursor->rewind();

$docs_found = 0;
while ($docs_found < 3) {
if ($cursor->valid()) {
$doc = $cursor->current();
echo json_encode($doc) . PHP_EOL;
$docs_found++;
}
$cursor->next();
}
// end-tailable
1 change: 1 addition & 0 deletions source/read.txt
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ Read Data from MongoDB

/read/retrieve
/read/project
/read/cursor
/read/count
/read/specify-documents-to-return
/read/specify-a-query
Expand Down
188 changes: 188 additions & 0 deletions source/read/cursor.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,188 @@
.. _php-cursors:

=========================
Access Data From a Cursor
=========================

.. contents:: On this page
:local:
:backlinks: none
:depth: 1
:class: singlecol

.. facet::
:name: genre
:values: reference

.. meta::
:keywords: read, results, code example

Overview
--------

In this guide, you can learn how to access data from a **cursor** by using the
{+php-library+}.

A cursor is a mechanism that returns the results of a read operation in iterable
batches. Cursors reduce both memory consumption and the number of server requests
by holding only a subset of documents at any given time, rather than returning all
documents at once.

Whenever the {+php-library+} performs a read operation by using the ``MongoDB\Collection::find()``
method, it returns the matching documents in a ``MongoDB\Driver\Cursor`` instance.

Sample Data
~~~~~~~~~~~

The examples in this guide use the ``restaurants`` collection in the ``sample_restaurants``
database from the :atlas:`Atlas sample datasets </sample-data>`. To access this collection
from your PHP application, instantiate a ``MongoDB\Client`` that connects to an Atlas cluster
and assign the following value to your ``$collection`` variable:

.. literalinclude:: /includes/read/cursor.php
:language: php
:dedent:
:start-after: start-db-coll
:end-before: end-db-coll

To learn how to create a free MongoDB Atlas cluster and load the sample datasets, see the
:atlas:`Get Started with Atlas </getting-started>` guide.

.. _php-cursors-iterate:

Access Cursor Contents Iteratively
----------------------------------

The ``MongoDB\Driver\Cursor`` class implements the ``Iterator`` interface, so you
can use a ``foreach`` loop to iterate through its contents.

The following example uses the ``MongoDB\Collection::find()`` method to retrieve all documents
in which the ``name`` field value is ``'Dunkin' Donuts'``. It then prints each document from the
cursor returned by the ``find()`` method:

.. io-code-block::
:copyable:

.. input:: /includes/read/cursor.php
:start-after: start-cursor-iterate
:end-before: end-cursor-iterate
:language: php
:dedent:

.. output::
:visible: false

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

Retrieve Documents Individually
-------------------------------

To retrieve an individual document from a cursor, call the ``current()`` method on
a ``MongoDB\Driver\Cursor`` instance. This method returns the document that the cursor
initially points to. You can continue to advance the cursor by calling the ``next()``
method, which instructs the cursor to point to the next retrieved document.

The following example finds all documents in which the ``name`` field value is
``'Dunkin' Donuts'``. Then, it prints the first retrieved document by calling the
``current()`` method on a cursor:

.. io-code-block::
:copyable:

.. input:: /includes/read/cursor.php
:start-after: start-cursor-first
:end-before: end-cursor-first
:language: php
:dedent:

.. output::
:visible: false

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

Retrieve All Documents
----------------------

.. warning::

If the number and size of documents returned by your query exceeds available
application memory, your program will crash. If you expect a large result
set, :ref:`access your cursor iteratively <php-cursors-iterate>`.

To retrieve all documents from a cursor, convert the cursor into an array by using
either of the following methods:

- ``MongoDB\\Driver\\Cursor::toArray()``: Call on a ``MongoDB\Driver\Cursor`` object
- ``iterator_to_array()``: Pass a ``MongoDB\Driver\Cursor`` object as a parameter

The following example calls the ``toArray()`` method on a cursor to store its results
in an array:

.. literalinclude:: /includes/read/cursor.php
:language: php
:dedent:
:start-after: start-cursor-array
:end-before: end-cursor-array

Tailable Cursors
----------------

When querying on a :manual:`capped collection </core/capped-collections/>`, you
can use a **tailable cursor** that remains open after the client exhausts the
results in a cursor. To create a tailable cursor, set the ``cursorType`` option to
``MongoDB\Operation\Find::TAILABLE`` in an array. Then, pass the array as an options
parameter to the ``MongoDB\Collection::find()`` method.

For example, you can create a capped collection called ``vegetables`` that stores
documents representing vegetables, as shown in the following code:

.. literalinclude:: /includes/read/cursor.php
:language: php
:dedent:
:start-after: start-capped-coll
:end-before: end-capped-coll

The following code uses a tailable cursor to retrieve all documents in the ``vegetables``
collection. After the cursor is exhausted, it remains open until retrieving three documents:

.. io-code-block::
:copyable:

.. input:: /includes/read/cursor.php
:start-after: start-tailable
:end-before: end-tailable
:language: php
:dedent:

.. output::
:visible: false

{"_id":{"$oid":"..."},"name":"cauliflower"}
{"_id":{"$oid":"..."},"name":"zucchini"}

If you insert another document into the ``vegetables`` collection, the preceding code prints
the new document and closes the ``while`` loop.

To learn more about tailable cursors, see :manual:`Tailable Cursors
</core/tailable-cursors/>` in the {+mdb-server+} manual.

Additional Information
----------------------

To learn more about read operations, see the :ref:`php-retrieve` guide.

To learn more about cursors, see the following pages in the PHP manual:

- `MongoDB\\Driver\\Cursor <{+php-manual+}/class.mongodb-driver-cursor.php>`__
- `MongoDB\\Driver\\Cursor::current() <{+php-manual+}/mongodb-driver-cursor.current.php>`__
- `MongoDB\\Driver\\Cursor::toArray() <{+php-manual+}/mongodb-driver-cursor.toarray.php>`__
- `iterator_to_array() <{+php-manual+}/function.iterator-to-array.php>`__

API Documentation
~~~~~~~~~~~~~~~~~

To learn more about the ``find()`` method, see the API documentation for
`MongoDB\\Collection::find() <{+api+}/method/MongoDBCollection-find/>`__.
Loading