summaryrefslogtreecommitdiff
path: root/server/apps/util.py
diff options
context:
space:
mode:
Diffstat (limited to 'server/apps/util.py')
-rw-r--r--server/apps/util.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/server/apps/util.py b/server/apps/util.py
index c5892d7..7e50f29 100644
--- a/server/apps/util.py
+++ b/server/apps/util.py
@@ -175,10 +175,12 @@ class DataHandler:
if len(differ) == 0:
if not count:
sql = """SELECT * FROM %s LIMIT %s, %s;""" % (tabname, offset, offset + limit)
+ da.conn.ping(reconnect=True)
self.cursor.execute(sql)
return self.cursor.fetchall()
else:
sql = """SELECT count(*) FROM %s""" % (tabname)
+ da.conn.ping(reconnect=True)
self.cursor.execute(sql)
return dict(self.cursor.fetchall()[0]).popitem()[1]
else:
@@ -196,12 +198,13 @@ class DataHandler:
if not count:
sql = """SELECT * FROM %s WHERE %s LIMIT %s, %s""" % (
tabname, " AND ".join(["=".join(condition.popitem()) for _ in range(l)]), offset, offset + limit)
- # print(sql)
+ da.conn.ping(reconnect=True)
self.cursor.execute(sql)
return self.cursor.fetchall()
else:
sql = """SELECT count(*) FROM %s WHERE %s LIMIT %s, %s""" % (
tabname, " AND ".join(["=".join(condition.popitem()) for _ in range(l)]), offset, limit)
+ da.conn.ping(reconnect=True)
self.cursor.execute(sql)
return dict(self.cursor.fetchall()[0]).popitem()[1]