nl.nn.adapterframework.jdbc.dbms

Class MySqlDbmsSupport

java.lang.Object

nl.nn.adapterframework.jdbc.dbms.GenericDbmsSupport

nl.nn.adapterframework.jdbc.dbms.MySqlDbmsSupport

All Implemented Interfaces:

IDbmsSupport

Direct Known Subclasses:

MariaDbDbmsSupport

public class MySqlDbmsSupport
extends GenericDbmsSupport

Support for MySql/MariaDB.

Field Summary

Fields inherited from class nl.nn.adapterframework.jdbc.dbms.GenericDbmsSupport

KEYWORD_SELECT, log, sqlTranslators, TYPE_BLOB, TYPE_CLOB, TYPE_FUNCTION

Constructor Summary

Constructors

Constructor and Description
MySqlDbmsSupport()

Method Summary

Modifier and Type	Method and Description
int	alterAutoIncrement(Connection connection, String tableName, int startWith)
String	getAutoIncrementKeyFieldType()
String	getBlobFieldType()
String	getCleanUpIbisstoreQuery(String tableName, String keyField, String typeField, String expiryDateField, int maxRows)
String	getClobFieldType()
String	getDateAndOffset(String dateValue, int daysOffset)
String	getDatetimeLiteral(Date date)
Dbms	getDbms() Numeric value defining database type, defined in DbmsSupportFactory.
String	getInsertedAutoIncrementValueQuery(String sequenceName)
String	getSchema(Connection conn)
String	getTimestampAsDate(String columnName)
boolean	hasIndexOnColumns(Connection conn, String schemaOwner, String tableName, List<String> columns)
boolean	hasSkipLockedFunctionality()
String	prepareQueryTextForWorkQueuePeeking(int batchSize, String selectQuery, int wait)
String	prepareQueryTextForWorkQueueReading(int batchSize, String selectQuery, int wait)

Methods inherited from class nl.nn.adapterframework.jdbc.dbms.GenericDbmsSupport

applyBlobParameter, applyClobParameter, autoIncrementInsertValue, autoIncrementKeyMustBeInserted, autoIncrementUsesSequenceObject, convertQuery, createTranslator, doHasIndexOnColumns, doIsColumnPresent, doIsTablePresent, emptyBlobValue, emptyClobValue, getBlobHandle, getBlobHandle, getBlobHandle, getBlobInputStream, getBlobInputStream, getBlobOutputStream, getBlobOutputStream, getBlobOutputStream, getBlobOutputStream, getBooleanFieldType, getBooleanValue, getClobHandle, getClobHandle, getClobHandle, getClobReader, getClobReader, getClobWriter, getClobWriter, getClobWriter, getDbmsName, getFirstRecordQuery, getFromForTablelessSelect, getIbisStoreSummaryQuery, getLength, getNumericKeyFieldType, getRowNumber, getRowNumberShortName, getSchemaOwner, getSysDate, getTableColumns, getTableColumns, getTableColumns, getTextFieldType, getTimestampFieldType, getUpdateBlobQuery, getUpdateClobQuery, hasIndexOnColumn, isBlobType, isClobType, isColumnPresent, isColumnPresent, isConstraintViolation, isIndexPresent, isParameterTypeMatchRequired, isQueryConversionRequired, isSequencePresent, isTablePresent, isTablePresent, mustInsertEmptyBlobBeforeData, mustInsertEmptyClobBeforeData, prepareQueryTextForNonLockingRead, prepareQueryTextForWorkQueuePeeking, prepareQueryTextForWorkQueueReading, prepareSessionForNonLockingRead, provideFirstRowsHintAfterFirstKeyword, provideIndexHintAfterFirstKeyword, provideTrailingFirstRowsHint, splitQuery, updateBlob, updateBlob, updateClob, updateClob, warnConvertQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlDbmsSupport

public MySqlDbmsSupport()

Method Detail

getDbms

public Dbms getDbms()

Description copied from interface: IDbmsSupport

Numeric value defining database type, defined in DbmsSupportFactory.

Specified by:

getDbms in interface IDbmsSupport

Overrides:

getDbms in class GenericDbmsSupport

hasSkipLockedFunctionality

public boolean hasSkipLockedFunctionality()

Specified by:

hasSkipLockedFunctionality in interface IDbmsSupport

Overrides:

hasSkipLockedFunctionality in class GenericDbmsSupport

getSchema

public String getSchema(Connection conn)
                 throws JdbcException

Specified by:

getSchema in interface IDbmsSupport

Overrides:

getSchema in class GenericDbmsSupport

Throws:

JdbcException

getDatetimeLiteral

public String getDatetimeLiteral(Date date)

Specified by:

getDatetimeLiteral in interface IDbmsSupport

Overrides:

getDatetimeLiteral in class GenericDbmsSupport

getTimestampAsDate

public String getTimestampAsDate(String columnName)

Specified by:

getTimestampAsDate in interface IDbmsSupport

Overrides:

getTimestampAsDate in class GenericDbmsSupport

getDateAndOffset

public String getDateAndOffset(String dateValue,
                               int daysOffset)

Specified by:

getDateAndOffset in interface IDbmsSupport

Overrides:

getDateAndOffset in class GenericDbmsSupport

getClobFieldType

public String getClobFieldType()

Specified by:

getClobFieldType in interface IDbmsSupport

Overrides:

getClobFieldType in class GenericDbmsSupport

getBlobFieldType

public String getBlobFieldType()

Specified by:

getBlobFieldType in interface IDbmsSupport

Overrides:

getBlobFieldType in class GenericDbmsSupport

prepareQueryTextForWorkQueueReading

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

Specified by:

prepareQueryTextForWorkQueueReading in interface IDbmsSupport

Overrides:

prepareQueryTextForWorkQueueReading in class GenericDbmsSupport

Throws:

JdbcException

prepareQueryTextForWorkQueuePeeking

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

Specified by:

prepareQueryTextForWorkQueuePeeking in interface IDbmsSupport

Overrides:

prepareQueryTextForWorkQueuePeeking in class GenericDbmsSupport

Throws:

JdbcException

hasIndexOnColumns

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

Specified by:

hasIndexOnColumns in interface IDbmsSupport

Overrides:

hasIndexOnColumns in class GenericDbmsSupport

alterAutoIncrement

public int alterAutoIncrement(Connection connection,
                              String tableName,
                              int startWith)
                       throws JdbcException

Throws:

JdbcException

getAutoIncrementKeyFieldType

public String getAutoIncrementKeyFieldType()

Specified by:

getAutoIncrementKeyFieldType in interface IDbmsSupport

Overrides:

getAutoIncrementKeyFieldType in class GenericDbmsSupport

getInsertedAutoIncrementValueQuery

public String getInsertedAutoIncrementValueQuery(String sequenceName)

Specified by:

getInsertedAutoIncrementValueQuery in interface IDbmsSupport

Overrides:

getInsertedAutoIncrementValueQuery in class GenericDbmsSupport

getCleanUpIbisstoreQuery

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

Specified by:

getCleanUpIbisstoreQuery in interface IDbmsSupport

Overrides:

getCleanUpIbisstoreQuery in class GenericDbmsSupport