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 streams 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. Puedes establecer el tamaño de lote de datos contenido por cada cursor subyacente utilizando el método FindPublisher.batchSize().
Datos de muestra
Los ejemplos de esta guÃa usan la colección sample_restaurants.restaurants de los 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 la guÃa Comenzar.
Importante
Proyecto Reactor librerÃa
Esta guÃa utiliza la biblioteca Project Reactor para consumir instancias Publisher devueltas por los métodos del controlador Java Reactive Streams. Para obtener más información sobre la biblioteca Project Reactor y cómo usarla, consulte la sección "Primeros pasos" en la documentación de Reactor. Para obtener más información sobre cómo utilizamos los métodos de la biblioteca Project Reactor en esta guÃa, consulte la guÃa "Insertar documentos".
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: