org.apache.openjpa.jdbc.sql
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.SerializedData
Modifier and Type | Field and Description |
---|---|
java.lang.String |
allSequencesFromOneSchemaSQL
SQL statement to load schema,name pairs from a named schema.
|
java.lang.String |
allSequencesSQL
SQL statement to load all sequence schema,name pairs from all schemas.
|
java.lang.String |
namedSequenceFromOneSchemaSQL
SQL statement to load a sequence's schema,name pair from one schema.
|
java.lang.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. |
allowsAliasInBulkClause, arrayTypeName, autoAssignClause, autoAssignTypeName, batchLimit, bigintTypeName, binaryTypeName, bitLengthFunction, bitTypeName, blobBufferSize, blobTypeName, 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, datePrecision, dateTypeName, DECI, decimalTypeName, delimitedCase, distinctCountColumnSeparator, distinctTypeName, doubleTypeName, driverVendor, dropTableSQL, fixedSizeTypeNames, fixedSizeTypeNameSet, floatTypeName, forUpdateClause, getStringVal, inClauseLimit, initializationSQL, innerJoinClause, integerTypeName, invalidColumnWordSet, isJDBC3, 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, 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, supportsNullUpdateAction, supportsParameterInSelect, supportsQueryTimeout, supportsRestrictDeleteAction, supportsRestrictUpdateAction, supportsSchemaForGetColumns, supportsSchemaForGetTables, supportsSelectEndIndex, supportsSelectForUpdate, supportsSelectFromFinalTable, supportsSelectStartIndex, supportsSimpleCaseExpression, supportsSubselect, supportsUniqueConstraints, supportsXMLColumn, systemSchemas, systemSchemaSet, systemTables, systemTableSet, tableForUpdateClause, tableTypes, timestampTypeName, timeTypeName, tinyintTypeName, toLowerCaseFunction, toUpperCaseFunction, trailingDelimiter, trimBothFunction, trimLeadingFunction, trimSchemaName, trimTrailingFunction, typeModifierSet, UNLIMITED, useGetBestRowIdentifierForPrimaryKeys, useGetBytesForBlobs, useGetObjectForBlobs, useGetStringForClobs, 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,
java.lang.String op,
FilterValue lhs,
FilterValue rhs,
boolean lhsxml,
boolean rhsxml)
Append XML comparison.
|
void |
connectedConfiguration(java.sql.Connection conn)
Determine whether XML column is supported.
|
java.sql.Connection |
decorate(java.sql.Connection conn)
Decorate the given connection if needed.
|
void |
deleteStream(JDBCStore store,
Select sel) |
byte |
getByte(java.sql.ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
java.lang.String[] |
getCreateSequenceSQL(Sequence seq)
Return a series of SQL statements to create the given sequence.
|
java.util.Date |
getDate(java.sql.ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
protected java.sql.Connection |
getDbcpDelegate(java.sql.Connection conn)
Get the delegated connection from the given DBCP connection.
|
int |
getInt(java.sql.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.
|
java.io.InputStream |
getLOBStream(JDBCStore store,
java.sql.ResultSet rs,
int column) |
long |
getLong(java.sql.ResultSet rs,
int column)
Convert the specified column of the SQL ResultSet to the proper
java type.
|
java.lang.Object |
getObject(java.sql.ResultSet rs,
int column,
java.util.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.
|
java.lang.String |
getPlaceholderValueString(Column col)
Return a SQL string to act as a placeholder for the given column.
|
protected java.lang.String |
getSequencesSQL(DBIdentifier schemaName,
DBIdentifier sequenceName) |
protected java.lang.String |
getSequencesSQL(java.lang.String schemaName,
java.lang.String sequenceName)
Return the SQL needed to select the list of sequences.
|
short |
getShort(java.sql.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,
java.lang.Object ob,
Select sel) |
boolean |
isSystemIndex(DBIdentifier name,
Table table)
This method is used to filter system indexes from database metadata.
|
boolean |
isSystemIndex(java.lang.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(java.lang.String name,
java.lang.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(java.lang.String name,
java.lang.String schema,
boolean targetSchema)
This method is used to filter system tables from database metadata.
|
void |
setBoolean(java.sql.PreparedStatement stmnt,
int idx,
boolean val,
Column col)
Set the given value as a parameter to the statement.
|
void |
setClobString(java.sql.PreparedStatement stmnt,
int idx,
java.lang.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(java.sql.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,
java.io.InputStream is) |
addCastAsType, addErrorCode, appendCast, appendLength, appendNumericCast, appendSelect, appendSize, appendUpdates, assertSupport, calculateValue, canOuterJoin, closeDataSource, combineForeignKey, comment, comparison, configureNamingRules, convertSchemaCase, convertSchemaCase, copy, copy, createIndexIfNecessary, createIndexIfNecessary, delimitAll, endConfiguration, executeQuery, fromDBName, getAddColumnSQL, getAddForeignKeySQL, getAddPrimaryKeySQL, getArray, getAsciiStream, getBatchFetchSize, getBatchLimit, getBatchUpdateCount, getBigDecimal, getBigInteger, getBinaryStream, getBlob, getBlobObject, getBoolean, getBytes, getCalendar, getCastFunction, getCastFunction, getCatalogNameForMetadata, getCatalogNameForMetadata, getChar, getCharacterStream, getClob, getClobString, getColumnDBName, getColumnIdentifier, getColumnNameForMetadata, getColumnNameForMetadata, getColumns, getColumns, getConversionKey, getCreateIndexSQL, 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, getIdentifierConcatenator, getIdentifierDelimiter, getIdentifierRule, getIdentifierRules, getImportedKeys, getImportedKeys, getImportedKeys, getImportedKeys, getIndexInfo, getIndexInfo, getInvalidColumnWordSet, getJDBCType, getJDBCType, getJDBCType, getKey, getLeadingDelimiter, getLocale, getLog, getNamingUtil, getNumber, getPreferredType, getPrimaryKeyConstraintSQL, getPrimaryKeys, getPrimaryKeys, getPrimaryKeysFromBestRowIdentifier, getPrimaryKeysFromBestRowIdentifier, getPrimaryKeysFromGetPrimaryKeys, getPrimaryKeysFromGetPrimaryKeys, getRef, getSchemaCase, getSchemaNameForMetadata, getSchemaNameForMetadata, getSelectOperation, getSelects, getSelectTableAliases, getSequence, getSequences, getSequences, 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, isSelect, makeNameValid, makeNameValid, makeNameValid, makeNameValid, matchErrorState, mathFunction, needsToCreateIndex, newColumn, newForeignKey, newIndex, newPrimaryKey, newSequence, newStoreException, newTable, prepareStatement, putBytes, putChars, putString, refSchemaComponents, serialize, setArray, setAsciiStream, setBatchLimit, setBigDecimal, setBigInteger, setBinaryStream, setBlob, setBlobObject, setByte, setBytes, setCalendar, setChar, setCharacterStream, setClob, setConfiguration, setDate, setDate, setDefaultSchemaName, setDelimitedCase, setDelimitIdentifiers, setDouble, setFloat, setInt, setJoinSyntax, setLeadingDelimiter, setLocale, setLong, setNumber, setObject, setQueryTimeout, setRef, setShort, setStatementQueryTimeout, setString, setSupportsDelimitedIdentifiers, setSupportsXMLColumn, setTime, setTimeouts, setTimeouts, setTimestamp, setTrailingDelimiter, setTrimSchemaName, setTyped, 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
public java.lang.String allSequencesSQL
public java.lang.String namedSequencesFromAllSchemasSQL
public java.lang.String allSequencesFromOneSchemaSQL
public java.lang.String namedSequenceFromOneSchemaSQL
public boolean supportsSetFetchSize
Statement.setFetchSize(int)
method.public java.util.Date getDate(java.sql.ResultSet rs, int column) throws java.sql.SQLException
DBDictionary
Timestamp
by default.getDate
in class DBDictionary
java.sql.SQLException
public byte getByte(java.sql.ResultSet rs, int column) throws java.sql.SQLException
DBDictionary
getByte
in class DBDictionary
java.sql.SQLException
public short getShort(java.sql.ResultSet rs, int column) throws java.sql.SQLException
DBDictionary
getShort
in class DBDictionary
java.sql.SQLException
public int getInt(java.sql.ResultSet rs, int column) throws java.sql.SQLException
DBDictionary
getInt
in class DBDictionary
java.sql.SQLException
public long getLong(java.sql.ResultSet rs, int column) throws java.sql.SQLException
DBDictionary
getLong
in class DBDictionary
java.sql.SQLException
public void setBoolean(java.sql.PreparedStatement stmnt, int idx, boolean val, Column col) throws java.sql.SQLException
DBDictionary
setBoolean
in class DBDictionary
java.sql.SQLException
public void setNull(java.sql.PreparedStatement stmnt, int idx, int colType, Column col) throws java.sql.SQLException
setNull
in class DBDictionary
java.sql.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 beginningpublic java.lang.String[] getCreateSequenceSQL(Sequence seq)
DBDictionary
CREATE SEQUENCE <sequence name>[ START WITH <start>]
[ INCREMENT BY <increment>]
by default.getCreateSequenceSQL
in class DBDictionary
protected boolean supportsDeferredUniqueConstraints()
DBDictionary
DBDictionary.supportsUniqueConstraints
.supportsDeferredUniqueConstraints
in class DBDictionary
protected java.lang.String getSequencesSQL(java.lang.String schemaName, java.lang.String sequenceName)
DBDictionary
getSequencesSQL
in class DBDictionary
protected java.lang.String getSequencesSQL(DBIdentifier schemaName, DBIdentifier sequenceName)
getSequencesSQL
in class DBDictionary
public boolean isSystemSequence(java.lang.String name, java.lang.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 isSystemTable(java.lang.String name, java.lang.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(java.lang.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 java.sql.Connection decorate(java.sql.Connection conn) throws java.sql.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
java.sql.SQLException
public java.io.InputStream getLOBStream(JDBCStore store, java.sql.ResultSet rs, int column) throws java.sql.SQLException
getLOBStream
in class DBDictionary
java.sql.SQLException
public void insertBlobForStreamingLoad(Row row, Column col, JDBCStore store, java.lang.Object ob, Select sel) throws java.sql.SQLException
insertBlobForStreamingLoad
in class DBDictionary
java.sql.SQLException
public void updateBlob(Select sel, JDBCStore store, java.io.InputStream is) throws java.sql.SQLException
updateBlob
in class DBDictionary
java.sql.SQLException
public void deleteStream(JDBCStore store, Select sel) throws java.sql.SQLException
deleteStream
in class DBDictionary
java.sql.SQLException
public void connectedConfiguration(java.sql.Connection conn) throws java.sql.SQLException
connectedConfiguration
in class DBDictionary
java.sql.SQLException
public void setClobString(java.sql.PreparedStatement stmnt, int idx, java.lang.String val, Column col) throws java.sql.SQLException
PreparedStatement.setObject(int, Object, int)
with Types.OTHER
as the third argument.setClobString
in class DBDictionary
java.sql.SQLException
public java.lang.Object getObject(java.sql.ResultSet rs, int column, java.util.Map map) throws java.sql.SQLException
getObject
in class DBDictionary
rs
- column
- map
- java.sql.SQLException
public void appendXmlComparison(SQLBuffer buf, java.lang.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 java.lang.String getPlaceholderValueString(Column col)
getPlaceholderValueString
in class DBDictionary
protected org.postgresql.largeobject.LargeObjectManager getLargeObjectManager(DelegatingConnection conn) throws java.sql.SQLException
java.sql.SQLException
protected org.postgresql.PGConnection getPGConnection(DelegatingConnection conn)
protected java.sql.Connection getDbcpDelegate(java.sql.Connection conn)
conn
- must be a DBCP connection