nl.nn.adapterframework.jdbc.dbms

Class GenericDbmsSupport

java.lang.Object

nl.nn.adapterframework.jdbc.dbms.GenericDbmsSupport

All Implemented Interfaces:

IDbmsSupport

Direct Known Subclasses:

Db2DbmsSupport, H2DbmsSupport, MsSqlServerDbmsSupport, MySqlDbmsSupport, OracleDbmsSupport, PostgresqlDbmsSupport

public class GenericDbmsSupport
extends Object
implements IDbmsSupport

Author:

Gerrit van Brakel

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	KEYWORD_SELECT
protected org.apache.logging.log4j.Logger	log
protected static Map<String,ISqlTranslator>	sqlTranslators
protected static String	TYPE_BLOB
protected static String	TYPE_CLOB
protected static String	TYPE_FUNCTION

Constructor Summary

Constructors

Constructor and Description
GenericDbmsSupport()

Method Summary

Modifier and Type	Method and Description
void	applyBlobParameter(PreparedStatement stmt, int column, Object blobInsertHandle)
void	applyClobParameter(PreparedStatement stmt, int column, Object clobHandle)
String	autoIncrementInsertValue(String sequenceName)
boolean	autoIncrementKeyMustBeInserted()
boolean	autoIncrementUsesSequenceObject()
void	convertQuery(QueryExecutionContext queryExecutionContext, String sqlDialectFrom)
protected ISqlTranslator	createTranslator(String source, String target)
protected boolean	doHasIndexOnColumns(Connection conn, String schemaOwner, String tableName, List<String> columns, String indexTableName, String indexColumnTableName, String tableOwnerColumnName, String tableNameColumnName, String indexNameColumnName, String columnNameColumnName, String columPositionColumnName)
protected boolean	doIsColumnPresent(Connection conn, String columnsTable, String schemaColumn, String tableNameColumn, String columnNameColumn, String schemaName, String tableName, String columnName) Alternative implementation of isColumnPresent(), that can be used by descender classes if the implementation via metadata does not work for that driver.
protected boolean	doIsTablePresent(Connection conn, String tablesTable, String schemaColumn, String tableNameColumn, String schemaName, String tableName) Alternative implementation of isTablePresent(), that can be used by descender classes if the implementation via metadata does not work for that driver.
String	emptyBlobValue()
String	emptyClobValue()
String	getAutoIncrementKeyFieldType()
String	getBlobFieldType()
Object	getBlobHandle(PreparedStatement stmt, int column)
Object	getBlobHandle(ResultSet rs, int column)
Object	getBlobHandle(ResultSet rs, String column)
InputStream	getBlobInputStream(ResultSet rs, int column)
InputStream	getBlobInputStream(ResultSet rs, String column)
OutputStream	getBlobOutputStream(PreparedStatement stmt, int column, Object blobInsertHandle)
OutputStream	getBlobOutputStream(ResultSet rs, int column, Object blobUpdateHandle)
protected OutputStream	getBlobOutputStream(ResultSet rs, Object blobUpdateHandle)
OutputStream	getBlobOutputStream(ResultSet rs, String column, Object blobUpdateHandle)
String	getBooleanFieldType()
String	getBooleanValue(boolean value)
String	getCleanUpIbisstoreQuery(String tableName, String keyField, String typeField, String expiryDateField, int maxRows)
String	getClobFieldType()
Object	getClobHandle(PreparedStatement stmt, int column)
Object	getClobHandle(ResultSet rs, int column)
Object	getClobHandle(ResultSet rs, String column)
Reader	getClobReader(ResultSet rs, int column)
Reader	getClobReader(ResultSet rs, String column)
Writer	getClobWriter(PreparedStatement stmt, int column, Object clobHandle)
Writer	getClobWriter(ResultSet rs, int column, Object clobHandle)
Writer	getClobWriter(ResultSet rs, String column, Object clobHandle)
String	getDateAndOffset(String dateValue, int daysOffset)
String	getDatetimeLiteral(Date date)
Dbms	getDbms() Numeric value defining database type, defined in DbmsSupportFactory.
String	getDbmsName()
String	getFirstRecordQuery(String tableName)
String	getFromForTablelessSelect() http://en.wikipedia.org/wiki/DUAL_table
String	getIbisStoreSummaryQuery()
String	getInsertedAutoIncrementValueQuery(String sequenceName)
String	getLength(String column)
String	getNumericKeyFieldType()
String	getRowNumber(String order, String sort)
String	getRowNumberShortName()
String	getSchema(Connection conn)
String	getSchemaOwner(Connection conn)
String	getSysDate() SQL String returning current date and time of dbms.
ResultSet	getTableColumns(Connection conn, String tableName)
ResultSet	getTableColumns(Connection conn, String schemaName, String tableName)
ResultSet	getTableColumns(Connection conn, String schemaName, String tableName, String columnNamePattern)
String	getTextFieldType()
String	getTimestampAsDate(String columnName)
String	getTimestampFieldType()
String	getUpdateBlobQuery(String table, String blobField, String keyField)
String	getUpdateClobQuery(String table, String clobField, String keyField)
boolean	hasIndexOnColumn(Connection conn, String schemaName, String tableName, String columnName)
boolean	hasIndexOnColumns(Connection conn, String schemaOwner, String tableName, List<String> columns)
boolean	hasSkipLockedFunctionality()
boolean	isBlobType(ResultSetMetaData rsmeta, int colNum)
boolean	isClobType(ResultSetMetaData rsmeta, int colNum)
boolean	isColumnPresent(Connection conn, String tableName, String columnName)
boolean	isColumnPresent(Connection conn, String schemaName, String tableName, String columnName)
boolean	isConstraintViolation(SQLException e)
boolean	isIndexPresent(Connection conn, String schemaOwner, String tableName, String indexName)
boolean	isParameterTypeMatchRequired()
protected boolean	isQueryConversionRequired(String sqlDialectFrom)
boolean	isSequencePresent(Connection conn, String schemaOwner, String tableName, String sequenceName)
boolean	isTablePresent(Connection conn, String tableName)
boolean	isTablePresent(Connection conn, String schemaName, String tableName)
boolean	mustInsertEmptyBlobBeforeData()
boolean	mustInsertEmptyClobBeforeData()
String	prepareQueryTextForNonLockingRead(String selectQuery) Modify the provided selectQuery in such a way that the resulting query will not be blocked by locks, and will avoid placing locks itself as much as possible.
String	prepareQueryTextForWorkQueuePeeking(int batchSize, String selectQuery)
String	prepareQueryTextForWorkQueuePeeking(int batchSize, String selectQuery, int wait)
String	prepareQueryTextForWorkQueueReading(int batchSize, String selectQuery)
String	prepareQueryTextForWorkQueueReading(int batchSize, String selectQuery, int wait)
JdbcSession	prepareSessionForNonLockingRead(Connection conn) Modify the connection in such a way that it when select queries, prepared by IDbmsSupport.prepareQueryTextForNonLockingRead(String) or by IDbmsSupport.prepareQueryTextForWorkQueuePeeking(int,String), are executed, they will not be blocked by locks, and will avoid placing locks itself as much as possible.
String	provideFirstRowsHintAfterFirstKeyword(int rowCount)
String	provideIndexHintAfterFirstKeyword(String tableName, String indexName)
String	provideTrailingFirstRowsHint(int rowCount)
protected List<String>	splitQuery(String query)
void	updateBlob(ResultSet rs, int column, Object blobUpdateHandle)
void	updateBlob(ResultSet rs, String column, Object blobUpdateHandle)
void	updateClob(ResultSet rs, int column, Object clobHandle)
void	updateClob(ResultSet rs, String column, Object clobHandle)
protected void	warnConvertQuery(String sqlDialectFrom)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected org.apache.logging.log4j.Logger log

