Retrieve Data

查找所有匹配文档

要查找所有符合条件的文档，请使用find()方法。 此方法将查询筛选器作为参数。 查询筛选器由构成要匹配的文档条件的字段和值组成。

该方法返回一个Cursor类型，您可以遍历该类型以检索与过滤条件匹配的任何文档。

要查看使用此方法检索数据的示例，请参阅find() 示例。

要了解有关指定查询的更多信息，请参阅指定查询指南。

查找一个文档

要查找第一个符合条件的文档，请使用find_one()方法。 此方法将查询筛选器作为参数。 查询筛选器由构成要匹配的文档条件的字段和值组成。

如果文档与筛选条件匹配，该方法将返回值为Some的Result<Option<T>>类型。 如果没有符合筛选条件的文档， find_one()将返回值为None的Result<Option<T>>类型。

要查看使用此方法检索数据的示例，请参阅find_one()示例。

修改查找行为

您可以通过将FindOptions选项构建器方法链接到find()来修改find()方法的行为，也可以通过将FindOneOptions选项构建器方法链接到find_one()来修改find_one()方法的行为。

下表描述了常用的FindOptions和FindOneOptions字段，您可以通过调用相应的构建器方法来设立这两个字段：

有关可以为每种类型指定的设置的完整列表，请参阅 FindOptions 和 FindOneOptions 的API文档。

示例

以下部分包含使用find()和findOne()方法检索与过滤条件匹配的样本文档的示例。

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,
    },
)

聚合文档数据

aggregate()方法将聚合管道作为参数。 聚合管道包括一个或多个指定如何转换数据的阶段。 阶段包括聚合操作符（以$为前缀）以及该操作符所需的任何参数。

要了解有关聚合的更多信息并查看聚合示例，请参阅聚合指南。

该方法以Cursor类型返回结果文档。 如果聚合管道不包含$match阶段，则管道会处理集合中的所有文档。

修改聚合行为

您可以通过将AggregateOptions选项构建器方法链接到aggregate()来修改aggregate()方法的行为。

下表描述了常用的AggregateOptions字段，您可以通过调用相应的构建器方法来设立这些字段：

有关设置的完整列表，请参阅 AggregateOptions 的API文档。

例子

此示例演示如何使用包含以下阶段的管道调用aggregate()方法：

• $group 阶段，用于计算 category字段的每个值的 unit_price字段的平均值

• $sort 阶段按 avg_price 升序对结果进行排序

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)})

API 文档

要进一步了解本指南所提及的方法和类型，请参阅以下 API 文档：

• find_one()

• find()

• FindOptions

• FindOneOptions

• Cursor

• 聚合(aggregate)()

• AggregateOptions