[Java] springboot集成flyway自动创表的详细配置

<dependency>
    <groupid>org.flywaydb</groupid>
    <artifactid>flyway-core</artifactid>
  </dependency>
<!--   不是必须的 -->
  <build>
    <plugins>
      <plugin>
        <groupid>org.flywaydb</groupid>
        <artifactid>flyway-maven-plugin</artifactid>
        <version>5.2.1</version>
      </plugin>
    </plugins>
  </build>

spring:
  # 配置flyway数据版本管理
  flyway:
    enabled: true
    baseline-on-migrate: true
    clean-on-validation-error: false
    sql-migration-prefix: v
    sql-migration-suffixes: .sql
    locations: classpath:db/migration/mysql

import org.quartz.scheduler;
import org.quartz.schedulerexception;
import org.slf4j.logger;
import org.slf4j.loggerfactory;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.context.applicationlistener;
import org.springframework.context.event.contextrefreshedevent;
import org.springframework.stereotype.component;
 
import java.util.list;
 
/**
 *
  * @author： 云诺
  * @date： 2021/6/25
  * @description： 将项目启动后flyway创建好表加载到缓存
 */
@component
public class runtimeconfig implements applicationlistener<contextrefreshedevent> {
 
  private final static logger logger = loggerfactory.getlogger(runtimeconfig.class);
 
  @autowired
  private sysconfigmapper configmapper;
 
 
  @autowired
  private sysdicttypemapper dicttypemapper;
 
  @autowired
  private sysdictdatamapper dictdatamapper;
 
  @autowired
  private scheduler scheduler;
 
  @autowired
  private sysjobmapper jobmapper;
 
  /**
   * 项目启动时，初始化参数
   */
  @override
  public void onapplicationevent(contextrefreshedevent contextrefreshedevent) {
    logger.info("init param ...");
    this.initparam();
    logger.info("init dict ...");
    this.initdict();
    try {
      logger.info("init job ...");
      this.initjob();
    } catch (schedulerexception e) {
      e.printstacktrace();
    } catch (taskexception e) {
      e.printstacktrace();
    }
  }
 
  /**
   * 初始化定时任务信息到缓存
   *
   * @throws schedulerexception
   * @throws taskexception
   */
  public void initjob() throws schedulerexception, taskexception {
    scheduler.clear();
    list<sysjob> joblist = jobmapper.selectjoball();
    for (sysjob job : joblist) {
      scheduleutils.createschedulejob(scheduler, job);
    }
  }
 
 
 
  /**
   * 初始化参数到缓存
   */
  public void initparam() {
    list<sysconfig> configslist = configmapper.selectconfiglist(new sysconfig());
    for (sysconfig config : configslist)
    {
      cacheutils.put(getcachename(), getcachekey(config.getconfigkey()), config.getconfigvalue());
    }
  }
 
  /**
   * 初始化字典到缓存
   */
  public void initdict() {
    list<sysdicttype> dicttypelist = dicttypemapper.selectdicttypeall();
    for (sysdicttype dicttype : dicttypelist)
    {
      list<sysdictdata> dictdatas = dictdatamapper.selectdictdatabytype(dicttype.getdicttype());
      dictutils.setdictcache(dicttype.getdicttype(), dictdatas);
    }
  }
 
  /**
   * 设置cache key
   *
   * @param configkey 参数键
   * @return 缓存键key
   */
  private string getcachekey(string configkey)
  {
    return constants.sys_config_key + configkey;
  }
  
  /**
   * 获取cache name
   *
   * @return 缓存名
   */
  private string getcachename()
  {
    return constants.sys_config_cache;
  }
}