get the query to return results, or an empty list if any error occurs

2024-01-14 13:53:34 -06:00 · 2024-01-14 13:53:34 -06:00 · e3d8a31285
commit e3d8a31285
parent 997dc064e6
1 changed files with 7 additions and 1 deletions
--- 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.