*/
private static final String SCHEMA_PATTERN = "%";
private DataSource dataSource;
- private ITableFilterSimple tables;
private IDatabaseTester dbtester;
/**
/**
* Constructs the database utils.
* Before use, {@link #start()} must be called.
- * @param aDataSource Datasource.
- * @param aTables Tables to work with.
+ * @param aDataSource Datasource.
*/
- public DatabaseUtils(DataSource aDataSource, ITableFilterSimple aTables) {
+ public DatabaseUtils(DataSource aDataSource) {
dataSource = aDataSource;
- tables = aTables;
dbtester = new DataSourceDatabaseTester(dataSource);
connections = new ArrayList<IDatabaseConnection>();
}
connections.clear();
}
- public IDatabaseTester createDbTester() throws Exception {
- return createDbTester(getTableNames(tables));
+ public IDatabaseTester createDbTester(ITableFilterSimple aTables) throws Exception {
+ return createDbTester(getTableNames(aTables));
}
public IDatabaseTester createDbTester(String[] aTables) throws Exception {
return dbtester;
}
- public void cleanDatabase() throws Exception {
- cleanDatabase(tables);
- }
-
public void executeOnTables(ITableFilterSimple aTables,
final TableSetOperation aOperation) throws Exception {
final String[] tableNames = getTableNames(aTables);
connection.close();
}
}
-
- public String[] getTableNames() throws Exception {
- return getTableNames(tables);
- }
-
+
/**
* @throws SQLException
*/
}
}
- public void emptyTables() throws Exception {
- executeOnTables(tables, new TableSetOperation() {
- public void execute(String aTable) throws Exception {
- emptyTable(aTable);
- }
- });
- }
-
/**
* @return
* @throws SQLException
executeSql("delete from " + aTable);
}
- public void dropTables() throws Exception {
- dropTables(tables);
- }
-
public void dropTables(ITableFilterSimple aTables) throws Exception {
final String[] tableNames = getTableNames(aTables);
String[] sortedTables = executeInTransaction(new JdbcUnitOfWork<String[]>() {