database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[feature](nereids) support join with joinRelation (#30909)

Browse Source
This commit is contained in:
starocean999
2024-02-26 14:32:46 +08:00
committed by yiguolei
parent bc41033b5d
commit 5d4a2d93a6
4 changed files with 28 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java
View File

@ -805,7 +805,7 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor<Object> {
StatementScopeIdGenerator.newRelationId(), visitMultipartIdentifier(ctx.tableName)));
query = withTableAlias(query, ctx.tableAlias());
if (ctx.fromClause() != null) {
query = withRelations(query, ctx.fromClause().relation());
query = withRelations(query, ctx.fromClause().relations().relation());
}
query = withFilter(query, Optional.of(ctx.whereClause()));
String tableAlias = null;
@ -836,7 +836,7 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor<Object> {
return new DeleteFromCommand(tableName, tableAlias, partitionSpec.first, partitionSpec.second, query);
} else {
// convert to insert into select
query = withRelations(query, ctx.relation());
query = withRelations(query, ctx.relations().relation());
query = withFilter(query, Optional.ofNullable(ctx.whereClause()));
Optional<LogicalPlan> cte = Optional.empty();
if (ctx.cte() != null) {
@ -2248,9 +2248,19 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor<Object> {
@Override
public LogicalPlan visitFromClause(FromClauseContext ctx) {
return ParserUtils.withOrigin(ctx, () -> visitRelations(ctx.relations()));
}
@Override
public LogicalPlan visitRelations(DorisParser.RelationsContext ctx) {
return ParserUtils.withOrigin(ctx, () -> withRelations(null, ctx.relation()));
}
@Override
public LogicalPlan visitRelationList(DorisParser.RelationListContext ctx) {
return ParserUtils.withOrigin(ctx, () -> withRelations(null, ctx.relations().relation()));
}
/* ********************************************************************************************
* Table Identifier parsing
* ******************************************************************************************** */