代码之家 › 专栏 › 技术社区 › vod0029

使用WSO2EI和MongoDB进行自定义聚合

jongo wso2dss wso2 mongodb

vod0029 · 技术社区 · 7 年前

我正试图在WSO2DSS(在WSO2EI中)中实现Mongo数据服务的聚合操作,因为只有CRUD和Count这样的基本操作才受到开箱即用的支持 here . 所以我克隆了 WSO2EI code version 4.4.10 (我们的团队碰巧正在使用此版本),我已经成功添加了一些自己的功能。然而,每当我尝试使用 org.jongo.MongoCollection.aggregate() 函数,我得到错误 Error in MongoQuery.runQuery: Command failed with error 9: 'The 'cursor' option is required, except for aggregate with the explain argument' . 我查看了所有关于这个问题的帖子,并尝试使用不同版本的Mongo驱动程序(3.4、3.6..),也更改了很多实际语法,但无论我尝试什么,如果我使用 .aggregate() 作用我也应该使用 org.jongo.MongoCollection.aggregate(String pipelineOperator) 或 com.mongodb.async.client.aggregate(java.util.List<? extends Bson> pipeline) 如Mongo Java 3.6文档所述 here . 我使用的示例代码:

private Iterator<MongoTestClass> doAggregate1(MongoCollection collection, String opQuery, Object[] parameters) throws DataServiceFault {

        return collection.aggregate("{$match:{componentType:'Endpoint'}}")
                .as(MongoTestClass.class).iterator();

    }

哪里 componentType 是我的MongoDB集合文档中的现有字段,并且 'Endpoint' 就是它的价值。我的实际synatax错了吗?或者还有其他问题吗?如何添加 'cursor' 这样错误就消失了?

我不知道这是怎么回事。。。非常感谢您的帮助。

1 回复 | 直到 7 年前

s7vr 7 年前

从文档中。

MongoDB 3.4不赞成使用不带光标的聚合命令选项,除非管道包含explain选项。什么时候使用aggregate命令内联返回聚合结果, 使用默认的批大小游标指定游标选项:{}或在光标选项光标中指定批次大小:{批次大小: }.

你可以通过 batchSize 具有 AggregationOptions Jongo骨料法。

AggregationOptions options = AggregationOptions.builder().options.
     batchSize(100).
     outputMode(AggregationOptions.OutputMode.CURSOR).build();

collection.aggregate("{$match:{componentType:'Endpoint'}}").options(options).as(MongoTestClass.class).iterator();

使用默认批量大小

AggregationOptions options = AggregationOptions.builder().options.
     outputMode(AggregationOptions.OutputMode.CURSOR).build();

或

AggregationOptions options = AggregationOptions.builder().build();

collection.aggregate("{$match:{componentType:'Endpoint'}}").options(options).as(MongoTestClass.class).iterator();

推荐文章

Tom McLean · 如何使用证书管理器制作的证书在AWS上创建到mongodb实例的TLS/SSL连接?健康检查失败

6 月前

hasratyan · Next.js 15 API路由-动态路由中的无效GET导出错误[id]

6 月前

RoadieRich · MongoDB:无法创建<type>的实例,因为它是一个抽象类

6 月前

Plup · 连接失败时,PyMongo异步客户端未引发异常

8 月前

Yusuf Damista · 将mongodb节点代码转换为php

8 月前

ian12_ · 客户端未定义,无法使用mongodb驱动程序连接到数据库

11 月前

Sachin · Spring Session响应MongoDB-如何处理属性

11 月前

Isus Ramzy · 如何在Vercel中使用“pymongo”和“flask”

11 月前

weareblahs · 由于BSONError,路径(pathName)处的值(数组)转换为ObjectId失败

11 月前

sachin p · MongoDB docker的默认用户和密码

11 月前