Retrieve Data

Encuentra todos los documentos coincidentes

Para encontrar todos los documentos que coinciden con sus criterios, utilice el find() método. Este método utiliza un filtro de consulta como parámetro. Un filtro de consulta consta de los campos y valores que conforman los criterios de coincidencia de los documentos.

El método devuelve un tipo Cursor que puede iterar para recuperar cualquier documento que coincida con los criterios de filtro.

Para ver un ejemplo que utiliza este método para recuperar datos, consulte el ejemplo find().

Para obtener más información sobre cómo especificar una consulta, consulte la guía Especificar una consulta.

Encuentre un documento

Para encontrar el primer documento que coincida con sus criterios, utilice el find_one() método. Este método utiliza un filtro de consulta como parámetro. Un filtro de consulta consta de los campos y valores que conforman los criterios de coincidencia de los documentos.

Si un documento cumple los criterios de filtro, el método devuelve un tipo Result<Option<T>> con un valor de Some. Si ningún documento cumple los criterios de filtro, find_one() devuelve un tipo Result<Option<T>> con un valor de None.

Para ver un ejemplo que utiliza este método para recuperar datos, consulte el ejemplo find_one().

Modificar el comportamiento de búsqueda

Puede modificar el comportamiento del método find() encadenando métodos del generador de opciones FindOptions a find(), y puede modificar el comportamiento del método find_one() encadenando métodos del generador de opciones FindOneOptions a find_one().

La siguiente tabla describe los campos FindOptions y FindOneOptions comúnmente utilizados que puede configurar llamando a sus métodos de generación correspondientes:

Para obtener una lista completa de las configuraciones que puede especificar para cada tipo, consulte la documentación de la API para FindOptionsy FindOneOptions.

Ejemplos

Las siguientes secciones contienen ejemplos que utilizan los métodos find() y findOne() para recuperar documentos de muestra que coinciden con los criterios de filtro.

let mut cursor = my_coll
    .find(doc! { "$and": vec!
    [
        doc! { "unit_price": doc! { "$lt": 12.00 } },
        doc! { "category": doc! { "$ne": "kitchen" } }
    ] })
    .sort(doc! { "unit_price": -1 })
    .await?;
while let Some(result) = cursor.try_next().await? {
    println!("{:?}", result);
}

Inventory { item: "watering can", category: "garden", unit_price: 11.99 }
Inventory { item: "candle", category: "decor", unit_price: 2.89 }

let result = my_coll
    .find_one(doc! { "unit_price": doc! { "$lte": 20.00 } })
    .skip(2)
    .await?;
println!("{:#?}", result);

Some(
    Inventory {
        item: "watering can",
        category: "garden",
        unit_price: 11.99,
    },
)

Datos agregados del documento

El aggregate() método utiliza una canalización de agregación como parámetro. Una canalización de agregación incluye una o más etapas que especifican cómo transformar los datos. Cada etapa incluye un operador de agregación (con el $ prefijo) y los parámetros necesarios para dicho operador.

Para obtener más información sobre las agregaciones y ver ejemplos de agregaciones, consulte la guía de agregación.

El método devuelve los documentos resultantes en un Cursor tipo. Si su canal de agregación no contiene una etapa `$match`, el canal procesará todos los documentos de la colección.

Modificar el comportamiento de agregación

Puede modificar el comportamiento del método aggregate() encadenando los métodos de generación de opciones AggregateOptions a aggregate().

La siguiente tabla describe los campos AggregateOptions de uso común que puede configurar llamando a sus métodos de generación correspondientes:

Para obtener una lista completa de configuraciones, consulte la documentación de la API de AggregateOptions.

Ejemplo

Este ejemplo muestra cómo llamar al método aggregate() con una canalización que contiene las siguientes etapas:

• $group Etapa para calcular el promedio del campo unit_price para cada valor del campo category

• $sort Etapa para ordenar los resultados por avg_price en orden ascendente

let pipeline = vec![
    doc! { "$group": doc! { "_id" : doc! {"category": "$category"} ,
    "avg_price" : doc! { "$avg" : "$unit_price" } } },
    doc! { "$sort": { "_id.avg_price" : 1 } },
];
let mut cursor = my_coll.aggregate(pipeline).await?;
while let Some(result) = cursor.try_next().await? {
    println!("{:?}", result);
}

Document({"_id": Document({"category": String("decor")}), "avg_price": Double(2.890000104904175)})
Document({"_id": Document({"category": String("kitchen")}), "avg_price": Double(20.840000867843628)})
Document({"_id": Document({"category": String("garden")}), "avg_price": Double(11.989999771118164)})

Documentación de la API

Para obtener más información sobre los métodos y tipos mencionados en esta guía, consulte la siguiente documentación de API:

• find_one()

• find()

• FindOptions

• FindOneOptions

• Cursor

• agregar()

• Opciones agregadas