Struct sqlx::MySqlConnection [−][src]
pub struct MySqlConnection { /* fields omitted */ }
mysql
only.Expand description
A connection to a MySQL database.
Trait Implementations
type Connection = &'c mut <MySql as Database>::Connection
type Options = MySqlConnectOptions
Explicitly close this database connection. Read more
Checks if a connection to the database is still valid.
The number of statements currently cached in the connection.
Removes all statements from the cache, closing them on the server if needed. Read more
pub fn begin(
&mut self
) -> Pin<Box<dyn Future<Output = Result<Transaction<'_, <MySqlConnection as Connection>::Database>, Error>> + Send, Global>> where
MySqlConnection: Sized,
pub fn begin(
&mut self
) -> Pin<Box<dyn Future<Output = Result<Transaction<'_, <MySqlConnection as Connection>::Database>, Error>> + Send, Global>> where
MySqlConnection: Sized,
Begin a new transaction or establish a savepoint within the active transaction. Read more
fn transaction<'a, F, R, E>(
&'a mut self,
callback: F
) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'a, Global>> where
F: 'a + for<'c> FnOnce(&'c mut Transaction<'_, Self::Database>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'c, Global>> + Send + Sync,
R: Send,
E: From<Error> + Send,
fn transaction<'a, F, R, E>(
&'a mut self,
callback: F
) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'a, Global>> where
F: 'a + for<'c> FnOnce(&'c mut Transaction<'_, Self::Database>) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'c, Global>> + Send + Sync,
R: Send,
E: From<Error> + Send,
Execute the function inside a transaction. Read more
Establish a new database connection. Read more
pub fn fetch_many<'e, 'q, E>(
self,
query: E
) -> Pin<Box<dyn Stream<Item = Result<Either<MySqlQueryResult, MySqlRow>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
E: 'q + Execute<'q, <&'c mut MySqlConnection as Executor<'c>>::Database>,
pub fn fetch_many<'e, 'q, E>(
self,
query: E
) -> Pin<Box<dyn Stream<Item = Result<Either<MySqlQueryResult, MySqlRow>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
E: 'q + Execute<'q, <&'c mut MySqlConnection as Executor<'c>>::Database>,
Execute multiple queries and return the generated results as a stream from each query, in a stream. Read more
Execute the query and returns at most one row.
pub fn prepare_with<'e, 'q>(
self,
sql: &'q str,
_parameters: &'e [MySqlTypeInfo]
) -> Pin<Box<dyn Future<Output = Result<MySqlStatement<'q>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
pub fn prepare_with<'e, 'q>(
self,
sql: &'q str,
_parameters: &'e [MySqlTypeInfo]
) -> Pin<Box<dyn Future<Output = Result<MySqlStatement<'q>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
Prepare the SQL query, with parameter type information, to inspect the type information about its parameters and results. Read more
Execute the query and return the total number of rows affected.
Execute multiple queries and return the rows affected from each query, in a stream.
Execute the query and return the generated results as a stream.
Execute the query and return all the generated results, collected into a Vec
.
Execute the query and returns exactly one row.