mirror of
https://github.com/jellyfin/jellyfin-kodi.git
synced 2024-12-25 18:26:15 +00:00
63 lines
No EOL
2.3 KiB
Python
63 lines
No EOL
2.3 KiB
Python
#################################################################################################
|
|
# ReadKodiDB
|
|
#################################################################################################
|
|
|
|
|
|
import xbmc
|
|
import xbmcgui
|
|
import xbmcaddon
|
|
import json
|
|
import os
|
|
|
|
import Utils as utils
|
|
|
|
|
|
#sleepval is used to throttle the calls to the xbmc json API
|
|
sleepVal = 15
|
|
|
|
class ReadKodiDB():
|
|
|
|
|
|
def getKodiMovies(self, connection, cursor):
|
|
#returns all movies in Kodi db
|
|
cursor.execute("SELECT kodi_id, emby_id, checksum FROM emby WHERE media_type='movie'")
|
|
allmovies = cursor.fetchall()
|
|
#this will return a list with tuples of all items returned from the database
|
|
return allmovies
|
|
|
|
def getKodiMusicVideos(self, connection, cursor):
|
|
#returns all musicvideos in Kodi db
|
|
cursor.execute("SELECT kodi_id, emby_id, checksum FROM emby WHERE media_type='musicvideo'")
|
|
allvideos = cursor.fetchall()
|
|
#this will return a list with tuples of all items returned from the database
|
|
return allvideos
|
|
|
|
def getKodiTvShows(self, connection, cursor):
|
|
cursor.execute("SELECT kodi_id, emby_id, checksum FROM emby WHERE media_type='tvshow'")
|
|
allshows = cursor.fetchall()
|
|
#this will return a list with tuples of all items returned from the database
|
|
return allshows
|
|
|
|
def getKodiEpisodes(self, connection, cursor, showid=None):
|
|
|
|
if showid == None:
|
|
cursor.execute("SELECT kodi_id, emby_id, checksum FROM emby WHERE media_type=?",("episode",))
|
|
else:
|
|
cursor.execute("SELECT kodi_id, emby_id, checksum FROM emby WHERE media_type=? AND parent_id=?",("episode", showid))
|
|
|
|
allepisodes = cursor.fetchall()
|
|
#this will return a list with tuples of all items returned from the database
|
|
return allepisodes
|
|
|
|
def getEmbyIdByKodiId(self, id, type, connection=None, cursor=None):
|
|
if not connection:
|
|
connection = utils.KodiSQL()
|
|
cursor = connection.cursor()
|
|
cursor.execute("SELECT emby_id FROM emby WHERE media_type=? AND kodi_id=?",(type,id))
|
|
result = cursor.fetchone()
|
|
if result:
|
|
return result[0]
|
|
else:
|
|
return None
|
|
|
|
|