Function perf_prepared_updates

xtask/src/main.rs:2536–2674

(args: &[String])

}

fn perf_prepared_updates(args: &[String]) -> Result<()> {
    let mut rows = 25_000usize;
    let mut skip_native = false;
    let mut gate = false;
    let mut cursor = 0usize;
    while cursor < args.len() {
        match args[cursor].as_str() {
            "--skip-native" => {
                skip_native = true;
            }
            "--gate" => {
                gate = true;
            }
            "--rows" => {
                cursor += 1;
                let value = args
                    .get(cursor)
                    .ok_or_else(|| anyhow!("--rows requires a value"))?;
                rows = value
                    .parse()
                    .with_context(|| format!("parse --rows value {value:?}"))?;
            }
            other => bail!("unknown perf prepared-updates flag: {other}"),
        }
        cursor += 1;
    }
    ensure!(rows > 0, "--rows must be greater than zero");

    Pglite::preload()?;
    let numeric_updates = parsed_numeric_updates(rows)?;
    let text_updates = parsed_text_updates(rows)?;
    ensure!(
        numeric_updates.len() == rows && text_updates.len() == rows,
        "prepared update parser returned fewer rows than requested"
    );

    let mut runs = vec![
        pglite_prepared_update_run(
            "pglite_server_sqlx",
            "PgliteServer over TCP using SQLx parameterized queries and SQLx statement cache.",
            || run_pglite_sqlx_prepared_update_tests(&numeric_updates, &text_updates),
        )?,
        pglite_prepared_update_run(
            "pglite_server_tcp_tokio_postgres_prepared",
            "PgliteServer over TCP using tokio-postgres explicit prepared statements.",
            || {
                run_pglite_tokio_prepared_update_tests(
                    &numeric_updates,
                    &text_updates,
                    PglitePreparedEndpoint::Tcp,
                    PreparedExecution::Sequential,
                )
            },
        )?,
        pglite_prepared_update_run(
            "pglite_server_tcp_tokio_postgres_pipelined_prepared",
            "PgliteServer over TCP using tokio-postgres explicit prepared statements with all update futures pipelined inside one transaction.",
            || {