Package org.hibernate.reactive.query.spi

Class ReactiveAbstractSelectionQuery<R>

java.lang.Object

org.hibernate.reactive.query.spi.ReactiveAbstractSelectionQuery<R>

Type Parameters:

R -

public class ReactiveAbstractSelectionQuery<R>
extends Object

Emulate AbstractSelectionQuery.

Hibernate Reactive implementations already extend another class, they cannot extends too. This approach allows us to avoid duplicating code.

Constructor Summary

Constructors

Constructor	Description
ReactiveAbstractSelectionQuery(Supplier<QueryOptions> queryOptionsSupplier, SharedSessionContractImplementor session, Supplier<CompletionStage<List<R>>> doList, Supplier<SqmStatement<?>> getStatement, Supplier<TupleMetadata> getTupleMetadata, Supplier<DomainParameterXref> getDomainParameterXref, Supplier<Class<?>> getResultType, Supplier<String> getQueryString, Runnable beforeQuery, Consumer<Boolean> afterQuery, Function<List<R>,R> uniqueElement, InterpretationsKeySource interpretationsKeySource)
ReactiveAbstractSelectionQuery(InterpretationsKeySource interpretationKeySource, SharedSessionContractImplementor session, Supplier<CompletionStage<List<R>>> doList, Supplier<SqmStatement<?>> getStatement, Supplier<TupleMetadata> getTupleMetadata, Supplier<DomainParameterXref> getDomainParameterXref, Supplier<Class<?>> getResultType, Supplier<String> getQueryString, Runnable beforeQuery, Consumer<Boolean> afterQuery, Function<List<R>,R> uniqueElement)

Method Summary

Modifier and Type	Method	Description
<T> ReactiveSelectQueryPlan<T>	buildConcreteSelectQueryPlan(SqmSelectStatement<?> concreteSqmStatement, Class<T> resultType, QueryOptions queryOptions)
void	enableFetchProfile(String profileName)
Callback	getCallback()
DomainParameterXref	getDomainParameterXref()
String	getQueryString()
CompletionStage<Long>	getReactiveResultsCount(SqmSelectStatement<?> sqmStatement, DomainQueryExecutionContext domainQueryExecutionContext)
CompletionStage<R>	getReactiveSingleResult()
CompletionStage<R>	getReactiveSingleResultOrNull()
List<R>	getResultList()
Stream<R>	getResultStream()
Class<R>	getResultType()
R	getSingleResult()
R	getSingleResultOrNull()
SqmStatement<R>	getSqmStatement()
TupleMetadata	getTupleMetadata()
List<R>	list()
CompletionStage<List<R>>	reactiveList()
CompletionStage<R>	reactiveUnique()
CompletionStage<Optional<R>>	reactiveUniqueResultOptional()
ReactiveSelectQueryPlan<R>	resolveSelectReactiveQueryPlan()
R	uniqueResult()
Optional<R>	uniqueResultOptional()

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveAbstractSelectionQuery

public ReactiveAbstractSelectionQuery(InterpretationsKeySource interpretationKeySource,
 SharedSessionContractImplementor session,
 Supplier<CompletionStage<List<R>>> doList,
 Supplier<SqmStatement<?>> getStatement,
 Supplier<TupleMetadata> getTupleMetadata,
 Supplier<DomainParameterXref> getDomainParameterXref,
 Supplier<Class<?>> getResultType,
 Supplier<String> getQueryString,
 Runnable beforeQuery,
 Consumer<Boolean> afterQuery,
 Function<List<R>,R> uniqueElement)

ReactiveAbstractSelectionQuery

public ReactiveAbstractSelectionQuery(Supplier<QueryOptions> queryOptionsSupplier,
 SharedSessionContractImplementor session,
 Supplier<CompletionStage<List<R>>> doList,
 Supplier<SqmStatement<?>> getStatement,
 Supplier<TupleMetadata> getTupleMetadata,
 Supplier<DomainParameterXref> getDomainParameterXref,
 Supplier<Class<?>> getResultType,
 Supplier<String> getQueryString,
 Runnable beforeQuery,
 Consumer<Boolean> afterQuery,
 Function<List<R>,R> uniqueElement,
 InterpretationsKeySource interpretationsKeySource)

Method Details

reactiveUnique

public CompletionStage<R> reactiveUnique()

reactiveUniqueResultOptional

public CompletionStage<Optional<R>> reactiveUniqueResultOptional()

getReactiveSingleResult

public CompletionStage<R> getReactiveSingleResult()

getReactiveResultsCount

public CompletionStage<Long> getReactiveResultsCount(SqmSelectStatement<?> sqmStatement,
 DomainQueryExecutionContext domainQueryExecutionContext)

getReactiveSingleResultOrNull

public CompletionStage<R> getReactiveSingleResultOrNull()

reactiveList

public CompletionStage<List<R>> reactiveList()

resolveSelectReactiveQueryPlan

public ReactiveSelectQueryPlan<R> resolveSelectReactiveQueryPlan()

buildConcreteSelectQueryPlan

public <T> ReactiveSelectQueryPlan<T> buildConcreteSelectQueryPlan(SqmSelectStatement<?> concreteSqmStatement,
 Class<T> resultType,
 QueryOptions queryOptions)

getSqmStatement

public SqmStatement<R> getSqmStatement()

getTupleMetadata

public TupleMetadata getTupleMetadata()

getResultType

public Class<R> getResultType()

getDomainParameterXref

public DomainParameterXref getDomainParameterXref()

getQueryString

public String getQueryString()

getSingleResult

public R getSingleResult()

getSingleResultOrNull

public R getSingleResultOrNull()

getResultList

public List<R> getResultList()

list

public List<R> list()

getResultStream

public Stream<R> getResultStream()

uniqueResult

public R uniqueResult()

uniqueResultOptional

public Optional<R> uniqueResultOptional()

enableFetchProfile

public void enableFetchProfile(String profileName)

getCallback

public Callback getCallback()