diff options
Diffstat (limited to 'django/db/backends/mysql/base.py')
| -rw-r--r-- | django/db/backends/mysql/base.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/django/db/backends/mysql/base.py b/django/db/backends/mysql/base.py index f4bad47e06..7690629209 100644 --- a/django/db/backends/mysql/base.py +++ b/django/db/backends/mysql/base.py @@ -229,7 +229,7 @@ class DatabaseWrapper(BaseDatabaseWrapper): ', '.join("'%s'" % s for s in sorted(self.isolation_levels)) )) # The variable assignment form of setting transaction isolation - # levels will be used, e.g. "set tx_isolation='repeatable-read'". + # levels will be used, e.g. "set transaction_isolation='repeatable-read'". isolation_level = isolation_level.replace(' ', '-') self.isolation_level = isolation_level kwargs.update(options) @@ -238,6 +238,10 @@ class DatabaseWrapper(BaseDatabaseWrapper): def get_new_connection(self, conn_params): return Database.connect(**conn_params) + @cached_property + def transaction_isolation_variable(self): + return 'tx_isolation' if self.mysql_version < (5, 7, 20) else 'transaction_isolation' + def init_connection_state(self): assignments = [] if self.features.is_sql_auto_is_null_enabled: @@ -248,7 +252,7 @@ class DatabaseWrapper(BaseDatabaseWrapper): assignments.append('SQL_AUTO_IS_NULL = 0') if self.isolation_level: - assignments.append("TX_ISOLATION = '%s'" % self.isolation_level) + assignments.append("%s = '%s'" % (self.transaction_isolation_variable, self.isolation_level)) if assignments: with self.cursor() as cursor: |