diff --git a/DB.py b/DB.py
index 2513e8c..2c3feda 100644
--- a/DB.py
+++ b/DB.py
@@ -264,6 +264,30 @@ class DBVidcon:
                     print("[交由Redis处理]")
                     break
 
+    @mysql_retry()
+    def fetch_keyword_title(self, level: int = 99):
+        sql = """
+        SELECT
+            k.keyword,
+            k.rn,
+            t.title            AS v_name,
+            ANY_VALUE(t.level) AS level
+        FROM
+            sh_dm_keyword k
+        LEFT JOIN
+            sh_dm_title  t ON k.title = t.title
+        WHERE
+            k.status = 1
+            AND t.status = 1
+            AND NOT EXISTS (
+                SELECT 1 FROM sh_dm_black_keyword b WHERE b.title = t.title
+            )
+            AND t.level = %s
+        GROUP BY k.keyword, k.rn
+        """
+        self.cursor.execute(sql, (level,))
+        return self.cursor.fetchall()
+
     @mysql_retry()
     def flush(self):
         """批量执行完后手动提交。"""