pub struct MySqlConnection { /* private fields */ }
Expand description
A connection to a MySQL database.
Trait Implementations§
source§impl<'c> Acquire<'c> for &'c mut MySqlConnection
impl<'c> Acquire<'c> for &'c mut MySqlConnection
source§impl AnyConnectionBackend for MySqlConnection
impl AnyConnectionBackend for MySqlConnection
source§fn close(self: Box<Self>) -> BoxFuture<'static, Result<()>>
fn close(self: Box<Self>) -> BoxFuture<'static, Result<()>>
Explicitly close this database connection. Read more
source§fn ping(&mut self) -> BoxFuture<'_, Result<()>>
fn ping(&mut self) -> BoxFuture<'_, Result<()>>
Checks if a connection to the database is still valid.
source§fn begin(&mut self) -> BoxFuture<'_, Result<()>>
fn begin(&mut self) -> BoxFuture<'_, Result<()>>
Begin a new transaction or establish a savepoint within the active transaction.
fn commit(&mut self) -> BoxFuture<'_, Result<()>>
fn rollback(&mut self) -> BoxFuture<'_, Result<()>>
fn start_rollback(&mut self)
source§fn shrink_buffers(&mut self)
fn shrink_buffers(&mut self)
Forward to
Connection::shrink_buffers()
.fn as_migrate(&mut self) -> Result<&mut (dyn Migrate + Send + 'static)>
fn fetch_many<'q>( &'q mut self, query: &'q str, persistent: bool, arguments: Option<AnyArguments<'q>>, ) -> BoxStream<'q, Result<Either<AnyQueryResult, AnyRow>>>
fn fetch_optional<'q>( &'q mut self, query: &'q str, persistent: bool, arguments: Option<AnyArguments<'q>>, ) -> BoxFuture<'q, Result<Option<AnyRow>>>
fn prepare_with<'c, 'q: 'c>( &'c mut self, sql: &'q str, _parameters: &[AnyTypeInfo], ) -> BoxFuture<'c, Result<AnyStatement<'q>>>
fn describe<'q>( &'q mut self, sql: &'q str, ) -> BoxFuture<'q, Result<Describe<Any>>>
source§fn cached_statements_size(&self) -> usize
fn cached_statements_size(&self) -> usize
The number of statements currently cached in the connection.
source§impl Connection for MySqlConnection
impl Connection for MySqlConnection
type Database = MySql
type Options = MySqlConnectOptions
source§fn close(self) -> BoxFuture<'static, Result<(), Error>>
fn close(self) -> BoxFuture<'static, Result<(), Error>>
Explicitly close this database connection. Read more
source§fn ping(&mut self) -> BoxFuture<'_, Result<(), Error>>
fn ping(&mut self) -> BoxFuture<'_, Result<(), Error>>
Checks if a connection to the database is still valid.
source§fn cached_statements_size(&self) -> usize
fn cached_statements_size(&self) -> usize
The number of statements currently cached in the connection.
source§fn clear_cached_statements(&mut self) -> BoxFuture<'_, Result<(), Error>>
fn clear_cached_statements(&mut self) -> BoxFuture<'_, Result<(), Error>>
Removes all statements from the cache, closing them on the server if
needed.
source§fn begin(
&mut self,
) -> BoxFuture<'_, Result<Transaction<'_, Self::Database>, Error>>where
Self: Sized,
fn begin(
&mut self,
) -> BoxFuture<'_, Result<Transaction<'_, Self::Database>, Error>>where
Self: Sized,
Begin a new transaction or establish a savepoint within the active transaction. Read more
source§fn shrink_buffers(&mut self)
fn shrink_buffers(&mut self)
Restore any buffers in the connection to their default capacity, if possible. Read more
source§fn transaction<'a, F, R, E>(
&'a mut self,
callback: F,
) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'a>>
fn transaction<'a, F, R, E>( &'a mut self, callback: F, ) -> Pin<Box<dyn Future<Output = Result<R, E>> + Send + 'a>>
Execute the function inside a transaction. Read more
source§impl Debug for MySqlConnection
impl Debug for MySqlConnection
source§impl<'c> Executor<'c> for &'c mut MySqlConnection
impl<'c> Executor<'c> for &'c mut MySqlConnection
type Database = MySql
source§fn fetch_many<'e, 'q, E>(
self,
query: E,
) -> BoxStream<'e, Result<Either<MySqlQueryResult, MySqlRow>, Error>>
fn fetch_many<'e, 'q, E>( self, query: E, ) -> BoxStream<'e, Result<Either<MySqlQueryResult, MySqlRow>, Error>>
Execute multiple queries and return the generated results as a stream
from each query, in a stream.
source§fn fetch_optional<'e, 'q, E>(
self,
query: E,
) -> BoxFuture<'e, Result<Option<MySqlRow>, Error>>
fn fetch_optional<'e, 'q, E>( self, query: E, ) -> BoxFuture<'e, Result<Option<MySqlRow>, Error>>
Execute the query and returns at most one row.
source§fn prepare_with<'e, 'q: 'e>(
self,
sql: &'q str,
_parameters: &'e [MySqlTypeInfo],
) -> BoxFuture<'e, Result<MySqlStatement<'q>, Error>>where
'c: 'e,
fn prepare_with<'e, 'q: 'e>(
self,
sql: &'q str,
_parameters: &'e [MySqlTypeInfo],
) -> BoxFuture<'e, Result<MySqlStatement<'q>, Error>>where
'c: 'e,
Prepare the SQL query, with parameter type information, to inspect the
type information about its parameters and results. Read more
source§fn execute<'e, 'q, E>(
self,
query: E,
) -> Pin<Box<dyn Future<Output = Result<<Self::Database as Database>::QueryResult, Error>> + Send + 'e>>
fn execute<'e, 'q, E>( self, query: E, ) -> Pin<Box<dyn Future<Output = Result<<Self::Database as Database>::QueryResult, Error>> + Send + 'e>>
Execute the query and return the total number of rows affected.
source§fn execute_many<'e, 'q, E>(
self,
query: E,
) -> Pin<Box<dyn Stream<Item = Result<<Self::Database as Database>::QueryResult, Error>> + Send + 'e>>
fn execute_many<'e, 'q, E>( self, query: E, ) -> Pin<Box<dyn Stream<Item = Result<<Self::Database as Database>::QueryResult, Error>> + Send + 'e>>
Execute multiple queries and return the rows affected from each query, in a stream.
source§fn fetch<'e, 'q, E>(
self,
query: E,
) -> Pin<Box<dyn Stream<Item = Result<<Self::Database as Database>::Row, Error>> + Send + 'e>>
fn fetch<'e, 'q, E>( self, query: E, ) -> Pin<Box<dyn Stream<Item = Result<<Self::Database as Database>::Row, Error>> + Send + 'e>>
Execute the query and return the generated results as a stream.
source§fn fetch_all<'e, 'q, E>(
self,
query: E,
) -> Pin<Box<dyn Future<Output = Result<Vec<<Self::Database as Database>::Row>, Error>> + Send + 'e>>
fn fetch_all<'e, 'q, E>( self, query: E, ) -> Pin<Box<dyn Future<Output = Result<Vec<<Self::Database as Database>::Row>, Error>> + Send + 'e>>
Execute the query and return all the generated results, collected into a
Vec
.source§impl Migrate for MySqlConnection
impl Migrate for MySqlConnection
fn ensure_migrations_table(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>
fn dirty_version(&mut self) -> BoxFuture<'_, Result<Option<i64>, MigrateError>>
fn list_applied_migrations( &mut self, ) -> BoxFuture<'_, Result<Vec<AppliedMigration>, MigrateError>>
fn lock(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>
fn unlock(&mut self) -> BoxFuture<'_, Result<(), MigrateError>>
fn apply<'e: 'm, 'm>( &'e mut self, migration: &'m Migration, ) -> BoxFuture<'m, Result<Duration, MigrateError>>
fn revert<'e: 'm, 'm>( &'e mut self, migration: &'m Migration, ) -> BoxFuture<'m, Result<Duration, MigrateError>>
Auto Trait Implementations§
impl Freeze for MySqlConnection
impl !RefUnwindSafe for MySqlConnection
impl Send for MySqlConnection
impl Sync for MySqlConnection
impl Unpin for MySqlConnection
impl !UnwindSafe for MySqlConnection
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more