diff --git a/DB.py b/DB.py index 8c02fb3..4ede33d 100644 --- a/DB.py +++ b/DB.py @@ -161,7 +161,7 @@ class DBVidcon: def upsert_video(self, data: dict): data.setdefault("a_id", 0) data.setdefault("history_status", "") - data.setdefault("is_repeat", 3) + data.setdefault("is_piracy", 3) data["sort"] = data.get("index", 0) max_retries = 1 # 除了第一次外,再重试一次 @@ -180,7 +180,7 @@ class DBVidcon: self.cursor.execute(select_repeat, data) row = self.cursor.fetchone() if row: - data['is_repeat'] = row[0] + data['is_repeat'] = row.get('is_repeat', 3) # 2) 插入到 op 表 sql_op = """ @@ -228,6 +228,7 @@ class DBVidcon: break # 成功跳出重试循环 except Exception as e: + # 回滚这次未提交的改动 self.conn.rollback() print("[数据库写入异常]", str(e))