public class ReactiveQuerydslMongoPredicateExecutor<T> extends Object implements ReactiveQuerydslPredicateExecutor<T>
QuerydslPredicateExecutor that allows execution Predicates in various forms.| Constructor and Description |
|---|
ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation,
ReactiveMongoOperations mongoOperations)
Creates a new
ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation and
ReactiveMongoOperations. |
ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation,
ReactiveMongoOperations mongoOperations,
EntityPathResolver resolver)
Creates a new
ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation,
ReactiveMongoOperations and EntityPathResolver. |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<Long> |
count(com.querydsl.core.types.Predicate predicate) |
reactor.core.publisher.Mono<Boolean> |
exists(com.querydsl.core.types.Predicate predicate) |
reactor.core.publisher.Flux<T> |
findAll(com.querydsl.core.types.OrderSpecifier<?>... orders) |
reactor.core.publisher.Flux<T> |
findAll(com.querydsl.core.types.Predicate predicate) |
reactor.core.publisher.Flux<T> |
findAll(com.querydsl.core.types.Predicate predicate,
com.querydsl.core.types.OrderSpecifier<?>... orders) |
reactor.core.publisher.Flux<T> |
findAll(com.querydsl.core.types.Predicate predicate,
Sort sort) |
<S extends T,R,P extends org.reactivestreams.Publisher<R>> |
findBy(com.querydsl.core.types.Predicate predicate,
Function<FluentQuery.ReactiveFluentQuery<S>,P> queryFunction) |
reactor.core.publisher.Mono<T> |
findOne(com.querydsl.core.types.Predicate predicate) |
protected org.springframework.data.mongodb.repository.support.SpringDataMongodbSerializer |
mongodbSerializer() |
protected static <E> com.querydsl.core.types.dsl.PathBuilder<E> |
pathBuilderFor(com.querydsl.core.types.EntityPath<E> path) |
protected com.querydsl.core.types.OrderSpecifier<?> |
toOrder(Sort.Order order)
Transforms a plain
Sort.Order into a Querydsl specific OrderSpecifier. |
protected List<com.querydsl.core.types.OrderSpecifier<?>> |
toOrderSpecifiers(Sort sort)
Converts the given
Sort to OrderSpecifier. |
protected EntityInformation<T,?> |
typeInformation() |
public ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation, ReactiveMongoOperations mongoOperations)
ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation and
ReactiveMongoOperations. Uses the SimpleEntityPathResolver to create an EntityPath for the
given domain class.entityInformation - must not be null.mongoOperations - must not be null.public ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation, ReactiveMongoOperations mongoOperations, EntityPathResolver resolver)
ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation,
ReactiveMongoOperations and EntityPathResolver.entityInformation - must not be null.mongoOperations - must not be null.resolver - must not be null.public reactor.core.publisher.Mono<T> findOne(com.querydsl.core.types.Predicate predicate)
findOne in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate)
findAll in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate, com.querydsl.core.types.OrderSpecifier<?>... orders)
findAll in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate, Sort sort)
findAll in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.OrderSpecifier<?>... orders)
findAll in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Mono<Long> count(com.querydsl.core.types.Predicate predicate)
count in interface ReactiveQuerydslPredicateExecutor<T>public reactor.core.publisher.Mono<Boolean> exists(com.querydsl.core.types.Predicate predicate)
exists in interface ReactiveQuerydslPredicateExecutor<T>public <S extends T,R,P extends org.reactivestreams.Publisher<R>> P findBy(com.querydsl.core.types.Predicate predicate, Function<FluentQuery.ReactiveFluentQuery<S>,P> queryFunction)
findBy in interface ReactiveQuerydslPredicateExecutor<T>protected static <E> com.querydsl.core.types.dsl.PathBuilder<E> pathBuilderFor(com.querydsl.core.types.EntityPath<E> path)
protected EntityInformation<T,?> typeInformation()
protected org.springframework.data.mongodb.repository.support.SpringDataMongodbSerializer mongodbSerializer()
protected com.querydsl.core.types.OrderSpecifier<?> toOrder(Sort.Order order)
Sort.Order into a Querydsl specific OrderSpecifier.order - Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.