sqlx-utils 1.1.3

Utilities for working with SQLx in a structured and efficient way, both when developing and running
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
28
29
30
31
32
33
34
35

use crate::prelude::*;
use std::future::Future;

pub trait UpdatableRepositoryTransaction<M: Model>:
    UpdatableRepository<M> + TransactionRepository<M>
{
    fn update_in_transaction<'a>(
        &'a self,
        model: M,
    ) -> impl Future<Output = Result<M, Error>> + Send + 'a
    where
        M: 'a,
    {
        self.with_transaction(move |mut tx| async move {
            let res = self.update_with_executor(&mut *tx, model).await;

            (res, tx)
        })
    }

    fn update_ref_in_transaction<'a, 'b>(
        &'a self,
        model: &'b M,
    ) -> impl Future<Output = Result<(), Error>> + Send + 'a
    where
        'b: 'a,
        M: 'b,
    {
        self.with_transaction(move |mut tx| async move {
            let res = self.update_ref_with_executor(&mut *tx, model).await;

            (res, tx)
        })
    }
}