org.hibernate.loader.plan.exec.internal

Class AbstractLoadPlanBasedLoader

java.lang.Object

org.hibernate.loader.plan.exec.internal.AbstractLoadPlanBasedLoader

Direct Known Subclasses:

AbstractLoadPlanBasedCollectionInitializer, AbstractLoadPlanBasedEntityLoader

public abstract class AbstractLoadPlanBasedLoader
extends java.lang.Object

A superclass for loader implementations based on using LoadPlans.

See Also:

EntityLoader, CollectionLoader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AbstractLoadPlanBasedLoader.SqlStatementWrapper Wrapper class for Statement and associated ResultSet.

Constructor Summary

Constructors

Constructor and Description
AbstractLoadPlanBasedLoader(SessionFactoryImplementor factory) Constructs a AbstractLoadPlanBasedLoader.

Method Summary

Modifier and Type	Method and Description
protected void	advance(java.sql.ResultSet rs, RowSelection selection) Advance the cursor to the first required row of the ResultSet
protected abstract void	autoDiscoverTypes(java.sql.ResultSet rs)
protected int	bindNamedParameters(java.sql.PreparedStatement statement, java.util.Map namedParams, int startIndex, SharedSessionContractImplementor session) Bind named parameters to the JDBC prepared statement.
protected int	bindParameterValues(java.sql.PreparedStatement statement, QueryParameters queryParameters, int startIndex, SharedSessionContractImplementor session) Bind all parameter values into the prepared statement in preparation for execution.
protected int	bindPositionalParameters(java.sql.PreparedStatement statement, QueryParameters queryParameters, int startIndex, SharedSessionContractImplementor session) Bind positional parameter values to the JDBC prepared statement.
protected java.util.List	executeLoad(SharedSessionContractImplementor session, QueryParameters queryParameters, LoadQueryDetails loadQueryDetails, boolean returnProxies, ResultTransformer forcedResultTransformer)
protected java.util.List	executeLoad(SharedSessionContractImplementor session, QueryParameters queryParameters, LoadQueryDetails loadQueryDetails, boolean returnProxies, ResultTransformer forcedResultTransformer, java.util.List<AfterLoadAction> afterLoadActions)
protected AbstractLoadPlanBasedLoader.SqlStatementWrapper	executeQueryStatement(QueryParameters queryParameters, boolean scroll, java.util.List<AfterLoadAction> afterLoadActions, SharedSessionContractImplementor session)
protected AbstractLoadPlanBasedLoader.SqlStatementWrapper	executeQueryStatement(java.lang.String sqlStatement, QueryParameters queryParameters, boolean scroll, java.util.List<AfterLoadAction> afterLoadActions, SharedSessionContractImplementor session)
protected SessionFactoryImplementor	getFactory()
protected LimitHandler	getLimitHandler(RowSelection selection) Build LIMIT clause handler applicable for given selection criteria.
protected abstract int[]	getNamedParameterLocs(java.lang.String name)
protected java.sql.ResultSet	getResultSet(java.sql.PreparedStatement st, RowSelection selection, LimitHandler limitHandler, boolean autodiscovertypes, SharedSessionContractImplementor session) Execute given PreparedStatement, advance to the first result and return SQL ResultSet.
protected ScrollMode	getScrollMode(boolean scroll, boolean hasFirstRow, boolean useLimitOffSet, QueryParameters queryParameters)
protected abstract LoadQueryDetails	getStaticLoadQuery()
protected java.sql.PreparedStatement	prepareQueryStatement(java.lang.String sql, QueryParameters queryParameters, LimitHandler limitHandler, boolean scroll, SharedSessionContractImplementor session) Obtain a PreparedStatement with all parameters pre-bound.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractLoadPlanBasedLoader

public AbstractLoadPlanBasedLoader(SessionFactoryImplementor factory)

Constructs a AbstractLoadPlanBasedLoader.

Parameters:

factory - The session factory

See Also:

SessionFactoryImplementor

Method Detail

getFactory

protected SessionFactoryImplementor getFactory()

getStaticLoadQuery

protected abstract LoadQueryDetails getStaticLoadQuery()

getNamedParameterLocs

protected abstract int[] getNamedParameterLocs(java.lang.String name)

autoDiscoverTypes

protected abstract void autoDiscoverTypes(java.sql.ResultSet rs)

executeLoad

protected java.util.List executeLoad(SharedSessionContractImplementor session,
                                     QueryParameters queryParameters,
                                     LoadQueryDetails loadQueryDetails,
                                     boolean returnProxies,
                                     ResultTransformer forcedResultTransformer)
                              throws java.sql.SQLException

Throws:

java.sql.SQLException

executeLoad

protected java.util.List executeLoad(SharedSessionContractImplementor session,
                                     QueryParameters queryParameters,
                                     LoadQueryDetails loadQueryDetails,
                                     boolean returnProxies,
                                     ResultTransformer forcedResultTransformer,
                                     java.util.List<AfterLoadAction> afterLoadActions)
                              throws java.sql.SQLException

