Struct QueryExecutor 

pub struct QueryExecutor { /* private fields */ }

Handles SQL query execution via HTTP.

Implementations

impl QueryExecutor

pub async fn execute( &self, sql: &str, files: Option<Vec<(String, String, Vec<u8>, Option<String>)>>, params: Option<Vec<Value>>, namespace_id: Option<String>, ) -> Result<QueryResponse, KalamLinkError>

Execute a SQL query with optional parameters and namespace.

pub async fn execute_with_progress( &self, sql: &str, files: Option<Vec<(String, String, Vec<u8>, Option<String>)>>, params: Option<Vec<Value>>, namespace_id: Option<String>, progress: Option<Arc<dyn Fn(UploadProgress) + Send + Sync>>, ) -> Result<QueryResponse, KalamLinkError>

Execute a SQL query with optional parameters and namespace, with upload progress callback.

Trait Implementations

impl Clone for QueryExecutor

fn clone(&self) -> QueryExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.