1 | #include "duckdb/catalog/catalog_entry/table_catalog_entry.hpp" |
---|---|
2 | #include "duckdb/execution/operator/persistent/physical_delete.hpp" |
3 | #include "duckdb/execution/physical_plan_generator.hpp" |
4 | #include "duckdb/planner/expression/bound_reference_expression.hpp" |
5 | #include "duckdb/planner/operator/logical_delete.hpp" |
6 | |
7 | using namespace duckdb; |
8 | using namespace std; |
9 | |
10 | unique_ptr<PhysicalOperator> PhysicalPlanGenerator::CreatePlan(LogicalDelete &op) { |
11 | assert(op.children.size() == 1); |
12 | assert(op.expressions.size() == 1); |
13 | assert(op.expressions[0]->type == ExpressionType::BOUND_REF); |
14 | |
15 | auto plan = CreatePlan(*op.children[0]); |
16 | |
17 | // get the index of the row_id column |
18 | auto &bound_ref = (BoundReferenceExpression &)*op.expressions[0]; |
19 | |
20 | dependencies.insert(op.table); |
21 | auto del = make_unique<PhysicalDelete>(op, *op.table, *op.table->storage, bound_ref.index); |
22 | del->children.push_back(move(plan)); |
23 | return move(del); |
24 | } |
25 |