Function run_native_prepared_update_case

xtask/src/main.rs:3109–3155

(
    runtime: &tokio::runtime::Runtime,
    postgres_bin: &Path,
    initdb_bin: &Path,
    id: &'static str,
    label: &'static str,
    sql: &'static str,
    numeric_updates: &[(i32, i32)],
    t

#[allow(clippy::too_many_arguments)]
fn run_native_prepared_update_case(
    runtime: &tokio::runtime::Runtime,
    postgres_bin: &Path,
    initdb_bin: &Path,
    id: &'static str,
    label: &'static str,
    sql: &'static str,
    numeric_updates: &[(i32, i32)],
    text_updates: Option<&[(i32, String)]>,
    execution: PreparedExecution,
) -> Result<PreparedUpdateTest> {
    let open_started = Instant::now();
    let native = NativePostgres::start(postgres_bin, initdb_bin)?;
    let open_micros = open_started.elapsed().as_micros();

    runtime.block_on(async {
        let mut config = tokio_postgres::Config::new();
        configure_native_postgres_client(&mut config, &native);
        let connect_started = Instant::now();
        let (client, connection) = config
            .connect(tokio_postgres::NoTls)
            .await
            .context("connect native prepared-update client")?;
        let connection_task = tokio::spawn(async move {
            if let Err(err) = connection.await {
                eprintln!("native prepared-update connection error: {err}");
            }
        });
        let connect_micros = connect_started.elapsed().as_micros();

        let result = run_tokio_prepared_update_case_on_client(
            &client,
            id,
            label,
            sql,
            numeric_updates,
            text_updates,
            execution,
            open_micros,
            connect_micros,
        )
        .await;
        drop(client);
        let _ = connection_task.await;
        result
    })
}

#[allow(clippy::too_many_arguments)]
async fn run_tokio_prepared_update_case_on_client(