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

[fix](Nereids) relation in constraints should be multi parts (#30293)

Browse Source
This commit is contained in:
谢健
2024-01-24 14:09:53 +08:00
committed by yiguolei
parent 7e1a986fa1
commit 2951f9a2c7
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -435,7 +435,6 @@ import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.function.Supplier;
import java.util.stream.Collectors;
@ -755,14 +754,14 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor<Object> {
@Override
public LogicalPlan visitShowConstraint(ShowConstraintContext ctx) {
Set<UnboundRelation> unboundRelation = visitRelation(ctx.table)
.collect(UnboundRelation.class::isInstance);
return new ShowConstraintsCommand(unboundRelation.iterator().next().getNameParts());
List<String> parts = visitMultipartIdentifier(ctx.table);
return new ShowConstraintsCommand(parts);
}
@Override
public LogicalPlan visitAddConstraint(AddConstraintContext ctx) {
LogicalPlan curTable = visitRelation(ctx.table);
List<String> parts = visitMultipartIdentifier(ctx.table);
UnboundRelation curTable = new UnboundRelation(StatementScopeIdGenerator.newRelationId(), parts);
ImmutableList<Slot> slots = visitIdentifierList(ctx.constraint().slots).stream()
.map(UnboundSlot::new)
.collect(ImmutableList.toImmutableList());
@ -786,7 +785,8 @@ public class LogicalPlanBuilder extends DorisParserBaseVisitor<Object> {
@Override
public LogicalPlan visitDropConstraint(DropConstraintContext ctx) {
LogicalPlan curTable = visitRelation(ctx.table);
List<String> parts = visitMultipartIdentifier(ctx.table);
UnboundRelation curTable = new UnboundRelation(StatementScopeIdGenerator.newRelationId(), parts);
return new DropConstraintCommand(ctx.constraintName.getText().toLowerCase(), curTable);
}