Package org.postgresql.ds.common
Class BaseDataSource
- java.lang.Object
-
- org.postgresql.ds.common.BaseDataSource
-
- All Implemented Interfaces:
javax.naming.Referenceable
,javax.sql.CommonDataSource
- Direct Known Subclasses:
PGConnectionPoolDataSource
,PGPoolingDataSource
,PGSimpleDataSource
,PGXADataSource
public abstract class BaseDataSource extends java.lang.Object implements javax.sql.CommonDataSource, 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 Deprecated 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()
boolean
getCleanupSavepoints()
see PGProperty#CLEANUP_SAVEPOINTSjava.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
getEscapeSyntaxCallMode()
java.lang.String
getGssLib()
boolean
getHideUnprivilegedObjects()
int
getHostRecheckSeconds()
java.lang.String
getJaasApplicationName()
boolean
getJaasLogin()
java.lang.String
getKerberosServerName()
boolean
getLoadBalanceHosts()
java.lang.String
getLoggerFile()
java.lang.String
getLoggerLevel()
int
getLoginTimeout()
boolean
getLogServerErrorDetail()
boolean
getLogUnclosedConnections()
java.io.PrintWriter
getLogWriter()
This implementation don't use a LogWriter.java.lang.String
getMaxResultBuffer()
java.lang.String
getOptions()
java.util.logging.Logger
getParentLogger()
java.lang.String
getPassword()
Gets the password to connect with by default.int
getPortNumber()
Deprecated.usegetPortNumbers()
int[]
getPortNumbers()
Gets the port(s) 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()
java.lang.String
getReadOnlyMode()
int
getReceiveBufferSize()
int
getRecvBufferSize()
javax.naming.Reference
getReference()
java.lang.String
getReplication()
boolean
getReWriteBatchedInserts()
int
getSendBufferSize()
java.lang.String
getServerName()
Deprecated.usegetServerNames()
java.lang.String[]
getServerNames()
Gets the name of the host(s) 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
getSslCert()
java.lang.String
getSslfactory()
java.lang.String
getSslfactoryarg()
java.lang.String
getSslFactoryArg()
java.lang.String
getSslhostnameverifier()
java.lang.String
getSslHostnameVerifier()
java.lang.String
getSslkey()
java.lang.String
getSslKey()
java.lang.String
getSslmode()
java.lang.String
getSslMode()
java.lang.String
getSslpassword()
java.lang.String
getSslPassword()
java.lang.String
getSslpasswordcallback()
java.lang.String
getSslPasswordCallback()
java.lang.String
getSslrootcert()
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
getURL()
Generates aDriverManager
URL from the other properties supplied.java.lang.String
getUser()
Gets the user to connect as by default.boolean
getUseSpNego()
void
initializeFrom(BaseDataSource source)
boolean
isAllowEncodingChanges()
boolean
isCleanupSavePoints()
boolean
isColumnSanitiserDisabled()
boolean
isDisableColumnSanitiser()
boolean
isLoadBalanceHosts()
boolean
isLogUnclosedConnections()
boolean
isReadOnly()
boolean
isReWriteBatchedInserts()
boolean
isSsl()
boolean
isTcpKeepAlive()
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
setCleanupSavepoints(boolean cleanupSavepoints)
see PGProperty#CLEANUP_SAVEPOINTSvoid
setCleanupSavePoints(boolean cleanupSavepoints)
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
setEscapeSyntaxCallMode(java.lang.String callMode)
void
setFromReference(javax.naming.Reference ref)
void
setGssLib(java.lang.String lib)
void
setHideUnprivilegedObjects(boolean hideUnprivileged)
void
setHostRecheckSeconds(int hostRecheckSeconds)
void
setJaasApplicationName(java.lang.String name)
void
setJaasLogin(boolean doLogin)
void
setKerberosServerName(java.lang.String serverName)
void
setLoadBalanceHosts(boolean loadBalanceHosts)
void
setLoggerFile(java.lang.String loggerFile)
void
setLoggerLevel(java.lang.String loggerLevel)
void
setLoginTimeout(int loginTimeout)
void
setLogServerErrorDetail(boolean enabled)
void
setLogUnclosedConnections(boolean enabled)
void
setLogWriter(java.io.PrintWriter printWriter)
This implementation don't use a LogWriter.void
setMaxResultBuffer(java.lang.String maxResultBuffer)
void
setOptions(java.lang.String options)
Set command line options for this connectionvoid
setPassword(java.lang.String password)
Sets the password to connect with by default.void
setPortNumber(int portNumber)
Deprecated.void
setPortNumbers(int[] portNumbers)
Sets the port(s) 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
setReadOnlyMode(java.lang.String mode)
void
setReceiveBufferSize(int nbytes)
void
setRecvBufferSize(int nbytes)
void
setReplication(java.lang.String replication)
void
setReWriteBatchedInserts(boolean reWrite)
void
setSendBufferSize(int nbytes)
void
setServerName(java.lang.String serverName)
Deprecated.void
setServerNames(java.lang.String[] serverNames)
Sets the name of the host(s) 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
setSslCert(java.lang.String file)
void
setSslfactory(java.lang.String classname)
void
setSslfactoryarg(java.lang.String arg)
void
setSslFactoryArg(java.lang.String arg)
void
setSslhostnameverifier(java.lang.String className)
void
setSslHostnameVerifier(java.lang.String className)
void
setSslkey(java.lang.String file)
void
setSslKey(java.lang.String file)
void
setSslmode(java.lang.String mode)
void
setSslMode(java.lang.String mode)
void
setSslpassword(java.lang.String sslpassword)
void
setSslPassword(java.lang.String password)
void
setSslpasswordcallback(java.lang.String className)
void
setSslPasswordCallback(java.lang.String className)
void
setSslrootcert(java.lang.String file)
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
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)
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()
This implementation don't use a LogWriter.- Specified by:
getLogWriter
in interfacejavax.sql.CommonDataSource
-
setLogWriter
public void setLogWriter(java.io.PrintWriter printWriter)
This implementation don't use a LogWriter.- Specified by:
setLogWriter
in interfacejavax.sql.CommonDataSource
- Parameters:
printWriter
- Not used
-
getServerName
@Deprecated public java.lang.String getServerName()
Deprecated.usegetServerNames()
Gets the name of the host the PostgreSQL database is running on.- Returns:
- name of the host the PostgreSQL database is running on
-
getServerNames
public java.lang.String[] getServerNames()
Gets the name of the host(s) the PostgreSQL database is running on.- Returns:
- name of the host(s) the PostgreSQL database is running on
-
setServerName
@Deprecated public void setServerName(java.lang.String serverName)
Deprecated.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 islocalhost
.- Parameters:
serverName
- name of the host the PostgreSQL database is running on
-
setServerNames
public void setServerNames(java.lang.String[] serverNames)
Sets the name of the host(s) the PostgreSQL database is running on. If this is changed, it will only affect future calls to getConnection. The default value islocalhost
.- Parameters:
serverNames
- name of the host(s) 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
@Deprecated public int getPortNumber()
Deprecated.usegetPortNumbers()
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.
-
getPortNumbers
public int[] getPortNumbers()
Gets the port(s) which the PostgreSQL server is listening on for TCP/IP connections.- Returns:
- The port(s), or 0 if the default port will be used.
-
setPortNumber
@Deprecated public void setPortNumber(int portNumber)
Deprecated.Sets 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
-
setPortNumbers
public void setPortNumbers(int[] portNumbers)
Sets the port(s) 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:
portNumbers
- port(s) which the PostgreSQL server is listening on for TCP/IP
-
getOptions
public java.lang.String getOptions()
- Returns:
- command line options for this connection
-
setOptions
public void setOptions(java.lang.String options)
Set command line options for this connection- Parameters:
options
- string to set options to
-
getLoginTimeout
public int getLoginTimeout()
- Specified by:
getLoginTimeout
in interfacejavax.sql.CommonDataSource
- Returns:
- login timeout
- See Also:
PGProperty.LOGIN_TIMEOUT
-
setLoginTimeout
public void setLoginTimeout(int loginTimeout)
- Specified by:
setLoginTimeout
in interfacejavax.sql.CommonDataSource
- 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
-
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
-
getReadOnlyMode
public java.lang.String getReadOnlyMode()
- Returns:
- The behavior when set read only
- See Also:
PGProperty.READ_ONLY_MODE
-
setReadOnlyMode
public void setReadOnlyMode(java.lang.String mode)
- Parameters:
mode
- the behavior when set read only- See Also:
PGProperty.READ_ONLY_MODE
-
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
-
getLogServerErrorDetail
public boolean getLogServerErrorDetail()
- Returns:
- true if driver should log include detail in server error messages
- See Also:
PGProperty.LOG_SERVER_ERROR_DETAIL
-
setLogServerErrorDetail
public void setLogServerErrorDetail(boolean enabled)
- Parameters:
enabled
- true if driver should include detail in server error messages- See Also:
PGProperty.LOG_SERVER_ERROR_DETAIL
-
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
-
getJaasLogin
public boolean getJaasLogin()
- Returns:
- true if perform JAAS login before GSS authentication
- See Also:
PGProperty.JAAS_LOGIN
-
setJaasLogin
public void setJaasLogin(boolean doLogin)
- Parameters:
doLogin
- true if perform JAAS login before GSS authentication- See Also:
PGProperty.JAAS_LOGIN
-
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
-
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
-
setReplication
public void setReplication(java.lang.String replication)
- Parameters:
replication
- set to 'database' for logical replication or 'true' for physical replication- See Also:
PGProperty.REPLICATION
-
getEscapeSyntaxCallMode
public java.lang.String getEscapeSyntaxCallMode()
- Returns:
- 'select', "callIfNoReturn', or 'call'
- See Also:
PGProperty.ESCAPE_SYNTAX_CALL_MODE
-
setEscapeSyntaxCallMode
public void setEscapeSyntaxCallMode(java.lang.String callMode)
- Parameters:
callMode
- the call mode to use for JDBC escape call syntax- See Also:
PGProperty.ESCAPE_SYNTAX_CALL_MODE
-
getReplication
public java.lang.String getReplication()
- Returns:
- null, 'database', or 'true
- See Also:
PGProperty.REPLICATION
-
getLoggerLevel
public java.lang.String getLoggerLevel()
- Returns:
- Logger Level of the JDBC Driver
- See Also:
PGProperty.LOGGER_LEVEL
-
setLoggerLevel
public void setLoggerLevel(java.lang.String loggerLevel)
- Parameters:
loggerLevel
- of the JDBC Driver- See Also:
PGProperty.LOGGER_LEVEL
-
getLoggerFile
public java.lang.String getLoggerFile()
- Returns:
- File output of the Logger.
- See Also:
PGProperty.LOGGER_FILE
-
setLoggerFile
public void setLoggerFile(java.lang.String loggerFile)
- Parameters:
loggerFile
- File output of the Logger.- See Also:
PGProperty.LOGGER_LEVEL
-
getUrl
public java.lang.String getUrl()
Generates aDriverManager
URL from the other properties supplied.- Returns:
DriverManager
URL from the other properties supplied
-
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
-
setURL
public void setURL(java.lang.String url)
Sets properties from aDriverManager
URL. Added to follow convention used in other DBMS.- 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
-
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 extendedCacheEverything- 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
-
getCleanupSavepoints
public boolean getCleanupSavepoints()
see PGProperty#CLEANUP_SAVEPOINTS- Returns:
- boolean indicating property set
-
setCleanupSavepoints
public void setCleanupSavepoints(boolean cleanupSavepoints)
see PGProperty#CLEANUP_SAVEPOINTS- Parameters:
cleanupSavepoints
- will cleanup savepoints after a successful transaction
-
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
-
getHideUnprivilegedObjects
public boolean getHideUnprivilegedObjects()
- Returns:
- boolean indicating property is enabled or not.
- See Also:
PGProperty.HIDE_UNPRIVILEGED_OBJECTS
-
setHideUnprivilegedObjects
public void setHideUnprivilegedObjects(boolean hideUnprivileged)
- Parameters:
hideUnprivileged
- boolean value to set the property in the properties collection- See Also:
PGProperty.HIDE_UNPRIVILEGED_OBJECTS
-
getMaxResultBuffer
public java.lang.String getMaxResultBuffer()
-
setMaxResultBuffer
public void setMaxResultBuffer(java.lang.String maxResultBuffer)
-
getParentLogger
public java.util.logging.Logger getParentLogger()
- Specified by:
getParentLogger
in interfacejavax.sql.CommonDataSource
-
isSsl
public boolean isSsl()
-
getSslfactoryarg
public java.lang.String getSslfactoryarg()
-
setSslfactoryarg
public void setSslfactoryarg(java.lang.String arg)
-
getSslcert
public java.lang.String getSslcert()
-
setSslcert
public void setSslcert(java.lang.String file)
-
getSslmode
public java.lang.String getSslmode()
-
setSslmode
public void setSslmode(java.lang.String mode)
-
getSslhostnameverifier
public java.lang.String getSslhostnameverifier()
-
setSslhostnameverifier
public void setSslhostnameverifier(java.lang.String className)
-
getSslkey
public java.lang.String getSslkey()
-
setSslkey
public void setSslkey(java.lang.String file)
-
getSslrootcert
public java.lang.String getSslrootcert()
-
setSslrootcert
public void setSslrootcert(java.lang.String file)
-
getSslpasswordcallback
public java.lang.String getSslpasswordcallback()
-
setSslpasswordcallback
public void setSslpasswordcallback(java.lang.String className)
-
getSslpassword
public java.lang.String getSslpassword()
-
setSslpassword
public void setSslpassword(java.lang.String sslpassword)
-
getRecvBufferSize
public int getRecvBufferSize()
-
setRecvBufferSize
public void setRecvBufferSize(int nbytes)
-
isAllowEncodingChanges
public boolean isAllowEncodingChanges()
-
isLogUnclosedConnections
public boolean isLogUnclosedConnections()
-
isTcpKeepAlive
public boolean isTcpKeepAlive()
-
isReadOnly
public boolean isReadOnly()
-
isDisableColumnSanitiser
public boolean isDisableColumnSanitiser()
-
isLoadBalanceHosts
public boolean isLoadBalanceHosts()
-
isCleanupSavePoints
public boolean isCleanupSavePoints()
-
setCleanupSavePoints
public void setCleanupSavePoints(boolean cleanupSavepoints)
-
isReWriteBatchedInserts
public boolean isReWriteBatchedInserts()
-
-