Struct SqliteSqlExecutor 

pub struct SqliteSqlExecutor;

Trait Implementations

impl Clone for SqliteSqlExecutor

fn clone(&self) -> SqliteSqlExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Executor for SqliteSqlExecutor

type Row<'a> = SqliteRow<'a>

type Conn = Object<Manager>

async fn query<T, R, F, Q>( &self, conn: Arc<Mutex<Self::Conn>>, sql: &str, params: &Vec<ParamValue>, mapper: F, processor: Q, ) -> Result<R, DatabaseError>

where T: Send + 'static, R: Send + 'static, F: for<'a> Fn(&Self::Row<'a>) -> Result<T, DatabaseError> + Send + 'static, Q: FnOnce(Vec<T>) -> Result<R, DatabaseError> + Send + 'static,

async fn execute( &self, conn: Arc<Mutex<Self::Conn>>, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

fn get_conn_ref(&self) -> Result<Arc<Mutex<Self::Conn>>, DatabaseError>

async fn get_conn(&self) -> Result<Self::Conn, DatabaseError>

async fn start_transaction(&self) -> Result<(), DatabaseError>

async fn commit(&self) -> Result<(), DatabaseError>

async fn rollback(&self) -> Result<(), DatabaseError>

async fn transaction_basic_exec<F, T, Fut>( &self, func: F, ) -> Result<T, DatabaseError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T, DatabaseError>>,

async fn exec_basic( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

async fn query_basic<T, R, F, Q>( &self, sql: &str, params: &Vec<ParamValue>, mapper: F, processor: Q, ) -> Result<R, DatabaseError>

where T: Send + 'static, R: Send + 'static, F: for<'a> Fn(&Self::Row<'a>) -> Result<T, DatabaseError> + Send + 'static + Sync, Q: FnOnce(Vec<T>) -> Result<R, DatabaseError> + Send + 'static,

fn row_to_e<E>(row: &Self::Row<'_>) -> Result<E, DatabaseError>

where E: Mapping,

async fn query_some<E>( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<Vec<E>, DatabaseError>

where E: Mapping,

async fn query_one<E>( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<Option<E>, DatabaseError>

where E: Mapping,

async fn query_one_value<T>( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<Option<T>, DatabaseError>

where Option<T>: From<ParamValue> + Send + Sync + 'static,

async fn query_count( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

async fn insert<E>( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<Option<<E as Entity>::K>, DatabaseError>

where E: Entity,

async fn insert_batch<E>( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

where E: Entity,

async fn delete( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

async fn update( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>

async fn execute_sql( &self, sql: &str, params: &Vec<ParamValue>, ) -> Result<u64, DatabaseError>