mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-06 04:40:17 -06:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3695 from actiontech/fix/rwsplituser

Browse Source 
fix: add type judgment
This commit is contained in:
LUA
2023-05-18 10:15:30 +08:00
committed by GitHub
parent 1940e36009 6f5e960018
commit d97d885283
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/actiontech/dble/config/util/ConfigUtil.java
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);
}
}
}
}