From fbdb82636f517362aed09d04b0cdb697ae3c45ea Mon Sep 17 00:00:00 2001
From: besscroft <besscroft@foxmail.com>
Date: Wed, 9 Aug 2023 11:01:34 +0800
Subject: [PATCH] =?UTF-8?q?fix:flyway=20=E5=88=9D=E5=A7=8B=E5=8C=96?=
 =?UTF-8?q?=E6=B5=81=E7=A8=8B=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Fixed #36
---
 .../com/besscroft/diyfile/config/FlywayConfigure.java    | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/diyfile-system/src/main/java/com/besscroft/diyfile/config/FlywayConfigure.java b/diyfile-system/src/main/java/com/besscroft/diyfile/config/FlywayConfigure.java
index 17568ab..133231c 100644
--- a/diyfile-system/src/main/java/com/besscroft/diyfile/config/FlywayConfigure.java
+++ b/diyfile-system/src/main/java/com/besscroft/diyfile/config/FlywayConfigure.java
@@ -69,8 +69,10 @@ public void flywayMigrate() {
             }
             String databaseProductVersion = databaseMetaData.getDatabaseProductVersion();
             log.info("当前数据库版本为：{}", databaseProductVersion);
+            // 设置数据库是否初始化标志
+            boolean isInit = false;
             if ("5".equals(StrUtil.sub(databaseProductVersion, 0, 1))) {
-                log.info("数据库版本不支持自动初始化，跳过初始化...");
+                log.warn("数据库版本不支持自动初始化，跳过初始化...");
                 return;
             }
             for (DatabaseType type : SORTED_DATABASE_TYPES) {
@@ -78,8 +80,13 @@ public void flywayMigrate() {
                     log.info("数据库版本支持自动初始化，即将开始初始化...");
                     Flyway flyway = Flyway.configure().dataSource(dataSource).outOfOrder(true).locations("db/" + dbType + "/migration").load();
                     flyway.migrate();
+                    isInit = true;
                 }
             }
+            if (!isInit) {
+                log.warn("Unable to find a Flyway plugin for database: {}, with version: {}, and type: {}.", databaseProductName, databaseProductVersion, dbType);
+                return;
+            }
             log.info("数据库初始化完毕！");
         } catch (SQLException e) {
             throw new DiyFileException(e.getMessage());