Struct Executor 

pub struct Executor { /* private fields */ }

SQL Query Executor

The executor is the main entry point for executing SQL statements. It coordinates between the parser, storage engine, and function registry.

Implementations

impl Executor

pub fn install_application_relations( &self, ) -> Result<ApplicationRelationIdentity>

Install both relation contracts in one ordinary transaction.

Existing names are accepted only when owner and ordered schema match exactly. Opening a database never invokes this method implicitly.

pub fn application_relation_identity( &self, ) -> Result<ApplicationRelationIdentity>

Resolve and validate the durable catalog identity without mutating it.

pub fn append_audit_event( &self, context: &ExecutionContext, event: AuditEvent, ) -> Result<[u8; 16]>

Append one immutable audit success record to the caller transaction. Parameter values are never captured implicitly.

pub fn append_outbox_message(&self, message: OutboxMessage) -> Result<[u8; 16]>

Append one typed external side-effect intent to the caller transaction.

pub fn claim_outbox( &self, worker_id: &str, now: DateTime<Utc>, lease_duration: Duration, limit: usize, max_attempts: u32, ) -> Result<Vec<OutboxClaim>>

Atomically claim pending or expired-lease messages for one worker.

The scan and returned batch are both bounded. A conflicting claimant loses at the ordinary MVCC write-claim/commit boundary and receives no unpublished lease records.

pub fn complete_outbox( &self, message_id: [u8; 16], lease_token: [u8; 16], completed_at: DateTime<Utc>, ) -> Result<OutboxCompletion>

Durably mark delivery complete. Repeating the same token is idempotent.

pub fn retry_outbox( &self, message_id: [u8; 16], lease_token: [u8; 16], failed_at: DateTime<Utc>, retry_at: DateTime<Utc>, error: &str, max_attempts: u32, ) -> Result<OutboxRetryDisposition>

Release a failed delivery for retry or move it to the dead-letter state.

pub fn prune_application_history( &self, now: DateTime<Utc>, policy: ApplicationRetentionPolicy, ) -> Result<ApplicationRetentionOutcome>

Delete only expired immutable audit history and terminal outbox rows.

impl Executor

pub fn authenticate_principal( &self, login: &str, password: &str, ) -> Result<ObjectId>

Resolve and verify a durable catalog Principal for a network session. The returned stable ID is the only identity accepted by later request contexts; credentials never leave this boundary.

pub fn new(engine: Arc<MVCCEngine>) -> Self

Create a new executor with the given storage engine

pub fn with_function_registry( engine: Arc<MVCCEngine>, function_registry: Arc<FunctionRegistry>, ) -> Self

Create a new executor with a custom function registry

pub fn with_cache_size(engine: Arc<MVCCEngine>, cache_size: usize) -> Self

Create a new executor with a custom cache size

pub fn has_active_transaction(&self) -> bool

Check if there is an active explicit transaction

pub fn set_default_isolation_level(&self, level: IsolationLevel)

Set the default isolation level for new transactions

pub fn default_isolation_level(&self) -> IsolationLevel

Return this connection’s default isolation for future transactions.

pub fn engine(&self) -> &Arc<MVCCEngine>

Get the storage engine

pub fn function_registry(&self) -> &Arc<FunctionRegistry>

Get the function registry

pub fn execute(&self, sql: &str) -> Result<ExecutionResult>

Execute a SQL query string

This is the main entry point for executing SQL statements. It parses the query and executes each statement in order. Uses the query cache to avoid re-parsing identical queries.

pub fn execute_with_params( &self, sql: &str, params: ParamVec, ) -> Result<ExecutionResult>

Execute a SQL query with positional parameters

Parameters are substituted for $1, $2, etc. placeholders in the query. Uses the query cache and selects any eligible borrowed-parameter fast path internally, so public facades do not own execution policy.

pub fn try_fast_path_with_params( &self, sql: &str, params: &[Value], ) -> Option<Result<ExecutionResult>>

Try fast path execution with borrowed params slice Returns None if fast path doesn’t apply, Some(result) otherwise

pub fn execute_with_named_params( &self, sql: &str, params: FxHashMap<String, Value>, ) -> Result<ExecutionResult>

Execute a SQL query with named parameters

Parameters are substituted for :name placeholders in the query. Uses the query cache for efficient re-execution of parameterized queries.

pub fn execute_with_context( &self, sql: &str, ctx: &ExecutionContext, ) -> Result<ExecutionResult>

Execute a SQL query with a full execution context Uses the query cache for efficient re-execution.

pub fn query_cache(&self) -> &QueryCache

Get the query cache

pub fn cache_stats(&self) -> CacheStats

Get query cache statistics

pub fn clear_cache(&self)

Clear the query cache

pub fn semantic_cache(&self) -> &SemanticCache

Get the semantic cache

pub fn semantic_cache_stats(&self) -> SemanticCacheStatsSnapshot

Get semantic cache statistics

pub fn clear_semantic_cache(&self)

Clear the semantic cache

pub fn invalidate_semantic_cache(&self, table_name: &str)

Invalidate semantic cache for a specific table

Call this after INSERT, UPDATE, DELETE, or TRUNCATE on a table.

pub fn execute_program(&self, program: &Program) -> Result<ExecutionResult>

Execute a parsed program

pub fn execute_program_with_context( &self, program: &Program, ctx: &ExecutionContext, ) -> Result<ExecutionResult>

