Package org.jumpmind.db.sql

Class AbstractSqlTemplate

java.lang.Object

org.jumpmind.db.sql.AbstractSqlTemplate

All Implemented Interfaces:

ISqlTemplate

Direct Known Subclasses:

AbstractJavaDriverSqlTemplate, JdbcSqlTemplate

public abstract class AbstractSqlTemplate
extends Object
implements ISqlTemplate

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	dateOverrideToTimestamp
protected String	identifierQuoteString
protected static final org.slf4j.Logger	log
protected LogSqlBuilder	logSqlBuilder

Constructor Summary

Constructors

Constructor	Description
AbstractSqlTemplate()

Method Summary

Modifier and Type	Method	Description
boolean	doesObjectAlreadyExist(Throwable ex)
boolean	doesObjectNotExist(Throwable ex)
protected Object[]	expandArgs(String sql, Object[] args)
protected String	expandSql(String sql, Object[] args)
String	getUniqueKeyViolationIndexName(Throwable ex)
boolean	isDeadlock(Throwable ex)
boolean	isForeignKeyChildExistsViolation(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 maxNumberOfRowsToFetch, ISqlRowMapper<T> mapper, Object[] args, int[] types)
<T> List<T>	query(String sql, int maxRowsToFetch, ISqlRowMapper<T> mapper, Map<String,Object> namedParams)
<T> List<T>	query(String sql, int maxNumberOfRowsToFetch, ISqlRowMapper<T> mapper, IConnectionHandler handler, Object[] args, int[] types)
List<Row>	query(String sql, Object[] args)
List<Row>	query(String sql, Object[] args, int[] types)
<T, W> Map<T,W>	query(String sql, String keyCol, String valueCol, Object[] args, int[] types)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, 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,?> namedParams)
<T> List<T>	query(String sql, ISqlRowMapper<T> mapper, IConnectionHandler handler, Object[] args, int[] types)
<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, Map<String,Object> namedParams)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, IConnectionHandler connectionHandler, Object[] args, 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, 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, ISqlRowMapper<T> mapper, Object... args)
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)
SqlException	translate(String message, Throwable ex)
SqlException	translate(Throwable ex)
int	update(String sql, Object... values)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.db.sql.ISqlTemplate

getDatabaseMajorVersion, getDatabaseMinorVersion, getDatabaseProductName, getDatabaseProductVersion, getDriverName, getDriverVersion, getSqlKeywords, insertWithGeneratedKey, isDataTruncationViolation, isForeignKeyViolation, isStoresLowerCaseIdentifiers, isStoresMixedCaseQuotedIdentifiers, isStoresUpperCaseIdentifiers, isUniqueKeyViolation, queryForBlob, queryForClob, queryForCursor, queryForMap, queryForObject, startSqlTransaction, startSqlTransaction, supportsGetGeneratedKeys, testConnection, update, update, update, update

Field Details

log

protected static final org.slf4j.Logger log

dateOverrideToTimestamp

protected boolean dateOverrideToTimestamp

identifierQuoteString

protected String identifierQuoteString

logSqlBuilder

protected LogSqlBuilder logSqlBuilder

Constructor Details

AbstractSqlTemplate

public AbstractSqlTemplate()

Method Details

queryForObject

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

Specified by:

queryForObject in interface ISqlTemplate

queryForString

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

Specified by:

queryForString in interface ISqlTemplate

queryForInt

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

Specified by:

queryForInt in interface ISqlTemplate

queryForInt

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

Specified by:

queryForInt in interface ISqlTemplate

queryForLong

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

Specified by:

queryForLong in interface ISqlTemplate

queryForMap

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

Specified by:

queryForMap in interface ISqlTemplate

queryForMap

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

Specified by:

queryForMap in interface ISqlTemplate

queryForCursor

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

Specified by:

queryForCursor in interface ISqlTemplate

queryForCursor

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

Specified by:

queryForCursor in interface ISqlTemplate

queryForCursor

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

Specified by:

queryForCursor in interface ISqlTemplate

queryForCursor

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

Specified by:

queryForCursor in interface ISqlTemplate

query

public List<Row> query(String sql)

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

queryWithHandler

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

Specified by:

queryWithHandler in interface ISqlTemplate

queryForRow

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

Specified by:

queryForRow in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

Specified by:

query in interface ISqlTemplate

query

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

query

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

Specified by:

query in interface ISqlTemplate

query

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

update

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

Specified by:

update in interface ISqlTemplate

expandSql

protected String expandSql(String sql,
 Object[] args)

expandArgs

protected Object[] expandArgs(String sql,
 Object[] args)

translate

public SqlException translate(Throwable ex)

Specified by:

translate in interface ISqlTemplate

translate

public SqlException translate(String message,
 Throwable ex)

getUniqueKeyViolationIndexName

public String getUniqueKeyViolationIndexName(Throwable ex)

Specified by:

getUniqueKeyViolationIndexName in interface ISqlTemplate

isForeignKeyChildExistsViolation

public boolean isForeignKeyChildExistsViolation(Throwable ex)

Specified by:

isForeignKeyChildExistsViolation in interface ISqlTemplate

isDeadlock

public boolean isDeadlock(Throwable ex)

Specified by:

isDeadlock in interface ISqlTemplate

doesObjectAlreadyExist

public boolean doesObjectAlreadyExist(Throwable ex)

Specified by:

doesObjectAlreadyExist in interface ISqlTemplate

doesObjectNotExist

public boolean doesObjectNotExist(Throwable ex)

Specified by:

doesObjectNotExist in interface ISqlTemplate