Struct DuckDBBackend 

pub struct DuckDBBackend { /* private fields */ }

DuckDB backend for OLAP workloads and analytics

Implementations

impl DuckDBBackend

pub async fn memory() -> Result<Self>

Create a new DuckDB backend with an in-memory database

pub async fn file(path: &str) -> Result<Self>

Create a new DuckDB backend with a file-based database

pub async fn export_parquet(&mut self, table: &str, path: &str) -> Result<()>

Export database to Parquet file

pub async fn import_parquet(&mut self, table: &str, path: &str) -> Result<()>

Import data from Parquet file

pub async fn export_csv(&mut self, table: &str, path: &str) -> Result<()>

Export database to CSV file

pub async fn analyze_table(&mut self, table: &str) -> Result<()>

Get table statistics

pub async fn create_index( &mut self, table: &str, column: &str, index_name: &str, ) -> Result<()>

Create an index on a table

Trait Implementations

impl DatabaseBackend for DuckDBBackend

fn connect<'life0, 'async_trait>( url: &'life0 str, ) -> Pin<Box<dyn Future<Output = Result<Self>> + Send + 'async_trait>>

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

Connect to the database

fn execute<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Execute a SQL statement (no results)

fn query<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<QueryResult>> + Send + 'async_trait>>

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

Query and return results

fn begin_transaction<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Begin a transaction

fn commit<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Commit the current transaction

fn rollback<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Rollback the current transaction

fn is_connected(&self) -> bool

Check if connected

fn close<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait,

Close the connection