Function run_server_sqlx_single_connection_repeated_queries

xtask/src/main.rs:4886–4914

(iterations: usize)

}

fn run_server_sqlx_single_connection_repeated_queries(iterations: usize) -> Result<()> {
    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 mut conn = sqlx::PgConnection::connect(&uri)
            .await
            .context("connect SQLx to PGliteServer")?;
        run_sqlx_scalar_query(&mut conn, 41).await?;
        let started = Instant::now();
        for value in 0..iterations {
            run_sqlx_scalar_query(&mut conn, value as i32).await?;
        }
        record_total_and_average(
            "warm.server_sqlx_single_connection_repeated_queries.total",
            "warm.server_sqlx_single_connection_repeated_queries.avg",
            started.elapsed(),
            iterations,
        );
        conn.close().await.context("close SQLx connection")?;
        Ok::<_, anyhow::Error>(())
    })?;
    measure_phase("operation.shutdown", || server.shutdown())
}

fn run_server_sqlx_repeated_connections(iterations: usize) -> Result<()> {
    let server = measure_phase("server.start", PgliteServer::temporary_tcp)?;