diff --git a/database.py b/database.py index f68e7c0..4ee403f 100644 --- a/database.py +++ b/database.py @@ -24,7 +24,13 @@ class DBConnector: self.conn.close() def _query(self, sql): - self.cur.execute(sql) + try: + self.cur.execute(sql) + result = self.cur.fetchall() + except psycopg2.DatabaseError as e: + result = [] + return result + def read(self, **kwargs): """Read rows from a database that match the specified filters.