Struct rbatis::executor::RBatisTxExecutor

pub struct RBatisTxExecutor {
    pub tx_id: i64,
    pub conn: Mutex<Box<dyn Connection>>,
    pub rb: RBatis,
    pub done: bool,
}

Fields

tx_id: i64

conn: Mutex<Box<dyn Connection>>

rb: RBatis

done: bool

if tx call .commit() or .rollback() done = true. if tx not call .commit() or .rollback() done = false

Implementations

impl<'a> RBatisTxExecutor

pub fn new(rb: RBatis, conn: Box<dyn Connection>) -> Self

pub async fn exec( &self, sql: &str, args: Vec<Value> ) -> Result<ExecResult, Error>

exec

pub async fn query(&self, sql: &str, args: Vec<Value>) -> Result<Value, Error>

query value

pub async fn query_decode<T>( &self, sql: &str, args: Vec<Value> ) -> Result<T, Error>

where T: DeserializeOwned,

query and decode

pub fn begin(self) -> BoxFuture<'static, Result<Self, Error>>

pub fn rollback(&mut self) -> BoxFuture<'_, Result<(), Error>>

pub fn commit(&mut self) -> BoxFuture<'_, Result<(), Error>>

impl RBatisTxExecutor

pub fn take_conn(self) -> Option<Box<dyn Connection>>

impl RBatisTxExecutor

pub fn defer_async<F>( self, callback: fn(s: RBatisTxExecutor) -> F ) -> RBatisTxExecutorGuard

where F: Future<Output = ()> + Send + 'static,

defer and use future method for example: tx.defer_async(|mut tx| async { tx.rollback().await; });

Trait Implementations

impl Debug for RBatisTxExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Executor for RBatisTxExecutor

fn exec( &self, sql: &str, args: Vec<Value> ) -> BoxFuture<'_, Result<ExecResult, Error>>

fn query( &self, sql: &str, args: Vec<Value> ) -> BoxFuture<'_, Result<Value, Error>>

fn name(&self) -> &str

impl RBatisRef for RBatisTxExecutor

fn rb_ref(&self) -> &RBatis

fn driver_type(&self) -> Result<&str>