public class PostgresDictionary extends DBDictionary
Modifier and Type | Class and Description |
---|---|
protected static class |
PostgresDictionary.PostgresConnection
Connection wrapper to work around the postgres empty result set bug.
|
protected static class |
PostgresDictionary.PostgresPreparedStatement
Statement wrapper to work around the postgres empty result set bug.
|
DBDictionary.DateMillisecondBehaviors, DBDictionary.SerializedData
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
_timestampTypes |
String |
allSequencesFromOneSchemaSQL
SQL statement to load schema,name pairs from a named schema.
|
String |
allSequencesSQL
SQL statement to load all sequence schema,name pairs from all schemas.
|
String |
isOwnedSequenceSQL
Statement used to determine whether a sequence is owned.
|
String |
namedSequenceFromOneSchemaSQL
SQL statement to load a sequence's schema,name pair from one schema.
|
String |
namedSequencesFromAllSchemasSQL
SQL statement to load schema,name pairs for all sequences with a
certain name from all schemas.
|
boolean |
supportsSetFetchSize
Some Postgres drivers do not support the
Statement.setFetchSize(int)
method. |
_procs, _proxyManager, allowQueryTimeoutOnFindUpdate, allowsAliasInBulkClause, arrayTypeName, autoAssignClause, autoAssignTypeName, batchLimit, bigintTypeName, binaryTypeName, bitLengthFunction, bitTypeName, blobBufferSize, blobTypeName, booleanRepresentation, booleanTypeName, castFunction, catalogSeparator, CENTI, characterColumnSize, charTypeName, clobBufferSize, clobTypeName, closePoolSQL, concatenateDelimiter, concatenateFunction, conf, connected, CONS_NAME_AFTER, CONS_NAME_BEFORE, CONS_NAME_MID, constraintNameMode, createPrimaryKeys, crossJoinClause, currentDateFunction, currentTimeFunction, currentTimestampFunction, databaseProductName, databaseProductVersion, datePrecision, dateTypeName, DECI, decimalTypeName, defaultSchemaName, delimitedCase, disableAlterSeqenceIncrementBy, disableSchemaFactoryColumnTypeErrors, distinctCountColumnSeparator, distinctTypeName, doubleTypeName, driverVendor, dropTableSQL, fixedSizeTypeNames, fixedSizeTypeNameSet, floatTypeName, forUpdateClause, fullResultCollectionInOrderByRelation, getStringVal, inClauseLimit, initializationSQL, innerJoinClause, integerTypeName, invalidColumnWordSet, isJDBC3, isJDBC4, javaObjectTypeName, joinSyntax, lastGeneratedKeyQuery, leadingDelimiter, log, longVarbinaryTypeName, longVarcharTypeName, maxAutoAssignNameLength, maxColumnNameLength, maxConstraintNameLength, maxEmbeddedBlobSize, maxEmbeddedClobSize, maxIndexesPerTable, maxIndexNameLength, maxTableNameLength, MICRO, MILLI, NAME_ANY, NAME_SEQUENCE, NAME_TABLE, nameConcatenator, NANO, nativeSequenceType, nextSequenceQuery, NO_BATCH, nullTypeName, numericTypeName, otherTypeName, outerJoinClause, platform, RANGE_POST_DISTINCT, RANGE_POST_LOCK, RANGE_POST_SELECT, RANGE_PRE_DISTINCT, rangePosition, realTypeName, refTypeName, reportsSuccessNoInfoOnBatchUpdates, requiresAliasForSubselect, requiresAutoCommitForMetaData, requiresCastForComparisons, requiresCastForMathFunctions, requiresConditionForCrossJoin, requiresSearchStringEscapeForLike, requiresTargetForDelete, reservedWords, reservedWordSet, roundTimeToMillisec, SCHEMA_CASE_LOWER, SCHEMA_CASE_PRESERVE, SCHEMA_CASE_UPPER, schemaCase, searchStringEscape, SEC, selectWords, selectWordSet, sequenceNameSQL, sequenceSchemaSQL, sequenceSQL, setStringRightTruncationOn, simulateLocking, smallintTypeName, sqlStateCodes, storageLimitationsFatal, storeCharsAsNumbers, storeLargeNumbersAsStrings, stringLengthFunction, structTypeName, substringFunctionName, supportsAlterTableWithAddColumn, supportsAlterTableWithDropColumn, supportsAutoAssign, supportsCascadeDeleteAction, supportsCascadeUpdateAction, supportsCaseConversionForLob, supportsComments, supportsCorrelatedSubselect, supportsDefaultDeleteAction, supportsDefaultUpdateAction, supportsDeferredConstraints, supportsDelimitedIdentifiers, supportsForeignKeys, supportsForeignKeysComposite, supportsGeneralCaseExpression, supportsGetGeneratedKeys, supportsHaving, supportsLockingWithDistinctClause, supportsLockingWithInnerJoin, supportsLockingWithMultipleTables, supportsLockingWithOrderClause, supportsLockingWithOuterJoin, supportsLockingWithSelectRange, supportsModOperator, supportsMultipleNontransactionalResultSets, supportsNullDeleteAction, supportsNullTableForGetColumns, supportsNullTableForGetImportedKeys, supportsNullTableForGetIndexInfo, supportsNullTableForGetPrimaryKeys, supportsNullUniqueColumn, supportsNullUpdateAction, supportsParameterInSelect, supportsQueryTimeout, supportsRestrictDeleteAction, supportsRestrictUpdateAction, supportsSchemaForGetColumns, supportsSchemaForGetTables, supportsSelectEndIndex, supportsSelectForUpdate, supportsSelectFromFinalTable, supportsSelectStartIndex, supportsSimpleCaseExpression, supportsSubselect, supportsUniqueConstraints, supportsXMLColumn, systemSchemas, systemSchemaSet, systemTables, systemTableSet, tableForUpdateClause, tableLengthIncludesSchema, tableTypes, timestampTypeName, timeTypeName, tinyintTypeName, toLowerCaseFunction, toUpperCaseFunction, trailingDelimiter, trimBothFunction, trimLeadingFunction, trimSchemaName, trimStringColumns, trimTrailingFunction, typeModifierSet, UNLIMITED, useGetBestRowIdentifierForPrimaryKeys, useGetBytesForBlobs, useGetObjectForBlobs, useGetStringForClobs, useJDBC4SetBinaryStream, useNativeSequenceCache, useSchemaName, useSetBytesForBlobs, useSetStringForClobs, useWildCardForCount, validationSQL, varbinaryTypeName, varcharTypeName, VENDOR_DATADIRECT, VENDOR_OTHER, xmlTypeEncoding, xmlTypeName
SYNTAX_DATABASE, SYNTAX_SQL92, SYNTAX_TRADITIONAL
Constructor and Description |
---|
PostgresDictionary() |
Modifier and Type | Method and Description |
---|---|
protected void |
appendSelectRange(SQLBuffer buf,
long start,
long end,
boolean subselect)
If this dictionary can select ranges,
use this method to append the range SQL.
|
void |
appendXmlComparison(SQLBuffer buf,
String op,
FilterValue lhs,
FilterValue rhs,
boolean lhsxml,
boolean rhsxml)
Append XML comparison.
|
void |
connectedConfiguration(Connection conn)
Determine XML column support and backslash handling.
|
Connection |
decorate(Connection conn)
Decorate the given connection if needed.
|
void |
deleteStream(JDBCStore store,
Select sel) |
byte |
getByte(ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
Date |
getDate(ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
protected Connection |
getDbcpDelegate(Connection conn)
Get the delegated connection from the given DBCP connection.
|
int |
getInt(ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
protected org.postgresql.largeobject.LargeObjectManager |
getLargeObjectManager(DelegatingConnection conn)
Get the native PostgreSQL Large Object Manager used for LOB handling.
|
InputStream |
getLOBStream(JDBCStore store,
ResultSet rs,
int column) |
long |
getLong(ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
Object |
getObject(ResultSet rs,
int column,
Map map)
Override the getOjbect() method to handle the case where the latest
Postgres JDBC driver returns a org.postgresql.util.PGobject instead of a
java.sql.Timestamp
|
protected org.postgresql.PGConnection |
getPGConnection(DelegatingConnection conn)
Get the native PostgreSQL connection from the given connection.
|
String |
getPlaceholderValueString(Column col)
Return a SQL string to act as a placeholder for the given column.
|
protected String |
getSequencesSQL(DBIdentifier schemaName,
DBIdentifier sequenceName) |
protected String |
getSequencesSQL(String schemaName,
String sequenceName)
Return the SQL needed to select the list of sequences.
|
short |
getShort(ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
void |
indexOf(SQLBuffer buf,
FilterValue str,
FilterValue find,
FilterValue start)
Invoke this database's indexOf function.
|
void |
insertBlobForStreamingLoad(Row row,
Column col,
JDBCStore store,
Object ob,
Select sel) |
boolean |
isOwnedSequence(DBIdentifier name,
DBIdentifier schema,
Connection conn)
Uses the native Postgres function pg_get_serial_sequence to determine whether
a sequence is owned by the database.
|
boolean |
isSystemIndex(DBIdentifier name,
Table table)
This method is used to filter system indexes from database metadata.
|
boolean |
isSystemIndex(String name,
Table table)
This method is used to filter system indexes from database metadata.
|
boolean |
isSystemSequence(DBIdentifier name,
DBIdentifier schema,
boolean targetSchema)
This method is used to filter system sequences from database metadata.
|
boolean |
isSystemSequence(DBIdentifier name,
DBIdentifier schema,
boolean targetSchema,
Connection conn)
This method is used to filter system sequences from database metadata.
|
boolean |
isSystemSequence(String name,
String schema,
boolean targetSchema)
This method is used to filter system sequences from database metadata.
|
boolean |
isSystemTable(DBIdentifier name,
DBIdentifier schema,
boolean targetSchema)
This method is used to filter system tables from database metadata.
|
boolean |
isSystemTable(String name,
String schema,
boolean targetSchema)
This method is used to filter system tables from database metadata.
|
void |
setClobString(PreparedStatement stmnt,
int idx,
String val,
Column col)
If column is an XML column, PostgreSQL requires that its value is set
by using
PreparedStatement.setObject(int, Object, int)
with Types.OTHER as the third argument. |
void |
setNull(PreparedStatement stmnt,
int idx,
int colType,
Column col)
Handle XML and bytea/oid columns in a PostgreSQL way.
|
protected boolean |
supportsDeferredUniqueConstraints()
Whether or not this dictionary supports deferred unique constraints.
|
void |
updateBlob(Select sel,
JDBCStore store,
InputStream is) |
addCastAsType, addErrorCode, appendCast, appendLength, appendNumericCast, appendSelect, appendSize, appendUpdates, applyRange, assertSupport, calculateValue, canOuterJoin, closeDataSource, combineForeignKey, comment, comparison, configureNamingRules, convertSchemaCase, convertSchemaCase, copy, copy, createIndexIfNecessary, createIndexIfNecessary, delimitAll, endConfiguration, executeQuery, fromDBName, getAddColumnSQL, getAddForeignKeySQL, getAddPrimaryKeySQL, getAlterSequenceSQL, getArray, getAsciiStream, getBatchFetchSize, getBatchLimit, getBatchUpdateCount, getBigDecimal, getBigInteger, getBinaryStream, getBlob, getBlobObject, getBoolean, getBooleanRepresentation, getBytes, getCalendar, getCastFunction, getCastFunction, getCatalogNameForMetadata, getCatalogNameForMetadata, getChar, getCharacterStream, getClob, getClobString, getColumnDBName, getColumnIdentifier, getColumnNameForMetadata, getColumnNameForMetadata, getColumns, getColumns, getConversionKey, getCreateIndexSQL, getCreateSequenceSQL, getCreateTableSQL, getCreateTableSQL, getDate, getDeclareColumnSQL, getDefaultIdentifierRule, getDefaultSchemaName, getDeleteTableContentsSQL, getDeleteTargets, getDelimitedCase, getDelimitIdentifiers, getDouble, getDropColumnSQL, getDropForeignKeySQL, getDropIndexSQL, getDropPrimaryKeySQL, getDropSequenceSQL, getDropTableSQL, getFloat, getForeignKeyConstraintSQL, getForUpdateClause, getFrom, getFromSelect, getFullIdentifier, getFullName, getFullName, getFullName, getGeneratedKey, getGeneratedKeySequenceName, getGenKeySeqName, getIdentifierConcatenator, getIdentifierDelimiter, getIdentifierRule, getIdentifierRules, getIdentityColumnName, getImportedKeys, getImportedKeys, getImportedKeys, getImportedKeys, getIndexInfo, getIndexInfo, getInvalidColumnWordSet, getIsNotNullSQL, getIsNullSQL, getJDBCType, getJDBCType, getJDBCType, getKey, getLeadingDelimiter, getLocale, getLog, getMajorVersion, getMarkerForInsertUpdate, getMillisecondBehavior, getMinorVersion, getNamingUtil, getNumber, getPreferredType, getPrimaryKeyConstraintSQL, getPrimaryKeys, getPrimaryKeys, getPrimaryKeysFromBestRowIdentifier, getPrimaryKeysFromBestRowIdentifier, getPrimaryKeysFromGetPrimaryKeys, getPrimaryKeysFromGetPrimaryKeys, getRef, getSchemaCase, getSchemaNameForMetadata, getSchemaNameForMetadata, getSelectOperation, getSelects, getSelectTableAliases, getSequence, getSequences, getSequences, getStoredProcedure, getString, getSupportsDelimitedIdentifiers, getSupportsXMLColumn, getTableNameForMetadata, getTableNameForMetadata, getTables, getTables, getTime, getTimestamp, getTrailingDelimiter, getTrimSchemaName, getTypeName, getTypeName, getUniqueConstraintSQL, getValidColumnName, getValidColumnName, getValidColumnName, getValidColumnName, getValidForeignKeyName, getValidForeignKeyName, getValidIndexName, getValidIndexName, getValidPrimaryKeyName, getValidSequenceName, getValidSequenceName, getValidTableName, getValidTableName, getValidUniqueName, getValidUniqueName, getVersionColumn, getVersionColumn, getWhere, getXMLTypeEncoding, handleWarning, insertClobForStreamingLoad, insertSize, isFatalException, isImplicitJoin, isSelect, isUsingLimit, isUsingOffset, isUsingOrderBy, isUsingRange, makeNameValid, makeNameValid, makeNameValid, makeNameValid, matchErrorState, mathFunction, needsToCreateIndex, needsToCreateIndex, newColumn, newForeignKey, newIndex, newPrimaryKey, newSequence, newStoreException, newTable, prepareStatement, putBytes, putChars, putString, refSchemaComponents, serialize, setArray, setAsciiStream, setBatchLimit, setBigDecimal, setBigInteger, setBinaryStream, setBlob, setBlobObject, setBoolean, setBooleanRepresentation, setByte, setBytes, setCalendar, setChar, setCharacterStream, setClob, setConfiguration, setDate, setDate, setDateMillisecondBehavior, setDefaultSchemaName, setDelimitedCase, setDelimitIdentifiers, setDouble, setFloat, setInt, setJoinSyntax, setLeadingDelimiter, setLocale, setLong, setMajorVersion, setMinorVersion, setNumber, setObject, setQueryTimeout, setRef, setShort, setStatementQueryTimeout, setString, setSupportsDelimitedIdentifiers, setSupportsXMLColumn, setTime, setTimeouts, setTimeouts, setTimestamp, setTrailingDelimiter, setTrimSchemaName, setTyped, setUnknown, setUnknown, setXMLTypeEncoding, shorten, startConfiguration, storageWarning, substring, supportsDeferredForeignKeyConstraints, supportsDeleteAction, supportsIsolationForUpdate, supportsLocking, supportsRandomAccessResultSet, supportsUpdateAction, toBulkOperation, toDBName, toDBName, toDelete, toNativeJoin, toOperation, toOperation, toSelect, toSelect, toSelect, toSelect, toSelect, toSelectCount, toSQL92Join, toTraditionalJoin, toUpdate, updateClob, validateBatchProcess, validateDBSpecificBatchProcess, versionEqualOrEarlierThan, versionEqualOrLaterThan, versionLaterThan
public String allSequencesSQL
public String namedSequencesFromAllSchemasSQL
public String allSequencesFromOneSchemaSQL
public String namedSequenceFromOneSchemaSQL
public boolean supportsSetFetchSize
Statement.setFetchSize(int)
method.public String isOwnedSequenceSQL
public Date getDate(ResultSet rs, int column) throws SQLException
DBDictionary
Timestamp
by default.getDate
in class DBDictionary
SQLException
public byte getByte(ResultSet rs, int column) throws SQLException
DBDictionary
getByte
in class DBDictionary
SQLException
public short getShort(ResultSet rs, int column) throws SQLException
DBDictionary
getShort
in class DBDictionary
SQLException
public int getInt(ResultSet rs, int column) throws SQLException
DBDictionary
getInt
in class DBDictionary
SQLException
public long getLong(ResultSet rs, int column) throws SQLException
DBDictionary
getLong
in class DBDictionary
SQLException
public void setNull(PreparedStatement stmnt, int idx, int colType, Column col) throws SQLException
setNull
in class DBDictionary
SQLException
protected void appendSelectRange(SQLBuffer buf, long start, long end, boolean subselect)
DBDictionary
appendSelectRange
in class DBDictionary
public void indexOf(SQLBuffer buf, FilterValue str, FilterValue find, FilterValue start)
DBDictionary
indexOf
in class DBDictionary
buf
- the SQL buffer to write the indexOf invocation tostr
- a query value representing the target stringfind
- a query value representing the search stringstart
- a query value representing the start index, or null
to start at the beginningprotected boolean supportsDeferredUniqueConstraints()
DBDictionary
DBDictionary.supportsUniqueConstraints
.supportsDeferredUniqueConstraints
in class DBDictionary
protected String getSequencesSQL(String schemaName, String sequenceName)
DBDictionary
getSequencesSQL
in class DBDictionary
protected String getSequencesSQL(DBIdentifier schemaName, DBIdentifier sequenceName)
getSequencesSQL
in class DBDictionary
public boolean isSystemSequence(String name, String schema, boolean targetSchema)
DBDictionary
isSystemSequence
in class DBDictionary
name
- the table nameschema
- the table schema; may be nulltargetSchema
- if true, then the given schema was listed by
the user as one of his schemaspublic boolean isSystemSequence(DBIdentifier name, DBIdentifier schema, boolean targetSchema)
DBDictionary
isSystemSequence
in class DBDictionary
name
- the table nameschema
- the table schema; may be nulltargetSchema
- if true, then the given schema was listed by
the user as one of his schemaspublic boolean isSystemSequence(DBIdentifier name, DBIdentifier schema, boolean targetSchema, Connection conn)
DBDictionary
isSystemSequence
in class DBDictionary
name
- the table nameschema
- the table schema; may be nulltargetSchema
- if true, then the given schema was listed by
the user as one of his schemasconn
- connection to the databasepublic boolean isOwnedSequence(DBIdentifier name, DBIdentifier schema, Connection conn)
public boolean isSystemTable(String name, String schema, boolean targetSchema)
DBDictionary
isSystemTable
in class DBDictionary
name
- the table nameschema
- the table schema; may be nulltargetSchema
- if true, then the given schema was listed by
the user as one of his schemaspublic boolean isSystemTable(DBIdentifier name, DBIdentifier schema, boolean targetSchema)
DBDictionary
isSystemTable
in class DBDictionary
name
- the table nameschema
- the table schema; may be nulltargetSchema
- if true, then the given schema was listed by
the user as one of his schemaspublic boolean isSystemIndex(String name, Table table)
DBDictionary
isSystemIndex
in class DBDictionary
name
- the index nametable
- the index tablepublic boolean isSystemIndex(DBIdentifier name, Table table)
DBDictionary
isSystemIndex
in class DBDictionary
name
- the index nametable
- the index tablepublic Connection decorate(Connection conn) throws SQLException
DBDictionary
DBDictionary.initializationSQL
that has been set for the dictionary but
does not decorate the connection.decorate
in interface ConnectionDecorator
decorate
in class DBDictionary
SQLException
public InputStream getLOBStream(JDBCStore store, ResultSet rs, int column) throws SQLException
getLOBStream
in class DBDictionary
SQLException
public void insertBlobForStreamingLoad(Row row, Column col, JDBCStore store, Object ob, Select sel) throws SQLException
insertBlobForStreamingLoad
in class DBDictionary
SQLException
public void updateBlob(Select sel, JDBCStore store, InputStream is) throws SQLException
updateBlob
in class DBDictionary
SQLException
public void deleteStream(JDBCStore store, Select sel) throws SQLException
deleteStream
in class DBDictionary
SQLException
public void connectedConfiguration(Connection conn) throws SQLException
connectedConfiguration
in class DBDictionary
SQLException
public void setClobString(PreparedStatement stmnt, int idx, String val, Column col) throws SQLException
PreparedStatement.setObject(int, Object, int)
with Types.OTHER
as the third argument.setClobString
in class DBDictionary
SQLException
public Object getObject(ResultSet rs, int column, Map map) throws SQLException
getObject
in class DBDictionary
rs
- column
- map
- SQLException
public void appendXmlComparison(SQLBuffer buf, String op, FilterValue lhs, FilterValue rhs, boolean lhsxml, boolean rhsxml)
appendXmlComparison
in class DBDictionary
buf
- the SQL buffer to write the comparisonop
- the comparison operation to performlhs
- the left hand side of the comparisonrhs
- the right hand side of the comparisonlhsxml
- indicates whether the left operand maps to XMLrhsxml
- indicates whether the right operand maps to XMLpublic String getPlaceholderValueString(Column col)
getPlaceholderValueString
in class DBDictionary
protected org.postgresql.largeobject.LargeObjectManager getLargeObjectManager(DelegatingConnection conn) throws SQLException
SQLException
protected org.postgresql.PGConnection getPGConnection(DelegatingConnection conn)
protected Connection getDbcpDelegate(Connection conn)
conn
- must be a DBCP connectionCopyright © 2006–2018 Apache Software Foundation. All rights reserved.