以代码的形式实现flyway的迁移

1 packagecom.enmo.dbaas.firewall.common.config;
2 
3 importorg.flywaydb.core.Flyway;
4 importorg.flywaydb.core.api.configuration.FluentConfiguration;
5 importorg.springframework.stereotype.Component;
6 importcom.enmo.dbaas.firewall.common.utils.SpringContextProvider;
7 importlombok.extern.slf4j.Slf4j;
8 
9 /**
10 * @ClassName: FlywayConfig.java
11 * @Description:
12 * @Author guo.yu
13 * @Version V1.0.0
14 * @Date 2019-05-12 19:46:10
15  */
16 @Component
17 @Slf4j
18 public classFlywayConfig {
19 
20     private static final String FLYWAY_TAB_NAME = "dbaas_firewall_flyway_schema_history";
21     
22     private static final String FLYWAY_LOCATION = "db/firewall/migration";
23 
24     publicFlywayConfig(SpringContextProvider provider) {
25         Flyway defFlyway = null;
26         try{
27             defFlyway = provider.getBean(Flyway.class);
28         } catch(Exception e) {
29             log.warn("flyway is not enabled.");
30 }
31         if (defFlyway != null) {
32 firewallMigrate(defFlyway);
33 }
34 
35 }
36 
37     @SuppressWarnings("deprecation")
38     public voidfirewallMigrate(Flyway defFlyway) {
39         FluentConfiguration config = newFluentConfiguration();
40 
41 config.dataSource(defFlyway.getDataSource())
42 .baselineOnMigrate(defFlyway.isBaselineOnMigrate())
43 .locations(FLYWAY_LOCATION)
44 .table(FLYWAY_TAB_NAME)
45                //允许运行之前版本（相对于schema表最新版本）的schema文件
46                .outOfOrder(true)
47 .load()
48 .migrate();
49         
50         
51 }
52 
53 }