import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
/**
 * Creates a new instance of flyway schema initializer.
 *
 * @param scriptsLocations the locations where to search migration scripts, if locations is not
 *     prefixed or prefixed with <i>classpath:</i> then initializer will try to find scripts in
 *     classpath using {@code Thread.currentThread().}{@link Thread#getContextClassLoader()
 *     getContextClassLoader()}
 * @param scriptsPrefix prefix of migration scripts e.g. 'v' or empty string
 * @param scriptsSuffix suffix of migration scripts e.g. '.sql'
 * @param versionSeparator separate version from the other part of script name e.g. '.' or '__'
 * @param baselineOnMigrate whether to ignore scripts up to the version configured by {@code
 *     baselineVersion}
 * @param baselineVersion up to this version all the scripts ignored, unless schema is initialized
 *     first time, note that scripts with version equal to baseline version are also ignored
 * @param dataSource data source used for migrations
 * @param placeholderReplacer used to replace variables in script with configured values
 */
@Inject
public FlywaySchemaInitializer(
    @Named("db.schema.flyway.scripts.locations") String[] scriptsLocations,
    @Named("db.schema.flyway.scripts.prefix") String scriptsPrefix,
    @Named("db.schema.flyway.scripts.suffix") String scriptsSuffix,
    @Named("db.schema.flyway.scripts.version_separator") String versionSeparator,
    @Named("db.schema.flyway.baseline.enabled") boolean baselineOnMigrate,
    @Named("db.schema.flyway.baseline.version") String baselineVersion,
    DataSource dataSource,
    PlaceholderReplacer placeholderReplacer) {
  this.dataSource = dataSource;
  this.locations = scriptsLocations;
  this.scriptsPrefix = scriptsPrefix;
  this.scriptsSuffix = scriptsSuffix;
  this.versionSeparator = versionSeparator;
  this.baselineOnMigrate = baselineOnMigrate;
  this.baselineVersion = baselineVersion;
  this.placeholderReplacer = placeholderReplacer;
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
public CustomSqlMigrationResolver(
    String dbProviderName, DbSupport dbSupport, PlaceholderReplacer placeholderReplacer) {
  this.vendorName = dbProviderName;
  this.dbSupport = dbSupport;
  this.placeholderReplacer = placeholderReplacer;
  this.finder = new ResourcesFinder();
  this.versionResolver = new VersionResolver();
  this.scriptsCreator = new SqlScriptCreator();
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
@Test
public void replacesVariablesWhenPlaceholderReplacerIsConfigured() throws Exception {
  createScript(
      "1.0/1__init.sql",
      "CREATE TABLE test (id INT, text TEXT, PRIMARY KEY (id));"
          + "INSERT INTO test VALUES(1, '${variable}');");

  FlywayInitializerBuilder.from(dataSource)
      .setReplacer(new PlaceholderReplacer(ImmutableMap.of("variable", "test"), "${", "}"))
      .build()
      .init();

  assertEquals(queryEntities(), Sets.newHashSet(new TestEntity(1, "test")));
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
public static FlywayInitializerBuilder from(DataSource dataSource) {
  try {
    final String scriptsRoot = targetDir().resolve(Paths.get(SCRIPTS_ROOT)).toString();
    return new FlywayInitializerBuilder()
        .setDataSource(dataSource)
        .setScriptsPrefix("")
        .setScriptsSuffix(".sql")
        .setVersionSeparator("__")
        .setReplacer(PlaceholderReplacer.NO_PLACEHOLDERS)
        .setBaselineOnMigrate(false)
        .addLocation("filesystem:" + scriptsRoot);
  } catch (Exception x) {
    throw new RuntimeException(x.getMessage(), x);
  }
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
private static PlaceholderReplacer createPlaceholderReplacer(Flyway flyway) {
    if (flyway.isPlaceholderReplacement()) {
        return new PlaceholderReplacer(flyway.getPlaceholders(), flyway.getPlaceholderPrefix(), flyway.getPlaceholderSuffix());
    }
    return PlaceholderReplacer.NO_PLACEHOLDERS;
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
@Inject
public PlaceholderReplacerProvider(ConfigurationProperties properties) {
  replacer = new PlaceholderReplacer(properties.getProperties(".*"), "${", "}");
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
@Override
public PlaceholderReplacer get() {
  return replacer;
}
 

import org.flywaydb.core.internal.util.PlaceholderReplacer; //导入依赖的package包/类
public FlywayInitializerBuilder setReplacer(PlaceholderReplacer replacer) {
  this.replacer = replacer;
  return this;
}