ReactiveQueryLoader (Hibernate Reactive Core 1.0.0.Alpha10 API)

java.lang.Object
- QueryLoader
- - org.hibernate.reactive.loader.hql.impl.ReactiveQueryLoader

All Implemented Interfaces:
CachingReactiveLoader, ReactiveLoader, ReactiveLoaderBasedLoader
```
public class ReactiveQueryLoader
extends QueryLoader
implements CachingReactiveLoader, ReactiveLoaderBasedLoader
```
A reactive QueryLoader for HQL queries.

Field Summary
- Fields inherited from interface org.hibernate.reactive.loader.CachingReactiveLoader
  log

Constructor Summary
Constructors
Constructor and Description
ReactiveQueryLoader(QueryTranslatorImpl queryTranslator, SessionFactoryImplementor factory, SelectClause selectClause)

Constructors
Constructor and Description
`ReactiveQueryLoader(QueryTranslatorImpl queryTranslator, SessionFactoryImplementor factory, SelectClause selectClause)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`areResultSetRowsTransformedImmediately()`
`void`	`bindToPreparedStatement(PreparedStatement adaptor, QueryParameters queryParameters, LimitHandler limitHandler, SharedSessionContractImplementor session)`
`void`	`createSubselects(List keys, QueryParameters queryParameters, SharedSessionContractImplementor session)`
`void`	`endCollectionLoad(Object resultSetId, SharedSessionContractImplementor session, CollectionPersister collectionPersister)`
`CollectionPersister[]`	`getCollectionPersisters()`
`List<Object>`	`getReactiveResultFromQueryCache(SharedSessionContractImplementor session, QueryParameters queryParameters, Set<Serializable> querySpaces, Type[] resultTypes, QueryResultsCache queryCache, QueryKey key)`
`ReactiveResultSetProcessor`	`getReactiveResultSetProcessor()`
`List<Object>`	`getResultList(List results, ResultTransformer resultTransformer)`
`String[]`	`getResultRowAliases()`
`List<Object>`	`getRowsFromResultSet(ResultSet rs, QueryParameters queryParameters, SharedSessionContractImplementor session, boolean returnProxies, ResultTransformer forcedResultTransformer, int maxRows, List<Object> hydratedObjects, List<EntityKey[]> subselectResultKeys)`
`boolean[]`	`includeInResultRow()`
`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)`
`void`	`putReactiveResultInQueryCache(SharedSessionContractImplementor session, QueryParameters queryParameters, Type[] resultTypes, QueryResultsCache queryCache, QueryKey key, List<Object> cachableList)`
`CompletionStage<List<Object>>`	`reactiveList(SharedSessionContractImplementor session, QueryParameters queryParameters)`
`protected CompletionStage<List<Object>>`	`reactiveList(SharedSessionContractImplementor session, QueryParameters queryParameters, Set<Serializable> querySpaces, Type[] resultTypes)` Return the query results, using the query cache, called by subclasses that implement cacheable queries
`ResultTransformer`	`resolveResultTransformer(ResultTransformer resultTransformer)`

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.CachingReactiveLoader
cacheableResultTransformer, doReactiveList, queryKey, reactiveListIgnoreQueryCache, reactiveListUsingQueryCache, toParameterArray, transform

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

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

Constructor Detail

ReactiveQueryLoader

public ReactiveQueryLoader(QueryTranslatorImpl queryTranslator,
                           SessionFactoryImplementor factory,
                           SelectClause selectClause)

Method Detail

reactiveList

public CompletionStage<List<Object>> reactiveList(SharedSessionContractImplementor session,
                                                  QueryParameters queryParameters)
                                           throws HibernateException

Throws:: HibernateException

reactiveList

protected CompletionStage<List<Object>> reactiveList(SharedSessionContractImplementor session,
                                                     QueryParameters queryParameters,
                                                     Set<Serializable> querySpaces,
                                                     Type[] resultTypes)
                                              throws HibernateException

Return the query results, using the query cache, called by subclasses that implement cacheable queries

Throws:: HibernateException
See Also:: QueryLoader#list(SharedSessionContractImplementor, QueryParameters, Set, Type[])

processResultSet

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

Throws:: SQLException

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)

includeInResultRow
```
public boolean[] includeInResultRow()
```
Specified by:
includeInResultRow in interface CachingReactiveLoader

getReactiveResultFromQueryCache

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

Specified by:: getReactiveResultFromQueryCache in interface CachingReactiveLoader

putReactiveResultInQueryCache

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

Specified by:: putReactiveResultInQueryCache in interface CachingReactiveLoader

resolveResultTransformer
```
public ResultTransformer resolveResultTransformer(ResultTransformer resultTransformer)
```
Specified by:
resolveResultTransformer in interface CachingReactiveLoader

getResultRowAliases
```
public String[] getResultRowAliases()
```
Specified by:
getResultRowAliases in interface CachingReactiveLoader

areResultSetRowsTransformedImmediately
```
public boolean areResultSetRowsTransformedImmediately()
```
Specified by:
areResultSetRowsTransformedImmediately in interface CachingReactiveLoader

getResultList

public List<Object> getResultList(List results,
                                  ResultTransformer resultTransformer)
                           throws QueryException

Specified by:: getResultList in interface CachingReactiveLoader
Throws:: QueryException

bindToPreparedStatement

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

Specified by:: bindToPreparedStatement in interface CachingReactiveLoader
Throws:: SQLException

getCollectionPersisters
```
public CollectionPersister[] getCollectionPersisters()
```
Specified by:
getCollectionPersisters in interface ReactiveLoaderBasedLoader

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 ReactiveQueryLoader

Field Summary

Fields inherited from interface org.hibernate.reactive.loader.CachingReactiveLoader

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

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

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

Constructor Detail

ReactiveQueryLoader

Method Detail

reactiveList

reactiveList

processResultSet

getReactiveResultSetProcessor

preprocessSQL

includeInResultRow

getReactiveResultFromQueryCache

putReactiveResultInQueryCache

resolveResultTransformer

getResultRowAliases

areResultSetRowsTransformedImmediately

getResultList

bindToPreparedStatement

getCollectionPersisters

isSubselectLoadingEnabled

getRowsFromResultSet

createSubselects

endCollectionLoad