KEYWORD_SELECT

protected static final String KEYWORD_SELECT

See Also:

Constant Field Values

TYPE_BLOB

protected static final String TYPE_BLOB

See Also:

Constant Field Values

TYPE_CLOB

protected static final String TYPE_CLOB

See Also:

Constant Field Values

TYPE_FUNCTION

protected static final String TYPE_FUNCTION

See Also:

Constant Field Values

sqlTranslators

protected static Map<String,ISqlTranslator> sqlTranslators

Constructor Detail

GenericDbmsSupport

public GenericDbmsSupport()

Method Detail

getDbmsName

public String getDbmsName()

Specified by:

getDbmsName in interface IDbmsSupport

getDbms

public Dbms getDbms()

Description copied from interface: IDbmsSupport

Numeric value defining database type, defined in DbmsSupportFactory.

Specified by:

getDbms in interface IDbmsSupport

isParameterTypeMatchRequired

public boolean isParameterTypeMatchRequired()

Specified by:

isParameterTypeMatchRequired in interface IDbmsSupport

hasSkipLockedFunctionality

public boolean hasSkipLockedFunctionality()

Specified by:

hasSkipLockedFunctionality in interface IDbmsSupport

getSysDate

public String getSysDate()

Description copied from interface: IDbmsSupport

