Struct SqliteBackend 

pub struct SqliteBackend { /* private fields */ }

SQLite backend backed by sqlx::SqlitePool.

Implementations

impl SqliteBackend

pub fn pool(&self) -> &SqlitePool

Get a reference to the underlying pool.

pub fn from_pool(pool: SqlitePool) -> Self

Create from an existing pool (useful for tests).

Trait Implementations

impl DatabaseBackend for SqliteBackend

fn connect<'life0, 'async_trait>( uri: &'life0 str, pool_size: u32, acquire_timeout_secs: u64, max_lifetime_secs: u64, idle_timeout_secs: u64, ) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to the database and return a backend instance.

fn version<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<DbVersion, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query the database server version.

fn min_version(&self) -> (u32, u32)

Return the minimum supported version for this backend.

fn exec_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [SqlParam], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a raw SQL statement (no result set expected).

fn exec_statement<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, sql: &'life1 str, params: &'life2 [SqlParam], ) -> Pin<Box<dyn Future<Output = Result<StatementResult, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a CTE-wrapped statement and parse the standard result set.

fn exec_in_transaction<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tx_vars: Option<&'life1 SqlBuilder>, pre_req: Option<&'life2 SqlBuilder>, mutation: Option<&'life3 SqlBuilder>, main: Option<&'life4 SqlBuilder>, ) -> Pin<Box<dyn Future<Output = Result<StatementResult, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Begin a transaction and execute multiple statements within it.

fn introspector(&self) -> Box<dyn DbIntrospector + '_>

Get a database introspector for schema cache loading.

fn start_listener<'life0, 'life1, 'async_trait>( &'life0 self, _channel: &'life1 str, _cancel: Receiver<bool>, _on_event: Arc<dyn Fn(String) + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start a background change listener (e.g. PostgreSQL NOTIFY).

fn map_error(&self, err: Box<dyn Error + Send + Sync>) -> Error

Map a backend-specific database error into our Error type.