MCPcopy Create free account
hub / github.com/f0rr0/oliphaunt / run_direct_transaction_batch

Function run_direct_transaction_batch

xtask/src/main.rs:4822–4844  ·  view source on GitHub ↗
(iterations: usize)

Source from the content-addressed store, hash-verified

4820}
4821
4822fn run_direct_transaction_batch(iterations: usize) -> Result<()> {
4823 let mut db = Pglite::builder().temporary().open()?;
4824 run_direct_scalar_query(&mut db, 41)?;
4825 let started = Instant::now();
4826 db.transaction(|tx| {
4827 for value in 0..iterations {
4828 let result = tx.query(
4829 "SELECT $1::int4 + 1 AS answer",
4830 &[serde_json::json!(value as i32)],
4831 None,
4832 )?;
4833 ensure_json_int(&result.rows[0]["answer"], value as i64 + 1)?;
4834 }
4835 Ok(())
4836 })?;
4837 record_total_and_average(
4838 "warm.direct_transaction_batch.total",
4839 "warm.direct_transaction_batch.avg",
4840 started.elapsed(),
4841 iterations,
4842 );
4843 measure_phase("operation.close", || db.close())
4844}
4845
4846fn run_direct_repeated_vector_queries(iterations: usize) -> Result<()> {
4847 let mut db = Pglite::builder()

Callers 1

perf_warmFunction · 0.85

Calls 10

run_direct_scalar_queryFunction · 0.85
ensure_json_intFunction · 0.85
record_total_and_averageFunction · 0.85
measure_phaseFunction · 0.85
transactionMethod · 0.80
elapsedMethod · 0.80
openMethod · 0.45
temporaryMethod · 0.45
queryMethod · 0.45
closeMethod · 0.45

Tested by

no test coverage detected