async fn run_query(db: Arc<Db>, query: &str) -> Vec<RecordBatch> {
        let planner = SqlQueryPlanner::default();
        let executor = db.executor();

        let physical_plan = planner.query(db, query, &executor).unwrap();

        executor
            .collect(physical_plan, ExecutorType::Query)
            .await
            .unwrap()
    }
// run a sql query against the database, returning the results as record batches
run a sql query against the database, returning the results as record batches
run a sql query against the database returning the results as record batches
async fn run_query(db: Arc<Db>, query: &str) -> Vec<RecordBatch> {
        let planner = SqlQueryPlanner::default();
        let executor = db.executor();
        let physical_plan = planner.query(db, query, &executor).unwrap();
        executor
            .collect(physical_plan, ExecutorType::Query)
            .await
            .unwrap()
    }
async fn run_query ( db : Arc < Db > , query : & str ) -> Vec < RecordBatch > { let planner = SqlQueryPlanner :: default ( ) ; let executor = db . executor ( ) ; let physical_plan = planner . query ( db , query , & executor ) . unwrap ( ) ; executor . collect ( physical_plan , ExecutorType :: Query ) . await . unwrap ( ) }
run a sql query against the database, returning the results as record batches
run a sql query against the database returning the results as record batches
db
Arc<Db>
query
&str
db
Arc<Db>
query
&str