com.mysema.query.sql.dml

Class AbstractSQLClause<C extends AbstractSQLClause<C>>

java.lang.Object

com.mysema.query.sql.dml.AbstractSQLClause<C>

All Implemented Interfaces:

DMLClause<C>

Direct Known Subclasses:

SetQueryBandClause, SQLDeleteClause, SQLInsertClause, SQLMergeClause, SQLUpdateClause

public abstract class AbstractSQLClause<C extends AbstractSQLClause<C>>
extends Object
implements DMLClause<C>

AbstractSQLClause is a superclass for SQL based DMLClause implementations

Author:

tiwe

Field Summary

Fields

Modifier and Type	Field and Description
protected Configuration	configuration
protected SQLListenerContextImpl	context
protected SQLListeners	listeners
protected boolean	useLiterals

Constructor Summary

Constructors

Constructor and Description
AbstractSQLClause(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
void	addListener(SQLListener listener)
protected void	cleanupMDC()
protected void	close(Collection<? extends Statement> stmts)
protected void	close(ResultSet rs)
protected void	close(Statement stmt)
protected SQLBindings	createBindings(QueryMetadata metadata, SQLSerializer serializer)
protected SQLSerializer	createSerializer()
protected void	endContext(SQLListenerContextImpl context) Called to end a SQL listener context
protected long	executeBatch(Collection<PreparedStatement> stmts)
abstract List<SQLBindings>	getSQL() Get the SQL string and bindings
protected void	logQuery(org.slf4j.Logger logger, String queryString, Collection<Object> parameters)
protected void	onException(SQLListenerContextImpl context, Exception e) Called to make the call back to listeners when an exception happens
protected void	reset()
protected void	setParameters(PreparedStatement stmt, List<?> objects, List<Path<?>> constantPaths, Map<ParamExpression<?>,?> params) Set the parameters to the given PreparedStatement
void	setUseLiterals(boolean useLiterals)
protected SQLListenerContextImpl	startContext(Connection connection, QueryMetadata metadata, RelationalPath<?> entity) Called to create and start a new SQL Listener context

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mysema.query.dml.DMLClause

execute

Field Detail

configuration

protected final Configuration configuration

listeners

protected final SQLListeners listeners

useLiterals

protected boolean useLiterals

context

protected SQLListenerContextImpl context

Constructor Detail

AbstractSQLClause

public AbstractSQLClause(Configuration configuration)

Parameters:

configuration -

Method Detail

addListener

public void addListener(SQLListener listener)

Parameters:

listener -

startContext

protected SQLListenerContextImpl startContext(Connection connection,
                                              QueryMetadata metadata,
                                              RelationalPath<?> entity)

Called to create and start a new SQL Listener context

Parameters:

connection - the database connection

metadata - the meta data for that context

entity - the entity for that context

Returns:

the newly started context

onException

protected void onException(SQLListenerContextImpl context,
                           Exception e)

Called to make the call back to listeners when an exception happens

Parameters:

context - the current context in play

e - the exception

endContext

protected void endContext(SQLListenerContextImpl context)

Called to end a SQL listener context

Parameters:

context - the listener context to end

createBindings

protected SQLBindings createBindings(QueryMetadata metadata,
                                     SQLSerializer serializer)

createSerializer

protected SQLSerializer createSerializer()

getSQL

public abstract List<SQLBindings> getSQL()

Get the SQL string and bindings

Returns:

setParameters

protected void setParameters(PreparedStatement stmt,
                             List<?> objects,
                             List<Path<?>> constantPaths,
                             Map<ParamExpression<?>,?> params)

Set the parameters to the given PreparedStatement

Parameters:

stmt - preparedStatement to be populated

objects - list of constants

constantPaths - list of paths related to the constants

params - map of param to value for param resolving

executeBatch

protected long executeBatch(Collection<PreparedStatement> stmts)
                     throws SQLException

Throws:

SQLException

close

protected void close(Statement stmt)

close

protected void close(Collection<? extends Statement> stmts)

close

protected void close(ResultSet rs)

logQuery

protected void logQuery(org.slf4j.Logger logger,
                        String queryString,
                        Collection<Object> parameters)

cleanupMDC

protected void cleanupMDC()

reset

protected void reset()

setUseLiterals

public void setUseLiterals(boolean useLiterals)