Struct InMemorySqlEngine 

pub struct InMemorySqlEngine { /* private fields */ }

The in-memory SQLite engine.

Implementations

impl InMemorySqlEngine

pub fn open() -> Result<Self, SqlQueryError>

pub fn interrupt_handle(&self) -> InterruptHandle

Returns an interrupt handle that can cancel a running statement from another thread (used by the request-level timeout watchdog).

pub fn create_table( &self, label: &str, schema: &TableSchema, ) -> Result<(), SqlQueryError>

Create a table with the given label and schema.

pub async fn insert_rows<S>( &mut self, label: &str, schema: &TableSchema, rows: Pin<Box<S>>, max_rows: usize, ) -> Result<usize, SqlQueryError>

where S: Stream<Item = Result<Value, String>> + Send + ?Sized,

Stream rows into label. Each row is a flat JSON object whose keys match column names; missing or null keys become SQL NULL.

pub fn execute_select( &self, sql: &str, bindings: &[BoundParam], max_rows: usize, ) -> Result<QueryResult, SqlQueryError>

Run a SELECT with named bindings and a row cap.