artis 0.2.13

Artis is a SQL library
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

use std::sync::Arc;

use rbatis::executor::RBatisTxExecutor;

use crate::{types::Args, ArtisTxExecutor, BoxFuture, ExecResult, Result, Value};

#[derive(Debug)]
pub struct InnerRBatisTx {
    rb: Arc<RBatisTxExecutor>,
}

impl From<RBatisTxExecutor> for crate::ArtisTx {
    fn from(value: RBatisTxExecutor) -> Self {
        (Box::new(InnerRBatisTx {
            rb: Arc::new(value),
        }) as Box<dyn ArtisTxExecutor>)
            .into()
    }
}

impl ArtisTxExecutor for InnerRBatisTx {
    fn query(&self, raw: String, args: Args) -> BoxFuture<'_, Result<Value>> {
        Box::pin(async move { Ok(self.rb.query(&raw, args).await?) })
    }

    fn exec(&self, raw: String, args: Args) -> BoxFuture<'_, Result<ExecResult>> {
        Box::pin(async move {
            let rst = self.rb.exec(&raw, args).await?;
            Ok(ExecResult {
                rows_affected: rst.rows_affected,
                last_insert_id: rst.last_insert_id,
            })
        })
    }

    fn commit(&self) -> BoxFuture<'_, Result<()>> {
        Box::pin(async move { Ok(self.rb.conn_executor.commit().await?) })
    }

    fn rollback(&self) -> BoxFuture<'_, Result<()>> {
        Box::pin(async move { Ok(self.rb.conn_executor.rollback().await?) })
    }
}