import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
private FlywayFactory getFlywayFactory(RegisterName registerName, Optional<String> custodianName, RegisterConfigConfiguration registerConfigConfiguration) {
    FlywayFactory flywayFactory = new FlywayFactory();
    flywayFactory.setLocations(Arrays.asList("/sql", "uk.gov.migration"));
    flywayFactory.setPlaceholders(ImmutableMap.of("registerName", registerName.value(), "custodianName", custodianName.orElse(""), "fieldsYamlUrl",registerConfigConfiguration.getFieldsYamlLocation(),
            "registersYamlUrl", registerConfigConfiguration.getRegistersYamlLocation()));
    flywayFactory.setOutOfOrder(true);
    return flywayFactory;
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
@Override
protected void before() {
    for (TestRegister register : registers) {
        FlywayFactory flywayFactory = getFlywayFactory(register.name());
        Flyway flyway = flywayFactory.build(getDataSource(register.getDatabaseConnectionString("MigrateDatabaseRule")));
        flyway.setSchemas(register.getSchema());
        flyway.migrate();
    }
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
private FlywayFactory getFlywayFactory(String registerName) {
    FlywayFactory flywayFactory = new FlywayFactory();
    flywayFactory.setLocations(Collections.singletonList("/sql"));
    flywayFactory.setPlaceholders(Collections.singletonMap("registerName", registerName));
    flywayFactory.setOutOfOrder(true);
    return flywayFactory;
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
@Override
protected void run(final Bootstrap<T> bootstrap, final Namespace namespace, final T configuration) throws Exception {
    final PooledDataSourceFactory datasourceFactory = databaseConfiguration.getDataSourceFactory(configuration);
    final FlywayFactory flywayFactory = flywayConfiguration.getFlywayFactory(configuration);
    final Flyway flyway = flywayFactory.build(datasourceFactory.build(bootstrap.getMetricRegistry(), "Flyway"));

    try {
        run(namespace, flyway);
    } catch (FlywayException e) {
        LOG.error("Error while running database command", e);
        throw e;
    }
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
public FlywayFactory getFlywayFactory() {
	return flywayFactory;
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
@Override
public FlywayFactory getFlywayFactory(BiblioConfiguration configuration) {
    return configuration.getFlywayFactory();
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
public FlywayFactory getFlywayFactory() {
    return _flywayFactory;
}
 

import io.dropwizard.flyway.FlywayFactory; //导入依赖的package包/类
public FlywayFactory flyway() {
    return flyway;
}