diff --git a/scripts/db_helper.py b/scripts/db_helper.py
index 35db921..7890b4f 100644
--- a/scripts/db_helper.py
+++ b/scripts/db_helper.py
@@ -13,10 +13,13 @@ PROJECT_ROOT = Path(__file__).parent.parent
 sys.path.insert(0, str(PROJECT_ROOT))
 sys.path.insert(0, str(PROJECT_ROOT / 'platform' / 'backend'))
 
-from app.database import SessionLocal
+from app.database import SessionLocal, init_db
 from app.models import Topic
 from sqlalchemy.orm import Session
 
+# 确保数据库 schema 最新（含 org_id 等迁移）
+init_db()
+
 def get_topic_by_id(topic_id: str, db: Optional[Session] = None) -> Optional[Dict]:
     close_db = False
     if db is None: