Spring Boot+Hibernate+Flyway:不在新数据库上运行迁移

Question

我正在使用Flyway更新DB模式。当前，模式的最新版本是3（最新的迁移文件名为v3__postgres.sql)。

我是否正确理解了baseline-version参数，还是遗漏了什么？

注意：我知道自Spring Boot2以来，参数名称空间已经更改为Spring.flyway.*，但我使用的是Spring Boot1，所以这不是问题。

Answer 1

解决方案：我创建了一个自定义的FlywayMigrationStrategybean，在这个bean中，我手动检查Flyway是否已经引入数据库（通过检查迁移表是否存在）。如果不是，我运行baseline命令。然后我像往常一样调用migrate命令。

下面是Spring Boot配置：

import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.flyway.FlywayMigrationStrategy;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FlywayConfig {

    @Autowired
    private DataSource dataSource;

    @Value("${flyway.table}")
    private String flywayTableName;

    @Value("${flyway.baselineVersionAsString}")
    private String baselineVersion;

    @Bean
    public FlywayMigrationStrategy flywayMigrationStrategy() {
        return flyway -> {
            if (!isFlywayInitialized()) {
                flyway.setBaselineVersionAsString(baselineVersion);
                flyway.baseline();
            }
            flyway.migrate();
        };
    }

    private boolean isFlywayInitialized() {

        try (Connection connection = dataSource.getConnection()) {
            DatabaseMetaData metadata = connection.getMetaData();
            ResultSet result = metadata.getTables(null, null, flywayTableName, null);
            return result.next();
        } catch (SQLException e) {
            throw new RuntimeException("Failed to check if Flyway is initialized", e);
        }
    }

}