research/resources
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify scripts

Browse Source
This commit is contained in:
oscarz
2025-04-26 16:50:06 +08:00
parent c538e0c715
commit 275252e97d
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
javdb/src/sqlite_utils.py
View File

@ -63,7 +63,7 @@ def insert_actor_index(name, href, from_actor_list=None, from_movie_list=None):
conn.rollback() conn.rollback()
logging.error(f"未知错误: {e}") logging.error(f"未知错误: {e}")
return None return None
'''
def insert_movie_index_old(title, href, from_actor_list=None, from_movie_makers=None, from_movie_series=None, maker_id=None, series_id=None, from_movie_publishers=None, pub_id=None): def insert_movie_index_old(title, href, from_actor_list=None, from_movie_makers=None, from_movie_series=None, maker_id=None, series_id=None, from_movie_publishers=None, pub_id=None):
try: try:
# **先检查数据库中是否已有该电影** # **先检查数据库中是否已有该电影**
@ -113,7 +113,7 @@ def insert_movie_index_old(title, href, from_actor_list=None, from_movie_makers=
conn.rollback() conn.rollback()
logging.error(f"Error inserting/updating movie: {e}") logging.error(f"Error inserting/updating movie: {e}")
return None return None
'''
def insert_movie_index(title, href, **kwargs): def insert_movie_index(title, href, **kwargs):
try: try:
# 先检查数据库中是否已有该电影 # 先检查数据库中是否已有该电影
@ -847,7 +847,7 @@ def query_movies(identifier):
except sqlite3.Error as e: except sqlite3.Error as e:
logging.error(f"查询失败: {e}") logging.error(f"查询失败: {e}")
return None return None
'''
# 按条件查询 href 列表 # 按条件查询 href 列表
def query_movie_hrefs_old(**filters): def query_movie_hrefs_old(**filters):
try: try:
@ -904,11 +904,11 @@ def query_movie_hrefs_old(**filters):
except sqlite3.Error as e: except sqlite3.Error as e:
logging.error(f"查询 href 失败: {e}") logging.error(f"查询 href 失败: {e}")
return [] return []
'''
# 查询 # 查询
def query_movie_hrefs(**filters): def query_movie_hrefs(**filters):
try: try:
sql = "SELECT href, name FROM javdb_movies WHERE 1=1" sql = "SELECT href, title, id FROM javdb_movies WHERE 1=1"
params = [] params = []
conditions = { conditions = {
@ -950,7 +950,8 @@ def query_movie_hrefs(**filters):
cursor.execute(sql, params) cursor.execute(sql, params)
#return [row[0].lower() for row in cursor.fetchall()] # 返回小写 #return [row[0].lower() for row in cursor.fetchall()] # 返回小写
return [{'href': row[0], 'name': row[1]} for row in cursor.fetchall()] #return [{'href': row[0], 'name': row[1]} for row in cursor.fetchall()]
return [{'href': row[0], 'title': row[1], 'id':row[2]} for row in cursor.fetchall()]
except sqlite3.Error as e: except sqlite3.Error as e:
logging.error(f"查询 href 失败: {e}") logging.error(f"查询 href 失败: {e}")