You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Python操作MySQL无返回结果求助:JSON列数据迁移与计算

问题分析与解决方案

我帮你排查了代码里的几个关键问题,这些问题要么导致代码直接语法错误无法运行,要么执行时抛出异常却没被正确处理,最终导致没有输出结果:

1. 错误的try-except结构

你的代码里第二个except没有对应的try块,这是Python语法错误,会直接导致代码无法正常启动。所有需要捕获异常的操作都必须被包裹在try块内。

2. 不合法的SQL语句

第二个修改Population的语句缺少UPDATE city前缀,正确的SQL应该明确指定要更新的表,否则数据库无法识别这个语句。

3. 中文单引号导致SQL解析失败

在SELECT语句里,你用了中文的单引号’代替英文的':info->’$.Population’,数据库会把这个当成无效语法,执行SELECT时会报错,自然拿不到结果。

4. 异常处理的遗漏

你后面的SELECT操作没有被包裹在try-except里,而且如果前面的SQL执行出错,数据库连接的状态可能异常,后续操作也无法正常进行。


修正后的完整代码

try:
    # 第一步:从JSON列info中提取Population到新列
    query = ("UPDATE city SET Population = info->'$.Population' WHERE info->'$.Population' > 0")
    cursor.execute(query)
    conn.commit()
    
    # 第二步:将Population乘以1.1(增长10%)
    query = ("UPDATE city SET Population = Population * 1.1 WHERE Population IS NOT NULL")
    cursor.execute(query)
    conn.commit()
    
    # 第三步:查询原始人口和更新后的数据
    query = ("SELECT Name, info->'$.Population' AS Original_Population, Population AS Increased_Population FROM city;")
    cursor.execute(query)
    
    # 打印结果
    for row in cursor:
        print(u"{:<45} {:<20} {:<20}".format(row[0], row[1], row[2]))
        
except Exception as ex:
    print("执行失败: " + str(ex))
    # 出错时回滚事务,保证数据一致性
    conn.rollback()
finally:
    # 确保游标和连接被正确关闭,避免资源泄漏
    cursor.close()
    conn.close()

额外提示

  • 我给SELECT语句加了别名Original_Population和Increased_Population,让输出结果更清晰;
  • 增加了WHERE Population IS NOT NULL,避免对空值进行乘法操作;
  • 加入了finally块来确保游标和连接被正确关闭;
  • 出错时增加事务回滚,防止数据处于不一致状态。

内容的提问来源于stack exchange,提问作者ryanpalu

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.05.29 06:54:40