Struct SqliteSourceHandle 

pub struct SqliteSourceHandle { /* private fields */ }

Cloneable handle for issuing SQL statements against the source-owned connection.

Implementations

impl SqliteSourceHandle

pub fn source_id(&self) -> &str

Source ID this handle is associated with.

pub async fn execute(&self, sql: impl Into<String>) -> Result<usize>

Execute a SQL statement.

pub async fn execute_parameterized( &self, sql: impl Into<String>, params: Vec<SqliteParam>, ) -> Result<usize>

Execute a parameterized SQL statement with bind parameters.

pub async fn execute_batch(&self, sql: impl Into<String>) -> Result<()>

Execute a SQL script batch.

pub async fn query( &self, sql: impl Into<String>, ) -> Result<Vec<Map<String, Value>>>

Execute a query and return rows as JSON objects.

pub async fn query_parameterized( &self, sql: impl Into<String>, params: Vec<SqliteParam>, ) -> Result<Vec<Map<String, Value>>>

Execute a parameterized query and return rows as JSON objects.

pub async fn execute_statements_in_transaction( &self, statements: Vec<String>, ) -> Result<()>

Execute a sequence of SQL statements atomically.

pub async fn execute_parameterized_in_transaction( &self, statements: Vec<(String, Vec<SqliteParam>)>, ) -> Result<()>

Execute multiple parameterized statements atomically in a transaction.

pub async fn transaction<F, Fut, T>(&self, f: F) -> Result<T>

where F: FnOnce(SqliteTxHandle) -> Fut, Fut: Future<Output = Result<T>>,

Execute user logic in a transaction scope.

Trait Implementations

impl Clone for SqliteSourceHandle

fn clone(&self) -> SqliteSourceHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.