import sqlite3
conn = sqlite3.connect("/root/search.db")
conn.execute("PRAGMA busy_timeout=10000")
cnt = conn.execute("SELECT COUNT(*) FROM gov_raw WHERE site_name=?", ("资阳原创文艺",)).fetchone()[0]
print(f"Deleting {cnt} garbled records...")
conn.execute("DELETE FROM gov_raw WHERE site_name=?", ("资阳原创文艺",))
conn.commit()
cnt2 = conn.execute("SELECT COUNT(*) FROM gov_raw WHERE site_name=?", ("资阳原创文艺",)).fetchone()[0]
print(f"After delete: {cnt2}")
conn.close()