From 08bb4665b6b7c95db978b4b8724d341f621298a1 Mon Sep 17 00:00:00 2001
From: Pekka Enberg <penberg@iki.fi>
Date: Mon, 16 Jun 2025 14:24:02 +0300
Subject: [PATCH] stress: Run integrity check for every iteration

---
 stress/main.rs | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/stress/main.rs b/stress/main.rs
index 414447f38..f84518108 100644
--- a/stress/main.rs
+++ b/stress/main.rs
@@ -459,6 +459,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
                         _ => panic!("Error executing query: {}", e),
                     }
                 }
+                let mut res = conn.query("PRAGMA integrity_check", ()).await.unwrap();
+                if let Some(row) = res.next().await? {
+                    let value = row.get_value(0).unwrap();
+                    if value != "ok".into() {
+                        panic!("integrity check failed: {:?}", value);
+                    }
+                } else {
+                    panic!("integrity check failed: no rows");
+                }
             }
             Ok::<_, Box<dyn std::error::Error + Send + Sync>>(())
         });