fix(concurrency): can now use tally across multiple processes

uhryniuk · Nov 14, 2024 · 7831bce · 7831bce
1 parent 4066a4b
commit 7831bce
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/database.rs b/src/database.rs
@@ -1,5 +1,6 @@
 use anyhow::Result;
 use sqlite::{ConnectionThreadSafe, Value};
+use std::time::Duration;
 
 #[derive(Debug)]
 pub struct Counter {
@@ -16,8 +17,12 @@ pub struct Database {
 
 impl Database {
     pub fn new(name: &str) -> Result<Database> {
+        let mut connection = sqlite::Connection::open_thread_safe(name).expect("ORPS");
+        connection.set_busy_timeout(5_000_000)?;
+        connection.execute("PRAGMA journal_mode = WAL;")?;
         let db = Database {
-            conn: sqlite::Connection::open_thread_safe(name)?,
+            conn: connection,
+            // conn: sqlite::Connection::open_thread_safe(name).expect("ORGIE"),
         };
         db.init_database()?;
         db.get_default_counter()?;