diff --git a/src/api/database/mysql_connector.py b/src/api/database/mysql_connector.py index 9a5ed04a1a2dadbc6d9e6e6032b365a2207f38c4..76e54f9205a8592e1dcc1456ea81ba0ed9ee5355 100644 --- a/src/api/database/mysql_connector.py +++ b/src/api/database/mysql_connector.py @@ -59,7 +59,7 @@ class _MySqlDbConnection(PythonDbConnection[MySQLConnection, MySQLCursor]): self._closed = True self._py_connection.close() - def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> PreparedStatement or str: + def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> list[PreparedStatement or str]: if writable: return [ f"SET SESSION TRANSACTION ISOLATION LEVEL {isolation_level.value}", diff --git a/src/api/database/postgres_connector.py b/src/api/database/postgres_connector.py index 7975e82baf8378c9e15a3c86a0dec225b1475674..8962b4aed4f5ed616afcce13ffd43f2d21424b85 100644 --- a/src/api/database/postgres_connector.py +++ b/src/api/database/postgres_connector.py @@ -90,7 +90,7 @@ source_function: {diagnostic.source_function} self._closed = True self._py_connection.close() - def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> PreparedStatement or str: + def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> list[PreparedStatement or str]: if writable: return [f"START TRANSACTION ISOLATION LEVEL {isolation_level.value}, READ WRITE"] else: diff --git a/src/api/database/sqlite_connector.py b/src/api/database/sqlite_connector.py index 3f5282e816b38d23c102d8989338cdcfef5160e6..8d47d2554eaa96c81dcc6d56c09d184db5299908 100644 --- a/src/api/database/sqlite_connector.py +++ b/src/api/database/sqlite_connector.py @@ -62,7 +62,7 @@ class SqLiteDbConnection(PythonDbConnection[Connection, Cursor]): self._closed = True self._py_connection.close() - def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> PreparedStatement or str: + def get_transaction_begin_statements(self, writable: bool, isolation_level: TransactionIsolationLevel) -> list[PreparedStatement or str]: return ["BEGIN DEFERRED TRANSACTION"] # Transactions in SQLite are serializable by default def get_transaction_end_statement(self, commit: bool) -> PreparedStatement or str: