Package org.jumpmind.db.sql

Interface ISqlTemplate

All Known Implementing Classes:

AbstractJavaDriverSqlTemplate, AbstractSqlTemplate, AseJdbcSqlTemplate, CassandraSqlTemplate, Db2JdbcSqlTemplate, DerbyJdbcSqlTemplate, FirebirdJdbcSqlTemplate, GenericJdbcSqlTemplate, GreenplumJdbcSqlTemplate, H2JdbcSqlTemplate, HanaSqlJdbcSqlTemplate, HsqlDb2JdbcSqlTemplate, HsqlDbJdbcSqlTemplate, InformixJdbcSqlTemplate, IngresJdbcSqlTemplate, InterbaseJdbcSqlTemplate, JdbcSqlTemplate, KafkaSqlTemplate, MsSqlJdbcSqlTemplate, MySqlJdbcSqlTemplate, NuoDbJdbcSqlTemplate, OracleJdbcSqlTemplate, PostgreSqlJdbcSqlTemplate, RaimaJdbcSqlTemplate, RedshiftJdbcSqlTemplate, SqlAnywhereJdbcSqlTemplate, SqliteJdbcSqlTemplate, SybaseJdbcSqlTemplate, VoltDbJdbcSqlTemplate

public interface ISqlTemplate

This interface insulates the application from the data connection technology.

Method Summary

Modifier and Type	Method	Description
boolean	doesObjectAlreadyExist(Throwable ex)
boolean	doesObjectNotExist(Throwable ex)
int	getDatabaseMajorVersion()
int	getDatabaseMinorVersion()
String	getDatabaseProductName()
String	getDatabaseProductVersion()
String	getDriverName()
String	getDriverVersion()
Set<String>	getSqlKeywords()
String	getUniqueKeyViolationIndexName(Throwable ex)
long	insertWithGeneratedKey(String sql, String column, String sequenceName, Object[] args, int[] types)
boolean	isDataTruncationViolation(Throwable ex)
boolean	isDeadlock(Throwable ex)
boolean	isForeignKeyChildExistsViolation(Throwable ex)
boolean	isForeignKeyViolation(Throwable ex)
boolean	isStoresLowerCaseIdentifiers()
boolean	isStoresMixedCaseQuotedIdentifiers()
boolean	isStoresUpperCaseIdentifiers()
boolean	isUniqueKeyViolation(Throwable ex)
List<Row>	query(String sql)
<T> List<T>	query(String sql, int maxRowsToFetch, ISqlRowMapper<T> mapper, Object... params)
<T> List<T>	query(String sql, int maxRowsToFetch, ISqlRowMapper<T> mapper, Object[] params, int[] types)
<T> List<T>	query(String sql, int maxRowsToFetch, ISqlRowMapper<T> mapper, Map<String,Object> params)
List<Row>	query(String sql, Object[] params)
List<Row>	query(String sql, Object[] params, int[] types)
<T, W> Map<T,W>	query(String sql, String keyCol, String valueCol, Object[] params, int[] types)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, Object... params)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, Object[] params, int[] types)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, Map<String,?> namedParams)
byte[]	queryForBlob(String sql, int jdbcTypeCode, String jdbcTypeName, Object... args)
String	queryForClob(String sql, int jdbcTypeCode, String jdbcTypeName, Object... args)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, boolean returnLobObjects)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, Object[] params, int[] types)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, Map<String,Object> params)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, IConnectionHandler connectionHandler, Object[] params, int[] types)
int	queryForInt(String sql, Object... args)
int	queryForInt(String sql, Map<String,Object> params)
long	queryForLong(String sql, Object... args)
Map<String,Object>	queryForMap(String sql, Object... params)
<T> Map<String,T>	queryForMap(String sql, String keyColumn, String valueColumn, Object... args)
<T> Map<String,T>	queryForMap(String sql, ISqlRowMapper<T> mapper, String keyColumn, Object... args)
<T> T	queryForObject(String sql, Class<T> clazz, Object... params)
<T> T	queryForObject(String sql, ISqlRowMapper<T> mapper, Object... params)
Row	queryForRow(String sql, Object... args)
String	queryForString(String sql, Object... args)
<T> List<T>	queryWithHandler(String sql, ISqlRowMapper<T> mapper, IConnectionHandler conHandler, Object... params)
ISqlTransaction	startSqlTransaction()
ISqlTransaction	startSqlTransaction(boolean autoCommit)
boolean	supportsGetGeneratedKeys()
void	testConnection()
SqlException	translate(Throwable ex)
int	update(boolean autoCommit, boolean failOnError, boolean failOnDrops, boolean failOnSequenceCreate, int commitRate, ISqlResultsListener listener, ISqlStatementSource source)
int	update(boolean autoCommit, boolean failOnError, int commitRate, String... sql)
int	update(boolean autoCommit, boolean failOnError, int commitRate, ISqlResultsListener listener, String... sql)
int	update(String sql, Object... values)
int	update(String sql, Object[] values, int[] types)

