(
&self,
subquery: Query,
negated: bool,
input_schema: &DFSchema,
planner_context: &mut PlannerContext,
)
| 25 | |
| 26 | impl<S: ContextProvider> SqlToRel<'_, S> { |
| 27 | pub(super) fn parse_exists_subquery( |
| 28 | &self, |
| 29 | subquery: Query, |
| 30 | negated: bool, |
| 31 | input_schema: &DFSchema, |
| 32 | planner_context: &mut PlannerContext, |
| 33 | ) -> Result<Expr> { |
| 34 | planner_context.append_outer_query_schema(input_schema.clone().into()); |
| 35 | let sub_plan = self.query_to_plan(subquery, planner_context)?; |
| 36 | let outer_ref_columns = sub_plan.all_out_ref_exprs(); |
| 37 | planner_context.pop_outer_query_schema(); |
| 38 | Ok(Expr::Exists(Exists { |
| 39 | subquery: Subquery { |
| 40 | subquery: Arc::new(sub_plan), |
| 41 | outer_ref_columns, |
| 42 | spans: Spans::new(), |
| 43 | }, |
| 44 | negated, |
| 45 | })) |
| 46 | } |
| 47 | |
| 48 | pub(super) fn parse_in_subquery( |
| 49 | &self, |
no test coverage detected