com.splicemachine.db.client.net

Class NetXAConnection

java.lang.Object

com.splicemachine.db.client.net.NetXAConnection

public class NetXAConnection
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
NetXAConnection(NetLogWriter netLogWriter, java.lang.String user, java.lang.String password, ClientBaseDataSource dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) The construcor for the NetXAConnection.

Method Summary

Modifier and Type	Method and Description
protected NetConnection	createNetConnection(NetLogWriter netLogWriter, java.lang.String user, java.lang.String password, ClientBaseDataSource dataSource, int rmId, boolean isXAConn, ClientPooledConnection cpc) Creates NetConnection for the supported version of jdbc.
protected void	finalize()
byte[]	getCorrelatorToken()
NetConnection	getNetConnection() Returns underlying net connection
int	getPort(javax.transaction.xa.Xid xid)
byte[]	getUOWID(javax.transaction.xa.Xid xid)
void	readCommit()
void	readLocalXACommit_()
void	readLocalXARollback_()
void	readLocalXAStart_()
void	readRollback()
void	setCorrelatorToken(byte[] crttoken)
(package private) void	setNetXAResource(NetXAResource xares)
void	writeCommit()
void	writeLocalXACommit_()
void	writeLocalXARollback_()
void	writeLocalXAStart_()
void	writeRollback()
void	writeTransactionStart(Statement statement)

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NetXAConnection

public NetXAConnection(NetLogWriter netLogWriter,
                       java.lang.String user,
                       java.lang.String password,
                       ClientBaseDataSource 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:

netLogWriter - NetLogWriter 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 Detail

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

setCorrelatorToken

public void setCorrelatorToken(byte[] crttoken)

getCorrelatorToken

public byte[] getCorrelatorToken()

setNetXAResource

void setNetXAResource(NetXAResource xares)

writeLocalXAStart_

public void writeLocalXAStart_()
                        throws SqlException

Throws:

SqlException

readLocalXAStart_

public void readLocalXAStart_()
                       throws SqlException

Throws:

SqlException

writeLocalXACommit_

public void writeLocalXACommit_()
                         throws SqlException

Throws:

SqlException

readLocalXACommit_

public void readLocalXACommit_()
                        throws SqlException

Throws:

SqlException

writeLocalXARollback_

public void writeLocalXARollback_()
                           throws SqlException

Throws:

SqlException

readLocalXARollback_

public void readLocalXARollback_()
                          throws SqlException

Throws:

SqlException

writeTransactionStart

public void writeTransactionStart(Statement statement)
                           throws SqlException

Throws:

SqlException

getUOWID

public byte[] getUOWID(javax.transaction.xa.Xid xid)

getPort

public int getPort(javax.transaction.xa.Xid xid)

writeCommit

public void writeCommit()
                 throws SqlException

Throws:

SqlException

readCommit

public void readCommit()
                throws SqlException

Throws:

SqlException

writeRollback

public void writeRollback()
                   throws SqlException

Throws:

SqlException

readRollback

public void readRollback()
                  throws SqlException

Throws:

SqlException

getNetConnection

public NetConnection getNetConnection()

Returns underlying net connection

Returns:

NetConnection

createNetConnection

protected NetConnection createNetConnection(NetLogWriter netLogWriter,
                                            java.lang.String user,
                                            java.lang.String password,
                                            ClientBaseDataSource 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:

netLogWriter - NetLogWriter 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