We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0edc937 commit 24fe0f7Copy full SHA for 24fe0f7
testgres/connection.py
@@ -103,14 +103,16 @@ def rollback(self):
103
104
def execute(self, query, *args):
105
self.cursor.execute(query, args)
106
+ if self.cursor.rowcount < 0:
107
+ self.cursor.close()
108
+ return None
109
try:
- res = self.cursor.fetchall()
- # pg8000 might return tuples
- if isinstance(res, tuple):
110
- res = [tuple(t) for t in res]
111
-
+ res = [tuple(t) for t in self.cursor.fetchall()]
112
return res
113
- except Exception:
+ except ProgrammingError:
114
+ except Exception as e:
115
+ print("Error executing query: {}\n {}".format(repr(e), query))
116
return None
117
118
def close(self):
0 commit comments