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;

     }

}