kennethreitz/django-postgrespool
1
0
Fork 0
mirror of https://github.com/kennethreitz/django-postgrespool.git synced 2026-06-05 23:00:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

Correctly invalidate connections on failure

Browse Source 
_cursor does not check if the connection is still valid, meaning that
once a connection has been marked as invalid it will attempt to get an
sqlalchemy cursor on a broken connection and throw an exception. This
commit causes the connection to be validated when using the cursor,
triggering a new connection to be fetched from the pool if the previous
one has been marked as dead.
This commit is contained in:
Jonty Wareing
2013-07-02 18:34:42 +00:00
parent 046c0e51f2
commit a156ba98e6
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_postgrespool/base.py
+1 -1
View File
@@ -108,7 +108,7 @@ class DatabaseWrapper(Psycopg2DatabaseWrapper):
self.creation = DatabaseCreation(self)
def _cursor(self):
if self.connection is None:
if self.connection is None or self.connection.is_valid == False:
self.connection = db_pool.connect(**self._get_conn_params())
self.connection.set_client_encoding('UTF8')
tz = 'UTC' if settings.USE_TZ else self.settings_dict.get('TIME_ZONE')