Struct ConnectionWithTransaction 

pub struct ConnectionWithTransaction<DB, W>
where
    DB: DatabaseConnector + 'static,
    W: Debug + Deref<Target = DB> + DerefMut<Target = DB> + Send + Sync + 'static,
{ /* private fields */ }

Database connection with a transaction

Implementations

impl<DB, W> ConnectionWithTransaction<DB, W>

where DB: DatabaseConnector, W: Debug + Deref<Target = DB> + DerefMut<Target = DB> + Send + Sync + 'static,

pub async fn new(inner: W) -> Result<Self, Error>

Creates a new transaction

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

Commits the transaction consuming it and releasing the connection back to the pool (or disconnecting)

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

Rollback the transaction consuming it and releasing the connection back to the pool (or disconnecting)

Trait Implementations

impl<DB, W> DatabaseExecutor for ConnectionWithTransaction<DB, W>

where DB: DatabaseConnector, W: Debug + Deref<Target = DB> + DerefMut<Target = DB> + Send + Sync + 'static,

fn execute<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes a query and returns the affected rows

fn fetch_one<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Column>>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Runs the query and returns the first row or None

fn fetch_all<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Vec<Vec<Column>>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Runs the query and returns the first row or None

fn pluck<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<Option<Column>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fetches the first row and column from a query

fn batch<'life0, 'async_trait>( &'life0 self, statement: Statement, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Batch execution

fn name() -> &'static str

Database driver name

impl<DB, W> Debug for ConnectionWithTransaction<DB, W>

where DB: DatabaseConnector + 'static + Debug, W: Debug + Deref<Target = DB> + DerefMut<Target = DB> + Send + Sync + 'static + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<DB, W> Drop for ConnectionWithTransaction<DB, W>

where DB: DatabaseConnector, W: Debug + Deref<Target = DB> + DerefMut<Target = DB> + Send + Sync + 'static,

fn drop(&mut self)

Executes the destructor for this type.