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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

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

pub trait DeleteRepositoryTransaction<M: Model>:
    DeleteRepository<M> + TransactionRepository<M>
{
    fn delete_by_id_in_transaction<'a>(
        &'a self,
        id: impl Into<M::Id> + Send + 'a,
    ) -> impl Future<Output = Result<(), Error>> + Send + 'a
    where
        M::Id: 'a,
    {
        self.with_transaction(move |mut tx| async move {
            let res = self.delete_by_id_with_executor(&mut *tx, id).await;

            (res, tx)
        })
    }

    fn delete_by_filter_in_transaction<'a>(
        &'a self,
        filter: impl SqlFilter<'a> + Send + 'a,
    ) -> impl Future<Output = Result<(), Error>> + Send + 'a {
        self.with_transaction(move |mut tx| async move {
            let res = self.delete_by_filter_with_executor(&mut *tx, filter).await;

            (res, tx)
        })
    }

    fn delete_by_values_in_transaction<'a, I>(
        &'a self,
        column: &'static str,
        values: I,
    ) -> impl Future<Output = Result<(), Error>> + Send + 'a
    where
        M::Id: ::sqlx::Type<Database> + ::sqlx::Encode<'a, Database> + 'a,
        I: IntoIterator<Item = M::Id> + Send + 'a,
        I::IntoIter: Send + 'a,
    {
        let filter = InValues::new(column, values);

        self.delete_by_filter_in_transaction(filter)
    }
}

impl<T, M> DeleteRepositoryTransaction<M> for T
where
    T: DeleteRepository<M> + TransactionRepository<M>,
    M: Model,
{
}