arrow-sql-server 0.3.0

High-performance Apache Arrow RecordBatch bulk writer for Microsoft SQL Server.
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

//! Apply an explicit planning policy for a policy-dependent Arrow type.

use arrow_schema::{DataType, Field, Schema};
use arrow_sql_server::{
    CompatibilityLevel, MssqlProfile, MssqlVersion, PlanOptions, TableName, UInt64Policy,
    create_table_sql_from_mappings,
};

fn main() -> arrow_sql_server::Result<()> {
    let schema = Schema::new(vec![
        Field::new("event_id", DataType::UInt64, false),
        Field::new("payload", DataType::Binary, true),
    ]);

    let plan_options = PlanOptions {
        uint64_policy: UInt64Policy::Decimal20_0,
        ..PlanOptions::default()
    };

    let profile = MssqlProfile::new(
        MssqlVersion::SqlServer2022,
        CompatibilityLevel::SQL_SERVER_2022,
    )?;
    let outcome = profile.plan_arrow_schema(&schema, plan_options)?;

    for mapping in outcome.mappings() {
        println!(
            "{} -> {}",
            mapping.arrow().name(),
            mapping.mssql().ty().to_sql()
        );
    }

    let table = TableName::new("dbo", "events")?;
    let ddl = create_table_sql_from_mappings(&table, outcome.mappings());
    println!("{ddl}");

    Ok(())
}