简而言之,我尝试使用带有Query
对象的find
和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());
}
}
但是通过这种方式,我假设这一切都是在内存中完成的--拉出所有的游标,然后对其进行排序。对于大量的数据来说,这可能是一个大问题。
请帮助或建议任何事情!提前谢谢你!
发布于 2021-09-15 20:59:10
实际上我发现了问题所在。
我在一个不能保持顺序的flatMap
中使用结果。
对于排序列表,需要使用concatMap
或flatMapSequential
。
https://stackoverflow.com/questions/69199472
复制相似问题