如何使用Python将京东商品评论数据存储到数据库中？

CREATE TABLE jd_comment (
    id INT PRIMARY KEY AUTO_INCREMENT,
    sku_id VARCHAR(32) NOT NULL COMMENT '商品ID',
    nickname VARCHAR(64) COMMENT '用户名',
    score INT COMMENT '评分1-5',
    content TEXT COMMENT '评论内容',
    creation_time DATETIME COMMENT '评论时间',
    create_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

import pymysql
import json

# 数据库连接
def get_db():
    return pymysql.connect(
        host="localhost",
        user="root",
        password="你的密码",
        database="test",  # 库名
        charset="utf8mb4"
    )

# 插入单条评论
def save_comment(sku_id, nickname, score, content, creation_time):
    db = get_db()
    cursor = db.cursor()

    sql = """
    INSERT INTO jd_comment(sku_id, nickname, score, content, creation_time)
    VALUES (%s, %s, %s, %s, %s)
    """
    cursor.execute(sql, (sku_id, nickname, score, content, creation_time))
    db.commit()
    cursor.close()
    db.close()

# 假设这是京东API返回的JSON数据
jd_json = {
    "result": {
        "comments": [
            {
                "nickname": "jd_abc123",
                "score": 5,
                "content": "东西很好，物流很快",
                "creationTime": "2026-04-09 12:30:00"
            }
        ]
    }
}

# 解析并保存
sku_id = "100012345678"  # 商品ID
comments = jd_json["result"]["comments"]

for c in comments:
    save_comment(
        sku_id=sku_id,
        nickname=c["nickname"],
        score=c["score"],
        content=c["content"],
        creation_time=c["creationTime"]
    )

print("保存成功")

import sqlite3

conn = sqlite3.connect("jd.db")
cursor = conn.cursor()

cursor.execute('''
CREATE TABLE IF NOT EXISTS jd_comment
(sku_id text, nickname text, score int, content text, creation_time text)
''')

# 插入
cursor.execute('INSERT INTO jd_comment VALUES (?,?,?,?,?)',
               ("1000123456", "user1", 5, "很好", "2026-04-09"))

conn.commit()
conn.close()