0.91-bufixes: Backport [4244] for those using legacy Django with psycopg1

git-svn-id: http://code.djangoproject.com/svn/django/branches/0.91-bugfixes@4419 bcc190cf-cafb-0310-a4f2-bffc1f526a37
This commit is contained in:
James Bennett 2007-01-24 19:57:41 +00:00
parent f931905517
commit d0672a7344
1 changed files with 33 additions and 0 deletions

View File

@ -16,6 +16,38 @@ except ImportError:
# Import copy of _thread_local.py from python 2.4 # Import copy of _thread_local.py from python 2.4
from django.utils._threading_local import local from django.utils._threading_local import local
def smart_basestring(s, charset):
if isinstance(s, unicode):
return s.encode(charset)
return s
class UnicodeCursorWrapper(object):
"""
A thin wrapper around psycopg cursors that allows them to accept Unicode
strings as params.
This is necessary because psycopg doesn't apply any DB quoting to
parameters that are Unicode strings. If a param is Unicode, this will
convert it to a bytestring using DEFAULT_CHARSET before passing it to
psycopg.
"""
def __init__(self, cursor, charset):
self.cursor = cursor
self.charset = charset
def execute(self, sql, params=()):
return self.cursor.execute(sql, [smart_basestring(p, self.charset) for p in params])
def executemany(self, sql, param_list):
new_param_list = [tuple([smart_basestring(p, self.charset) for p in params]) for params in param_list]
return self.cursor.executemany(sql, new_param_list)
def __getattr__(self, attr):
if self.__dict__.has_key(attr):
return self.__dict__[attr]
else:
return getattr(self.cursor, attr)
class DatabaseWrapper(local): class DatabaseWrapper(local):
def __init__(self): def __init__(self):
self.connection = None self.connection = None
@ -40,6 +72,7 @@ class DatabaseWrapper(local):
self.connection.set_isolation_level(1) # make transactions transparent to all cursors self.connection.set_isolation_level(1) # make transactions transparent to all cursors
cursor = self.connection.cursor() cursor = self.connection.cursor()
cursor.execute("SET TIME ZONE %s", [TIME_ZONE]) cursor.execute("SET TIME ZONE %s", [TIME_ZONE])
cursor = UnicodeCursorWrapper(cursor, settings.DEFAULT_CHARSET)
if DEBUG: if DEBUG:
return base.CursorDebugWrapper(cursor, self) return base.CursorDebugWrapper(cursor, self)
return cursor return cursor