Package org.springframework.data.mongodb.repository.support

Class ReactiveQuerydslMongoPredicateExecutor<T>

java.lang.Object

org.springframework.data.mongodb.repository.support.ReactiveQuerydslMongoPredicateExecutor<T>

All Implemented Interfaces:

ReactiveQuerydslPredicateExecutor<T>

public class ReactiveQuerydslMongoPredicateExecutor<T>
extends Object
implements ReactiveQuerydslPredicateExecutor<T>

MongoDB-specific QuerydslPredicateExecutor that allows execution Predicates in various forms.

Since:

2.2

Author:

Mark Paluch, Christoph Strobl

Constructor Summary

Constructors

Constructor	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.

Method Summary

Modifier and Type	Method	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>> P	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReactiveQuerydslMongoPredicateExecutor

public ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation,
 ReactiveMongoOperations mongoOperations)

Creates a new ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation and ReactiveMongoOperations. Uses the SimpleEntityPathResolver to create an EntityPath for the given domain class.

Parameters:

entityInformation - must not be null.

mongoOperations - must not be null.

ReactiveQuerydslMongoPredicateExecutor

public ReactiveQuerydslMongoPredicateExecutor(MongoEntityInformation<T,?> entityInformation,
 ReactiveMongoOperations mongoOperations,
 EntityPathResolver resolver)

Creates a new ReactiveQuerydslMongoPredicateExecutor for the given MongoEntityInformation, ReactiveMongoOperations and EntityPathResolver.

Parameters:

entityInformation - must not be null.

mongoOperations - must not be null.

resolver - must not be null.

Method Details

findOne

public reactor.core.publisher.Mono<T> findOne(com.querydsl.core.types.Predicate predicate)

Specified by:

findOne in interface ReactiveQuerydslPredicateExecutor<T>

findAll

public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate)

Specified by:

findAll in interface ReactiveQuerydslPredicateExecutor<T>

findAll

public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate,
 com.querydsl.core.types.OrderSpecifier<?>... orders)

Specified by:

findAll in interface ReactiveQuerydslPredicateExecutor<T>

findAll

public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.Predicate predicate,
 Sort sort)

Specified by:

findAll in interface ReactiveQuerydslPredicateExecutor<T>

findAll

public reactor.core.publisher.Flux<T> findAll(com.querydsl.core.types.OrderSpecifier<?>... orders)

Specified by:

findAll in interface ReactiveQuerydslPredicateExecutor<T>

count

public reactor.core.publisher.Mono<Long> count(com.querydsl.core.types.Predicate predicate)

Specified by:

count in interface ReactiveQuerydslPredicateExecutor<T>

exists

public reactor.core.publisher.Mono<Boolean> exists(com.querydsl.core.types.Predicate predicate)

Specified by:

exists in interface ReactiveQuerydslPredicateExecutor<T>

findBy

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)

Specified by:

findBy in interface ReactiveQuerydslPredicateExecutor<T>

pathBuilderFor

protected static <E>
com.querydsl.core.types.dsl.PathBuilder<E> pathBuilderFor(com.querydsl.core.types.EntityPath<E> path)

typeInformation

protected EntityInformation<T,?> typeInformation()

mongodbSerializer

protected org.springframework.data.mongodb.repository.support.SpringDataMongodbSerializer mongodbSerializer()

toOrder

protected com.querydsl.core.types.OrderSpecifier<?> toOrder(Sort.Order order)

Transforms a plain Sort.Order into a Querydsl specific OrderSpecifier.

Parameters:

order -

Returns:

toOrderSpecifiers

protected List<com.querydsl.core.types.OrderSpecifier<?>> toOrderSpecifiers(Sort sort)

Converts the given Sort to OrderSpecifier.

Parameters:

sort -

Returns: