aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-31 13:54:27 +01:00
Code Issues Packages Projects Releases Wiki Activity

Extract QueryDestination::placeholder_for_subquery

Browse Source
This commit is contained in:
Piotr Rzysko
2025-09-06 05:58:36 +02:00
parent 1826023c32
commit c81cd16230
2 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/translate/plan.rs
View File

@@ -198,6 +198,15 @@ pub enum QueryDestination {
},
}
impl QueryDestination {
pub fn placeholder_for_subquery() -> Self {
QueryDestination::CoroutineYield {
yield_reg: usize::MAX, // will be set later in bytecode emission
coroutine_implementation_start: BranchOffset::Placeholder, // will be set later in bytecode emission
}
}
}
#[derive(Debug, Default, Clone, Copy, PartialEq, Eq)]
pub struct JoinOrderMember {
/// The internal ID of the[TableReference]

12
core/translate/planner.rs
View File

@@ -18,7 +18,7 @@ use crate::{
schema::{Schema, Table},
translate::expr::walk_expr_mut,
util::{exprs_are_equivalent, normalize_ident},
vdbe::{builder::TableRefIdCounter, BranchOffset},
vdbe::builder::TableRefIdCounter,
Result,
};
use turso_macros::match_ignore_ascii_case;
@@ -403,10 +403,7 @@ fn parse_from_clause_table(
syms,
table_references.outer_query_refs(),
table_ref_counter,
QueryDestination::CoroutineYield {
yield_reg: usize::MAX, // will be set later in bytecode emission
coroutine_implementation_start: BranchOffset::Placeholder, // will be set later in bytecode emission
},
QueryDestination::placeholder_for_subquery(),
connection,
)?
else {
@@ -722,10 +719,7 @@ pub fn parse_from(
syms,
&outer_query_refs_for_cte,
table_ref_counter,
QueryDestination::CoroutineYield {
yield_reg: usize::MAX, // will be set later in bytecode emission
coroutine_implementation_start: BranchOffset::Placeholder, // will be set later in bytecode emission
},
QueryDestination::placeholder_for_subquery(),
connection,
)?;
let Plan::Select(cte_plan) = cte_plan else {