以下是一些示例代码,演示如何将 JSON 数据写入 MySQL 数据库。
首先,假设我们有一个包含以下 JSON 数据的文件(data.json):
[ {"name": "Alice", "age": 28, "city": "New York"}, {"name": "Bob", "age": 35, "city": "Los Angeles"}, {"name": "Charlie", "age": 45, "city": "Chicago"}]
接下来,我们可以使用 Python 中的 json 模块将数据读取到 Python 对象中,并使用 pymysql 模块连接到 MySQL 数据库。以下示例代码假定您已经安装了 pymysql 模块并具有适当的 MySQL 连接信息:
import json
import pymysql
with open('data.json', 'r') as f:
data = json.load(f)
conn = pymysql.connect(
host='localhost',
user='myuser',
password='mypassword',
db='mydatabase',
charset='utf8mb4',
cursorclass=pymysql.cursors.DictCursor
with conn.cursor() as cursor:
cursor.execute("""
CREATE TABLE IF NOT EXISTS mytable (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(50),
age INT,
city VARCHAR(50)
""")
with conn.cursor() as cursor:
for row in data:
name = row['name']
age = row['age']
city = row['city']
cursor.execute("""
INSERT INTO mytable (name, age, city)
VALUES (%s, %s, %s)
""", (name, age, city))
conn.commit()
该代码使用 pymysql 模块建立了与 MySQL 数据库的连接,并使用 CREATE TABLE 语句创建了一个名为 mytable 的表来存储 JSON 数据。然后,它使用 for 循环迭代 Python 对象中的每一行,并使用 INSERT INTO 语句将数据插入到 mytable 表中。最后,代码调用 commit() 方法以确保数据插入成功并将其保存到数据库中。
请注意,此示例中使用的是基本的 INSERT INTO 语句,并且数据是硬编码在代码中的。如果您的 JSON 数据结构与表结构不匹配,您需要在代码中进行相应的更改以确保正确的数据插入。
希望这个示例代码能够帮助您将 JSON 数据写入 MySQL 数据库。
- 2257
-
牛牛_sean
Node.js
Redis