Package org.postgresql.ds.common
Class BaseDataSource
- java.lang.Object
-
- org.postgresql.ds.common.BaseDataSource
-
- All Implemented Interfaces:
javax.naming.Referenceable
- Direct Known Subclasses:
PGConnectionPoolDataSource
,PGPoolingDataSource
,PGSimpleDataSource
,PGXADataSource
public abstract class BaseDataSource extends java.lang.Object implements javax.naming.Referenceable
Base class for data sources and related classes.- Author:
- Aaron Mulder (ammulder@chariotsolutions.com)
-
-
Constructor Summary
Constructors Constructor Description BaseDataSource()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected javax.naming.Reference
createReference()
Generates a reference using the appropriate object factory.boolean
getAllowEncodingChanges()
java.lang.String
getApplicationName()
java.lang.String
getAssumeMinServerVersion()
AutoSave
getAutosave()
boolean
getBinaryTransfer()
java.lang.String
getBinaryTransferDisable()
java.lang.String
getBinaryTransferEnable()
int
getCancelSignalTimeout()
java.lang.String
getCharset()
java.lang.String
getCompatible()
java.sql.Connection
getConnection()
Gets a connection to the PostgreSQL database.java.sql.Connection
getConnection(java.lang.String user, java.lang.String password)
Gets a connection to the PostgreSQL database.int
getConnectTimeout()
java.lang.String
getCurrentSchema()
int
getDatabaseMetadataCacheFields()
int
getDatabaseMetadataCacheFieldsMiB()
java.lang.String
getDatabaseName()
Gets the name of the PostgreSQL database, running on the server identified by the serverName property.int
getDefaultRowFetchSize()
abstract java.lang.String
getDescription()
Gets a description of this DataSource-ish thing.boolean
getDisableColumnSanitiser()
java.lang.String
getGssLib()
int
getHostRecheckSeconds()
java.lang.String
getJaasApplicationName()
java.lang.String
getKerberosServerName()
boolean
getLoadBalanceHosts()
int
getLoginTimeout()
int
getLoglevel()
int
getLogLevel()
boolean
getLogUnclosedConnections()
java.io.PrintWriter
getLogWriter()
Gets the log writer used to log connections opened.java.lang.String
getPassword()
Gets the password to connect with by default.int
getPortNumber()
Gets the port which the PostgreSQL server is listening on for TCP/IP connections.PreferQueryMode
getPreferQueryMode()
int
getPreparedStatementCacheQueries()
int
getPreparedStatementCacheSizeMiB()
int
getPrepareThreshold()
java.lang.String
getProperty(java.lang.String name)
java.lang.String
getProperty(PGProperty property)
int
getProtocolVersion()
boolean
getReadOnly()
int
getReceiveBufferSize()
javax.naming.Reference
getReference()
boolean
getReWriteBatchedInserts()
int
getSendBufferSize()
java.lang.String
getServerName()
Gets the name of the host the PostgreSQL database is running on.java.lang.String
getSocketFactory()
java.lang.String
getSocketFactoryArg()
int
getSocketTimeout()
boolean
getSsl()
java.lang.String
getSslCert()
java.lang.String
getSslfactory()
java.lang.String
getSslFactoryArg()
java.lang.String
getSslHostnameVerifier()
java.lang.String
getSslKey()
java.lang.String
getSslMode()
java.lang.String
getSslPassword()
java.lang.String
getSslPasswordCallback()
java.lang.String
getSslRootCert()
java.lang.String
getSspiServiceClass()
java.lang.String
getStringType()
java.lang.String
getTargetServerType()
boolean
getTcpKeepAlive()
int
getUnknownLength()
java.lang.String
getUrl()
Generates aDriverManager
URL from the other properties supplied.java.lang.String
getUser()
Gets the user to connect as by default.boolean
getUseSpNego()
java.lang.String
getXmlFactoryFactory()
void
initializeFrom(BaseDataSource source)
boolean
isColumnSanitiserDisabled()
protected void
readBaseObject(java.io.ObjectInputStream in)
void
setAllowEncodingChanges(boolean allow)
void
setApplicationName(java.lang.String applicationName)
void
setAssumeMinServerVersion(java.lang.String minVersion)
void
setAutosave(AutoSave autoSave)
void
setBinaryTransfer(boolean enabled)
void
setBinaryTransferDisable(java.lang.String oidList)
void
setBinaryTransferEnable(java.lang.String oidList)
void
setCancelSignalTimeout(int seconds)
void
setCharset(java.lang.String charset)
void
setCompatible(java.lang.String compatible)
void
setConnectTimeout(int connectTimeout)
void
setCurrentSchema(java.lang.String currentSchema)
void
setDatabaseMetadataCacheFields(int cacheSize)
void
setDatabaseMetadataCacheFieldsMiB(int cacheSize)
void
setDatabaseName(java.lang.String databaseName)
Sets the name of the PostgreSQL database, running on the server identified by the serverName property.void
setDefaultRowFetchSize(int fetchSize)
void
setDisableColumnSanitiser(boolean disableColumnSanitiser)
void
setFromReference(javax.naming.Reference ref)
void
setGssLib(java.lang.String lib)
void
setHostRecheckSeconds(int hostRecheckSeconds)
void
setJaasApplicationName(java.lang.String name)
void
setKerberosServerName(java.lang.String serverName)
void
setLoadBalanceHosts(boolean loadBalanceHosts)
void
setLoginTimeout(int loginTimeout)
void
setLoglevel(int logLevel)
void
setLogLevel(int logLevel)
void
setLogUnclosedConnections(boolean enabled)
void
setLogWriter(java.io.PrintWriter printWriter)
The DataSource will note every connection opened to the provided log writer.void
setPassword(java.lang.String password)
Sets the password to connect with by default.void
setPortNumber(int portNumber)
Gets the port which the PostgreSQL server is listening on for TCP/IP connections.void
setPreferQueryMode(PreferQueryMode preferQueryMode)
void
setPreparedStatementCacheQueries(int cacheSize)
void
setPreparedStatementCacheSizeMiB(int cacheSize)
void
setPrepareThreshold(int count)
void
setProperty(java.lang.String name, java.lang.String value)
void
setProperty(PGProperty property, java.lang.String value)
void
setProtocolVersion(int protocolVersion)
void
setReadOnly(boolean readOnly)
void
setReceiveBufferSize(int nbytes)
void
setReWriteBatchedInserts(boolean reWrite)
void
setSendBufferSize(int nbytes)
void
setServerName(java.lang.String serverName)
Sets the name of the host the PostgreSQL database is running on.void
setSocketFactory(java.lang.String socketFactoryClassName)
void
setSocketFactoryArg(java.lang.String socketFactoryArg)
void
setSocketTimeout(int seconds)
void
setSsl(boolean enabled)
void
setSslCert(java.lang.String file)
void
setSslfactory(java.lang.String classname)
void
setSslFactoryArg(java.lang.String arg)
void
setSslHostnameVerifier(java.lang.String className)
void
setSslKey(java.lang.String file)
void
setSslMode(java.lang.String mode)
void
setSslPassword(java.lang.String password)
void
setSslPasswordCallback(java.lang.String className)
void
setSslRootCert(java.lang.String file)
void
setSspiServiceClass(java.lang.String serviceClass)
void
setStringType(java.lang.String stringType)
void
setTargetServerType(java.lang.String targetServerType)
void
setTcpKeepAlive(boolean enabled)
void
setUnknownLength(int unknownLength)
void
setUrl(java.lang.String url)
Sets properties from aDriverManager
URL.void
setUser(java.lang.String user)
Sets the user to connect as by default.void
setUseSpNego(boolean use)
void
setXmlFactoryFactory(java.lang.String xmlFactoryFactory)
protected void
writeBaseObject(java.io.ObjectOutputStream out)
-
-
-
Method Detail
-
getConnection
public java.sql.Connection getConnection() throws java.sql.SQLException
Gets a connection to the PostgreSQL database. The database is identified by the DataSource properties serverName, databaseName, and portNumber. The user to connect as is identified by the DataSource properties user and password.- Returns:
- A valid database connection.
- Throws:
java.sql.SQLException
- Occurs when the database connection cannot be established.
-
getConnection
public java.sql.Connection getConnection(java.lang.String user, java.lang.String password) throws java.sql.SQLException
Gets a connection to the PostgreSQL database. The database is identified by the DataSource properties serverName, databaseName, and portNumber. The user to connect as is identified by the arguments user and password, which override the DataSource properties by the same name.- Parameters:
user
- userpassword
- password- Returns:
- A valid database connection.
- Throws:
java.sql.SQLException
- Occurs when the database connection cannot be established.
-
getLogWriter
public java.io.PrintWriter getLogWriter()
Gets the log writer used to log connections opened.- Returns:
- log writer used to log connections opened
-
setLogWriter
public void setLogWriter(java.io.PrintWriter printWriter)
The DataSource will note every connection opened to the provided log writer.- Parameters:
printWriter
- log writer used to log connections opened
-
getServerName
public java.lang.String getServerName()
Gets the name of the host the PostgreSQL database is running on.- Returns:
- name of the host the PostgreSQL database is running on
-
setServerName
public void setServerName(java.lang.String serverName)
Sets the name of the host the PostgreSQL database is running on. If this is changed, it will only affect future calls to getConnection. The default value is localhost.- Parameters:
serverName
- name of the host the PostgreSQL database is running on
-
getDatabaseName
public java.lang.String getDatabaseName()
Gets the name of the PostgreSQL database, running on the server identified by the serverName property.- Returns:
- name of the PostgreSQL database
-
setDatabaseName
public void setDatabaseName(java.lang.String databaseName)
Sets the name of the PostgreSQL database, running on the server identified by the serverName property. If this is changed, it will only affect future calls to getConnection.- Parameters:
databaseName
- name of the PostgreSQL database
-
getDescription
public abstract java.lang.String getDescription()
Gets a description of this DataSource-ish thing. Must be customized by subclasses.- Returns:
- description of this DataSource-ish thing
-
getUser
public java.lang.String getUser()
Gets the user to connect as by default. If this is not specified, you must use the getConnection method which takes a user and password as parameters.- Returns:
- user to connect as by default
-
setUser
public void setUser(java.lang.String user)
Sets the user to connect as by default. If this is not specified, you must use the getConnection method which takes a user and password as parameters. If this is changed, it will only affect future calls to getConnection.- Parameters:
user
- user to connect as by default
-
getPassword
public java.lang.String getPassword()
Gets the password to connect with by default. If this is not specified but a password is needed to log in, you must use the getConnection method which takes a user and password as parameters.- Returns:
- password to connect with by default
-
setPassword
public void setPassword(java.lang.String password)
Sets the password to connect with by default. If this is not specified but a password is needed to log in, you must use the getConnection method which takes a user and password as parameters. If this is changed, it will only affect future calls to getConnection.- Parameters:
password
- password to connect with by default
-
getPortNumber
public int getPortNumber()
Gets the port which the PostgreSQL server is listening on for TCP/IP connections.- Returns:
- The port, or 0 if the default port will be used.
-
setPortNumber
public void setPortNumber(int portNumber)
Gets the port which the PostgreSQL server is listening on for TCP/IP connections. Be sure the -i flag is passed to postmaster when PostgreSQL is started. If this is not set, or set to 0, the default port will be used.- Parameters:
portNumber
- port which the PostgreSQL server is listening on for TCP/IP
-
getCompatible
public java.lang.String getCompatible()
- Returns:
- value of compatible parameter
- See Also:
PGProperty.COMPATIBLE
-
setCompatible
public void setCompatible(java.lang.String compatible)
- Parameters:
compatible
- value of compatible parameter- See Also:
PGProperty.COMPATIBLE
-
getLoginTimeout
public int getLoginTimeout()
- Returns:
- login timeout
- See Also:
PGProperty.LOGIN_TIMEOUT
-
setLoginTimeout
public void setLoginTimeout(int loginTimeout)
- Parameters:
loginTimeout
- login timeout- See Also:
PGProperty.LOGIN_TIMEOUT
-
getConnectTimeout
public int getConnectTimeout()
- Returns:
- connect timeout
- See Also:
PGProperty.CONNECT_TIMEOUT
-
setConnectTimeout
public void setConnectTimeout(int connectTimeout)
- Parameters:
connectTimeout
- connect timeout- See Also:
PGProperty.CONNECT_TIMEOUT
-
getLogLevel
public int getLogLevel()
- Returns:
- log level
- See Also:
PGProperty.LOG_LEVEL
-
setLogLevel
public void setLogLevel(int logLevel)
- Parameters:
logLevel
- log level- See Also:
PGProperty.LOG_LEVEL
-
getProtocolVersion
public int getProtocolVersion()
- Returns:
- protocol version
- See Also:
PGProperty.PROTOCOL_VERSION
-
setProtocolVersion
public void setProtocolVersion(int protocolVersion)
- Parameters:
protocolVersion
- protocol version- See Also:
PGProperty.PROTOCOL_VERSION
-
getReceiveBufferSize
public int getReceiveBufferSize()
- Returns:
- receive buffer size
- See Also:
PGProperty.RECEIVE_BUFFER_SIZE
-
setReceiveBufferSize
public void setReceiveBufferSize(int nbytes)
- Parameters:
nbytes
- receive buffer size- See Also:
PGProperty.RECEIVE_BUFFER_SIZE
-
getSendBufferSize
public int getSendBufferSize()
- Returns:
- send buffer size
- See Also:
PGProperty.SEND_BUFFER_SIZE
-
setSendBufferSize
public void setSendBufferSize(int nbytes)
- Parameters:
nbytes
- send buffer size- See Also:
PGProperty.SEND_BUFFER_SIZE
-
setPrepareThreshold
public void setPrepareThreshold(int count)
- Parameters:
count
- prepare threshold- See Also:
PGProperty.PREPARE_THRESHOLD
-
getPrepareThreshold
public int getPrepareThreshold()
- Returns:
- prepare threshold
- See Also:
PGProperty.PREPARE_THRESHOLD
-
getPreparedStatementCacheQueries
public int getPreparedStatementCacheQueries()
- Returns:
- prepared statement cache size (number of statements per connection)
- See Also:
PGProperty.PREPARED_STATEMENT_CACHE_QUERIES
-
setPreparedStatementCacheQueries
public void setPreparedStatementCacheQueries(int cacheSize)
- Parameters:
cacheSize
- prepared statement cache size (number of statements per connection)- See Also:
PGProperty.PREPARED_STATEMENT_CACHE_QUERIES
-
getPreparedStatementCacheSizeMiB
public int getPreparedStatementCacheSizeMiB()
- Returns:
- prepared statement cache size (number of megabytes per connection)
- See Also:
PGProperty.PREPARED_STATEMENT_CACHE_SIZE_MIB
-
setPreparedStatementCacheSizeMiB
public void setPreparedStatementCacheSizeMiB(int cacheSize)
- Parameters:
cacheSize
- statement cache size (number of megabytes per connection)- See Also:
PGProperty.PREPARED_STATEMENT_CACHE_SIZE_MIB
-
getDatabaseMetadataCacheFields
public int getDatabaseMetadataCacheFields()
- Returns:
- database metadata cache fields size (number of fields cached per connection)
- See Also:
PGProperty.DATABASE_METADATA_CACHE_FIELDS
-
setDatabaseMetadataCacheFields
public void setDatabaseMetadataCacheFields(int cacheSize)
- Parameters:
cacheSize
- database metadata cache fields size (number of fields cached per connection)- See Also:
PGProperty.DATABASE_METADATA_CACHE_FIELDS
-
getDatabaseMetadataCacheFieldsMiB
public int getDatabaseMetadataCacheFieldsMiB()
- Returns:
- database metadata cache fields size (number of megabytes per connection)
- See Also:
PGProperty.DATABASE_METADATA_CACHE_FIELDS_MIB
-
setDatabaseMetadataCacheFieldsMiB
public void setDatabaseMetadataCacheFieldsMiB(int cacheSize)
- Parameters:
cacheSize
- database metadata cache fields size (number of megabytes per connection)- See Also:
PGProperty.DATABASE_METADATA_CACHE_FIELDS_MIB
-
setDefaultRowFetchSize
public void setDefaultRowFetchSize(int fetchSize)
- Parameters:
fetchSize
- default fetch size- See Also:
PGProperty.DEFAULT_ROW_FETCH_SIZE
-
getDefaultRowFetchSize
public int getDefaultRowFetchSize()
- Returns:
- default fetch size
- See Also:
PGProperty.DEFAULT_ROW_FETCH_SIZE
-
setUnknownLength
public void setUnknownLength(int unknownLength)
- Parameters:
unknownLength
- unknown length- See Also:
PGProperty.UNKNOWN_LENGTH
-
getUnknownLength
public int getUnknownLength()
- Returns:
- unknown length
- See Also:
PGProperty.UNKNOWN_LENGTH
-
setSocketTimeout
public void setSocketTimeout(int seconds)
- Parameters:
seconds
- socket timeout- See Also:
PGProperty.SOCKET_TIMEOUT
-
getSocketTimeout
public int getSocketTimeout()
- Returns:
- socket timeout
- See Also:
PGProperty.SOCKET_TIMEOUT
-
setCancelSignalTimeout
public void setCancelSignalTimeout(int seconds)
- Parameters:
seconds
- timeout that is used for sending cancel command- See Also:
PGProperty.CANCEL_SIGNAL_TIMEOUT
-
getCancelSignalTimeout
public int getCancelSignalTimeout()
- Returns:
- timeout that is used for sending cancel command in seconds
- See Also:
PGProperty.CANCEL_SIGNAL_TIMEOUT
-
setSsl
public void setSsl(boolean enabled)
- Parameters:
enabled
- if SSL is enabled- See Also:
PGProperty.SSL
-
getSsl
public boolean getSsl()
- Returns:
- true if SSL is enabled
- See Also:
PGProperty.SSL
-
setSslfactory
public void setSslfactory(java.lang.String classname)
- Parameters:
classname
- SSL factory class name- See Also:
PGProperty.SSL_FACTORY
-
getSslfactory
public java.lang.String getSslfactory()
- Returns:
- SSL factory class name
- See Also:
PGProperty.SSL_FACTORY
-
getSslMode
public java.lang.String getSslMode()
- Returns:
- SSL mode
- See Also:
PGProperty.SSL_MODE
-
setSslMode
public void setSslMode(java.lang.String mode)
- Parameters:
mode
- SSL mode- See Also:
PGProperty.SSL_MODE
-
getSslFactoryArg
public java.lang.String getSslFactoryArg()
- Returns:
- SSL mode
- See Also:
PGProperty.SSL_FACTORY_ARG
-
setSslFactoryArg
public void setSslFactoryArg(java.lang.String arg)
- Parameters:
arg
- argument forwarded to SSL factory- See Also:
PGProperty.SSL_FACTORY_ARG
-
getSslHostnameVerifier
public java.lang.String getSslHostnameVerifier()
- Returns:
- argument forwarded to SSL factory
- See Also:
PGProperty.SSL_HOSTNAME_VERIFIER
-
setSslHostnameVerifier
public void setSslHostnameVerifier(java.lang.String className)
- Parameters:
className
- SSL hostname verifier- See Also:
PGProperty.SSL_HOSTNAME_VERIFIER
-
getSslCert
public java.lang.String getSslCert()
- Returns:
- className SSL hostname verifier
- See Also:
PGProperty.SSL_CERT
-
setSslCert
public void setSslCert(java.lang.String file)
- Parameters:
file
- SSL certificate- See Also:
PGProperty.SSL_CERT
-
getSslKey
public java.lang.String getSslKey()
- Returns:
- SSL certificate
- See Also:
PGProperty.SSL_KEY
-
setSslKey
public void setSslKey(java.lang.String file)
- Parameters:
file
- SSL key- See Also:
PGProperty.SSL_KEY
-
getSslRootCert
public java.lang.String getSslRootCert()
- Returns:
- SSL root certificate
- See Also:
PGProperty.SSL_ROOT_CERT
-
setSslRootCert
public void setSslRootCert(java.lang.String file)
- Parameters:
file
- SSL root certificate- See Also:
PGProperty.SSL_ROOT_CERT
-
getSslPassword
public java.lang.String getSslPassword()
- Returns:
- SSL password
- See Also:
PGProperty.SSL_PASSWORD
-
setSslPassword
public void setSslPassword(java.lang.String password)
- Parameters:
password
- SSL password- See Also:
PGProperty.SSL_PASSWORD
-
getSslPasswordCallback
public java.lang.String getSslPasswordCallback()
- Returns:
- SSL password callback
- See Also:
PGProperty.SSL_PASSWORD_CALLBACK
-
setSslPasswordCallback
public void setSslPasswordCallback(java.lang.String className)
- Parameters:
className
- SSL password callback class name- See Also:
PGProperty.SSL_PASSWORD_CALLBACK
-
setApplicationName
public void setApplicationName(java.lang.String applicationName)
- Parameters:
applicationName
- application name- See Also:
PGProperty.APPLICATION_NAME
-
getApplicationName
public java.lang.String getApplicationName()
- Returns:
- application name
- See Also:
PGProperty.APPLICATION_NAME
-
setTargetServerType
public void setTargetServerType(java.lang.String targetServerType)
- Parameters:
targetServerType
- target server type- See Also:
PGProperty.TARGET_SERVER_TYPE
-
getTargetServerType
public java.lang.String getTargetServerType()
- Returns:
- target server type
- See Also:
PGProperty.TARGET_SERVER_TYPE
-
setLoadBalanceHosts
public void setLoadBalanceHosts(boolean loadBalanceHosts)
- Parameters:
loadBalanceHosts
- load balance hosts- See Also:
PGProperty.LOAD_BALANCE_HOSTS
-
getLoadBalanceHosts
public boolean getLoadBalanceHosts()
- Returns:
- load balance hosts
- See Also:
PGProperty.LOAD_BALANCE_HOSTS
-
setHostRecheckSeconds
public void setHostRecheckSeconds(int hostRecheckSeconds)
- Parameters:
hostRecheckSeconds
- host recheck seconds- See Also:
PGProperty.HOST_RECHECK_SECONDS
-
getHostRecheckSeconds
public int getHostRecheckSeconds()
- Returns:
- host recheck seconds
- See Also:
PGProperty.HOST_RECHECK_SECONDS
-
setTcpKeepAlive
public void setTcpKeepAlive(boolean enabled)
- Parameters:
enabled
- if TCP keep alive should be enabled- See Also:
PGProperty.TCP_KEEP_ALIVE
-
getTcpKeepAlive
public boolean getTcpKeepAlive()
- Returns:
- true if TCP keep alive is enabled
- See Also:
PGProperty.TCP_KEEP_ALIVE
-
setBinaryTransfer
public void setBinaryTransfer(boolean enabled)
- Parameters:
enabled
- if binary transfer should be enabled- See Also:
PGProperty.BINARY_TRANSFER
-
getBinaryTransfer
public boolean getBinaryTransfer()
- Returns:
- true if binary transfer is enabled
- See Also:
PGProperty.BINARY_TRANSFER
-
setBinaryTransferEnable
public void setBinaryTransferEnable(java.lang.String oidList)
- Parameters:
oidList
- list of OIDs that are allowed to use binary transfer- See Also:
PGProperty.BINARY_TRANSFER_ENABLE
-
getBinaryTransferEnable
public java.lang.String getBinaryTransferEnable()
- Returns:
- list of OIDs that are allowed to use binary transfer
- See Also:
PGProperty.BINARY_TRANSFER_ENABLE
-
setBinaryTransferDisable
public void setBinaryTransferDisable(java.lang.String oidList)
- Parameters:
oidList
- list of OIDs that are not allowed to use binary transfer- See Also:
PGProperty.BINARY_TRANSFER_DISABLE
-
getBinaryTransferDisable
public java.lang.String getBinaryTransferDisable()
- Returns:
- list of OIDs that are not allowed to use binary transfer
- See Also:
PGProperty.BINARY_TRANSFER_DISABLE
-
getStringType
public java.lang.String getStringType()
- Returns:
- string type
- See Also:
PGProperty.STRING_TYPE
-
setStringType
public void setStringType(java.lang.String stringType)
- Parameters:
stringType
- string type- See Also:
PGProperty.STRING_TYPE
-
isColumnSanitiserDisabled
public boolean isColumnSanitiserDisabled()
- Returns:
- true if column sanitizer is disabled
- See Also:
PGProperty.DISABLE_COLUMN_SANITISER
-
getDisableColumnSanitiser
public boolean getDisableColumnSanitiser()
- Returns:
- true if column sanitizer is disabled
- See Also:
PGProperty.DISABLE_COLUMN_SANITISER
-
setDisableColumnSanitiser
public void setDisableColumnSanitiser(boolean disableColumnSanitiser)
- Parameters:
disableColumnSanitiser
- if column sanitizer should be disabled- See Also:
PGProperty.DISABLE_COLUMN_SANITISER
-
getCurrentSchema
public java.lang.String getCurrentSchema()
- Returns:
- current schema
- See Also:
PGProperty.CURRENT_SCHEMA
-
setCurrentSchema
public void setCurrentSchema(java.lang.String currentSchema)
- Parameters:
currentSchema
- current schema- See Also:
PGProperty.CURRENT_SCHEMA
-
getReadOnly
public boolean getReadOnly()
- Returns:
- true if connection is readonly
- See Also:
PGProperty.READ_ONLY
-
setReadOnly
public void setReadOnly(boolean readOnly)
- Parameters:
readOnly
- if connection should be readonly- See Also:
PGProperty.READ_ONLY
-
getLogUnclosedConnections
public boolean getLogUnclosedConnections()
- Returns:
- true if driver should log unclosed connections
- See Also:
PGProperty.LOG_UNCLOSED_CONNECTIONS
-
setLogUnclosedConnections
public void setLogUnclosedConnections(boolean enabled)
- Parameters:
enabled
- true if driver should log unclosed connections- See Also:
PGProperty.LOG_UNCLOSED_CONNECTIONS
-
getAssumeMinServerVersion
public java.lang.String getAssumeMinServerVersion()
- Returns:
- assumed minimal server version
- See Also:
PGProperty.ASSUME_MIN_SERVER_VERSION
-
setAssumeMinServerVersion
public void setAssumeMinServerVersion(java.lang.String minVersion)
- Parameters:
minVersion
- assumed minimal server version- See Also:
PGProperty.ASSUME_MIN_SERVER_VERSION
-
getJaasApplicationName
public java.lang.String getJaasApplicationName()
- Returns:
- JAAS application name
- See Also:
PGProperty.JAAS_APPLICATION_NAME
-
setJaasApplicationName
public void setJaasApplicationName(java.lang.String name)
- Parameters:
name
- JAAS application name- See Also:
PGProperty.JAAS_APPLICATION_NAME
-
getKerberosServerName
public java.lang.String getKerberosServerName()
- Returns:
- Kerberos server name
- See Also:
PGProperty.KERBEROS_SERVER_NAME
-
setKerberosServerName
public void setKerberosServerName(java.lang.String serverName)
- Parameters:
serverName
- Kerberos server name- See Also:
PGProperty.KERBEROS_SERVER_NAME
-
getUseSpNego
public boolean getUseSpNego()
- Returns:
- true if use SPNEGO
- See Also:
PGProperty.USE_SPNEGO
-
setUseSpNego
public void setUseSpNego(boolean use)
- Parameters:
use
- true if use SPNEGO- See Also:
PGProperty.USE_SPNEGO
-
getGssLib
public java.lang.String getGssLib()
- Returns:
- GSS mode: auto, sspi, or gssapi
- See Also:
PGProperty.GSS_LIB
-
setGssLib
public void setGssLib(java.lang.String lib)
- Parameters:
lib
- GSS mode: auto, sspi, or gssapi- See Also:
PGProperty.GSS_LIB
-
getSspiServiceClass
public java.lang.String getSspiServiceClass()
- Returns:
- SSPI service class
- See Also:
PGProperty.SSPI_SERVICE_CLASS
-
setSspiServiceClass
public void setSspiServiceClass(java.lang.String serviceClass)
- Parameters:
serviceClass
- SSPI service class- See Also:
PGProperty.SSPI_SERVICE_CLASS
-
getCharset
public java.lang.String getCharset()
- Returns:
- character set to use for data sent to the database or received
- See Also:
PGProperty.CHARSET
-
setCharset
public void setCharset(java.lang.String charset)
- Parameters:
charset
- character set to use for data sent to the database or received- See Also:
PGProperty.CHARSET
-
getAllowEncodingChanges
public boolean getAllowEncodingChanges()
- Returns:
- if connection allows encoding changes
- See Also:
PGProperty.ALLOW_ENCODING_CHANGES
-
setAllowEncodingChanges
public void setAllowEncodingChanges(boolean allow)
- Parameters:
allow
- if connection allows encoding changes- See Also:
PGProperty.ALLOW_ENCODING_CHANGES
-
getSocketFactory
public java.lang.String getSocketFactory()
- Returns:
- socket factory class name
- See Also:
PGProperty.SOCKET_FACTORY
-
setSocketFactory
public void setSocketFactory(java.lang.String socketFactoryClassName)
- Parameters:
socketFactoryClassName
- socket factory class name- See Also:
PGProperty.SOCKET_FACTORY
-
getSocketFactoryArg
public java.lang.String getSocketFactoryArg()
- Returns:
- socket factory argument
- See Also:
PGProperty.SOCKET_FACTORY_ARG
-
setSocketFactoryArg
public void setSocketFactoryArg(java.lang.String socketFactoryArg)
- Parameters:
socketFactoryArg
- socket factory argument- See Also:
PGProperty.SOCKET_FACTORY_ARG
-
getUrl
public java.lang.String getUrl()
Generates aDriverManager
URL from the other properties supplied.- Returns:
DriverManager
URL from the other properties supplied
-
setUrl
public void setUrl(java.lang.String url)
Sets properties from aDriverManager
URL.- Parameters:
url
- properties to set
-
getProperty
public java.lang.String getProperty(java.lang.String name) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
setProperty
public void setProperty(java.lang.String name, java.lang.String value) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getProperty
public java.lang.String getProperty(PGProperty property)
-
setProperty
public void setProperty(PGProperty property, java.lang.String value)
-
createReference
protected javax.naming.Reference createReference()
Generates a reference using the appropriate object factory.- Returns:
- reference using the appropriate object factory
-
getReference
public javax.naming.Reference getReference() throws javax.naming.NamingException
- Specified by:
getReference
in interfacejavax.naming.Referenceable
- Throws:
javax.naming.NamingException
-
setFromReference
public void setFromReference(javax.naming.Reference ref)
-
writeBaseObject
protected void writeBaseObject(java.io.ObjectOutputStream out) throws java.io.IOException
- Throws:
java.io.IOException
-
readBaseObject
protected void readBaseObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
initializeFrom
public void initializeFrom(BaseDataSource source) throws java.io.IOException, java.lang.ClassNotFoundException
- Throws:
java.io.IOException
java.lang.ClassNotFoundException
-
setLoglevel
public void setLoglevel(int logLevel)
-
getLoglevel
public int getLoglevel()
-
getPreferQueryMode
public PreferQueryMode getPreferQueryMode()
- Returns:
- preferred query execution mode
- See Also:
PGProperty.PREFER_QUERY_MODE
-
setPreferQueryMode
public void setPreferQueryMode(PreferQueryMode preferQueryMode)
- Parameters:
preferQueryMode
- extended, simple, extendedForPrepared, or extendedCacheEveryting- See Also:
PGProperty.PREFER_QUERY_MODE
-
getAutosave
public AutoSave getAutosave()
- Returns:
- connection configuration regarding automatic per-query savepoints
- See Also:
PGProperty.AUTOSAVE
-
setAutosave
public void setAutosave(AutoSave autoSave)
- Parameters:
autoSave
- connection configuration regarding automatic per-query savepoints- See Also:
PGProperty.AUTOSAVE
-
getReWriteBatchedInserts
public boolean getReWriteBatchedInserts()
- Returns:
- boolean indicating property is enabled or not.
- See Also:
PGProperty.REWRITE_BATCHED_INSERTS
-
setReWriteBatchedInserts
public void setReWriteBatchedInserts(boolean reWrite)
- Parameters:
reWrite
- boolean value to set the property in the properties collection- See Also:
PGProperty.REWRITE_BATCHED_INSERTS
-
getXmlFactoryFactory
public java.lang.String getXmlFactoryFactory()
-
setXmlFactoryFactory
public void setXmlFactoryFactory(java.lang.String xmlFactoryFactory)
-
-