Struct PooledConnection

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

Implementations

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

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

where F: FnOnce(&mut ReadTransaction<'_, T>) -> 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 transaction_closure<F, R, E>(&mut self, closure: F) -> Result<R, E>

where F: FnOnce(&mut Transaction<'_, T>) -> 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.

pub fn transaction(&mut self) -> Result<Transaction<'_, T>, T::Error>

Create a new transaction type that needs to be manually commited.

If the transaction is dropped without an explicit call to Transaction::rollback or Transaction::commit, the transaction will be rolled back.

Errors

Returns an error if the transaction could not be created.

pub fn read_transaction(&mut self) -> Result<ReadTransaction<'_, T>, T::Error>

Create a new read transaction type that needs to be manually commited.

If the transaction is dropped without an explicit call to ReadTransaction::commit, the transaction will be rolled back.

Errors

Returns an error if the transaction could not be created.

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: DriverMutConnectionDeref> DerefMut for PooledConnection<T, SyncConnectionAdapter<T>>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

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

fn drop(&mut self)

Executes the destructor for this type.