1 | #include "duckdb/execution/operator/schema/physical_create_function.hpp" |
2 | #include "duckdb/execution/operator/schema/physical_create_schema.hpp" |
3 | #include "duckdb/execution/operator/schema/physical_create_sequence.hpp" |
4 | #include "duckdb/execution/operator/schema/physical_create_type.hpp" |
5 | #include "duckdb/execution/operator/schema/physical_create_view.hpp" |
6 | #include "duckdb/execution/physical_plan_generator.hpp" |
7 | #include "duckdb/parser/parsed_data/create_type_info.hpp" |
8 | #include "duckdb/planner/logical_operator.hpp" |
9 | #include "duckdb/planner/operator/logical_create.hpp" |
10 | |
11 | namespace duckdb { |
12 | |
13 | unique_ptr<PhysicalOperator> PhysicalPlanGenerator::CreatePlan(LogicalCreate &op) { |
14 | switch (op.type) { |
15 | case LogicalOperatorType::LOGICAL_CREATE_SEQUENCE: |
16 | return make_uniq<PhysicalCreateSequence>(args: unique_ptr_cast<CreateInfo, CreateSequenceInfo>(src: std::move(op.info)), |
17 | args&: op.estimated_cardinality); |
18 | case LogicalOperatorType::LOGICAL_CREATE_VIEW: |
19 | return make_uniq<PhysicalCreateView>(args: unique_ptr_cast<CreateInfo, CreateViewInfo>(src: std::move(op.info)), |
20 | args&: op.estimated_cardinality); |
21 | case LogicalOperatorType::LOGICAL_CREATE_SCHEMA: |
22 | return make_uniq<PhysicalCreateSchema>(args: unique_ptr_cast<CreateInfo, CreateSchemaInfo>(src: std::move(op.info)), |
23 | args&: op.estimated_cardinality); |
24 | case LogicalOperatorType::LOGICAL_CREATE_MACRO: |
25 | return make_uniq<PhysicalCreateFunction>(args: unique_ptr_cast<CreateInfo, CreateMacroInfo>(src: std::move(op.info)), |
26 | args&: op.estimated_cardinality); |
27 | case LogicalOperatorType::LOGICAL_CREATE_TYPE: { |
28 | unique_ptr<PhysicalOperator> create = make_uniq<PhysicalCreateType>( |
29 | args: unique_ptr_cast<CreateInfo, CreateTypeInfo>(src: std::move(op.info)), args&: op.estimated_cardinality); |
30 | if (!op.children.empty()) { |
31 | D_ASSERT(op.children.size() == 1); |
32 | auto plan = CreatePlan(op&: *op.children[0]); |
33 | create->children.push_back(x: std::move(plan)); |
34 | } |
35 | return create; |
36 | } |
37 | default: |
38 | throw NotImplementedException("Unimplemented type for logical simple create" ); |
39 | } |
40 | } |
41 | |
42 | } // namespace duckdb |
43 | |