com.arjuna.ats.internal.jdbc

Class DirectRecoverableConnection

java.lang.Object

com.arjuna.ats.internal.jdbc.DirectRecoverableConnection

All Implemented Interfaces:

RecoverableXAConnection

public class DirectRecoverableConnection
extends Object
implements RecoverableXAConnection

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)

Field Summary

Fields inherited from interface com.arjuna.ats.jta.xa.RecoverableXAConnection

AUTO_RECOVERY, OBJECT_RECOVERY

Constructor Summary

Constructors

Constructor and Description
DirectRecoverableConnection()
DirectRecoverableConnection(String dbName, String user, String passwd, String dynamic, ConnectionImple conn)

Method Summary

Methods

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()
boolean	packInto(OutputObjectState os)
String	password()
void	reset()
void	setModifier(ConnectionModifier cm)
boolean	setTransaction(Transaction tx) Remember the transaction we are being used within.
Transaction	transaction()
boolean	unpackFrom(InputObjectState os)
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

DirectRecoverableConnection

public DirectRecoverableConnection()
                            throws SQLException

Throws:

SQLException

DirectRecoverableConnection

public DirectRecoverableConnection(String dbName,
                           String user,
                           String passwd,
                           String dynamic,
                           ConnectionImple conn)
                            throws SQLException

Throws:

SQLException

Method Detail

finalize

public void finalize()

Overrides:

finalize in class Object

packInto

public boolean packInto(OutputObjectState os)

Specified by:

packInto in interface RecoverableXAConnection

unpackFrom

public boolean unpackFrom(InputObjectState os)

Specified by:

unpackFrom in interface RecoverableXAConnection

setTransaction

public boolean setTransaction(Transaction tx)

Description copied from interface: RecoverableXAConnection

Remember the transaction we are being used within.

Specified by:

setTransaction in interface RecoverableXAConnection

validTransaction

public boolean validTransaction(Transaction tx)

Description copied from interface: RecoverableXAConnection

Is this the same transaction?

Specified by:

validTransaction in interface RecoverableXAConnection

Returns:

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

getResource

public XAResource getResource()
                       throws SQLException

Specified by:

getResource in interface RecoverableXAConnection

Returns:

a new XAResource for this connection.

Throws:

SQLException

close

public final void close()

Specified by:

close in interface RecoverableXAConnection

reset

public final void reset()

Specified by:

reset in interface RecoverableXAConnection

getCurrentConnection

public XAConnection getCurrentConnection()
                                  throws SQLException

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

Specified by:

getCurrentConnection in interface RecoverableXAConnection

Throws:

SQLException

closeCloseCurrentConnection

public void closeCloseCurrentConnection()
                                 throws SQLException

Specified by:

closeCloseCurrentConnection in interface RecoverableXAConnection

Throws:

SQLException

getConnection

public XAConnection getConnection()
                           throws SQLException

Specified by:

getConnection in interface RecoverableXAConnection

Throws:

SQLException

getDataSource

public XADataSource getDataSource()
                           throws SQLException

Specified by:

getDataSource in interface RecoverableXAConnection

Throws:

SQLException

inuse

public boolean inuse()

Specified by:

inuse in interface RecoverableXAConnection

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)