Trait SyncDbConnection

pub trait SyncDbConnection<T, P>: DbConnection<T, P> {
    // Required methods
    fn new(conn: T) -> Self
       where Self: Sized;
    fn tables(&self, schema: &str) -> Result<Vec<String>, Error>;
    fn schemas(&self) -> Result<Vec<String>, Error>;
    fn get_schema(
        &self,
        table_reference: &TableReference,
    ) -> Result<SchemaRef, Error>;
    fn query_arrow(
        &self,
        sql: &str,
        params: &[P],
        projected_schema: Option<SchemaRef>,
    ) -> Result<SendableRecordBatchStream, GenericError>;
    fn execute(&self, sql: &str, params: &[P]) -> Result<u64, GenericError>;
}

Required Methods

fn new(conn: T) -> Self

where Self: Sized,

fn tables(&self, schema: &str) -> Result<Vec<String>, Error>

fn schemas(&self) -> Result<Vec<String>, Error>

fn get_schema( &self, table_reference: &TableReference, ) -> Result<SchemaRef, Error>

Get the schema for a table reference.

Arguments

• table_reference - The table reference.

Errors

Returns an error if the schema cannot be retrieved.

fn query_arrow( &self, sql: &str, params: &[P], projected_schema: Option<SchemaRef>, ) -> Result<SendableRecordBatchStream, GenericError>

Query the database with the given SQL statement and parameters, returning a Result of SendableRecordBatchStream.

Arguments

• sql - The SQL statement.
• params - The parameters for the SQL statement.
• projected_schema - The Projected schema for the query.

Errors

Returns an error if the query fails.

fn execute(&self, sql: &str, params: &[P]) -> Result<u64, GenericError>

Execute the given SQL statement with parameters, returning the number of affected rows.

Arguments

• sql - The SQL statement.
• params - The parameters for the SQL statement.

Errors

Returns an error if the execution fails.

Implementors

impl SyncDbConnection<PooledConnection<DuckdbConnectionManager>, Box<dyn DuckDBSyncParameter>> for DuckDbConnection

Available on crate feature duckdb only.