Invoke PGLITE_SYNC on SQLite INSERT/UPDATE/DELETE

2026-04-28 10:33:02 -05:00 · 2025-05-12 08:24:57 -07:00
parent 72abea19dd
commit 84e0d0ffee
7 changed files with 862 additions and 3 deletions
--- a/packages/loot-core/migrations/1746726462000_pglite_sync_triggers.sql
+++ b/packages/loot-core/migrations/1746726462000_pglite_sync_triggers.sql
@@ -0,0 +1,555 @@
+BEGIN TRANSACTION;
+
+-- banks table
+
+CREATE TRIGGER banks_after_insert_pglite_sync
+AFTER INSERT ON banks
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('banks', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER banks_after_update_pglite_sync
+AFTER UPDATE ON banks
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('banks', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER banks_after_delete_pglite_sync
+AFTER DELETE ON banks
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('banks', 'DELETE', 'id', OLD.id);
+END;
+
+-- accounts table
+
+CREATE TRIGGER accounts_after_insert_pglite_sync
+AFTER INSERT ON accounts
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('accounts', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER accounts_after_update_pglite_sync
+AFTER UPDATE ON accounts
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('accounts', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER accounts_after_delete_pglite_sync
+AFTER DELETE ON accounts
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('accounts', 'DELETE', 'id', OLD.id);
+END;
+
+-- category_groups table
+
+CREATE TRIGGER category_groups_after_insert_pglite_sync
+AFTER INSERT ON category_groups
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_groups', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER category_groups_after_update_pglite_sync
+AFTER UPDATE ON category_groups
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_groups', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER category_groups_after_delete_pglite_sync
+AFTER DELETE ON category_groups
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_groups', 'DELETE', 'id', OLD.id);
+END;
+
+-- categories table
+
+CREATE TRIGGER categories_after_insert_pglite_sync
+AFTER INSERT ON categories
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('categories', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER categories_after_update_pglite_sync
+AFTER UPDATE ON categories
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('categories', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER categories_after_delete_pglite_sync
+AFTER DELETE ON categories
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('categories', 'DELETE', 'id', OLD.id);
+END;
+
+-- category_mapping table
+
+CREATE TRIGGER category_mapping_after_insert_pglite_sync
+AFTER INSERT ON category_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_mapping', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER category_mapping_after_update_pglite_sync
+AFTER UPDATE ON category_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_mapping', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER category_mapping_after_delete_pglite_sync
+AFTER DELETE ON category_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('category_mapping', 'DELETE', 'id', OLD.id);
+END;
+
+-- kvcache table
+
+CREATE TRIGGER kvcache_after_insert_pglite_sync
+AFTER INSERT ON kvcache
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache', 'INSERT', 'key', NEW.key);
+END;
+
+CREATE TRIGGER kvcache_after_update_pglite_sync
+AFTER UPDATE ON kvcache
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache', 'UPDATE', 'key', NEW.key);
+END;
+
+CREATE TRIGGER kvcache_after_delete_pglite_sync
+AFTER DELETE ON kvcache
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache', 'DELETE', 'key', OLD.key);
+END;
+
+-- kvcache_key table
+
+CREATE TRIGGER kvcache_key_after_insert_pglite_sync
+AFTER INSERT ON kvcache_key
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache_key', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER kvcache_key_after_update_pglite_sync
+AFTER UPDATE ON kvcache_key
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache_key', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER kvcache_key_after_delete_pglite_sync
+AFTER DELETE ON kvcache_key
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('kvcache_key', 'DELETE', 'id', OLD.id);
+END;
+
+-- messages_clock table
+
+CREATE TRIGGER messages_clock_after_insert_pglite_sync
+AFTER INSERT ON messages_clock
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_clock', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER messages_clock_after_update_pglite_sync
+AFTER UPDATE ON messages_clock
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_clock', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER messages_clock_after_delete_pglite_sync
+AFTER DELETE ON messages_clock
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_clock', 'DELETE', 'id', OLD.id);
+END;
+
+-- messages_crdt table
+
+CREATE TRIGGER messages_crdt_after_insert_pglite_sync
+AFTER INSERT ON messages_crdt
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_crdt', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER messages_crdt_after_update_pglite_sync
+AFTER UPDATE ON messages_crdt
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_crdt', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER messages_crdt_after_delete_pglite_sync
+AFTER DELETE ON messages_crdt
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('messages_crdt', 'DELETE', 'id', OLD.id);
+END;
+
+-- notes table
+
+CREATE TRIGGER notes_after_insert_pglite_sync
+AFTER INSERT ON notes
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('notes', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER notes_after_update_pglite_sync
+AFTER UPDATE ON notes
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('notes', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER notes_after_delete_pglite_sync
+AFTER DELETE ON notes
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('notes', 'DELETE', 'id', OLD.id);
+END;
+
+-- payees table
+
+CREATE TRIGGER payees_after_insert_pglite_sync
+AFTER INSERT ON payees
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payees', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER payees_after_update_pglite_sync
+AFTER UPDATE ON payees
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payees', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER payees_after_delete_pglite_sync
+AFTER DELETE ON payees
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payees', 'DELETE', 'id', OLD.id);
+END;
+
+-- payee_mapping table
+
+CREATE TRIGGER payee_mapping_after_insert_pglite_sync
+AFTER INSERT ON payee_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payee_mapping', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER payee_mapping_after_update_pglite_sync
+AFTER UPDATE ON payee_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payee_mapping', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER payee_mapping_after_delete_pglite_sync
+AFTER DELETE ON payee_mapping
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('payee_mapping', 'DELETE', 'id', OLD.id);
+END;
+
+-- rules table
+
+CREATE TRIGGER rules_after_insert_pglite_sync
+AFTER INSERT ON rules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('rules', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER rules_after_update_pglite_sync
+AFTER UPDATE ON rules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('rules', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER rules_after_delete_pglite_sync
+AFTER DELETE ON rules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('rules', 'DELETE', 'id', OLD.id);
+END;
+
+-- schedules table
+
+CREATE TRIGGER schedules_after_insert_pglite_sync
+AFTER INSERT ON schedules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER schedules_after_update_pglite_sync
+AFTER UPDATE ON schedules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER schedules_after_delete_pglite_sync
+AFTER DELETE ON schedules
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules', 'DELETE', 'id', OLD.id);
+END;
+
+-- schedules_json_paths table
+
+CREATE TRIGGER schedules_json_paths_after_insert_pglite_sync
+AFTER INSERT ON schedules_json_paths
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_json_paths', 'INSERT', 'schedule_id', NEW.schedule_id);
+END;
+
+CREATE TRIGGER schedules_json_paths_after_update_pglite_sync
+AFTER UPDATE ON schedules_json_paths
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_json_paths', 'UPDATE', 'schedule_id', NEW.schedule_id);
+END;
+
+CREATE TRIGGER schedules_json_paths_after_delete_pglite_sync
+AFTER DELETE ON schedules_json_paths
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_json_paths', 'DELETE', 'schedule_id', OLD.schedule_id);
+END;
+
+-- schedules_next_date table
+
+CREATE TRIGGER schedules_next_date_after_insert_pglite_sync
+AFTER INSERT ON schedules_next_date
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_next_date', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER schedules_next_date_after_update_pglite_sync
+AFTER UPDATE ON schedules_next_date
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_next_date', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER schedules_next_date_after_delete_pglite_sync
+AFTER DELETE ON schedules_next_date
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('schedules_next_date', 'DELETE', 'id', OLD.id);
+END;
+
+-- transactions table
+
+CREATE TRIGGER transactions_after_insert_pglite_sync
+AFTER INSERT ON transactions
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transactions', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER transactions_after_update_pglite_sync
+AFTER UPDATE ON transactions
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transactions', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER transactions_after_delete_pglite_sync
+AFTER DELETE ON transactions
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transactions', 'DELETE', 'id', OLD.id);
+END;
+
+-- reflect_budgets table
+
+CREATE TRIGGER reflect_budgets_after_insert_pglite_sync
+AFTER INSERT ON reflect_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('reflect_budgets', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER reflect_budgets_after_update_pglite_sync
+AFTER UPDATE ON reflect_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('reflect_budgets', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER reflect_budgets_after_delete_pglite_sync
+AFTER DELETE ON reflect_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('reflect_budgets', 'DELETE', 'id', OLD.id);
+END;
+
+-- zero_budgets table
+
+CREATE TRIGGER zero_budgets_after_insert_pglite_sync
+AFTER INSERT ON zero_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budgets', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER zero_budgets_after_update_pglite_sync
+AFTER UPDATE ON zero_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budgets', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER zero_budgets_after_delete_pglite_sync
+AFTER DELETE ON zero_budgets
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budgets', 'DELETE', 'id', OLD.id);
+END;
+
+-- zero_budget_months table
+
+CREATE TRIGGER zero_budget_months_after_insert_pglite_sync
+AFTER INSERT ON zero_budget_months
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budget_months', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER zero_budget_months_after_update_pglite_sync
+AFTER UPDATE ON zero_budget_months
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budget_months', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER zero_budget_months_after_delete_pglite_sync
+AFTER DELETE ON zero_budget_months
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('zero_budget_months', 'DELETE', 'id', OLD.id);
+END;
+
+-- transaction_filters table
+
+CREATE TRIGGER transaction_filters_after_insert_pglite_sync
+AFTER INSERT ON transaction_filters
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transaction_filters', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER transaction_filters_after_update_pglite_sync
+AFTER UPDATE ON transaction_filters
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transaction_filters', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER transaction_filters_after_delete_pglite_sync
+AFTER DELETE ON transaction_filters
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('transaction_filters', 'DELETE', 'id', OLD.id);
+END;
+
+-- preferences table
+
+CREATE TRIGGER preferences_after_insert_pglite_sync
+AFTER INSERT ON preferences
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('preferences', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER preferences_after_update_pglite_sync
+AFTER UPDATE ON preferences
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('preferences', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER preferences_after_delete_pglite_sync
+AFTER DELETE ON preferences
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('preferences', 'DELETE', 'id', OLD.id);
+END;
+
+-- custom_reports table
+
+CREATE TRIGGER custom_reports_after_insert_pglite_sync
+AFTER INSERT ON custom_reports
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('custom_reports', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER custom_reports_after_update_pglite_sync
+AFTER UPDATE ON custom_reports
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('custom_reports', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER custom_reports_after_delete_pglite_sync
+AFTER DELETE ON custom_reports
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('custom_reports', 'DELETE', 'id', OLD.id);
+END;
+
+-- dashboard table
+
+CREATE TRIGGER dashboard_after_insert_pglite_sync
+AFTER INSERT ON dashboard
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('dashboard', 'INSERT', 'id', NEW.id);
+END;
+
+CREATE TRIGGER dashboard_after_update_pglite_sync
+AFTER UPDATE ON dashboard
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('dashboard', 'UPDATE', 'id', NEW.id);
+END;
+
+CREATE TRIGGER dashboard_after_delete_pglite_sync
+AFTER DELETE ON dashboard
+FOR EACH ROW
+BEGIN
+  SELECT PGLITE_SYNC('dashboard', 'DELETE', 'id', OLD.id);
+END;
+
+COMMIT;
--- a/packages/loot-core/src/platform/server/pglite/index.web.ts
+++ b/packages/loot-core/src/platform/server/pglite/index.web.ts
@@ -85,6 +85,7 @@ export async function openDatabase(id?: string): Promise<PgliteDatabase> {
  // Enable extensions as needed.
  await db.execute('CREATE EXTENSION IF NOT EXISTS pg_trgm');

+  /* eslint-disable rulesdir/typography */
  const results = await db.execute(
    `SELECT table_name, column_name, data_type
      FROM information_schema.columns
@@ -92,6 +93,8 @@ export async function openDatabase(id?: string): Promise<PgliteDatabase> {
      ORDER BY table_name, ordinal_position;
    `,
  );
+  /* eslint-enable rulesdir/typography */
+
  console.log('PGlite columns:', JSON.stringify(results));

  return db;
@@ -136,13 +139,13 @@ function blobToUint8Array(blob: Blob): Promise<Uint8Array> {
  });
 }

-function ensureDataDir(id: string) {
+function ensureDataDir(id?: string) {
  if (!id) {
    const currentPrefs = prefs.getPrefs();
    if (!currentPrefs || !currentPrefs.id) {
-      throw new Error('No id provided and there is not budgeted currently open.');
+      throw new Error('No id provided and there is no budget file currently open.');
    }
-    return `idb://${currentPrefs.id}`;
+    id = currentPrefs.id;
  }

  return `idb://${id}`;
--- a/packages/loot-core/src/platform/server/sqlite/index.electron.ts
+++ b/packages/loot-core/src/platform/server/sqlite/index.electron.ts
@@ -6,6 +6,7 @@ import { removeFile, readFile } from '../fs';
 import { logger } from '../log';

 import { normalise } from './normalise';
+import { pgliteSync } from './pgliteSync';
 import { unicodeLike } from './unicodeLike';

 function verifyParamTypes(sql, arr) {
@@ -113,6 +114,8 @@ export function openDatabase(pathOrBuffer: string | Buffer) {
  db.function('UNICODE_LIKE', { deterministic: true }, unicodeLike);
  db.function('REGEXP', { deterministic: true }, regexp);
  db.function('NORMALISE', { deterministic: true }, normalise);
+  // @ts-expect-error @types/better-sqlite3 does not support setting strict 3rd argument
+  db.function('SYNC_PGLITE', { deterministic: true }, pgliteSync);
  return db;
 }

--- a/packages/loot-core/src/platform/server/sqlite/index.web.ts
+++ b/packages/loot-core/src/platform/server/sqlite/index.web.ts
@@ -4,6 +4,7 @@ import initSqlJS, { type Database } from '@jlongster/sql.js';
 import { logger } from '../log';

 import { normalise } from './normalise';
+import { pgliteSync } from './pgliteSync';
 import { unicodeLike } from './unicodeLike';

 import type { SqlJsModule } from '.';
@@ -205,6 +206,7 @@ export async function openDatabase(pathOrBuffer?: string | Buffer) {
  db.create_function('UNICODE_LIKE', unicodeLike);
  db.create_function('REGEXP', regexp);
  db.create_function('NORMALISE', normalise);
+  db.create_function('PGLITE_SYNC', pgliteSync);
  return db;
 }

--- a/packages/loot-core/src/platform/server/sqlite/pgliteSync.d.ts
+++ b/packages/loot-core/src/platform/server/sqlite/pgliteSync.d.ts
@@ -0,0 +1,6 @@
+export function pgliteSync(
+  table: string,
+  operation: 'INSERT' | 'UPDATE' | 'DELETE',
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+): 1 | 0;
--- a/packages/loot-core/src/platform/server/sqlite/pgliteSync.electron.ts
+++ b/packages/loot-core/src/platform/server/sqlite/pgliteSync.electron.ts
@@ -0,0 +1,145 @@
+import { sql } from 'drizzle-orm';
+
+import * as db from '../../../server/db';
+import { actualSchema } from '../../../server/db/schema';
+import * as dbUtil from '../../../server/db/util';
+import * as pglite from '../pglite';
+
+import * as sqlite from '.';
+
+// These have been renamed in the PGlite schema so that
+// they match the rest of the schema which is snake_case.
+const RENAMED_COLUMNS = new Map([
+  ['targetId', 'target_id'],
+  ['transferId', 'transfer_id'],
+  ['isParent', 'is_parent'],
+  ['isChild', 'is_child'],
+]);
+
+export function pgliteSync(
+  table: string,
+  operation: 'INSERT' | 'UPDATE' | 'DELETE',
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+) {
+  // Default to id.
+  primaryKeyColumn = primaryKeyColumn || 'id';
+
+  console.log(
+    'pgliteSync',
+    table,
+    operation,
+    primaryKeyColumn,
+    primaryKeyValue,
+  );
+
+  switch (operation) {
+    case 'INSERT':
+    case 'UPDATE':
+      insertOrUpdateRow(table, primaryKeyColumn, primaryKeyValue);
+      break;
+    case 'DELETE':
+      deleteRow(table, primaryKeyColumn, primaryKeyValue);
+      break;
+    default:
+      return 0;
+  }
+
+  return 1;
+}
+
+async function insertOrUpdateRow(
+  table: string,
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+): Promise<void> {
+  const pgliteDb = await pglite.openDatabase();
+  // Get from sqlite.
+  const sqliteDb = db.getDatabase();
+  const [row] = await sqlite.runQuery<Record<string, unknown>>(
+    sqliteDb,
+    `SELECT * FROM ${table} WHERE ${primaryKeyColumn} = ?`,
+    [primaryKeyValue],
+    true,
+  );
+
+  if (!row) {
+    console.warn(
+      `${table} row not found in sqlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+    );
+    return;
+  }
+
+  console.log(`${table} row from sqlite:`, JSON.stringify(row));
+
+  const columnNames = Object.keys(row).map(column => {
+    const renamedColumn = RENAMED_COLUMNS.get(column);
+    return renamedColumn ? renamedColumn : column;
+  });
+
+  const columns = sql.join(
+    columnNames.map(column => sql.identifier(column)),
+    sql`,`,
+  );
+
+  const values = sql.join(
+    Object.values(row).map(value => sql`${value}`),
+    sql`,`,
+  );
+
+  const updateValues = sql.join(
+    columnNames
+      // No need to update the id column.
+      .filter(column => column !== primaryKeyColumn)
+      .map(
+        column => sql`${sql.identifier(column)} = ${dbUtil.excluded(column)}`,
+      ),
+    sql`,`,
+  );
+
+  try {
+    await pgliteDb.execute(sql`
+      INSERT INTO ${actualSchema}.${sql.identifier(table)} (${columns}) VALUES (${values})
+      ON CONFLICT (${sql.identifier(primaryKeyColumn)}) DO UPDATE SET ${updateValues}
+    `);
+
+    const { rows } = await pgliteDb.execute(sql`
+      SELECT * FROM ${actualSchema}.${sql.identifier(table)}
+      WHERE ${sql.identifier(primaryKeyColumn)} = ${primaryKeyValue}
+    `);
+
+    console.log(
+      `${table} row inserted/updated in PGlite:`,
+      JSON.stringify(rows[0]),
+    );
+  } catch (err) {
+    console.error(
+      `Error inserting/updating ${table} row in PGlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+      err,
+    );
+  }
+}
+
+async function deleteRow(
+  table: string,
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+): Promise<void> {
+  console.log(`Deleting row with ${primaryKeyColumn}:`, primaryKeyValue);
+  const pgliteDb = await pglite.openDatabase();
+  try {
+    await pgliteDb.execute(sql`
+      DELETE FROM ${actualSchema}.${sql.identifier(table)}
+      WHERE ${sql.identifier(primaryKeyColumn)} = ${primaryKeyValue}
+    `);
+    console.log(
+      `${table} row deleted from PGlite with ${primaryKeyColumn}:`,
+      primaryKeyValue,
+    );
+  } catch (err) {
+    console.error(
+      `Error deleting ${table} row in PGlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+      err,
+    );
+  }
+}
--- a/packages/loot-core/src/platform/server/sqlite/pgliteSync.web.ts
+++ b/packages/loot-core/src/platform/server/sqlite/pgliteSync.web.ts
@@ -0,0 +1,145 @@
+import { sql } from 'drizzle-orm';
+
+import * as db from '../../../server/db';
+import { actualSchema } from '../../../server/db/schema';
+import * as dbUtil from '../../../server/db/util';
+import * as pglite from '../pglite';
+
+import * as sqlite from '.';
+
+// These have been renamed in the PGlite schema so that
+// they match the rest of the schema which is snake_case.
+const RENAMED_COLUMNS = new Map([
+  ['targetId', 'target_id'],
+  ['transferId', 'transfer_id'],
+  ['isParent', 'is_parent'],
+  ['isChild', 'is_child'],
+]);
+
+export function pgliteSync(
+  table: string,
+  operation: 'INSERT' | 'UPDATE' | 'DELETE',
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+) {
+  // Default to id.
+  primaryKeyColumn = primaryKeyColumn || 'id';
+
+  console.log(
+    'pgliteSync',
+    table,
+    operation,
+    primaryKeyColumn,
+    primaryKeyValue,
+  );
+
+  switch (operation) {
+    case 'INSERT':
+    case 'UPDATE':
+      insertOrUpdateRow(table, primaryKeyColumn, primaryKeyValue);
+      break;
+    case 'DELETE':
+      deleteRow(table, primaryKeyColumn, primaryKeyValue);
+      break;
+    default:
+      return 0;
+  }
+
+  return 1;
+}
+
+async function insertOrUpdateRow(
+  table: string,
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+): Promise<void> {
+  const pgliteDb = await pglite.openDatabase();
+  // Get from sqlite.
+  const sqliteDb = db.getDatabase();
+  const [row] = await sqlite.runQuery<Record<string, unknown>>(
+    sqliteDb,
+    `SELECT * FROM ${table} WHERE ${primaryKeyColumn} = ?`,
+    [primaryKeyValue],
+    true,
+  );
+
+  if (!row) {
+    console.warn(
+      `${table} row not found in sqlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+    );
+    return;
+  }
+
+  console.log(`${table} row from sqlite:`, JSON.stringify(row));
+
+  const columnNames = Object.keys(row).map(column => {
+    const renamedColumn = RENAMED_COLUMNS.get(column);
+    return renamedColumn ? renamedColumn : column;
+  });
+
+  const columns = sql.join(
+    columnNames.map(column => sql.identifier(column)),
+    sql`,`,
+  );
+
+  const values = sql.join(
+    Object.values(row).map(value => sql`${value}`),
+    sql`,`,
+  );
+
+  const updateValues = sql.join(
+    columnNames
+      // No need to update the id column.
+      .filter(column => column !== primaryKeyColumn)
+      .map(
+        column => sql`${sql.identifier(column)} = ${dbUtil.excluded(column)}`,
+      ),
+    sql`,`,
+  );
+
+  try {
+    await pgliteDb.execute(sql`
+      INSERT INTO ${actualSchema}.${sql.identifier(table)} (${columns}) VALUES (${values})
+      ON CONFLICT (${sql.identifier(primaryKeyColumn)}) DO UPDATE SET ${updateValues}
+    `);
+
+    const { rows } = await pgliteDb.execute(sql`
+      SELECT * FROM ${actualSchema}.${sql.identifier(table)}
+      WHERE ${sql.identifier(primaryKeyColumn)} = ${primaryKeyValue}
+    `);
+
+    console.log(
+      `${table} row inserted/updated in PGlite:`,
+      JSON.stringify(rows[0]),
+    );
+  } catch (err) {
+    console.error(
+      `Error inserting/updating ${table} row in PGlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+      err,
+    );
+  }
+}
+
+async function deleteRow(
+  table: string,
+  primaryKeyColumn: string,
+  primaryKeyValue: string,
+): Promise<void> {
+  console.log(`Deleting row with ${primaryKeyColumn}:`, primaryKeyValue);
+  const pgliteDb = await pglite.openDatabase();
+  try {
+    await pgliteDb.execute(sql`
+      DELETE FROM ${actualSchema}.${sql.identifier(table)}
+      WHERE ${sql.identifier(primaryKeyColumn)} = ${primaryKeyValue}
+    `);
+    console.log(
+      `${table} row deleted from PGlite with ${primaryKeyColumn}:`,
+      primaryKeyValue,
+    );
+  } catch (err) {
+    console.error(
+      `Error deleting ${table} row in PGlite with ${primaryKeyColumn}: ${primaryKeyValue}`,
+      err,
+    );
+  }
+}