Struct Client

pub struct Client { /* private fields */ }

Client represents a single sqlite connection that can be used from async contexts.

Implementations

impl Client

pub async fn conn<F, T>(&self, func: F) -> Result<T, Error>

where F: FnOnce(&Connection) -> Result<T, Error> + Send + 'static, T: Send + 'static,

Invokes the provided function with a rusqlite::Connection.

pub async fn conn_with_err<F, T, E: From<Error> + From<Error> + Send + 'static>( &self, func: F, ) -> Result<T, E>

where F: FnOnce(&Connection) -> Result<T, E> + Send + 'static, T: Send + 'static,

Invokes the provided function with a rusqlite::Connection.

pub async fn conn_mut<F, T>(&self, func: F) -> Result<T, Error>

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

Invokes the provided function with a mutable rusqlite::Connection.

pub async fn conn_mut_with_err<F, T, E: From<Error> + From<Error> + Send + 'static>( &self, func: F, ) -> Result<T, E>

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

Invokes the provided function with a mutable rusqlite::Connection.

pub async fn transaction_write<F, T, E: From<Error> + From<Error> + Send + 'static>( &self, func: F, ) -> Result<T, E>

where F: FnOnce(&mut Transaction<'_>) -> Result<T, E> + Send + 'static, T: Send + 'static,

Invokes the provided function wrapping a new rusqlite::Transaction that is committed automatically.

pub async fn transaction_read<F, T, E: From<Error> + From<Error> + Send + 'static>( &self, func: F, ) -> Result<T, E>

where F: FnOnce(&mut Transaction<'_>) -> Result<T, E> + Send + 'static, T: Send + 'static,

Invokes the provided function wrapping a new rusqlite::Transaction that is committed automatically.

pub async fn transaction<F, T, E: From<Error> + From<Error> + Send + 'static>( &self, func: F, behavior: TransactionBehavior, ) -> Result<T, E>

where F: FnOnce(&mut Transaction<'_>) -> Result<T, E> + Send + 'static, T: Send + 'static,

Invokes the provided function wrapping a new rusqlite::Transaction that is committed automatically.

pub async fn close(&self) -> Result<(), Error>

Closes the underlying sqlite connection.

After this method returns, all calls to self::conn() or self::conn_mut() will return an Error::Closed error.

pub fn conn_blocking<F, T>(&self, func: F) -> Result<T, Error>

where F: FnOnce(&Connection) -> Result<T, Error> + Send + 'static, T: Send + 'static,

Invokes the provided function with a rusqlite::Connection, blocking the current thread until completion.

pub fn conn_mut_blocking<F, T>(&self, func: F) -> Result<T, Error>

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

Invokes the provided function with a mutable rusqlite::Connection, blocking the current thread until completion.

pub fn close_blocking(&self) -> Result<(), Error>

Closes the underlying sqlite connection, blocking the current thread until complete.

After this method returns, all calls to self::conn_blocking() or self::conn_mut_blocking() will return an Error::Closed error.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.