oxisql-datafusion 0.3.1

Apache DataFusion TableProvider over oxisql Connection — enables OLAP SQL queries against oxisql-backed tables
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

//! Shared test helpers for oxisql-datafusion integration tests.
//!
//! Each test binary (`tests/*.rs`) includes this module via `mod common;`.

use std::sync::Arc;

use arrow::datatypes::{DataType, Field, Schema};
use oxisql_core::{Row, Value};

/// Build a small test dataset: two rows with id / name / score columns.
#[allow(dead_code)]
pub fn make_test_rows() -> (Vec<Row>, Arc<Schema>) {
    let schema = Arc::new(Schema::new(vec![
        Field::new("id", DataType::Int64, false),
        Field::new("name", DataType::Utf8, false),
        Field::new("score", DataType::Float64, false),
    ]));

    let cols: Vec<String> = vec!["id".into(), "name".into(), "score".into()];
    let rows = vec![
        Row::new(
            cols.clone(),
            vec![
                Value::I64(1),
                Value::Text("Alice".to_string()),
                Value::F64(95.5),
            ],
        ),
        Row::new(
            cols,
            vec![
                Value::I64(2),
                Value::Text("Bob".to_string()),
                Value::F64(87.0),
            ],
        ),
    ];

    (rows, schema)
}