Struct RusqliteEngine 

pub struct RusqliteEngine { /* private fields */ }

Rusqlite-backed OLTP engine.

Uses a single dedicated write connection for DML/DDL and a round-robin pool of read connections for queries. WAL mode is enabled on startup so readers don’t block the writer.

Implementations

impl RusqliteEngine

pub async fn new_local( path: &str, read_pool_size: usize, ) -> Result<RusqliteEngine, RusqliteOltpError>

Create a new engine backed by a local SQLite database file.

read_pool_size controls how many concurrent read connections are maintained. Values below 1 are clamped to 1.

pub async fn new_connection(&self) -> Result<Connection, RusqliteOltpError>

Create a fresh, independent connection to the same database file.

Used to give RusqliteCdcProducer its own connection that doesn’t compete with application reads/writes.

pub fn connection(&self) -> Connection

Returns a clone of the write connection handle. Used by CDC trigger setup/teardown (DDL).

Trait Implementations

impl OltpEngine for RusqliteEngine

async fn query( &self, sql: &str, params: &[Value], ) -> Result<Vec<RecordBatch>, <RusqliteEngine as OltpEngine>::Error>

Execute a read-only SQL query and return the results as Arrow RecordBatches.

Dispatches to the next connection in the round-robin read pool. The Arrow schema is inferred from actual cell values (see the SCHEMA_WARMUP_ROWS constant for the sparse-column strategy).

Errors

Returns RusqliteOltpError if statement preparation, execution, or Arrow conversion fails.

async fn execute( &self, sql: &str, params: &[Value], ) -> Result<u64, <RusqliteEngine as OltpEngine>::Error>

Execute a single write statement (INSERT, UPDATE, DELETE, or DDL) and return the number of rows affected.

Always dispatches to the single dedicated write connection.

Errors

Returns RusqliteOltpError if the statement fails (e.g., constraint violation, syntax error, or the database is locked beyond busy_timeout).

async fn execute_batch( &self, statements: &[(String, Vec<Value>)], ) -> Result<(), <RusqliteEngine as OltpEngine>::Error>

Execute a batch of write statements inside a single BEGIN…COMMIT transaction.

All statements succeed or the entire transaction is rolled back. Dispatches to the dedicated write connection.

Errors

Returns RusqliteOltpError if any statement fails or the transaction cannot be committed.

async fn table_exists( &self, table_name: &str, ) -> Result<bool, <RusqliteEngine as OltpEngine>::Error>

Return true if a table named table_name exists in sqlite_master.

Uses a read-pool connection.

Errors

Returns RusqliteOltpError if the metadata query fails.

type Error = RusqliteOltpError

Engine-specific error type returned by all fallible methods.