import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
private void initialize(DataSource dataSource) throws AmbiguousTableNameException {
    databaseTester = new DataSourceDatabaseTester(dataSource);
    databaseTester.setSetUpOperation(DatabaseOperation.CLEAN_INSERT);
    databaseTester.setTearDownOperation(DatabaseOperation.DELETE_ALL);
    DefaultDataSet dataSet = new DefaultDataSet();
    dataSet.addTable(new DefaultTable("agents"));

    dataSet.addTable(new DefaultTable("pipelines"));
    dataSet.addTable(new DefaultTable("pipelinestates"));
    dataSet.addTable(new DefaultTable("materials"));
    dataSet.addTable(new DefaultTable("modifications"));
    dataSet.addTable(new DefaultTable("pipelineMaterialRevisions"));
    dataSet.addTable(new DefaultTable("modifiedFiles"));

    dataSet.addTable(new DefaultTable("notificationfilters"));
    dataSet.addTable(new DefaultTable("users"));
    dataSet.addTable(new DefaultTable("artifactPropertiesGenerator"));
    dataSet.addTable(new DefaultTable("stages"));
    dataSet.addTable(new DefaultTable("pipelineLabelCounts"));
    dataSet.addTable(new DefaultTable("environmentVariables"));
    dataSet.addTable(new DefaultTable("properties"));
    dataSet.addTable(new DefaultTable("artifactPlans"));
    dataSet.addTable(new DefaultTable("buildStateTransitions"));
    dataSet.addTable(new DefaultTable("resources"));
    dataSet.addTable(new DefaultTable("builds"));

    dataSet.addTable(new DefaultTable("oauthclients"));
    dataSet.addTable(new DefaultTable("oauthauthorizations"));
    dataSet.addTable(new DefaultTable("oauthtokens"));

    dataSet.addTable(new DefaultTable("stageArtifactCleanupProhibited"));
    dataSet.addTable(new DefaultTable("serverBackups"));
    dataSet.addTable(new DefaultTable("jobAgentMetadata"));

    databaseTester.setDataSet(dataSet);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
public static IDataSet emptyBatchSet(ProarcDatabase schema) throws Exception {
    ITable[] tables = {
        new DefaultTable(schema.tableBatch.getName()),
        new DefaultTable(schema.tableBatchItem.getName()),
    };
    return new DefaultDataSet(tables);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
private static IDataSet emptyBatchSet(ProarcDatabase schema) throws Exception {
    ITable[] tables = {
        new DefaultTable(schema.tableWorkflowJob.getName()),
        new DefaultTable(schema.tableWorkflowTask.getName()),
        new DefaultTable(schema.tableWorkflowParameter.getName()),
        new DefaultTable(schema.tableWorkflowMaterial.getName()),
        new DefaultTable(schema.tableWorkflowDigObj.getName()),
        new DefaultTable(schema.tableWorkflowFolder.getName()),
        new DefaultTable(schema.tableWorkflowPhysicalDoc.getName()),
        new DefaultTable(schema.tableWorkflowMaterialInTask.getName()),
    };
    return new DefaultDataSet(tables);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
/**
 * データセットにコンバートする。
 * 
 * @return データセット
 */
public IDataSet convert() {

	if (list == null || list.isEmpty()) {
		return new DefaultDataSet();
	}

	addTable();
       try {
           return new DefaultDataSet(tableMap.values().toArray(
               new BeanListTable[tableMap.size()]));
       } catch (AmbiguousTableNameException e) {
           throw new DbUnitNGRuntimeException(e);
       }
   }
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
public static List<File> write(ITable table, File directory) throws DataSetException {
    return write(new DefaultDataSet(table), directory);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
public static List<File> write(ITable table, Charset encoding, CsvPreference preference, File directory) throws DataSetException {
    return write(new DefaultDataSet(table), encoding, preference, directory);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
public void verifyEmptyDataSet() throws Exception {
    IDataSet actualDataSet = databaseTester.getConnection().createDataSet();
    assertEquals(new DefaultDataSet(), actualDataSet);
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
/**
 * 空のデータセットでインスタンスを生成する。
 * @param connectionManager DbUnitのコネクション管理を行うオブジェクト
 * @since 1.0
 */
public DbUnitTester(DatabaseConnectionManager connectionManager) {
    this(connectionManager, new DefaultDataSet());
}
 

import org.dbunit.dataset.DefaultDataSet; //导入依赖的package包/类
/**
 * Empty a specific table.
 * 
 * @param tableName
 * @throws Exception
 */
protected void emptyTable(String tableName) throws Exception {
    IDataSet dataSet = new DefaultDataSet(new DefaultTable(tableName));
    DatabaseOperation.DELETE_ALL.execute(dbunitConn, dataSet);
}