Jellyfin/jellyfin-kodi
1
0
Fork 0
mirror of https://github.com/jellyfin/jellyfin-kodi.git synced 2024-12-26 02:36:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #485 from mcarlton00/people-sync

Browse source 
Fix integrity error in actor table during sync
This commit is contained in:
Abby 2021-03-14 04:06:05 +00:00 committed by GitHub
commit 96bdbefb8c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
jellyfin_kodi/objects/kodi/kodi.py
View file

@ -3,8 +3,6 @@ from __future__ import division, absolute_import, print_function, unicode_litera
################################################################################################## ##################################################################################################
from sqlite3 import IntegrityError
from helper import values from helper import values
from helper import LazyLogger from helper import LazyLogger
@ -163,21 +161,22 @@ class Kodi(object):
return self.cursor.lastrowid return self.cursor.lastrowid
def _get_person(self, *args): def _get_person(self, *args):
try: '''Retrieve person from the database, or add them if they don't exist
'''
resp = self.cursor.execute(QU.get_person, args).fetchone()
if len(resp) > 0:
return resp[0]
else:
return self.add_person(*args) return self.add_person(*args)
except IntegrityError:
# The person already exists in the database
# Now we can do the expensive operation of fetching the id
self.cursor.execute(QU.get_person, args)
return self.cursor.fetchone()[0]
def get_person(self, *args): def get_person(self, *args):
try: '''Retrieve person from cache, else forward to db query
return self._people_cache[args] '''
except KeyError: person_id = self._people_cache.get(args)
if not person_id:
person_id = self._get_person(*args) person_id = self._get_person(*args)
self._people_cache[args] = person_id self._people_cache[args] = person_id
return person_id return person_id
def add_genres(self, genres, *args): def add_genres(self, genres, *args):