Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

227.6. MongoDB Operations - producer 端点

227.6.1. 查询操作

227.6.1.1. findById

此操作从其 _id 字段与 IN 消息正文内容匹配的集合中检索一个元素。传入对象可以是与 BSON 类型等效的任何内容。请参阅 http://bsonspec.org//specification[http://bsonspec.org// specification] 和 http://www.mongodb.org/display/DOCS/Java+Types。

Copy to Clipboard Toggle word wrap 
from("direct:findById")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findById")
    .to("mock:resultFindById");
提示

支持可选参数。此操作支持指定字段过滤器。请参阅 指定可选参数。

227.6.1.2. findOneByQuery

使用此操作从与 MongoDB 查询匹配的集合中检索一个元素。查询对象从 IN 消息正文中提取，即，它的类型应该是 DBObject 的类型，或者转换为 DBObject。它可以是 JSON String 或 Hashmap。如需更多信息，请参阅 #Type 转换。

没有查询的示例（返回集合的任何对象）：

Copy to Clipboard Toggle word wrap 
from("direct:findOneByQuery")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findOneByQuery")
    .to("mock:resultFindOneByQuery");

带有查询的示例（返回一个匹配的结果）：

Copy to Clipboard Toggle word wrap 
from("direct:findOneByQuery")
    .setBody().constant("{ \"name\": \"Raul Kripalani\" }")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findOneByQuery")
    .to("mock:resultFindOneByQuery");
提示

支持可选参数。此操作支持指定字段过滤器和/或排序子。请参阅 指定可选参数。

227.6.1.3. findAll

findAll 操作会返回与查询匹配的所有文档，或根本没有内容，在这种情况下，集合中包含的所有文档都会被返回。查询对象从 IN 消息正文中提取，即，它的类型应该是 DBObject 的类型，或者转换为 DBObject。它可以是 JSON String 或 Hashmap。如需更多信息，请参阅 #Type 转换。

没有查询的示例（在集合中返回所有对象）：

Copy to Clipboard Toggle word wrap 
from("direct:findAll")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findAll")
    .to("mock:resultFindAll");

带有查询的示例（返回所有匹配结果）：

Copy to Clipboard Toggle word wrap 
from("direct:findAll")
    .setBody().constant("{ \"name\": \"Raul Kripalani\" }")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findAll")
    .to("mock:resultFindAll");

通过以下标头支持分页和高效的检索：

标头密钥快速持续描述（从 MongoDB API doc中提取）预期类型

CamelMongoDbNumToSkip

MongoDbConstants.NUM_TO_SKIP

丢弃光标开头的给定数量元素。

int/Integer

CamelMongoDbLimit

MongoDbConstants.LIMIT

限制返回的元素数量。

int/Integer

CamelMongoDbBatchSize

MongoDbConstants.BATCH_SIZE

限制一个批处理中返回的元素数量。光标通常获取结果对象的批处理，并将它们存储在本地。如果 batchSize 为正数，代表检索对象的每个批处理的大小。可以调整它，以优化性能和限制数据传输。如果 batchSize 为负数，它将限制返回的数量对象，其适用于最大批处理大小限制（通常为 4MB），并且光标将被关闭。例如，如果 batchSize 是 -10，那么服务器会返回最多 10 个文档，并且与在 4MB 中可容纳的数目像 4MB 一样，然后关闭光标。请注意，这个功能与在最大大小的 limit （）中不同，它不需要发送请求以关闭光标服务器端。即使在迭代光标后，也可以更改批处理大小，在这种情况下，设置将应用到下一个批处理检索。

int/Integer

您还可以通过包含 outputType=DBCursor (Camel 2.16+)作为 endpoint 选项，从服务器返回至您的路由的文档可能比设置上述标头更简单。这个 Exchange the DBCursor 来自 Mongo 驱动程序，就如同是在 Mongo shell 中执行 findAll （）一样，允许您的路由迭代结果。默认情况下，如果不使用此选项，此组件会将驱动程序的光标中的文档加载到列表，并将此数据返回到您的路由 - 这可能导致大量内存对象。请记住，使用 DBCursor 并不要求提供匹配的文档数量 - 请参阅 MongoDB 文档网站了解详细信息。

