Class PostgresqlDbmsSupport

java.lang.Object

org.frankframework.dbms.GenericDbmsSupport

org.frankframework.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 GenericDbmsSupport

KEYWORD_SELECT, log, sqlTranslators

Constructor Summary

Constructors

Constructor	Description
PostgresqlDbmsSupport()

Method Summary

Modifier and Type	Method	Description
int	alterAutoIncrement(Connection connection, String tableName, int startWith)
void	applyBlobParameter(@NonNull PreparedStatement stmt, int column, @NonNull Object blobHandle)
void	applyClobParameter(@NonNull PreparedStatement stmt, int column, @NonNull Object clobHandle)
String	getAutoIncrementKeyFieldType()
String	getBlobFieldType()
@NonNull Object	getBlobHandle(@NonNull PreparedStatement stmt, int column)
@NonNull Object	getBlobHandle(@NonNull ResultSet rs, int column)
@Nullable InputStream	getBlobInputStream(@NonNull ResultSet rs, int column)
@Nullable InputStream	getBlobInputStream(@NonNull ResultSet rs, String column)
@NonNull OutputStream	getBlobOutputStream(@NonNull PreparedStatement stmt, int column, @NonNull Object blobHandle)
@NonNull OutputStream	getBlobOutputStream(@NonNull ResultSet rs, int column, @NonNull Object blobHandle)
@NonNull Object	getClobHandle(@NonNull PreparedStatement stmt, int column)
@NonNull Object	getClobHandle(@NonNull ResultSet rs, int column)
@Nullable Reader	getClobReader(ResultSet rs, int column)
@Nullable Reader	getClobReader(ResultSet rs, String column)
@NonNull Writer	getClobWriter(@NonNull PreparedStatement stmt, int column, @NonNull Object clobHandle)
@NonNull Writer	getClobWriter(@NonNull ResultSet rs, int column, @NonNull Object clobHandle)
String	getDateAndOffset(String dateValue, int daysOffset)
String	getDatetimeLiteral(Date date)
Dbms	getDbms()
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	isStoredProcedureResultSetSupported()	DBMS Feature flag: is it possible to call a stored procedure that returns the results of a SELECT statement directly, without needing a REFCURSOR OUT parameter.
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(@NonNull ResultSet rs, int column, @NonNull Object blobHandle)
void	updateBlob(@NonNull ResultSet rs, @NonNull String column, @NonNull Object blobHandle)
void	updateClob(@NonNull ResultSet rs, int column, @NonNull Object clobHandle)
void	updateClob(@NonNull ResultSet rs, String column, @NonNull Object clobHandle)

Methods inherited from class GenericDbmsSupport

autoIncrementInsertValue, autoIncrementKeyMustBeInserted, autoIncrementUsesSequenceObject, convertQuery, createTranslator, doHasIndexOnColumns, doIsColumnPresent, doIsTablePresent, getBlobOutputStream, getFormattedDate, getFromForTablelessSelect, getSqlTranslator, getSysDate, getTableColumns, getTableColumns, getTimestampFieldType, isBlobType, isColumnPresent, isConstraintViolation, isQueryConversionRequired, isSequencePresent, isTablePresent, prepareQueryTextForNonLockingRead, prepareQueryTextForWorkQueuePeeking, prepareQueryTextForWorkQueueReading, provideFirstRowsHintAfterFirstKeyword, provideIndexHintAfterFirstKeyword, provideTrailingFirstRowsHint, splitQuery, warnConvertQuery

Methods inherited from class Object

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

Methods inherited from interface IDbmsSupport

canFetchStatementParameterMetaData, getBooleanValue, getCursorSqlType, getDbmsName, getLength, getTargetSqlDialect, getTextFieldType, isRowVersionTimestamp

Constructor Details

PostgresqlDbmsSupport

public PostgresqlDbmsSupport()

Method Details

getDbms

public Dbms getDbms()

Specified by:

getDbms in interface IDbmsSupport

Overrides:

getDbms in class GenericDbmsSupport

isParameterTypeMatchRequired

public boolean isParameterTypeMatchRequired()

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

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 @Nullable Reader getClobReader(ResultSet rs,
 int column)
                               throws SQLException

Specified by:

getClobReader in interface IDbmsSupport

Overrides:

getClobReader in class GenericDbmsSupport

Throws:

SQLException

getClobReader

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

Specified by:

getClobReader in interface IDbmsSupport

Overrides:

getClobReader in class GenericDbmsSupport

Throws:

SQLException

getClobHandle

public @NonNull Object getClobHandle(@NonNull ResultSet rs,
 int column)
                              throws SQLException,
DbmsException

Specified by:

getClobHandle in interface IDbmsSupport

Overrides:

getClobHandle in class GenericDbmsSupport

Throws:

SQLException

DbmsException

getClobHandle

public @NonNull Object getClobHandle(@NonNull PreparedStatement stmt,
 int column)
                              throws SQLException,
DbmsException

Specified by:

getClobHandle in interface IDbmsSupport

Overrides:

getClobHandle in class GenericDbmsSupport

Throws:

SQLException

DbmsException

getClobWriter

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

Specified by:

getClobWriter in interface IDbmsSupport

Overrides:

getClobWriter in class GenericDbmsSupport

Throws:

SQLException

getClobWriter

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

Specified by:

getClobWriter in interface IDbmsSupport

