Struct rbatis::rbatis::Rbatis

pub struct Rbatis {
    pub pool: Arc<OnceCell<Pool>>,
    pub sql_intercepts: Arc<Vec<Box<dyn SqlIntercept>>>,
    pub log_plugin: Arc<Box<dyn LogPlugin>>,
}

rbatis engine

Fields

pool: Arc<OnceCell<Pool>>

sql_intercepts: Arc<Vec<Box<dyn SqlIntercept>>>

log_plugin: Arc<Box<dyn LogPlugin>>

Implementations

impl Rbatis

pub fn new() -> Self

create an Rbatis

pub fn new_with_opt(option: RbatisOption) -> Self

new Rbatis from Option

pub async fn link<Driver: Driver + 'static>(
    &self,
    driver: Driver,
    url: &str
) -> Result<(), Error>

link pool

pub async fn link_builder<Driver: Driver + 'static>(
    &self,
    builder: Builder<ManagerPorxy>,
    driver: Driver,
    url: &str
) -> Result<(), Error>

link pool

pub async fn link_opt<Driver: Driver + 'static, ConnectOptions: ConnectOptions>(
    &self,
    driver: Driver,
    options: ConnectOptions
) -> Result<(), Error>

link pool by DBPoolOptions for example:

pub fn set_log_plugin(&mut self, arg: impl LogPlugin + 'static)

set_log_plugin

pub fn set_sql_intercepts(&mut self, arg: Vec<Box<dyn SqlIntercept>>)

set_sql_intercepts for many

pub fn get_pool(&self) -> Result<&Pool, Error>

get conn pool

can set option for example:

let rbatis = rbatis::Rbatis::new();
// rbatis.link(**).await;
// rbatis.get_pool().unwrap().set_max_open_conns()

pub fn driver_type(&self) -> Result<&str, Error>

get driver type

pub async fn acquire(&self) -> Result<RBatisConnExecutor, Error>

get an DataBase Connection used for the next step

pub async fn acquire_begin(&self) -> Result<RBatisTxExecutor, Error>

get an DataBase Connection,and call begin method,used for the next step

pub fn is_debug_mode(&self) -> bool

is debug mode

impl Rbatis

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

exec sql

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

fetch raw Value

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

fetch and decode

Trait Implementations

impl Clone for Rbatis

fn clone(&self) -> Rbatis

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Rbatis

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

Formats the value using the given formatter.

impl Default for Rbatis

fn default() -> Rbatis

Returns the “default value” for a type.

impl<'impl0> Executor for &'impl0 Rbatis

fn exec<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    sql: &'life1 str,
    args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<ExecResult, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn fetch<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    sql: &'life1 str,
    args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl Executor for Rbatis

fn exec<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    sql: &'life1 str,
    args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<ExecResult, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

fn fetch<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    sql: &'life1 str,
    args: Vec<Value>
) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

impl RbatisRef for &Rbatis

fn get_rbatis(&self) -> &Rbatis

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

impl RbatisRef for Rbatis

fn get_rbatis(&self) -> &Rbatis

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