geode-client 0.3.2

//! Basic example of using the Geode Rust QUIC client.

use geode_client::{Client, Result, Value};

#[tokio::main]
async fn main() -> Result<()> {
    // Create QUIC client (skip TLS verification for development)
    let client = Client::new("127.0.0.1", 8443)
        .skip_verify(true)
        .page_size(1000);

    // Connect via QUIC
    let mut conn = client.connect().await?;
    println!("Connected to Geode via QUIC!");

    // Simple query
    let (page, _) = conn
        .query("RETURN 1 AS x, 'Hello QUIC' AS greeting")
        .await?;
    println!("\nSimple query results:");
    for row in &page.rows {
        if let (Ok(x), Ok(greeting)) = (
            row.get("x").unwrap().as_int(),
            row.get("greeting").unwrap().as_string(),
        ) {
            println!("  x={}, greeting={}", x, greeting);
        }
    }

    // Query with parameters
    let mut params = std::collections::HashMap::new();
    params.insert("name".to_string(), Value::string("Alice"));
    params.insert("age".to_string(), Value::int(30));

    let (page, _) = conn
        .query_with_params("RETURN $name AS name, $age AS age", &params)
        .await?;
    println!("\nParameterized query results:");
    for row in &page.rows {
        if let (Ok(name), Ok(age)) = (
            row.get("name").unwrap().as_string(),
            row.get("age").unwrap().as_int(),
        ) {
            println!("  name={}, age={}", name, age);
        }
    }

    // Transaction
    println!("\nStarting transaction...");
    conn.begin().await?;

    let mut create_params = std::collections::HashMap::new();
    create_params.insert("name".to_string(), Value::string("Bob"));
    create_params.insert("age".to_string(), Value::int(25));

    match conn
        .query_with_params("CREATE (p:Person {name: $name, age: $age})", &create_params)
        .await
    {
        Ok(_) => {
            conn.commit().await?;
            println!("Transaction committed successfully");
        }
        Err(e) => {
            conn.rollback().await?;
            println!("Transaction rolled back: {}", e);
        }
    }

    // Close connection
    conn.close()?;
    println!("\nConnection closed");

    Ok(())
}