fix(db): pass params=None correctly to both psycopg2 and sqlite3
Some checks failed
Build and Deploy MoneyMaker / build-and-deploy (push) Failing after 11m37s
Some checks failed
Build and Deploy MoneyMaker / build-and-deploy (push) Failing after 11m37s
psycopg2 raises TypeError if params=None is passed to cur.execute() sqlite3 raises ProgrammingError on unsupported parameter type
This commit is contained in:
7
db.py
7
db.py
@@ -54,9 +54,14 @@ class DBConn:
|
|||||||
if self.db_type == "postgres":
|
if self.db_type == "postgres":
|
||||||
import psycopg2.extras
|
import psycopg2.extras
|
||||||
cur = self._conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
|
cur = self._conn.cursor(cursor_factory=psycopg2.extras.RealDictCursor)
|
||||||
cur.execute(sql, params)
|
if params is None:
|
||||||
|
cur.execute(sql)
|
||||||
|
else:
|
||||||
|
cur.execute(sql, params)
|
||||||
return cur
|
return cur
|
||||||
else:
|
else:
|
||||||
|
if params is None:
|
||||||
|
return self._conn.execute(sql)
|
||||||
return self._conn.execute(sql, params)
|
return self._conn.execute(sql, params)
|
||||||
|
|
||||||
def executemany(self, sql: str, seq):
|
def executemany(self, sql: str, seq):
|
||||||
|
|||||||
Reference in New Issue
Block a user