org.sqlproc.engine.hibernate

Class HibernateQuery

java.lang.Object

org.sqlproc.engine.hibernate.HibernateQuery

All Implemented Interfaces:

SqlQuery

public class HibernateQuery
extends Object
implements SqlQuery

The Hibernate stack implementation of the SQL Engine query contract. In fact it's an adapter the internal Hibernate stuff.

For more info please see the Tutorials.

Author:

Vladimir Hudec

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	HibernateQuery.BatchResultHolder

Nested classes/interfaces inherited from interface org.sqlproc.engine.SqlQuery

SqlQuery.SqlQueryRowProcessor

Field Summary

Fields

Modifier and Type	Field and Description
(package private) List<String>	identities The collection of all (auto-generated) identities.
(package private) Map<String,IdentitySetter>	identitySetters The collection of all identities setters.
(package private) Map<String,Object>	identityTypes The collection of all identities types.
(package private) boolean	logError The failed SQL command should be logged.
(package private) org.slf4j.Logger	logger The internal slf4j logger.
(package private) org.hibernate.SQLQuery	query The Hibernate SQLQuery instance.
(package private) org.hibernate.Session	session The Hibernate Session instance.

Constructor Summary

Constructors

Constructor and Description
HibernateQuery(org.hibernate.Session session, org.hibernate.SQLQuery query) Creates a new instance of this adapter.

Method Summary

Methods

Modifier and Type	Method and Description
SqlQuery	addScalar(String columnAlias)
SqlQuery	addScalar(String columnAlias, Object type, Class<?>... moreTypes)
Map<String,Object>	callFunction()
List<Map<String,Object>>	callList(SqlRuntimeContext runtime)
Map<String,Object>	callUnique(SqlRuntimeContext runtime)
int	callUpdate(SqlRuntimeContext runtime)
private void	doIdentitySelect(String identityName) Runs the select to obtain the value of auto-generated identity.
int[]	executeBatch(String[] statements)
Object	getQuery()
private boolean	isSetJDBCIdentity()
List<Map<String,Object>>	list(SqlRuntimeContext runtime)
protected SqlProcessorException	newSqlProcessorException(org.hibernate.HibernateException ex, String query)
int	query(SqlRuntimeContext runtimeCtx, SqlQuery.SqlQueryRowProcessor sqlQueryRowProcessor)
void	setLogError(boolean logError) Sets an indicator the failed SQL command should be logged
SqlQuery	setOrdered(boolean ordered)
SqlQuery	setParameter(String name, Object val)
SqlQuery	setParameter(String name, Object val, Object type, Class<?>... moreTypes)
SqlQuery	setParameterList(String name, Object[] vals)
SqlQuery	setParameterList(String name, Object[] vals, Object type, Class<?>... moreTypes)
SqlQuery	setSqlControl(SqlControl sqlControl)
Map<String,Object>	unique(SqlRuntimeContext runtime)
int	update(SqlRuntimeContext runtime)

Methods inherited from class java.lang.Object

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

Field Detail

logger

final org.slf4j.Logger logger

The internal slf4j logger.

session

org.hibernate.Session session

The Hibernate Session instance.

query

org.hibernate.SQLQuery query

The Hibernate SQLQuery instance.

identities

List<String> identities

The collection of all (auto-generated) identities.

identitySetters

Map<String,IdentitySetter> identitySetters

The collection of all identities setters.

identityTypes

Map<String,Object> identityTypes

The collection of all identities types.

logError

boolean logError

The failed SQL command should be logged.

Constructor Detail

HibernateQuery

public HibernateQuery(org.hibernate.Session session,
              org.hibernate.SQLQuery query)

Creates a new instance of this adapter.

Parameters:

session - the Hibernate Session instance

query - the Hibernate SQLQuery instance

Method Detail

getQuery

public Object getQuery()

Specified by:

getQuery in interface SqlQuery

setSqlControl

public SqlQuery setSqlControl(SqlControl sqlControl)

Specified by:

setSqlControl in interface SqlQuery

setOrdered

public SqlQuery setOrdered(boolean ordered)

Specified by:

setOrdered in interface SqlQuery

list

public List<Map<String,Object>> list(SqlRuntimeContext runtime)
                              throws SqlProcessorException

Specified by:

list in interface SqlQuery

Throws:

SqlProcessorException

query

public int query(SqlRuntimeContext runtimeCtx,
        SqlQuery.SqlQueryRowProcessor sqlQueryRowProcessor)
          throws SqlProcessorException

Specified by:

query in interface SqlQuery

Throws:

SqlProcessorException

unique

public Map<String,Object> unique(SqlRuntimeContext runtime)
                          throws SqlProcessorException

Specified by:

unique in interface SqlQuery

Throws:

SqlProcessorException

update

public int update(SqlRuntimeContext runtime)
           throws SqlProcessorException

Specified by:

update in interface SqlQuery

Throws:

SqlProcessorException

isSetJDBCIdentity

private boolean isSetJDBCIdentity()

doIdentitySelect

private void doIdentitySelect(String identityName)

Runs the select to obtain the value of auto-generated identity.

Parameters:

identityName - the identity name from the META SQL statement

addScalar

public SqlQuery addScalar(String columnAlias)

Specified by:

addScalar in interface SqlQuery

addScalar

public SqlQuery addScalar(String columnAlias,
                 Object type,
                 Class<?>... moreTypes)

Specified by:

addScalar in interface SqlQuery

setParameter

public SqlQuery setParameter(String name,
                    Object val)
                      throws SqlProcessorException

Specified by:

setParameter in interface SqlQuery

Throws:

SqlProcessorException

setParameter

public SqlQuery setParameter(String name,
                    Object val,
                    Object type,
                    Class<?>... moreTypes)
                      throws SqlProcessorException

Specified by:

setParameter in interface SqlQuery

Throws:

SqlProcessorException

setParameterList

public SqlQuery setParameterList(String name,
                        Object[] vals)
                          throws SqlProcessorException

Specified by:

setParameterList in interface SqlQuery

Throws:

SqlProcessorException

setParameterList

public SqlQuery setParameterList(String name,
                        Object[] vals,
                        Object type,
                        Class<?>... moreTypes)
                          throws SqlProcessorException

Specified by:

setParameterList in interface SqlQuery

Throws:

SqlProcessorException

callList

public List<Map<String,Object>> callList(SqlRuntimeContext runtime)
                                  throws SqlProcessorException

Specified by:

callList in interface SqlQuery

Throws:

SqlProcessorException

callUnique

public Map<String,Object> callUnique(SqlRuntimeContext runtime)
                              throws SqlProcessorException

Specified by:

callUnique in interface SqlQuery

Throws:

SqlProcessorException

callUpdate

public int callUpdate(SqlRuntimeContext runtime)
               throws SqlProcessorException

Specified by:

callUpdate in interface SqlQuery

Throws:

SqlProcessorException

callFunction

public Map<String,Object> callFunction()
                                throws SqlProcessorException

Specified by:

callFunction in interface SqlQuery

Throws:

SqlProcessorException

executeBatch

public int[] executeBatch(String[] statements)
                   throws SqlProcessorException

Specified by:

executeBatch in interface SqlQuery

Throws:

SqlProcessorException

newSqlProcessorException

protected SqlProcessorException newSqlProcessorException(org.hibernate.HibernateException ex,
                                             String query)

setLogError

public void setLogError(boolean logError)

Sets an indicator the failed SQL command should be logged

Specified by:

setLogError in interface SqlQuery

Parameters:

logError - an indicator the failed SQL command should be logged