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<org.hibernate.query.sqm.tree.SqmStatement<?>> getStatement, Supplier<org.hibernate.sql.results.internal.TupleMetadata> getTupleMetadata, Supplier<org.hibernate.query.sqm.internal.DomainParameterXref> getDomainParameterXref, Supplier<Class<?>> getResultType, Supplier<String> getQueryString, Runnable beforeQuery, Consumer<Boolean> afterQuery, Function<List<R>,R> uniqueElement, org.hibernate.query.sqm.spi.InterpretationsKeySource interpretationsKeySource)
ReactiveAbstractSelectionQuery(org.hibernate.query.sqm.spi.InterpretationsKeySource interpretationKeySource, SharedSessionContractImplementor session, Supplier<CompletionStage<List<R>>> doList, Supplier<org.hibernate.query.sqm.tree.SqmStatement<?>> getStatement, Supplier<org.hibernate.sql.results.internal.TupleMetadata> getTupleMetadata, Supplier<org.hibernate.query.sqm.internal.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(org.hibernate.query.sqm.tree.select.SqmSelectStatement<?> concreteSqmStatement, Class<T> resultType, QueryOptions queryOptions)
void	enableFetchProfile(String profileName)
org.hibernate.sql.exec.spi.Callback	getCallback()
org.hibernate.query.sqm.internal.DomainParameterXref	getDomainParameterXref()
String	getQueryString()
CompletionStage<Long>	getReactiveResultsCount(org.hibernate.query.sqm.tree.select.SqmSelectStatement<?> sqmStatement, DomainQueryExecutionContext domainQueryExecutionContext)
CompletionStage<R>	getReactiveSingleResult()
CompletionStage<R>	getReactiveSingleResultOrNull()
List<R>	getResultList()
Stream<R>	getResultStream()
Class<R>	getResultType()
R	getSingleResult()
R	getSingleResultOrNull()
org.hibernate.query.sqm.tree.SqmStatement<R>	getSqmStatement()
org.hibernate.sql.results.internal.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(org.hibernate.query.sqm.spi.InterpretationsKeySource interpretationKeySource,
 SharedSessionContractImplementor session,
 Supplier<CompletionStage<List<R>>> doList,
 Supplier<org.hibernate.query.sqm.tree.SqmStatement<?>> getStatement,
 Supplier<org.hibernate.sql.results.internal.TupleMetadata> getTupleMetadata,
 Supplier<org.hibernate.query.sqm.internal.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<org.hibernate.query.sqm.tree.SqmStatement<?>> getStatement,
 Supplier<org.hibernate.sql.results.internal.TupleMetadata> getTupleMetadata,
 Supplier<org.hibernate.query.sqm.internal.DomainParameterXref> getDomainParameterXref,
 Supplier<Class<?>> getResultType,
 Supplier<String> getQueryString,
 Runnable beforeQuery,
 Consumer<Boolean> afterQuery,
 Function<List<R>,R> uniqueElement,
 org.hibernate.query.sqm.spi.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(org.hibernate.query.sqm.tree.select.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(org.hibernate.query.sqm.tree.select.SqmSelectStatement<?> concreteSqmStatement,
 Class<T> resultType,
 QueryOptions queryOptions)

getSqmStatement

public org.hibernate.query.sqm.tree.SqmStatement<R> getSqmStatement()

getTupleMetadata

public org.hibernate.sql.results.internal.TupleMetadata getTupleMetadata()

getResultType

public Class<R> getResultType()

getDomainParameterXref

public org.hibernate.query.sqm.internal.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 org.hibernate.sql.exec.spi.Callback getCallback()