summaryrefslogtreecommitdiff
path: root/lib/sqlalchemy/dialects/postgresql
diff options
context:
space:
mode:
authorMike Bayer <mike_mp@zzzcomputing.com>2009-08-09 21:41:56 +0000
committerMike Bayer <mike_mp@zzzcomputing.com>2009-08-09 21:41:56 +0000
commit00d247edcc89ae7620d75112cd9183138db7ebe7 (patch)
treeb3de54fa8a553516a145405f8dda24a94e008282 /lib/sqlalchemy/dialects/postgresql
parente7241263aa9db24885b41984b85300178428a60c (diff)
downloadsqlalchemy-00d247edcc89ae7620d75112cd9183138db7ebe7.tar.gz
close out py3k + pg8000 bugs that are fixable for now without pg8000 decimal fix
Diffstat (limited to 'lib/sqlalchemy/dialects/postgresql')
-rw-r--r--lib/sqlalchemy/dialects/postgresql/base.py13
1 files changed, 13 insertions, 0 deletions
diff --git a/lib/sqlalchemy/dialects/postgresql/base.py b/lib/sqlalchemy/dialects/postgresql/base.py
index 874907abc..fbba8221b 100644
--- a/lib/sqlalchemy/dialects/postgresql/base.py
+++ b/lib/sqlalchemy/dialects/postgresql/base.py
@@ -619,8 +619,13 @@ class PGDialect(default.DefaultDialect):
"""
rp = connection.execute(s)
# what about system tables?
+ # Py3K
+ #schema_names = [row[0] for row in rp \
+ # if not row[0].startswith('pg_')]
+ # Py2K
schema_names = [row[0].decode(self.encoding) for row in rp \
if not row[0].startswith('pg_')]
+ # end Py2K
return schema_names
@reflection.cache
@@ -644,7 +649,11 @@ class PGDialect(default.DefaultDialect):
WHERE relkind = 'v'
AND '%(schema)s' = (select nspname from pg_namespace n where n.oid = c.relnamespace)
""" % dict(schema=current_schema)
+ # Py3K
+ #view_names = [row[0] for row in connection.execute(s)]
+ # Py2K
view_names = [row[0].decode(self.encoding) for row in connection.execute(s)]
+ # end Py2K
return view_names
@reflection.cache
@@ -661,7 +670,11 @@ class PGDialect(default.DefaultDialect):
rp = connection.execute(sql.text(s),
view_name=view_name, schema=current_schema)
if rp:
+ # Py3K
+ #view_def = rp.scalar()
+ # Py2K
view_def = rp.scalar().decode(self.encoding)
+ # end Py2K
return view_def
@reflection.cache