org.wamblee.test.persistence

Class DatabaseUtils

java.lang.Object

org.wamblee.test.persistence.DatabaseUtils

public class DatabaseUtils
extends Object

Database utilities is a simple support class for common tasks in working with databases.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DatabaseUtils.JdbcUnitOfWork<T> Represents a unit of work (transaction).
static interface	DatabaseUtils.TableSet Represents a set of tables.
static interface	DatabaseUtils.TableSetOperation Operation to be executed on a set of tables for each table individually.

Constructor Summary

Constructors

Constructor and Description
DatabaseUtils(DataSource aDataSource) Constructs the database utils.

Method Summary

Modifier and Type	Method and Description
void	cleanDatabase(org.dbunit.dataset.filter.ITableFilterSimple aSelection) Cleans a number of database tables.
int	countResultSet(ResultSet aResultSet) Counts the results in a result set.
org.dbunit.IDatabaseTester	createDbTester(org.dbunit.dataset.filter.ITableFilterSimple aTables) Creates database tester.
org.dbunit.IDatabaseTester	createDbTester(String[] aTables) Creates database tester.
void	dropTable(String aTable) Drops a table.
void	dropTables(org.dbunit.dataset.filter.ITableFilterSimple aTables) Drops tables.
void	emptyTable(String aTable) Deprecated.
void	emptyTables(org.dbunit.dataset.filter.ITableFilterSimple aSelection) Deprecated.
<T> T	executeInTransaction(DatabaseUtils.JdbcUnitOfWork<T> aWork) Executes a unit of work within a transaction.
void	executeOnTables(org.dbunit.dataset.filter.ITableFilterSimple aTables, DatabaseUtils.TableSetOperation aOperation) Executes an operation on a set of tables.
ResultSet	executeQuery(Connection aConnection, String aSql) Executes an SQL query.
ResultSet	executeQuery(Connection aConnection, String aSql, Object aArg) Executes a query with a single argument.
ResultSet	executeQuery(Connection aConnection, String aSql, Object[] aArgs) Executes a query.
int	executeSql(String aSql) Executes an SQL statement within a transaction.
int	executeSql(String aSql, Object aArg) Executes an SQL statement within a transaction.
int	executeSql(String aSql, Object[] aArgs) Executes an sql statement.
int	executeUpdate(Connection aConnection, String aSql, Object... aArgs) Executes an update.
String[]	getTableNames(org.dbunit.dataset.filter.ITableFilterSimple aSelection) Returns table names based on a table filter.
int	getTableSize(String aTable) Gets the table size.
void	start() Starts the database utils.
void	stop() Stops the database utils, closing any JDBC connections that were created by this utility.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseUtils

public DatabaseUtils(DataSource aDataSource)

Constructs the database utils. Before use, start() must be called.

Parameters:

aDataSource - Datasource.

Method Detail

start

public void start()

Starts the database utils.

stop

public void stop()

Stops the database utils, closing any JDBC connections that were created by this utility. Note that connections obtained from the datasource directly must still be closed by the user. The involved connections are only those that are created by this utility.

createDbTester

public org.dbunit.IDatabaseTester createDbTester(org.dbunit.dataset.filter.ITableFilterSimple aTables)
                                          throws Exception

Creates database tester.

Parameters:

aTables - Tables to create the tester for.

Returns:

Database tester.

Throws:

Exception

createDbTester

public org.dbunit.IDatabaseTester createDbTester(String[] aTables)
                                          throws Exception

Creates database tester.

Parameters:

aTables - Tables to create the tester for.

Returns:

Database tester.

Throws:

Exception

executeOnTables

public void executeOnTables(org.dbunit.dataset.filter.ITableFilterSimple aTables,
                            DatabaseUtils.TableSetOperation aOperation)
                     throws Exception

Executes an operation on a set of tables.

Parameters:

aTables - Tables.

aOperation - Operation.

Throws:

Exception

cleanDatabase

public void cleanDatabase(org.dbunit.dataset.filter.ITableFilterSimple aSelection)
                   throws Exception

