Python处理复盘系统中,sqlite3数据库中的json热点和行业字段

# -*- coding: utf-8 -*-# @Author : 小红牛# 微信公众号：gxzfp888import sqlite3import jsondef update_database(db_path='fp_analysis.db'):    """    遍历数据库中的所有记录，对热点和申万行业字段进行标准化处理。    """    conn = sqlite3.connect(db_path)    cursor = conn.cursor()    # 查询所有记录    cursor.execute("SELECT id, data FROM raw_data")    rows = cursor.fetchall()    update_count = 0    for row_id, data_json in rows:        try:            data = json.loads(data_json)        except json.JSONDecodeError:            continue  # 数据损坏，跳过        modified = False        # 处理热点列（取“：”左边）        if '热点' in data and data['热点'] is not None:            val = data['热点']            if isinstance(val, str) and '：' in val:                new_val = val.split('：', 1)[0].strip()                if new_val != val:                    data['热点'] = new_val                    modified = True        # 处理申万行业列（取“--”右边）        if '申万行业' in data and data['申万行业'] is not None:            val = data['申万行业']            if isinstance(val, str) and '--' in val:                new_val = val.split('--', 1)[1].strip()                if new_val != val:                    data['申万行业'] = new_val                    modified = True        if modified:            new_data_json = json.dumps(data, ensure_ascii=False)            cursor.execute("UPDATE raw_data SET data = ? WHERE id = ?", (new_data_json, row_id))            update_count += 1            # 每2000 条提交一次，避免事务过大            if update_count % 2000 == 0:                conn.commit()                print(f"已更新 {update_count} 条记录...")    conn.commit()    conn.close()    print(f"数据库更新完成，共更新 {update_count} 条记录。")if __name__ == "__main__":    # 如果数据库文件不在当前目录，请修改路径    update_database('fp_analysis.db')