anonfunc/JellyPy
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix deleteing duplicate rows from session history tables after import

Browse Source
This commit is contained in:
JonnyWong16
2020-05-24 00:01:58 -07:00
parent fe4ddaeb52
commit 0462121f69
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
plexpy/database.py
View File

@@ -152,11 +152,16 @@ def import_tautulli_db(database=None, method=None, backup=False):
db.connection.execute('DETACH import_db') db.connection.execute('DETACH import_db')
if method == 'merge': if method == 'merge':
for table, columns in table_columns.items(): for table_name, columns in sorted(table_columns.items()):
duplicate_columns = ', '.join([c for c in columns if c != 'id']) duplicate_columns = ', '.join([c for c in columns if c != 'id'])
logger.info("Tautulli Database :: Removing duplicate rows from database table '%s'.", table) logger.info("Tautulli Database :: Removing duplicate rows from database table '%s'.", table_name)
db.action('DELETE FROM {table} WHERE id NOT IN ' if table_name in session_history_tables[1:]:
'(SELECT MIN(id) FROM {table} GROUP BY {columns})'.format(table=table, columns=duplicate_columns)) db.action('DELETE FROM {table} WHERE id NOT IN '
'(SELECT id FROM session_history)'.format(table=table_name))
else:
db.action('DELETE FROM {table} WHERE id NOT IN '
'(SELECT MIN(id) FROM {table} GROUP BY {columns})'.format(table=table_name,
columns=duplicate_columns))
logger.info("Tautulli Database :: Deleting temporary database tables.") logger.info("Tautulli Database :: Deleting temporary database tables.")
for table_name in session_history_tables: for table_name in session_history_tables: