如何使用Python列表批量更新MySQL表指定列的各行值

关键注意事项 #

MySQL 未指定 ORDER BY 时返回的行顺序无稳定保障，直接按行数匹配更新必然出现值错位的问题。必须先通过表的唯一主键（通常为自增id字段）固定行顺序，才能让fakeNames列表的值按索引准确对应到每一行。
另外原代码连接数据库时未指定目标库名，会直接导致后续表操作报错，需要补全该参数。

具体实现步骤 #

• 连接数据库时补全目标数据库名参数
• 按主键升序查询所有行的主键值，拿到和fakeNames长度一致、顺序固定的主键列表
• 使用参数化批量更新的方式，将主键和对应位置的假名字段组成更新参数，一次性执行更新
• 执行成功后手动提交事务，将修改持久化到数据库；如果执行出错则回滚事务，避免产生脏数据
• 操作完成后关闭游标和数据库连接

可直接运行的参考代码 #

import MySQLdb

# 连接数据库，注意补全你自己的数据库名参数
db = MySQLdb.connect(
  host="abc.us-east-1.rds.amazonaws.com",
  user="abc",
  password="password",
  db="你的目标数据库名" # 原代码缺失该参数，必须补全
)

cursor = db.cursor()

# 1. 按主键固定顺序查询所有行的主键值，假设表主键为id，如果你表主键是其他字段替换即可
cursor.execute("SELECT id FROM z3_table ORDER BY id ASC")
row_ids = [item[0] for item in cursor.fetchall()]
number_of_names = len(row_ids)

print(f"查询到共{number_of_names}行数据")

# 这里是你已生成的fakeNames列表，要求长度和row_ids完全相等
fakeNames = []

# 校验长度匹配，避免索引越界或者更新不全
if len(fakeNames) != number_of_names:
    raise ValueError("fakeNames列表长度和表数据行数不匹配，无法更新")

try:
    # 2. 组装批量更新参数：每个元素为(假名字段值, 对应行主键id)
    update_params = [(fakeNames[i], row_ids[i]) for i in range(number_of_names)]
    # 3. 参数化批量执行更新，避免SQL注入和特殊字符转义问题
    cursor.executemany(
        "UPDATE z3_table SET person_names = %s WHERE id = %s",
        update_params
    )
    # 4. 提交事务，修改才会实际持久化到数据库
    db.commit()
    print(f"成功更新{cursor.rowcount}行数据")
except Exception as e:
    # 出错时回滚所有未提交的修改
    db.rollback()
    print(f"更新失败，已回滚操作，错误信息：{str(e)}")
finally:
    # 关闭资源
    cursor.close()
    db.close()

关键逻辑说明 #

• 必须加ORDER BY id排序规则：保证每次查询返回的主键顺序固定，和fakeNames列表的索引严格一一对应，从根源避免更新错行
• 选用executemany做批量更新：相比循环单条执行update，性能提升非常明显，同时会自动处理参数转义，避免特殊字符（比如引号、emoji）导致SQL报错，也能防范SQL注入风险
• 必须显式调用db.commit()：MySQLdb默认开启事务模式，不执行commit的话所有修改仅在当前临时连接生效，连接关闭后修改会直接回滚，不会写入数据库
• 增加长度校验逻辑：提前拦截列表长度和行数不匹配的异常场景，避免出现部分行更新、部分行没更新的问题
• 新增异常回滚逻辑：更新过程中如果出现报错，会自动撤销所有未提交的修改，不会产生半更新的脏数据

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