Package org.jumpmind.db.sql

Class JdbcSqlTransaction

java.lang.Object

org.jumpmind.db.sql.JdbcSqlTransaction

All Implemented Interfaces:

ISqlTransaction

Direct Known Subclasses:

AseJdbcSqlTransaction, H2JdbcSqlTransaction, MsSqlJdbcSqlTransaction

public class JdbcSqlTransaction
extends Object
implements ISqlTransaction

TODO Support Oracle's non-standard way of batching

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	autoCommit
protected int	batchSize
protected Connection	connection
protected boolean	inBatchMode
protected JdbcSqlTemplate	jdbcSqlTemplate
protected List<ISqlTransactionListener>	listeners
protected LogSqlBuilder	logSqlBuilder
protected List<Object>	markers
protected boolean	oldAutoCommitValue
protected String	psql
protected PreparedStatement	pstmt

Constructor Summary

Constructors

Constructor	Description
JdbcSqlTransaction(JdbcSqlTemplate jdbcSqlTemplate)
JdbcSqlTransaction(JdbcSqlTemplate jdbcSqlTemplate, boolean autoCommit)

Method Summary

Modifier and Type	Method	Description
int	addRow(Object marker, Object[] args, int[] argTypes)
void	addSqlTransactionListener(ISqlTransactionListener listener)
void	allowInsertIntoAutoIncrementColumns(boolean value, Table table, String quote, String catalogSeparator, String schemaSepartor)	Indicate that the current session is to allow updates to columns that have been marked as auto increment.
void	clearBatch()
void	close()
void	commit()
int	execute(String sql)
protected int	executeAllowingResults(PreparedStatement preparedStatement)
<T> T	executeCallback(IConnectionCallback<T> callback)
protected int	executePreparedUpdate(PreparedStatement preparedStatement, String sql, Object[] args, int[] argTypes)
int	flush()
int	getBatchSize()
Connection	getConnection()
LogSqlBuilder	getLogSqlBuilder()
List<Object>	getUnflushedMarkers(boolean clear)
protected final void	init()
long	insertWithGeneratedKey(String sql, String column, String sequenceName, Object[] args, int[] types)
boolean	isAllowInsertIntoAutoIncrement()
boolean	isInBatchMode()
protected final int	normalizeUpdateCount(int value)	According to the executeUpdate() javadoc -2 means that the result was successful, but that the number of rows affected is unknown.
void	prepare(String sql)	Each time the SQL changes it needs to be submitted for preparation
int	prepareAndExecute(String sql, Object... args)
int	prepareAndExecute(String sql, Object[] args, int[] types)
int	prepareAndExecute(String sql, Map<String,Object> args)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, Object[] args, int[] types)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, Map<String,Object> namedParams)
int	queryForInt(String sql, Object... args)
long	queryForLong(String sql, Object... args)
<T> T	queryForObject(String sql, Class<T> clazz, Object... args)
Row	queryForRow(String sql, Object... args)
protected void	removeMarkersThatWereSuccessful(BatchUpdateException ex)
void	rollback()
protected void	rollback(boolean clearMarkers)
void	setBatchSize(int batchSize)
void	setInBatchMode(boolean useBatching)
void	setLogSqlBuilder(LogSqlBuilder logSqlBuilder)

Methods inherited from class java.lang.Object

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

Field Details

inBatchMode

protected boolean inBatchMode

connection

protected Connection connection

psql

protected String psql

pstmt

protected PreparedStatement pstmt

jdbcSqlTemplate

protected JdbcSqlTemplate jdbcSqlTemplate

autoCommit

protected boolean autoCommit

oldAutoCommitValue

protected boolean oldAutoCommitValue

markers

protected List<Object> markers

logSqlBuilder

protected LogSqlBuilder logSqlBuilder

listeners

protected List<ISqlTransactionListener> listeners

batchSize

protected int batchSize

Constructor Details

JdbcSqlTransaction

public JdbcSqlTransaction(JdbcSqlTemplate jdbcSqlTemplate)

JdbcSqlTransaction

public JdbcSqlTransaction(JdbcSqlTemplate jdbcSqlTemplate,
 boolean autoCommit)

Method Details

addSqlTransactionListener

public void addSqlTransactionListener(ISqlTransactionListener listener)

Specified by:

addSqlTransactionListener in interface ISqlTransaction

init

protected final void init()

setInBatchMode

public void setInBatchMode(boolean useBatching)

Specified by:

setInBatchMode in interface ISqlTransaction

