summary refs log tree commit diff
path: root/synapse/storage/engines/sqlite.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-10-07 17:09:29 +0100
committerErik Johnston <erik@matrix.org>2020-10-07 17:09:29 +0100
commit4b43332131bd0cc96dc5e806cc69236a39ce72f5 (patch)
treec7e5991a890ccc623f5d3e0318873e91821f817a /synapse/storage/engines/sqlite.py
parentMerge remote-tracking branch 'origin/release-v1.21.0' into matrix-org-hotfixes (diff)
parentReduce serialization errors in MultiWriterIdGen (#8456) (diff)
downloadsynapse-4b43332131bd0cc96dc5e806cc69236a39ce72f5.tar.xz
Merge remote-tracking branch 'origin/release-v1.21.0' into matrix-org-hotfixes
Diffstat (limited to 'synapse/storage/engines/sqlite.py')
-rw-r--r--synapse/storage/engines/sqlite.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/synapse/storage/engines/sqlite.py b/synapse/storage/engines/sqlite.py

index 8a0f8c89d1..5db0f0b520 100644 --- a/synapse/storage/engines/sqlite.py +++ b/synapse/storage/engines/sqlite.py
@@ -17,6 +17,7 @@ import threading import typing from synapse.storage.engines import BaseDatabaseEngine +from synapse.storage.types import Connection if typing.TYPE_CHECKING: import sqlite3 # noqa: F401 @@ -86,6 +87,7 @@ class Sqlite3Engine(BaseDatabaseEngine["sqlite3.Connection"]): db_conn.create_function("rank", 1, _rank) db_conn.execute("PRAGMA foreign_keys = ON;") + db_conn.commit() def is_deadlock(self, error): return False @@ -105,6 +107,14 @@ class Sqlite3Engine(BaseDatabaseEngine["sqlite3.Connection"]): """ return "%i.%i.%i" % self.module.sqlite_version_info + def in_transaction(self, conn: Connection) -> bool: + return conn.in_transaction # type: ignore + + def attempt_to_set_autocommit(self, conn: Connection, autocommit: bool): + # Twisted doesn't let us set attributes on the connections, so we can't + # set the connection to autocommit mode. + pass + # Following functions taken from: https://github.com/coleifer/peewee