Overview
En esta guía, puedes aprender cómo utilizar el controlador de flujos reactivos de MongoDB Java para recuperar datos de una colección de MongoDB mediante operaciones de lectura.
Datos de muestra
Los ejemplos de esta guía utilizan el sample_restaurants.restaurants colección 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, consulte
Empezar.
Importante
Proyecto Reactor librería
Esta guía utiliza la biblioteca Project Reactor para consumir Publisher las instancias 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 "Introducción" en la documentación de Reactor. Para obtener más información sobre cómo usamos los métodos de la biblioteca Project Reactor en esta guía, consulte la guía "Escribir datos en MongoDB".
Buscar documentos
El controlador Java Reactive Streams incluye un método para recuperar documentos de una colección: find().
Este método utiliza un filtro de consulta y devuelve uno o más documentos coincidentes. Un filtro de consulta es un objeto que especifica los documentos que desea recuperar en su consulta.
Para obtener más información sobre los filtros de query, consulta la guía Especificar una consulta.
Encuentre un documento
Para encontrar un solo documento en una colección, encadene el método first() a la llamada del método find() y pase un filtro de query a la llamada del método find() que especifique los criterios del documento que desea encontrar. Si más de un documento coincide con el filtro de query, la construcción find().first() devuelve el primer documento coincidente de los resultados recuperados. Si ningún documento coincide con el filtro de query, la construcción devuelve None.
Tip
La construcción find().first() es útil cuando sabes que solo hay un documento coincidente o si solo te interesa la primera coincidencia.
El siguiente ejemplo utiliza la construcción find().first() para encontrar el primer documento donde el campo "cuisine" tiene el valor "Bakery":
Publisher<Document> findDocPublisher = restaurants.find( eq("cuisine", "Bakery")).first(); Mono.from(findDocPublisher) .doOnNext(System.out::println) .blockLast();
Tip
Orden de clasificación
Si no especificas un orden de clasificación, el constructo find().first() devuelve el primer documento en orden natural en disco.
Para aprender más sobre la clasificación, consulta la guía Especificar Documentos para Devolver.
Encuentra varios documentos
Para encontrar varios documentos en una colección, pasar un filtro de query al método find() que especifique los criterios de los documentos que desea recuperar.
El siguiente ejemplo usa el método find() para encontrar todos los documentos donde el campo "cuisine" tiene el valor "Spanish":
FindPublisher<Document> findDocPublisher = restaurants.find( eq("cuisine", "Spanish")); Flux.from(findDocPublisher) .doOnNext(System.out::println) .blockLast();
Nota
Encuentre todos los documentos
Para encontrar todos los documentos en una colección, no pases parámetros al método find():
Publisher<Document> findAllPublisher = restaurants.find(); Flux.from(findAllPublisher) .doOnNext(System.out::println) .blockLast();
Modificar el comportamiento de búsqueda
Puede modificar el comportamiento del método find() encadenándolo con otros métodos. La siguiente tabla describe los métodos más comunes:
Argument | Descripción |
|---|---|
| The maximum number of documents within each batch returned in a query result. By
default, the driver sets this value to Long.MAX_VALUE.A batchSize of 0 means that the cursor will be established, but no documents
will be returned in the first batch. |
| Sets the collation options as an instance of the Collation class. |
| Attaches a string to the query. This can help you trace and interpret the
operation in the server logs and in profile data. To learn more about query comments,
see the cursor.comment() page in
the MongoDB Server manual. |
| Gets or sets the index to scan for documents.
For more information, see the hint statement
in the MongoDB Server manual. |
El siguiente ejemplo utiliza el método find() para encontrar todos los documentos en los que el campo "cuisine" tiene el valor "Italian" y establece un comentario:
FindPublisher<Document> findDocPublisher = restaurants.find( eq("cuisine", "Italian")).comment("Find operation"); Flux.from(findDocPublisher) .doOnNext(System.out::println) .blockLast();
Para obtener una lista completa de los argumentos disponibles, consulte la documentación de la API de la interfaz FindPublisher.
Información Adicional
Para obtener más información sobre los filtros de query, consulta la guía Especificar una consulta.
Para ejemplos de código ejecutables de la recuperación de documentos mediante el controlador de Java Reactive Streams, consulta la guía Leer datos.
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: