Function parsed_text_updates

xtask/src/main.rs:3291–3316

(limit: usize)

}

fn parsed_text_updates(limit: usize) -> Result<Vec<(i32, String)>> {
    let sql = read_pglite_benchmark_sql("10")?;
    let mut updates = Vec::with_capacity(limit);
    for line in sql.lines() {
        let line = line.trim();
        let Some(rest) = line.strip_prefix("UPDATE t2 SET c='") else {
            continue;
        };
        let rest = rest
            .strip_suffix(';')
            .ok_or_else(|| anyhow!("text update line is missing semicolon: {line}"))?;
        let (value, lookup) = rest
            .split_once("' WHERE a=")
            .ok_or_else(|| anyhow!("text update line has unexpected shape: {line}"))?;
        updates.push((lookup.parse()?, value.to_owned()));
        if updates.len() == limit {
            break;
        }
    }
    ensure!(
        updates.len() == limit,
        "benchmark10 only contained {} update rows; requested {limit}",
        updates.len()
    );
    Ok(updates)
}

struct NativePostgres {
    child: Child,