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

small fixes

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-07-07 12:49:14 +04:00
parent 3e7e66c0e7
commit 1655c0b84f
2 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
core/translate/emitter.rs
View File

@@ -581,7 +581,7 @@ fn emit_delete_insns(
OperationMode::DELETE,
turso_cdc_cursor_id,
rowid_reg,
&table_reference.identifier, // is it OK to use identifier here?
table_reference.table.get_name(),
)?;
}
@@ -1108,7 +1108,7 @@ fn emit_update_insns(
OperationMode::DELETE,
cdc_cursor_id,
rowid_reg,
&table_ref.identifier, // is it OK to use identifier here?
table_ref.table.get_name(),
)?;
program.emit_insn(Insn::Copy {
src_reg: rowid_set_clause_reg.expect(
@@ -1123,7 +1123,7 @@ fn emit_update_insns(
OperationMode::INSERT,
cdc_cursor_id,
rowid_reg,
&table_ref.identifier, // is it OK to use identifier here?
table_ref.table.get_name(),
)?;
} else {
program.emit_insn(Insn::Copy {
@@ -1137,7 +1137,7 @@ fn emit_update_insns(
OperationMode::UPDATE,
cdc_cursor_id,
rowid_reg,
&table_ref.identifier, // is it OK to use identifier here?
table_ref.table.get_name(),
)?;
}
}
@@ -1189,7 +1189,7 @@ pub fn emit_cdc_insns(
rowid_reg: usize,
table_name: &str,
) -> Result<()> {
// (operation_id INTEGER PRIMARY KEY, operation_time INTEGER, operation_type INTEGER, table_name TEXT, row_key BLOB)
// (operation_id INTEGER PRIMARY KEY AUTOINCREMENT, operation_time INTEGER, operation_type INTEGER, table_name TEXT, id)
let turso_cdc_registers = program.alloc_registers(5);
program.emit_insn(Insn::Null {
dest: turso_cdc_registers,
@@ -1230,11 +1230,10 @@ pub fn emit_cdc_insns(
});
let rowid_reg = program.alloc_register();
// todo(sivukhin): we **must** guarantee sequential generation or operation_id column
program.emit_insn(Insn::NewRowid {
cursor: cdc_cursor_id,
rowid_reg,
prev_largest_reg: 0,
prev_largest_reg: 0, // todo(sivukhin): properly set value here from sqlite_sequence table when AUTOINCREMENT will be properly implemented in Turso
});
let record_reg = program.alloc_register();

2
tests/integration/functions/mod.rs
View File

@@ -1,2 +1,2 @@
mod test_function_rowid;
mod test_cdc;
mod test_function_rowid;