ReactiveCollectionLoader (Hibernate Reactive Core 1.0.0.Alpha10 API)

java.lang.Object
- CollectionLoader
- - org.hibernate.reactive.loader.collection.impl.ReactiveCollectionLoader

All Implemented Interfaces:
ReactiveCollectionInitializer, ReactiveLoader, ReactiveLoaderBasedLoader
Direct Known Subclasses:
ReactiveDynamicBatchingCollectionDelegator, ReactiveDynamicBatchingCollectionInitializer, ReactiveOneToManyLoader, ReactivePaddedBatchingCollectionInitializer
```
public class ReactiveCollectionLoader
extends CollectionLoader
implements ReactiveCollectionInitializer, ReactiveLoaderBasedLoader
```
A reactific org.hibernate.loader.collection.CollectionLoader.
See Also:
org.hibernate.loader.collection.CollectionLoader

Constructor Summary
Constructors
Constructor and Description
ReactiveCollectionLoader(QueryableCollection collectionPersister, SessionFactoryImplementor factory, LoadQueryInfluencers loadQueryInfluencers)

Constructors
Constructor and Description
`ReactiveCollectionLoader(QueryableCollection collectionPersister, SessionFactoryImplementor factory, LoadQueryInfluencers loadQueryInfluencers)`

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
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)` Deprecated. use `reactiveInitialize(Serializable, SharedSessionContractImplementor)`
`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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.hibernate.reactive.loader.ReactiveLoaderBasedLoader
getCollectionPersisters, getEntityPersisters, getFactory

Methods inherited from interface org.hibernate.reactive.loader.ReactiveLoader
discoverTypes, doReactiveQueryAndInitializeNonLazyCollections, executeReactiveQueryStatement, limitHandler, reactiveProcessResultSet, toParameterArray

Constructor Detail

ReactiveCollectionLoader

public ReactiveCollectionLoader(QueryableCollection collectionPersister,
                                SessionFactoryImplementor factory,
                                LoadQueryInfluencers loadQueryInfluencers)

Method Detail

doReactiveQueryAndInitializeNonLazyCollections

protected CompletionStage<List<Object>> doReactiveQueryAndInitializeNonLazyCollections(SessionImplementor session,
                                                                                       QueryParameters queryParameters,
                                                                                       boolean returnProxies)

Specified by:: doReactiveQueryAndInitializeNonLazyCollections in interface ReactiveLoader

initialize

@Deprecated
public void initialize(Serializable id,
                                    SharedSessionContractImplementor session)
                             throws HibernateException

Deprecated. use reactiveInitialize(Serializable, SharedSessionContractImplementor)

Throws:: HibernateException

reactiveInitialize

public CompletionStage<Void> reactiveInitialize(Serializable id,
                                                SharedSessionContractImplementor session)
                                         throws HibernateException

Specified by:: reactiveInitialize in interface ReactiveCollectionInitializer
Throws:: HibernateException

reactiveLoadCollection

public CompletionStage<Void> reactiveLoadCollection(SessionImplementor session,
                                                    Serializable id,
                                                    Type type)
                                             throws HibernateException

Called by subclasses that initialize collections

Throws:: HibernateException

reactiveLoadCollectionBatch

public final CompletionStage<Void> reactiveLoadCollectionBatch(SessionImplementor session,
                                                               Serializable[] ids,
                                                               Type type)
                                                        throws HibernateException

Called by wrappers that batch initialize collections

Throws:: HibernateException

getReactiveResultSetProcessor
```
public ReactiveResultSetProcessor getReactiveResultSetProcessor()
```
Specified by:
getReactiveResultSetProcessor in interface ReactiveLoader

preprocessSQL
```
public String preprocessSQL(String sql,
                            QueryParameters queryParameters,
                            SessionFactoryImplementor factory,
                            List<AfterLoadAction> afterLoadActions)
```
Description copied from interface: ReactiveLoader
Used by query loaders to add stuff like locking and hints/comments
Specified by:
preprocessSQL in interface ReactiveLoader
See Also:
org.hibernate.loader.Loader#preprocessSQL(String, QueryParameters, SessionFactoryImplementor, List)

processResultSet

public List<Object> processResultSet(ResultSet resultSet,
                                     QueryParameters queryParameters,
                                     SharedSessionContractImplementor session,
                                     boolean returnProxies,
                                     ResultTransformer forcedResultTransformer,
                                     int maxRows,
                                     List<AfterLoadAction> afterLoadActions)
                              throws SQLException

Throws:: SQLException

isSubselectLoadingEnabled
```
public boolean isSubselectLoadingEnabled()
```
Specified by:
isSubselectLoadingEnabled in interface ReactiveLoaderBasedLoader

getRowsFromResultSet

public List<Object> getRowsFromResultSet(ResultSet rs,
                                         QueryParameters queryParameters,
                                         SharedSessionContractImplementor session,
                                         boolean returnProxies,
                                         ResultTransformer forcedResultTransformer,
                                         int maxRows,
                                         List<Object> hydratedObjects,
                                         List<EntityKey[]> subselectResultKeys)
                                  throws SQLException

Specified by:: getRowsFromResultSet in interface ReactiveLoaderBasedLoader
Throws:: SQLException

createSubselects

public void createSubselects(List keys,
                             QueryParameters queryParameters,
                             SharedSessionContractImplementor session)

Specified by:: createSubselects in interface ReactiveLoaderBasedLoader

endCollectionLoad

public void endCollectionLoad(Object resultSetId,
                              SharedSessionContractImplementor session,
                              CollectionPersister collectionPersister)

Specified by:: endCollectionLoad in interface ReactiveLoaderBasedLoader

Class ReactiveCollectionLoader

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

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

Constructor Detail

ReactiveCollectionLoader

Method Detail

doReactiveQueryAndInitializeNonLazyCollections

initialize

reactiveInitialize

reactiveLoadCollection

reactiveLoadCollectionBatch

getReactiveResultSetProcessor

preprocessSQL

processResultSet

isSubselectLoadingEnabled

getRowsFromResultSet

createSubselects

endCollectionLoad