diff --git a/javdb/src/sqlite_utils.py b/javdb/src/sqlite_utils.py index ec518d9..d282efc 100644 --- a/javdb/src/sqlite_utils.py +++ b/javdb/src/sqlite_utils.py @@ -63,7 +63,7 @@ def insert_actor_index(name, href, from_actor_list=None, from_movie_list=None): conn.rollback() logging.error(f"未知错误: {e}") 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): try: # **先检查数据库中是否已有该电影** @@ -113,7 +113,7 @@ def insert_movie_index_old(title, href, from_actor_list=None, from_movie_makers= conn.rollback() logging.error(f"Error inserting/updating movie: {e}") return None - +''' def insert_movie_index(title, href, **kwargs): try: # 先检查数据库中是否已有该电影 @@ -847,7 +847,7 @@ def query_movies(identifier): except sqlite3.Error as e: logging.error(f"查询失败: {e}") return None - +''' # 按条件查询 href 列表 def query_movie_hrefs_old(**filters): try: @@ -904,11 +904,11 @@ def query_movie_hrefs_old(**filters): except sqlite3.Error as e: logging.error(f"查询 href 失败: {e}") return [] - +''' # 查询 def query_movie_hrefs(**filters): try: - sql = "SELECT href, name FROM javdb_movies WHERE 1=1" + sql = "SELECT href, title, id FROM javdb_movies WHERE 1=1" params = [] conditions = { @@ -950,7 +950,8 @@ def query_movie_hrefs(**filters): cursor.execute(sql, params) #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: logging.error(f"查询 href 失败: {e}")