Struct DBProvider 

pub struct DBProvider<E> { /* private fields */ }

Thin, reusable DB entrypoint for application services.

This wraps a module-scoped Db and provides:

• conn() for non-transactional operations
• transaction(...) for transactional operations without exposing DbHandle

Services can store this behind an Arc and use:

let conn = self.db.conn()?;
let out = self.db.transaction(|tx| Box::pin(async move { /* ... */ })).await?;

Implementations

impl<E> DBProvider<E>

where E: From<DbError> + Send + 'static,

pub fn new(db: Db) -> Self

pub fn conn(&self) -> Result<DbConn<'_>, E>

Create a non-transactional database runner.

Errors

Returns E if Db::conn() fails (including the transaction-bypass guard).

pub async fn transaction<T, F>(&self, f: F) -> Result<T, E>

where T: Send + 'static, F: for<'a> FnOnce(&'a DbTx<'a>) -> Pin<Box<dyn Future<Output = Result<T, E>> + Send + 'a>> + Send,

Execute a closure inside a database transaction.

Errors

Returns E if:

• starting the transaction fails (mapped from DbError)
• the closure returns an error
• commit fails (mapped from DbError)

Trait Implementations

impl<E> Clone for DBProvider<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.