Package org.springframework.data.neo4j.repository.query

Class ReactiveQuerydslNeo4jPredicateExecutor<T>

java.lang.Object

org.springframework.data.neo4j.repository.query.ReactiveQuerydslNeo4jPredicateExecutor<T>

Type Parameters:

T - The returned domain type.

All Implemented Interfaces:

ReactiveQuerydslPredicateExecutor<T>

@API(status=INTERNAL,
     since="6.2")
public final class ReactiveQuerydslNeo4jPredicateExecutor<T>
extends Object
implements ReactiveQuerydslPredicateExecutor<T>

Querydsl specific fragment for extending SimpleReactiveNeo4jRepository with an implementation of ReactiveQuerydslPredicateExecutor. Provides the necessary infrastructure for translating Query-DSL predicates into conditions that are passed along to the Cypher-DSL and eventually to the template infrastructure. This fragment will be loaded by the repository infrastructure when a repository is declared extending the above interface.

Since:

6.2

Author:

Michael J. Simons

Constructor Summary

Constructors

Constructor	Description
ReactiveQuerydslNeo4jPredicateExecutor(Neo4jMappingContext mappingContext, Neo4jEntityInformation<T,Object> entityInformation, ReactiveNeo4jOperations neo4jOperations)

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)

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveQuerydslNeo4jPredicateExecutor

public ReactiveQuerydslNeo4jPredicateExecutor(Neo4jMappingContext mappingContext,
 Neo4jEntityInformation<T,Object> entityInformation,
 ReactiveNeo4jOperations neo4jOperations)

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,
 Sort sort)

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