Struct MySQLConnection 

pub struct MySQLConnection { /* private fields */ }

Connection wrapper used by the MySQL/MariaDB driver.

Holds the underlying mysql_async connection and adapts it to the tank_core::Connection/Executor APIs.

Trait Implementations

impl Connection for MySQLConnection

async fn connect(url: Cow<'static, str>) -> Result<Self>

Create a connection (or pool) to the given URL.

fn begin(&mut self) -> impl Future<Output = Result<MySQLTransaction<'_>>>

Begin a transaction scope tied to this connection.

fn sanitize_url(url: Cow<'static, str>) -> Result<Url, Error>

where Self: Sized,

fn disconnect(self) -> impl Future<Output = Result<(), Error>>

where Self: Sized,

Disconnect and release the underlying session(s).

impl Executor for MySQLConnection

type Driver = MySQLDriver

Associated driver.

fn accepts_multiple_statements(&self) -> bool

Supports multiple statements per request.

fn do_prepare( &mut self, sql: String, ) -> impl Future<Output = Result<Query<Self::Driver>>> + Send

Actual implementation for prepare.

fn run<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<QueryResult>> + Send

Execute a query, streaming QueryResult (rows or affected counts).

fn fetch<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Stream<Item = Result<RowLabeled>> + Send + 's

Execute a query yielding RowLabeled from the resulting stream (filtering out RowsAffected).

fn execute<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<RowsAffected>> + Send

Execute and aggregate affected rows counter.

fn append<'a, E, It>( &mut self, entities: It, ) -> impl Future<Output = Result<RowsAffected>> + Send

where E: Entity + 'a, It: IntoIterator<Item = &'a E> + Send, <It as IntoIterator>::IntoIter: Send,

Insert many entities efficiently.

fn driver(&self) -> Self::Driver

where Self: Sized,

Get the driver instance.

fn prepare<'s>( &'s mut self, query: impl AsQuery<Self::Driver> + 's, ) -> impl Future<Output = Result<Query<Self::Driver>, Error>> + Send

Prepare query.