SQL String returning current date and time of dbms.

Specified by:

getSysDate in interface IDbmsSupport

getDateAndOffset

public String getDateAndOffset(String dateValue,
                               int daysOffset)

Specified by:

getDateAndOffset in interface IDbmsSupport

getNumericKeyFieldType

public String getNumericKeyFieldType()

Specified by:

getNumericKeyFieldType in interface IDbmsSupport

getFromForTablelessSelect

public String getFromForTablelessSelect()

Description copied from interface: IDbmsSupport

http://en.wikipedia.org/wiki/DUAL_table

Specified by:

getFromForTablelessSelect in interface IDbmsSupport

getAutoIncrementKeyFieldType

public String getAutoIncrementKeyFieldType()

Specified by:

getAutoIncrementKeyFieldType in interface IDbmsSupport

autoIncrementKeyMustBeInserted

public boolean autoIncrementKeyMustBeInserted()

Specified by:

autoIncrementKeyMustBeInserted in interface IDbmsSupport

autoIncrementInsertValue

public String autoIncrementInsertValue(String sequenceName)

Specified by:

autoIncrementInsertValue in interface IDbmsSupport

autoIncrementUsesSequenceObject

public boolean autoIncrementUsesSequenceObject()

Specified by:

autoIncrementUsesSequenceObject in interface IDbmsSupport

getInsertedAutoIncrementValueQuery

public String getInsertedAutoIncrementValueQuery(String sequenceName)

Specified by:

getInsertedAutoIncrementValueQuery in interface IDbmsSupport

getIbisStoreSummaryQuery

public String getIbisStoreSummaryQuery()

Specified by:

getIbisStoreSummaryQuery in interface IDbmsSupport

getTimestampFieldType

public String getTimestampFieldType()

Specified by:

getTimestampFieldType in interface IDbmsSupport

getDatetimeLiteral

public String getDatetimeLiteral(Date date)

Specified by:

getDatetimeLiteral in interface IDbmsSupport

getTimestampAsDate

public String getTimestampAsDate(String columnName)

Specified by:

getTimestampAsDate in interface IDbmsSupport

getClobFieldType

public String getClobFieldType()

Specified by:

getClobFieldType in interface IDbmsSupport

isClobType

public boolean isClobType(ResultSetMetaData rsmeta,
                          int colNum)
                   throws SQLException

Specified by:

isClobType in interface IDbmsSupport

Throws:

SQLException

mustInsertEmptyClobBeforeData

public boolean mustInsertEmptyClobBeforeData()

Specified by:

mustInsertEmptyClobBeforeData in interface IDbmsSupport

