public class PgConnection extends java.lang.Object implements BaseConnection
Modifier and Type | Class and Description |
---|---|
class |
PgConnection.AbortCommand |
Modifier and Type | Field and Description |
---|---|
protected int |
defaultFetchSize
Default fetch size for statement.
|
protected boolean |
forcebinary |
protected java.sql.DatabaseMetaData |
metadata |
protected int |
prepareThreshold |
protected java.util.Map<java.lang.String,java.lang.Class<?>> |
typemap
The current type mappings.
|
Constructor and Description |
---|
PgConnection(HostSpec[] hostSpecs,
java.lang.String user,
java.lang.String database,
java.util.Properties info,
java.lang.String url) |
Modifier and Type | Method and Description |
---|---|
protected void |
abort() |
void |
abort(java.util.concurrent.Executor executor) |
void |
addDataType(java.lang.String type,
java.lang.Class<? extends PGobject> klass)
This allows client code to add a handler for one of org.postgresql's more unique data types.
|
void |
addDataType(java.lang.String type,
java.lang.String name)
This allows client code to add a handler for one of org.postgresql's more unique data types.
|
void |
addTimerTask(java.util.TimerTask timerTask,
long milliSeconds)
Schedule a TimerTask for later execution.
|
void |
addWarning(java.sql.SQLWarning warn)
This adds a warning to the warning chain.
|
boolean |
binaryTransferSend(int oid)
Returns true if value for the given oid should be sent using binary transfer.
|
void |
cancelQuery()
Cancel the current query executing on this connection.
|
protected void |
checkClosed() |
void |
clearWarnings() |
void |
close()
Note: even though
Statement is automatically closed when it is garbage
collected, it is better to close it explicitly to lower resource consumption. |
void |
commit() |
java.sql.Array |
createArrayOf(java.lang.String typeName,
java.lang.Object elements)
Creates an
Array wrapping elements. |
java.sql.Array |
createArrayOf(java.lang.String typeName,
java.lang.Object[] elements) |
java.sql.Blob |
createBlob() |
java.sql.Clob |
createClob() |
java.sql.NClob |
createNClob() |
CachedQuery |
createQuery(java.lang.String sql,
boolean escapeProcessing,
boolean isParameterized,
java.lang.String... columnNames) |
<T> T |
createQueryObject(java.lang.Class<T> ifc) |
java.sql.SQLXML |
createSQLXML() |
java.sql.Statement |
createStatement() |
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency) |
java.sql.Statement |
createStatement(int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
java.sql.Struct |
createStruct(java.lang.String typeName,
java.lang.Object[] attributes) |
protected TypeInfo |
createTypeInfo(BaseConnection conn,
int unknownLength) |
byte[] |
encodeString(java.lang.String str)
Encode a string using the database's client_encoding (usually UTF8, but can vary on older
server versions).
|
java.lang.String |
escapeIdentifier(java.lang.String identifier)
Return the given string suitably quoted to be used as an identifier in an SQL statement string.
|
java.lang.String |
escapeLiteral(java.lang.String literal)
Return the given string suitably quoted to be used as a string literal in an SQL statement
string.
|
java.lang.String |
escapeString(java.lang.String str)
Escapes a string for use as string-literal within an SQL command.
|
java.sql.ResultSet |
execSQLQuery(java.lang.String s)
Execute a SQL query that returns a single resultset.
|
java.sql.ResultSet |
execSQLQuery(java.lang.String s,
int resultSetType,
int resultSetConcurrency) |
void |
execSQLUpdate(java.lang.String s)
Execute a SQL query that does not return results.
|
protected void |
finalize()
Overrides finalize().
|
boolean |
getAutoCommit() |
AutoSave |
getAutosave()
Connection configuration regarding automatic per-query savepoints.
|
int |
getBackendPID()
Return the process ID (PID) of the backend server process handling this connection.
|
java.lang.String |
getCatalog() |
java.util.Properties |
getClientInfo() |
java.lang.String |
getClientInfo(java.lang.String name) |
CopyManager |
getCopyAPI()
This returns the COPY API for the current connection.
|
java.lang.String |
getCursorName()
getCursorName gets the cursor name.
|
java.lang.String |
getDBVersionNumber()
Get server version number.
|
int |
getDefaultFetchSize()
Get the default fetch size for statements created from this connection.
|
Encoding |
getEncoding() |
Fastpath |
getFastpathAPI()
This returns the Fastpath API for the current connection.
|
LruCache<FieldMetadata.Key,FieldMetadata> |
getFieldMetadataCache()
Return metadata cache for given connection.
|
boolean |
getForceBinary() |
boolean |
getHideUnprivilegedObjects() |
int |
getHoldability() |
protected java.lang.String |
getIsolationLevelName(int level) |
LargeObjectManager |
getLargeObjectAPI()
This returns the LargeObject API for the current connection.
|
java.util.logging.Logger |
getLogger() |
java.sql.DatabaseMetaData |
getMetaData() |
int |
getNetworkTimeout() |
PGNotification[] |
getNotifications()
This method returns any notifications that have been received since the last call to this
method.
|
PGNotification[] |
getNotifications(int timeoutMillis)
This method returns any notifications that have been received since the last call to this
method.
|
java.lang.Object |
getObject(java.lang.String type,
java.lang.String value,
byte[] byteValue)
Construct and return an appropriate object for the given type and value.
|
java.lang.String |
getParameterStatus(java.lang.String parameterName)
Shorthand for getParameterStatuses().get(...) .
|
java.util.Map<java.lang.String,java.lang.String> |
getParameterStatuses()
Returns the current values of all parameters reported by the server.
|
PreferQueryMode |
getPreferQueryMode()
Returns the query mode for this connection.
|
int |
getPrepareThreshold()
Get the default server-side prepare reuse threshold for statements created from this
connection.
|
int |
getProtocolVersion() |
QueryExecutor |
getQueryExecutor()
Get the QueryExecutor implementation for this connection.
|
PGReplicationConnection |
getReplicationAPI() |
ReplicationProtocol |
getReplicationProtocol()
Internal protocol for work with physical and logical replication.
|
java.lang.String |
getSchema() |
int |
getServerMajorVersion()
Get server major version.
|
int |
getServerMinorVersion()
Get server minor version.
|
boolean |
getStandardConformingStrings()
Returns whether the server treats string-literals according to the SQL standard or if it uses
traditional PostgreSQL escaping rules.
|
boolean |
getStringVarcharFlag() |
TimestampUtils |
getTimestampUtils() |
int |
getTransactionIsolation() |
TransactionState |
getTransactionState()
Get the current transaction state of this connection.
|
TypeInfo |
getTypeInfo() |
java.util.Map<java.lang.String,java.lang.Class<?>> |
getTypeMap() |
java.lang.String |
getURL()
We are required to bring back certain information by the DatabaseMetaData class.
|
java.lang.String |
getUserName()
Method getUserName() brings back the User Name (again, we saved it).
|
java.sql.SQLWarning |
getWarnings() |
PGXmlFactoryFactory |
getXmlFactoryFactory()
Retrieve the factory to instantiate XML processing factories.
|
boolean |
haveMinimumServerVersion(int ver)
Check if we have at least a particular server version.
|
boolean |
haveMinimumServerVersion(Version ver)
Check if we have at least a particular server version.
|
boolean |
hintReadOnly()
Indicates if statements to backend should be hinted as read only.
|
boolean |
isClosed() |
boolean |
isColumnSanitiserDisabled()
Return whether to disable column name sanitation.
|
boolean |
isReadOnly() |
boolean |
isValid(int timeout) |
boolean |
isWrapperFor(java.lang.Class<?> iface) |
protected java.sql.Array |
makeArray(int oid,
java.lang.String fieldString) |
protected java.sql.Blob |
makeBlob(long oid) |
protected java.sql.Clob |
makeClob(long oid) |
protected java.sql.SQLXML |
makeSQLXML() |
java.lang.String |
nativeSQL(java.lang.String sql) |
java.sql.CallableStatement |
prepareCall(java.lang.String sql) |
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency) |
java.sql.CallableStatement |
prepareCall(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int autoGeneratedKeys) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int[] columnIndexes) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) |
java.sql.PreparedStatement |
prepareStatement(java.lang.String sql,
java.lang.String[] columnNames) |
void |
purgeTimerTasks()
Invoke purge() on the underlying shared Timer so that internal resources will be released.
|
void |
releaseSavepoint(java.sql.Savepoint savepoint) |
void |
rollback() |
void |
rollback(java.sql.Savepoint savepoint) |
void |
setAutoCommit(boolean autoCommit) |
void |
setAutosave(AutoSave autoSave)
Configures if connection should use automatic savepoints.
|
void |
setCatalog(java.lang.String catalog) |
void |
setClientInfo(java.util.Properties properties) |
void |
setClientInfo(java.lang.String name,
java.lang.String value) |
void |
setCursorName(java.lang.String cursor)
In SQL, a result table can be retrieved through a cursor that is named.
|
void |
setDefaultFetchSize(int fetchSize)
Set the default fetch size for statements created from this connection.
|
void |
setDisableColumnSanitiser(boolean disableColumnSanitiser) |
void |
setFlushCacheOnDeallocate(boolean flushCacheOnDeallocate)
By default, the connection resets statement cache in case deallocate all/discard all
message is observed.
|
void |
setForceBinary(boolean newValue) |
void |
setHoldability(int holdability) |
void |
setNetworkTimeout(java.util.concurrent.Executor executor,
int milliseconds) |
void |
setPrepareThreshold(int newThreshold)
Set the default statement reuse threshold before enabling server-side prepare.
|
void |
setReadOnly(boolean readOnly) |
java.sql.Savepoint |
setSavepoint() |
java.sql.Savepoint |
setSavepoint(java.lang.String name) |
void |
setSchema(java.lang.String schema) |
void |
setTransactionIsolation(int level) |
void |
setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map) |
void |
setTypeMapImpl(java.util.Map<java.lang.String,java.lang.Class<?>> map) |
<T> T |
unwrap(java.lang.Class<T> iface) |
protected int prepareThreshold
protected int defaultFetchSize
PGProperty.DEFAULT_ROW_FETCH_SIZE
protected boolean forcebinary
protected java.util.Map<java.lang.String,java.lang.Class<?>> typemap
protected java.sql.DatabaseMetaData metadata
public PgConnection(HostSpec[] hostSpecs, java.lang.String user, java.lang.String database, java.util.Properties info, java.lang.String url) throws java.sql.SQLException
java.sql.SQLException
public CachedQuery createQuery(java.lang.String sql, boolean escapeProcessing, boolean isParameterized, java.lang.String... columnNames) throws java.sql.SQLException
createQuery
in interface BaseConnection
java.sql.SQLException
public void setFlushCacheOnDeallocate(boolean flushCacheOnDeallocate)
BaseConnection
setFlushCacheOnDeallocate
in interface BaseConnection
flushCacheOnDeallocate
- true if statement cache should be reset when "deallocate/discard" message observedpublic TimestampUtils getTimestampUtils()
getTimestampUtils
in interface BaseConnection
public java.sql.Statement createStatement() throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.CallableStatement prepareCall(java.lang.String sql) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
public java.util.Map<java.lang.String,java.lang.Class<?>> getTypeMap() throws java.sql.SQLException
getTypeMap
in interface java.sql.Connection
java.sql.SQLException
public QueryExecutor getQueryExecutor()
BaseConnection
getQueryExecutor
in interface BaseConnection
public ReplicationProtocol getReplicationProtocol()
BaseConnection
getReplicationProtocol
in interface BaseConnection
public void addWarning(java.sql.SQLWarning warn)
warn
- warning to addpublic java.sql.ResultSet execSQLQuery(java.lang.String s) throws java.sql.SQLException
BaseConnection
execSQLQuery
in interface BaseConnection
s
- the query to executejava.sql.SQLException
- if something goes wrong.public java.sql.ResultSet execSQLQuery(java.lang.String s, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
execSQLQuery
in interface BaseConnection
java.sql.SQLException
public void execSQLUpdate(java.lang.String s) throws java.sql.SQLException
BaseConnection
execSQLUpdate
in interface BaseConnection
s
- the query to executejava.sql.SQLException
- if something goes wrong.public void setCursorName(java.lang.String cursor) throws java.sql.SQLException
In SQL, a result table can be retrieved through a cursor that is named. The current row of a result can be updated or deleted using a positioned update/delete statement that references the cursor name.
We do not support positioned update/delete, so this is a no-op.
cursor
- the cursor namejava.sql.SQLException
- if a database access error occurspublic java.lang.String getCursorName() throws java.sql.SQLException
java.sql.SQLException
- if a database access error occurspublic java.lang.String getURL() throws java.sql.SQLException
We are required to bring back certain information by the DatabaseMetaData class. These functions do that.
Method getURL() brings back the URL (good job we saved it)
java.sql.SQLException
- just in case...public java.lang.String getUserName() throws java.sql.SQLException
java.sql.SQLException
- just in case...public Fastpath getFastpathAPI() throws java.sql.SQLException
PGConnection
getFastpathAPI
in interface PGConnection
java.sql.SQLException
- if something wrong happenspublic LargeObjectManager getLargeObjectAPI() throws java.sql.SQLException
PGConnection
getLargeObjectAPI
in interface PGConnection
java.sql.SQLException
- if something wrong happenspublic java.lang.Object getObject(java.lang.String type, java.lang.String value, byte[] byteValue) throws java.sql.SQLException
BaseConnection
Construct and return an appropriate object for the given type and value. This only considers
the types registered via PGConnection.addDataType(String, Class)
and
PGConnection.addDataType(String, String)
.
If no class is registered as handling the given type, then a generic
PGobject
instance is returned.
value or byteValue must be non-null
getObject
in interface BaseConnection
type
- the backend typenamevalue
- the type-specific string representation of the valuebyteValue
- the type-specific binary representation of the valuejava.sql.SQLException
- if something goes wrongprotected TypeInfo createTypeInfo(BaseConnection conn, int unknownLength)
public TypeInfo getTypeInfo()
getTypeInfo
in interface BaseConnection
public void addDataType(java.lang.String type, java.lang.String name)
PGConnection
addDataType(type, Class.forName(name))
.addDataType
in interface PGConnection
type
- JDBC type namename
- class namepublic void addDataType(java.lang.String type, java.lang.Class<? extends PGobject> klass) throws java.sql.SQLException
PGConnection
This allows client code to add a handler for one of org.postgresql's more unique data types.
NOTE: This is not part of JDBC, but an extension.
The best way to use this is as follows:
... ((org.postgresql.PGConnection)myconn).addDataType("mytype", my.class.name.class); ...
where myconn is an open Connection to org.postgresql.
The handling class must extend org.postgresql.util.PGobject
addDataType
in interface PGConnection
type
- the PostgreSQL type to registerklass
- the class implementing the Java representation of the type; this class must
implement PGobject
).java.sql.SQLException
- if klass
does not implement
PGobject
).PGobject
public void close() throws java.sql.SQLException
Statement
is automatically closed when it is garbage
collected, it is better to close it explicitly to lower resource consumption.
close
in interface java.lang.AutoCloseable
close
in interface java.sql.Connection
java.sql.SQLException
public java.lang.String nativeSQL(java.lang.String sql) throws java.sql.SQLException
nativeSQL
in interface java.sql.Connection
java.sql.SQLException
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
getWarnings
in interface java.sql.Connection
java.sql.SQLException
public void clearWarnings() throws java.sql.SQLException
clearWarnings
in interface java.sql.Connection
java.sql.SQLException
public void setReadOnly(boolean readOnly) throws java.sql.SQLException
setReadOnly
in interface java.sql.Connection
java.sql.SQLException
public boolean isReadOnly() throws java.sql.SQLException
isReadOnly
in interface java.sql.Connection
java.sql.SQLException
public boolean hintReadOnly()
BaseConnection
hintReadOnly
in interface BaseConnection
PGProperty.READ_ONLY_MODE
public void setAutoCommit(boolean autoCommit) throws java.sql.SQLException
setAutoCommit
in interface java.sql.Connection
java.sql.SQLException
public boolean getAutoCommit() throws java.sql.SQLException
getAutoCommit
in interface java.sql.Connection
java.sql.SQLException
public void commit() throws java.sql.SQLException
commit
in interface java.sql.Connection
java.sql.SQLException
protected void checkClosed() throws java.sql.SQLException
java.sql.SQLException
public void rollback() throws java.sql.SQLException
rollback
in interface java.sql.Connection
java.sql.SQLException
public TransactionState getTransactionState()
BaseConnection
getTransactionState
in interface BaseConnection
public int getTransactionIsolation() throws java.sql.SQLException
getTransactionIsolation
in interface java.sql.Connection
java.sql.SQLException
public void setTransactionIsolation(int level) throws java.sql.SQLException
setTransactionIsolation
in interface java.sql.Connection
java.sql.SQLException
protected java.lang.String getIsolationLevelName(int level)
public void setCatalog(java.lang.String catalog) throws java.sql.SQLException
setCatalog
in interface java.sql.Connection
java.sql.SQLException
public java.lang.String getCatalog() throws java.sql.SQLException
getCatalog
in interface java.sql.Connection
java.sql.SQLException
public boolean getHideUnprivilegedObjects()
protected void finalize() throws java.lang.Throwable
Overrides finalize(). If called, it closes the connection.
This was done at the request of Rachel Greenham who hit a problem where multiple clients didn't close the connection, and once a fortnight enough clients were open to kill the postgres server.
finalize
in class java.lang.Object
java.lang.Throwable
public java.lang.String getDBVersionNumber()
public int getServerMajorVersion()
public int getServerMinorVersion()
public boolean haveMinimumServerVersion(int ver)
BaseConnection
Check if we have at least a particular server version.
The input version is of the form xxyyzz, matching a PostgreSQL version like xx.yy.zz. So 9.0.12 is 90012.
haveMinimumServerVersion
in interface BaseConnection
ver
- the server version to check, of the form xxyyzz eg 90401public boolean haveMinimumServerVersion(Version ver)
BaseConnection
Check if we have at least a particular server version.
The input version is of the form xxyyzz, matching a PostgreSQL version like xx.yy.zz. So 9.0.12 is 90012.
haveMinimumServerVersion
in interface BaseConnection
ver
- the server version to checkpublic Encoding getEncoding()
getEncoding
in interface BaseConnection
public byte[] encodeString(java.lang.String str) throws java.sql.SQLException
BaseConnection
encodeString
in interface BaseConnection
str
- the string to encodejava.sql.SQLException
- if something goes wrong.public java.lang.String escapeString(java.lang.String str) throws java.sql.SQLException
BaseConnection
BaseConnection.getStandardConformingStrings()
.escapeString
in interface BaseConnection
str
- a string valuejava.sql.SQLException
- if the string contains a \0
characterpublic boolean getStandardConformingStrings()
BaseConnection
standard_conforming_strings
server variable.getStandardConformingStrings
in interface BaseConnection
QueryExecutor.getStandardConformingStrings()
public boolean isClosed() throws java.sql.SQLException
isClosed
in interface java.sql.Connection
java.sql.SQLException
public void cancelQuery() throws java.sql.SQLException
BaseConnection
cancelQuery
in interface BaseConnection
cancelQuery
in interface PGConnection
java.sql.SQLException
- if something goes wrong.public PGNotification[] getNotifications() throws java.sql.SQLException
PGConnection
getNotifications
in interface PGConnection
java.sql.SQLException
- if something wrong happenspublic PGNotification[] getNotifications(int timeoutMillis) throws java.sql.SQLException
PGConnection
getNotifications
in interface PGConnection
timeoutMillis
- when 0, blocks forever. when > 0, blocks up to the specified number of millies
or until at least one notification has been received. If more than one notification is
about to be received, these will be returned in one batch.java.sql.SQLException
- if something wrong happenspublic int getPrepareThreshold()
PGConnection
getPrepareThreshold
in interface PGConnection
public void setDefaultFetchSize(int fetchSize) throws java.sql.SQLException
PGConnection
setDefaultFetchSize
in interface PGConnection
fetchSize
- new default fetch sizejava.sql.SQLException
- if specified negative fetchSize
parameterStatement.setFetchSize(int)
public int getDefaultFetchSize()
PGConnection
getDefaultFetchSize
in interface PGConnection
PGProperty.DEFAULT_ROW_FETCH_SIZE
,
Statement.getFetchSize()
public void setPrepareThreshold(int newThreshold)
PGConnection
PGStatement.setPrepareThreshold(int)
for details.setPrepareThreshold
in interface PGConnection
newThreshold
- the new thresholdpublic boolean getForceBinary()
public void setForceBinary(boolean newValue)
public void setTypeMapImpl(java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
java.sql.SQLException
public java.util.logging.Logger getLogger()
getLogger
in interface BaseConnection
public int getProtocolVersion()
public boolean getStringVarcharFlag()
getStringVarcharFlag
in interface BaseConnection
public CopyManager getCopyAPI() throws java.sql.SQLException
PGConnection
getCopyAPI
in interface PGConnection
java.sql.SQLException
- if something wrong happenspublic boolean binaryTransferSend(int oid)
BaseConnection
binaryTransferSend
in interface BaseConnection
oid
- The oid to check.public int getBackendPID()
PGConnection
getBackendPID
in interface PGConnection
public boolean isColumnSanitiserDisabled()
BaseConnection
isColumnSanitiserDisabled
in interface BaseConnection
public void setDisableColumnSanitiser(boolean disableColumnSanitiser)
public PreferQueryMode getPreferQueryMode()
PGConnection
Returns the query mode for this connection.
When running in simple query mode, certain features are not available: callable statements, partial result set fetch, bytea type, etc.
The list of supported features is subject to change.
getPreferQueryMode
in interface PGConnection
PreferQueryMode
public AutoSave getAutosave()
PGConnection
getAutosave
in interface PGConnection
PGProperty.AUTOSAVE
public void setAutosave(AutoSave autoSave)
PGConnection
setAutosave
in interface PGConnection
autoSave
- connection configuration regarding automatic per-query savepointsPGProperty.AUTOSAVE
protected void abort()
public void addTimerTask(java.util.TimerTask timerTask, long milliSeconds)
BaseConnection
addTimerTask
in interface BaseConnection
timerTask
- timer task to schedulemilliSeconds
- delay in millisecondspublic void purgeTimerTasks()
BaseConnection
purgeTimerTasks
in interface BaseConnection
public java.lang.String escapeIdentifier(java.lang.String identifier) throws java.sql.SQLException
PGConnection
escapeIdentifier
in interface PGConnection
identifier
- input identifierjava.sql.SQLException
- if something goes wrongpublic java.lang.String escapeLiteral(java.lang.String literal) throws java.sql.SQLException
PGConnection
escapeLiteral
in interface PGConnection
literal
- input literaljava.sql.SQLException
- if something goes wrongpublic LruCache<FieldMetadata.Key,FieldMetadata> getFieldMetadataCache()
BaseConnection
getFieldMetadataCache
in interface BaseConnection
public PGReplicationConnection getReplicationAPI()
getReplicationAPI
in interface PGConnection
public java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
public java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
getMetaData
in interface java.sql.Connection
java.sql.SQLException
public void setTypeMap(java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
setTypeMap
in interface java.sql.Connection
java.sql.SQLException
protected java.sql.Array makeArray(int oid, java.lang.String fieldString) throws java.sql.SQLException
java.sql.SQLException
protected java.sql.Blob makeBlob(long oid) throws java.sql.SQLException
java.sql.SQLException
protected java.sql.Clob makeClob(long oid) throws java.sql.SQLException
java.sql.SQLException
protected java.sql.SQLXML makeSQLXML() throws java.sql.SQLException
java.sql.SQLException
public java.sql.Clob createClob() throws java.sql.SQLException
createClob
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Blob createBlob() throws java.sql.SQLException
createBlob
in interface java.sql.Connection
java.sql.SQLException
public java.sql.NClob createNClob() throws java.sql.SQLException
createNClob
in interface java.sql.Connection
java.sql.SQLException
public java.sql.SQLXML createSQLXML() throws java.sql.SQLException
createSQLXML
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Struct createStruct(java.lang.String typeName, java.lang.Object[] attributes) throws java.sql.SQLException
createStruct
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Array createArrayOf(java.lang.String typeName, java.lang.Object elements) throws java.sql.SQLException
PGConnection
Array
wrapping elements. This is similar to
Connection.createArrayOf(String, Object[])
, but also
provides support for primitive arrays.createArrayOf
in interface PGConnection
typeName
- The SQL name of the type to map the elements to.
Must not be null
.elements
- The array of objects to map. A null
value will result in
an Array
representing null
.Array
wrapping elements.java.sql.SQLException
- If for some reason the array cannot be created.Connection.createArrayOf(String, Object[])
public java.sql.Array createArrayOf(java.lang.String typeName, java.lang.Object[] elements) throws java.sql.SQLException
createArrayOf
in interface java.sql.Connection
java.sql.SQLException
public boolean isValid(int timeout) throws java.sql.SQLException
isValid
in interface java.sql.Connection
java.sql.SQLException
public void setClientInfo(java.lang.String name, java.lang.String value) throws java.sql.SQLClientInfoException
setClientInfo
in interface java.sql.Connection
java.sql.SQLClientInfoException
public void setClientInfo(java.util.Properties properties) throws java.sql.SQLClientInfoException
setClientInfo
in interface java.sql.Connection
java.sql.SQLClientInfoException
public java.lang.String getClientInfo(java.lang.String name) throws java.sql.SQLException
getClientInfo
in interface java.sql.Connection
java.sql.SQLException
public java.util.Properties getClientInfo() throws java.sql.SQLException
getClientInfo
in interface java.sql.Connection
java.sql.SQLException
public <T> T createQueryObject(java.lang.Class<T> ifc) throws java.sql.SQLException
java.sql.SQLException
public boolean isWrapperFor(java.lang.Class<?> iface) throws java.sql.SQLException
isWrapperFor
in interface java.sql.Wrapper
java.sql.SQLException
public <T> T unwrap(java.lang.Class<T> iface) throws java.sql.SQLException
unwrap
in interface java.sql.Wrapper
java.sql.SQLException
public java.lang.String getSchema() throws java.sql.SQLException
getSchema
in interface java.sql.Connection
java.sql.SQLException
public void setSchema(java.lang.String schema) throws java.sql.SQLException
setSchema
in interface java.sql.Connection
java.sql.SQLException
public void abort(java.util.concurrent.Executor executor) throws java.sql.SQLException
abort
in interface java.sql.Connection
java.sql.SQLException
public void setNetworkTimeout(java.util.concurrent.Executor executor, int milliseconds) throws java.sql.SQLException
setNetworkTimeout
in interface java.sql.Connection
java.sql.SQLException
public int getNetworkTimeout() throws java.sql.SQLException
getNetworkTimeout
in interface java.sql.Connection
java.sql.SQLException
public void setHoldability(int holdability) throws java.sql.SQLException
setHoldability
in interface java.sql.Connection
java.sql.SQLException
public int getHoldability() throws java.sql.SQLException
getHoldability
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
setSavepoint
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Savepoint setSavepoint(java.lang.String name) throws java.sql.SQLException
setSavepoint
in interface java.sql.Connection
java.sql.SQLException
public void rollback(java.sql.Savepoint savepoint) throws java.sql.SQLException
rollback
in interface java.sql.Connection
java.sql.SQLException
public void releaseSavepoint(java.sql.Savepoint savepoint) throws java.sql.SQLException
releaseSavepoint
in interface java.sql.Connection
java.sql.SQLException
public java.sql.Statement createStatement(int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
createStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.CallableStatement prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency) throws java.sql.SQLException
prepareCall
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int autoGeneratedKeys) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, int[] columnIndexes) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public java.sql.PreparedStatement prepareStatement(java.lang.String sql, java.lang.String[] columnNames) throws java.sql.SQLException
prepareStatement
in interface java.sql.Connection
java.sql.SQLException
public final java.util.Map<java.lang.String,java.lang.String> getParameterStatuses()
PGConnection
Returns the current values of all parameters reported by the server.
PostgreSQL reports values for a subset of parameters (GUCs) to the client
at connect-time, then sends update messages whenever the values change
during a session. PgJDBC records the latest values and exposes it to client
applications via getParameterStatuses()
.
PgJDBC exposes individual accessors for some of these parameters as listed below. They are more backwarrds-compatible and should be preferred where possible.
Not all parameters are reported, only those marked
GUC_REPORT
in the source code. The pg_settings
view does not expose information about which parameters are reportable.
PgJDBC's map will only contain the parameters the server reports values
for, so you cannot use this method as a substitute for running a
SHOW paramname;
or SELECT
current_setting('paramname');
query for arbitrary parameters.
Parameter names are case-insensitive and case-preserving
in this map, like in PostgreSQL itself. So DateStyle
and
datestyle
are the same key.
As of PostgreSQL 11 the reportable parameter list, and related PgJDBC interfaces or accesors, are:
application_name
-
Connection.getClientInfo()
,
Connection.setClientInfo(java.util.Properties)
and ApplicationName
connection property.
client_encoding
- PgJDBC always sets this to UTF8
.
See allowEncodingChanges
connection property.
DateStyle
- PgJDBC requires this to always be set to ISO
standard_conforming_strings
- indirectly via PGConnection.escapeLiteral(String)
TimeZone
- set from JDK timezone see TimeZone.getDefault()
and TimeZone.setDefault(TimeZone)
integer_datetimes
IntervalStyle
server_encoding
server_version
is_superuser
session_authorization
Note that some PgJDBC operations will change server parameters automatically.
getParameterStatuses
in interface PGConnection
public final java.lang.String getParameterStatus(java.lang.String parameterName)
PGConnection
getParameterStatus
in interface PGConnection
parameterName
- case-insensitive parameter namePGConnection.getParameterStatuses()
public PGXmlFactoryFactory getXmlFactoryFactory() throws java.sql.SQLException
BaseConnection
getXmlFactoryFactory
in interface BaseConnection
java.sql.SQLException
- if the class cannot be found or instantiated.Copyright © 2021 PostgreSQL Global Development Group. All rights reserved.