Package org.hibernate.reactive.loader

Interface ReactiveLoader

All Known Subinterfaces:

CachingReactiveLoader<T>, ReactiveLoaderBasedLoader

public interface ReactiveLoader

Defines common reactive operations inherited by all kinds of loaders.

See Also:

Loader

Method Summary

Modifier and Type	Method	Description
default void	discoverTypes(QueryParameters queryParameters, ResultSet resultSet)	Used by ReactiveCustomLoader when there is no result set mapping.
default CompletionStage<List<Object>>	doReactiveQueryAndInitializeNonLazyCollections(String sql, SharedSessionContractImplementor session, QueryParameters queryParameters)
default CompletionStage<List<Object>>	doReactiveQueryAndInitializeNonLazyCollections(String sql, SharedSessionContractImplementor session, QueryParameters queryParameters, boolean returnProxies, ResultTransformer forcedResultTransformer)
default CompletionStage<ResultSet>	executeReactiveQueryStatement(String sqlStatement, QueryParameters queryParameters, List<AfterLoadAction> afterLoadActions, SharedSessionContractImplementor session)
ReactiveResultSetProcessor	getReactiveResultSetProcessor()
default boolean	isPostgresSQL(SharedSessionContractImplementor session)
default LimitHandler	limitHandler(RowSelection selection, SharedSessionContractImplementor session)
org.hibernate.reactive.pool.impl.Parameters	parameters()
default String	preprocessSQL(String sql, QueryParameters queryParameters, SessionFactoryImplementor factory, List<AfterLoadAction> afterLoadActions)	Used by query loaders to add stuff like locking and hints/comments
default CompletionStage<List<Object>>	reactiveProcessResultSet(ResultSet rs, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, List<AfterLoadAction> afterLoadActions)
default Object[]	toParameterArray(QueryParameters queryParameters, SharedSessionContractImplementor session, LimitHandler limitHandler)

Method Detail

isPostgresSQL

default boolean isPostgresSQL(SharedSessionContractImplementor session)

doReactiveQueryAndInitializeNonLazyCollections

default CompletionStage<List<Object>> doReactiveQueryAndInitializeNonLazyCollections(String sql,
                                                                                     SharedSessionContractImplementor session,
                                                                                     QueryParameters queryParameters)

doReactiveQueryAndInitializeNonLazyCollections

default CompletionStage<List<Object>> doReactiveQueryAndInitializeNonLazyCollections(String sql,
                                                                                     SharedSessionContractImplementor session,
                                                                                     QueryParameters queryParameters,
                                                                                     boolean returnProxies,
                                                                                     ResultTransformer forcedResultTransformer)

parameters

org.hibernate.reactive.pool.impl.Parameters parameters()

executeReactiveQueryStatement

default CompletionStage<ResultSet> executeReactiveQueryStatement(String sqlStatement,
                                                                 QueryParameters queryParameters,
                                                                 List<AfterLoadAction> afterLoadActions,
                                                                 SharedSessionContractImplementor session)

limitHandler

default LimitHandler limitHandler(RowSelection selection,
                                  SharedSessionContractImplementor session)

reactiveProcessResultSet

default CompletionStage<List<Object>> reactiveProcessResultSet(ResultSet rs,
                                                               QueryParameters queryParameters,
                                                               SharedSessionContractImplementor session,
                                                               boolean returnProxies,
                                                               ResultTransformer forcedResultTransformer,
                                                               List<AfterLoadAction> afterLoadActions)

getReactiveResultSetProcessor

ReactiveResultSetProcessor getReactiveResultSetProcessor()

preprocessSQL

default String preprocessSQL(String sql,
                             QueryParameters queryParameters,
                             SessionFactoryImplementor factory,
                             List<AfterLoadAction> afterLoadActions)

Used by query loaders to add stuff like locking and hints/comments

See Also:

Loader.preprocessSQL(String, QueryParameters, SessionFactoryImplementor, List)

discoverTypes

default void discoverTypes(QueryParameters queryParameters,
                           ResultSet resultSet)

Used by ReactiveCustomLoader when there is no result set mapping.

toParameterArray

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