diff --git a/DB.py b/DB.py
index aef23d4..57aea96 100644
--- a/DB.py
+++ b/DB.py
@@ -759,10 +759,13 @@ class DBSA:
                 "follow_number": data.get("fans", 0),
                 "video_number": data.get("videos", 0),
                 "is_repeat": 3,
-                # "is_piracy": data.get("is_piracy", 3),
                 "ts_status": data.get("ts_status", 1),
             }
 
+            # 仅保留 sh_dm_video_v3 表中存在的字段
+            video_fields = {c.name for c in video.columns}
+            vid_row = {k: v for k, v in vid_row.items() if k in video_fields}
+
             cls._buf_op.append(op_row)
             cls._buf_vid.append(vid_row)
             cls._buf_payload.append(data)
@@ -854,7 +857,6 @@ class DBSA:
                 upd = {
                     "title": stmt.inserted.title,
                     "link": stmt.inserted.link,
-                    # "is_piracy": stmt.inserted.is_piracy,
                     "edition": stmt.inserted.edition,
                     "duration": stmt.inserted.duration,
                     "watch_number": stmt.inserted.watch_number,
@@ -892,4 +894,4 @@ class DBSA:
                 if getattr(e.orig, "args", [None])[0] == 1213 and attempt < 2:
                     time.sleep(0.5 * (attempt + 1))
                     continue
-                raise
+                raise
\ No newline at end of file