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 query, consulta la guía Especificar una query.

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, consulta el ejemplo de find_one().

Modificar el comportamiento de búsqueda

Puedes modificar el comportamiento de find() pasando una instancia de FindOptions como parámetro, y puedes modificar el comportamiento de find_one() pasando una instancia de FindOneOptions.

Para usar valores por defecto para cada configuración, especifica el valor None como parámetro de opciones.

La siguiente tabla describe la configuración utilizada comúnmente que puedes especificar en FindOptions y FindOneOptions:

Para una lista completa de ajustes que puede especificar para cada tipo, consulte la documentación de la API para FindOptions y 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 opts = FindOptions::builder()
    .sort(doc! { "unit_price": -1 })
    .build();
let mut cursor = my_coll.find(
    doc! { "$and": vec!
        [
            doc! { "unit_price": doc! { "$lt": 12.00 } },
            doc! { "category": doc! { "$ne": "kitchen" } }
        ] },
    opts
).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 opts = FindOneOptions::builder().skip(2).build();
let result = my_coll.find_one(
    doc! { "unit_price":
        doc! { "$lte": 20.00 } },
    opts
).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 de aggregate() pasando una instancia de AggregateOptions como parámetro opcional.

Para usar valores por defecto para cada configuración, especifica el valor None como parámetro de opciones.

La siguiente tabla describe las configuraciones de uso común que puede especificar en AggregateOptions:

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:

• Una etapa de $group para agrupar documentos por el campo category y calcular el promedio del campo unit_price por category

• Una etapa de $sort para 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, None).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