Function handle_query

gql-cli/src/cli/gqlcli.rs:261–318

Handle the query command (one-off query execution)

(
    path: PathBuf,
    query: String,
    user: Option<String>,
    password: Option<String>,
    format: OutputFormat,
    explain: bool,
    ast: bool,
)

/// Handle the query command (one-off query execution)
pub fn handle_query(
    path: PathBuf,
    query: String,
    user: Option<String>,
    password: Option<String>,
    format: OutputFormat,
    explain: bool,
    ast: bool,
) -> Result<(), Box<dyn std::error::Error>> {
    // Check if database exists
    if !path.exists() {
        return Err(format!(
            "Database not found at {:?}. Run 'cargo run -- install' first.",
            path
        )
        .into());
    }

    // Load database
    let coordinator = load_database(&path)?;

    // Authenticate if credentials provided, otherwise use anonymous session
    let session_id = if let (Some(u), Some(p)) = (user, password) {
        authenticate(&coordinator, &u, &p)?
    } else {
        // Create anonymous session (limited permissions)
        coordinator.create_simple_session("anonymous")?
    };

    // Show AST if requested
    if ast {
        println!(
            "{}",
            "AST display feature not available in CLI-only mode".yellow()
        );
        println!("{}", "AST is an internal implementation detail".yellow());
        return Ok(());
    }

    // Show execution plan if requested
    if explain {
        println!("{}", "Query execution plan not yet implemented".yellow());
        return Ok(());
    }

    // Execute query
    match coordinator.process_query(&query, &session_id) {
        Ok(result) => {
            let output = ResultFormatter::format(&result, format);
            println!("{}", output);
            Ok(())
        }
        Err(e) => {
            eprintln!("{}", format!("Error: {}", e).red());
            Err(e.into())
        }
    }
}