itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-27 19:23:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Ensure tests pass

Browse Source
This commit is contained in:
Hamza 2020-12-04 17:36:42 +05:00 committed by Ryan Leckey
parent 8a55ae2d32
commit d1417dc2ec
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
sqlx-core/src/connection.rs
View File

@ -39,23 +39,27 @@ pub trait Connection: Send {
/// # Example
///
/// ```rust
/// use sqlx_core::postgres::{PgConnection, PgRow};
/// use sqlx_core::connection::Connection;
/// use sqlx_core::error::Error;
/// use sqlx_core::executor::Executor;
/// use sqlx_core::postgres::{PgConnection, PgRow};
/// use sqlx_core::query::query;
///
/// # pub async fn _f(conn: &mut PgConnection) -> Result<Vec<PgRow>, Error> {
/// conn.transaction(|conn|Box::pin(async move {
/// sqlx::query("select * from ..").fetch_all(conn).await
/// query("select * from ..").fetch_all(conn).await
/// })).await
/// # }
/// ```
fn transaction<F, R, E>(&mut self, callback: F) -> BoxFuture<Result<R, E>>
where
for<'c> F:
FnOnce(&'c mut Transaction<Self::Database>) -> BoxFuture<'c, Result<R, E>> + 'static + Send + Sync,
Self: Sized,
R: Send,
E: From<Error> + Send,
where
for<'c> F: FnOnce(&'c mut Transaction<Self::Database>) -> BoxFuture<'c, Result<R, E>>
+ 'static
+ Send
+ Sync,
Self: Sized,
R: Send,
E: From<Error> + Send,
{
Box::pin(async move {
let mut transaction = self.begin().await?;