1 | #include "duckdb/planner/expression/bound_cast_expression.hpp" |
2 | #include "duckdb/planner/binder.hpp" |
3 | #include "duckdb/planner/operator/logical_projection.hpp" |
4 | #include "duckdb/planner/operator/logical_recursive_cte.hpp" |
5 | #include "duckdb/planner/operator/logical_set_operation.hpp" |
6 | #include "duckdb/planner/query_node/bound_recursive_cte_node.hpp" |
7 | |
8 | using namespace duckdb; |
9 | using namespace std; |
10 | |
11 | unique_ptr<LogicalOperator> Binder::CreatePlan(BoundRecursiveCTENode &node) { |
12 | // Generate the logical plan for the left and right sides of the set operation |
13 | node.left_binder->plan_subquery = plan_subquery; |
14 | node.right_binder->plan_subquery = plan_subquery; |
15 | |
16 | auto left_node = node.left_binder->CreatePlan(*node.left); |
17 | auto right_node = node.right_binder->CreatePlan(*node.right); |
18 | |
19 | // check if there are any unplanned subqueries left in either child |
20 | has_unplanned_subqueries = |
21 | node.left_binder->has_unplanned_subqueries || node.right_binder->has_unplanned_subqueries; |
22 | |
23 | // for both the left and right sides, cast them to the same types |
24 | left_node = CastLogicalOperatorToTypes(node.left->types, node.types, move(left_node)); |
25 | right_node = CastLogicalOperatorToTypes(node.right->types, node.types, move(right_node)); |
26 | |
27 | if (node.right_binder->bind_context.cte_references[node.ctename] == 0) { |
28 | auto root = make_unique<LogicalSetOperation>(node.setop_index, node.types.size(), move(left_node), |
29 | move(right_node), LogicalOperatorType::UNION); |
30 | return VisitQueryNode(node, move(root)); |
31 | } |
32 | auto root = make_unique<LogicalRecursiveCTE>(node.setop_index, node.types.size(), node.union_all, move(left_node), |
33 | move(right_node), LogicalOperatorType::RECURSIVE_CTE); |
34 | |
35 | return VisitQueryNode(node, move(root)); |
36 | } |
37 | |