Struct SqlExecutor 

pub struct SqlExecutor {
    pub connection: Box<dyn DatabaseConnection>,
    /* private fields */
}

Fields

connection: Box<dyn DatabaseConnection>

Implementations

impl SqlExecutor

pub fn new(connection: Box<dyn DatabaseConnection>, db_type: &str) -> Self

pub fn with_connection(connection: Box<dyn DatabaseConnection>) -> Self

pub async fn execute(&mut self, sql: &str) -> ExecutionResult

pub async fn insert( &mut self, table: &str, data: &HashMap<String, Value>, ) -> ExecutionResult

pub async fn update( &mut self, table: &str, data: &HashMap<String, Value>, where_clause: &str, ) -> ExecutionResult

pub async fn delete( &mut self, table: &str, where_clause: &str, ) -> ExecutionResult

pub async fn select( &mut self, table: &str, fields: &[&str], where_clause: Option<&str>, order_by: Option<&str>, limit: Option<u64>, ) -> ExecutionResult

pub async fn batch_execute( &mut self, sql_statements: &[&str], ) -> Vec<ExecutionResult>

pub async fn create_table_if_not_exists( &mut self, table: &str, fields: &[(&str, &str)], primary_key: Option<&str>, ) -> ExecutionResult

pub async fn drop_table( &mut self, table: &str, if_exists: bool, ) -> ExecutionResult

pub fn last_execution_time(&self) -> Option<Duration>