use exarrow_rs::adbc::Driver;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // Create driver and connect
    let driver = Driver::new();
    let database = driver.open("exasol://sys:exasol@localhost:8563/my_schema")?;
    let mut connection = database.connect().await?;

    // Execute a query (convenience method)
    let results = connection.query("SELECT * FROM customers WHERE age > 25").await?;

    // Process results as Arrow RecordBatches
    for batch in results {
        println!("Retrieved {} rows", batch.num_rows());
        println!("Schema: {:?}", batch.schema());
    }

    // Execute with parameters using Statement
    let mut stmt = connection.create_statement("SELECT * FROM orders WHERE customer_id = ?");
    stmt.bind(0, 12345)?;
    let results = connection.execute_statement(&stmt).await?;

    // Or use prepared statements for repeated execution
    let mut prepared = connection.prepare("SELECT * FROM orders WHERE status = ?").await?;
    prepared.bind(0, "pending")?;
    let results = connection.execute_prepared(&prepared).await?;
    connection.close_prepared(prepared).await?;

    // Transaction support
    connection.begin_transaction().await?;
    connection.execute_update("INSERT INTO logs VALUES (1, 'test')").await?;
    connection.commit().await?;

    connection.close().await?;
    Ok(())
}

use adbc_core::options::{AdbcVersion, OptionDatabase, OptionValue};
use adbc_core::{Connection, Database, Driver, Statement};
use adbc_driver_manager::ManagedDriver;

// Build the FFI library first: cargo build --release --features ffi

let mut driver = ManagedDriver::load_dynamic_from_filename(
    "target/release/libexarrow_rs.dylib", // .so on Linux
    Some(b"ExarrowDriverInit"),
    AdbcVersion::V110,
)?;

let opts = vec![(OptionDatabase::Uri, OptionValue::String(
    "exasol://sys:exasol@localhost:8563".to_string()
))];
let db = driver.new_database_with_opts(opts)?;
let mut conn = db.new_connection()?;

let mut stmt = conn.new_statement()?;
stmt.set_sql_query("SELECT 1")?;
let reader = stmt.execute()?;