Overrides:

getClobWriter in class GenericDbmsSupport

Throws:

SQLException

updateClob

public void updateClob(@NonNull ResultSet rs,
 int column,
 @NonNull Object clobHandle)
                throws SQLException,
DbmsException

Specified by:

updateClob in interface IDbmsSupport

Overrides:

updateClob in class GenericDbmsSupport

Throws:

SQLException

DbmsException

updateClob

public void updateClob(@NonNull ResultSet rs,
 String column,
 @NonNull Object clobHandle)
                throws SQLException,
DbmsException

Specified by:

updateClob in interface IDbmsSupport

Overrides:

updateClob in class GenericDbmsSupport

Throws:

SQLException

DbmsException

applyClobParameter

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

Specified by:

applyClobParameter in interface IDbmsSupport

Overrides:

applyClobParameter in class GenericDbmsSupport

Throws:

SQLException

getBlobFieldType

public String getBlobFieldType()

Specified by:

getBlobFieldType in interface IDbmsSupport

Overrides:

getBlobFieldType in class GenericDbmsSupport

getBlobInputStream

public @Nullable InputStream getBlobInputStream(@NonNull ResultSet rs,
 int column)
                                         throws SQLException

Specified by:

getBlobInputStream in interface IDbmsSupport

Overrides:

getBlobInputStream in class GenericDbmsSupport

Throws:

SQLException

getBlobInputStream

public @Nullable InputStream getBlobInputStream(@NonNull ResultSet rs,
 String column)
                                         throws SQLException

Specified by:

getBlobInputStream in interface IDbmsSupport

Overrides:

getBlobInputStream in class GenericDbmsSupport

Throws:

SQLException

getBlobHandle

public @NonNull Object getBlobHandle(@NonNull ResultSet rs,
 int column)
                              throws SQLException,
DbmsException

Specified by:

getBlobHandle in interface IDbmsSupport

Overrides:

getBlobHandle in class GenericDbmsSupport

Throws:

SQLException

DbmsException

getBlobHandle

public @NonNull Object getBlobHandle(@NonNull PreparedStatement stmt,
 int column)
                              throws SQLException,
DbmsException

Specified by:

getBlobHandle in interface IDbmsSupport

Overrides:

getBlobHandle in class GenericDbmsSupport

Throws:

SQLException

DbmsException

getBlobOutputStream

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

Specified by:

getBlobOutputStream in interface IDbmsSupport

Overrides:

getBlobOutputStream in class GenericDbmsSupport

Throws:

SQLException

getBlobOutputStream

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

Specified by:

getBlobOutputStream in interface IDbmsSupport

Overrides:

getBlobOutputStream in class GenericDbmsSupport

Throws:

SQLException

updateBlob

public void updateBlob(@NonNull ResultSet rs,
 int column,
 @NonNull Object blobHandle)
                throws SQLException,
DbmsException

Specified by:

updateBlob in interface IDbmsSupport

Overrides:

updateBlob in class GenericDbmsSupport

Throws:

SQLException

DbmsException

updateBlob

public void updateBlob(@NonNull ResultSet rs,
 @NonNull String column,
 @NonNull Object blobHandle)
                throws SQLException,
DbmsException

Specified by:

updateBlob in interface IDbmsSupport

Overrides:

updateBlob in class GenericDbmsSupport

Throws:

SQLException

DbmsException

applyBlobParameter

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

Specified by:

applyBlobParameter in interface IDbmsSupport

Overrides:

applyBlobParameter in class GenericDbmsSupport

Throws:

SQLException

getSchema

public String getSchema(Connection conn)
                 throws DbmsException

Specified by:

getSchema in interface IDbmsSupport

Overrides:

getSchema in class GenericDbmsSupport

Throws:

DbmsException

getTableColumns

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

Specified by:

getTableColumns in interface IDbmsSupport

Overrides:

getTableColumns in class GenericDbmsSupport

Throws:

DbmsException

isTablePresent

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

Specified by:

isTablePresent in interface IDbmsSupport

Overrides:

isTablePresent in class GenericDbmsSupport

Throws:

DbmsException

isColumnPresent

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

Specified by:

isColumnPresent in interface IDbmsSupport

Overrides:

isColumnPresent in class GenericDbmsSupport

Throws:

DbmsException

hasIndexOnColumn

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

Specified by:

hasIndexOnColumn in interface IDbmsSupport

Overrides:

hasIndexOnColumn in class GenericDbmsSupport

Throws:

DbmsException

hasIndexOnColumns

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

Specified by:

hasIndexOnColumns in interface IDbmsSupport

Overrides:

hasIndexOnColumns in class GenericDbmsSupport

Throws:

DbmsException

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

alterAutoIncrement

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

Throws:

DbmsException

getAutoIncrementKeyFieldType

public String getAutoIncrementKeyFieldType()

Specified by:

getAutoIncrementKeyFieldType in interface IDbmsSupport

Overrides:

getAutoIncrementKeyFieldType in class GenericDbmsSupport

isStoredProcedureResultSetSupported

public boolean isStoredProcedureResultSetSupported()

Description copied from interface: IDbmsSupport

DBMS Feature flag: is it possible to call a stored procedure that returns the results of a SELECT statement directly, without needing a REFCURSOR OUT parameter.

Returns:

true for database that can directly return SELECT results. Not supported for PostgreSQL and Oracle.