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

small fixes

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-07-06 22:26:34 +04:00
parent 32fa2ac3ee
commit 62c1e38805
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
core/translate/emitter.rs
View File

@@ -25,7 +25,6 @@ use crate::function::Func;
use crate::schema::Schema;
use crate::translate::compound_select::emit_program_for_compound_select;
use crate::translate::plan::{DeletePlan, Plan, QueryDestination, Search};
use crate::translate::pragma::TURSO_CDC_TABLE_NAME;
use crate::translate::values::emit_values;
use crate::util::exprs_are_equivalent;
use crate::vdbe::builder::{CursorKey, CursorType, ProgramBuilder};
@@ -1251,7 +1250,7 @@ pub fn emit_cdc_insns(
key_reg: rowid_reg,
record_reg,
flag: InsertFlags::new(),
table_name: TURSO_CDC_TABLE_NAME.to_string(),
table_name: "".to_string(),
});
Ok(())
}

2
core/translate/insert.rs
View File

@@ -120,7 +120,7 @@ pub fn translate_insert(
let cdc_table = program.capture_data_changes_mode().table();
let cdc_table = if let Some(cdc_table) = cdc_table {
if table.get_name() != cdc_table {
let Some(turso_cdc_table) = schema.get_table(&cdc_table) else {
let Some(turso_cdc_table) = schema.get_table(cdc_table) else {
crate::bail_parse_error!("no such table: {}", cdc_table);
};
let Some(cdc_btree) = turso_cdc_table.btree().clone() else {