Trait SqlConnection 

pub trait SqlConnection {
    // Required methods
    fn select(
        &self,
        table: &str,
        columns: &[String],
        where_clause: Option<&Expr>,
        order_by: &[OrderByItem],
        limit: Option<usize>,
        offset: Option<usize>,
        params: &[SochValue],
    ) -> SqlResult<ExecutionResult>;
    fn insert(
        &mut self,
        table: &str,
        columns: Option<&[String]>,
        rows: &[Vec<Expr>],
        on_conflict: Option<&OnConflict>,
        params: &[SochValue],
    ) -> SqlResult<ExecutionResult>;
    fn update(
        &mut self,
        table: &str,
        assignments: &[Assignment],
        where_clause: Option<&Expr>,
        params: &[SochValue],
    ) -> SqlResult<ExecutionResult>;
    fn delete(
        &mut self,
        table: &str,
        where_clause: Option<&Expr>,
        params: &[SochValue],
    ) -> SqlResult<ExecutionResult>;
    fn create_table(
        &mut self,
        stmt: &CreateTableStmt,
    ) -> SqlResult<ExecutionResult>;
    fn drop_table(&mut self, stmt: &DropTableStmt) -> SqlResult<ExecutionResult>;
    fn create_index(
        &mut self,
        stmt: &CreateIndexStmt,
    ) -> SqlResult<ExecutionResult>;
    fn drop_index(&mut self, stmt: &DropIndexStmt) -> SqlResult<ExecutionResult>;
    fn begin(&mut self, stmt: &BeginStmt) -> SqlResult<ExecutionResult>;
    fn commit(&mut self) -> SqlResult<ExecutionResult>;
    fn rollback(
        &mut self,
        savepoint: Option<&str>,
    ) -> SqlResult<ExecutionResult>;
    fn table_exists(&self, table: &str) -> SqlResult<bool>;
    fn index_exists(&self, index: &str) -> SqlResult<bool>;
}

Storage connection trait for executing SQL against actual storage

Implementations of this trait provide the bridge between parsed SQL and the underlying storage engine.

Required Methods

fn select( &self, table: &str, columns: &[String], where_clause: Option<&Expr>, order_by: &[OrderByItem], limit: Option<usize>, offset: Option<usize>, params: &[SochValue], ) -> SqlResult<ExecutionResult>

Execute a SELECT query

fn insert( &mut self, table: &str, columns: Option<&[String]>, rows: &[Vec<Expr>], on_conflict: Option<&OnConflict>, params: &[SochValue], ) -> SqlResult<ExecutionResult>

Execute an INSERT

fn update( &mut self, table: &str, assignments: &[Assignment], where_clause: Option<&Expr>, params: &[SochValue], ) -> SqlResult<ExecutionResult>

Execute an UPDATE

fn delete( &mut self, table: &str, where_clause: Option<&Expr>, params: &[SochValue], ) -> SqlResult<ExecutionResult>

Execute a DELETE

fn create_table(&mut self, stmt: &CreateTableStmt) -> SqlResult<ExecutionResult>

Create a table

fn drop_table(&mut self, stmt: &DropTableStmt) -> SqlResult<ExecutionResult>

Drop a table

fn create_index(&mut self, stmt: &CreateIndexStmt) -> SqlResult<ExecutionResult>

Create an index

fn drop_index(&mut self, stmt: &DropIndexStmt) -> SqlResult<ExecutionResult>

Drop an index

fn begin(&mut self, stmt: &BeginStmt) -> SqlResult<ExecutionResult>

Begin transaction

fn commit(&mut self) -> SqlResult<ExecutionResult>

Commit transaction

fn rollback(&mut self, savepoint: Option<&str>) -> SqlResult<ExecutionResult>

Rollback transaction

fn table_exists(&self, table: &str) -> SqlResult<bool>

Check if table exists

fn index_exists(&self, index: &str) -> SqlResult<bool>

Check if index exists

Implementors