Struct Connection 

pub struct Connection<'a> { /* private fields */ }

Implementations

impl<'a> Connection<'a>

pub fn open(db: &'a Database) -> Result<Self>

pub fn txn_start_ts(&self) -> Option<i64>

Txn-start UTC µs inside BEGIN/COMMIT, else None.

pub fn session_timezone(&self) -> String

Returns the session time-zone (IANA name or fixed offset). Default "UTC".

pub fn set_session_timezone(&self, tz: &str) -> Result<()>

Set the session time-zone. Accepts IANA names, ISO-8601 offsets, "UTC", "Z".

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

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

pub fn execute_script(&self, sql: &str) -> ScriptExecution

Execute ;-separated SQL statements. Stops at the first failure.

pub fn query(&self, sql: &str) -> Result<QueryResult>

pub fn query_params(&self, sql: &str, params: &[Value]) -> Result<QueryResult>

pub fn prepare(&self, sql: &str) -> Result<PreparedStatement<'_, 'a>>

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

pub fn in_transaction(&self) -> bool

Returns true if an explicit transaction is active (BEGIN was issued).

pub fn table_schema(&self, name: &str) -> Option<TableSchema>

pub fn refresh_schema(&self) -> Result<()>

pub fn persist_ann_index( &self, table: &str, column: &str, ) -> Result<AnnSegmentInfo>

Freeze the ANN index for table.column into a persisted segment: one write txn scans, builds, serializes, and commits atomically; subsequent cold attaches LOAD it (seconds) instead of rebuilding (minutes), with the load-time scan re-proving freshness by content. The single writer lock is held for the whole build - an offline/builder operation. Refused inside an explicit transaction (it owns its own txn), and for TEMP tables (their storage bypasses the DDL paths that purge segments).

pub fn ann_cache_status( &self, table: &str, column: &str, ) -> Result<Option<(AnnIndexSource, u64)>>

The identity of the index currently cached for table.column: (source, snapshot generation) - Loaded{segment_b3} means queries are served by the persisted segment; Built{refusal} carries why a segment was rejected, if one was.

Trait Implementations

impl<'a> Drop for Connection<'a>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.