Struct MySqlConnection

pub struct MySqlConnection { /* private fields */ }

A MySQL connection using mysql-async

Implementations

impl MySqlConnection

pub async fn connect(connection_string: String) -> Result<Self, MySqlError>

Create a new connection to the database

pub async fn client(&self) -> Arc<Mutex<Conn>>

Get a reference to the connection

pub async fn query_drop<Q: AsRef<str>>( &self, query: Q, ) -> Result<(), MySqlError>

Execute a query directly

pub async fn exec_drop<Q: AsRef<str>, P: Into<Params> + Send>( &self, query: Q, params: P, ) -> Result<(), MySqlError>

Execute a parameterized query directly

pub async fn begin_transaction(&self) -> Result<MySqlTransaction, MySqlError>

Start a transaction

pub fn connection_string(&self) -> &str

Get the connection string

pub async fn query_map<T, F, Q>( &self, query: Q, f: F, ) -> Result<Vec<T>, MySqlError>

where Q: AsRef<str>, F: FnMut(Row) -> T + Send + 'static, T: Send + 'static,

Execute a query and map the results

pub async fn query_first<T: FromRow + Send + 'static, Q: AsRef<str>>( &self, query: Q, ) -> Result<T, MySqlError>

Execute a query and return the first result

pub async fn select_database( &self, database_name: &str, ) -> Result<(), MySqlError>

Select a specific database

Trait Implementations

impl Clone for MySqlConnection

fn clone(&self) -> MySqlConnection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl TestDatabaseConnection for MySqlConnection

fn connection_string(&self) -> String