mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2025-12-30 17:30:21 -06:00
Code Issues Packages Projects Releases Wiki Activity

#1280 check a table is view when the table has a schema name above (#1296)

Browse Source
This commit is contained in:
zhengfang.sun
2019-08-08 13:43:03 +08:00
committed by tiger.yan
parent 610315f908
commit cfff7cae5a
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/actiontech/dble/plan/visitor/MySQLPlanNodeVisitor.java
View File

@@ -167,12 +167,27 @@ public class MySQLPlanNodeVisitor {
SQLExpr expr = tableSource.getExpr();
if (expr instanceof SQLPropertyExpr) {
SQLPropertyExpr propertyExpr = (SQLPropertyExpr) expr;
QueryNode viewNode = null;
try {
table = new TableNode(StringUtil.removeBackQuote(propertyExpr.getOwner().toString()), StringUtil.removeBackQuote(propertyExpr.getName()), this.metaManager);
viewNode = metaManager.getSyncView(propertyExpr.getOwnernName(), propertyExpr.getName());
} catch (SQLNonTransientException e) {
throw new MySQLOutPutException(e.getErrorCode(), e.getSQLState(), e.getMessage());
}
containSchema = true;
if (viewNode != null) {
viewNode.setAlias(tableSource.getAlias() == null ? propertyExpr.getName() : tableSource.getAlias());
this.tableNode = viewNode;
tableNode.setWithSubQuery(true);
this.tableNode.setExistView(true);
tableNode.setKeepFieldSchema(false);
return true;
} else {
try {
table = new TableNode(StringUtil.removeBackQuote(propertyExpr.getOwner().toString()), StringUtil.removeBackQuote(propertyExpr.getName()), this.metaManager);
} catch (SQLNonTransientException e) {
throw new MySQLOutPutException(e.getErrorCode(), e.getSQLState(), e.getMessage());
}
}
} else if (expr instanceof SQLIdentifierExpr) {
SQLIdentifierExpr identifierExpr = (SQLIdentifierExpr) expr;
if (identifierExpr.getName().equalsIgnoreCase("dual")) {