红帽全球峰会228.5. MongoDB 操作 - producer 端点
228.5.1. 查询操作
228.5.1.1. findById
此操作只从 _id 字段的集合中检索一个元素，该元素与 IN 消息正文的内容匹配。传入对象可以是等同于 Bson 类型的任何对象。请参阅 http://bsonspec.org//specification[http://bsonspec.org// specification] 和 http://www.mongodb.org/display/DOCS/Java+Types。
from("direct:findById")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findById")
.to("mock:resultFindById");
from("direct:findById")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findById")
.to("mock:resultFindById");支持可选参数。此操作支持指定字段过滤器。请参阅 指定可选参数。
228.5.1.2. findOneByQuery
使用这个操作从与 MongoDB 查询匹配的集合中仅检索一个元素（第一个）。查询对象被提取为 CamelMongoDbCriteria 标头。如果 CamelMongoDbCriteria 标头为空，则会提取查询对象正文，例如： Bson 或将可转换为 Bson。它可以是 JSON String 或 Hashmap。如需更多信息，请参阅 #Type 转换。您可以使用 MongoDB Driver 中的 Filters 类。
没有查询的示例（返回集合的任何对象）：
from("direct:findOneByQuery")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findOneByQuery")
.to("mock:resultFindOneByQuery");
from("direct:findOneByQuery")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findOneByQuery")
.to("mock:resultFindOneByQuery");带有查询的示例（返回一个匹配的结果）：
from("direct:findOneByQuery")
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findOneByQuery")
.to("mock:resultFindOneByQuery");
from("direct:findOneByQuery")
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findOneByQuery")
.to("mock:resultFindOneByQuery");支持可选参数。此操作支持指定字段投射和/或排序子。请参阅 指定可选参数。
228.5.1.3. findAll
findAll 操作会返回与查询匹配或 none 的所有文档，在这种情况下，当集合中包含的所有文档都会被返回。query 对象提取 CamelMongoDbCriteria 标头。如果 CamelMongoDbCriteria 标头为 null，则查询对象正在提取消息正文，即它应当键入 Bson 或转换为 Bson。它可以是 JSON String 或 Hashmap。如需更多信息，请参阅 #Type 转换。
没有查询的示例（在集合中返回所有对象）：
from("direct:findAll")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
.to("mock:resultFindAll");
from("direct:findAll")
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
.to("mock:resultFindAll");带有查询的示例（返回所有匹配结果）：
from("direct:findAll")
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
.to("mock:resultFindAll");
from("direct:findAll")
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
.to("mock:resultFindAll");以下标头支持分页和有效的检索：
| 标头密钥 | 快速持续 | 描述（从 MongoDB API doc中提取） | 预期类型 |
|---|---|---|---|
|
|
| 在光标的开头丢弃指定数量的元素。 | int/Integer |
|
|
| 限制返回的元素数量。 | int/Integer |
|
|
| 限制一个批处理中返回的元素数量。光标通常获取结果对象的批处理，并将它们保存到本地。如果 batchSize 是正数的，它代表检索的每个批处理对象的大小。可以调整它以优化性能和限制数据传输。如果 batchSize 为负数，它将限制返回的数字对象，这适用于最大批处理大小限制（通常为 4MB），光标将被关闭。例如，如果 batchSize 是 -10，则服务器将返回最多 10 个文档，并且尽可能多地在 4MB 中容纳，然后关闭光标。请注意，这个功能与文档中的 limit（）不同，该文档必须在最大大小内容纳，它不再需要发送请求以关闭光标服务器。即使要迭代光标，也可以更改批处理大小，在这种情况下，设置将应用到下一个批处理检索。 | int/Integer |
带有选项 outputType=MongoIterable 和 batch 大小示例：
from("direct:findAll")
.setHeader(MongoDbConstants.BATCH_SIZE).constant(10)
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll&outputType=MongoIterable")
.to("mock:resultFindAll");
from("direct:findAll")
.setHeader(MongoDbConstants.BATCH_SIZE).constant(10)
.setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "Raul Kripalani"))
.to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll&outputType=MongoIterable")
.to("mock:resultFindAll");
findAll 操作还会返回以下 OUT 标头，以便在使用分页时迭代结果页面：
| 标头密钥 | 快速持续 | 描述（从 MongoDB API doc中提取） | 数据类型 |
|---|---|---|---|
|
|
| 与查询匹配的对象数。这不会考虑 limit/skip。 | int/Integer |
|
|
| 与查询匹配的对象数。这不会考虑 limit/skip。 | int/Integer |
支持可选参数。此操作支持指定字段投射和/或排序子。请参阅 指定可选参数。
228.5.1.4. 数量
返回集合中对象总数，返回 OUT 邮件正文。
以下示例将计算"dynamicCollectionName"集合中的记录数。请注意如何启用动态性，因此操作不会针对"明确的家"集合运行，而是针对"dynamicCollectionName"集合来运行。
// from("direct:count").to("mongodb3:myDb?database=tickets&collection=flights&operation=count&dynamicity=true");
Long result = template.requestBodyAndHeader("direct:count", "irrelevantBody", MongoDbConstants.COLLECTION, "dynamicCollectionName");
assertTrue("Result is not of type Long", result instanceof Long);
// from("direct:count").to("mongodb3:myDb?database=tickets&collection=flights&operation=count&dynamicity=true");
Long result = template.requestBodyAndHeader("direct:count", "irrelevantBody", MongoDbConstants.COLLECTION, "dynamicCollectionName");
assertTrue("Result is not of type Long", result instanceof Long);
您可以提供 查询对象 提取 CamelMongoDbCriteria 标头。如果 CamelMongoDbCriteria 标头为空，则查询对象是提取的消息正文，即： Bson 或将可转换为 Bson。操作将返回匹配此条件的文档数量。
Document query = ...
Long count = template.requestBodyAndHeader("direct:count", query, MongoDbConstants.COLLECTION, "dynamicCollectionName");
Document query = ...
Long count = template.requestBodyAndHeader("direct:count", query, MongoDbConstants.COLLECTION, "dynamicCollectionName");228.5.1.5. 指定字段过滤器（项目）
默认情况下，查询操作将全部返回匹配对象（含有所有字段）。如果您的文档较大，且您只需要检索其字段的子集，您可以在所有查询操作中指定字段过滤器，只需设置相关的 （或类型转换为 Bson），如 Bson CamelMongoDbFieldsProjection 标头上的 JSON String、Map 等。
下面是一个示例，它使用 MongoDB 的投射来简化 Bson 的创建。它检索 _id 和 boringField 以外的所有字段：
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson fieldProjection = Projection.exclude("_id", "boringField");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.FIELDS_PROJECTION, fieldProjection);
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson fieldProjection = Projection.exclude("_id", "boringField");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.FIELDS_PROJECTION, fieldProjection);
下面是一个示例，它使用 MongoDB 的投射来简化 Bson 的创建。它检索 _id 和 boringField 以外的所有字段：
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson fieldProjection = Projection.exclude("_id", "boringField");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.FIELDS_PROJECTION, fieldProjection);
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson fieldProjection = Projection.exclude("_id", "boringField");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.FIELDS_PROJECTION, fieldProjection);228.5.1.6. 指定 sort 子句
通常需要根据特定字段排序从集合中获取 min/max 记录，以使用 MongoDB 的 Sorts 简化 Bson 的创建。它检索 _id 和 boringField 以外的所有字段：
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson sorts = Sorts.descending("_id");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.SORT_BY, sorts);
// route: from("direct:findAll").to("mongodb3:myDb?database=flights&collection=tickets&operation=findAll")
Bson sorts = Sorts.descending("_id");
Object result = template.requestBodyAndHeader("direct:findAll", ObjectUtils.NULL, MongoDbConstants.SORT_BY, sorts);
在 Camel 路由中，SORT_BY 标头可与 findOneByQuery 操作一起使用，以获得相同的结果。如果还指定了 FIELDS_PROJECTION 标头，操作会返回单个字段/值对，可以直接传递给另一组件（例如，参数化 MyBatis SELECT 查询）。本例演示了根据文档 Timestamp 字段从集合中获取最新文档，并将结果减少到单个字段：
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}