改进聚合查询以获得不同的结果
Improve aggregation query to get distinct results
我有这个聚合查询,returns Operation
字段 amount:BigDecimal
高于 minAmount
且在日期 range.I 内的对象只想获取不同的结果(每个 Operation
对象都有一个 operationId:String
),基于 operationId
.
我在这里找到了一个相关的例子,但它并没有帮助我解决我的问题:
我知道可以使用 addToSet
或 group
,但我不清楚如何将它准确地合并到查询的其余部分中
private List<OperationDataVO> getInfoFromDB(BigDecimal minAmount,
Instant startDate, Instant endDate) {
Criteria criterias = new Criteria()
.andOperator(Criteria.where(WinningOperation.AMOUNT)
.gte(minAmount)
.and(Operation.TYPE).is(OperationTypeEnum.WINNING_TYPE)
.and("createdAt").gte(startDate).lte(endDate));
MatchOperation matchOperation = Aggregation.match(criterias);
ProjectionOperation projectionOperation =
Aggregation.project("amount", "operationId");
Aggregation aggregation = Aggregation.newAggregation(matchOperation,
projectionOperation, sort(direction, "amount"));
AggregationResults<OperationDataVO> aggregate = mongoTemplate
.aggregate(aggregation, COLLECTION, OperationDataVO.class);
return aggregate.getMappedResults();
}
此外,我尝试在 Aggregation
管道中添加一个组操作,但是当我这样做时,我得到一个 OperationDataVO
列表,其中每个对象的两个字段都是 null
(Aggregation aggregation = Aggregation.newAggregation(matchOperation, projectionOperation, sort(direction, "amount"), group("operationId"));
)
在进行分组之前,您需要按 amount
降序排列。
应该使用“$first”累加器进行分组。我们使用 $$ROOT
保留整个文档。
然后您可以用组中的文档替换根文档。
分组不保留任何顺序,因为您想对最终结果进行排序,您需要重新排序。
实现此目的的 mongo shell 代码如下所示:
db.getCollection('operationData').aggregate([
{ $match: ... } ,
{ $project: { amount: 1, operationId: 1 } },
{ $sort: { amount: -1 } },
{ $group: { _id: '$operationId', g: { $first: {data: '$$ROOT'} }} },
{ $replaceRoot: { newRoot: '$g.data' }},
{ $sort: { amount: 1 } }
])
这需要翻译成Spring数据Mongo(也许我以后有时间自己试试)。
我有这个聚合查询,returns Operation
字段 amount:BigDecimal
高于 minAmount
且在日期 range.I 内的对象只想获取不同的结果(每个 Operation
对象都有一个 operationId:String
),基于 operationId
.
我在这里找到了一个相关的例子,但它并没有帮助我解决我的问题:
我知道可以使用 addToSet
或 group
,但我不清楚如何将它准确地合并到查询的其余部分中
private List<OperationDataVO> getInfoFromDB(BigDecimal minAmount,
Instant startDate, Instant endDate) {
Criteria criterias = new Criteria()
.andOperator(Criteria.where(WinningOperation.AMOUNT)
.gte(minAmount)
.and(Operation.TYPE).is(OperationTypeEnum.WINNING_TYPE)
.and("createdAt").gte(startDate).lte(endDate));
MatchOperation matchOperation = Aggregation.match(criterias);
ProjectionOperation projectionOperation =
Aggregation.project("amount", "operationId");
Aggregation aggregation = Aggregation.newAggregation(matchOperation,
projectionOperation, sort(direction, "amount"));
AggregationResults<OperationDataVO> aggregate = mongoTemplate
.aggregate(aggregation, COLLECTION, OperationDataVO.class);
return aggregate.getMappedResults();
}
此外,我尝试在 Aggregation
管道中添加一个组操作,但是当我这样做时,我得到一个 OperationDataVO
列表,其中每个对象的两个字段都是 null
(Aggregation aggregation = Aggregation.newAggregation(matchOperation, projectionOperation, sort(direction, "amount"), group("operationId"));
)
在进行分组之前,您需要按 amount
降序排列。
应该使用“$first”累加器进行分组。我们使用 $$ROOT
保留整个文档。
然后您可以用组中的文档替换根文档。
分组不保留任何顺序,因为您想对最终结果进行排序,您需要重新排序。
实现此目的的 mongo shell 代码如下所示:
db.getCollection('operationData').aggregate([
{ $match: ... } ,
{ $project: { amount: 1, operationId: 1 } },
{ $sort: { amount: -1 } },
{ $group: { _id: '$operationId', g: { $first: {data: '$$ROOT'} }} },
{ $replaceRoot: { newRoot: '$g.data' }},
{ $sort: { amount: 1 } }
])
这需要翻译成Spring数据Mongo(也许我以后有时间自己试试)。