Class BrokeredConnection

  • All Implemented Interfaces:
    java.lang.AutoCloseable, java.sql.Connection, java.sql.Wrapper, EngineConnection
    Direct Known Subclasses:
    BrokeredConnection42

    public class BrokeredConnection
    extends java.lang.Object
    implements EngineConnection
    This is a rudimentary connection that delegates EVERYTHING to Connection.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.lang.String connString  
      (package private) BrokeredConnectionControl control  
      protected boolean isClosed  
      private boolean stateAutoCommit  
      (package private) int stateHoldability  
      private int stateIsolationLevel
      Maintain state as seen by this Connection handle, not the state of the underlying Connection it is attached to.
      private boolean stateReadOnly  
      • Fields inherited from interface java.sql.Connection

        TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void abort​(java.util.concurrent.Executor executor)  
      void addWarning​(java.sql.SQLWarning w)
      Add a SQLWarning to this Connection object.
      void clearWarnings()  
      void close()  
      void commit()  
      java.sql.Array createArrayOf​(java.lang.String typeName, java.lang.Object[] elements)  
      java.sql.Blob createBlob()
      Constructs an object that implements the Blob interface.
      java.sql.Clob createClob()
      Constructs an object that implements the Clob interface.
      java.sql.NClob createNClob()  
      java.sql.SQLXML createSQLXML()  
      java.sql.Statement createStatement()  
      java.sql.Statement createStatement​(int resultSetType, int resultSetConcurrency)  
      java.sql.Statement createStatement​(int resultSetType, int resultSetConcurrency, int resultSetHoldability)  
      java.sql.Struct createStruct​(java.lang.String typeName, java.lang.Object[] attributes)  
      boolean getAutoCommit()  
      java.lang.String getCatalog()  
      java.util.Properties getClientInfo()
      getClientInfo forwards to the real connection.
      java.lang.String getClientInfo​(java.lang.String name)
      getClientInfo forwards to the real connection.
      java.lang.String getCurrentSchemaName()
      Obtain the name of the current schema.
      int getHoldability()
      Get the holdability for statements created by this connection when holdability is not passed in.
      void getIsolationUptoDate()
      Isolation level state in BrokeredConnection can get out of sync if the isolation is set using SQL rather than JDBC.
      java.lang.Object getLOBMapping​(int key)
      Get the LOB reference corresponding to the locator.
      java.sql.DatabaseMetaData getMetaData()  
      int getNetworkTimeout()  
      int getPrepareIsolation()
      get the isolation level that is currently being used to prepare statements (used for network server)
      (package private) EngineConnection getRealConnection()
      A little indirection for getting the real connection.
      java.lang.String getSchema()
      Get the name of the current schema.
      int getTransactionIsolation()  
      java.util.Map<java.lang.String,​java.lang.Class<?>> getTypeMap()  
      java.sql.SQLWarning getWarnings()  
      boolean isClosed()  
      boolean isInGlobalTransaction()
      Is this a global transaction
      boolean isReadOnly()  
      boolean isValid​(int timeout)
      Checks if the connection has not been closed and is still valid.
      boolean isWrapperFor​(java.lang.Class<?> iface)
      Returns false unless iface is implemented.
      java.lang.String nativeSQL​(java.lang.String sql)  
      BrokeredStatement newBrokeredStatement​(BrokeredStatementControl statementControl)  
      BrokeredCallableStatement newBrokeredStatement​(BrokeredStatementControl statementControl, java.lang.String sql)  
      BrokeredPreparedStatement newBrokeredStatement​(BrokeredStatementControl statementControl, java.lang.String sql, java.lang.Object generatedKeys)  
      (package private) java.sql.SQLException noCurrentConnection()
      Generate an exception reporting that there is no current connection.
      (package private) void notifyException​(java.sql.SQLException sqle)  
      java.sql.CallableStatement prepareCall​(java.lang.String sql)  
      java.sql.CallableStatement prepareCall​(java.lang.String sql, int resultSetType, int resultSetConcurrency)  
      java.sql.CallableStatement prepareCall​(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)  
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql)  
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql, int autoGeneratedKeys)  
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql, int[] columnIndexes)  
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql, int resultSetType, int resultSetConcurrency)  
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
      Prepare statement with explicit holdability.
      java.sql.PreparedStatement prepareStatement​(java.lang.String sql, java.lang.String[] columnNames)  
      void releaseSavepoint​(java.sql.Savepoint savepoint)  
      void resetFromPool()
      Resets the connection before it is returned from a PooledConnection to a new application request (wrapped by a BrokeredConnection).
      void rollback()  
      void rollback​(java.sql.Savepoint savepoint)  
      void setAutoCommit​(boolean autoCommit)  
      void setCatalog​(java.lang.String catalog)  
      void setClientInfo​(java.lang.String name, java.lang.String value)
      setClientInfo forwards to the real connection.
      void setClientInfo​(java.util.Properties properties)
      setClientInfo forwards to the real connection.
      void setDrdaID​(java.lang.String drdaID)
      set the DrdaId for this connection.
      void setHoldability​(int holdability)  
      void setNetworkTimeout​(java.util.concurrent.Executor executor, int milliseconds)  
      void setPrepareIsolation​(int level)
      Set the internal isolation level to use for preparing statements.
      void setReadOnly​(boolean readOnly)  
      java.sql.Savepoint setSavepoint()  
      java.sql.Savepoint setSavepoint​(java.lang.String name)  
      void setSchema​(java.lang.String schemaName)
      Set the default schema for the Connection.
      void setState​(boolean complete)
      Set the state of the underlying connection according to the state of this connection's view of state.
      void setTransactionIsolation​(int level)  
      void setTypeMap​(java.util.Map<java.lang.String,​java.lang.Class<?>> map)  
      (package private) int statementHoldabilityCheck​(int resultSetHoldability)
      Check the result set holdability when creating a statement object.
      void syncState()
      Sync up the state of the underlying connection with the state of this new handle.
      java.lang.String toString()
      Get the string representation for this connection.
      <T> T unwrap​(java.lang.Class<T> iface)
      Returns this if this class implements the interface.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface java.sql.Connection

        beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid
    • Field Detail

      • stateHoldability

        int stateHoldability
      • isClosed

        protected boolean isClosed
      • connString

        private java.lang.String connString
      • stateIsolationLevel

        private int stateIsolationLevel
        Maintain state as seen by this Connection handle, not the state of the underlying Connection it is attached to.
      • stateReadOnly

        private boolean stateReadOnly
      • stateAutoCommit

        private boolean stateAutoCommit
    • Constructor Detail

      • BrokeredConnection

        public BrokeredConnection​(BrokeredConnectionControl control)
                           throws java.sql.SQLException
        Throws:
        java.sql.SQLException
    • Method Detail

      • setAutoCommit

        public final void setAutoCommit​(boolean autoCommit)
                                 throws java.sql.SQLException
        Specified by:
        setAutoCommit in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getAutoCommit

        public final boolean getAutoCommit()
                                    throws java.sql.SQLException
        Specified by:
        getAutoCommit in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createStatement

        public final java.sql.Statement createStatement()
                                                 throws java.sql.SQLException
        Specified by:
        createStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql)
                                                          throws java.sql.SQLException
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareCall

        public final java.sql.CallableStatement prepareCall​(java.lang.String sql)
                                                     throws java.sql.SQLException
        Specified by:
        prepareCall in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • nativeSQL

        public final java.lang.String nativeSQL​(java.lang.String sql)
                                         throws java.sql.SQLException
        Specified by:
        nativeSQL in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • commit

        public final void commit()
                          throws java.sql.SQLException
        Specified by:
        commit in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • rollback

        public final void rollback()
                            throws java.sql.SQLException
        Specified by:
        rollback in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • close

        public final void close()
                         throws java.sql.SQLException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • isClosed

        public final boolean isClosed()
                               throws java.sql.SQLException
        Specified by:
        isClosed in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getWarnings

        public final java.sql.SQLWarning getWarnings()
                                              throws java.sql.SQLException
        Specified by:
        getWarnings in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • clearWarnings

        public final void clearWarnings()
                                 throws java.sql.SQLException
        Specified by:
        clearWarnings in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getMetaData

        public final java.sql.DatabaseMetaData getMetaData()
                                                    throws java.sql.SQLException
        Specified by:
        getMetaData in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setReadOnly

        public final void setReadOnly​(boolean readOnly)
                               throws java.sql.SQLException
        Specified by:
        setReadOnly in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • isReadOnly

        public final boolean isReadOnly()
                                 throws java.sql.SQLException
        Specified by:
        isReadOnly in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setCatalog

        public final void setCatalog​(java.lang.String catalog)
                              throws java.sql.SQLException
        Specified by:
        setCatalog in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getCatalog

        public final java.lang.String getCatalog()
                                          throws java.sql.SQLException
        Specified by:
        getCatalog in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setTransactionIsolation

        public final void setTransactionIsolation​(int level)
                                           throws java.sql.SQLException
        Specified by:
        setTransactionIsolation in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getTransactionIsolation

        public final int getTransactionIsolation()
                                          throws java.sql.SQLException
        Specified by:
        getTransactionIsolation in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createStatement

        public final java.sql.Statement createStatement​(int resultSetType,
                                                        int resultSetConcurrency)
                                                 throws java.sql.SQLException
        Specified by:
        createStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql,
                                                                 int resultSetType,
                                                                 int resultSetConcurrency)
                                                          throws java.sql.SQLException
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareCall

        public final java.sql.CallableStatement prepareCall​(java.lang.String sql,
                                                            int resultSetType,
                                                            int resultSetConcurrency)
                                                     throws java.sql.SQLException
        Specified by:
        prepareCall in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getTypeMap

        public java.util.Map<java.lang.String,​java.lang.Class<?>> getTypeMap()
                                                                            throws java.sql.SQLException
        Specified by:
        getTypeMap in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setTypeMap

        public final void setTypeMap​(java.util.Map<java.lang.String,​java.lang.Class<?>> map)
                              throws java.sql.SQLException
        Specified by:
        setTypeMap in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createStatement

        public final java.sql.Statement createStatement​(int resultSetType,
                                                        int resultSetConcurrency,
                                                        int resultSetHoldability)
                                                 throws java.sql.SQLException
        Specified by:
        createStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareCall

        public final java.sql.CallableStatement prepareCall​(java.lang.String sql,
                                                            int resultSetType,
                                                            int resultSetConcurrency,
                                                            int resultSetHoldability)
                                                     throws java.sql.SQLException
        Specified by:
        prepareCall in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setSavepoint

        public final java.sql.Savepoint setSavepoint()
                                              throws java.sql.SQLException
        Specified by:
        setSavepoint in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setSavepoint

        public final java.sql.Savepoint setSavepoint​(java.lang.String name)
                                              throws java.sql.SQLException
        Specified by:
        setSavepoint in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • rollback

        public final void rollback​(java.sql.Savepoint savepoint)
                            throws java.sql.SQLException
        Specified by:
        rollback in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • releaseSavepoint

        public final void releaseSavepoint​(java.sql.Savepoint savepoint)
                                    throws java.sql.SQLException
        Specified by:
        releaseSavepoint in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • setHoldability

        public final void setHoldability​(int holdability)
                                  throws java.sql.SQLException
        Specified by:
        setHoldability in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql,
                                                                 int autoGeneratedKeys)
                                                          throws java.sql.SQLException
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql,
                                                                 int[] columnIndexes)
                                                          throws java.sql.SQLException
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql,
                                                                 java.lang.String[] columnNames)
                                                          throws java.sql.SQLException
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • noCurrentConnection

        final java.sql.SQLException noCurrentConnection()
        Generate an exception reporting that there is no current connection.
        Returns:
        a no-current-connection exception
      • getRealConnection

        final EngineConnection getRealConnection()
                                          throws java.sql.SQLException
        A little indirection for getting the real connection.
        Returns:
        the current connection
        Throws:
        java.sql.SQLException
      • notifyException

        final void notifyException​(java.sql.SQLException sqle)
      • syncState

        public void syncState()
                       throws java.sql.SQLException
        Sync up the state of the underlying connection with the state of this new handle.
        Throws:
        java.sql.SQLException
      • getIsolationUptoDate

        public void getIsolationUptoDate()
                                  throws java.sql.SQLException
        Isolation level state in BrokeredConnection can get out of sync if the isolation is set using SQL rather than JDBC. In order to ensure correct state level information, this method is called at the start and end of a global transaction.
        Throws:
        java.sql.SQLException
      • setState

        public void setState​(boolean complete)
                      throws java.sql.SQLException
        Set the state of the underlying connection according to the state of this connection's view of state.
        Parameters:
        complete - If true set the complete state of the underlying Connection, otherwise set only the Connection related state (ie. the non-transaction specific state).
        Throws:
        java.sql.SQLException
      • setDrdaID

        public final void setDrdaID​(java.lang.String drdaID)
        set the DrdaId for this connection. The drdaID prints with the statement text to the errror log
        Specified by:
        setDrdaID in interface EngineConnection
        Parameters:
        drdaID - drdaID to be used for this connection
      • setPrepareIsolation

        public final void setPrepareIsolation​(int level)
                                       throws java.sql.SQLException
        Set the internal isolation level to use for preparing statements. Subsequent prepares will use this isoalation level
        Specified by:
        setPrepareIsolation in interface EngineConnection
        Parameters:
        level - - internal isolation level
        Throws:
        java.sql.SQLException - See EmbedConnection#setPrepareIsolation
      • getPrepareIsolation

        public final int getPrepareIsolation()
                                      throws java.sql.SQLException
        get the isolation level that is currently being used to prepare statements (used for network server)
        Specified by:
        getPrepareIsolation in interface EngineConnection
        Returns:
        current prepare isolation level See EmbedConnection#getPrepareIsolation
        Throws:
        java.sql.SQLException
      • addWarning

        public final void addWarning​(java.sql.SQLWarning w)
                              throws java.sql.SQLException
        Add a SQLWarning to this Connection object.
        Specified by:
        addWarning in interface EngineConnection
        Parameters:
        w - Warning to be added, will be chained to any existing warnings.
        Throws:
        java.sql.SQLException
      • toString

        public java.lang.String toString()
        Get the string representation for this connection. Return the class name/hash code and various debug information.
        Overrides:
        toString in class java.lang.Object
        Returns:
        unique string representation for this connection
      • prepareStatement

        public final java.sql.PreparedStatement prepareStatement​(java.lang.String sql,
                                                                 int resultSetType,
                                                                 int resultSetConcurrency,
                                                                 int resultSetHoldability)
                                                          throws java.sql.SQLException
        Prepare statement with explicit holdability.
        Specified by:
        prepareStatement in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • getHoldability

        public final int getHoldability()
                                 throws java.sql.SQLException
        Get the holdability for statements created by this connection when holdability is not passed in.
        Specified by:
        getHoldability in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createArrayOf

        public final java.sql.Array createArrayOf​(java.lang.String typeName,
                                                  java.lang.Object[] elements)
                                           throws java.sql.SQLException
        Specified by:
        createArrayOf in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createBlob

        public final java.sql.Blob createBlob()
                                       throws java.sql.SQLException
        Constructs an object that implements the Blob interface. The object returned initially contains no data. The setBinaryStream and setBytes methods of the Blob interface may be used to add data to the Blob.
        Specified by:
        createBlob in interface java.sql.Connection
        Returns:
        An object that implements the Blob interface
        Throws:
        java.sql.SQLException - if an object that implements the Blob interface can not be constructed, this method is called on a closed connection or a database access error occurs.
      • createClob

        public final java.sql.Clob createClob()
                                       throws java.sql.SQLException
        Constructs an object that implements the Clob interface. The object returned initially contains no data. The setAsciiStream, setCharacterStream and setString methods of the Clob interface may be used to add data to the Clob.
        Specified by:
        createClob in interface java.sql.Connection
        Returns:
        An object that implements the Clob interface
        Throws:
        java.sql.SQLException - if an object that implements the Clob interface can not be constructed, this method is called on a closed connection or a database access error occurs.
      • createNClob

        public final java.sql.NClob createNClob()
                                         throws java.sql.SQLException
        Specified by:
        createNClob in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createSQLXML

        public final java.sql.SQLXML createSQLXML()
                                           throws java.sql.SQLException
        Specified by:
        createSQLXML in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • createStruct

        public final java.sql.Struct createStruct​(java.lang.String typeName,
                                                  java.lang.Object[] attributes)
                                           throws java.sql.SQLException
        Specified by:
        createStruct in interface java.sql.Connection
        Throws:
        java.sql.SQLException
      • isValid

        public final boolean isValid​(int timeout)
                              throws java.sql.SQLException
        Checks if the connection has not been closed and is still valid. The validity is checked by running a simple query against the database.
        Specified by:
        isValid in interface java.sql.Connection
        Parameters:
        timeout - The time in seconds to wait for the database operation used to validate the connection to complete. If the timeout period expires before the operation completes, this method returns false. A value of 0 indicates a timeout is not applied to the database operation.
        Returns:
        true if the connection is valid, false otherwise
        Throws:
        java.sql.SQLException - if the call on the physical connection throws an exception.
      • setClientInfo

        public final void setClientInfo​(java.lang.String name,
                                        java.lang.String value)
                                 throws java.sql.SQLClientInfoException
        setClientInfo forwards to the real connection.
        Specified by:
        setClientInfo in interface java.sql.Connection
        Parameters:
        name - the property key String
        value - the property value String
        Throws:
        java.sql.SQLClientInfoException - if the property is not supported or the real connection could not be obtained.
      • setClientInfo

        public final void setClientInfo​(java.util.Properties properties)
                                 throws java.sql.SQLClientInfoException
        setClientInfo forwards to the real connection. If the call to getRealConnection fails the resulting SQLException is wrapped in a SQLClientInfoException to satisfy the specified signature.
        Specified by:
        setClientInfo in interface java.sql.Connection
        Parameters:
        properties - a Properties object with the properties to set.
        Throws:
        java.sql.SQLClientInfoException - if the properties are not supported or the real connection could not be obtained.
      • getClientInfo

        public final java.lang.String getClientInfo​(java.lang.String name)
                                             throws java.sql.SQLException
        getClientInfo forwards to the real connection.
        Specified by:
        getClientInfo in interface java.sql.Connection
        Parameters:
        name - a String that is the property key to get.
        Returns:
        a String that is returned from the real connection.
        Throws:
        java.sql.SQLException - if a database access error occurs.
      • getClientInfo

        public final java.util.Properties getClientInfo()
                                                 throws java.sql.SQLException
        getClientInfo forwards to the real connection.
        Specified by:
        getClientInfo in interface java.sql.Connection
        Returns:
        a Properties object from the real connection.
        Throws:
        java.sql.SQLException - if a database access error occurs.
      • isWrapperFor

        public final boolean isWrapperFor​(java.lang.Class<?> iface)
                                   throws java.sql.SQLException
        Returns false unless iface is implemented.
        Specified by:
        isWrapperFor in interface java.sql.Wrapper
        Parameters:
        iface - a Class defining an interface.
        Returns:
        true if this implements the interface or directly or indirectly wraps an object that does.
        Throws:
        java.sql.SQLException - if an error occurs while determining whether this is a wrapper for an object with the given interface.
      • unwrap

        public final <T> T unwrap​(java.lang.Class<T> iface)
                           throws java.sql.SQLException
        Returns this if this class implements the interface.
        Specified by:
        unwrap in interface java.sql.Wrapper
        Parameters:
        iface - a Class defining an interface
        Returns:
        an object that implements the interface
        Throws:
        java.sql.SQLException - if no object if found that implements the interface
      • statementHoldabilityCheck

        final int statementHoldabilityCheck​(int resultSetHoldability)
                                     throws java.sql.SQLException
        Check the result set holdability when creating a statement object. Section 16.1.3.1 of JDBC 4.0 (proposed final draft) says the driver may change the holdabilty and add a SQLWarning to the Connection object. This work-in-progress implementation throws an exception to match the old behaviour just as part of incremental development.
        Throws:
        java.sql.SQLException
      • getLOBMapping

        public java.lang.Object getLOBMapping​(int key)
                                       throws java.sql.SQLException
        Get the LOB reference corresponding to the locator.
        Specified by:
        getLOBMapping in interface EngineConnection
        Parameters:
        key - the integer that represents the LOB locator value.
        Returns:
        the LOB Object corresponding to this locator.
        Throws:
        java.sql.SQLException
      • getCurrentSchemaName

        public java.lang.String getCurrentSchemaName()
                                              throws java.sql.SQLException
        Obtain the name of the current schema. Not part of the java.sql.Connection interface, but is accessible through the EngineConnection interface, so that the NetworkServer can get at the current schema for piggy-backing
        Specified by:
        getCurrentSchemaName in interface EngineConnection
        Returns:
        the current schema name
        Throws:
        java.sql.SQLException
      • resetFromPool

        public void resetFromPool()
                           throws java.sql.SQLException
        Description copied from interface: EngineConnection
        Resets the connection before it is returned from a PooledConnection to a new application request (wrapped by a BrokeredConnection).

        Note that resetting the transaction isolation level is not performed as part of this method. Temporary tables, IDENTITY_VAL_LOCAL and current schema are reset.

        Specified by:
        resetFromPool in interface EngineConnection
        Throws:
        java.sql.SQLException
        See Also:
        EngineConnection
      • getSchema

        public java.lang.String getSchema()
                                   throws java.sql.SQLException
        Get the name of the current schema.
        Specified by:
        getSchema in interface java.sql.Connection
        Specified by:
        getSchema in interface EngineConnection
        Throws:
        java.sql.SQLException
      • setSchema

        public void setSchema​(java.lang.String schemaName)
                       throws java.sql.SQLException
        Set the default schema for the Connection.
        Specified by:
        setSchema in interface java.sql.Connection
        Specified by:
        setSchema in interface EngineConnection
        Throws:
        java.sql.SQLException
      • abort

        public void abort​(java.util.concurrent.Executor executor)
                   throws java.sql.SQLException
        Specified by:
        abort in interface java.sql.Connection
        Specified by:
        abort in interface EngineConnection
        Throws:
        java.sql.SQLException
      • getNetworkTimeout

        public int getNetworkTimeout()
                              throws java.sql.SQLException
        Specified by:
        getNetworkTimeout in interface java.sql.Connection
        Specified by:
        getNetworkTimeout in interface EngineConnection
        Throws:
        java.sql.SQLException
      • setNetworkTimeout

        public void setNetworkTimeout​(java.util.concurrent.Executor executor,
                                      int milliseconds)
                               throws java.sql.SQLException
        Specified by:
        setNetworkTimeout in interface java.sql.Connection
        Specified by:
        setNetworkTimeout in interface EngineConnection
        Throws:
        java.sql.SQLException