(iterations: usize)
| 4820 | } |
| 4821 | |
| 4822 | fn 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 | |
| 4846 | fn run_direct_repeated_vector_queries(iterations: usize) -> Result<()> { |
| 4847 | let mut db = Pglite::builder() |
no test coverage detected