nl.nn.adapterframework.jdbc.dbms

Class PostgresqlDbmsSupport

java.lang.Object

nl.nn.adapterframework.jdbc.dbms.GenericDbmsSupport

nl.nn.adapterframework.jdbc.dbms.PostgresqlDbmsSupport

All Implemented Interfaces:

IDbmsSupport

public class PostgresqlDbmsSupport
extends GenericDbmsSupport

Support for PostgreSQL. Limitations: PostgreSQL blobs and clobs are handled via byte arrays that are kept in memory. The maximum size of blobs and clobs is therefor limited by memory size.

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
PostgresqlDbmsSupport()

Method Summary

Modifier and Type	Method and Description
int	alterAutoIncrement(Connection connection, String tableName, int startWith)
void	applyBlobParameter(PreparedStatement stmt, int column, Object blobHandle)
void	applyClobParameter(PreparedStatement stmt, int column, Object clobHandle)
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 blobHandle)
OutputStream	getBlobOutputStream(ResultSet rs, int column, Object blobHandle)
OutputStream	getBlobOutputStream(ResultSet rs, String column, Object blobHandle)
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	getInsertedAutoIncrementValueQuery(String sequenceName)
String	getSchema(Connection conn)
ResultSet	getTableColumns(Connection conn, String schemaName, String tableName, String columnNamePattern)
String	getTimestampAsDate(String columnName)
boolean	hasIndexOnColumn(Connection conn, String schemaOwner, String tableName, String columnName)
boolean	hasIndexOnColumns(Connection conn, String schemaOwner, String tableName, List<String> columns)
boolean	hasSkipLockedFunctionality()
boolean	isClobType(ResultSetMetaData rsmeta, int colNum)
boolean	isColumnPresent(Connection conn, String schemaName, String tableName, String columnName)
boolean	isParameterTypeMatchRequired()
boolean	isTablePresent(Connection conn, String schemaName, String tableName)
String	prepareQueryTextForWorkQueuePeeking(int batchSize, String selectQuery, int wait)
String	prepareQueryTextForWorkQueueReading(int batchSize, String selectQuery, int wait)
void	updateBlob(ResultSet rs, int column, Object blobHandle)
void	updateBlob(ResultSet rs, String column, Object blobHandle)
void	updateClob(ResultSet rs, int column, Object clobHandle)
void	updateClob(ResultSet rs, String column, Object clobHandle)

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

autoIncrementInsertValue, autoIncrementKeyMustBeInserted, autoIncrementUsesSequenceObject, convertQuery, createTranslator, doHasIndexOnColumns, doIsColumnPresent, doIsTablePresent, emptyBlobValue, emptyClobValue, getBlobOutputStream, getBooleanFieldType, getBooleanValue, getCleanUpIbisstoreQuery, getDbmsName, getFirstRecordQuery, getFromForTablelessSelect, getIbisStoreSummaryQuery, getLength, getNumericKeyFieldType, getRowNumber, getRowNumberShortName, getSchemaOwner, getSysDate, getTableColumns, getTableColumns, getTextFieldType, getTimestampFieldType, getUpdateBlobQuery, getUpdateClobQuery, isBlobType, isColumnPresent, isConstraintViolation, isIndexPresent, isQueryConversionRequired, isSequencePresent, isTablePresent, mustInsertEmptyBlobBeforeData, mustInsertEmptyClobBeforeData, prepareQueryTextForNonLockingRead, prepareQueryTextForWorkQueuePeeking, prepareQueryTextForWorkQueueReading, prepareSessionForNonLockingRead, provideFirstRowsHintAfterFirstKeyword, provideIndexHintAfterFirstKeyword, provideTrailingFirstRowsHint, splitQuery, warnConvertQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresqlDbmsSupport

public PostgresqlDbmsSupport()

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

isParameterTypeMatchRequired

public boolean isParameterTypeMatchRequired()

Specified by:

isParameterTypeMatchRequired in interface IDbmsSupport

Overrides:

isParameterTypeMatchRequired in class GenericDbmsSupport

hasSkipLockedFunctionality

public boolean hasSkipLockedFunctionality()

Specified by:

hasSkipLockedFunctionality in interface IDbmsSupport

Overrides:

hasSkipLockedFunctionality 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

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

isClobType

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

Specified by:

isClobType in interface IDbmsSupport

Overrides:

isClobType in class GenericDbmsSupport

Throws:

SQLException

getClobReader

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

Specified by:

getClobReader in interface IDbmsSupport

Overrides:

getClobReader in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobReader

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

Specified by:

getClobReader in interface IDbmsSupport

Overrides:

getClobReader in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobHandle

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

Specified by:

