mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-27 15:58:52 -06:00
Code Issues Packages Projects Releases Wiki Activity

inner DBLE0REQ-1466

Browse Source
This commit is contained in:
yanhuqing666
2021-11-17 15:53:10 +08:00
parent 3a410c272f
commit a87d12f064
2 changed files with 28 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/actiontech/dble/server/NonBlockingSession.java
View File

@@ -10,6 +10,7 @@ import com.actiontech.dble.backend.datasource.ShardingNode;
import com.actiontech.dble.backend.mysql.nio.handler.*;
import com.actiontech.dble.backend.mysql.nio.handler.builder.BaseHandlerBuilder;
import com.actiontech.dble.backend.mysql.nio.handler.builder.HandlerBuilder;
import com.actiontech.dble.backend.mysql.nio.handler.builder.sqlvisitor.GlobalVisitor;
import com.actiontech.dble.backend.mysql.nio.handler.query.DMLResponseHandler;
import com.actiontech.dble.backend.mysql.nio.handler.query.impl.OutputHandler;
import com.actiontech.dble.backend.mysql.nio.handler.transaction.ImplicitCommitHandler;
@@ -614,7 +615,17 @@ public class NonBlockingSession extends Session {
tableSet.addAll(set);
}
}
RouteResultsetNode[] nodes = {new RouteResultsetNode(nodeName, rrs.getSqlType(), node.getSql(), tableSet)};
String sql = node.getSql();
if (node.isExistView()) {
GlobalVisitor visitor = new GlobalVisitor(node, true);
visitor.visit();
sql = visitor.getSql().toString();
Map<String, String> mapTableToSimple = visitor.getMapTableToSimple();
for (Map.Entry<String, String> tableToSimple : mapTableToSimple.entrySet()) {
sql = sql.replace(tableToSimple.getKey(), tableToSimple.getValue());
}
}
RouteResultsetNode[] nodes = {new RouteResultsetNode(nodeName, rrs.getSqlType(), sql, tableSet)};
rrs.setNodes(nodes);
setRouteResultToTrace(nodes);
// dml or simple select

19
src/main/java/com/actiontech/dble/server/handler/ExplainHandler.java
View File

@@ -9,6 +9,7 @@ import com.actiontech.dble.DbleServer;
import com.actiontech.dble.backend.mysql.PacketUtil;
import com.actiontech.dble.backend.mysql.nio.handler.builder.BaseHandlerBuilder;
import com.actiontech.dble.backend.mysql.nio.handler.builder.HandlerBuilder;
import com.actiontech.dble.backend.mysql.nio.handler.builder.sqlvisitor.GlobalVisitor;
import com.actiontech.dble.backend.mysql.nio.handler.query.impl.MultiNodeMergeHandler;
import com.actiontech.dble.config.ErrorCode;
import com.actiontech.dble.config.Fields;
@@ -45,6 +46,7 @@ import java.sql.SQLException;
import java.sql.SQLNonTransientException;
import java.sql.SQLSyntaxErrorException;
import java.util.List;
import java.util.Map;
/**
* @author mycat
@@ -235,9 +237,20 @@ public final class ExplainHandler {
}
}
if (!StringUtil.isBlank(routeNode)) {
RouteResultsetNode[] nodes = {new RouteResultsetNode(routeNode, rrs.getSqlType(), builder.getNode().getSql())};
for (RouteResultsetNode node : nodes) {
RowDataPacket row = getRow(node, service.getCharset().getResults());
PlanNode node = builder.getNode();
String sql = node.getSql();
if (node.isExistView()) {
GlobalVisitor visitor = new GlobalVisitor(node, true);
visitor.visit();
sql = visitor.getSql().toString();
Map<String, String> mapTableToSimple = visitor.getMapTableToSimple();
for (Map.Entry<String, String> tableToSimple : mapTableToSimple.entrySet()) {
sql = sql.replace(tableToSimple.getKey(), tableToSimple.getValue());
}
}
RouteResultsetNode[] nodes = {new RouteResultsetNode(routeNode, rrs.getSqlType(), sql)};
for (RouteResultsetNode rrsNode : nodes) {
RowDataPacket row = getRow(rrsNode, service.getCharset().getResults());
row.setPacketId(++packetId);
buffer = row.write(buffer, service, true);
}