Function run_sql

crates/cli/src/subcommands/sql.rs:146–165

(builder: RequestBuilder, sql: &str, with_stats: bool)

}

pub(crate) async fn run_sql(builder: RequestBuilder, sql: &str, with_stats: bool) -> Result<(), anyhow::Error> {
    let now = Instant::now();

    let json = builder
        .body(sql.to_owned())
        .send()
        .await?
        .ensure_content_type("application/json")
        .await?
        .text()
        .await?;

    let stmt_result_json: Vec<SqlStmtResult> = serde_json::from_str(&json).context("malformed sql response")?;

    let mut out = String::new();
    print_stmt_result(&stmt_result_json, with_stats.then_some(now.elapsed()), &mut out)?;
    println!("{out}");

    Ok(())
}

fn stmt_result_to_table(client: PsqlClient, stmt_result: &SqlStmtResult) -> anyhow::Result<(StmtStats, tabled::Table)> {
    let stats = StmtStats::from(stmt_result);