Method Details

queryForBlob

byte[] queryForBlob(String sql,
 int jdbcTypeCode,
 String jdbcTypeName,
 Object... args)

queryForClob

String queryForClob(String sql,
 int jdbcTypeCode,
 String jdbcTypeName,
 Object... args)

queryForObject

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

queryForObject

<T> T queryForObject(String sql,
 ISqlRowMapper<T> mapper,
 Object... params)

queryForInt

int queryForInt(String sql,
 Map<String,Object> params)

queryForInt

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

queryForString

String queryForString(String sql,
 Object... args)

queryForLong

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

queryForRow

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

queryForMap

Map<String,Object> queryForMap(String sql,
 Object... params)

queryForMap

<T> Map<String,T> queryForMap(String sql,
 ISqlRowMapper<T> mapper,
 String keyColumn,
 Object... args)

queryForMap

<T> Map<String,T> queryForMap(String sql,
 String keyColumn,
 String valueColumn,
 Object... args)

queryForCursor

<T> ISqlReadCursor<T> queryForCursor(String sql,
 ISqlRowMapper<T> mapper,
 Object[] params,
 int[] types)

queryForCursor

<T> ISqlReadCursor<T> queryForCursor(String sql,
 ISqlRowMapper<T> mapper,
 IConnectionHandler connectionHandler,
 Object[] params,
 int[] types)

queryForCursor

<T> ISqlReadCursor<T> queryForCursor(String sql,
 ISqlRowMapper<T> mapper)

queryForCursor

<T> ISqlReadCursor<T> queryForCursor(String sql,
 ISqlRowMapper<T> mapper,
 boolean returnLobObjects)

queryForCursor

<T> ISqlReadCursor<T> queryForCursor(String sql,
 ISqlRowMapper<T> mapper,
 Map<String,Object> params)

query

List<Row> query(String sql)

query

List<Row> query(String sql,
 Object[] params,
 int[] types)

query

List<Row> query(String sql,
 Object[] params)

query

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

query

<T> List<T> query(String sql,
 ISqlRowMapper<T> mapper,
 Object... params)

queryWithHandler

<T> List<T> queryWithHandler(String sql,
 ISqlRowMapper<T> mapper,
 IConnectionHandler conHandler,
 Object... params)

query

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

query

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

query

<T> List<T> query(String sql,
 int maxRowsToFetch,
 ISqlRowMapper<T> mapper,
 Object... params)

query

<T> List<T> query(String sql,
 int maxRowsToFetch,
 ISqlRowMapper<T> mapper,
 Map<String,Object> params)

query

<T,
W> Map<T,W> query(String sql,
 String keyCol,
 String valueCol,
 Object[] params,
 int[] types)

update

int update(boolean autoCommit,
 boolean failOnError,
 int commitRate,
 ISqlResultsListener listener,
 String... sql)

update

int update(boolean autoCommit,
 boolean failOnError,
 boolean failOnDrops,
 boolean failOnSequenceCreate,
 int commitRate,
 ISqlResultsListener listener,
 ISqlStatementSource source)

update

int update(boolean autoCommit,
 boolean failOnError,
 int commitRate,
 String... sql)

update

int update(String sql,
 Object[] values,
 int[] types)

update

int update(String sql,
 Object... values)

testConnection

void testConnection()

translate

SqlException translate(Throwable ex)

isUniqueKeyViolation

boolean isUniqueKeyViolation(Throwable ex)

getUniqueKeyViolationIndexName

String getUniqueKeyViolationIndexName(Throwable ex)

isDataTruncationViolation

boolean isDataTruncationViolation(Throwable ex)

isForeignKeyViolation

boolean isForeignKeyViolation(Throwable ex)

isForeignKeyChildExistsViolation

boolean isForeignKeyChildExistsViolation(Throwable ex)

isDeadlock

boolean isDeadlock(Throwable ex)

doesObjectAlreadyExist

boolean doesObjectAlreadyExist(Throwable ex)

doesObjectNotExist

boolean doesObjectNotExist(Throwable ex)

startSqlTransaction

ISqlTransaction startSqlTransaction()

startSqlTransaction

ISqlTransaction startSqlTransaction(boolean autoCommit)

getDatabaseMajorVersion

int getDatabaseMajorVersion()

getDatabaseMinorVersion

int getDatabaseMinorVersion()

getDatabaseProductName

String getDatabaseProductName()

getDatabaseProductVersion

String getDatabaseProductVersion()

getDriverName

String getDriverName()

getDriverVersion

String getDriverVersion()

getSqlKeywords

Set<String> getSqlKeywords()

supportsGetGeneratedKeys

boolean supportsGetGeneratedKeys()

isStoresUpperCaseIdentifiers

boolean isStoresUpperCaseIdentifiers()

isStoresLowerCaseIdentifiers

boolean isStoresLowerCaseIdentifiers()

isStoresMixedCaseQuotedIdentifiers

boolean isStoresMixedCaseQuotedIdentifiers()

insertWithGeneratedKey

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