0

简而言之 - 我尝试使用对象和对象来检索对象的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());
    }
}

但是这种方式我假设它在内存中完成所有操作,拉出所有光标然后对其进行排序。对于大量数据,这可能是一个大问题。

请帮助或建议任何事情!非常感谢您!

4

1 回答 1

0

我确实发现了问题。

我在flatMap不保留顺序的情况下使用结果。

需要使用concatMapflatMapSequential用于排序列表。

于 2021-09-15T20:59:10.143 回答