getUpdateClobQuery

public String getUpdateClobQuery(String table,
                                 String clobField,
                                 String keyField)

Specified by:

getUpdateClobQuery in interface IDbmsSupport

emptyClobValue

public String emptyClobValue()

Specified by:

emptyClobValue in interface IDbmsSupport

getClobHandle

public Object getClobHandle(ResultSet rs,
                            int column)
                     throws SQLException,
                            JdbcException

Specified by:

getClobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobHandle

public Object getClobHandle(ResultSet rs,
                            String column)
                     throws SQLException,
                            JdbcException

Specified by:

getClobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

public Writer getClobWriter(ResultSet rs,
                            int column,
                            Object clobHandle)
                     throws SQLException,
                            JdbcException

Specified by:

getClobWriter in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

public Writer getClobWriter(ResultSet rs,
                            String column,
                            Object clobHandle)
                     throws SQLException,
                            JdbcException

Specified by:

getClobWriter in interface IDbmsSupport

Throws:

SQLException

JdbcException

updateClob

public void updateClob(ResultSet rs,
                       int column,
                       Object clobHandle)
                throws SQLException,
                       JdbcException

Specified by:

updateClob in interface IDbmsSupport

Throws:

SQLException

JdbcException

updateClob

public void updateClob(ResultSet rs,
                       String column,
                       Object clobHandle)
                throws SQLException,
                       JdbcException

Specified by:

updateClob in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobHandle

public Object getClobHandle(PreparedStatement stmt,
                            int column)
                     throws SQLException,
                            JdbcException

Specified by:

getClobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

public Writer getClobWriter(PreparedStatement stmt,
                            int column,
                            Object clobHandle)
                     throws SQLException,
                            JdbcException

Specified by:

getClobWriter in interface IDbmsSupport

Throws:

SQLException

JdbcException

applyClobParameter

public void applyClobParameter(PreparedStatement stmt,
                               int column,
                               Object clobHandle)
                        throws SQLException,
                               JdbcException

Specified by:

applyClobParameter in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobReader

public Reader getClobReader(ResultSet rs,
                            int column)
                     throws SQLException,
                            JdbcException

Specified by:

getClobReader in interface IDbmsSupport

Throws:

SQLException

JdbcException

getClobReader

public Reader getClobReader(ResultSet rs,
                            String column)
                     throws SQLException,
                            JdbcException

Specified by:

getClobReader in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobFieldType

public String getBlobFieldType()

Specified by:

getBlobFieldType in interface IDbmsSupport

isBlobType

public boolean isBlobType(ResultSetMetaData rsmeta,
                          int colNum)
                   throws SQLException

Specified by:

isBlobType in interface IDbmsSupport

Throws:

SQLException

mustInsertEmptyBlobBeforeData

public boolean mustInsertEmptyBlobBeforeData()

Specified by:

mustInsertEmptyBlobBeforeData in interface IDbmsSupport

getUpdateBlobQuery

public String getUpdateBlobQuery(String table,
                                 String blobField,
                                 String keyField)

Specified by:

getUpdateBlobQuery in interface IDbmsSupport

emptyBlobValue

public String emptyBlobValue()

Specified by:

emptyBlobValue in interface IDbmsSupport

getBlobHandle

public Object getBlobHandle(ResultSet rs,
                            int column)
                     throws SQLException,
                            JdbcException

Specified by:

getBlobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobHandle

public Object getBlobHandle(ResultSet rs,
                            String column)
                     throws SQLException,
                            JdbcException

Specified by:

getBlobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

protected OutputStream getBlobOutputStream(ResultSet rs,
                                           Object blobUpdateHandle)
                                    throws SQLException,
                                           JdbcException

Throws:

SQLException

JdbcException

getBlobOutputStream

public OutputStream getBlobOutputStream(ResultSet rs,
                                        int column,
                                        Object blobUpdateHandle)
                                 throws SQLException,
                                        JdbcException

