Function measure_async_transaction_sqlx

xtask/src/main.rs:2860–2895

(
    conn: &mut sqlx::PgConnection,
    sql: &'static str,
    values: PreparedUpdateValues<'_>,
)

}

async fn measure_async_transaction_sqlx(
    conn: &mut sqlx::PgConnection,
    sql: &'static str,
    values: PreparedUpdateValues<'_>,
) -> Result<Duration> {
    let started = Instant::now();
    conn.execute("BEGIN")
        .await
        .context("begin SQLx transaction")?;
    match values {
        PreparedUpdateValues::Numeric(values) => {
            for (lookup, value) in values {
                sqlx::query(sql)
                    .bind(*value)
                    .bind(*lookup)
                    .execute(&mut *conn)
                    .await
                    .context("execute SQLx prepared numeric update")?;
            }
        }
        PreparedUpdateValues::Text(values) => {
            for (lookup, value) in values {
                sqlx::query(sql)
                    .bind(value.as_str())
                    .bind(*lookup)
                    .execute(&mut *conn)
                    .await
                    .context("execute SQLx prepared text update")?;
            }
        }
    }
    conn.execute("COMMIT")
        .await
        .context("commit SQLx transaction")?;
    Ok(started.elapsed())
}

fn run_pglite_tokio_prepared_update_tests(
    numeric_updates: &[(i32, i32)],