Struct DuckDbRedshiftQueryBackend 

pub struct DuckDbRedshiftQueryBackend { /* private fields */ }

Implementations

impl DuckDbRedshiftQueryBackend

pub fn new(conn: Arc<Mutex<Connection>>) -> Self

Create a backend that executes queries against the given shared DuckDB connection. The caller retains an Arc<Mutex<Connection>> handle and can use it to seed the database or share it across multiple backends.

Each query briefly locks the mutex to call Connection::try_clone, which creates a lightweight handle to the same underlying database.

Trait Implementations

impl RedshiftQueryBackend for DuckDbRedshiftQueryBackend

fn execute_statement( &self, sql: String, ) -> Pin<Box<dyn Future<Output = StatementResult> + Send>>

Execute a single SQL statement and return the result asynchronously.

fn batch_execute( &self, sqls: Vec<String>, ) -> Pin<Box<dyn Future<Output = StatementResult> + Send>>

Execute a batch of SQL statements sequentially. Batch executions typically do not return a result set.