datafusion_table_providers::sql::db_connection_pool::dbconnection

Function query_arrow

source 
pub async fn query_arrow<T, P>(
    conn: Box<dyn DbConnection<T, P>>,
    sql: String,
    projected_schema: Option<SchemaRef>,
) -> Result<SendableRecordBatchStream, Error>
Expand description

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

§Arguments

  • conn - The database connection.
  • sql - The SQL statement.

§Errors

Returns an error if the query fails.