Specified by:

getBlobOutputStream in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

public OutputStream getBlobOutputStream(ResultSet rs,
                                        String column,
                                        Object blobUpdateHandle)
                                 throws SQLException,
                                        JdbcException

Specified by:

getBlobOutputStream in interface IDbmsSupport

Throws:

SQLException

JdbcException

updateBlob

public void updateBlob(ResultSet rs,
                       int column,
                       Object blobUpdateHandle)
                throws SQLException,
                       JdbcException

Specified by:

updateBlob in interface IDbmsSupport

Throws:

SQLException

JdbcException

updateBlob

public void updateBlob(ResultSet rs,
                       String column,
                       Object blobUpdateHandle)
                throws SQLException,
                       JdbcException

Specified by:

updateBlob in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobHandle

public Object getBlobHandle(PreparedStatement stmt,
                            int column)
                     throws SQLException,
                            JdbcException

Specified by:

getBlobHandle in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

public OutputStream getBlobOutputStream(PreparedStatement stmt,
                                        int column,
                                        Object blobInsertHandle)
                                 throws SQLException,
                                        JdbcException

Specified by:

getBlobOutputStream in interface IDbmsSupport

Throws:

SQLException

JdbcException

applyBlobParameter

public void applyBlobParameter(PreparedStatement stmt,
                               int column,
                               Object blobInsertHandle)
                        throws SQLException,
                               JdbcException

Specified by:

applyBlobParameter in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobInputStream

public InputStream getBlobInputStream(ResultSet rs,
                                      int column)
                               throws SQLException,
                                      JdbcException

Specified by:

getBlobInputStream in interface IDbmsSupport

Throws:

SQLException

JdbcException

getBlobInputStream

public InputStream getBlobInputStream(ResultSet rs,
                                      String column)
                               throws SQLException,
                                      JdbcException

Specified by:

getBlobInputStream in interface IDbmsSupport

Throws:

SQLException

JdbcException

getTextFieldType

public String getTextFieldType()

Specified by:

getTextFieldType in interface IDbmsSupport

prepareQueryTextForWorkQueueReading

public String prepareQueryTextForWorkQueueReading(int batchSize,
                                                  String selectQuery)
                                           throws JdbcException

Specified by:

prepareQueryTextForWorkQueueReading in interface IDbmsSupport

Throws:

JdbcException

prepareQueryTextForWorkQueueReading

public String prepareQueryTextForWorkQueueReading(int batchSize,
                                                  String selectQuery,
                                                  int wait)
                                           throws JdbcException

Specified by:

prepareQueryTextForWorkQueueReading in interface IDbmsSupport

Throws:

JdbcException

prepareQueryTextForWorkQueuePeeking

public String prepareQueryTextForWorkQueuePeeking(int batchSize,
                                                  String selectQuery)
                                           throws JdbcException

Specified by:

prepareQueryTextForWorkQueuePeeking in interface IDbmsSupport

Throws:

JdbcException

prepareQueryTextForWorkQueuePeeking

public String prepareQueryTextForWorkQueuePeeking(int batchSize,
                                                  String selectQuery,
                                                  int wait)
                                           throws JdbcException

Specified by:

prepareQueryTextForWorkQueuePeeking in interface IDbmsSupport

Throws:

JdbcException

getFirstRecordQuery

public String getFirstRecordQuery(String tableName)
                           throws JdbcException

Specified by:

getFirstRecordQuery in interface IDbmsSupport

Throws:

JdbcException

prepareQueryTextForNonLockingRead

public String prepareQueryTextForNonLockingRead(String selectQuery)
                                         throws JdbcException

Description copied from interface: IDbmsSupport

