Package org.jumpmind.db.sql

Interface ISqlTransaction

All Known Implementing Classes:

AseJdbcSqlTransaction, CassandraSqlTransaction, H2JdbcSqlTransaction, JdbcSqlTransaction, MsSqlJdbcSqlTransaction

public interface ISqlTransaction

Method Summary

Modifier and Type	Method	Description
<T> int	addRow(T marker, Object[] values, int[] types)
void	addSqlTransactionListener(ISqlTransactionListener listener)
void	allowInsertIntoAutoIncrementColumns(boolean value, Table table, String quote, String catalogSeparator, String schemaSeparator)	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)
int	flush()
<T> List<T>	getUnflushedMarkers(boolean clear)
long	insertWithGeneratedKey(String sql, String column, String sequenceName, Object[] args, int[] types)
boolean	isAllowInsertIntoAutoIncrement()
boolean	isInBatchMode()
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)
void	rollback()
void	setInBatchMode(boolean batchMode)

Method Details

addSqlTransactionListener

void addSqlTransactionListener(ISqlTransactionListener listener)

isInBatchMode

boolean isInBatchMode()

setInBatchMode

void setInBatchMode(boolean batchMode)

queryForObject

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

queryForRow

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

queryForInt

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

queryForLong

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

execute

int execute(String sql)

prepareAndExecute

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

prepareAndExecute

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

prepareAndExecute

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

query

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

query

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

commit

void commit()

rollback

void rollback()

close

void close()

prepare

void prepare(String sql)

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

addRow

<T> int addRow(T marker,
 Object[] values,
 int[] types)

flush

int flush()

getUnflushedMarkers

<T> List<T> getUnflushedMarkers(boolean clear)

allowInsertIntoAutoIncrementColumns

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

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

isAllowInsertIntoAutoIncrement

boolean isAllowInsertIntoAutoIncrement()

insertWithGeneratedKey

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

clearBatch

void clearBatch()