Function run_server_sqlx_repeated_connections

xtask/src/main.rs:4916–4943

(iterations: usize)

}

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

fn run_server_sqlx_vector_single_connection_repeated_queries(iterations: usize) -> Result<()> {
    let server = measure_phase("server.start", || {