Package org.frankframework.dbms

Class MsSqlServerDbmsSupport

java.lang.Object

org.frankframework.dbms.GenericDbmsSupport

org.frankframework.dbms.MsSqlServerDbmsSupport

All Implemented Interfaces:

IDbmsSupport

public class MsSqlServerDbmsSupport
extends GenericDbmsSupport

Author:

Gerrit van Brakel

Field Summary

Fields inherited from class org.frankframework.dbms.GenericDbmsSupport

KEYWORD_SELECT, log, sqlTranslators

Constructor Summary

Constructors

Constructor	Description
MsSqlServerDbmsSupport()

Method Summary

Modifier and Type	Method	Description
String	getAutoIncrementKeyFieldType()
String	getBlobFieldType()
String	getBooleanValue(boolean value)
String	getDateAndOffset(String dateValue, int daysOffset)
String	getDatetimeLiteral(Date date)
Dbms	getDbms()
String	getLength(String column)
String	getSchema(Connection conn)
String	getSysDate()	SQL String returning current date and time of dbms.
String	getTimestampAsDate(String columnName)
String	getTimestampFieldType()
boolean	hasIndexOnColumns(Connection conn, String schemaOwner, String tableName, List<String> columns)
boolean	hasSkipLockedFunctionality()
boolean	isClobType(ResultSetMetaData rsmeta, int colNum)
boolean	isRowVersionTimestamp(ResultSetMetaData resultSetMetaData, int columnNumber)
boolean	isSequencePresent(Connection conn, String schemaOwner, String tableName, String sequenceName)
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, int wait)
String	prepareQueryTextForWorkQueueReading(int batchSize, String selectQuery, int wait)
String	provideTrailingFirstRowsHint(int rowCount)

Methods inherited from class org.frankframework.dbms.GenericDbmsSupport

applyBlobParameter, applyClobParameter, autoIncrementInsertValue, autoIncrementKeyMustBeInserted, autoIncrementUsesSequenceObject, convertQuery, createTranslator, doHasIndexOnColumns, doIsColumnPresent, doIsTablePresent, getBlobHandle, getBlobHandle, getBlobInputStream, getBlobInputStream, getBlobOutputStream, getBlobOutputStream, getBlobOutputStream, getClobHandle, getClobHandle, getClobReader, getClobReader, getClobWriter, getClobWriter, getDbmsName, getFormattedDate, getFromForTablelessSelect, getSqlTranslator, getTableColumns, getTableColumns, getTableColumns, getTextFieldType, hasIndexOnColumn, isBlobType, isColumnPresent, isColumnPresent, isConstraintViolation, isParameterTypeMatchRequired, isQueryConversionRequired, isTablePresent, isTablePresent, prepareQueryTextForWorkQueuePeeking, prepareQueryTextForWorkQueueReading, provideFirstRowsHintAfterFirstKeyword, provideIndexHintAfterFirstKeyword, splitQuery, updateBlob, updateBlob, updateClob, updateClob, warnConvertQuery

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.frankframework.dbms.IDbmsSupport

canFetchStatementParameterMetaData, getCursorSqlType, isStoredProcedureResultSetSupported

Constructor Details

MsSqlServerDbmsSupport

public MsSqlServerDbmsSupport()

Method Details

getDbms

public Dbms getDbms()

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

getSysDate

public String getSysDate()

Description copied from interface: IDbmsSupport

SQL String returning current date and time of dbms.

Specified by:

getSysDate in interface IDbmsSupport

Overrides:

getSysDate in class GenericDbmsSupport

getDateAndOffset

public String getDateAndOffset(String dateValue,
 int daysOffset)

Specified by:

getDateAndOffset in interface IDbmsSupport

Overrides:

getDateAndOffset in class GenericDbmsSupport

getAutoIncrementKeyFieldType

public String getAutoIncrementKeyFieldType()

Specified by:

getAutoIncrementKeyFieldType in interface IDbmsSupport

Overrides:

getAutoIncrementKeyFieldType in class GenericDbmsSupport

getTimestampFieldType

public String getTimestampFieldType()

Specified by:

getTimestampFieldType in interface IDbmsSupport

Overrides:

getTimestampFieldType in class GenericDbmsSupport

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

getBlobFieldType

public String getBlobFieldType()

Specified by:

getBlobFieldType in interface IDbmsSupport

Overrides:

getBlobFieldType in class GenericDbmsSupport

isClobType

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

Specified by:

isClobType in interface IDbmsSupport

Overrides:

isClobType in class GenericDbmsSupport

Throws:

SQLException

prepareQueryTextForWorkQueueReading

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

Specified by:

prepareQueryTextForWorkQueueReading in interface IDbmsSupport

Overrides:

prepareQueryTextForWorkQueueReading in class GenericDbmsSupport

Throws:

DbmsException

prepareQueryTextForWorkQueuePeeking

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

Specified by:

prepareQueryTextForWorkQueuePeeking in interface IDbmsSupport

Overrides:

prepareQueryTextForWorkQueuePeeking in class GenericDbmsSupport

Throws:

DbmsException

prepareQueryTextForNonLockingRead

public String prepareQueryTextForNonLockingRead(String selectQuery)
                                         throws DbmsException

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. Preferably, the effective isolation level is READ_COMMITTED (committed rows of other transactions may be read), but if placing locks can be avoided 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 prepareQueryTextForNonLockingRead(String)

Specified by:

prepareQueryTextForNonLockingRead in interface IDbmsSupport

Overrides:

prepareQueryTextForNonLockingRead in class GenericDbmsSupport

Throws:

DbmsException

provideTrailingFirstRowsHint

public String provideTrailingFirstRowsHint(int rowCount)

Specified by:

provideTrailingFirstRowsHint in interface IDbmsSupport

Overrides:

provideTrailingFirstRowsHint in class GenericDbmsSupport

getSchema

public String getSchema(Connection conn)
                 throws DbmsException

Specified by:

getSchema in interface IDbmsSupport

Overrides:

getSchema in class GenericDbmsSupport

Throws:

DbmsException

getLength

public String getLength(String column)

Specified by:

getLength in interface IDbmsSupport

Overrides:

getLength in class GenericDbmsSupport

isSequencePresent

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

Specified by:

isSequencePresent in interface IDbmsSupport

Overrides:

isSequencePresent in class GenericDbmsSupport

hasIndexOnColumns

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

Specified by:

hasIndexOnColumns in interface IDbmsSupport

Overrides:

hasIndexOnColumns in class GenericDbmsSupport

getBooleanValue

public String getBooleanValue(boolean value)

Specified by:

getBooleanValue in interface IDbmsSupport

Overrides:

getBooleanValue in class GenericDbmsSupport

isRowVersionTimestamp

public boolean isRowVersionTimestamp(ResultSetMetaData resultSetMetaData,
 int columnNumber)
                              throws SQLException

Parameters:

resultSetMetaData -

columnNumber -

Returns:

whether the columnNumber metadata is defined as a RowVersion/Timestamp (MSSQL - specific, see MsSqlServerDbmsSupport).

Throws:

SQLException