actiontech · yanhuqing666 · Nov 15, 2019 · Nov 15, 2019 · Nov 15, 2019 · Nov 15, 2019
diff --git a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDBPoolDiff.java b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDBPoolDiff.java
@@ -57,27 +57,30 @@ private Set<PhysicalDatasourceDiff> createHostChangeSet(AbstractPhysicalDBPool n
         for (int i = 0; i < newDbPool.getWriteSources().length; i++) {
             PhysicalDatasource writeHost = newDbPool.getWriteSources()[i];
             PhysicalDatasource[] readHost = newDbPool.getReadSources().get(i);
+            PhysicalDatasource[] standByHost = newDbPool.getStandbyReadSourcesMap().get(i);
 
             PhysicalDatasource orgHost = null;
             PhysicalDatasource[] relatedHost = null;
             for (int j = 0; j < orgDbPool.getWriteSources().length; j++) {
                 PhysicalDatasource oldHost = orgDbPool.getWriteSources()[j];
                 PhysicalDatasource[] oldRHost = orgDbPool.getReadSources().get(j);
+                PhysicalDatasource[] oldStandByHost = orgDbPool.getStandbyReadSourcesMap().get(j);
+
 
                 if (oldHost.equals(writeHost) &&
-                        ((oldRHost == null && readHost == null) ||
-                                ((oldRHost != null && readHost != null) && oldRHost.length == readHost.length))) {
+                        ((oldRHost == null && readHost == null) || ((oldRHost != null && readHost != null) && oldRHost.length == readHost.length)) &&
+                        ((oldStandByHost == null && standByHost == null) || ((oldStandByHost != null && standByHost != null) && oldStandByHost.length == standByHost.length))) {
                     boolean sameFlag = true;
-                    if (oldRHost != null) {
-                        for (int k = 0; k < oldRHost.length; k++) {
-                            if (!oldRHost[k].equals(readHost[k])) {
-                                sameFlag = false;
-                                break;
-                            } else {
-                                oldRHost[k].setTestConnSuccess(readHost[k].isTestConnSuccess());
-                            }
-                        }
+
+                    //compare the readHost is the same
+                    sameFlag = calculateForDataSources(oldRHost, readHost);
+                    //compare the sandByHost is the same
+                    if (sameFlag) {
+                        sameFlag = calculateForDataSources(oldStandByHost, standByHost);
                     }
+
+                    //only when the writeHost is the same && readHost list is the same && standByHost is the same
+                    // that means the two dataHost is the same
                     if (sameFlag) {
                         //update connection test result
                         oldHost.setTestConnSuccess(writeHost.isTestConnSuccess());
@@ -86,6 +89,7 @@ private Set<PhysicalDatasourceDiff> createHostChangeSet(AbstractPhysicalDBPool n
                         break;
                     }
                 }
+
             }
 
             if (orgHost != null) {
@@ -115,6 +119,20 @@ private Set<PhysicalDatasourceDiff> createHostChangeSet(AbstractPhysicalDBPool n
         return hostDiff;
     }
 
+
+    private boolean calculateForDataSources(PhysicalDatasource[] olds, PhysicalDatasource[] news) {
+        if (olds != null) {
+            for (int k = 0; k < olds.length; k++) {
+                if (!olds[k].equals(news[k])) {
+                    return false;
+                } else {
+                    olds[k].setTestConnSuccess(news[k].isTestConnSuccess());
+                }
+            }
+        }
+        return true;
+    }
+
     //    private Set<BaseInfoDiff> createBaseDiff(PhysicalDBPool newDbPool, PhysicalDBPool orgDbPool) {
     //        Set<BaseInfoDiff> baseDiffSet = new HashSet<BaseInfoDiff>();
     //        if (newDbPool.getDataHostConfig().getBalance() != orgDbPool.getDataHostConfig().getBalance()) {

diff --git a/src/main/java/com/actiontech/dble/manager/response/DataHostDisable.java b/src/main/java/com/actiontech/dble/manager/response/DataHostDisable.java
@@ -85,7 +85,7 @@ public static void execute(Matcher disable, ManagerConnection mc) {
                 packet.setServerStatus(2);
                 packet.write(mc);
             } else {
-                mc.writeErrMessage(ErrorCode.ER_YES, "dataHost mod not allowed to disable");
+                mc.writeErrMessage(ErrorCode.ER_YES, "dble server not in useOuterHa mode");
             }
         } finally {
             lock.readLock().unlock();

diff --git a/src/main/java/com/actiontech/dble/manager/response/DataHostEnable.java b/src/main/java/com/actiontech/dble/manager/response/DataHostEnable.java
@@ -79,7 +79,7 @@ public static void execute(Matcher enable, ManagerConnection mc) {
                 packet.setServerStatus(2);
                 packet.write(mc);
             } else {
-                mc.writeErrMessage(ErrorCode.ER_YES, "dataHost " + dhName + " do not exists");
+                mc.writeErrMessage(ErrorCode.ER_YES, "dble server not in useOuterHa mode");
             }
         } finally {
             lock.readLock().unlock();

diff --git a/src/main/java/com/actiontech/dble/manager/response/DataHostSwitch.java b/src/main/java/com/actiontech/dble/manager/response/DataHostSwitch.java
@@ -78,7 +78,7 @@ public static void execute(Matcher switcher, ManagerConnection mc) {
                 packet.setServerStatus(2);
                 packet.write(mc);
             } else {
-                mc.writeErrMessage(ErrorCode.ER_YES, "dataHost " + dhName + " do not exists");
+                mc.writeErrMessage(ErrorCode.ER_YES, "dble server not in useOuterHa mode");
             }
         } finally {
             lock.readLock().unlock();

diff --git a/src/main/java/com/actiontech/dble/manager/response/ShowSysParam.java b/src/main/java/com/actiontech/dble/manager/response/ShowSysParam.java
@@ -151,6 +151,7 @@ public static void execute(ManagerConnection c) {
         paramValues.add(sysConfig.getSqlSlowTime() + "ms");
         paramValues.add(sysConfig.getMaxCharsPerColumn() + "");
         paramValues.add(sysConfig.getMaxRowSizeToFile() + "");
+        paramValues.add(sysConfig.isUseOuterHa() + "");
 
 
         for (int i = 0; i < PARAM_NAMES.length; i++) {
@@ -252,6 +253,7 @@ public static void execute(ManagerConnection c) {
             "sqlSlowTime",
             "maxCharsPerColumn",
             "maxRowSizeToFile",
+            "useOuterHa",
     };
 
     private static final String[] PARAM_DESCRIPTION = {
@@ -335,6 +337,7 @@ public static void execute(ManagerConnection c) {
             "The threshold of Slow Query, the default is 100ms",
             "The maximum number of characters allowed for per column when load data.The default value is 65535",
             "The maximum row size,if over this value,row data will be saved to file when load data.The default value is 10000",
+            "Whether use outer ha component ",
     };
 
     private static final String[] ISOLATION_LEVELS = {"", "READ_UNCOMMITTED", "READ_COMMITTED", "REPEATABLE_READ", "SERIALIZABLE"};

diff --git a/src/main/resources/myid.properties b/src/main/resources/myid.properties
@@ -13,3 +13,4 @@ clusterId=cluster-1
 #it must be different for every node in cluster
 myid=server_02
 serverID=server_02
+clusterHa=false