wimby/tubesync
1
0 Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

Cleanup for _start_transaction_under_autocommit

Browse Source
This commit is contained in:
tcely authored and GitHub committed 2024-12-12 09:03:08 -05:00
1 parent de52e55e34
commit 21e9cbef4b
1 file changed
+6 -7
Download Patch File Download Diff File Expand all files Collapse all files
tubesync/tubesync/sqlite3/base.py
+6 -7
View File
@@ -5,15 +5,14 @@ class DatabaseWrapper(base.DatabaseWrapper):
def _start_transaction_under_autocommit(self): def _start_transaction_under_autocommit(self):
conn_params = self.get_connection_params() conn_params = self.get_connection_params()
if "transaction_mode" not in conn_params:
self.cursor().execute("BEGIN TRANSACTION")
else:
tm = str(conn_params["transaction_mode"]).upper().strip()
transaction_modes = frozenset(["DEFERRED", "EXCLUSIVE", "IMMEDIATE"]) transaction_modes = frozenset(["DEFERRED", "EXCLUSIVE", "IMMEDIATE"])
sql_statement = "BEGIN TRANSACTION"
if "transaction_mode" in conn_params:
tm = str(conn_params["transaction_mode"]).upper().strip()
if tm in transaction_modes: if tm in transaction_modes:
self.cursor().execute(f"BEGIN {tm} TRANSACTION") sql_statement = f"BEGIN {tm} TRANSACTION"
else: self.cursor().execute(sql_statement)
self.cursor().execute("BEGIN TRANSACTION")
def init_connection_state(self): def init_connection_state(self):