Pagination & Tri

Utilise la pagination find générale, PageStream réactif, la page d'agrégation et SortSpec ordonné selon les besoins.

Pagination de recherche générale

java

Flux<User> users = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(pair("status", "ACTIVE"))
    .end()
    .findAll()
    .paging(0, 20)
    .sorts(sort -> sort.desc("id"))
    .execute();

pageNumber est basé sur 0. Un constructeur imbriqué sous la forme paging().pageNumber(...).pageSize(...).and() peut également être utilisé.

PageStream

java

PageStream<User> page = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(pair("status", "ACTIVE"))
    .end()
    .findAll()
    .paging(0, 20)
    .executePageStream();

Flux<User> data = page.data();
Mono<Long> totalCount = page.totalCount();

대량 처리에서 data를 즉시 List로 모으고 싶지 않다면 PageStream을 사용합니다. 필요하면 collectToPageResult()로 PageResult<T>로 변환할 수 있습니다.

Pagination d'agrégation

java

PageStream<User> page = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(pair("status", "ACTIVE"))
    .end()
    .findAll()
    .paging(0, 20)
    .executeAggregationPageStream();

Mono<PageResult<User>> collected = dsl
    .executeEntity(User.class, MongoTemplateName.FRONT)
    .fields(pair("status", "ACTIVE"))
    .end()
    .findAll()
    .paging(0, 20)
    .executeAggregation();

executeAggregation()은 reactive page data를 최종 List로 collect해 PageResult<T>를 만듭니다. stream 상태가 중요하면 executeAggregationPageStream()을 사용합니다.

SortSpec

java

.sorts(sort -> sort
    .desc("score")
    .asc("createdAt")
    .desc("id")
    .driver(Sorts.metaTextScore("textScore"))
)

La clé de tri maintient l'ordre d'ajout. La direction dynamique peut utiliser sort.of(direction, field) et le tri natif du Driver peut être mélangé avec driver(Bson).

Ajoutez un tri secondaire unique pour une pagination stable.

Pour les listes avec de nombreuses valeurs de score/date identiques, ajouter un champ stable et unique comme _id peut réduire les problèmes de fluctuation des frontières de page.