解析JSON以存储在SQL数据库中的最佳方法(SQL存储过程/Python)

DELIMITER //

CREATE PROCEDURE ParseAndStoreJSON()
BEGIN
    DECLARE json_data TEXT;
    DECLARE name VARCHAR(255);
    DECLARE age INT;

    -- 从表中获取JSON数据
    SELECT data INTO json_data FROM json_data LIMIT 1;

    -- 解析JSON数据
    SET name = JSON_UNQUOTE(JSON_EXTRACT(json_data, '$.name'));
    SET age = JSON_EXTRACT(json_data, '$.age');

    -- 将解析后的数据插入到目标表中
    INSERT INTO parsed_data (name, age) VALUES (name, age);
END //

DELIMITER ;

import json
import sqlite3

# 连接到SQLite数据库
conn = sqlite3.connect('example.db')
cursor = conn.cursor()

# 创建目标表
cursor.execute('''
CREATE TABLE IF NOT EXISTS parsed_data (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name TEXT,
    age INTEGER
)
''')

# 读取并解析JSON文件
with open('data.json', 'r') as file:
    data = json.load(file)

# 将解析后的数据插入到数据库中
for item in data:
    cursor.execute('INSERT INTO parsed_data (name, age) VALUES (?, ?)', (item['name'], item['age']))

# 提交事务并关闭连接
conn.commit()
conn.close()

try:
    data = json.loads(json_string)
except json.JSONDecodeError as e:
    print(f"JSON解析错误: {e}")

for item in data:
    if 'name' in item and 'age' in item:
        cursor.execute('INSERT INTO parsed_data (name, age) VALUES (?, ?)', (item['name'], item['age']))
    else:
        print(f"数据缺失: {item}")