Enum MiddlewarePoolConnection 

pub enum MiddlewarePoolConnection {
    Postgres(Object),
    Sqlite(SqliteConnection),
}

Variants

Postgres(Object)

Sqlite(SqliteConnection)

Implementations

impl MiddlewarePoolConnection

pub async fn with_sqlite_connection<F, R>( &mut self, func: F, ) -> Result<R, SqlMiddlewareDbError>

where F: FnOnce(&mut Connection) -> Result<R, SqlMiddlewareDbError> + Send + 'static, R: Send + 'static,

Run synchronous SQLite work on the underlying worker-owned connection.

Errors

Returns SqlMiddlewareDbError::Unimplemented when the connection is not SQLite.

pub async fn prepare_sqlite_statement( &mut self, query: &str, ) -> Result<SqlitePreparedStatement, SqlMiddlewareDbError>

Prepare a SQLite statement and obtain a reusable handle backed by the worker thread.

Errors

Returns SqlMiddlewareDbError::Unimplemented when the underlying connection is not SQLite, or propagates any preparation error reported by the worker thread.

impl MiddlewarePoolConnection

pub async fn interact_async<F, Fut>( &mut self, func: F, ) -> Result<Fut::Output, SqlMiddlewareDbError>

where F: FnOnce(AnyConnWrapper<'_>) -> Fut + Send + 'static, Fut: Future<Output = Result<(), SqlMiddlewareDbError>> + Send + 'static,

Interact with the connection asynchronously

Errors

Returns SqlMiddlewareDbError::Unimplemented for unsupported database types.

pub async fn interact_sync<F, R>(&self, f: F) -> Result<R, SqlMiddlewareDbError>

where F: FnOnce(AnyConnWrapper<'_>) -> R + Send + 'static, R: Send + 'static,

Interact with the connection synchronously

Errors

Returns SqlMiddlewareDbError::Unimplemented for unsupported database types.

Trait Implementations

impl AsyncDatabaseExecutor for MiddlewarePoolConnection

fn execute_batch<'life0, 'life1, 'async_trait>( &'life0 mut self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), SqlMiddlewareDbError>> + Send + 'async_trait>>

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

Executes a batch of SQL queries within a transaction by delegating to the specific database module.

fn execute_select<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, query: &'life1 str, params: &'life2 [RowValues], ) -> Pin<Box<dyn Future<Output = Result<ResultSet, SqlMiddlewareDbError>> + Send + 'async_trait>>

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

Executes a single SELECT statement and returns the result set.

fn execute_dml<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, query: &'life1 str, params: &'life2 [RowValues], ) -> Pin<Box<dyn Future<Output = Result<usize, SqlMiddlewareDbError>> + Send + 'async_trait>>

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

Executes a single DML statement (INSERT, UPDATE, DELETE, etc.) and returns the number of rows affected.

impl Debug for MiddlewarePoolConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.