Class NetXAConnection

java.lang.Object
org.apache.derby.client.net.NetXAConnection
public class NetXAConnection extends Object

  • Field Details

  • Constructor Details

    • NetXAConnection

      public NetXAConnection(LogWriter logWriter, String user, String password, BasicClientDataSource40 dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) throws SqlException
      The construcor for the NetXAConnection. The parameter is set to this from ClientXAConnection when it creates an instance of NetXAConnection. This is then passed on the underlying NetConnection constructor and is used to raise StatementEvents from any PreparedStatement that would be created from that NetConnection.
      Parameters:
      logWriter - LogWriter object associated with this connection
      user - user id for this connection
      password - password for this connection
      dataSource - The DataSource object passed from the ClientXAConnection object from which this constructor was called
      rmId - The Resource manager ID for XA Connections
      isXAConn - true if this is a XA connection
      cpc - The ClientPooledConnection object from which this NetConnection constructor was called. This is used to pass StatementEvents back to the pooledConnection object
      Throws:
      SqlException

  • Method Details

    • setCorrelatorToken

      public void setCorrelatorToken(byte[] crttoken)

    • setNetXAResource

      void setNetXAResource(NetXAResource xares)

    • writeLocalXACommit_

      private void writeLocalXACommit_() throws SqlException
      Throws:
      SqlException

    • readLocalXACommit_

      private void readLocalXACommit_() throws SqlException
      Throws:
      SqlException

    • writeLocalXARollback_

      private void writeLocalXARollback_() throws SqlException
      Throws:
      SqlException

    • readLocalXARollback_

      private void readLocalXARollback_() throws SqlException
      Throws:
      SqlException

    • writeTransactionStart

      void writeTransactionStart(ClientStatement statement) throws SqlException
      Throws:
      SqlException

    • writeCommit

      void writeCommit() throws SqlException
      Throws:
      SqlException

    • readCommit

      void readCommit() throws SqlException
      Throws:
      SqlException

    • writeRollback

      void writeRollback() throws SqlException
      Throws:
      SqlException

    • readRollback

      void readRollback() throws SqlException
      Throws:
      SqlException

    • getNetConnection

      public NetConnection getNetConnection()
      Returns underlying net connection
      Returns:
      NetConnection

    • checkPlatformVersion

      private void checkPlatformVersion() throws SqlException
      Throws:
      SqlException

    • createNetConnection

      private NetConnection createNetConnection(LogWriter logWriter, String user, String password, BasicClientDataSource40 dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) throws SqlException
      Creates NetConnection for the supported version of jdbc. This method can be overwritten to return NetConnection of the supported jdbc version.
      Parameters:
      logWriter - LogWriter object associated with this connection
      user - user id for this connection
      password - password for this connection
      dataSource - The DataSource object passed from the ClientXAConnection object from which this constructor was called
      rmId - The Resource manager ID for XA Connections
      isXAConn - true if this is a XA connection
      cpc - The ClientPooledConnection object from which this NetConnection constructor was called. This is used to pass StatementEvents back to the pooledConnection object
      Returns:
      NetConnection
      Throws:
      SqlException