Function exec

crates/cli/src/subcommands/sql.rs:181–249

(config: Config, args: &ArgMatches)

}

pub async fn exec(config: Config, args: &ArgMatches) -> Result<(), anyhow::Error> {
    eprintln!("{UNSTABLE_WARNING}\n");
    let interactive = args.get_one::<bool>("interactive").unwrap_or(&false);
    let no_config = args.get_flag("no_config");
    let raw_parts: Vec<String> = args
        .get_many::<String>("sql_parts")
        .map(|vals| vals.cloned().collect())
        .unwrap_or_default();
    let config_targets = load_config_db_targets(no_config)?;

    if *interactive {
        if raw_parts.len() > 1 {
            anyhow::bail!(
                "Too many positional arguments for interactive mode.\nUsage: spacetime sql [database] --interactive [--no-config]"
            );
        }
        let resolved = resolve_database_arg(
            raw_parts.first().map(|s| s.as_str()),
            config_targets.as_deref(),
            "spacetime sql [database] --interactive [--no-config]",
        )?;
        let con = parse_req(config, args, &resolved.database, resolved.server.as_deref()).await?;

        crate::repl::exec(con).await?;
    } else {
        let resolved = resolve_optional_database_parts(
            &raw_parts,
            config_targets.as_deref(),
            "query",
            "spacetime sql [database] <query> [--no-config]",
        )
        .or_else(|e| {
            // `sql` expects exactly 1 query arg, so if we have 2+ positional args the first
            // must be a database name. If it didn't match any config target, treat it as an
            // ad-hoc database outside the project (auto-fallthrough).
            if raw_parts.len() >= 2 {
                Ok(ResolvedDbArgs {
                    database: raw_parts[0].clone(),
                    server: None,
                    remaining_args: raw_parts[1..].to_vec(),
                })
            } else if raw_parts.len() == 1 && raw_parts[0].contains(' ') {
                // The single arg contains spaces, so it's almost certainly a SQL query,
                // not a database name. Give a clearer error than "missing <query>".
                let targets = config_targets.as_deref().unwrap_or_default();
                let known: Vec<&str> = targets.iter().map(|t| t.database.as_str()).collect();
                Err(anyhow::anyhow!(
                    "Multiple databases found in config: {}. Please specify which database to query:\n  \
                     spacetime sql <database> \"{}\"",
                    known.join(", "),
                    raw_parts[0]
                ))
            } else {
                Err(e)
            }
        })?;
        let query = resolved.remaining_args.join(" ");
        let confirmed = args.get_one::<bool>("confirmed").copied();