diff --git a/DB.py b/DB.py index 4b5b24f..0449979 100644 --- a/DB.py +++ b/DB.py @@ -602,13 +602,15 @@ class DBSA: params = dict(stats) params["updatetime"] = int(time.time()) + # 过滤只保留 video 表中存在的列 + valid_cols = set(video.c.keys()) + filtered_params = {k: v for k, v in params.items() if k in valid_cols} - # 使用 Core Table 的 update() 方法 stmt = ( video .update() .where(video.c.v_xid == v_xid, video.c.rn == rn) - .values(**params) + .values(**filtered_params) ) with _engine.begin() as conn: result = conn.execute(stmt)