Interface BaseConnection

  • All Superinterfaces:
    java.lang.AutoCloseable, java.sql.Connection, PGConnection, java.sql.Wrapper
    All Known Implementing Classes:
    PgConnection

    public interface BaseConnection
    extends PGConnection, java.sql.Connection
    Driver-internal connection interface. Application code should not use this interface.
    • Method Detail

      • cancelQuery

        void cancelQuery()
                  throws java.sql.SQLException
        Cancel the current query executing on this connection.
        Specified by:
        cancelQuery in interface PGConnection
        Throws:
        java.sql.SQLException - if something goes wrong.
      • execSQLQuery

        java.sql.ResultSet execSQLQuery​(java.lang.String s)
                                 throws java.sql.SQLException
        Execute a SQL query that returns a single resultset. Never causes a new transaction to be started regardless of the autocommit setting.
        Parameters:
        s - the query to execute
        Returns:
        the (non-null) returned resultset
        Throws:
        java.sql.SQLException - if something goes wrong.
      • execSQLQuery

        java.sql.ResultSet execSQLQuery​(java.lang.String s,
                                        int resultSetType,
                                        int resultSetConcurrency)
                                 throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • execSQLUpdate

        void execSQLUpdate​(java.lang.String s)
                    throws java.sql.SQLException
        Execute a SQL query that does not return results. Never causes a new transaction to be started regardless of the autocommit setting.
        Parameters:
        s - the query to execute
        Throws:
        java.sql.SQLException - if something goes wrong.
      • getQueryExecutor

        QueryExecutor getQueryExecutor()
        Get the QueryExecutor implementation for this connection.
        Returns:
        the (non-null) executor
      • getReplicationProtocol

        ReplicationProtocol getReplicationProtocol()
        Internal protocol for work with physical and logical replication. Physical replication available only since PostgreSQL version 9.1. Logical replication available only since PostgreSQL version 9.4.
        Returns:
        not null replication protocol
      • getObject

        java.lang.Object getObject​(java.lang.String type,
                                   java.lang.String value,
                                   byte[] byteValue)
                            throws java.sql.SQLException

        Construct and return an appropriate object for the given type and value. This only considers the types registered via PGConnection.addDataType(String, Class) and PGConnection.addDataType(String, String).

        If no class is registered as handling the given type, then a generic PGobject instance is returned.

        Parameters:
        type - the backend typename
        value - the type-specific string representation of the value
        byteValue - the type-specific binary representation of the value
        Returns:
        an appropriate object; never null.
        Throws:
        java.sql.SQLException - if something goes wrong
      • getEncoding

        Encoding getEncoding()
                      throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • haveMinimumServerVersion

        boolean haveMinimumServerVersion​(int ver)

        Check if we have at least a particular server version.

        The input version is of the form xxyyzz, matching a PostgreSQL version like xx.yy.zz. So 9.0.12 is 90012.

        Parameters:
        ver - the server version to check, of the form xxyyzz eg 90401
        Returns:
        true if the server version is at least "ver".
      • haveMinimumServerVersion

        boolean haveMinimumServerVersion​(Version ver)

        Check if we have at least a particular server version.

        The input version is of the form xxyyzz, matching a PostgreSQL version like xx.yy.zz. So 9.0.12 is 90012.

        Parameters:
        ver - the server version to check
        Returns:
        true if the server version is at least "ver".
      • encodeString

        byte[] encodeString​(java.lang.String str)
                     throws java.sql.SQLException
        Encode a string using the database's client_encoding (usually UTF8, but can vary on older server versions). This is used when constructing synthetic resultsets (for example, in metadata methods).
        Parameters:
        str - the string to encode
        Returns:
        an encoded representation of the string
        Throws:
        java.sql.SQLException - if something goes wrong.
      • escapeString

        java.lang.String escapeString​(java.lang.String str)
                               throws java.sql.SQLException
        Escapes a string for use as string-literal within an SQL command. The method chooses the applicable escaping rules based on the value of getStandardConformingStrings().
        Parameters:
        str - a string value
        Returns:
        the escaped representation of the string
        Throws:
        java.sql.SQLException - if the string contains a \0 character
      • getStandardConformingStrings

        boolean getStandardConformingStrings()
        Returns whether the server treats string-literals according to the SQL standard or if it uses traditional PostgreSQL escaping rules. Versions up to 8.1 always treated backslashes as escape characters in string-literals. Since 8.2, this depends on the value of the standard_conforming_strings server variable.
        Returns:
        true if the server treats string literals according to the SQL standard
        See Also:
        QueryExecutor.getStandardConformingStrings()
      • getLogger

        java.util.logging.Logger getLogger()
      • getStringVarcharFlag

        boolean getStringVarcharFlag()
      • getTransactionState

        TransactionState getTransactionState()
        Get the current transaction state of this connection.
        Returns:
        current transaction state of this connection
      • binaryTransferSend

        boolean binaryTransferSend​(int oid)
        Returns true if value for the given oid should be sent using binary transfer. False if value should be sent using text transfer.
        Parameters:
        oid - The oid to check.
        Returns:
        True for binary transfer, false for text transfer.
      • isColumnSanitiserDisabled

        boolean isColumnSanitiserDisabled()
        Return whether to disable column name sanitation.
        Returns:
        true column sanitizer is disabled
      • addTimerTask

        void addTimerTask​(java.util.TimerTask timerTask,
                          long milliSeconds)
        Schedule a TimerTask for later execution. The task will be scheduled with the shared Timer for this connection.
        Parameters:
        timerTask - timer task to schedule
        milliSeconds - delay in milliseconds
      • purgeTimerTasks

        void purgeTimerTasks()
        Invoke purge() on the underlying shared Timer so that internal resources will be released.
      • createQuery

        CachedQuery createQuery​(java.lang.String sql,
                                boolean escapeProcessing,
                                boolean isParameterized,
                                java.lang.String... columnNames)
                         throws java.sql.SQLException
        Throws:
        java.sql.SQLException
      • setFlushCacheOnDeallocate

        void setFlushCacheOnDeallocate​(boolean flushCacheOnDeallocate)
        By default, the connection resets statement cache in case deallocate all/discard all message is observed. This API allows to disable that feature for testing purposes.
        Parameters:
        flushCacheOnDeallocate - true if statement cache should be reset when "deallocate/discard" message observed
      • hintReadOnly

        boolean hintReadOnly()
        Indicates if statements to backend should be hinted as read only.
        Returns:
        Indication if hints to backend (such as when transaction begins) should be read only.
        See Also:
        PGProperty.READ_ONLY_MODE