org.apache.derbyTesting.junit

Class XADataSourceConnector

java.lang.Object

org.apache.derbyTesting.junit.XADataSourceConnector

All Implemented Interfaces:

Connector

public class XADataSourceConnector
extends java.lang.Object
implements Connector

Connection factory using javax.sql.XADataSource. Returns a connection in local mode obtained from getXAConnection().getConnection().

Field Summary

Fields

Modifier and Type	Field and Description
private TestConfiguration	config
private javax.sql.XADataSource	ds DataSource that maps to the database for the configuration.

Constructor Summary

Constructors

Constructor and Description
XADataSourceConnector()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDatabaseName() get the physical databasename in use at this time
int	getLoginTimeout() Get the login timeout in seconds.
java.sql.Connection	openConnection() Open a connection with the database, user and password defined by the configuration passed to setConfiguration.
java.sql.Connection	openConnection(java.lang.String databaseName) Open a connection with the database, user and password defined by the configuration passed to setConfiguration.
java.sql.Connection	openConnection(java.lang.String user, java.lang.String password) Open a connection to the database defined by the configuration passed to setConfiguration.
java.sql.Connection	openConnection(java.lang.String databaseName, java.lang.String user, java.lang.String password) Open a connection to the database defined by the configuration passed to setConfiguration.
java.sql.Connection	openConnection(java.lang.String databaseName, java.lang.String user, java.lang.String password, java.util.Properties connectionProperties) Open a connection to the database defined by the configuration passed to setConfiguration.
void	setConfiguration(TestConfiguration config) Link this connector to the given configuration.
void	setLoginTimeout(int seconds) Set the login timeout for getting connections.
void	shutDatabase() Shutdown the running default database using user and password defined by the configuration passed to setConfiguration.
void	shutEngine() Shutdown the running derby engine (not the network server).
private javax.sql.XADataSource	singleUseDS(java.util.HashMap hm) Get a connection from a single use XADataSource configured from the configuration but with the passed in property set.

Methods inherited from class java.lang.Object

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

Field Detail

config

private TestConfiguration config

ds

private javax.sql.XADataSource ds

DataSource that maps to the database for the configuration. The no-arg getXAConnection() method maps to the default user and password for the configuration.

Constructor Detail

XADataSourceConnector

public XADataSourceConnector()

Method Detail

setConfiguration

public void setConfiguration(TestConfiguration config)

Description copied from interface: Connector

Link this connector to the given configuration. Should be called once upon setup.

Specified by:

setConfiguration in interface Connector

openConnection

public java.sql.Connection openConnection()
                                   throws java.sql.SQLException

Description copied from interface: Connector

Open a connection with the database, user and password defined by the configuration passed to setConfiguration. If the database does not exist then it should be created.

Specified by:

openConnection in interface Connector

Throws:

java.sql.SQLException

openConnection

public java.sql.Connection openConnection(java.lang.String databaseName)
                                   throws java.sql.SQLException

Description copied from interface: Connector

Open a connection with the database, user and password defined by the configuration passed to setConfiguration. If the database does not exist then it should be created.

Specified by:

openConnection in interface Connector

Throws:

java.sql.SQLException

openConnection

public java.sql.Connection openConnection(java.lang.String user,
                                          java.lang.String password)
                                   throws java.sql.SQLException

Description copied from interface: Connector

Open a connection to the database defined by the configuration passed to setConfiguration. If the database does not exist then it should be created.

Specified by:

openConnection in interface Connector

Throws:

java.sql.SQLException

openConnection

public java.sql.Connection openConnection(java.lang.String databaseName,
                                          java.lang.String user,
                                          java.lang.String password)
                                   throws java.sql.SQLException

Description copied from interface: Connector

Open a connection to the database defined by the configuration passed to setConfiguration. If the database does not exist then it should be created.

Specified by:

openConnection in interface Connector

Throws:

java.sql.SQLException

openConnection

public java.sql.Connection openConnection(java.lang.String databaseName,
                                          java.lang.String user,
                                          java.lang.String password,
                                          java.util.Properties connectionProperties)
                                   throws java.sql.SQLException

Description copied from interface: Connector

Open a connection to the database defined by the configuration passed to setConfiguration. If the database does not exist then it should be created.

Specified by:

openConnection in interface Connector

Throws:

java.sql.SQLException

shutDatabase

public void shutDatabase()
                  throws java.sql.SQLException

Description copied from interface: Connector

Shutdown the running default database using user and password defined by the configuration passed to setConfiguration. Return nothing, exception is expected to be thrown with SQLState 08006

Specified by:

shutDatabase in interface Connector

Throws:

java.sql.SQLException

shutEngine

public void shutEngine()
                throws java.sql.SQLException

Description copied from interface: Connector

Shutdown the running derby engine (not the network server). This method can only be called when the engine is running embedded in this JVM. Return nothing, exception is expected to be thrown with SQLState XJ015

Specified by:

shutEngine in interface Connector

Throws:

java.sql.SQLException

setLoginTimeout

public void setLoginTimeout(int seconds)
                     throws java.sql.SQLException

Description copied from interface: Connector

Set the login timeout for getting connections. Timeout is measured in seconds.

Specified by:

setLoginTimeout in interface Connector

Throws:

java.sql.SQLException

getLoginTimeout

public int getLoginTimeout()
                    throws java.sql.SQLException

Description copied from interface: Connector

Get the login timeout in seconds.

Specified by:

getLoginTimeout in interface Connector

Throws:

java.sql.SQLException

getDatabaseName

public java.lang.String getDatabaseName()

Description copied from interface: Connector

get the physical databasename in use at this time

Specified by:

getDatabaseName in interface Connector

Returns:

Name of database

singleUseDS

private javax.sql.XADataSource singleUseDS(java.util.HashMap hm)
                                    throws java.sql.SQLException

Get a connection from a single use XADataSource configured from the configuration but with the passed in property set.

Throws:

java.sql.SQLException