From ecbadc6087e4290cb6d6d249c6dafd52bad4750a Mon Sep 17 00:00:00 2001 From: pablorevilla-meshtastic Date: Thu, 15 Jan 2026 14:10:49 -0800 Subject: [PATCH] configure "Wal" for sqlite --- meshview/mqtt_database.py | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/meshview/mqtt_database.py b/meshview/mqtt_database.py index e74b9b0..957c4c6 100644 --- a/meshview/mqtt_database.py +++ b/meshview/mqtt_database.py @@ -1,16 +1,32 @@ from sqlalchemy.engine.url import make_url from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine +from sqlalchemy import event from meshview import models def init_database(database_connection_string): global engine, async_session + url = make_url(database_connection_string) kwargs = {"echo": False} + if url.drivername.startswith("sqlite"): - kwargs["connect_args"] = {"timeout": 900} + kwargs["connect_args"] = {"timeout": 900} # seconds + engine = create_async_engine(url, **kwargs) + + # Enforce SQLite pragmas on every new DB connection + if url.drivername.startswith("sqlite"): + + @event.listens_for(engine.sync_engine, "connect") + def _set_sqlite_pragmas(dbapi_conn, _): + cursor = dbapi_conn.cursor() + cursor.execute("PRAGMA journal_mode=WAL;") + cursor.execute("PRAGMA busy_timeout=900000;") # ms + cursor.execute("PRAGMA synchronous=NORMAL;") + cursor.close() + async_session = async_sessionmaker(engine, expire_on_commit=False)