import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
/**
 * Ensures that every {@link IDatabaseConnection} produced during
 * the course of execution is configured to use the supplied {@link
 * IDataTypeFactory}.
 *
 * @param dataTypeFactory the {@link IDataTypeFactory} suitable for
 * the underlying database; may be {@code null}
 *
 * @see IOperationListener#connectionRetrieved(IDatabaseConnection)
 *
 * @see DatabaseConfig#PROPERTY_DATATYPE_FACTORY
 */
private final void installDataTypeFactory(final IDataTypeFactory dataTypeFactory) {
  if (dataTypeFactory != null && this.tester != null) {
    this.tester.setOperationListener(new DefaultOperationListener() {
        @Override
        public final void connectionRetrieved(final IDatabaseConnection connection) {
          super.connectionRetrieved(connection);
          if (connection != null) {
            final DatabaseConfig config = connection.getConfig();
            if (config != null) {
              config.setProperty(DatabaseConfig.PROPERTY_DATATYPE_FACTORY, dataTypeFactory);
            }
          }
        }
      });
  }
}
 

import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
/**
 * Creates a new instance of dbUnit's <code>IDatabaseConnection</code>
 *
 * @param schemaName The schema name, not null
 * @return A new instance of dbUnit's <code>IDatabaseConnection</code>
 */
protected DbUnitDatabaseConnection createDbUnitConnection(String schemaName) {
    // A DbSupport instance is fetched in order to get the schema name in correct case
    DataSourceWrapper wrapper = getDatabaseModule().getWrapper(databaseName);
    DataSource dataSource = wrapper.getDataSourceAndActivateTransactionIfNeeded();
    SQLHandler sqlHandler = new DefaultSQLHandler(dataSource);
    DbSupport dbSupport = getDbSupport(configuration, sqlHandler, schemaName, wrapper.getDatabaseConfiguration().getDialect());

    // Create connection
    DbUnitDatabaseConnection connection = new DbUnitDatabaseConnection(dataSource, dbSupport.getSchemaName());
    DatabaseConfig config = connection.getConfig();

    // Make sure that dbunit's correct IDataTypeFactory, that handles dbms specific data type issues, is used
    IDataTypeFactory dataTypeFactory = getInstanceOf(IDataTypeFactory.class, configuration, dbSupport.getDatabaseDialect());
    config.setProperty(PROPERTY_DATATYPE_FACTORY, dataTypeFactory);
    // Make sure that table and column names are escaped using the dbms-specific identifier quote string
    if (dbSupport.getIdentifierQuoteString() != null)
        config.setProperty(PROPERTY_ESCAPE_PATTERN, dbSupport.getIdentifierQuoteString() + '?' + dbSupport.getIdentifierQuoteString());
    // Make sure that batched statements are used to insert the data into the database
    config.setProperty(FEATURE_BATCHED_STATEMENTS, "true");
    // Make sure that Oracle's recycled tables (BIN$) are ignored (value is used to ensure dbunit-2.2 compliancy)
    config.setProperty("http://www.dbunit.org/features/skipOracleRecycleBinTables", "true");

    //set MetaHandler
    config.setProperty(DatabaseConfig.PROPERTY_METADATA_HANDLER, getDefaultDatabaseMetaHandler());

    return connection;
}
 

import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
private IDataTypeFactory createDefaultDataTypeFactory() {
    return new DefaultDataTypeFactory();
}
 

