aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-06 08:44:23 +01:00
Code Issues Packages Projects Releases Wiki Activity

rename

Browse Source
This commit is contained in:
Jussi Saurio
2025-05-22 12:49:36 +03:00
parent 6ed5412bde
commit 0c4c451d2a
5 changed files with 15 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/translate/aggregation.rs
View File

@@ -67,13 +67,13 @@ pub fn handle_distinct(program: &mut ProgramBuilder, agg: &Aggregate, agg_arg_re
let Distinctness::Distinct { ctx } = &agg.distinctness else {
return;
};
let distinct_agg_ctx = ctx
let distinct_ctx = ctx
.as_ref()
.expect("distinct aggregate context not populated");
let num_regs = 1;
program.emit_insn(Insn::Found {
cursor_id: distinct_agg_ctx.cursor_id,
target_pc: distinct_agg_ctx.label_on_conflict,
cursor_id: distinct_ctx.cursor_id,
target_pc: distinct_ctx.label_on_conflict,
record_reg: agg_arg_reg,
num_regs,
});
@@ -82,10 +82,10 @@ pub fn handle_distinct(program: &mut ProgramBuilder, agg: &Aggregate, agg_arg_re
start_reg: agg_arg_reg,
count: num_regs,
dest_reg: record_reg,
index_name: Some(distinct_agg_ctx.ephemeral_index_name.to_string()),
index_name: Some(distinct_ctx.ephemeral_index_name.to_string()),
});
program.emit_insn(Insn::IdxInsert {
cursor_id: distinct_agg_ctx.cursor_id,
cursor_id: distinct_ctx.cursor_id,
record_reg: record_reg,
unpacked_start: None,
unpacked_count: None,

4
core/translate/group_by.rs
View File

@@ -775,8 +775,8 @@ pub fn group_by_emit_row_phase<'a>(
);
// SELECT DISTINCT also jumps here if there is a duplicate.
if let Distinctness::Distinct { ctx } = &plan.distinctness {
let distinct_agg_ctx = ctx.as_ref().expect("distinct context must exist");
program.resolve_label(distinct_agg_ctx.label_on_conflict, program.offset());
let distinct_ctx = ctx.as_ref().expect("distinct context must exist");
program.resolve_label(distinct_ctx.label_on_conflict, program.offset());
}
program.emit_insn(Insn::Return {
return_reg: registers.reg_subrtn_acc_output_return_offset,

8
core/translate/main_loop.rs
View File

@@ -791,8 +791,8 @@ fn emit_loop_source<'a>(
)?;
if let Distinctness::Distinct { ctx } = &plan.distinctness {
let distinct_agg_ctx = ctx.as_ref().expect("distinct context must exist");
program.preassign_label_to_next_insn(distinct_agg_ctx.label_on_conflict);
let distinct_ctx = ctx.as_ref().expect("distinct context must exist");
program.preassign_label_to_next_insn(distinct_ctx.label_on_conflict);
}
Ok(())
@@ -887,8 +887,8 @@ fn emit_loop_source<'a>(
)?;
if let Distinctness::Distinct { ctx } = &plan.distinctness {
let distinct_agg_ctx = ctx.as_ref().expect("distinct context must exist");
program.preassign_label_to_next_insn(distinct_agg_ctx.label_on_conflict);
let distinct_ctx = ctx.as_ref().expect("distinct context must exist");
program.preassign_label_to_next_insn(distinct_ctx.label_on_conflict);
}
Ok(())

4
core/translate/order_by.rs
View File

@@ -252,9 +252,9 @@ pub fn order_by_sorter_insert(
// Handle SELECT DISTINCT deduplication
if let Distinctness::Distinct { ctx } = &plan.distinctness {
let distinct_agg_ctx = ctx.as_ref().expect("distinct context must exist");
let distinct_ctx = ctx.as_ref().expect("distinct context must exist");
let num_regs = order_by_len + translated_result_col_count;
distinct_agg_ctx.emit_deduplication_insns(program, num_regs, start_reg);
distinct_ctx.emit_deduplication_insns(program, num_regs, start_reg);
}
let SortMetadata {

4
core/translate/result_row.rs
View File

@@ -52,9 +52,9 @@ pub fn emit_select_result(
// Handle SELECT DISTINCT deduplication
if let Distinctness::Distinct { ctx } = &plan.distinctness {
let distinct_agg_ctx = ctx.as_ref().expect("distinct context must exist");
let distinct_ctx = ctx.as_ref().expect("distinct context must exist");
let num_regs = plan.result_columns.len();
distinct_agg_ctx.emit_deduplication_insns(program, num_regs, start_reg);
distinct_ctx.emit_deduplication_insns(program, num_regs, start_reg);
}
emit_result_row_and_limit(