Package org.hibernate.reactive.session

Interface ReactiveQueryExecutor

All Superinterfaces:

ReactiveConnectionSupplier

All Known Subinterfaces:

ReactiveSession, ReactiveStatelessSession

public interface ReactiveQueryExecutor
extends ReactiveConnectionSupplier

Executes queries in a non-blocking fashion. An internal contract between the NativeQueryImplementors and stateless and stateful reactive sessions.

See Also:

SharedSessionContractImplementor

Method Summary

Modifier and Type	Method	Description
void	addBulkCleanupAction(org.hibernate.action.internal.BulkOperationCleanupAction action)
<T> EntityGraph<T>	createEntityGraph(Class<T> entity)
<T> EntityGraph<T>	createEntityGraph(Class<T> entity, String name)
<T> ReactiveQuery<T>	createReactiveCriteriaQuery(String jpaqlString, Class<T> resultClass, CriteriaQueryOptions queryOptions)
<R> ReactiveQuery<R>	createReactiveNamedQuery(String name)
<R> ReactiveQuery<R>	createReactiveNamedQuery(String name, Class<R> resultClass)
<T> ReactiveQuery<T>	createReactiveNativeQuery(String sqlString)
<T> ReactiveQuery<T>	createReactiveNativeQuery(String sqlString, Class<T> resultType)
<T> ReactiveQuery<T>	createReactiveNativeQuery(String sqlString, String resultSetMapping)
<R> ReactiveQuery<R>	createReactiveQuery(String queryString)
<R> ReactiveQuery<R>	createReactiveQuery(String queryString, Class<R> resultType)
<R> ReactiveQuery<R>	createReactiveQuery(Criteria<R> criteria)
CompletionStage<Integer>	executeReactiveUpdate(String expandedQuery, QueryParameters parameters)
CompletionStage<Integer>	executeReactiveUpdate(NativeSQLQuerySpecification specification, QueryParameters parameters)
Dialect	getDialect()
<T> EntityGraph<T>	getEntityGraph(Class<T> entity, String name)
SessionFactoryImplementor	getFactory()
<T> ResultSetMapping<T>	getResultSetMapping(Class<T> resultType, String mappingName)
SharedSessionContractImplementor	getSharedContract()
<T> CompletionStage<T>	reactiveFetch(T association, boolean unproxy)
CompletionStage<Object>	reactiveInternalLoad(String entityName, Serializable id, boolean eager, boolean nullable)
<T> CompletionStage<List<T>>	reactiveList(String query, QueryParameters parameters)
<T> CompletionStage<List<T>>	reactiveList(NativeSQLQuerySpecification spec, QueryParameters parameters)

Methods inherited from interface org.hibernate.reactive.session.ReactiveConnectionSupplier

getReactiveConnection

Method Detail

getFactory

SessionFactoryImplementor getFactory()

getSharedContract

SharedSessionContractImplementor getSharedContract()

getDialect

Dialect getDialect()

reactiveList

<T> CompletionStage<List<T>> reactiveList(String query,
                                          QueryParameters parameters)

reactiveList

<T> CompletionStage<List<T>> reactiveList(NativeSQLQuerySpecification spec,
                                          QueryParameters parameters)

executeReactiveUpdate

CompletionStage<Integer> executeReactiveUpdate(String expandedQuery,
                                               QueryParameters parameters)

executeReactiveUpdate

CompletionStage<Integer> executeReactiveUpdate(NativeSQLQuerySpecification specification,
                                               QueryParameters parameters)

getResultSetMapping

<T> ResultSetMapping<T> getResultSetMapping(Class<T> resultType,
                                            String mappingName)

addBulkCleanupAction

void addBulkCleanupAction(org.hibernate.action.internal.BulkOperationCleanupAction action)

reactiveInternalLoad

CompletionStage<Object> reactiveInternalLoad(String entityName,
                                             Serializable id,
                                             boolean eager,
                                             boolean nullable)

createReactiveQuery

<R> ReactiveQuery<R> createReactiveQuery(Criteria<R> criteria)

createReactiveCriteriaQuery

<T> ReactiveQuery<T> createReactiveCriteriaQuery(String jpaqlString,
                                                 Class<T> resultClass,
                                                 CriteriaQueryOptions queryOptions)

createEntityGraph

<T> EntityGraph<T> createEntityGraph(Class<T> entity)

createEntityGraph

<T> EntityGraph<T> createEntityGraph(Class<T> entity,
                                     String name)

getEntityGraph

<T> EntityGraph<T> getEntityGraph(Class<T> entity,
                                  String name)

createReactiveQuery

<R> ReactiveQuery<R> createReactiveQuery(String queryString)

createReactiveQuery

<R> ReactiveQuery<R> createReactiveQuery(String queryString,
                                         Class<R> resultType)

createReactiveNamedQuery

<R> ReactiveQuery<R> createReactiveNamedQuery(String name)

createReactiveNamedQuery

<R> ReactiveQuery<R> createReactiveNamedQuery(String name,
                                              Class<R> resultClass)

createReactiveNativeQuery

<T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString)

createReactiveNativeQuery

<T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString,
                                               Class<T> resultType)

createReactiveNativeQuery

<T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString,
                                               String resultSetMapping)

reactiveFetch

<T> CompletionStage<T> reactiveFetch(T association,
                                     boolean unproxy)