Package org.jumpmind.db.sql

Class AbstractJavaDriverSqlTemplate

java.lang.Object

org.jumpmind.db.sql.AbstractSqlTemplate

org.jumpmind.db.sql.AbstractJavaDriverSqlTemplate

All Implemented Interfaces:

ISqlTemplate

Direct Known Subclasses:

CassandraSqlTemplate, KafkaSqlTemplate

public abstract class AbstractJavaDriverSqlTemplate
extends AbstractSqlTemplate

Field Summary

Fields inherited from class org.jumpmind.db.sql.AbstractSqlTemplate

dateOverrideToTimestamp, identifierQuoteString, log, logSqlBuilder

Constructor Summary

Constructors

Constructor	Description
AbstractJavaDriverSqlTemplate()

Method Summary

Modifier and Type	Method	Description
int	getDatabaseMajorVersion()
int	getDatabaseMinorVersion()
abstract String	getDatabaseProductName()
String	getDatabaseProductVersion()
String	getDriverName()
String	getDriverVersion()
Set<String>	getSqlKeywords()
long	insertWithGeneratedKey(String sql, String column, String sequenceName, Object[] args, int[] types)
boolean	isDataTruncationViolation(Throwable ex)
boolean	isForeignKeyChildExistsViolation(Throwable ex)
boolean	isForeignKeyViolation(Throwable ex)
boolean	isStoresLowerCaseIdentifiers()
boolean	isStoresMixedCaseQuotedIdentifiers()
boolean	isStoresUpperCaseIdentifiers()
boolean	isUniqueKeyViolation(Throwable ex)
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, boolean returnLobObjects)
<T> ISqlReadCursor<T>	queryForCursor(String sql, ISqlRowMapper<T> mapper, Object[] params, int[] types)
Map<String,Object>	queryForMap(String sql, Object... params)
<T> T	queryForObject(String sql, Class<T> clazz, Object... params)
ISqlTransaction	startSqlTransaction()
ISqlTransaction	startSqlTransaction(boolean autoCommit)
boolean	supportsGetGeneratedKeys()
void	testConnection()
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[] types)

Methods inherited from class org.jumpmind.db.sql.AbstractSqlTemplate

doesObjectAlreadyExist, doesObjectNotExist, expandArgs, expandSql, getUniqueKeyViolationIndexName, isDeadlock, query, query, query, query, query, query, query, query, query, query, query, query, queryForCursor, queryForCursor, queryForCursor, queryForInt, queryForInt, queryForLong, queryForMap, queryForMap, queryForObject, queryForRow, queryForString, queryWithHandler, translate, translate, update

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractJavaDriverSqlTemplate

public AbstractJavaDriverSqlTemplate()

Method Details

getDatabaseProductName

public abstract String getDatabaseProductName()

queryForBlob

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

queryForClob

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

queryForObject

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

queryForMap

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

queryForCursor

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

queryForCursor

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

Specified by:

queryForCursor in interface ISqlTemplate

Overrides:

queryForCursor in class AbstractSqlTemplate

update

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

update

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

update

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

update

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

testConnection

public void testConnection()

isUniqueKeyViolation

public boolean isUniqueKeyViolation(Throwable ex)

isDataTruncationViolation

public boolean isDataTruncationViolation(Throwable ex)

isForeignKeyViolation

public boolean isForeignKeyViolation(Throwable ex)

startSqlTransaction

public ISqlTransaction startSqlTransaction()

startSqlTransaction

public ISqlTransaction startSqlTransaction(boolean autoCommit)

getDatabaseMajorVersion

public int getDatabaseMajorVersion()

getDatabaseMinorVersion

public int getDatabaseMinorVersion()

getDatabaseProductVersion

public String getDatabaseProductVersion()

getDriverName

public String getDriverName()

getDriverVersion

public String getDriverVersion()

getSqlKeywords

public Set<String> getSqlKeywords()

supportsGetGeneratedKeys

public boolean supportsGetGeneratedKeys()

isStoresUpperCaseIdentifiers

public boolean isStoresUpperCaseIdentifiers()

isStoresLowerCaseIdentifiers

public boolean isStoresLowerCaseIdentifiers()

isStoresMixedCaseQuotedIdentifiers

public boolean isStoresMixedCaseQuotedIdentifiers()

insertWithGeneratedKey

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

isForeignKeyChildExistsViolation

public boolean isForeignKeyChildExistsViolation(Throwable ex)

Specified by:

isForeignKeyChildExistsViolation in interface ISqlTemplate

Overrides:

isForeignKeyChildExistsViolation in class AbstractSqlTemplate