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

[Fix](planner)fix delete stmt contains where but delete all data. (#22563)

Browse Source
This commit is contained in:
mch_ucchi
2023-08-03 23:44:05 +08:00
committed by GitHub
parent c4cee5122b
commit 3447a70b25
4 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fe/fe-core/src/main/java/org/apache/doris/analysis/DeleteStmt.java
View File

@ -125,6 +125,7 @@ public class DeleteStmt extends DdlStmt {
if (!(((OlapTable) targetTable).getKeysType() == KeysType.UNIQUE_KEYS)) {
throw new AnalysisException(e.getMessage(), e.getCause());
}
wherePredicate.reset();
constructInsertStmt();
}
} else {

2
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/DeleteCommand.java
View File

@ -112,7 +112,7 @@ public class DeleteCommand extends Command implements ForwardWithSync, Explainab
logicalQuery = new LogicalProject<>(selectLists, logicalQuery);
boolean isPartialUpdate = false;
if (((OlapTable) targetTable).getEnableUniqueKeyMergeOnWrite()
if (targetTable.getEnableUniqueKeyMergeOnWrite()
&& cols.size() < targetTable.getColumns().size()) {
isPartialUpdate = true;
}