Package org.hibernate.reactive.loader

Interface CachingReactiveLoader<T>

All Superinterfaces:

ReactiveLoader

public interface CachingReactiveLoader<T>
extends ReactiveLoader

Defines common reactive operations inherited by query loaders, in particular, interaction with the cache.

See Also:

Loader

Field Summary

Fields

Modifier and Type	Field	Description
static org.hibernate.reactive.logging.impl.Log	LOG

Method Summary

Modifier and Type	Method	Description
boolean	areResultSetRowsTransformedImmediately()
void	bindToPreparedStatement(PreparedStatement adaptor, QueryParameters queryParameters, LimitHandler limitHandler, SharedSessionContractImplementor session)
default CacheableResultTransformer	cacheableResultTransformer(QueryParameters queryParameters)
default CompletionStage<List<Object>>	doReactiveList(String sql, String queryIdentifier, SharedSessionContractImplementor session, QueryParameters queryParameters, ResultTransformer forcedResultTransformer)
List<Object>	getReactiveResultFromQueryCache(SharedSessionContractImplementor session, QueryParameters queryParameters, Set<Serializable> querySpaces, Type[] resultTypes, QueryResultsCache queryCache, QueryKey key)
List<T>	getResultList(List<?> results, ResultTransformer resultTransformer)
String[]	getResultRowAliases()
boolean[]	includeInResultRow()
void	putReactiveResultInQueryCache(SharedSessionContractImplementor session, QueryParameters queryParameters, Type[] resultTypes, QueryResultsCache queryCache, QueryKey key, List<Object> cachableList)
default QueryKey	queryKey(String sql, SharedSessionContractImplementor session, QueryParameters queryParameters)
default CompletionStage<List<T>>	reactiveListIgnoreQueryCache(String sql, String queryIdentifier, SharedSessionContractImplementor session, QueryParameters queryParameters)
default CompletionStage<List<T>>	reactiveListUsingQueryCache(String sql, String queryIdentifier, SharedSessionContractImplementor session, QueryParameters queryParameters, Set<Serializable> querySpaces, Type[] resultTypes)
ResultTransformer	resolveResultTransformer(ResultTransformer resultTransformer)
default Object[]	toParameterArray(QueryParameters queryParameters, SharedSessionContractImplementor session, LimitHandler limitHandler)
default List<?>	transform(QueryParameters queryParameters, QueryKey key, List<Object> result, ResultTransformer resolvedTransformer)

Methods inherited from interface org.hibernate.reactive.loader.ReactiveLoader

discoverTypes, doReactiveQueryAndInitializeNonLazyCollections, doReactiveQueryAndInitializeNonLazyCollections, executeReactiveQueryStatement, getReactiveResultSetProcessor, isPostgresSQL, limitHandler, parameters, preprocessSQL, reactiveProcessResultSet

Field Detail

LOG

static final org.hibernate.reactive.logging.impl.Log LOG

Method Detail

doReactiveList

default CompletionStage<List<Object>> doReactiveList(String sql,
                                                     String queryIdentifier,
                                                     SharedSessionContractImplementor session,
                                                     QueryParameters queryParameters,
                                                     ResultTransformer forcedResultTransformer)
                                              throws HibernateException

Throws:

HibernateException

reactiveListIgnoreQueryCache

default CompletionStage<List<T>> reactiveListIgnoreQueryCache(String sql,
                                                              String queryIdentifier,
                                                              SharedSessionContractImplementor session,
                                                              QueryParameters queryParameters)

reactiveListUsingQueryCache

default CompletionStage<List<T>> reactiveListUsingQueryCache(String sql,
                                                             String queryIdentifier,
                                                             SharedSessionContractImplementor session,
                                                             QueryParameters queryParameters,
                                                             Set<Serializable> querySpaces,
                                                             Type[] resultTypes)

transform

default List<?> transform(QueryParameters queryParameters,
                          QueryKey key,
                          List<Object> result,
                          ResultTransformer resolvedTransformer)

queryKey

default QueryKey queryKey(String sql,
                          SharedSessionContractImplementor session,
                          QueryParameters queryParameters)

cacheableResultTransformer

default CacheableResultTransformer cacheableResultTransformer(QueryParameters queryParameters)

includeInResultRow

boolean[] includeInResultRow()

getReactiveResultFromQueryCache

List<Object> getReactiveResultFromQueryCache(SharedSessionContractImplementor session,
                                             QueryParameters queryParameters,
                                             Set<Serializable> querySpaces,
                                             Type[] resultTypes,
                                             QueryResultsCache queryCache,
                                             QueryKey key)

putReactiveResultInQueryCache

void putReactiveResultInQueryCache(SharedSessionContractImplementor session,
                                   QueryParameters queryParameters,
                                   Type[] resultTypes,
                                   QueryResultsCache queryCache,
                                   QueryKey key,
                                   List<Object> cachableList)

resolveResultTransformer

ResultTransformer resolveResultTransformer(ResultTransformer resultTransformer)

getResultRowAliases

String[] getResultRowAliases()

areResultSetRowsTransformedImmediately

boolean areResultSetRowsTransformedImmediately()

getResultList

List<T> getResultList(List<?> results,
                      ResultTransformer resultTransformer)
               throws QueryException

Throws:

QueryException

toParameterArray

default Object[] toParameterArray(QueryParameters queryParameters,
                                  SharedSessionContractImplementor session,
                                  LimitHandler limitHandler)

Specified by:

toParameterArray in interface ReactiveLoader

bindToPreparedStatement

void bindToPreparedStatement(PreparedStatement adaptor,
                             QueryParameters queryParameters,
                             LimitHandler limitHandler,
                             SharedSessionContractImplementor session)
                      throws SQLException

Throws:

SQLException