diff --git a/aiopg/connection.py b/aiopg/connection.py index d6b16790..85840e00 100755 --- a/aiopg/connection.py +++ b/aiopg/connection.py @@ -39,8 +39,12 @@ def _enable_hstore(conn): """) rv0, rv1 = [], [] for oids in (yield from cur.fetchall()): - rv0.append(oids[0]) - rv1.append(oids[1]) + if isinstance(oids, dict): + rv0.append(oids['oid']) + rv1.append(oids['typarray']) + else: + rv0.append(oids[0]) + rv1.append(oids[1]) cur.close() return tuple(rv0), tuple(rv1)