API响应后通过Python变量为MySQL posts表新增product_id列并插入数据求助

核心错误点 #

• SQL语法错误：ALTER TABLE语句不符合MySQL规范，且不可与INSERT语句合并执行。正确的新增列语法为ALTER TABLE 表名 ADD COLUMN 列名 类型 [约束]，同时新增NOT NULL约束时如果表内已有存量数据会触发报错（存量数据无对应字段值），建议先允许为NULL或设置默认值。
• 逻辑错误：此前已经插入了一条post记录，需求是给这条已存在的记录写入product_id，应当使用UPDATE语句而非INSERT语句，INSERT会新增冗余的空记录。
• API调用错误：commit()是数据库连接对象（conn）的方法，游标对象（cur）没有该方法，调用cur.commit()会直接抛出异常。
• 缺少定位标识：插入post后没有获取该条记录的自增ID，后续更新操作无法定位到需要修改的对应行。
• 架构逻辑错误：ALTER TABLE属于DDL操作，仅需执行一次即可完成表结构变更，不应该写在业务逻辑中每次请求都执行，否则第二次请求就会报「列已存在」的错误。

操作步骤 #

1. 先在MySQL客户端/可视化工具中手动执行一次DDL语句完成表结构更新，仅需执行一次：

ALTER TABLE posts ADD COLUMN product_id VARCHAR(64) NULL COMMENT '关联产品ID';

2. 修正业务代码如下：

try:
    """
    新增用户输入到数据库
    """
    conn = get_db_connection()
    cur = conn.cursor()
    # 插入文章记录
    cur.execute('INSERT INTO posts (title, content, price) VALUES (?, ?, ?)',
                 (title, content, price))
    # 获取刚插入的文章自增ID
    post_id = cur.lastrowid
    conn.commit()

    """
    创建产品并生成价格
    """
    product = Product.create(name=title, description=content, metadata={'amount': price})
    get_product_response = json.dumps(product)
    load_product_response = json.loads(get_product_response)
    product_id = load_product_response['id']
    price = load_product_response['metadata']['amount']
    Price.create(product=product_id, unit_amount=price, currency='usd')
    print(f'产品{product_id}已创建，价格为${price}。')

    """
    更新对应文章的产品ID字段
    """
    # 注：如果使用pymysql等MySQL驱动，需将占位符?替换为%s
    cur.execute('UPDATE posts SET product_id = ? WHERE id = ?', (product_id, post_id))
    conn.commit()

    # 资源释放
    cur.close()
    conn.close()
except Exception as e:
    print(f"操作失败：{str(e)}")
    # 异常时回滚事务
    conn.rollback()

内容的提问来源于stack exchange，提问作者Tucker