String sql = "delete from " + DataSetUtils.getQualifiedName( connection.getSchema(), metaData.getTableName()); statement.addBatch(sql);
StringBuffer sqlBuffer = new StringBuffer(128); sqlBuffer.append("delete from "); sqlBuffer.append(DataSetUtils.getQualifiedName( connection.getSchema(), metaData.getTableName())); statement.addBatch(sqlBuffer.toString());
    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);            for (int i = 0; i < tableNames.length; i++)            {                String name = tableNames[i];                ITableMetaData metaData = dataSet.getTableMetaData(name);                String sql = "delete from " + DataSetUtils.getQualifiedName(                        connection.getSchema(), metaData.getTableName());                statement.addBatch(sql);            }            statement.executeBatch();            statement.clearBatch();        }        finally        {            statement.close();        }    }