diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-12-20 10:46:46 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-12-20 10:46:46 +0000 |
commit | 4caab0e95e6972e9c0533bc1897073bda5a464bf (patch) | |
tree | bb7b9669b6b9336301969511ab5ee17d28bb84dc /synapse | |
parent | Fix exceptions when attempting to backfill (#6576) (diff) | |
download | synapse-4caab0e95e6972e9c0533bc1897073bda5a464bf.tar.xz |
Backport fixes to sqlite upgrade from develop (#6578)
Only run prepare_database on connection for in-memory databases. Fixes #6569.
Diffstat (limited to 'synapse')
-rw-r--r-- | synapse/storage/engines/sqlite.py | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/synapse/storage/engines/sqlite.py b/synapse/storage/engines/sqlite.py index ddad17dc5a..cbc74cd302 100644 --- a/synapse/storage/engines/sqlite.py +++ b/synapse/storage/engines/sqlite.py @@ -25,6 +25,9 @@ class Sqlite3Engine(object): def __init__(self, database_module, database_config): self.module = database_module + database = database_config.get("args", {}).get("database") + self._is_in_memory = database in (None, ":memory:",) + # The current max state_group, or None if we haven't looked # in the DB yet. self._current_state_group_id = None @@ -59,7 +62,12 @@ class Sqlite3Engine(object): return sql def on_new_connection(self, db_conn): - prepare_database(db_conn, self, config=None) + if self._is_in_memory: + # In memory databases need to be rebuilt each time. Ideally we'd + # reuse the same connection as we do when starting up, but that + # would involve using adbapi before we have started the reactor. + prepare_database(db_conn, self, config=None) + db_conn.create_function("rank", 1, _rank) def is_deadlock(self, error): |