connection.getSchema(), tableNames[i], true));
connection.getSchema(), tableName, true));
    public void execute(IDatabaseConnection connection, IDataSet dataSet)            throws DatabaseUnitException, SQLException    {        IStatementFactory statementFactory = connection.getStatementFactory();        IBatchStatement statement = statementFactory.createBatchStatement(connection);        try        {            String[] tableNames = DataSetUtils.getReverseTableNames(dataSet);            if (tableNames.length > 0)            {                for (int i = 0; i < tableNames.length; i++)                {                    StringBuffer sqlBuffer = new StringBuffer(128);                    sqlBuffer.append("delete from ");                    sqlBuffer.append(DataSetUtils.getQualifiedName(                            connection.getSchema(), tableNames[i], true));                    statement.addBatch(sqlBuffer.toString());                }                statement.executeBatch();                statement.clearBatch();            }        }        finally        {            statement.close();        }    }