Package org.jumpmind.db.platform.cassandra

Class CassandraSqlTransaction

java.lang.Object

org.jumpmind.db.platform.cassandra.CassandraSqlTransaction

All Implemented Interfaces:

ISqlTransaction

public class CassandraSqlTransaction
extends Object
implements ISqlTransaction

Constructor Summary

Constructors

Constructor	Description
CassandraSqlTransaction()

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)

Methods inherited from class java.lang.Object

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

Constructor Details

CassandraSqlTransaction

public CassandraSqlTransaction()

Method Details

addSqlTransactionListener

public void addSqlTransactionListener(ISqlTransactionListener listener)

Specified by:

addSqlTransactionListener in interface ISqlTransaction

isInBatchMode

public boolean isInBatchMode()

Specified by:

isInBatchMode in interface ISqlTransaction

setInBatchMode

public void setInBatchMode(boolean batchMode)

Specified by:

setInBatchMode in interface ISqlTransaction

queryForObject

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

Specified by:

queryForObject 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

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,
 Object... args)

Specified by:

prepareAndExecute in interface ISqlTransaction

prepareAndExecute

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

Specified by:

prepareAndExecute 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

commit

public void commit()

Specified by:

commit in interface ISqlTransaction

rollback

public void rollback()

Specified by:

rollback in interface ISqlTransaction

close

public void close()

Specified by:

close in interface ISqlTransaction

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 <T> int addRow(T marker,
 Object[] values,
 int[] types)

Specified by:

addRow in interface ISqlTransaction

flush

public int flush()

Specified by:

flush in interface ISqlTransaction

getUnflushedMarkers

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

Specified by:

getUnflushedMarkers in interface ISqlTransaction

allowInsertIntoAutoIncrementColumns

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

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

isAllowInsertIntoAutoIncrement

public boolean isAllowInsertIntoAutoIncrement()

Specified by:

isAllowInsertIntoAutoIncrement in interface ISqlTransaction

clearBatch

public void clearBatch()

Specified by:

clearBatch in interface ISqlTransaction