Class BaseDataSource

java.lang.Object
org.postgresql.ds.common.BaseDataSource
All Implemented Interfaces:
Referenceable, CommonDataSource
Direct Known Subclasses:
PGConnectionPoolDataSource, PGPoolingDataSource, PGSimpleDataSource, PGXADataSource

public abstract class BaseDataSource extends Object implements CommonDataSource, Referenceable
Base class for data sources and related classes.
  • Field Details

    • LOGGER

      private static final Logger LOGGER
    • serverNames

      private String[] serverNames
    • databaseName

      private String databaseName
    • user

      private String user
    • password

      private String password
    • portNumbers

      private int[] portNumbers
    • properties

      private Properties properties
  • Constructor Details

    • BaseDataSource

      public BaseDataSource()
  • Method Details

    • getConnection

      public Connection getConnection() throws 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:
      SQLException - Occurs when the database connection cannot be established.
    • getConnection

      public Connection getConnection(String user, String password) throws 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 - user
      password - password
      Returns:
      A valid database connection.
      Throws:
      SQLException - Occurs when the database connection cannot be established.
    • getLogWriter

      public PrintWriter getLogWriter()
      This implementation don't use a LogWriter.
      Specified by:
      getLogWriter in interface CommonDataSource
    • setLogWriter

      public void setLogWriter(PrintWriter printWriter)
      This implementation don't use a LogWriter.
      Specified by:
      setLogWriter in interface CommonDataSource
      Parameters:
      printWriter - Not used
    • getServerName

      @Deprecated public String getServerName()
      Deprecated.
      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 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(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 is localhost.
      Parameters:
      serverName - name of the host the PostgreSQL database is running on
    • setServerNames

      public void setServerNames(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 is localhost.
      Parameters:
      serverNames - name of the host(s) the PostgreSQL database is running on
    • getDatabaseName

      public 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(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 String getDescription()
      Gets a description of this DataSource-ish thing. Must be customized by subclasses.
      Returns:
      description of this DataSource-ish thing
    • getUser

      public 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(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 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(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.
      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 String getOptions()
      Returns:
      command line options for this connection
    • setOptions

      public void setOptions(String options)
      Set command line options for this connection
      Parameters:
      options - string to set options to
    • getLoginTimeout

      public int getLoginTimeout()
      Specified by:
      getLoginTimeout in interface CommonDataSource
      Returns:
      login timeout
      See Also:
    • setLoginTimeout

      public void setLoginTimeout(int loginTimeout)
      Specified by:
      setLoginTimeout in interface CommonDataSource
      Parameters:
      loginTimeout - login timeout
      See Also:
    • getConnectTimeout

      public int getConnectTimeout()
      Returns:
      connect timeout
      See Also:
    • setConnectTimeout

      public void setConnectTimeout(int connectTimeout)
      Parameters:
      connectTimeout - connect timeout
      See Also:
    • getGssResponseTimeout

      public int getGssResponseTimeout()
      Returns:
      GSS ResponseTimeout
      See Also:
    • setGssResponseTimeout

      public void setGssResponseTimeout(int gssResponseTimeout)
      Parameters:
      gssResponseTimeout - gss response timeout
      See Also:
    • getSslResponseTimeout

      public int getSslResponseTimeout()
      Returns:
      SSL ResponseTimeout
      See Also:
    • setSslResponseTimeout

      public void setSslResponseTimeout(int sslResponseTimeout)
      Parameters:
      sslResponseTimeout - ssl response timeout
      See Also:
    • getProtocolVersion

      public int getProtocolVersion()
      Returns:
      protocol version
      See Also:
    • setProtocolVersion

      public void setProtocolVersion(int protocolVersion)
      Parameters:
      protocolVersion - protocol version
      See Also:
    • getQuoteReturningIdentifiers

      public boolean getQuoteReturningIdentifiers()
      Returns:
      quoteReturningIdentifiers
      See Also:
    • setQuoteReturningIdentifiers

      public void setQuoteReturningIdentifiers(boolean quoteIdentifiers)
      Parameters:
      quoteIdentifiers - indicate whether to quote identifiers
      See Also:
    • getReceiveBufferSize

      public int getReceiveBufferSize()
      Returns:
      receive buffer size
      See Also:
    • setReceiveBufferSize

      public void setReceiveBufferSize(int nbytes)
      Parameters:
      nbytes - receive buffer size
      See Also:
    • getSendBufferSize

      public int getSendBufferSize()
      Returns:
      send buffer size
      See Also:
    • setSendBufferSize

      public void setSendBufferSize(int nbytes)
      Parameters:
      nbytes - send buffer size
      See Also:
    • getMaxSendBufferSize

      public int getMaxSendBufferSize()
      Returns:
      send max buffer size
      See Also:
    • setMaxSendBufferSize

      public void setMaxSendBufferSize(int nbytes)
      Parameters:
      nbytes - send max buffer size
      See Also:
    • setPrepareThreshold

      public void setPrepareThreshold(int count)
      Parameters:
      count - prepare threshold
      See Also:
    • getPrepareThreshold

      public int getPrepareThreshold()
      Returns:
      prepare threshold
      See Also:
    • getPreparedStatementCacheQueries

      public int getPreparedStatementCacheQueries()
      Returns:
      prepared statement cache size (number of statements per connection)
      See Also:
    • setPreparedStatementCacheQueries

      public void setPreparedStatementCacheQueries(int cacheSize)
      Parameters:
      cacheSize - prepared statement cache size (number of statements per connection)
      See Also:
    • getPreparedStatementCacheSizeMiB

      public int getPreparedStatementCacheSizeMiB()
      Returns:
      prepared statement cache size (number of megabytes per connection)
      See Also:
    • setPreparedStatementCacheSizeMiB

      public void setPreparedStatementCacheSizeMiB(int cacheSize)
      Parameters:
      cacheSize - statement cache size (number of megabytes per connection)
      See Also:
    • getDatabaseMetadataCacheFields

      public int getDatabaseMetadataCacheFields()
      Returns:
      database metadata cache fields size (number of fields cached per connection)
      See Also:
    • setDatabaseMetadataCacheFields

      public void setDatabaseMetadataCacheFields(int cacheSize)
      Parameters:
      cacheSize - database metadata cache fields size (number of fields cached per connection)
      See Also:
    • getDatabaseMetadataCacheFieldsMiB

      public int getDatabaseMetadataCacheFieldsMiB()
      Returns:
      database metadata cache fields size (number of megabytes per connection)
      See Also:
    • setDatabaseMetadataCacheFieldsMiB

      public void setDatabaseMetadataCacheFieldsMiB(int cacheSize)
      Parameters:
      cacheSize - database metadata cache fields size (number of megabytes per connection)
      See Also:
    • setDefaultRowFetchSize

      public void setDefaultRowFetchSize(int fetchSize)
      Parameters:
      fetchSize - default fetch size
      See Also:
    • getDefaultRowFetchSize

      public int getDefaultRowFetchSize()
      Returns:
      default fetch size
      See Also:
    • setUnknownLength

      public void setUnknownLength(int unknownLength)
      Parameters:
      unknownLength - unknown length
      See Also:
    • getUnknownLength

      public int getUnknownLength()
      Returns:
      unknown length
      See Also:
    • setSocketTimeout

      public void setSocketTimeout(int seconds)
      Parameters:
      seconds - socket timeout
      See Also:
    • getSocketTimeout

      public int getSocketTimeout()
      Returns:
      socket timeout
      See Also:
    • setCancelSignalTimeout

      public void setCancelSignalTimeout(int seconds)
      Parameters:
      seconds - timeout that is used for sending cancel command
      See Also:
    • getCancelSignalTimeout

      public int getCancelSignalTimeout()
      Returns:
      timeout that is used for sending cancel command in seconds
      See Also:
    • setSsl

      public void setSsl(boolean enabled)
      Parameters:
      enabled - if SSL is enabled
      See Also:
    • getSsl

      public boolean getSsl()
      Returns:
      true if SSL is enabled
      See Also:
    • setSslfactory

      public void setSslfactory(String classname)
      Parameters:
      classname - SSL factory class name
      See Also:
    • getSslfactory

      public String getSslfactory()
      Returns:
      SSL factory class name
      See Also:
    • getSslMode

      public String getSslMode()
      Returns:
      SSL mode
      See Also:
    • setSslMode

      public void setSslMode(String mode)
      Parameters:
      mode - SSL mode
      See Also:
    • getSslFactoryArg

      public String getSslFactoryArg()
      Returns:
      SSL mode
      See Also:
    • setSslFactoryArg

      public void setSslFactoryArg(String arg)
      Parameters:
      arg - argument forwarded to SSL factory
      See Also:
    • getSslHostnameVerifier

      public String getSslHostnameVerifier()
      Returns:
      argument forwarded to SSL factory
      See Also:
    • setSslHostnameVerifier

      public void setSslHostnameVerifier(String className)
      Parameters:
      className - SSL hostname verifier
      See Also:
    • getSslCert

      public String getSslCert()
      Returns:
      className SSL hostname verifier
      See Also:
    • setSslCert

      public void setSslCert(String file)
      Parameters:
      file - SSL certificate
      See Also:
    • getSslKey

      public String getSslKey()
      Returns:
      SSL certificate
      See Also:
    • setSslKey

      public void setSslKey(String file)
      Parameters:
      file - SSL key
      See Also:
    • getSslRootCert

      public String getSslRootCert()
      Returns:
      SSL root certificate
      See Also:
    • setSslRootCert

      public void setSslRootCert(String file)
      Parameters:
      file - SSL root certificate
      See Also:
    • setSslNegotiation

      public void setSslNegotiation(String sslNegotiation)
      Parameters:
      sslNegotiation - one of SSLNegotiation.POSTGRES or SSLNegotiation.DIRECT
      See Also:
    • getSslNegotiation

      public String getSslNegotiation()
      Returns:
      SSL Negotiation scheme
      See Also:
    • getSslPassword

      public String getSslPassword()
      Returns:
      SSL password
      See Also:
    • setSslPassword

      public void setSslPassword(String password)
      Parameters:
      password - SSL password
      See Also:
    • getSslPasswordCallback

      public String getSslPasswordCallback()
      Returns:
      SSL password callback
      See Also:
    • setSslPasswordCallback

      public void setSslPasswordCallback(String className)
      Parameters:
      className - SSL password callback class name
      See Also:
    • setApplicationName

      public void setApplicationName(String applicationName)
      Parameters:
      applicationName - application name
      See Also:
    • getApplicationName

      public String getApplicationName()
      Returns:
      application name
      See Also:
    • setTargetServerType

      public void setTargetServerType(String targetServerType)
      Parameters:
      targetServerType - target server type
      See Also:
    • getTargetServerType

      public String getTargetServerType()
      Returns:
      target server type
      See Also:
    • setLoadBalanceHosts

      public void setLoadBalanceHosts(boolean loadBalanceHosts)
      Parameters:
      loadBalanceHosts - load balance hosts
      See Also:
    • getLoadBalanceHosts

      public boolean getLoadBalanceHosts()
      Returns:
      load balance hosts
      See Also:
    • setHostRecheckSeconds

      public void setHostRecheckSeconds(int hostRecheckSeconds)
      Parameters:
      hostRecheckSeconds - host recheck seconds
      See Also:
    • getHostRecheckSeconds

      public int getHostRecheckSeconds()
      Returns:
      host recheck seconds
      See Also:
    • setTcpKeepAlive

      public void setTcpKeepAlive(boolean enabled)
      Parameters:
      enabled - if TCP keep alive should be enabled
      See Also:
    • getTcpKeepAlive

      public boolean getTcpKeepAlive()
      Returns:
      true if TCP keep alive is enabled
      See Also:
    • setTcpNoDelay

      public void setTcpNoDelay(boolean enabled)
      Parameters:
      enabled - if TCP no delay should be enabled
      See Also:
    • getTcpNoDelay

      public boolean getTcpNoDelay()
      Returns:
      true if TCP no delay is enabled
      See Also:
    • setBinaryTransfer

      public void setBinaryTransfer(boolean enabled)
      Parameters:
      enabled - if binary transfer should be enabled
      See Also:
    • getBinaryTransfer

      public boolean getBinaryTransfer()
      Returns:
      true if binary transfer is enabled
      See Also:
    • setBinaryTransferEnable

      public void setBinaryTransferEnable(String oidList)
      Parameters:
      oidList - list of OIDs that are allowed to use binary transfer
      See Also:
    • getBinaryTransferEnable

      public String getBinaryTransferEnable()
      Returns:
      list of OIDs that are allowed to use binary transfer
      See Also:
    • setBinaryTransferDisable

      public void setBinaryTransferDisable(String oidList)
      Parameters:
      oidList - list of OIDs that are not allowed to use binary transfer
      See Also:
    • getBinaryTransferDisable

      public String getBinaryTransferDisable()
      Returns:
      list of OIDs that are not allowed to use binary transfer
      See Also:
    • getStringType

      public String getStringType()
      Returns:
      string type
      See Also:
    • setStringType

      public void setStringType(String stringType)
      Parameters:
      stringType - string type
      See Also:
    • isColumnSanitiserDisabled

      public boolean isColumnSanitiserDisabled()
      Returns:
      true if column sanitizer is disabled
      See Also:
    • getDisableColumnSanitiser

      public boolean getDisableColumnSanitiser()
      Returns:
      true if column sanitizer is disabled
      See Also:
    • setDisableColumnSanitiser

      public void setDisableColumnSanitiser(boolean disableColumnSanitiser)
      Parameters:
      disableColumnSanitiser - if column sanitizer should be disabled
      See Also:
    • getCurrentSchema

      public String getCurrentSchema()
      Returns:
      current schema
      See Also:
    • setCurrentSchema

      public void setCurrentSchema(String currentSchema)
      Parameters:
      currentSchema - current schema
      See Also:
    • getReadOnly

      public boolean getReadOnly()
      Returns:
      true if connection is readonly
      See Also:
    • setReadOnly

      public void setReadOnly(boolean readOnly)
      Parameters:
      readOnly - if connection should be readonly
      See Also:
    • getReadOnlyMode

      public String getReadOnlyMode()
      Returns:
      The behavior when set read only
      See Also:
    • setReadOnlyMode

      public void setReadOnlyMode(String mode)
      Parameters:
      mode - the behavior when set read only
      See Also:
    • getLogUnclosedConnections

      public boolean getLogUnclosedConnections()
      Returns:
      true if driver should log unclosed connections
      See Also:
    • setLogUnclosedConnections

      public void setLogUnclosedConnections(boolean enabled)
      Parameters:
      enabled - true if driver should log unclosed connections
      See Also:
    • getLogServerErrorDetail

      public boolean getLogServerErrorDetail()
      Returns:
      true if driver should log include detail in server error messages
      See Also:
    • setLogServerErrorDetail

      public void setLogServerErrorDetail(boolean enabled)
      Parameters:
      enabled - true if driver should include detail in server error messages
      See Also:
    • getAssumeMinServerVersion

      public String getAssumeMinServerVersion()
      Returns:
      assumed minimal server version
      See Also:
    • setAssumeMinServerVersion

      public void setAssumeMinServerVersion(String minVersion)
      Parameters:
      minVersion - assumed minimal server version
      See Also:
    • getGroupStartupParameters

      public boolean getGroupStartupParameters()
      This is important in pool-by-transaction scenarios in order to make sure that all the statements reaches the same connection that is being initialized. If set then we will group the startup parameters in a transaction
      Returns:
      whether to group startup parameters or not
      See Also:
    • setGroupStartupParameters

      public void setGroupStartupParameters(boolean groupStartupParameters)
      Parameters:
      groupStartupParameters - whether to group startup Parameters in a transaction or not
      See Also:
    • getJaasApplicationName

      public String getJaasApplicationName()
      Returns:
      JAAS application name
      See Also:
    • setJaasApplicationName

      public void setJaasApplicationName(String name)
      Parameters:
      name - JAAS application name
      See Also:
    • getJaasLogin

      public boolean getJaasLogin()
      Returns:
      true if perform JAAS login before GSS authentication
      See Also:
    • setJaasLogin

      public void setJaasLogin(boolean doLogin)
      Parameters:
      doLogin - true if perform JAAS login before GSS authentication
      See Also:
    • getKerberosServerName

      public String getKerberosServerName()
      Returns:
      Kerberos server name
      See Also:
    • setKerberosServerName

      public void setKerberosServerName(String serverName)
      Parameters:
      serverName - Kerberos server name
      See Also:
    • getUseSpNego

      public boolean getUseSpNego()
      Returns:
      true if use SPNEGO
      See Also:
    • setUseSpNego

      public void setUseSpNego(boolean use)
      Parameters:
      use - true if use SPNEGO
      See Also:
    • getGssLib

      public String getGssLib()
      Returns:
      GSS mode: auto, sspi, or gssapi
      See Also:
    • setGssLib

      public void setGssLib(String lib)
      Parameters:
      lib - GSS mode: auto, sspi, or gssapi
      See Also:
    • getGssEncMode

      public String getGssEncMode()
      Returns:
      GSS encryption mode: disable, prefer or require
    • setGssEncMode

      public void setGssEncMode(String mode)
      Parameters:
      mode - encryption mode: disable, prefer or require
    • getSspiServiceClass

      public String getSspiServiceClass()
      Returns:
      SSPI service class
      See Also:
    • setSspiServiceClass

      public void setSspiServiceClass(String serviceClass)
      Parameters:
      serviceClass - SSPI service class
      See Also:
    • getAllowEncodingChanges

      public boolean getAllowEncodingChanges()
      Returns:
      if connection allows encoding changes
      See Also:
    • setAllowEncodingChanges

      public void setAllowEncodingChanges(boolean allow)
      Parameters:
      allow - if connection allows encoding changes
      See Also:
    • getSocketFactory

      public String getSocketFactory()
      Returns:
      socket factory class name
      See Also:
    • setSocketFactory

      public void setSocketFactory(String socketFactoryClassName)
      Parameters:
      socketFactoryClassName - socket factory class name
      See Also:
    • getSocketFactoryArg

      public String getSocketFactoryArg()
      Returns:
      socket factory argument
      See Also:
    • setSocketFactoryArg

      public void setSocketFactoryArg(String socketFactoryArg)
      Parameters:
      socketFactoryArg - socket factory argument
      See Also:
    • setReplication

      public void setReplication(String replication)
      Parameters:
      replication - set to 'database' for logical replication or 'true' for physical replication
      See Also:
    • getEscapeSyntaxCallMode

      public String getEscapeSyntaxCallMode()
      Returns:
      'select', "callIfNoReturn', or 'call'
      See Also:
    • setEscapeSyntaxCallMode

      public void setEscapeSyntaxCallMode(String callMode)
      Parameters:
      callMode - the call mode to use for JDBC escape call syntax
      See Also:
    • getReplication

      public String getReplication()
      Returns:
      null, 'database', or 'true
      See Also:
    • getLocalSocketAddress

      public String getLocalSocketAddress()
      Returns:
      the localSocketAddress
      See Also:
    • setLocalSocketAddress

      public void setLocalSocketAddress(String localSocketAddress)
      Parameters:
      localSocketAddress - local address to bind client side to
      See Also:
    • getLoggerLevel

      @Deprecated public String getLoggerLevel()
      Deprecated.
      Configure via java.util.logging
      This property is no longer used by the driver and will be ignored.
      Returns:
      loggerLevel in properties
    • setLoggerLevel

      @Deprecated public void setLoggerLevel(String loggerLevel)
      Deprecated.
      Configure via java.util.logging
      This property is no longer used by the driver and will be ignored.
      Parameters:
      loggerLevel - loggerLevel to set, will be ignored
    • getLoggerFile

      @Deprecated public String getLoggerFile()
      Deprecated.
      Configure via java.util.logging
      This property is no longer used by the driver and will be ignored.
      Returns:
      loggerFile in properties
    • setLoggerFile

      @Deprecated public void setLoggerFile(String loggerFile)
      Deprecated.
      Configure via java.util.logging
      This property is no longer used by the driver and will be ignored.
      Parameters:
      loggerFile - will be ignored
    • getChannelBinding

      public String getChannelBinding()
      Returns:
      Channel binding option
      See Also:
    • setChannelBinding

      public void setChannelBinding(String channelBinding)
      Parameters:
      channelBinding - Channel binding option
      See Also:
    • getUrl

      public String getUrl()
      Generates a DriverManager URL from the other properties supplied.
      Returns:
      DriverManager URL from the other properties supplied
    • getURL

      public String getURL()
      Generates a DriverManager URL from the other properties supplied.
      Returns:
      DriverManager URL from the other properties supplied
    • setUrl

      public void setUrl(String url)
      Sets properties from a DriverManager URL.
      Parameters:
      url - properties to set
    • setURL

      public void setURL(String url)
      Sets properties from a DriverManager URL. Added to follow convention used in other DBMS.
      Parameters:
      url - properties to set
    • getAuthenticationPluginClassName

      public String getAuthenticationPluginClassName()
      Returns:
      the class name to use for the Authentication Plugin. This can be null in which case the default password authentication plugin will be used
    • setAuthenticationPluginClassName

      public void setAuthenticationPluginClassName(String className)
      Parameters:
      className - name of a class which implements AuthenticationPlugin This class will be used to get the encoded bytes to be sent to the server as the password to authenticate the user.
    • getProperty

      public String getProperty(String name) throws SQLException
      Throws:
      SQLException
    • setProperty

      public void setProperty(String name, String value) throws SQLException
      Throws:
      SQLException
    • getProperty

      public String getProperty(PGProperty property)
    • setProperty

      public void setProperty(PGProperty property, String value)
    • createReference

      protected Reference createReference()
      Generates a reference using the appropriate object factory.
      Returns:
      reference using the appropriate object factory
    • getReference

      public Reference getReference() throws NamingException
      Specified by:
      getReference in interface Referenceable
      Throws:
      NamingException
    • setFromReference

      public void setFromReference(Reference ref)
    • getReferenceProperty

      private static String getReferenceProperty(Reference ref, String propertyName)
    • writeBaseObject

      protected void writeBaseObject(ObjectOutputStream out) throws IOException
      Throws:
      IOException
    • readBaseObject

      protected void readBaseObject(ObjectInputStream in) throws IOException, ClassNotFoundException
      Throws:
      IOException
      ClassNotFoundException
    • initializeFrom

      public void initializeFrom(BaseDataSource source) throws IOException, ClassNotFoundException
      Throws:
      IOException
      ClassNotFoundException
    • getPreferQueryMode

      public PreferQueryMode getPreferQueryMode()
      Returns:
      preferred query execution mode
      See Also:
    • setPreferQueryMode

      public void setPreferQueryMode(PreferQueryMode preferQueryMode)
      Parameters:
      preferQueryMode - extended, simple, extendedForPrepared, or extendedCacheEverything
      See Also:
    • getAutosave

      public AutoSave getAutosave()
      Returns:
      connection configuration regarding automatic per-query savepoints
      See Also:
    • setAutosave

      public void setAutosave(AutoSave autoSave)
      Parameters:
      autoSave - connection configuration regarding automatic per-query savepoints
      See Also:
    • 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:
    • setReWriteBatchedInserts

      public void setReWriteBatchedInserts(boolean reWrite)
      Parameters:
      reWrite - boolean value to set the property in the properties collection
      See Also:
    • getHideUnprivilegedObjects

      public boolean getHideUnprivilegedObjects()
      Returns:
      boolean indicating property is enabled or not.
      See Also:
    • setHideUnprivilegedObjects

      public void setHideUnprivilegedObjects(boolean hideUnprivileged)
      Parameters:
      hideUnprivileged - boolean value to set the property in the properties collection
      See Also:
    • getMaxResultBuffer

      public String getMaxResultBuffer()
    • setMaxResultBuffer

      public void setMaxResultBuffer(String maxResultBuffer)
    • getAdaptiveFetch

      public boolean getAdaptiveFetch()
    • setAdaptiveFetch

      public void setAdaptiveFetch(boolean adaptiveFetch)
    • getAdaptiveFetchMaximum

      public int getAdaptiveFetchMaximum()
    • setAdaptiveFetchMaximum

      public void setAdaptiveFetchMaximum(int adaptiveFetchMaximum)
    • getAdaptiveFetchMinimum

      public int getAdaptiveFetchMinimum()
    • setAdaptiveFetchMinimum

      public void setAdaptiveFetchMinimum(int adaptiveFetchMinimum)
    • getParentLogger

      public Logger getParentLogger()
      Specified by:
      getParentLogger in interface CommonDataSource
    • getXmlFactoryFactory

      public String getXmlFactoryFactory()
    • setXmlFactoryFactory

      public void setXmlFactoryFactory(String xmlFactoryFactory)
    • isSsl

      public boolean isSsl()
    • getSslfactoryarg

      public String getSslfactoryarg()
    • setSslfactoryarg

      public void setSslfactoryarg(String arg)
    • getSslcert

      public String getSslcert()
    • setSslcert

      public void setSslcert(String file)
    • getSslmode

      public String getSslmode()
    • setSslmode

      public void setSslmode(String mode)
    • getSslhostnameverifier

      public String getSslhostnameverifier()
    • setSslhostnameverifier

      public void setSslhostnameverifier(String className)
    • getSslkey

      public String getSslkey()
    • setSslkey

      public void setSslkey(String file)
    • getSslrootcert

      public String getSslrootcert()
    • setSslrootcert

      public void setSslrootcert(String file)
    • getSslpasswordcallback

      public String getSslpasswordcallback()
    • setSslpasswordcallback

      public void setSslpasswordcallback(String className)
    • getSslpassword

      public String getSslpassword()
    • setSslpassword

      public void setSslpassword(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()