| 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 | 
