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> { _ => 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>(()) });