Merge branch 'master' into inner-2218

actiontech · Jun 28, 2023 · 1c9b6dd · 1c9b6dd
2 parents e45711c + da4593e
commit 1c9b6dd
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/main/java/com/actiontech/dble/btrace/provider/SlowLogProvider.java b/src/main/java/com/actiontech/dble/btrace/provider/SlowLogProvider.java
@@ -0,0 +1,9 @@
+package com.actiontech.dble.btrace.provider;
+
+public final class SlowLogProvider {
+    private SlowLogProvider() {
+    }
+
+    public static void setShardingNodes() {
+    }
+}
diff --git a/src/main/java/com/actiontech/dble/server/trace/TraceResult.java b/src/main/java/com/actiontech/dble/server/trace/TraceResult.java
@@ -10,6 +10,7 @@
 import com.actiontech.dble.backend.mysql.nio.handler.query.DMLResponseHandler;
 import com.actiontech.dble.backend.mysql.nio.handler.query.impl.BaseSelectHandler;
 import com.actiontech.dble.backend.mysql.nio.handler.query.impl.OutputHandler;
+import com.actiontech.dble.btrace.provider.SlowLogProvider;
 import com.actiontech.dble.plan.util.ComplexQueryPlanUtil;
 import com.actiontech.dble.plan.util.ReferenceHandlerInfo;
 import com.actiontech.dble.route.RouteResultsetNode;
@@ -127,6 +128,7 @@ public void setShardingNodes(RouteResultsetNode[] shardingNodes) {
             System.arraycopy(this.shardingNodes, 0, tempShardingNodes, 0, this.shardingNodes.length);
             System.arraycopy(shardingNodes, 0, tempShardingNodes, this.shardingNodes.length, shardingNodes.length);
             this.shardingNodes = tempShardingNodes;
+            SlowLogProvider.setShardingNodes();
             if (LOGGER.isDebugEnabled()) {
                 LOGGER.debug("append to existing shardingNodes,current size is " + this.shardingNodes.length);
             }