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

[regression](partial update) Add cases when the deleted rows have non nullable columns without default value (#26776)

Browse Source
This commit is contained in:
bobhan1
2023-11-13 10:36:59 +08:00
committed by GitHub
parent c0fda8c5c2
commit 7e36ab838f
6 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -157,7 +157,7 @@ public class DeleteStmt extends DdlStmt {
expr = new BoolLiteral(true);
} else if (column.isKey()) {
expr = new SlotRef(targetTableRef.getAliasAsName(), column.getName());
} else if (!isMow && !column.isVisible() || (!column.isAllowNull() && !column.hasDefaultValue())) {
} else if (!isMow && !column.isVisible()) {
expr = new SlotRef(targetTableRef.getAliasAsName(), column.getName());
} else {
continue;

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

@ -103,7 +103,7 @@ public class DeleteCommand extends Command implements ForwardWithSync, Explainab
selectLists.add(new UnboundSlot(tableName, targetTable.getSequenceMapCol()));
} else if (column.isKey()) {
selectLists.add(new UnboundSlot(tableName, column.getName()));
} else if ((!isMow && !column.isVisible()) || (!column.isAllowNull() && !column.hasDefaultValue())) {
} else if (!isMow && !column.isVisible()) {
selectLists.add(new UnboundSlot(tableName, column.getName()));
} else {
continue;