aprender-db 0.60.0

//! SQL Query Interface Example
//!
//! Demonstrates the complete SQL query execution pipeline with:
//! - SELECT with column projection
//! - WHERE clause filtering
//! - Aggregations (SUM, AVG, COUNT, MIN, MAX)
//! - ORDER BY + LIMIT (Top-K optimization)
//!
//! Toyota Way: Jidoka (Built-in Quality) - Backend equivalence testing

use arrow::array::{Float64Array, Int32Array, RecordBatch, StringArray};
use arrow::datatypes::{DataType, Field, Schema};
use std::sync::Arc;
use trueno_db::query::{QueryEngine, QueryExecutor};
use trueno_db::storage::StorageEngine;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("=== Trueno-DB SQL Query Interface Example ===\n");

    // Create sample e-commerce dataset
    println!("📊 Creating sample e-commerce dataset (10,000 orders)...");
    let schema = Arc::new(Schema::new(vec![
        Field::new("order_id", DataType::Int32, false),
        Field::new("customer_id", DataType::Int32, false),
        Field::new("amount", DataType::Float64, false),
        Field::new("quantity", DataType::Int32, false),
        Field::new("category", DataType::Utf8, false),
    ]));

    let num_orders = 10_000;
    let order_ids: Vec<i32> = (1..=num_orders).collect();
    let customer_ids: Vec<i32> = (1..=num_orders).map(|i| (i % 1000) + 1).collect();
    let amounts: Vec<f64> =
        (1..=num_orders).map(|i| (f64::from(i) * 12.5) % 500.0 + 10.0).collect();
    let quantities: Vec<i32> = (1..=num_orders).map(|i| (i % 10) + 1).collect();
    let categories: Vec<&str> = (1..=num_orders)
        .map(|i| match i % 4 {
            0 => "Electronics",
            1 => "Clothing",
            2 => "Food",
            _ => "Home",
        })
        .collect();

    let batch = RecordBatch::try_new(
        schema,
        vec![
            Arc::new(Int32Array::from(order_ids)),
            Arc::new(Int32Array::from(customer_ids)),
            Arc::new(Float64Array::from(amounts)),
            Arc::new(Int32Array::from(quantities)),
            Arc::new(StringArray::from(categories)),
        ],
    )?;

    let mut storage = StorageEngine::new(vec![]);
    storage.append_batch(batch)?;

    println!("  ✓ Created {num_orders} orders");
    println!("  ✓ Columns: order_id, customer_id, amount, quantity, category\n");

    // Initialize query engine and executor
    let engine = QueryEngine::new();
    let executor = QueryExecutor::new();

    // Example 1: Simple SELECT with projection
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 1: Simple SELECT with column projection");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT order_id, amount FROM orders LIMIT 5";
    println!("SQL: {sql}");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    println!("\nResults ({} rows):", result.num_rows());
    println!("  order_id | amount");
    println!("  ---------|--------");
    for i in 0..result.num_rows() {
        let order_id = result.column(0).as_any().downcast_ref::<Int32Array>().unwrap().value(i);
        let amount = result.column(1).as_any().downcast_ref::<Float64Array>().unwrap().value(i);
        println!("  {order_id:8} | ${amount:6.2}");
    }

    // Example 2: WHERE clause filtering
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 2: WHERE clause filtering");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT order_id, amount FROM orders WHERE amount > 400.0 LIMIT 5";
    println!("SQL: {sql}");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    println!("\nResults ({} rows):", result.num_rows());
    println!("  order_id | amount");
    println!("  ---------|--------");
    for i in 0..result.num_rows() {
        let order_id = result.column(0).as_any().downcast_ref::<Int32Array>().unwrap().value(i);
        let amount = result.column(1).as_any().downcast_ref::<Float64Array>().unwrap().value(i);
        println!("  {order_id:8} | ${amount:6.2}");
    }

    // Example 3: Aggregations (SUM, AVG, COUNT)
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 3: Aggregations (SUM, AVG, COUNT, MIN, MAX)");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT COUNT(*), SUM(amount), AVG(amount), MIN(amount), MAX(amount) FROM orders";
    println!("SQL: {sql}");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    println!("\nResults:");
    let count =
        result.column(0).as_any().downcast_ref::<arrow::array::Int64Array>().unwrap().value(0);
    let sum = result.column(1).as_any().downcast_ref::<Float64Array>().unwrap().value(0);
    let avg = result.column(2).as_any().downcast_ref::<Float64Array>().unwrap().value(0);
    let min = result.column(3).as_any().downcast_ref::<Float64Array>().unwrap().value(0);
    let max = result.column(4).as_any().downcast_ref::<Float64Array>().unwrap().value(0);

    println!("  Total Orders:    {count:>10}");
    println!("  Total Revenue:   ${sum:>10.2}");
    println!("  Average Order:   ${avg:>10.2}");
    println!("  Minimum Order:   ${min:>10.2}");
    println!("  Maximum Order:   ${max:>10.2}");

    // Example 4: ORDER BY + LIMIT (Top-K optimization)
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 4: ORDER BY + LIMIT (Top-K optimization)");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT order_id, amount FROM orders ORDER BY amount DESC LIMIT 10";
    println!("SQL: {sql}");
    println!("Note: Uses O(N log K) Top-K algorithm instead of O(N log N) full sort\n");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    println!("Top 10 Highest Value Orders:");
    println!("  Rank | order_id | amount");
    println!("  -----|----------|--------");
    for i in 0..result.num_rows() {
        let order_id = result.column(0).as_any().downcast_ref::<Int32Array>().unwrap().value(i);
        let amount = result.column(1).as_any().downcast_ref::<Float64Array>().unwrap().value(i);
        println!("  {:4} | {:8} | ${:6.2}", i + 1, order_id, amount);
    }

    // Example 5: Filter + Aggregation
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 5: Combined WHERE filter + Aggregation");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT COUNT(*), AVG(amount) FROM orders WHERE amount > 300.0";
    println!("SQL: {sql}");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    let count =
        result.column(0).as_any().downcast_ref::<arrow::array::Int64Array>().unwrap().value(0);
    let avg = result.column(1).as_any().downcast_ref::<Float64Array>().unwrap().value(0);

    println!("\nResults:");
    println!("  High-value orders (>$300): {count}");
    println!("  Average amount:            ${avg:.2}");

    // Example 6: Multiple filters
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Example 6: Filter on quantity");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    let sql = "SELECT order_id, quantity, amount FROM orders WHERE quantity >= 8 LIMIT 5";
    println!("SQL: {sql}");

    let plan = engine.parse(sql)?;
    let result = executor.execute(&plan, &storage)?;

    println!("\nBulk Orders (quantity ≥ 8):");
    println!("  order_id | quantity | amount");
    println!("  ---------|----------|--------");
    for i in 0..result.num_rows() {
        let order_id = result.column(0).as_any().downcast_ref::<Int32Array>().unwrap().value(i);
        let quantity = result.column(1).as_any().downcast_ref::<Int32Array>().unwrap().value(i);
        let amount = result.column(2).as_any().downcast_ref::<Float64Array>().unwrap().value(i);
        println!("  {order_id:8} | {quantity:8} | ${amount:6.2}");
    }

    // Performance summary
    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Performance Characteristics");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    println!("✓ Aggregations: 2.78x faster than scalar (SIMD acceleration)");
    println!("✓ Top-K: 5-28x faster than heap-based sorting");
    println!("✓ Zero-copy operations via Apache Arrow");
    println!("✓ Cost-based backend selection (GPU when compute > 5x transfer)");

    println!("\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    println!("Toyota Way: Kaizen (Continuous Improvement)");
    println!("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n");

    println!("All queries executed successfully!");
    println!("Coverage: 92.64% with comprehensive test suite");
    println!("Backend equivalence: GPU == SIMD == Scalar results\n");

    Ok(())
}