Struct QueryEngine 

pub struct QueryEngine { /* private fields */ }

Query engine for executing SQL statements. Maintains separate ExecutionContexts per database for multi-tenancy. Now with disk persistence support for crash recovery.

Implementations

impl QueryEngine

pub fn new() -> Self

pub fn with_persistence(data_dir: &Path) -> Self

Create a QueryEngine with persistence to the specified directory.

pub fn set_peers(&self, peers: Vec<String>)

Set peer addresses for mutation replication.

pub fn is_mutation(sql: &str) -> bool

Check if a SQL statement is a mutation (DDL/DML that modifies data).

pub fn execute( &self, sql: &str, database: Option<&str>, ) -> Result<QueryResult, QueryError>

Execute a SQL query against the specified database. Supports multi-statement input with transaction control: BEGIN; INSERT ...; INSERT ...; COMMIT; executes atomically. On ROLLBACK (explicit or on error inside a transaction), all changes since BEGIN are undone.

pub fn execute_with_params( &self, sql: &str, database: Option<&str>, params: &[Value], ) -> Result<QueryResult, QueryError>

List all tables in the specified database. Execute a parameterized SQL query. Params are JSON values that replace $1, $2, … placeholders.

pub fn list_tables(&self, database: Option<&str>) -> Vec<String>

pub fn list_databases(&self) -> Vec<String>

List all databases.

pub fn get_table_info( &self, name: &str, database: Option<&str>, ) -> Option<TableInfo>

Get table schema information from the specified database.

pub fn flush(&self)

Force persist all databases to disk (for graceful shutdown).

Trait Implementations

impl Default for QueryEngine

fn default() -> Self

Returns the “default value” for a type.