From e681e32198ac3adcae71d1064705f816f50795a8 Mon Sep 17 00:00:00 2001 From: Pere Diaz Bou Date: Thu, 19 Jun 2025 10:56:01 +0200 Subject: [PATCH] fix test_limbo_open_read_only --- tests/integration/common.rs | 10 ++++++---- tests/integration/query_processing/test_write_path.rs | 5 ----- 2 files changed, 6 insertions(+), 9 deletions(-) diff --git a/tests/integration/common.rs b/tests/integration/common.rs index 25356deed..bee439e69 100644 --- a/tests/integration/common.rs +++ b/tests/integration/common.rs @@ -269,11 +269,9 @@ mod tests { #[test] fn test_limbo_open_read_only() -> anyhow::Result<()> { let path = TempDir::new().unwrap().keep().join("temp_read_only"); - let db = TempDatabase::new_with_existent_with_flags( - &path, - limbo_core::OpenFlags::default() | limbo_core::OpenFlags::ReadOnly, - ); { + let db = + TempDatabase::new_with_existent_with_flags(&path, limbo_core::OpenFlags::default()); let conn = db.connect_limbo(); let ret = limbo_exec_rows(&db, &conn, "CREATE table t(a)"); assert!(ret.is_empty(), "{:?}", ret); @@ -282,6 +280,10 @@ mod tests { } { + let db = TempDatabase::new_with_existent_with_flags( + &path, + limbo_core::OpenFlags::default() | limbo_core::OpenFlags::ReadOnly, + ); let conn = db.connect_limbo(); let ret = limbo_exec_rows(&db, &conn, "SELECT * from t"); assert_eq!(ret, vec![vec![Value::Integer(1)]]); diff --git a/tests/integration/query_processing/test_write_path.rs b/tests/integration/query_processing/test_write_path.rs index da89b2077..f80d61886 100644 --- a/tests/integration/query_processing/test_write_path.rs +++ b/tests/integration/query_processing/test_write_path.rs @@ -561,11 +561,6 @@ fn test_write_concurrent_connections() -> anyhow::Result<()> { } let conn = tmp_db.connect_limbo(); - // run_query_on_row(&tmp_db, &conn, "SELECT * from t", |row: &Row| { - // for value in row.get_values() { - // tracing::info!("got value {:?}", value); - // } - // })?; run_query_on_row(&tmp_db, &conn, "SELECT count(1) from t", |row: &Row| { let count = row.get::(0).unwrap(); assert_eq!(