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

fix com change user protocol error inner 1807 (#3300)

Browse Source 
* fix com changeu user  protocol  error  inner 1807

* fix ci
This commit is contained in:
ylinzhu
2022-07-08 15:06:06 +08:00
committed by GitHub
parent b565b57a71
commit 39465e2faf
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/actiontech/dble/services/rwsplit/RWSplitService.java
View File

@@ -40,6 +40,7 @@ import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.HashSet;
import java.util.Objects;
import java.util.Optional;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicLong;
@@ -436,9 +437,9 @@ public class RWSplitService extends BusinessService<SingleDbGroupUserConfig> {
setLockTable(false);
inLoadData = false;
txStarted = false;
this.tmpTableSet.clear();
this.sysVariables.clear();
this.usrVariables.clear();
Optional.ofNullable(tmpTableSet).ifPresent((tmpTables) -> tmpTables.clear());
Optional.ofNullable(sysVariables).ifPresent((sysVariableMap) -> sysVariableMap.clear());
Optional.ofNullable(usrVariables).ifPresent((usrVariableMap) -> usrVariableMap.clear());
autocommit = SystemConfig.getInstance().getAutocommit() == 1;
txIsolation = SystemConfig.getInstance().getTxIsolation();
setCharacterSet(SystemConfig.getInstance().getCharset());