Execute a parsed program with context

pub fn execute_statement( &self, statement: &Statement, ctx: &ExecutionContext, ) -> Result<ExecutionResult>

Execute a single statement

pub fn begin_transaction(&self) -> Result<Box<dyn Transaction>>

Begin a new transaction

pub fn begin_transaction_with_isolation( &self, isolation: IsolationLevel, ) -> Result<Box<dyn Transaction>>

Begin a new transaction with a specific isolation level

pub fn get_or_create_plan(&self, sql: &str) -> Result<CachedPlanRef>

Get or create a cached plan for a SQL statement.

Parses the SQL and caches the plan if not already cached. Returns a lightweight CachedPlanRef that can be stored and reused for repeated execution without re-parsing or cache lookup overhead.

pub fn execute_with_cached_plan( &self, plan: &CachedPlanRef, ctx: &ExecutionContext, ) -> Result<ExecutionResult>

Execute a pre-cached plan directly, skipping cache lookup.

This is the fast path for prepared statements: the caller holds a CachedPlanRef obtained from get_or_create_plan() and passes it here on every execution, avoiding normalize + hash + RwLock read per call.

impl Executor

pub fn execute_procedure( &self, routine: ObjectId, arguments: Vec<RuntimeValue>, context: &ExecutionContext, principals: PrincipalContext, results: &mut dyn ProceduralResultStage, ) -> ProceduralResult<ProceduralCallOutcome>

Resolve and execute one durable Procedure from the transaction-visible catalog generation. Source and typed metadata are verified after the call boundary pins that generation.

pub fn execute_procedural_program( &self, program: &VerifiedProgram, arguments: Vec<RuntimeValue>, context: &ExecutionContext, principals: PrincipalContext, policy: ResourcePolicy, results: &mut dyn ProceduralResultStage, ) -> ProceduralResult<ProceduralCallOutcome>

Execute one verified procedural program as one atomic engine operation.

impl Executor

pub fn execute_job_attempt( &self, job_id: ObjectId, metadata: JobAttemptMetadata, context: &ExecutionContext, ) -> Result<JobAttemptOutcome, Diagnostic>

Trait Implementations

impl AggregationHost for Executor

fn aggregation_engine(&self) -> &Arc<MVCCEngine>

fn aggregation_function_registry(&self) -> &FunctionRegistry

fn aggregation_active_transaction(&self) -> &Mutex<Option<ActiveTransaction>>

fn aggregation_process_where_subqueries( &self, expression: &Expression, context: &ExecutionContext, ) -> Result<Expression>

fn aggregation_try_process_select_subqueries( &self, columns: &[Expression], context: &ExecutionContext, ) -> Result<Option<Vec<Expression>>>

fn aggregation_has_correlated_subqueries(&self, expression: &Expression) -> bool

fn aggregation_process_correlated_expression( &self, expression: &Expression, context: &ExecutionContext, ) -> Result<Expression>

fn aggregation_output_column_names( &self, select_expressions: &[Expression], source_columns: &[String], table_alias: Option<&str>, ) -> Vec<String>

impl CteHost for Executor

fn cte_function_registry(&self) -> &FunctionRegistry

fn cte_execute_select( &self, statement: &SelectStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

impl NavigationHost for Executor

fn navigation_engine(&self) -> &Arc<MVCCEngine>

fn navigation_active_transaction(&self) -> &Mutex<Option<ActiveTransaction>>

fn navigation_execute_select( &self, statement: &SelectStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn navigation_project_rows_with_alias( &self, select_expressions: &[Expression], rows: RowVec, columns: &[String], columns_lower: Option<&[String]>, context: &ExecutionContext, table_alias: Option<&str>, ) -> Result<RowVec>

fn navigation_source_materialized( &self, plan: &ReferenceExpandPlan, context: &ExecutionContext, )

impl StatementDispatchHost for Executor

type NavigationPlan = ReferenceExpandPlan

fn dispatch_ddl_fence_already_held(&self) -> bool

fn dispatch_authorize_statement( &self, statement: &Statement, context: &ExecutionContext, ) -> Result<()>

fn dispatch_bind_navigation( &self, statement: &Statement, ) -> Result<Option<Self::NavigationPlan>>

fn dispatch_select( &self, statement: &SelectStatement, navigation: Option<&Self::NavigationPlan>, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_call( &self, statement: &CallStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_set( &self, statement: &SetStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_show_tables( &self, statement: &ShowTablesStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_show_views( &self, statement: &ShowViewsStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_show_create_table( &self, statement: &ShowCreateTableStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_show_create_view( &self, statement: &ShowCreateViewStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_show_indexes( &self, statement: &ShowIndexesStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_describe( &self, statement: &DescribeStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_pragma( &self, statement: &PragmaStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_expression( &self, statement: &ExpressionStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_explain( &self, statement: &ExplainStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_analyze( &self, statement: &AnalyzeStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

fn dispatch_vacuum( &self, statement: &VacuumStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

impl SubqueryHost for Executor

fn subquery_engine(&self) -> &Arc<MVCCEngine>

fn subquery_open_table(&self, table_name: &str) -> Result<QueryTableHandle>

fn subquery_execute_select( &self, statement: &SelectStatement, context: &ExecutionContext, ) -> Result<Box<dyn QueryResult>>

impl WindowHost for Executor

fn window_function_registry(&self) -> &FunctionRegistry