research/resources
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

modify scripts

Browse Source
This commit is contained in:
oscarz
2025-03-23 16:04:35 +08:00
parent db09f2786e
commit 20ef4b6842
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
aabook/src/alter_table.py
View File

@ -67,11 +67,13 @@ def check_dirty_chapters():
# 检查脏数据 # 检查脏数据
def update_dirty_chapters(): def update_dirty_chapters():
# 循环遍历 0 到 100 的数字 # 循环遍历 0 到 100 的数字
total = 0
for i in range(100): for i in range(100):
table_name = f'{tbl_name_chapters_prefix}_{i}' table_name = f'{tbl_name_chapters_prefix}_{i}'
try: try:
cursor.execute(f"update {table_name} set has_content = 0 WHERE updated_at >= '2025-03-23 10:20:00' and updated_at <= '2025-03-23 11:20:00' ") cursor.execute(f"update {table_name} set has_content = 0 WHERE updated_at >= '2025-03-23 10:20:00' and updated_at <= '2025-03-23 11:20:00' ")
updated_rows = cursor.rowcount updated_rows = cursor.rowcount
total += updated_rows
print(f"update {table_name}, affected rows: {updated_rows}") print(f"update {table_name}, affected rows: {updated_rows}")
conn.commit() conn.commit()
@ -82,6 +84,8 @@ def update_dirty_chapters():
except sqlite3.Error as e: except sqlite3.Error as e:
print(f"query error: {e}") print(f"query error: {e}")
print(f"\n\ntotal update rows: {total}")
# 检查是否存在，已存在的先删除 # 检查是否存在，已存在的先删除
def check_view_exist(view_name): def check_view_exist(view_name):
cursor.execute("SELECT name FROM sqlite_master WHERE type='view' AND name=?", (view_name,)) cursor.execute("SELECT name FROM sqlite_master WHERE type='view' AND name=?", (view_name,))