Struct JournalSql 

pub struct JournalSql {
    pub quote: fn(&str) -> String,
    pub placeholder: fn(usize) -> String,
    pub before_type: &'static str,
    pub insert_prefix: &'static str,
    pub insert_suffix: &'static str,
    pub now: &'static str,
    pub key_column: &'static str,
    pub primary_key: &'static str,
}

Dialect-neutral SQL for the before-image journal and the run-scoped delete.

Each builder takes the dialect’s identifier quoting and placeholder style as function pointers (plain fn, so a sink can hold one across an await in a Send future), so the SQL sinks share one tested generator instead of three hand-written copies. before_type is the dialect’s JSON-or-text column type (JSONB, TEXT, JSON); insert_ignore is its “skip an existing key” spelling (INSERT … ON CONFLICT DO NOTHING, INSERT OR IGNORE, INSERT IGNORE).

Fields

quote: fn(&str) -> String

placeholder: fn(usize) -> String

before_type: &'static str

insert_prefix: &'static str

insert_suffix: &'static str

now: &'static str

key_column: &'static str

The key_json column definition (plus any helper column). A dialect with a byte-limited index (MySQL: 3072 bytes) keys on a stored hash of the JSON instead of the text itself.

primary_key: &'static str

The primary-key clause.

Implementations

impl JournalSql

pub fn create(&self) -> String

CREATE TABLE IF NOT EXISTS _faucet_run_journal (…).

pub fn insert(&self, rows: usize) -> String

Insert rows journal rows of (run_id, table_name, key_json, before_json), skipping keys already journaled for the run — the first page to touch a key holds its true pre-run image.

pub fn select(&self) -> String

Every journal row of one run against one table.

pub fn delete_table(&self) -> String

Drop one run’s journal rows for one table (after a restore).

pub fn keys_in( &self, key: &[String], tuples: usize, start: usize, ) -> (String, usize)

(k1, k2) IN ((p, p), (p, p), …) over tuples key tuples, placeholders numbered from start + 1. Returns the predicate and the next free placeholder index.

pub fn delete_by_run(&self, table_ref: &str, run_id_col: &str) -> String

DELETE FROM <table> WHERE <run_id_col> = p1 — the append undo.

pub fn count_by_run(&self, table_ref: &str, run_id_col: &str) -> String

SELECT count(*) FROM <table> WHERE <run_id_col> = p1.

Trait Implementations

impl Clone for JournalSql

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for JournalSql