From 0bf868d3cdf9226e178c076d3b588ed5207409a0 Mon Sep 17 00:00:00 2001
From: kongzy <kongzy>
Date: 星期五, 24 十一月 2023 17:51:40 +0800
Subject: [PATCH] merge
---
assess-common/src/main/java/com/gkhy/assess/common/config/BaseFlywayConfig.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/assess-common/src/main/java/com/gkhy/assess/common/config/BaseFlywayConfig.java b/assess-common/src/main/java/com/gkhy/assess/common/config/BaseFlywayConfig.java
new file mode 100644
index 0000000..0db8c73
--- /dev/null
+++ b/assess-common/src/main/java/com/gkhy/assess/common/config/BaseFlywayConfig.java
@@ -0,0 +1,28 @@
+package com.gkhy.assess.common.config;
+
+import cn.hutool.extra.spring.SpringUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.flywaydb.core.Flyway;
+
+import javax.sql.DataSource;
+
+
+@Slf4j
+public class BaseFlywayConfig {
+ public void initDataSource(String dataSourceName){
+ Flyway flyway = Flyway.configure()
+ .dataSource(SpringUtil.getBean(dataSourceName,DataSource.class))
+ .locations("classpath:db/migration")
+ .encoding("UTF-8")
+ .outOfOrder(true)
+ .cleanDisabled(true)
+ .cleanOnValidationError(false)
+ .sqlMigrationPrefix("V")
+ .sqlMigrationSeparator("_")
+ .sqlMigrationSuffixes(".sql")
+ .validateOnMigrate(true)
+ .baselineOnMigrate(true)
+ .load();
+ flyway.migrate();
+ }
+}
--
Gitblit v1.9.2