Modify the provided selectQuery in such a way that the resulting query will not be blocked by locks, and will avoid placing locks itself as much as possible. Will always be executed together with IDbmsSupport.prepareSessionForNonLockingRead(Connection). Preferably, the effective isolation level is READ_COMMITTED (commited rows of other transactions may be read), but if placing locks can be avoid by an isolation level similar to READ_UNCOMMITTED, that is allowed too. Should return the query unmodified if no special action is required. For an example, see MsSqlServerDbmsSupport.prepareQueryTextForNonLockingRead(String)

Specified by:

prepareQueryTextForNonLockingRead in interface IDbmsSupport

Throws:

JdbcException

prepareSessionForNonLockingRead

public JdbcSession prepareSessionForNonLockingRead(Connection conn)
                                            throws JdbcException

Description copied from interface: IDbmsSupport

Modify the connection in such a way that it when select queries, prepared by IDbmsSupport.prepareQueryTextForNonLockingRead(String) or by IDbmsSupport.prepareQueryTextForWorkQueuePeeking(int,String), are executed, they will not be blocked by locks, and will avoid placing locks itself as much as possible. Preferably isolation level is READ_COMMITTED (commited rows of other transactions may be read), but if placing locks can be avoid by an isolation level similar to READ_UNCOMMITTED, that is allowed too. After the query is executed, jdbcSession.close() will be called, to return the connection to its normal state (which is expected to be REPEATABLE_READ). Should return null if no preparation of the connection is required. For an example, see prepareSessionForNonLockingRead(Connection)

Specified by:

prepareSessionForNonLockingRead in interface IDbmsSupport

Throws:

JdbcException

provideIndexHintAfterFirstKeyword

public String provideIndexHintAfterFirstKeyword(String tableName,
                                                String indexName)

Specified by:

provideIndexHintAfterFirstKeyword in interface IDbmsSupport

provideFirstRowsHintAfterFirstKeyword

public String provideFirstRowsHintAfterFirstKeyword(int rowCount)

Specified by:

provideFirstRowsHintAfterFirstKeyword in interface IDbmsSupport

provideTrailingFirstRowsHint

public String provideTrailingFirstRowsHint(int rowCount)

Specified by:

provideTrailingFirstRowsHint in interface IDbmsSupport

getSchema

public String getSchema(Connection conn)
                 throws JdbcException

Specified by:

getSchema in interface IDbmsSupport

Throws:

JdbcException

getTableColumns

public ResultSet getTableColumns(Connection conn,
                                 String tableName)
                          throws JdbcException

Specified by:

getTableColumns in interface IDbmsSupport

Throws:

JdbcException

getTableColumns

public ResultSet getTableColumns(Connection conn,
                                 String schemaName,
                                 String tableName)
                          throws JdbcException

Specified by:

getTableColumns in interface IDbmsSupport

Throws:

JdbcException

getTableColumns

public ResultSet getTableColumns(Connection conn,
                                 String schemaName,
                                 String tableName,
                                 String columnNamePattern)
                          throws JdbcException

Specified by:

getTableColumns in interface IDbmsSupport

Throws:

JdbcException

isTablePresent

public boolean isTablePresent(Connection conn,
                              String tableName)
                       throws JdbcException

Specified by:

isTablePresent in interface IDbmsSupport

Throws:

JdbcException

isTablePresent

public boolean isTablePresent(Connection conn,
                              String schemaName,
                              String tableName)
                       throws JdbcException

Specified by:

isTablePresent in interface IDbmsSupport

Throws:

JdbcException

isColumnPresent

public boolean isColumnPresent(Connection conn,
                               String tableName,
                               String columnName)
                        throws JdbcException

Specified by:

isColumnPresent in interface IDbmsSupport

Throws:

JdbcException

isColumnPresent

public boolean isColumnPresent(Connection conn,
                               String schemaName,
                               String tableName,
                               String columnName)
                        throws JdbcException

Specified by:

isColumnPresent in interface IDbmsSupport

Throws:

JdbcException

hasIndexOnColumn

public boolean hasIndexOnColumn(Connection conn,
                                String schemaName,
                                String tableName,
                                String columnName)
                         throws JdbcException

