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

handle schema changes in sync engine

Browse Source
This commit is contained in:
Nikita Sivukhin
2025-08-11 16:52:18 +04:00
parent 5e773d286e
commit 372d23b7cc
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/turso-sync-engine/src/database_sync_operations.rs
View File

@@ -326,6 +326,7 @@ pub async fn transfer_logical_changes(
let iterate_opts = DatabaseChangesIteratorOpts {
first_change_id: last_change_id.map(|x| x + 1),
mode: DatabaseChangesIteratorMode::Apply,
ignore_schema_changes: false,
..Default::default()
};
let mut changes = source.iterate_changes(iterate_opts)?;
@@ -599,7 +600,6 @@ pub mod tests {
conn1.execute("INSERT INTO t VALUES (1, 2), (3, 4), (5, 6)")?;
let conn2 = db2.connect(&coro).await?;
conn2.execute("CREATE TABLE t(x, y)")?;
transfer_logical_changes(&coro, &db1, &db2, "id-1", false).await?;