#!/usr/bin/env python3
"""检查交城县数据入库和FTS同步情况"""
import sqlite3

conn = sqlite3.connect("/root/gov_crawler/search.db")
cur = conn.cursor()

# 检查gov_raw是否有数据
cur.execute("SELECT COUNT(*) FROM gov_raw WHERE url LIKE '%sx-jc.gov.cn%'")
raw_count = cur.fetchone()[0]
print(f"gov_raw 中交城县数据: {raw_count}条")

# 检查FTS表
cur.execute("SELECT COUNT(*) FROM gov_search WHERE site_name LIKE '%交城%'")
fts_count = cur.fetchone()[0]
print(f"gov_search FTS中交城县数据: {fts_count}条")

cur.execute("SELECT COUNT(*) FROM gov_search_v3 WHERE site_name LIKE '%交城%'")
fts_v3_count = cur.fetchone()[0]
print(f"gov_search_v3 FTS中交城县数据: {fts_v3_count}条")

# 检查trigger
cur.execute("SELECT name, sql FROM sqlite_master WHERE type='trigger' AND sql LIKE '%gov_raw%'")
triggers = cur.fetchall()
for t in triggers:
    print(f"触发器: {t[0]}")
    print(f"  SQL: {t[1][:200]}...")

# 检查一条示例数据
cur.execute("SELECT url, title, site_name, publish_date FROM gov_raw WHERE url LIKE '%sx-jc%' LIMIT 2")
rows = cur.fetchall()
for r in rows:
    print(f"示例: url={r[0][:60]}, title={r[1][:40]}, site_name={r[2]}, date={r[3]}")

# 检查gov_search结构
cur.execute("PRAGMA table_info(gov_search)")
cols = cur.fetchall()
print(f"gov_search列: {[c[1] for c in cols]}")

conn.close()