getClobHandle in interface IDbmsSupport

Overrides:

getClobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobHandle

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

Specified by:

getClobHandle in interface IDbmsSupport

Overrides:

getClobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobHandle

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

Specified by:

getClobHandle in interface IDbmsSupport

Overrides:

getClobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

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

Specified by:

getClobWriter in interface IDbmsSupport

Overrides:

getClobWriter in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

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

Specified by:

getClobWriter in interface IDbmsSupport

Overrides:

getClobWriter in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getClobWriter

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

Specified by:

getClobWriter in interface IDbmsSupport

Overrides:

getClobWriter in class GenericDbmsSupport

Throws:

SQLException

JdbcException

updateClob

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

Specified by:

updateClob in interface IDbmsSupport

Overrides:

updateClob in class GenericDbmsSupport

Throws:

SQLException

JdbcException

updateClob

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

Specified by:

updateClob in interface IDbmsSupport

Overrides:

updateClob in class GenericDbmsSupport

Throws:

SQLException

JdbcException

applyClobParameter

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

Specified by:

applyClobParameter in interface IDbmsSupport

Overrides:

applyClobParameter in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobFieldType

public String getBlobFieldType()

Specified by:

getBlobFieldType in interface IDbmsSupport

Overrides:

getBlobFieldType in class GenericDbmsSupport

getBlobInputStream

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

Specified by:

getBlobInputStream in interface IDbmsSupport

Overrides:

getBlobInputStream in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobInputStream

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

Specified by:

getBlobInputStream in interface IDbmsSupport

Overrides:

getBlobInputStream in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobHandle

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

Specified by:

getBlobHandle in interface IDbmsSupport

Overrides:

getBlobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobHandle

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

Specified by:

getBlobHandle in interface IDbmsSupport

Overrides:

getBlobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobHandle

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

Specified by:

getBlobHandle in interface IDbmsSupport

Overrides:

getBlobHandle in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

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

Specified by:

getBlobOutputStream in interface IDbmsSupport

Overrides:

getBlobOutputStream in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

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

Specified by:

getBlobOutputStream in interface IDbmsSupport

Overrides:

getBlobOutputStream in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getBlobOutputStream

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

Specified by:

getBlobOutputStream in interface IDbmsSupport

Overrides:

getBlobOutputStream in class GenericDbmsSupport

Throws:

SQLException

JdbcException

updateBlob

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

Specified by:

updateBlob in interface IDbmsSupport

Overrides:

updateBlob in class GenericDbmsSupport

Throws:

SQLException

JdbcException

updateBlob

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

Specified by:

updateBlob in interface IDbmsSupport

Overrides:

updateBlob in class GenericDbmsSupport

Throws:

SQLException

JdbcException

applyBlobParameter

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

Specified by:

applyBlobParameter in interface IDbmsSupport

Overrides:

applyBlobParameter in class GenericDbmsSupport

Throws:

SQLException

JdbcException

getSchema

public String getSchema(Connection conn)
                 throws JdbcException

Specified by:

getSchema in interface IDbmsSupport

Overrides:

getSchema in class GenericDbmsSupport

Throws:

JdbcException

getTableColumns

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

Specified by:

getTableColumns in interface IDbmsSupport

Overrides:

getTableColumns in class GenericDbmsSupport

Throws:

JdbcException

isTablePresent

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

Specified by:

isTablePresent in interface IDbmsSupport

Overrides:

isTablePresent in class GenericDbmsSupport

Throws:

JdbcException

isColumnPresent

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

Specified by:

isColumnPresent in interface IDbmsSupport

Overrides:

isColumnPresent in class GenericDbmsSupport

Throws:

JdbcException

hasIndexOnColumn

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

Specified by:

hasIndexOnColumn in interface IDbmsSupport

Overrides:

hasIndexOnColumn in class GenericDbmsSupport

Throws:

JdbcException

hasIndexOnColumns

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

Specified by:

hasIndexOnColumns in interface IDbmsSupport

Overrides:

hasIndexOnColumns in class GenericDbmsSupport

Throws:

JdbcException

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

alterAutoIncrement

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

Throws:

JdbcException

getInsertedAutoIncrementValueQuery

public String getInsertedAutoIncrementValueQuery(String sequenceName)

Specified by:

getInsertedAutoIncrementValueQuery in interface IDbmsSupport

Overrides:

getInsertedAutoIncrementValueQuery in class GenericDbmsSupport

getAutoIncrementKeyFieldType

public String getAutoIncrementKeyFieldType()

Specified by:

getAutoIncrementKeyFieldType in interface IDbmsSupport

Overrides:

getAutoIncrementKeyFieldType in class GenericDbmsSupport