summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMalcolm Tredinnick <malcolm.tredinnick@gmail.com>2009-03-12 05:30:51 +0000
committerMalcolm Tredinnick <malcolm.tredinnick@gmail.com>2009-03-12 05:30:51 +0000
commitd4677d4bfbf73110a436037199b6938ce5ea167f (patch)
treecc08095e7876dd44ca96a9685c752209e0b1ed54
parent90a3c34b358b58367ed5d2354ba42de9e49daacc (diff)
Slight refactoring of isolation setting from r10029.
There was a bug in the way we were reading the DATABASE_OPTIONS setting and a lot of essentially duplicated code. This is neater. git-svn-id: http://code.djangoproject.com/svn/django/trunk@10033 bcc190cf-cafb-0310-a4f2-bffc1f526a37
-rw-r--r--django/db/backends/postgresql_psycopg2/base.py39
1 files changed, 13 insertions, 26 deletions
diff --git a/django/db/backends/postgresql_psycopg2/base.py b/django/db/backends/postgresql_psycopg2/base.py
index eee5258791..5972df3cb4 100644
--- a/django/db/backends/postgresql_psycopg2/base.py
+++ b/django/db/backends/postgresql_psycopg2/base.py
@@ -63,12 +63,9 @@ class DatabaseWrapper(BaseDatabaseWrapper):
super(DatabaseWrapper, self).__init__(*args, **kwargs)
self.features = DatabaseFeatures()
- if settings.DATABASE_OPTIONS.get('autocommit', False):
- self.features.uses_autocommit = True
- self._iso_level_0()
- else:
- self.features.uses_autocommit = False
- self._iso_level_1()
+ autocommit = self.settings_dict["DATABASE_OPTIONS"].get('autocommit', False)
+ self.features.uses_autocommit = autocommit
+ self._set_isolation_level(int(not autocommit))
self.ops = DatabaseOperations()
self.client = DatabaseClient(self)
self.creation = DatabaseCreation(self)
@@ -116,7 +113,7 @@ class DatabaseWrapper(BaseDatabaseWrapper):
the same transaction is visible across all the queries.
"""
if self.features.uses_autocommit and managed and not self.isolation_level:
- self._iso_level_1()
+ self._set_isolation_level(1)
def _leave_transaction_management(self, managed):
"""
@@ -124,29 +121,19 @@ class DatabaseWrapper(BaseDatabaseWrapper):
leaving transaction management.
"""
if self.features.uses_autocommit and not managed and self.isolation_level:
- self._iso_level_0()
+ self._set_isolation_level(0)
- def _iso_level_0(self):
+ def _set_isolation_level(self, level):
"""
- Do all the related feature configurations for isolation level 0. This
- doesn't touch the uses_autocommit feature, since that controls the
- movement *between* isolation levels.
+ Do all the related feature configurations for changing isolation
+ levels. This doesn't touch the uses_autocommit feature, since that
+ controls the movement *between* isolation levels.
"""
+ assert level in (0, 1)
try:
if self.connection is not None:
- self.connection.set_isolation_level(0)
+ self.connection.set_isolation_level(level)
finally:
- self.isolation_level = 0
- self.features.uses_savepoints = False
-
- def _iso_level_1(self):
- """
- The "isolation level 1" version of _iso_level_0().
- """
- try:
- if self.connection is not None:
- self.connection.set_isolation_level(1)
- finally:
- self.isolation_level = 1
- self.features.uses_savepoints = True
+ self.isolation_level = level
+ self.features.uses_savepoints = bool(level)