python，读取文件解析,写入数据库

最近在网上下载到了，qq绑定手机号的数据，试着写入数据库中

import json
import mysql.connector

file_path = r'D:\tens\tencent.txt'

# 数据库连接
db = mysql.connector.connect(
    host="192.168.1.8",  # 数据库主机
    user="social_engineering",  # 数据库用户名
    password="X",  # 数据库密码
    database="social_engineering"  # 数据库名
)

cursor = db.cursor()

with open(file_path, 'r', encoding='utf-8') as file:
    for line in file:
        # 处理每一行
        try:
            # 解析 JSON 数据
            data = json.loads(line.strip())
            _id = data["_id"]
            email_address = data["_source"]["email_address"]
            phone = data["_source"]["phone"]
            qq = data["_source"]["qq"]

            # 插入数据
            insert_query = '''
            INSERT INTO qq (_id, email_address, phone, qq) 
            VALUES (%s, %s, %s, %s)
            '''
            data_to_insert = (_id, email_address, phone, qq)

            cursor.execute(insert_query, data_to_insert)

        except mysql.connector.Error as err:
            print(f"插入数据时出错: {err}")
            db.rollback()  # 回滚更改，防止不完整数据
        except json.JSONDecodeError as json_err:
            print(f"解析 JSON 时出错: {json_err}")
            continue  # 对于无效的 JSON 行，跳过处理

        # 提交所有更改
        db.commit()  # 提交到数据库

# 关闭数据库连接
cursor.close()
db.close()