com.arjuna.ats.internal.jdbc

Class ProvidedXADataSourceConnection

java.lang.Object

com.arjuna.ats.internal.jdbc.ProvidedXADataSourceConnection

All Implemented Interfaces:

TransactionalDriverXAConnection

public class ProvidedXADataSourceConnection
extends Object
implements TransactionalDriverXAConnection

This class is responsible for maintaining connection information in such a manner that we can recover the connection to the XA database in the event of a failure.

Since:

JTS 2.0.

Version:

$Id: DirectRecoverableConnection.java 2342 2006-03-30 13:06:17Z $

Author:

Mark Little (mark@arjuna.com)

Constructor Summary

Constructors

Constructor and Description
ProvidedXADataSourceConnection(String dbName, String user, String passwd, XADataSource xaDatasource, ConnectionImple conn)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeCloseCurrentConnection()
String	dataSourceName()
String	dynamicClass()
void	finalize()
XAConnection	getConnection()
XAConnection	getCurrentConnection() If there is a connection then return it.
XADataSource	getDataSource()
XAResource	getResource()
boolean	inuse()
String	password()
void	reset()
void	setModifier(ConnectionModifier cm)
boolean	setTransaction(Transaction tx) Remember the transaction we are being used within.
Transaction	transaction()
String	url()
String	user()
boolean	validTransaction(Transaction tx) Is this the same transaction?

Methods inherited from class java.lang.Object

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

Constructor Detail

ProvidedXADataSourceConnection

public ProvidedXADataSourceConnection(String dbName,
                                      String user,
                                      String passwd,
                                      XADataSource xaDatasource,
                                      ConnectionImple conn)
                               throws SQLException

Throws:

SQLException

Method Detail

finalize

public void finalize()

Overrides:

finalize in class Object

setTransaction

public boolean setTransaction(Transaction tx)

Description copied from interface: TransactionalDriverXAConnection

Remember the transaction we are being used within.

Specified by:

setTransaction in interface TransactionalDriverXAConnection

validTransaction

public boolean validTransaction(Transaction tx)

Description copied from interface: TransactionalDriverXAConnection

Is this the same transaction?

Specified by:

validTransaction in interface TransactionalDriverXAConnection

Returns:

true if the connection can be used by this transaction, false otherwise.

getResource

public XAResource getResource()
                       throws SQLException

Specified by:

getResource in interface TransactionalDriverXAConnection

Returns:

a new XAResource for this connection.

Throws:

SQLException

close

public final void close()

reset

public final void reset()

getCurrentConnection

public XAConnection getCurrentConnection()
                                  throws SQLException

If there is a connection then return it. Do not create a new connection otherwise.

Throws:

SQLException

closeCloseCurrentConnection

public void closeCloseCurrentConnection()
                                 throws SQLException

Specified by:

closeCloseCurrentConnection in interface TransactionalDriverXAConnection

Throws:

SQLException

getConnection

public XAConnection getConnection()
                           throws SQLException

Specified by:

getConnection in interface TransactionalDriverXAConnection

Throws:

SQLException

getDataSource

public XADataSource getDataSource()
                           throws SQLException

Throws:

SQLException

inuse

public boolean inuse()

Specified by:

inuse in interface TransactionalDriverXAConnection

Returns:

true if the connection is being used within a transaction, false otherwise.

user

public String user()

password

public String password()

url

public String url()

dynamicClass

public String dynamicClass()

dataSourceName

public String dataSourceName()

transaction

public Transaction transaction()

setModifier

public void setModifier(ConnectionModifier cm)