Struct RuntimeSession 

pub struct RuntimeSession { /* private fields */ }

A session for executing operations with optional transaction support.

This is a high-level wrapper around the transaction machinery that provides a clean API for users. Operations can be executed directly or within a transaction.

Implementations

impl RuntimeSession

pub fn namespace_registry(&self) -> Arc<RwLock<RuntimeStorageNamespaceRegistry>>

pub fn begin_transaction(&self) -> Result<RuntimeStatementResult<BoxedPager>>

Begin a transaction in this session. Creates an empty staging context for new tables created within the transaction. Existing tables are accessed via MVCC visibility filtering - NO data copying occurs.

pub fn abort_transaction(&self)

Mark the current transaction as aborted due to an error. This should be called when any error occurs during a transaction.

pub fn has_active_transaction(&self) -> bool

Check if this session has an active transaction.

pub fn is_aborted(&self) -> bool

Check if the current transaction has been aborted due to an error.

pub fn is_table_created_in_transaction(&self, table_name: &str) -> bool

Check if a table was created in the current active transaction.

pub fn table_column_specs_from_transaction( &self, table_name: &str, ) -> Option<Vec<PlanColumnSpec>>

Get column specifications for a table created in the current transaction. Returns None if there’s no active transaction or the table wasn’t created in it.

pub fn tables_referencing_in_transaction( &self, referenced_table: &str, ) -> Vec<String>

Get tables that reference the given table via foreign keys created in the current transaction. Returns an empty vector if there’s no active transaction or no transactional FKs reference this table.

pub fn commit_transaction(&self) -> Result<RuntimeStatementResult<BoxedPager>>

Commit the current transaction and apply changes to the base context. If the transaction was aborted, this acts as a ROLLBACK instead.

pub fn rollback_transaction(&self) -> Result<RuntimeStatementResult<BoxedPager>>

Rollback the current transaction, discarding all changes.

pub fn execute_insert_plan( &self, plan: InsertPlan, ) -> Result<RuntimeStatementResult<BoxedPager>>

Insert rows (outside or inside transaction).

pub fn execute_select_plan( &self, plan: SelectPlan, ) -> Result<RuntimeStatementResult<BoxedPager>>

Select rows (outside or inside transaction).

pub fn table_rows(&self, table: &str) -> Result<Vec<Vec<PlanValue>>>

Convenience helper to fetch all rows from a table within this session.

pub fn execute_update_plan( &self, plan: UpdatePlan, ) -> Result<RuntimeStatementResult<BoxedPager>>

pub fn execute_delete_plan( &self, plan: DeletePlan, ) -> Result<RuntimeStatementResult<BoxedPager>>

pub fn execute_truncate_plan( &self, plan: TruncatePlan, ) -> Result<RuntimeStatementResult<BoxedPager>>

Trait Implementations

impl CatalogDdl for RuntimeSession

Implement CatalogDdl directly on the session so callers must import the trait to perform schema mutations. This keeps all runtime DDL entry points aligned with the shared contract used by contexts and storage namespaces.

type CreateTableOutput = RuntimeStatementResult<BoxedPager>

Output of executing a CREATE TABLE plan.

type DropTableOutput = RuntimeStatementResult<BoxedPager>

Output of executing a DROP TABLE plan.

type RenameTableOutput = ()

Output of executing a table rename.

type AlterTableOutput = RuntimeStatementResult<BoxedPager>

Output of executing an ALTER TABLE plan.

type CreateIndexOutput = RuntimeStatementResult<BoxedPager>

Output of executing a CREATE INDEX plan.

type DropIndexOutput = RuntimeStatementResult<BoxedPager>

Output of executing a DROP INDEX plan.

fn create_table(&self, plan: CreateTablePlan) -> Result<Self::CreateTableOutput>

Creates a table described by the given plan.

fn drop_table(&self, plan: DropTablePlan) -> Result<Self::DropTableOutput>

Drops a table identified by the given plan.

fn create_view(&self, plan: CreateViewPlan) -> Result<()>

Creates a view described by the given plan.

fn drop_view(&self, plan: DropViewPlan) -> Result<()>

Drops a view identified by the given plan.

fn rename_table(&self, plan: RenameTablePlan) -> Result<Self::RenameTableOutput>

Renames a table using the provided plan.

fn alter_table(&self, plan: AlterTablePlan) -> Result<Self::AlterTableOutput>

Alters a table using the provided plan.

fn create_index(&self, plan: CreateIndexPlan) -> Result<Self::CreateIndexOutput>

Creates an index described by the given plan.

fn drop_index(&self, plan: DropIndexPlan) -> Result<Self::DropIndexOutput>

Drops a single-column index described by the given plan, returning metadata about the index when it existed.