Struct NamespacedSqlConnection 

pub struct NamespacedSqlConnection<C: SqlConnection> { /* private fields */ }

A wrapper around any SqlConnection that prefixes table names with namespace:database: to provide storage-level isolation between tenants.

Key Isolation

All storage keys are prefixed: ns:db:table/row_id instead of table/row_id. This prevents any cross-namespace data leakage at the storage layer.

Example

// Without namespace prefix:
table key = "users/1"

// With namespace prefix (namespace="prod", database="app"):
table key = "prod:app:users/1"

Implementations

impl<C: SqlConnection> NamespacedSqlConnection<C>

pub fn new( inner: C, namespace: impl Into<String>, database: impl Into<String>, ) -> Self

Create a new namespaced connection.

pub fn namespace(&self) -> &str

Get the namespace.

pub fn database(&self) -> &str

Get the database.

pub fn inner(&self) -> &C

Get a reference to the inner connection.

pub fn inner_mut(&mut self) -> &mut C

Get a mutable reference to the inner connection.

Trait Implementations

impl<C: SqlConnection> SqlConnection for NamespacedSqlConnection<C>

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.