Struct DuckDbConnectionPool

pub struct DuckDbConnectionPool { /* private fields */ }

Available on crate feature duckdb only.

Implementations

impl DuckDbConnectionPool

pub fn db_path(&self) -> &str

Get the dataset path. Returns :memory: if the in memory database is used.

pub fn new_memory() -> Result<Self, Error>

Create a new DuckDbConnectionPool from memory.

Arguments

• access_mode - The access mode for the connection pool

Returns

• A new DuckDbConnectionPool

Errors

• DuckDBConnectionSnafu - If there is an error creating the connection pool
• ConnectionPoolSnafu - If there is an error creating the connection pool

pub fn new_file(path: &str, access_mode: &AccessMode) -> Result<Self, Error>

Create a new DuckDbConnectionPool from a file.

Arguments

• path - The path to the file
• access_mode - The access mode for the connection pool

Returns

• A new DuckDbConnectionPool

Errors

• DuckDBConnectionSnafu - If there is an error creating the connection pool
• ConnectionPoolSnafu - If there is an error creating the connection pool

pub fn with_unsupported_type_action(self, action: UnsupportedTypeAction) -> Self

pub fn set_attached_databases(self, databases: &[Arc<str>]) -> Self

pub fn with_connection_setup_queries(self, queries: Vec<Arc<str>>) -> Self

pub fn connect_sync( self: Arc<Self>, ) -> Result<Box<dyn DbConnection<PooledConnection<DuckdbConnectionManager>, DuckDBParameter>>, Error>

Create a new DuckDbConnectionPool from a database URL.

Errors

• DuckDBConnectionSnafu - If there is an error creating the connection pool

pub fn mode(&self) -> Mode

pub fn get_attachments(&self) -> Result<Option<Arc<DuckDBAttachments>>, Error>

Trait Implementations

impl Clone for DuckDbConnectionPool

fn clone(&self) -> DuckDbConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DbConnectionPool<PooledConnection<DuckdbConnectionManager>, Box<dyn DuckDBSyncParameter>> for DuckDbConnectionPool

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn DbConnection<PooledConnection<DuckdbConnectionManager>, DuckDBParameter>>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn join_push_down(&self) -> JoinPushDown

impl Debug for DuckDbConnectionPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.