diff --git a/records.py b/records.py index 1fd6a93..9193860 100644 --- a/records.py +++ b/records.py @@ -360,7 +360,10 @@ class Connection(object): cursor = self._conn.execute(text(query), **params) # TODO: PARAMS GO HERE # Row-by-row Record generator. - row_gen = (Record(cursor.keys(), row) for row in cursor) + row_gen = iter(Record([], [])) + + if cursor.returns_rows: + row_gen = (Record(cursor.keys(), row) for row in cursor) # Convert psycopg2 results to RecordCollection. results = RecordCollection(row_gen)