public class ReactiveCollectionLoader extends CollectionLoader implements ReactiveCollectionInitializer, ReactiveLoaderBasedLoader
org.hibernate.loader.collection.CollectionLoader
.org.hibernate.loader.collection.CollectionLoader
Constructor and Description |
---|
ReactiveCollectionLoader(QueryableCollection collectionPersister, SessionFactoryImplementor factory, LoadQueryInfluencers loadQueryInfluencers) |
Modifier and Type | Method and Description |
---|---|
void | createSubselects(List keys, QueryParameters queryParameters, SharedSessionContractImplementor session) |
protected CompletionStage<List<Object>> | doReactiveQueryAndInitializeNonLazyCollections(SessionImplementor session, QueryParameters queryParameters, boolean returnProxies) |
void | endCollectionLoad(Object resultSetId, SharedSessionContractImplementor session, CollectionPersister collectionPersister) |
ReactiveResultSetProcessor | getReactiveResultSetProcessor() |
List<Object> | getRowsFromResultSet(ResultSet rs, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, int maxRows, List<Object> hydratedObjects, List<EntityKey[]> subselectResultKeys) |
void | initialize(Serializable id, SharedSessionContractImplementor session) |
boolean | isSubselectLoadingEnabled() |
String | preprocessSQL(String sql, QueryParameters queryParameters, SessionFactoryImplementor factory, List<AfterLoadAction> afterLoadActions) Used by query loaders to add stuff like locking and hints/comments |
List<Object> | processResultSet(ResultSet resultSet, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, int maxRows, List<AfterLoadAction> afterLoadActions) |
CompletionStage<Void> | reactiveInitialize(Serializable id, SharedSessionContractImplementor session) |
CompletionStage<Void> | reactiveLoadCollection(SessionImplementor session, Serializable id, Type type) Called by subclasses that initialize collections |
CompletionStage<Void> | reactiveLoadCollectionBatch(SessionImplementor session, Serializable[] ids, Type type) Called by wrappers that batch initialize collections |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCollectionPersisters, getEntityPersisters, getFactory
discoverTypes, doReactiveQueryAndInitializeNonLazyCollections, executeReactiveQueryStatement, limitHandler, reactiveProcessResultSet, toParameterArray
public ReactiveCollectionLoader(QueryableCollection collectionPersister, SessionFactoryImplementor factory, LoadQueryInfluencers loadQueryInfluencers)
protected CompletionStage<List<Object>> doReactiveQueryAndInitializeNonLazyCollections(SessionImplementor session, QueryParameters queryParameters, boolean returnProxies)
doReactiveQueryAndInitializeNonLazyCollections
in interface ReactiveLoader
@Deprecated public void initialize(Serializable id, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public CompletionStage<Void> reactiveInitialize(Serializable id, SharedSessionContractImplementor session) throws HibernateException
reactiveInitialize
in interface ReactiveCollectionInitializer
HibernateException
public CompletionStage<Void> reactiveLoadCollection(SessionImplementor session, Serializable id, Type type) throws HibernateException
HibernateException
public final CompletionStage<Void> reactiveLoadCollectionBatch(SessionImplementor session, Serializable[] ids, Type type) throws HibernateException
HibernateException
public ReactiveResultSetProcessor getReactiveResultSetProcessor()
getReactiveResultSetProcessor
in interface ReactiveLoader
public String preprocessSQL(String sql, QueryParameters queryParameters, SessionFactoryImplementor factory, List<AfterLoadAction> afterLoadActions)
ReactiveLoader
preprocessSQL
in interface ReactiveLoader
org.hibernate.loader.Loader#preprocessSQL(String, QueryParameters, SessionFactoryImplementor, List)
public List<Object> processResultSet(ResultSet resultSet, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, int maxRows, List<AfterLoadAction> afterLoadActions) throws SQLException
SQLException
public boolean isSubselectLoadingEnabled()
isSubselectLoadingEnabled
in interface ReactiveLoaderBasedLoader
public List<Object> getRowsFromResultSet(ResultSet rs, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, int maxRows, List<Object> hydratedObjects, List<EntityKey[]> subselectResultKeys) throws SQLException
getRowsFromResultSet
in interface ReactiveLoaderBasedLoader
SQLException
public void createSubselects(List keys, QueryParameters queryParameters, SharedSessionContractImplementor session)
createSubselects
in interface ReactiveLoaderBasedLoader
public void endCollectionLoad(Object resultSetId, SharedSessionContractImplementor session, CollectionPersister collectionPersister)
endCollectionLoad
in interface ReactiveLoaderBasedLoader