import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
IDatabaseConnection createConnection()
    throws Exception
{

    // Instantiate JDBC driver
    Class dc = Class.forName( driver );
    Driver driverInstance = (Driver) dc.newInstance();
    Properties info = new Properties();
    info.put( "user", username );

    if ( password != null )
    {
        info.put( "password", password );
    }

    Connection conn = driverInstance.connect( url, info );

    if ( conn == null )
    {
        // Driver doesn't understand the URL
        throw new SQLException( "No suitable Driver for " + url );
    }
    conn.setAutoCommit( true );

    IDatabaseConnection connection = new DatabaseConnection( conn, schema );
    DatabaseConfig config = connection.getConfig();
    config.setFeature( DatabaseConfig.FEATURE_BATCHED_STATEMENTS, supportBatchStatement );
    config.setFeature( DatabaseConfig.FEATURE_QUALIFIED_TABLE_NAMES, useQualifiedTableNames );
    config.setFeature( DatabaseConfig.FEATURE_DATATYPE_WARNING, datatypeWarning );
    config.setFeature( DatabaseConfig.FEATURE_SKIP_ORACLE_RECYCLEBIN_TABLES, this.skipOracleRecycleBinTables );
    config.setFeature( DatabaseConfig.FEATURE_CASE_SENSITIVE_TABLE_NAMES, caseSensitiveTableNames );
    
    config.setProperty( DatabaseConfig.PROPERTY_ESCAPE_PATTERN, escapePattern );
    config.setProperty( DatabaseConfig.PROPERTY_RESULTSET_TABLE_FACTORY, new ForwardOnlyResultSetTableFactory() );

    // Setup data type factory
    IDataTypeFactory dataTypeFactory = (IDataTypeFactory) Class.forName( dataTypeFactoryName ).newInstance();
    config.setProperty( DatabaseConfig.PROPERTY_DATATYPE_FACTORY, dataTypeFactory );

    // Setup metadata handler
    IMetadataHandler metadataHandler = (IMetadataHandler) Class.forName( metadataHandlerName ).newInstance();
    config.setProperty( DatabaseConfig.PROPERTY_METADATA_HANDLER, metadataHandler );

    return connection;
}
 

import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
IDatabaseConnection createConnection()
	throws Exception {

	// Instantiate JDBC driver
	Class dc = Class.forName(driver);
	Driver driverInstance = (Driver) dc.newInstance();
	Properties info = new Properties();
	info.put("user", username);

	if (password != null) {
		info.put("password", password);
	}

	Connection conn = driverInstance.connect(url, info);

	if (conn == null) {
		// Driver doesn't understand the URL
		throw new SQLException("No suitable Driver for " + url);
	}
	conn.setAutoCommit(true);

	IDatabaseConnection connection = new DatabaseConnection(conn, schema);
	DatabaseConfig config = connection.getConfig();
	config.setProperty(DatabaseConfig.FEATURE_BATCHED_STATEMENTS, supportBatchStatement);
	config.setProperty(DatabaseConfig.FEATURE_QUALIFIED_TABLE_NAMES, useQualifiedTableNames);
	config.setProperty(DatabaseConfig.FEATURE_DATATYPE_WARNING, datatypeWarning);
	config.setProperty(DatabaseConfig.FEATURE_SKIP_ORACLE_RECYCLEBIN_TABLES, this.skipOracleRecycleBinTables);
	config.setProperty(DatabaseConfig.FEATURE_CASE_SENSITIVE_TABLE_NAMES, caseSensitiveTableNames);

	config.setProperty(DatabaseConfig.PROPERTY_ESCAPE_PATTERN, escapePattern);
	config.setProperty(DatabaseConfig.PROPERTY_RESULTSET_TABLE_FACTORY, new ForwardOnlyResultSetTableFactory());

	// Setup data type factory
	IDataTypeFactory dataTypeFactory = (IDataTypeFactory) Class.forName(dataTypeFactoryName).newInstance();
	config.setProperty(DatabaseConfig.PROPERTY_DATATYPE_FACTORY, dataTypeFactory);

	// Setup metadata handler
	IMetadataHandler metadataHandler = (IMetadataHandler) Class.forName(metadataHandlerName).newInstance();
	config.setProperty(DatabaseConfig.PROPERTY_METADATA_HANDLER, metadataHandler);

	return connection;
}
 

import org.dbunit.dataset.datatype.IDataTypeFactory; //导入依赖的package包/类
/**
 * Creates a {@link DataSourceDatabaseTesterRule}.
 *
 * @param dataSource the {@link DataSource} that will back a new
 * {@link DataSourceDatabaseTester} {@linkplain
 * DataSourceDatabaseTester#DataSourceDatabaseTester(DataSource)
 * created} by this constructor; must not be {@code null}
 *
 * @param dataTypeFactory the {@link IDataTypeFactory} that
 * describes data types for the database to which the supplied
 * {@link DataSource} is notionally connected; may be {@code null}
 *
 * @exception NullPointerException if {@code dataSource} is {@code
 * null}
 *
 * @see DataSourceDatabaseTester#DataSourceDatabaseTester(DataSource)
 */
public DataSourceDatabaseTesterRule(final DataSource dataSource, final IDataTypeFactory dataTypeFactory) {
  this(dataSource);
  this.installDataTypeFactory(dataTypeFactory);
}