mirrors/django
1
0
Fork 0
mirror of https://github.com/django/django.git synced 2025-10-31 09:41:08 +00:00
Code Issues 32 Releases Wiki Activity

[2.0.x] Fixed #28804 -- Fixed "Unknown system variable 'transaction_isolation'" on MariaDB.

Browse Source 
Regression in 967450a3bf.

Backport of e3c852cbd6 from master
This commit is contained in:
Tim Graham
2017-11-18 07:43:58 -05:00
parent 385e06d8c0
commit 205290f510
2 changed files with 6 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
django/db/backends/mysql/base.py
View File

@@ -228,9 +228,6 @@ class DatabaseWrapper(BaseDatabaseWrapper):
isolation_level, isolation_level,
', '.join("'%s'" % s for s in sorted(self.isolation_levels)) ', '.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 transaction_isolation='repeatable-read'".
isolation_level = isolation_level.replace(' ', '-')
self.isolation_level = isolation_level self.isolation_level = isolation_level
kwargs.update(options) kwargs.update(options)
return kwargs return kwargs
@@ -238,10 +235,6 @@ class DatabaseWrapper(BaseDatabaseWrapper):
def get_new_connection(self, conn_params): def get_new_connection(self, conn_params):
return Database.connect(**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): def init_connection_state(self):
assignments = [] assignments = []
if self.features.is_sql_auto_is_null_enabled: if self.features.is_sql_auto_is_null_enabled:
@@ -249,14 +242,14 @@ class DatabaseWrapper(BaseDatabaseWrapper):
# a recently inserted row will return when the field is tested # a recently inserted row will return when the field is tested
# for NULL. Disabling this brings this aspect of MySQL in line # for NULL. Disabling this brings this aspect of MySQL in line
# with SQL standards. # with SQL standards.
assignments.append('SQL_AUTO_IS_NULL = 0') assignments.append('SET SQL_AUTO_IS_NULL = 0')
if self.isolation_level: if self.isolation_level:
assignments.append("%s = '%s'" % (self.transaction_isolation_variable, self.isolation_level)) assignments.append('SET SESSION TRANSACTION ISOLATION LEVEL %s' % self.isolation_level.upper())
if assignments: if assignments:
with self.cursor() as cursor: with self.cursor() as cursor:
cursor.execute('SET ' + ', '.join(assignments)) cursor.execute('; '.join(assignments))
def create_cursor(self, name=None): def create_cursor(self, name=None):
cursor = self.connection.cursor() cursor = self.connection.cursor()

6
tests/backends/mysql/tests.py
View File

@@ -20,7 +20,7 @@ class IsolationLevelTests(TestCase):
read_committed = 'read committed' read_committed = 'read committed'
repeatable_read = 'repeatable read' repeatable_read = 'repeatable read'
isolation_values = { isolation_values = {
level: level.replace(' ', '-').upper() level: level.upper()
for level in (read_committed, repeatable_read) for level in (read_committed, repeatable_read)
} }
@@ -38,8 +38,8 @@ class IsolationLevelTests(TestCase):
@staticmethod @staticmethod
def get_isolation_level(connection): def get_isolation_level(connection):
with connection.cursor() as cursor: with connection.cursor() as cursor:
cursor.execute("SELECT @@session.%s" % connection.transaction_isolation_variable) cursor.execute("SHOW VARIABLES WHERE variable_name IN ('transaction_isolation', 'tx_isolation')")
return cursor.fetchone()[0] return cursor.fetchone()[1].replace('-', ' ')
def test_auto_is_null_auto_config(self): def test_auto_is_null_auto_config(self):
query = 'set sql_auto_is_null = 0' query = 'set sql_auto_is_null = 0'