Function run_server_sqlx_select_one

xtask/src/main.rs:4769–4804

()

}

fn run_server_sqlx_select_one() -> Result<()> {
    let visible_started = Instant::now();
    let server = measure_phase("server.start", PgliteServer::temporary_tcp)?;
    let uri = server.database_url();
    let runtime = measure_phase("client.tokio_runtime_create", || {
        tokio::runtime::Builder::new_current_thread()
            .enable_all()
            .build()
            .context("create perf tokio runtime")
    })?;
    runtime.block_on(async move {
        let started = Instant::now();
        let mut conn = sqlx::PgConnection::connect(&uri)
            .await
            .context("connect SQLx to PGliteServer")?;
        record_phase_timing("client.sqlx_connect", started.elapsed());
        let started = Instant::now();
        let row = sqlx::query("SELECT $1::int4 + 1 AS answer")
            .bind(41_i32)
            .fetch_one(&mut conn)
            .await
            .context("run first SQLx query")?;
        record_phase_timing("client.sqlx_first_query", started.elapsed());
        let answer: i32 = row.try_get("answer").context("read SQLx answer")?;
        if answer != 42 {
            bail!("SQLx server query returned {answer}, expected 42");
        }
        conn.close().await.context("close SQLx connection")?;
        Ok::<_, anyhow::Error>(())
    })?;
    record_phase_timing(
        "visible.server_start_to_first_sqlx_query",
        visible_started.elapsed(),
    );
    measure_phase("operation.shutdown", || server.shutdown())
}

fn run_direct_repeated_selects(iterations: usize) -> Result<()> {
    let mut db = Pglite::builder().temporary().open()?;