Function run_native_postgres_speed_sqlx_benchmark

xtask/src/main.rs:2448–2490

(
    conn: &mut sqlx::PgConnection,
    sql_source: SpeedSqlSource,
    open_micros: u128,
    connect_micros: u128,
)

}

async fn run_native_postgres_speed_sqlx_benchmark(
    conn: &mut sqlx::PgConnection,
    sql_source: SpeedSqlSource,
    open_micros: u128,
    connect_micros: u128,
) -> Result<BenchmarkRun> {
    conn.execute(
        "DROP TABLE IF EXISTS t1 CASCADE;\
         DROP TABLE IF EXISTS t2 CASCADE;\
         DROP TABLE IF EXISTS t2_1 CASCADE;\
         DROP TABLE IF EXISTS t3 CASCADE;\
         DROP TABLE IF EXISTS t3_1 CASCADE;",
    )
    .await
    .context("clear native Postgres speed benchmark tables over SQLx")?;

    let mut tests = Vec::new();
    for case in speed_cases(1.0, sql_source)? {
        let started = Instant::now();
        conn.execute(case.sql.as_str()).await.with_context(|| {
            format!(
                "execute native Postgres speed benchmark {} over SQLx",
                case.id
            )
        })?;
        tests.push(single_sample_result(
            case.id,
            case.label,
            "seconds",
            case.operation_count,
            started.elapsed(),
        ));
    }
    Ok(BenchmarkRun {
        suite: "speed",
        mode: "native_postgres_sqlx",
        description: "Native Postgres speed suite over TCP using one SQLx connection.",
        open_micros,
        connect_micros: Some(connect_micros),
        setup_micros: 0,
        tests,
    })
}

async fn run_pglite_nodefs_speed_sqlx_benchmark(
    conn: &mut sqlx::PgConnection,