mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-05-25 09:19:46 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: add type judgment

Browse Source
This commit is contained in:
guoaomen
2023-05-18 09:57:03 +08:00
parent 1940e36009
commit 6f5e960018
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/config/util/ConfigUtil.java
+7 -3
View File
@@ -18,6 +18,7 @@ import com.actiontech.dble.config.model.MysqlVersion;
import com.actiontech.dble.config.model.SystemConfig;
import com.actiontech.dble.config.model.db.type.DataBaseType;
import com.actiontech.dble.config.model.user.RwSplitUserConfig;
import com.actiontech.dble.config.model.user.UserConfig;
import com.actiontech.dble.services.manager.response.ChangeItem;
import com.actiontech.dble.services.manager.response.ChangeItemType;
import com.actiontech.dble.services.manager.response.ChangeType;
@@ -471,9 +472,12 @@ public final class ConfigUtil {
PhysicalDbGroup dbGroup = shardingNode.getDbGroup();
checkDbGroupVersion(dbGroup);
} else if (changeItem.getItemType() == ChangeItemType.USERNAME) {
RwSplitUserConfig rwSplitUserConfig = (RwSplitUserConfig) newConfigLoader.getUsers().get(item);
PhysicalDbGroup dbGroup = newConfigLoader.getDbGroups().get(rwSplitUserConfig.getDbGroup());
checkDbGroupVersion(dbGroup);
UserConfig userConfig = newConfigLoader.getUsers().get(item);
if (userConfig instanceof RwSplitUserConfig) {
RwSplitUserConfig rwSplitUserConfig = (RwSplitUserConfig) userConfig;
PhysicalDbGroup dbGroup = newConfigLoader.getDbGroups().get(rwSplitUserConfig.getDbGroup());
checkDbGroupVersion(dbGroup);
}
}
}
}