Overview
En esta guía, puedes aprender cómo acceder a datos desde un cursor utilizando el controlador Java Reactive Streams.
Un cursor es un mecanismo que devuelve los resultados de una operación de lectura en lotes iterables. Debido a que un cursor contiene solo un subconjunto de documentos en un momento dado, los cursores reducen tanto el consumo de memoria como el uso del ancho de banda de red.
En el controlador Java Reactive Streams, algunos flujos están respaldados por cursores. El tamaño de los lotes utilizados en estos cursores subyacentes depende de la demanda solicitada en el Subscription para el Publisher. Puede establecer el tamaño del lote de datos contenido por cada cursor subyacente utilizando el método FindPublisher.batchSize().
Datos de muestra
Los ejemplos en esta guía utilizan la colección sample_restaurants.restaurants de la Conjuntos de datos de muestra de Atlas. Para aprender a crear un clúster gratuito de MongoDB Atlas y cargar los conjuntos de datos de muestra, consulta el
Guía de primeros pasos.
Importante
Proyecto Reactor librería
Esta guía usa la librería Proyecto Reactor para consumir instancias Publisher devueltas por los métodos del driver Reactive Streams de Java. Para obtener más información sobre la biblioteca Project Reactor y cómo utilizarla, consulta Primeros pasos en la documentación de Reactor. Para obtener más información sobre cómo utilizamos los métodos de la librería Project Reactor en esta guía, consulta la guía Guardar datos en MongoDB.
Acceso iterativo al contenido del cursor
Para iterar sobre el contenido de un cursor, debe utilizar el método Flux.from(), como se muestra en el siguiente ejemplo:
FindPublisher<Document> findPublisher = collection.find(); Flux.from(findPublisher) .doOnNext(x -> System.out.println(x.getString("name"))) .blockLast();
Recuperar todos los documentos
Advertencia
Si la cantidad y el tamaño de los documentos devoluidos por tu query superan la memoria disponible de la aplicación, tu programa se bloqueará. Si esperas un conjunto de resultados grande, accede a tu cursor de forma iterativa.
Para recuperar todos los documentos de un cursor, convierte el cursor en un List, como se muestra en el siguiente ejemplo:
FindPublisher<Document> findPublisher = collection.find(Filters.eq("name", "Dunkin' Donuts")); List<Document> resultsList = Flux.from(findPublisher).collectList().block();
Cursores con seguimiento
Al consultar en una colección con tamaño fijo, puedes usar un cursor con seguimiento que permanece abierto después de que el cliente agota los resultados en un cursor. Para crear un cursor con seguimiento en una colección acotada, pasa un valor de CursorType.TailableAwait al método cursorType() de un objeto FindPublisher.
El siguiente ejemplo crea un cursor con seguimiento en una colección e imprime su contenido:
FindPublisher<Document> findPublisher = collection.find().cursorType(CursorType.TailableAwait); Flux.from(findPublisher) .doOnNext(System.out::println) .blockLast();
Para obtener más información sobre los cursores con seguimiento y su uso, consulta la Guía de cursores con seguimiento en el manual de MongoDB Server.
Documentación de la API
Para aprender más sobre cualquiera de los métodos o tipos analizados en esta guía, consulta la siguiente documentación de API: