简而言之,我尝试使用find
和Query
对象检索对象的排序列表和aggregation
对象。
但是…没有运气-每次都是随机排序的列表。
我尝试了两个选项:
@Component
@RequiredArgsConstructor
public class EventFilteredRepository {
private final ReactiveMongoTemplate mongoTemplate;
public Flux<Event> findEventsByCriteriaSortedByHostRating(Criteria criteria){
return mongoTemplate.aggregate(Aggregation.newAggregation(Aggregation.match(criteria),
Aggregation.sort(Sort.by(Sort.Direction.DESC,"hostRating"))), "Event", Event.class);
}
}
:
@Component
@RequiredArgsConstructor
public class EventFilteredRepository {
private final ReactiveMongoTemplate mongoTemplate;
public Flux<Event> findEventsByCriteriaSortedByHostRating(Criteria criteria){
return mongoTemplate.find(Query.query(criteria).with(Sort.by(Sort.Order.desc("hostRating"))), Event.class);
}
}
我唯一能让它工作的方法是:
@Component
@RequiredArgsConstructor
public class EventFilteredRepository {
private final ReactiveMongoTemplate mongoTemplate;
public Flux<Event> findEventsByCriteriaSortedByHostRating(Criteria criteria){
return mongoTemplate.find(Query.query(criteria), Event.class).sort(Comparator.comparingDouble(Event::getHostRating).reversed());
}
}
但是这种方式我假设它在内存中完成所有的拖动光标,然后对其排序。对于大量的数据,这可能是一个大问题。
请帮助或建议任何事情!提前谢谢你!
我找到问题了。
我在不保持顺序的flatMap
中使用结果。
对于排序列表,需要使用concatMap
或flatMapSequential
。