Throws:

java.sql.SQLException

executeQueryStatement

protected AbstractLoadPlanBasedLoader.SqlStatementWrapper executeQueryStatement(QueryParameters queryParameters,
                                                                                boolean scroll,
                                                                                java.util.List<AfterLoadAction> afterLoadActions,
                                                                                SharedSessionContractImplementor session)
                                                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

executeQueryStatement

protected AbstractLoadPlanBasedLoader.SqlStatementWrapper executeQueryStatement(java.lang.String sqlStatement,
                                                                                QueryParameters queryParameters,
                                                                                boolean scroll,
                                                                                java.util.List<AfterLoadAction> afterLoadActions,
                                                                                SharedSessionContractImplementor session)
                                                                         throws java.sql.SQLException

Throws:

java.sql.SQLException

getLimitHandler

protected LimitHandler getLimitHandler(RowSelection selection)

Build LIMIT clause handler applicable for given selection criteria. Returns NoopLimitHandler delegate if dialect does not support LIMIT expression or processed query does not use pagination.

Parameters:

selection - Selection criteria.

Returns:

LIMIT clause delegate.

prepareQueryStatement

protected final java.sql.PreparedStatement prepareQueryStatement(java.lang.String sql,
                                                                 QueryParameters queryParameters,
                                                                 LimitHandler limitHandler,
                                                                 boolean scroll,
                                                                 SharedSessionContractImplementor session)
                                                          throws java.sql.SQLException,
                                                                 HibernateException

Obtain a PreparedStatement with all parameters pre-bound. Bind JDBC-style ? parameters, named parameters, and limit parameters.

Throws:

java.sql.SQLException

HibernateException

getScrollMode

protected ScrollMode getScrollMode(boolean scroll,
                                   boolean hasFirstRow,
                                   boolean useLimitOffSet,
                                   QueryParameters queryParameters)

bindParameterValues

protected int bindParameterValues(java.sql.PreparedStatement statement,
                                  QueryParameters queryParameters,
                                  int startIndex,
                                  SharedSessionContractImplementor session)
                           throws java.sql.SQLException

Bind all parameter values into the prepared statement in preparation for execution.

Parameters:

statement - The JDBC prepared statement

queryParameters - The encapsulation of the parameter values to be bound.

startIndex - The position from which to start binding parameter values.

session - The originating session.

Returns:

The number of JDBC bind positions actually bound during this method execution.

Throws:

java.sql.SQLException - Indicates problems performing the binding.

bindPositionalParameters

protected int bindPositionalParameters(java.sql.PreparedStatement statement,
                                       QueryParameters queryParameters,
                                       int startIndex,
                                       SharedSessionContractImplementor session)
                                throws java.sql.SQLException,
                                       HibernateException

Bind positional parameter values to the JDBC prepared statement.

Positional parameters are those specified by JDBC-style ? parameters in the source query. It is (currently) expected that these come before any named parameters in the source query.

Parameters:

statement - The JDBC prepared statement

queryParameters - The encapsulation of the parameter values to be bound.

startIndex - The position from which to start binding parameter values.

session - The originating session.

Returns:

The number of JDBC bind positions actually bound during this method execution.

Throws:

java.sql.SQLException - Indicates problems performing the binding.

HibernateException - Indicates problems delegating binding to the types.

bindNamedParameters

protected int bindNamedParameters(java.sql.PreparedStatement statement,
                                  java.util.Map namedParams,
                                  int startIndex,
                                  SharedSessionContractImplementor session)
                           throws java.sql.SQLException,
                                  HibernateException

Bind named parameters to the JDBC prepared statement.

This is a generic implementation, the problem being that in the general case we do not know enough information about the named parameters to perform this in a complete manner here. Thus this is generally overridden on subclasses allowing named parameters to apply the specific behavior. The most usual limitation here is that we need to assume the type span is always one...

Parameters:

statement - The JDBC prepared statement

namedParams - A map of parameter names to values

startIndex - The position from which to start binding parameter values.

session - The originating session.

Returns:

The number of JDBC bind positions actually bound during this method execution.

Throws:

java.sql.SQLException - Indicates problems performing the binding.

HibernateException - Indicates problems delegating binding to the types.

getResultSet

protected final java.sql.ResultSet getResultSet(java.sql.PreparedStatement st,
                                                RowSelection selection,
                                                LimitHandler limitHandler,
                                                boolean autodiscovertypes,
                                                SharedSessionContractImplementor session)
                                         throws java.sql.SQLException,
                                                HibernateException

Execute given PreparedStatement, advance to the first result and return SQL ResultSet.

Throws:

java.sql.SQLException

HibernateException

advance

protected void advance(java.sql.ResultSet rs,
                       RowSelection selection)
                throws java.sql.SQLException

Advance the cursor to the first required row of the ResultSet

Throws:

java.sql.SQLException