Specified by:

hasIndexOnColumn in interface IDbmsSupport

Throws:

JdbcException

doHasIndexOnColumns

protected boolean doHasIndexOnColumns(Connection conn,
                                      String schemaOwner,
                                      String tableName,
                                      List<String> columns,
                                      String indexTableName,
                                      String indexColumnTableName,
                                      String tableOwnerColumnName,
                                      String tableNameColumnName,
                                      String indexNameColumnName,
                                      String columnNameColumnName,
                                      String columPositionColumnName)

doIsTablePresent

protected boolean doIsTablePresent(Connection conn,
                                   String tablesTable,
                                   String schemaColumn,
                                   String tableNameColumn,
                                   String schemaName,
                                   String tableName)
                            throws JdbcException

Alternative implementation of isTablePresent(), that can be used by descender classes if the implementation via metadata does not work for that driver.

Throws:

JdbcException

doIsColumnPresent

protected boolean doIsColumnPresent(Connection conn,
                                    String columnsTable,
                                    String schemaColumn,
                                    String tableNameColumn,
                                    String columnNameColumn,
                                    String schemaName,
                                    String tableName,
                                    String columnName)
                             throws JdbcException

Alternative implementation of isColumnPresent(), that can be used by descender classes if the implementation via metadata does not work for that driver.

Throws:

JdbcException

isIndexPresent

public boolean isIndexPresent(Connection conn,
                              String schemaOwner,
                              String tableName,
                              String indexName)

Specified by:

isIndexPresent in interface IDbmsSupport

isSequencePresent

public boolean isSequencePresent(Connection conn,
                                 String schemaOwner,
                                 String tableName,
                                 String sequenceName)

Specified by:

isSequencePresent in interface IDbmsSupport

hasIndexOnColumns

public boolean hasIndexOnColumns(Connection conn,
                                 String schemaOwner,
                                 String tableName,
                                 List<String> columns)
                          throws JdbcException

Specified by:

hasIndexOnColumns in interface IDbmsSupport

Throws:

JdbcException

getSchemaOwner

public String getSchemaOwner(Connection conn)
                      throws SQLException,
                             JdbcException

Specified by:

getSchemaOwner in interface IDbmsSupport

Throws:

SQLException

JdbcException

isConstraintViolation

public boolean isConstraintViolation(SQLException e)

Specified by:

isConstraintViolation in interface IDbmsSupport

getRowNumber

public String getRowNumber(String order,
                           String sort)

Specified by:

getRowNumber in interface IDbmsSupport

getRowNumberShortName

public String getRowNumberShortName()

Specified by:

getRowNumberShortName in interface IDbmsSupport

getLength

public String getLength(String column)

Specified by:

getLength in interface IDbmsSupport

getBooleanFieldType

public String getBooleanFieldType()

Specified by:

getBooleanFieldType in interface IDbmsSupport

getBooleanValue

public String getBooleanValue(boolean value)

Specified by:

getBooleanValue in interface IDbmsSupport

createTranslator

protected ISqlTranslator createTranslator(String source,
                                          String target)
                                   throws JdbcException

Throws:

JdbcException

convertQuery

public void convertQuery(QueryExecutionContext queryExecutionContext,
                         String sqlDialectFrom)
                  throws SQLException,
                         JdbcException

Specified by:

convertQuery in interface IDbmsSupport

Throws:

SQLException

JdbcException

warnConvertQuery

protected void warnConvertQuery(String sqlDialectFrom)

isQueryConversionRequired

protected boolean isQueryConversionRequired(String sqlDialectFrom)

splitQuery

protected List<String> splitQuery(String query)

getCleanUpIbisstoreQuery

public String getCleanUpIbisstoreQuery(String tableName,
                                       String keyField,
                                       String typeField,
                                       String expiryDateField,
                                       int maxRows)

Specified by:

getCleanUpIbisstoreQuery in interface IDbmsSupport