在Camel中使用动态选择器查询MongoDB

Question

我在这里找到了一个解决方案：如何使用ApacheCamel和MongoDB创建动态equals查询？

但这看起来需要做很多工作。难道Camel没有更简单的方法将值传递给MongoDB查询吗？我希望我们能传递Mongo使用的实际find（{}）语言。

以下是我的工作，一些日志显示了它在做什么：

.setHeader(MongoDbConstants.CRITERIA, new Expression() {
    @Override
    public <T> T evaluate(Exchange exchange, Class<T> type) {
        Long drRequestId = exchange.getIn().getHeader("orderid", Long.class);

        Bson equalsClause = Filters.eq("id", drRequestId);



        return exchange.getContext().getTypeConverter().convertTo(type, equalsClause);
    };
})
.log(MongoDbConstants.CRITERIA)
.log("${headers.CamelMongoDbCriteria}")
.to("mongodb:mongo?database={{spring.data.mongodb.database}}&collection=ftx_orders&operation=findOneByQuery")

Answer 1

你用${body.id}试过了吗？

此外，您还可以通过使用

exchange.getIn().setHeader("id","value");

然后用你上面提到的方法。

.setHeader(MongoDbConstants.CRITERIA, constant(Filters.eq("name", simple("${header.id}"))))