rqb 0.1.7

sqlx-first typed Postgres query builder.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

/// Runs an async expression or block in a sqlx transaction.
#[macro_export]
macro_rules! tx {
    ($pool:expr, |$conn:ident| $body:expr $(,)?) => {
        async move {
            let mut __rqb_tx = $pool.begin().await.map_err($crate::Error::from)?;
            let __rqb_result: $crate::Result<_> = {
                let $conn = &mut *__rqb_tx;
                (async move { $body }).await
            };

            match __rqb_result {
                Ok(__rqb_value) => {
                    __rqb_tx.commit().await.map_err($crate::Error::from)?;
                    Ok(__rqb_value)
                }
                Err(__rqb_error) => match __rqb_tx.rollback().await {
                    Ok(()) => Err(__rqb_error),
                    Err(__rqb_rollback) => Err($crate::Error::TransactionRollbackFailed {
                        error: Box::new(__rqb_error),
                        rollback: Box::new($crate::Error::from(__rqb_rollback)),
                    }),
                },
            }
        }
    };
}