Function run_native_postgres_speed_benchmark

xtask/src/main.rs:2188–2229

(
    client: &tokio_postgres::Client,
    sql_source: SpeedSqlSource,
    open_micros: u128,
    connect_micros: u128,
)

}

async fn run_native_postgres_speed_benchmark(
    client: &tokio_postgres::Client,
    sql_source: SpeedSqlSource,
    open_micros: u128,
    connect_micros: u128,
) -> Result<BenchmarkRun> {
    client
        .simple_query(
            "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")?;

    let mut tests = Vec::new();
    for case in speed_cases(1.0, sql_source)? {
        let started = Instant::now();
        client
            .simple_query(&case.sql)
            .await
            .with_context(|| format!("execute native Postgres speed benchmark {}", case.id))?;
        tests.push(single_sample_result(
            case.id,
            case.label,
            "seconds",
            case.operation_count,
            started.elapsed(),
        ));
    }
    Ok(BenchmarkRun {
        suite: "speed",
        mode: "native_postgres",
        description: "Native Postgres speed suite over Unix socket using tokio-postgres simple_query.",
        open_micros,
        connect_micros: Some(connect_micros),
        setup_micros: 0,
        tests,
    })
}

fn native_postgres_sqlx_options(native: &NativePostgres) -> PgConnectOptions {
    PgConnectOptions::new_without_pgpass()