Struct DuckDbAthenaQueryBackend 

pub struct DuckDbAthenaQueryBackend { /* private fields */ }

Implementations

impl DuckDbAthenaQueryBackend

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 AthenaQueryBackend for DuckDbAthenaQueryBackend

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

Execute sql and return the result asynchronously.