diff --git a/DB.py b/DB.py
index 0e5f1e2..080ecc3 100644
--- a/DB.py
+++ b/DB.py
@@ -27,7 +27,6 @@ _engine = create_engine(
 )
 _meta = MetaData()
 
-# 操作记录表 (sh_dm_video_op_v3)
 video_op = Table("sh_dm_video_op_v3", _meta,
     Column("id", Integer, primary_key=True, autoincrement=True),
     Column("v_id", String(64)),
@@ -49,11 +48,12 @@ video_op = Table("sh_dm_video_op_v3", _meta,
     Column("ts_status", Integer, default=1),
 )
 
-# 视频表 (sh_dm_video_v3)
+# 视频表
 video = Table("sh_dm_video_v3", _meta,
     Column("id", Integer, primary_key=True, autoincrement=True),
     Column("v_id", String(64)),
     Column("v_xid", String(64)),
+    Column("rn", String(50)),  # 关键修复：添加rn列
     Column("v_name", String(255), nullable=False),
     Column("title", String(255), nullable=False),
     Column("link", String(255), nullable=False),
@@ -79,6 +79,7 @@ video = Table("sh_dm_video_v3", _meta,
     Column("operatetime", Integer),
 )
 
+# 作者表
 video_author = Table(
     "sh_dm_video_author",
     _meta,
@@ -95,6 +96,7 @@ video_author = Table(
     Column("update_time", Integer, nullable=True, comment="更新时间（UNIX 时间戳）"),
 )
 
+
 def mysql_retry(max_retries: int = 3, base_delay: float = 2.0):
     """
     装饰器工厂：捕获 InterfaceError 后断线重连并重试，