Struct mysql_async::Transaction

pub struct Transaction<'a>(/* private fields */);

This struct represents MySql transaction.

Transaction is just a sugar for START TRANSACTION, ROLLBACK and COMMIT queries, so please note, that it is easy to mess things up calling this queries manually.

You should always call either commit or rollback, otherwise transaction will be rolled back implicitly when corresponding connection is dropped or queried.

Implementations

impl<'a> Transaction<'a>

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

Performs COMMIT query.

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

Performs ROLLBACK query.

Methods from Deref<Target = Conn>

pub fn id(&self) -> u32

Returns connection identifier.

pub fn last_insert_id(&self) -> Option<u64>

Returns the ID generated by a query (usually INSERT) on a table with a column having the AUTO_INCREMENT attribute. Returns None if there was no previous query on the connection or if the query did not update an AUTO_INCREMENT value.

pub fn affected_rows(&self) -> u64

Returns the number of rows affected by the last INSERT, UPDATE, REPLACE or DELETE query.

pub fn info(&self) -> Cow<'_, str>

Text information, as reported by the server in the last OK packet, or an empty string.

pub fn get_warnings(&self) -> u16

Number of warnings, as reported by the server in the last OK packet, or 0.

pub fn last_ok_packet(&self) -> Option<&OkPacket<'static>>

Returns a reference to the last OK packet.

pub fn server_version(&self) -> (u16, u16, u16)

Returns server version.

pub fn opts(&self) -> &Opts

Returns connection options.

Trait Implementations

impl<'a> Debug for Transaction<'a>

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

Formats the value using the given formatter.

impl Drop for Transaction<'_>

fn drop(&mut self)

Executes the destructor for this type.

impl Queryable for Transaction<'_>

fn ping(&mut self) -> BoxFuture<'_, Result<()>>

Executes COM_PING.

fn query_iter<'a, Q>( &'a mut self, query: Q ) -> BoxFuture<'a, Result<QueryResult<'a, 'static, TextProtocol>>>where Q: AsQuery + 'a,

Performs the given query and returns the result.

fn prep<'a, Q>(&'a mut self, query: Q) -> BoxFuture<'a, Result<Statement>>where Q: AsQuery + 'a,

Prepares the given statement.

fn close(&mut self, stmt: Statement) -> BoxFuture<'_, Result<()>>

Closes the given statement.

fn exec_iter<'a: 's, 's, Q, P>( &'a mut self, stmt: Q, params: P ) -> BoxFuture<'s, Result<QueryResult<'a, 'static, BinaryProtocol>>>where Q: StatementLike + 'a, P: Into<Params>,

Executes the given statement with given params.

fn exec_batch<'a: 'b, 'b, S, P, I>( &'a mut self, stmt: S, params_iter: I ) -> BoxFuture<'b, Result<()>>where S: StatementLike + 'b, I: IntoIterator<Item = P> + Send + 'b, I::IntoIter: Send, P: Into<Params> + Send,

Exectues the given statement for each item in the given params iterator.

fn query<'a, T, Q>(&'a mut self, query: Q) -> BoxFuture<'a, Result<Vec<T>>>where Q: AsQuery + 'a, T: FromRow + Send + 'static,

Performs the given query and collects the first result set.

fn query_first<'a, T, Q>( &'a mut self, query: Q ) -> BoxFuture<'a, Result<Option<T>>>where Q: AsQuery + 'a, T: FromRow + Send + 'static,

Performs the given query and returns the first row of the first result set.

fn query_map<'a, T, F, Q, U>( &'a mut self, query: Q, f: F ) -> BoxFuture<'a, Result<Vec<U>>>where Q: AsQuery + 'a, T: FromRow + Send + 'static, F: FnMut(T) -> U + Send + 'a, U: Send,

Performs the given query and maps each row of the first result set.

fn query_fold<'a, T, F, Q, U>( &'a mut self, query: Q, init: U, f: F ) -> BoxFuture<'a, Result<U>>where Q: AsQuery + 'a, T: FromRow + Send + 'static, F: FnMut(U, T) -> U + Send + 'a, U: Send + 'a,

Performs the given query and folds the first result set to a single value.

fn query_drop<'a, Q>(&'a mut self, query: Q) -> BoxFuture<'a, Result<()>>where Q: AsQuery + 'a,

Performs the given query and drops the query result.

fn exec<'a: 'b, 'b, T, S, P>( &'a mut self, stmt: S, params: P ) -> BoxFuture<'b, Result<Vec<T>>>where S: StatementLike + 'b, P: Into<Params> + Send + 'b, T: FromRow + Send + 'static,

Exectues the given statement and collects the first result set.

fn exec_first<'a: 'b, 'b, T, S, P>( &'a mut self, stmt: S, params: P ) -> BoxFuture<'b, Result<Option<T>>>where S: StatementLike + 'b, P: Into<Params> + Send + 'b, T: FromRow + Send + 'static,

Exectues the given statement and returns the first row of the first result set.

fn exec_map<'a: 'b, 'b, T, S, P, U, F>( &'a mut self, stmt: S, params: P, f: F ) -> BoxFuture<'b, Result<Vec<U>>>where S: StatementLike + 'b, P: Into<Params> + Send + 'b, T: FromRow + Send + 'static, F: FnMut(T) -> U + Send + 'a, U: Send + 'a,

Exectues the given stmt and maps each row of the first result set.

fn exec_fold<'a: 'b, 'b, T, S, P, U, F>( &'a mut self, stmt: S, params: P, init: U, f: F ) -> BoxFuture<'b, Result<U>>where S: StatementLike + 'b, P: Into<Params> + Send + 'b, T: FromRow + Send + 'static, F: FnMut(U, T) -> U + Send + 'a, U: Send + 'a,

Exectues the given stmt and folds the first result set to a signel value.

fn exec_drop<'a: 'b, 'b, S, P>( &'a mut self, stmt: S, params: P ) -> BoxFuture<'b, Result<()>>where S: StatementLike + 'b, P: Into<Params> + Send + 'b,

Exectues the given statement and drops the result.

fn query_stream<'a, T, Q>( &'a mut self, query: Q ) -> BoxFuture<'a, Result<ResultSetStream<'a, 'a, 'static, T, TextProtocol>>>where T: Unpin + FromRow + Send + 'static, Q: AsQuery + 'a,

Returns a stream over the first result set.

fn exec_stream<'a: 's, 's, T, Q, P>( &'a mut self, stmt: Q, params: P ) -> BoxFuture<'s, Result<ResultSetStream<'a, 'a, 'static, T, BinaryProtocol>>>where T: Unpin + FromRow + Send + 'static, Q: StatementLike + 'a, P: Into<Params> + Send + 's,

Returns a stream over the first result set.

impl Deref for Transaction<'_>

type Target = Conn

The resulting type after dereferencing.

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

Dereferences the value.

impl<'a, 't> ToConnection<'a, 't> for &'a mut Transaction<'t>