From c463bab609c2194f1dd20c41cb515ff906aca231 Mon Sep 17 00:00:00 2001 From: Pekka Enberg Date: Thu, 23 Oct 2025 16:27:12 +0300 Subject: [PATCH] perf/throughput: Use connection per transaction in rusqlite benchmark Open a connection per transaction in the rusqlite benchmark so that we're comparing the same workload with Turso. --- perf/throughput/rusqlite/src/main.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/perf/throughput/rusqlite/src/main.rs b/perf/throughput/rusqlite/src/main.rs index 1e1d5c5f5..e709e8d87 100644 --- a/perf/throughput/rusqlite/src/main.rs +++ b/perf/throughput/rusqlite/src/main.rs @@ -115,18 +115,18 @@ fn worker_thread( start_barrier: Arc, compute_usec: u64, ) -> Result { - let conn = Connection::open(&db_path)?; - - conn.pragma_update(None, "synchronous", "FULL")?; - conn.pragma_update(None, "fullfsync", "true")?; - - conn.busy_timeout(std::time::Duration::from_secs(30))?; - start_barrier.wait(); let mut total_inserts = 0; for iteration in 0..iterations { + let conn = Connection::open(&db_path)?; + + conn.pragma_update(None, "synchronous", "FULL")?; + conn.pragma_update(None, "fullfsync", "true")?; + + conn.busy_timeout(std::time::Duration::from_secs(30))?; + let mut stmt = conn.prepare("INSERT INTO test_table (id, data) VALUES (?, ?)")?; conn.execute("BEGIN", [])?;