Function parsed_numeric_updates

xtask/src/main.rs:3264–3289

(limit: usize)

}

fn parsed_numeric_updates(limit: usize) -> Result<Vec<(i32, i32)>> {
    let sql = read_pglite_benchmark_sql("9")?;
    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 b=") else {
            continue;
        };
        let rest = rest
            .strip_suffix(';')
            .ok_or_else(|| anyhow!("numeric update line is missing semicolon: {line}"))?;
        let (value, lookup) = rest
            .split_once(" WHERE a=")
            .ok_or_else(|| anyhow!("numeric update line has unexpected shape: {line}"))?;
        updates.push((lookup.parse()?, value.parse()?));
        if updates.len() == limit {
            break;
        }
    }
    ensure!(
        updates.len() == limit,
        "benchmark9 only contained {} update rows; requested {limit}",
        updates.len()
    );
    Ok(updates)
}

fn parsed_text_updates(limit: usize) -> Result<Vec<(i32, String)>> {
    let sql = read_pglite_benchmark_sql("10")?;