Struct DatabaseSqlConnection 

pub struct DatabaseSqlConnection { /* private fields */ }

Concrete implementation of SqlConnection backed by sochdb_storage::Database.

This enables the SqlBridge to route parsed SQL AST operations to the actual storage engine, making SELECT, INSERT, UPDATE, DELETE, and DDL statements work against real persisted data.

Transaction Model

The connection maintains an optional active write transaction. Read-only operations (select, table_exists) use fast read-only transactions. Write operations auto-begin a transaction if none is active.

Implementations

impl DatabaseSqlConnection

pub fn new(db: Arc<Database>) -> Self

Create a new SQL connection wrapping a Database instance.

pub fn database(&self) -> &Arc<Database>

Get a reference to the underlying database.

Trait Implementations

impl SqlConnection for DatabaseSqlConnection

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

Execute a SELECT query

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

Execute an INSERT

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

Execute an UPDATE

fn delete( &mut self, table: &str, where_clause: Option<&Expr>, params: &[CoreSochValue], ) -> 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 alter_table(&mut self, stmt: &AlterTableStmt) -> SqlResult<ExecutionResult>

Alter a table (add/drop/rename columns, rename table)

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

fn scan_all( &self, table: &str, columns: &[String], ) -> SqlResult<Vec<HashMap<String, CoreSochValue>>>

Scan all rows from a table (no filter, no ordering). Used for JOIN processing — each leaf table is scanned once, then join logic is applied in-memory.

fn eval_join_predicate( &self, expr: &Expr, row: &HashMap<String, CoreSochValue>, params: &[CoreSochValue], ) -> Option<bool>

Evaluate an expression against a merged row (used for JOIN ON conditions). Returns true/false, or None if evaluation fails.