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, consulta el
Comenzar.
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.
Buscar documentos
El controlador Java Reactive Streams incluye un método para recuperar documentos de una colección: find().
Este método toma un filtro de query y retorna uno o más documentos coincidentes. Un filtro de query es un objeto que define los documentos que se desean recuperar en una query.
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 en el que 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
Es posible modificar el comportamiento del método find() encadenando otros métodos a este. La siguiente tabla describe los métodos de uso más común:
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: