lifegpc/jellyfinStats
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commit changes

Browse Source
This commit is contained in:
lifegpc
2024-06-26 12:14:22 +08:00
parent b2ea5ddd8d
commit 9fee4fc572
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
jellyfinstats/db.py
View File

@@ -6,6 +6,7 @@ class PlaybackReportingDb:
def __init__(self, fn: str): def __init__(self, fn: str):
self._db = sqlite3.connect(fn) self._db = sqlite3.connect(fn)
self._closed = False self._closed = False
self._changed = False
def __enter__(self): def __enter__(self):
return self return self
@@ -16,6 +17,8 @@ class PlaybackReportingDb:
def close(self): def close(self):
if self._closed: if self._closed:
return return
if self._changed:
self._db.commit()
self._db.close() self._db.close()
self._closed = True self._closed = True
@@ -69,6 +72,7 @@ class PlaybackReportingDb:
def update_playduration(self, rowid: int, duration: int): def update_playduration(self, rowid: int, duration: int):
self._db.execute("UPDATE PlaybackActivity SET PlayDuration = ? WHERE rowid = ?;", [duration, rowid]) # noqa: E501 self._db.execute("UPDATE PlaybackActivity SET PlayDuration = ? WHERE rowid = ?;", [duration, rowid]) # noqa: E501
self._changed = True
class LibraryDb: class LibraryDb: