Python实现将json格式数据存储到Mysql数据库

pip install mysql-connector-python

import mysql.connector
import json
from datetime import datetime
 
 
# 创建数据库连接
db = mysql.connector.connect(
    host="localhost",  # mysql服务器地址
    user="root",           # 用户名
    password="123456",  # 密码
    database="test",  # 数据库名称
    port="3307"             # 端口
)
 
 
# 创建游标对象，用于执行sql查询
cursor = db.cursor()
 
 
# 读取json文件并解析为python字典
with open('./data/goods_2025-02-12.json', 'r', encoding='utf-8') as file:
    goods = json.load(file)
 
 
# 将字典转换为json字符串
goods_json = json.dumps(goods, ensure_ascii=false)
 
 
# 日期
date = '2025-02-12'
 
 
# 执行sql
sql = "insert into goods (content, date) values (%s, %s)"
val = (goods_json, date)
cursor.execute(sql, val)
 
 
# 提交事务
db.commit()
 
 
# 关闭游标和数据库连接
cursor.close()
db.close()

import mysql.connector
import json
from datetime import datetime
 
 
# 创建数据库连接
db = mysql.connector.connect(
    host="localhost",  # mysql服务器地址
    user="root",           # 用户名
    password="123456",  # 密码
    database="test",  # 数据库名称
    port="3307"             # 端口
)
 
 
# 创建游标对象，用于执行sql查询
cursor = db.cursor()
 
 
sql = "select * from goods where date = %s"
val = ('2025-02-12',)
cursor.execute(sql, val)
 
 
# 获取查询结果
result = cursor.fetchall()
 
 
# 遍历结果并打印
for row in result:
    print(row)
 
 
# 获取商品信息(json格式)
goods = json.loads(row[1])
    
# 提交事务
db.commit()
 
 
# 关闭游标和数据库连接
cursor.close()
db.close()