manager/zyplayer-doc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

#I6IWI9 解决没有升级脚本时提示没有找到文件问题

Browse Source
This commit is contained in:
暮光：城中城
2023-03-02 23:20:18 +08:00
parent 76307b05b3
commit a819a8df59
8 changed files with 42 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
zyplayer-doc-manage/src/main/java/com/zyplayer/doc/manage/task/UpgradeSystemDdlTask.java
View File

@@ -4,6 +4,7 @@ import com.alibaba.druid.sql.ast.SQLStatement;
import com.alibaba.druid.sql.ast.statement.*;
import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
import com.zyplayer.doc.core.enums.SystemConfigEnum;
import com.zyplayer.doc.core.util.UpgradeInfo;
import com.zyplayer.doc.core.util.ZyplayerDocVersion;
import com.zyplayer.doc.data.repository.manage.mapper.UserInfoMapper;
import com.zyplayer.doc.data.service.manage.SystemConfigService;
@@ -107,13 +108,15 @@ public class UpgradeSystemDdlTask {
logger.info("升级数据库DDL脚本：{} --> {}", nowVersion, ZyplayerDocVersion.version);
boolean isStart = false;
for (int i = ZyplayerDocVersion.versionUpgrade.size() - 1; i >= 0; i--) {
String version = ZyplayerDocVersion.versionUpgrade.get(i);
UpgradeInfo upgradeInfo = ZyplayerDocVersion.versionUpgrade.get(i);
if (!isStart) {
if (Objects.equals(version, nowVersion)) {
if (Objects.equals(upgradeInfo.getVersion(), nowVersion)) {
isStart = true;
}
} else if (!upgradeInfo.isHaveUpgradeSql()) {
logger.info("该版本无DDL脚本，跳过此版本：" + upgradeInfo.getVersion());
} else {
upgradeByVersion(version, tableList);
upgradeByVersion(upgradeInfo.getVersion(), tableList);
}
}
}
@@ -156,8 +159,12 @@ public class UpgradeSystemDdlTask {
public void upgradeByStart() {
logger.info("初始升级数据库DDL脚本：{} --> {}", "1.1.1", ZyplayerDocVersion.version);
for (int i = ZyplayerDocVersion.versionUpgrade.size() - 1; i >= 0; i--) {
String version = ZyplayerDocVersion.versionUpgrade.get(i);
String sql = loadDDLFile("sql/upgrade/" + version + ".sql");
UpgradeInfo upgradeInfo = ZyplayerDocVersion.versionUpgrade.get(i);
if (!upgradeInfo.isHaveUpgradeSql()) {
logger.info("该版本无DDL脚本，跳过此版本：" + upgradeInfo.getVersion());
continue;
}
String sql = loadDDLFile("sql/upgrade/" + upgradeInfo.getVersion() + ".sql");
if (StringUtils.isBlank(sql)) {
return;
}