带有选项 outputType=DBCursor 和批处理大小 的示例：

Copy to Clipboard Toggle word wrap 
from("direct:findAll")
    .setHeader(MongoDbConstants.BATCH_SIZE).constant(10)
    .setBody().constant("{ \"name\": \"Raul Kripalani\" }")
    .to("mongodb:myDb?database=flights&collection=tickets&operation=findAll&outputType=DBCursor")
    .to("mock:resultFindAll");

findAll 操作也会返回以下 OUT 标头，以便在使用分页时迭代结果页面：

标头密钥快速持续描述（从 MongoDB API doc中提取）数据类型

CamelMongoDbResultTotalSize

MongoDbConstants.RESULT_TOTAL_SIZE

与查询匹配的对象数量。这不会考虑限制/跳过。

int/Integer

CamelMongoDbResultPageSize

MongoDbConstants.RESULT_PAGE_SIZE

与查询匹配的对象数量。这不会考虑限制/跳过。

int/Integer

提示

支持可选参数。此操作支持指定字段过滤器和/或排序子。请参阅 指定可选参数。

227.6.1.4. 数量

返回集合中对象总数，将 Long 返回为 OUT 消息正文。
以下示例将计算 "dynamicCollectionName" 中的记录数。请注意，动态程度如何启用动态，因此操作不会针对"可见的Scientists"集合运行，而是针对"dynamicCollectionName"集合运行。

Copy to Clipboard Toggle word wrap 
// from("direct:count").to("mongodb: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);

从 Camel 2.14 开始，您可以提供消息正文中的 com.mongodb.DBObject 对象作为查询，操作会返回与此条件匹配的文档量。 

 

Copy to Clipboard Toggle word wrap 
DBObject query = ...
Long count = template.requestBodyAndHeader("direct:count", query, MongoDbConstants.COLLECTION, "dynamicCollectionName");

227.6.1.5. 指定字段过滤器（项目）

默认情况下，查询操作将完全返回匹配的对象（包含所有字段）。如果您的文档庞大，且您只需要检索其字段的子集，只需在所有查询操作中指定字段过滤器，只需设置相关的 DBObject （或者类型可以转换为 DBObject，如 JSON String、Map 等）在 CamelMongoDbFieldsFilter 标头上指定字段过滤器，持续快捷键：Mon DConstants.FIELDS_FILTER。

下面是一个示例，它使用 MongoDB 的 BasicDBObjectBuilder 来简化 DBObject 的创建。它检索 _id 和 boringField 以外的所有字段：

Copy to Clipboard Toggle word wrap 
// route: from("direct:findAll").to("mongodb:myDb?database=flights&collection=tickets&operation=findAll")
DBObject fieldFilter = BasicDBObjectBuilder.start().add("_id", 0).add("boringField", 0).get();
Object result = template.requestBodyAndHeader("direct:findAll", (Object) null, MongoDbConstants.FIELDS_FILTER, fieldFilter);

227.6.1.6. 指定 sort 子句

通常需要根据特定字段排序从集合中获取 min/max 记录。在 Mongo 中，操作是使用类似如下的语法执行的：

Copy to Clipboard Toggle word wrap 
db.collection.find().sort({_id: -1}).limit(1)
// or
db.collection.findOne({$query:{},$orderby:{_id:-1}})

在 Camel 路由中，可将 SORT_BY 标头用于 findOneByQuery 操作，以达到相同的结果。如果还指定 FIELDS_FILTER 标头，其操作会返回可直接传递给另一个组件的单个字段/值对（例如，参数化 MyBatis SELECT 查询）。本例演示了根据 documentTimestamp 字段从集合中获取最新文档并将结果减少到单个字段：

Copy to Clipboard Toggle word wrap 
.from("direct:someTriggeringEvent")
.setHeader(MongoDbConstants.SORT_BY).constant("{\"documentTimestamp\": -1}")
.setHeader(MongoDbConstants.FIELDS_FILTER).constant("{\"documentTimestamp\": 1}")
.setBody().constant("{}")
.to("mongodb:myDb?database=local&collection=myDemoCollection&operation=findOneByQuery")
.to("direct:aMyBatisParameterizedSelect")
;
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat, Inc.