SchoolGuy/ticketfrei
1
0
Fork 0
forked from ticketfrei/ticketfrei
Code Issues Pull requests Releases Wiki Activity

reduce explicit db commits

Browse source
This commit is contained in:
Egg 2024-10-09 15:38:35 +02:00
parent 9a262514fd
commit d7aea928d1
2 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
db.py
View file

@ -27,13 +27,15 @@ class DB(object):
break break
except sqlite3.OperationalError as error: except sqlite3.OperationalError as error:
# another thread may be writing, give it a chance to finish # another thread may be writing, give it a chance to finish
sleep(0.5) sleep(1)
logger.exception() logger.exception()
if time() - start_time > 5: if time() - start_time > 5:
# if it takes this long, something is wrong # if it takes this long, something is wrong
system("rcctl restart frontend_daemon") system("rcctl restart frontend_daemon")
logger.warning("frontend_daemon is getting restarted") logger.warning("frontend_daemon is getting restarted")
self.conn.commit() self.conn.commit()
elif time() - start_time > 10:
return
def close(self): def close(self):
self.conn.close() self.conn.close()

3
user.py
View file

@ -158,7 +158,6 @@ schlitz
def toot_witness(self, toot_uri): def toot_witness(self, toot_uri):
db.execute("INSERT INTO seen_toots (toot_uri, user_id) VALUES (?,?);", db.execute("INSERT INTO seen_toots (toot_uri, user_id) VALUES (?,?);",
(toot_uri, self.uid)) (toot_uri, self.uid))
db.commit()
def get_seen_tg(self): def get_seen_tg(self):
db.execute("SELECT tg_id FROM seen_telegrams WHERE user_id = ?;", db.execute("SELECT tg_id FROM seen_telegrams WHERE user_id = ?;",
@ -168,7 +167,6 @@ schlitz
def save_seen_tg(self, tg_id): def save_seen_tg(self, tg_id):
db.execute("UPDATE seen_telegrams SET tg_id = ? WHERE user_id = ?;", db.execute("UPDATE seen_telegrams SET tg_id = ? WHERE user_id = ?;",
(tg_id, self.uid)) (tg_id, self.uid))
db.commit()
def get_mailinglist(self): def get_mailinglist(self):
db.execute("SELECT email FROM mailinglist WHERE user_id = ?;", (self.uid, )) db.execute("SELECT email FROM mailinglist WHERE user_id = ?;", (self.uid, ))
@ -181,7 +179,6 @@ schlitz
def save_seen_mail(self, mail_date): def save_seen_mail(self, mail_date):
db.execute("UPDATE seen_mail SET mail_date = ? WHERE user_id = ?;", db.execute("UPDATE seen_mail SET mail_date = ? WHERE user_id = ?;",
(mail_date, self.uid)) (mail_date, self.uid))
db.commit()
def set_trigger_words(self, patterns): def set_trigger_words(self, patterns):
db.execute("UPDATE triggerpatterns SET patterns = ? WHERE user_id = ?;", db.execute("UPDATE triggerpatterns SET patterns = ? WHERE user_id = ?;",