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

fix cdc emit

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-07-23 15:50:34 +04:00
parent fd63128227
commit d3f3807ede
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/translate/insert.rs
View File

@@ -556,7 +556,7 @@ pub fn translate_insert(
Some(emit_cdc_patch_record(
&mut program,
&table,
column_registers_start,
column_registers_start + 1,
record_register,
column_registers_start,
))
@@ -794,7 +794,7 @@ fn populate_columns_multiple_rows(
if let Some(value_index) = mapping.value_index {
let write_directly_to_rowid_reg = mapping.column.is_rowid_alias;
let write_reg = if write_directly_to_rowid_reg {
if last_rowid_explicit_value.map_or(false, |x| x > value_index) {
if last_rowid_explicit_value.is_some_and(|x| x > value_index) {
continue;
}
last_rowid_explicit_value = Some(value_index);
@@ -864,7 +864,7 @@ fn populate_column_registers(
// directly into the rowid register and writes a NULL into the rowid alias column.
let write_directly_to_rowid_reg = mapping.column.is_rowid_alias;
let write_reg = if write_directly_to_rowid_reg {
if last_rowid_explicit_value.map_or(false, |x| x > value_index) {
if last_rowid_explicit_value.is_some_and(|x| x > value_index) {
continue;
}
last_rowid_explicit_value = Some(value_index);