Cleans a number of database tables. This means deleting the content not dropping the tables. This may fail in case of cyclic dependencies between the tables (current limitation).

Parameters:

aSelection - Tables.

Throws:

Exception

executeInTransaction

public <T> T executeInTransaction(DatabaseUtils.JdbcUnitOfWork<T> aWork)
                           throws Exception

Executes a unit of work within a transaction.

Type Parameters:

T - Result type of th ework.

Parameters:

aWork - Unit of work.

Returns:

Throws:

Exception

getTableNames

public String[] getTableNames(org.dbunit.dataset.filter.ITableFilterSimple aSelection)
                       throws Exception

Returns table names based on a table filter.

Parameters:

aSelection - Table filter.

Returns:

Table names.

Throws:

Exception

emptyTables

@Deprecated
public void emptyTables(org.dbunit.dataset.filter.ITableFilterSimple aSelection)
                             throws Exception

Deprecated.

Use cleanDatabase(ITableFilterSimple) instead.

Throws:

Exception

emptyTable

@Deprecated
public void emptyTable(String aTable)
                            throws Exception

Deprecated.

User cleanDatabase(ITableFilterSimple) instead.

Throws:

Exception

dropTables

public void dropTables(org.dbunit.dataset.filter.ITableFilterSimple aTables)
                throws Exception

Drops tables. This only works if there are no cyclic dependencies between the tables.

Parameters:

aTables - Tables to drop.

Throws:

Exception

dropTable

public void dropTable(String aTable)
               throws Exception

Drops a table.

Parameters:

aTable - Table to drop.

Throws:

Exception

executeSql

public int executeSql(String aSql)
               throws Exception

Executes an SQL statement within a transaction.

Parameters:

aSql - SQL statement.

Returns:

Return code of the corresponding JDBC call.

Throws:

Exception

executeSql

public int executeSql(String aSql,
                      Object aArg)
               throws Exception

Executes an SQL statement within a transaction. See setPreparedParam(int, PreparedStatement, Object)for details on supported argument types.

Parameters:

aSql - SQL statement.

aArg - Argument of the sql statement.

Returns:

Return code of the corresponding JDBC call.

Throws:

Exception

executeSql

public int executeSql(String aSql,
                      Object[] aArgs)
               throws Exception

Executes an sql statement. See setPreparedParam(int, PreparedStatement, Object)for details on supported argument types.

Parameters:

aSql - SQL query to execute.

aArgs - Arguments.

Returns:

Number of rows updated.

Throws:

Exception

executeQuery

public ResultSet executeQuery(Connection aConnection,
                              String aSql)

Executes an SQL query.

Parameters:

aSql - Query to execute.

Returns:

Result set.

executeQuery

public ResultSet executeQuery(Connection aConnection,
                              String aSql,
                              Object aArg)

Executes a query with a single argument. See setPreparedParam(int, PreparedStatement, Object)for details on supported argument types.

Parameters:

aSql - Query.

aArg - Argument.

Returns:

Result set.

executeQuery

public ResultSet executeQuery(Connection aConnection,
                              String aSql,
                              Object[] aArgs)

Executes a query. See setPreparedParam(int, PreparedStatement, Object)for details on supported argument types.

Parameters:

aSql - Sql query.

aArgs - Arguments to the query.

Returns:

Result set.

executeUpdate

public int executeUpdate(Connection aConnection,
                         String aSql,
                         Object... aArgs)

Executes an update.

Parameters:

aConnection - Connection to use.

aSql - SQL update to use.

aArgs - Arguments to the update.

Returns:

Number of rows updated.

getTableSize

public int getTableSize(String aTable)
                 throws Exception

Gets the table size.

Parameters:

aTable - Table.

Returns:

Table size.

Throws:

SQLException

Exception

countResultSet

public int countResultSet(ResultSet aResultSet)
                   throws SQLException

Counts the results in a result set.

Parameters:

aResultSet - Resultset.

Returns:

Number of rows in the set.

Throws:

SQLException