isInBatchMode

public boolean isInBatchMode()

Specified by:

isInBatchMode in interface ISqlTransaction

commit

public void commit()

Specified by:

commit in interface ISqlTransaction

rollback

public void rollback()

Specified by:

rollback in interface ISqlTransaction

rollback

protected void rollback(boolean clearMarkers)

close

public void close()

Specified by:

close in interface ISqlTransaction

flush

public int flush()

Specified by:

flush in interface ISqlTransaction

queryForRow

public Row queryForRow(String sql,
 Object... args)

Specified by:

queryForRow in interface ISqlTransaction

queryForInt

public int queryForInt(String sql,
 Object... args)

Specified by:

queryForInt in interface ISqlTransaction

queryForLong

public long queryForLong(String sql,
 Object... args)

Specified by:

queryForLong in interface ISqlTransaction

queryForObject

public <T> T queryForObject(String sql,
 Class<T> clazz,
 Object... args)

Specified by:

queryForObject in interface ISqlTransaction

query

public <T> List<T> query(String sql,
 ISqlRowMapper<T> mapper,
 Map<String,Object> namedParams)

Specified by:

query in interface ISqlTransaction

query

public <T> List<T> query(String sql,
 ISqlRowMapper<T> mapper,
 Object[] args,
 int[] types)

Specified by:

query in interface ISqlTransaction

execute

public int execute(String sql)

Specified by:

execute in interface ISqlTransaction

prepareAndExecute

public int prepareAndExecute(String sql,
 Object[] args,
 int[] types)

Specified by:

prepareAndExecute in interface ISqlTransaction

prepareAndExecute

public int prepareAndExecute(String sql,
 Map<String,Object> args)

Specified by:

prepareAndExecute in interface ISqlTransaction

prepareAndExecute

public int prepareAndExecute(String sql,
 Object... args)

Specified by:

prepareAndExecute in interface ISqlTransaction

executeCallback

public <T> T executeCallback(IConnectionCallback<T> callback)

normalizeUpdateCount

protected final int normalizeUpdateCount(int value)

According to the executeUpdate() javadoc -2 means that the result was successful, but that the number of rows affected is unknown. since we know that only one row is suppose to be affected, we'll default to 1.

Parameters:

value -

removeMarkersThatWereSuccessful

protected void removeMarkersThatWereSuccessful(BatchUpdateException ex)

prepare

public void prepare(String sql)

Description copied from interface: ISqlTransaction

Each time the SQL changes it needs to be submitted for preparation

Specified by:

prepare in interface ISqlTransaction

addRow

public int addRow(Object marker,
 Object[] args,
 int[] argTypes)

Specified by:

addRow in interface ISqlTransaction

setBatchSize

public void setBatchSize(int batchSize)

getBatchSize

public int getBatchSize()

executePreparedUpdate

protected int executePreparedUpdate(PreparedStatement preparedStatement,
 String sql,
 Object[] args,
 int[] argTypes)
                             throws SQLException

Throws:

SQLException

executeAllowingResults

protected int executeAllowingResults(PreparedStatement preparedStatement)
                              throws SQLException

Throws:

SQLException

getUnflushedMarkers

public List<Object> getUnflushedMarkers(boolean clear)

Specified by:

getUnflushedMarkers in interface ISqlTransaction

getConnection

public Connection getConnection()

allowInsertIntoAutoIncrementColumns

public void allowInsertIntoAutoIncrementColumns(boolean value,
 Table table,
 String quote,
 String catalogSeparator,
 String schemaSepartor)

Description copied from interface: ISqlTransaction

Indicate that the current session is to allow updates to columns that have been marked as auto increment. This is specific to SQL Server.

Specified by:

allowInsertIntoAutoIncrementColumns in interface ISqlTransaction

insertWithGeneratedKey

public long insertWithGeneratedKey(String sql,
 String column,
 String sequenceName,
 Object[] args,
 int[] types)

Specified by:

insertWithGeneratedKey in interface ISqlTransaction

getLogSqlBuilder

public LogSqlBuilder getLogSqlBuilder()

setLogSqlBuilder

public void setLogSqlBuilder(LogSqlBuilder logSqlBuilder)

clearBatch

public void clearBatch()

Specified by:

clearBatch in interface ISqlTransaction

isAllowInsertIntoAutoIncrement

public boolean isAllowInsertIntoAutoIncrement()

Specified by:

isAllowInsertIntoAutoIncrement in interface ISqlTransaction