aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-02-09 18:24:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

adjust proper ordering for value insert

Browse Source
This commit is contained in:
pedrocarlo
2025-05-23 21:00:02 -03:00
parent 810211b3d1
commit c8144340a0
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
core/translate/insert.rs
View File

@@ -214,7 +214,7 @@ pub fn translate_insert(
let record_register = program.alloc_register();
if inserting_multiple_rows {
populate_record_multiple_rows(
populate_columns_multiple_rows(
&mut program,
&column_mappings,
column_registers_start,
@@ -599,7 +599,7 @@ fn resolve_indicies_for_insert(
Ok(index_col_mappings)
}
fn populate_record_multiple_rows(
fn populate_columns_multiple_rows(
program: &mut ProgramBuilder,
column_mappings: &[ColumnMapping],
column_registers_start: usize,
@@ -607,19 +607,23 @@ fn populate_record_multiple_rows(
resolver: &Resolver,
) -> Result<()> {
let mut value_index_seen = 0;
let mut other_values_seen = 0;
for (i, mapping) in column_mappings.iter().enumerate() {
let target_reg = column_registers_start + i;
if mapping.value_index.is_some() {
// dbg!(mapping, i, target_reg, yield_reg + value_index_seen);
if let Some(value_index) = mapping.value_index {
// dbg!(column_registers_start + value_index);
program.emit_insn(Insn::Copy {
src_reg: yield_reg + value_index_seen,
dst_reg: target_reg,
dst_reg: column_registers_start + value_index + other_values_seen,
amount: 0,
});
value_index_seen += 1;
continue;
}
other_values_seen += 1;
if mapping.column.is_rowid_alias {
program.emit_insn(Insn::SoftNull { reg: target_reg });
} else if let Some(default_expr) = mapping.default_value {