生产采用外部mysql部署时，为了方便后续定制sql及减少与infra沟通，采用flyway自动执行和管理sql脚本，具体过程及相关点记录一下，方便后续回顾，希望对你也有所帮助。
flyway的引入
版本问题
本着要用就是最新的原则，直接使用了8.5.5，启动报类缺失的错，后发现springboot本身有管理flyway版本，因此不需要指定版本即可
FlywayAutoConfiguration
查看源码可知，依赖一个DataSource，因此我引入了starter-jpa，配置了datasource相关属性，无奈还是没法字段创建flyway(知道原因的小伙伴可以留言给我，谢谢)，因此只能自己创建一个DataSource
aws的secretmanager
由于数据库的密码信息是配置在aws的secretmanager中，因此需要在spring启动后进行配置拉取，并覆盖本地配置文件的值。
这里采用添加Listener的方式进行监听处理
# spring.factories
org.springframework.context.ApplicationListener=xx.AwsFetchConfigurationListener
public class AwsFetchConfigurationListener implements ApplicationListener<ApplicationEnvironmentPreparedEvent> {
@Override
public void onApplicationEvent(ApplicationEnvironmentPreparedEvent event) {
ConfigurableEnvironment environment = event.getEnvironment();
// 拉取配置，并添加到环境中
getCredential(environment).ifPresent(credential -> {
// all properties need to be config in AWS Secrets Management, otherwise it will occur error when setting
Properties props = new Properties();
props.put(AwsSecretManagerCredential.DB_URL_0, credential.getMysqlUrl());
props.put(AwsSecretManagerCredential.DB_USER_0, credential.getMysqlUser());
props.put(AwsSecretManagerCredential.DB_PASSWORD_0, credential.getMysqlPassword());
props.put(AwsSecretManagerCredential.AWS_REGION, credential.getAwsRegion());
});
}
nacos启动时的dump
ExternalDumpService在完成初始化后执行dumpOperate，可以看到这里有个对rpcConfigChangeNotifier的依赖
由于dumpOperate借助外部注入的PersistService从数据库里读取数据，同时在初始化时发现数据源的获取，
会依据PropertyUtil从配置文件和环境变量的数据判断，PropertiyUtil本身实现了ApplicationContextInitializer，遗憾的是这里的ExternalDataSourceServiceImpl并非spring管理。
之前看到ExternalDumpService的@DependsOn({“rpcConfigChangeNotifier”}),让我想起了拦截spring bean的注册时机，动态添加依赖，实验结果还是没法控制flyway的优先执行，理论上应该是可行的，后来才发现ExternalStoragePersistServiceImpl初始完成也会调用数据源，所以就调整了一下依赖。
最终结果如下
@Configuration
public class FlywayConfig implements BeanDefinitionRegistryPostProcessor {
// 注意这里注入的不是Environment
@Bean
public DataSource nacosDataSource(ConfigurableEnvironment env) {
DataSourceBuilder<?> dataSourceBuilder = DataSourceBuilder.create();
dataSourceBuilder.driverClassName(Driver.class.getName());
dataSourceBuilder.url(env.getProperty(AwsSecretManagerCredential.DB_URL_0));
dataSourceBuilder.username(env.getProperty(AwsSecretManagerCredential.DB_USER_0));
dataSourceBuilder.password(env.getProperty(AwsSecretManagerCredential.DB_PASSWORD_0));
dataSourceBuilder.type(HikariDataSource.class);
return dataSourceBuilder.build();
}
@Override
public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
String rpcName = "externalStoragePersistServiceImpl";
String addDep = "flywayInitializer";
if (beanDefinitionRegistry.containsBeanDefinition(rpcName)) {
BeanDefinition rpcBeanDefinition = beanDefinitionRegistry.getBeanDefinition(rpcName);
String[] oldDeps = rpcBeanDefinition.getDependsOn();
if (oldDeps != null) {
int len = oldDeps.length;
String[] deps = new String[len + 1];
System.arraycopy(oldDeps, 0, deps, 0, len);
deps[deps.length - 1] = addDep;
rpcBeanDefinition.setDependsOn(deps);
}else {
rpcBeanDefinition.setDependsOn(addDep);
}
}
}
@Override
public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
}
}
