Function query_col0

nodedb-cluster-tests/tests/bitemporal_array_cluster.rs:31–54

Run a SQL query and return the first column of every result row.

(client: &tokio_postgres::Client, sql: &str)

/// Run a SQL query and return the first column of every result row.
async fn query_col0(client: &tokio_postgres::Client, sql: &str) -> Vec<String> {
    let msgs = client.simple_query(sql).await.unwrap_or_else(|e| {
        let detail = if let Some(db) = e.as_db_error() {
            format!(
                "SQLSTATE={} severity={} msg={}",
                db.code().code(),
                db.severity(),
                db.message()
            )
        } else {
            format!("{e:?}")
        };
        panic!("query failed: {detail}\n  sql: {sql}")
    });
    msgs.into_iter()
        .filter_map(|m| {
            if let tokio_postgres::SimpleQueryMessage::Row(r) = m {
                r.get(0).map(|s| s.to_string())
            } else {
                None
            }
        })
        .collect()
}

/// Parse the `attrs[0]` int64 from a single ARRAY_SLICE result row.
///