Enum DatabaseConnection 

pub enum DatabaseConnection {
    PostgreSQL(PostgresConnection),
    DuckDB(DuckDBConnection),
    Redis(RedisConnection),
    Unsupported(String),
}

Database connection enum that wraps different database drivers

Variants

PostgreSQL(PostgresConnection)

DuckDB(DuckDBConnection)

Redis(RedisConnection)

Unsupported(String)

Implementations

impl DatabaseConnection

pub async fn new( connection_string: &str, db_type: DatabaseType, ) -> DatabaseResult<Self>

Create a new connection based on connection string and database type

pub async fn execute(&self, query: &str) -> DatabaseResult<Recordset>

Execute a query and return results

pub async fn execute_command(&self, command: &str) -> DatabaseResult<u64>

Execute a command (INSERT, UPDATE, DELETE) and return rows affected

pub async fn close(&mut self) -> DatabaseResult<()>

Close the connection

pub async fn is_connected(&self) -> bool

Check if connection is alive

Trait Implementations

impl Debug for DatabaseConnection

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

Formats the value using the given formatter.