feat: 添加 fetch_keyword_title 方法以支持关键词标题的数据库查询
This commit is contained in:
parent
b54f30c200
commit
5ba453fad7
24
DB.py
24
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):
|
||||
"""批量执行完后手动提交。"""
|
||||
|
Loading…
x
Reference in New Issue
Block a user