json导入mysql

### 将JSON文件数据导入到MySQL数据库

#### 方法概述
为了将JSON文件中的数据高效地导入到MySQL数据库，可以采用Python脚本实现自动化流程。此方法不仅适用于从本地文件读取JSON数据，也支持通过API获取的数据。

#### 准备工作
确保已安装必要的库来处理JSON以及连接MySQL数据库。通常情况下会用到`json`模块解析JSON字符串，并使用`mysql.connector`或`pymysql`建立与MySQL服务器之间的通信链接[^1]。

import json
import mysql.connector
from mysql.connector import errorcode

#### 解析JSON文件并构建SQL语句
首先打开目标JSON文件并将其中的内容加载成Python字典对象；接着遍历该字典创建相应的INSERT INTO SQL命令：

def load_json(file_path):
    with open(file_path, 'r', encoding='utf-8') as f:
        data = json.load(f)
    return data


def create_insert_sql(table_name, record_dict):
    columns = ', '.join("`" + str(x).replace('/', '_') + "`" for x in record_dict.keys())
    values = ', '.join("'" + str(x).replace("'", "''") + "'" for x in record_dict.values())
    sql = "INSERT INTO %s ( %s ) VALUES ( %s );" % (table_name, columns, values)
    return sql

#### 执行批量插入操作
考虑到性能因素，在实际应用中建议一次性提交多条记录而不是逐行执行insert语句。可以通过事务机制提高效率的同时减少网络开销。

def batch_execute(cursor, table_name, records_list):
    try:
        cursor.execute('START TRANSACTION')
        for item in records_list:
            insert_sql = create_insert_sql(table_name, item)
            cursor.execute(insert_sql)
        cursor.execute('COMMIT ')
    except Exception as e:
        print(e)
        cursor.execute('ROLLBACK')

# 建立数据库连接
conn = mysql.connector.connect(user='root', password='password',
                              host='localhost', database='testdb')
cursor = conn.cursor()

data_from_file = load_json('./example.json')['items']
batch_execute(cursor, 'your_table_name', data_from_file)

cursor.close()
conn.close()

上述代码片段展示了如何利用Python程序完成整个过程——从读入JSON文档直到最终写入关系型表格内。值得注意的是这里假设输入的JSON结构已经过验证并且可以直接映射为目标表字段名和值对的形式。