arrow-sql-server 0.3.0

//! Inspect structured planning diagnostics without string matching.

use std::sync::Arc;

use arrow_schema::{DataType, Field, Schema};
use arrow_sql_server::{CompatibilityLevel, Error, MssqlProfile, MssqlVersion, PlanOptions};

fn main() -> arrow_sql_server::Result<()> {
    let schema = Schema::new(vec![
        Field::new("external_id", DataType::UInt64, false),
        Field::new(
            "tags",
            DataType::List(Arc::new(Field::new("item", DataType::Utf8, true))),
            true,
        ),
    ]);

    let profile = MssqlProfile::new(
        MssqlVersion::SqlServer2022,
        CompatibilityLevel::SQL_SERVER_2022,
    )?;

    match profile.plan_arrow_schema(&schema, PlanOptions::default()) {
        Err(Error::Planning { diagnostics }) => {
            for diagnostic in diagnostics.all() {
                let field = diagnostic
                    .field()
                    .map(|field| format!("{} at index {}", field.name(), field.index()))
                    .unwrap_or_else(|| "schema".to_owned());

                println!(
                    "{:?}\t{:?}\t{}\t{}",
                    diagnostic.severity(),
                    diagnostic.code(),
                    field,
                    diagnostic.message()
                );
            }
        }
        Err(error) => return Err(error),
        Ok(outcome) => {
            println!(
                "planned {} columns without errors",
                outcome.mappings().len()
            );
        }
    }

    Ok(())
}