标签：goods Python 数据库 db cursor json Mysql import
Python操作Mysql数据库
1. 安装
pip install mysql-connector-python
2. 数据库插入json格式数据
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()
3. 数据库查询json格式数据
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()
标签：goods,
Python,
数据库,
db,
cursor,
json,
Mysql,
import
From： https://blog.csdn.net/m0_50111178/article/details/146049973