Struct sqlx::AnyConnection [−][src]
pub struct AnyConnection(_);
Expand description
A connection to any SQLx database.
The database driver used is determined by the scheme of the connection url.
postgres://postgres@localhost/test
sqlite://a.sqlite
Implementations
Trait Implementations
type Connection = &'c mut <Any as Database>::Connection
type Options = AnyConnectOptions
Explicitly close this database connection. Read more
Checks if a connection to the database is still valid.
pub fn begin(
&mut self
) -> Pin<Box<dyn Future<Output = Result<Transaction<'_, <AnyConnection as Connection>::Database>, Error>> + Send, Global>> where
AnyConnection: Sized,
pub fn begin(
&mut self
) -> Pin<Box<dyn Future<Output = Result<Transaction<'_, <AnyConnection as Connection>::Database>, Error>> + Send, Global>> where
AnyConnection: Sized,
Begin a new transaction or establish a savepoint within the active transaction. Read more
The number of statements currently cached in the connection.
Removes all statements from the cache, closing them on the server if needed. 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<AnyQueryResult, AnyRow>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
E: 'q + Execute<'q, <&'c mut AnyConnection as Executor<'c>>::Database>,
pub fn fetch_many<'e, 'q, E>(
self,
query: E
) -> Pin<Box<dyn Stream<Item = Result<Either<AnyQueryResult, AnyRow>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
E: 'q + Execute<'q, <&'c mut AnyConnection 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: &[AnyTypeInfo]
) -> Pin<Box<dyn Future<Output = Result<AnyStatement<'q>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
pub fn prepare_with<'e, 'q>(
self,
sql: &'q str,
_parameters: &[AnyTypeInfo]
) -> Pin<Box<dyn Future<Output = Result<AnyStatement<'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
pub fn describe<'e, 'q>(
self,
sql: &'q str
) -> Pin<Box<dyn Future<Output = Result<Describe<<&'c mut AnyConnection as Executor<'c>>::Database>, Error>> + Send + 'e, Global>> where
'q: 'e,
'c: 'e,
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.