duckdb 1.10502.0

Ergonomic wrapper for DuckDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::path::PathBuf;

use duckdb::{
    Connection, Result,
    arrow::{record_batch::RecordBatch, util::pretty::print_batches},
};

fn main() -> Result<()> {
    let db = Connection::open_in_memory()?;

    db.execute_batch("INSTALL parquet; LOAD parquet;")?;

    let parquet_path = PathBuf::from(env!("CARGO_MANIFEST_DIR")).join("examples/int32_decimal.parquet");

    let rbs: Vec<RecordBatch> = db
        .prepare("SELECT * FROM read_parquet(?)")?
        .query_arrow([parquet_path.to_string_lossy()])?
        .collect();

    assert!(print_batches(&rbs).is_ok());

    Ok(())
}