Trait ConnectionExt 

pub trait ConnectionExt: MaybeSend + MaybeSync {
    // Required methods
    fn raw_query_read<T, F>(&self, fun: F) -> Result<T, ConnectionError>
       where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>,
             Self: Sized;
    fn raw_query_write<T, F>(&self, fun: F) -> Result<T, ConnectionError>
       where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>,
             Self: Sized;
    fn disconnect(&self) -> Result<(), ConnectionError>;
    fn reconnect(&self) -> Result<(), ConnectionError>;
}

Required Methods

fn raw_query_read<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

in order to track transaction context

fn raw_query_write<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

Run a scoped write-only query in order to track transaction context

fn disconnect(&self) -> Result<(), ConnectionError>

fn reconnect(&self) -> Result<(), ConnectionError>

Implementations on Foreign Types

impl<C> ConnectionExt for &C

where C: ConnectionExt,

fn raw_query_read<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn raw_query_write<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn disconnect(&self) -> Result<(), ConnectionError>

fn reconnect(&self) -> Result<(), ConnectionError>

impl<C> ConnectionExt for &mut C

where C: ConnectionExt,

fn raw_query_read<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn raw_query_write<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn disconnect(&self) -> Result<(), ConnectionError>

fn reconnect(&self) -> Result<(), ConnectionError>

impl<C> ConnectionExt for Arc<C>

where C: ConnectionExt,

fn raw_query_read<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn raw_query_write<T, F>(&self, fun: F) -> Result<T, ConnectionError>

where F: FnOnce(&mut SqliteConnection) -> Result<T, Error>, Self: Sized,

fn disconnect(&self) -> Result<(), ConnectionError>

fn reconnect(&self) -> Result<(), ConnectionError>

Implementors

impl ConnectionExt for MockConnection

impl ConnectionExt for MockDbQuery

impl ConnectionExt for MemoryStorage

impl ConnectionExt for EphemeralDbConnection

impl ConnectionExt for NativeDbConnection

impl<C> ConnectionExt for DbConnection<C>

where C: ConnectionExt,

impl<P, M> ConnectionExt for PersistentOrMem<P, M>

where P: ConnectionExt, M: ConnectionExt,