org.apache.derbyTesting.junit

Class DataSourceConnector

java.lang.Object

org.apache.derbyTesting.junit.DataSourceConnector

All Implemented Interfaces:

Connector

public class DataSourceConnector
extends java.lang.Object
implements Connector

Connection factory using javax.sql.DataSource. Should work for an Derby data source, including JSR169 support.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
DataSourceConnector()

Method Summary

Methods

Modifier and Type	Method and Description
(package private) static void	copyProperties(java.util.Properties src, java.util.Map<java.lang.String,java.lang.Object> dest) Copy attributes from a Properties object to a Map.
java.lang.String	getDatabaseName() get the physical databasename in use at this time
int	getLoginTimeout() Get the login timeout in seconds.
(package private) static java.util.HashMap<java.lang.String,java.lang.Object>	makeCreateDBAttributes(TestConfiguration configuration)
(package private) static java.util.HashMap<java.lang.String,java.lang.Object>	makeShutdownDBAttributes(TestConfiguration configuration)
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(boolean deregisterDriver) Shutdown the running derby engine (not the network server).
private javax.sql.DataSource	singleUseDS(java.util.HashMap hm) Get a connection from a single use DataSource 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.DataSource ds

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

Constructor Detail

DataSourceConnector

public DataSourceConnector()

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(boolean deregisterDriver)
                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

Parameters:

deregisterDriver - if true, deregister driver

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

singleUseDS

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

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

Throws:

java.sql.SQLException

makeCreateDBAttributes

static java.util.HashMap<java.lang.String,java.lang.Object> makeCreateDBAttributes(TestConfiguration configuration)

makeShutdownDBAttributes

static java.util.HashMap<java.lang.String,java.lang.Object> makeShutdownDBAttributes(TestConfiguration configuration)

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

copyProperties

static void copyProperties(java.util.Properties src,
                  java.util.Map<java.lang.String,java.lang.Object> dest)

Copy attributes from a Properties object to a Map.