Struct PooledConnection

pub struct PooledConnection<T: Driver, A: ConnectionAdapter<T>> { /* private fields */ }

Implementations

impl<T: Driver> PooledConnection<T, SyncConnectionAdapter<T>>

pub fn scoped_read<F, R, E>(&mut self, closure: F) -> Result<R, E>

where F: FnOnce(T::ConnectionRef<'_>) -> Result<R, E>, E: From<T::Error>,

Perform a read operation with a stable scope.

This method uses an explicit transaction to ensure the reader does not take into account ongoing modifications of writers during the execution of the statements in the scope of the closure.

Use Self::read if you want to have the default sqlite behavior, where each statement gets their own transaction.

Errors

Returns error if the closure failed or if the read transaction could not be initiated.

pub fn read<F, R, E>(&mut self, closure: F) -> Result<R, E>

where F: FnOnce(&T::Connection) -> Result<R, E>, E: From<T::Error>,

Perform a read operation without a stable scope.

Unlike Self::scoped_read, this method uses the default Sqlite transaction behavior where each statement will create its own transaction.

Errors

Returns error if the closure failed.

pub fn transaction<F, R, E>(&mut self, closure: F) -> Result<R, E>

where F: FnOnce(&mut T::Transaction<'_>) -> Result<R, E>, E: From<T::Error>,

Create a transaction and run the given closure in its scope.

If the closure returns an error the transaction is aborted, otherwise it is commited.

Errors

Returns error if the closure failed or the transaction failed to commit.

Trait Implementations

impl<T: Driver> Deref for PooledConnection<T, SyncConnectionAdapter<T>>

type Target = <T as Driver>::Connection

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T: Driver, A: ConnectionAdapter<T>> Drop for PooledConnection<T, A>

fn drop(&mut self)

Executes the destructor for this type.