nostr/gossip
1
0
Fork 0
mirror of https://github.com/mikedilger/gossip.git synced 2024-09-29 16:31:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'tonygiorgio/db-lock'

Browse Source
This commit is contained in:
Mike Dilger 2023-03-12 09:25:33 +13:00
commit 5dc82ad65b
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/db/mod.rs
View File

@ -30,6 +30,7 @@ use r2d2_sqlite::SqliteConnectionManager;
use rusqlite::OpenFlags;
use std::fs;
use std::sync::atomic::Ordering;
use std::time::Duration;
pub fn init_database() -> Result<Pool<SqliteConnectionManager>, Error> {
let mut data_dir =
@ -50,12 +51,21 @@ pub fn init_database() -> Result<Pool<SqliteConnectionManager>, Error> {
| OpenFlags::SQLITE_OPEN_NOFOLLOW,
);
let pool = Pool::new(sqlite_connection_manager)
let pool = Pool::builder()
.max_size(16)
.test_on_check_out(true)
.build(sqlite_connection_manager)
.map_err(|_| Error::from("Failed to create r2d2 SQLite connection pool"))?;
// Turn on foreign keys
// Turn on multiple options
let connection = pool.get()?;
connection.execute("PRAGMA foreign_keys = ON", ())?;
connection.execute_batch(
format!(
"PRAGMA foreign_keys = ON; PRAGMA journal_mode = WAL; PRAGMA synchronous = NORMAL; PRAGMA busy_timeout = {};",
Duration::from_secs(30).as_millis()
)
.as_str(),
)?;
Ok(pool)
}