Retrieve Data

Encontrar todos los documentos coincidentes

Para encontrar todos los documentos que coincidan con tus criterios, utiliza el método find(). Este método toma un filtro de query como parámetro. Un filtro de query consta de los campos y valores que forman los criterios para que los documentos coincidan.

El método retorna un tipo Cursor a través del cual puedes iterar para recuperar cualquier documento que coincida con los criterios de filtro.

Para ver un ejemplo que utiliza este método para recuperar datos, consulta el ejemplo de 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 cumpla con tus criterios, usa el método find_one(). Este método toma un filtro de query como parámetro. Un filtro de query consta de los campos y valores que forman los criterios para que los documentos coincidan.

Si un documento coincide con los criterios del filtro, el método devuelve un tipo Result<Option<T>> con un valor de Some. Si ningún documento cumple con los criterios del 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 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,
    },
)

Agrupar datos de documentos

El método aggregate() toma una pipeline de agregación como parámetro. Una pipeline de agregación incluye una o más etapas que especifican cómo transformar los datos. Una etapa incluye un operador de agregación (precedido por un $) y cualquier parámetro requerido para ese operador.

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

El método devuelve los documentos resultantes en un tipo Cursor. Si tu pipeline de agregación no contiene una etapa $match, el pipeline procesa 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, consulta la documentación de la API para AggregateOptions.

Ejemplo

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

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

• $sort escenario 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, vea la siguiente documentación de la API:

• find_one()

• find()

• FindOptions

• FindOneOptions

• Cursor

• aggregate()

• AggregateOptions