Python使用PyMySQL更新MySQL数据库的操作指南

环境准备与连接建立

首先，确保已安装 pymysql 库。在Python脚本中导入该模块，并使用 pymysql.connect() 方法建立与MySQL服务器的连接。连接参数通常包括主机地址（如 localhost）、用户名、密码以及目标数据库名称。

import pymysql
# 打开数据库连接
db = pymysql.connect("localhost","root","root","db_test01")

获取游标与构造SQL

连接建立后，通过 db.cursor() 获取操作游标。游标是执行SQL语句的接口。接下来，构造UPDATE语句。在示例中，我们更新 EMPLOYEE 表中性别为 'M' 的记录，将其 AGE 字段值加1。

# 使用cursor()方法获取操作游标
cursor = db.cursor()
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')

执行与事务控制

使用 cursor.execute(sql) 执行SQL语句。由于数据库更新涉及数据变更，必须使用事务机制保证数据一致性。在 try 块中执行成功后，调用 db.commit() 提交事务。若执行过程中发生异常，则在 except 块中调用 db.rollback() 回滚操作，防止部分更新导致的数据错乱或丢失。

try:
  # 执行SQL语句
  cursor.execute(sql)
  # 提交到数据库执行
  db.commit()
  print("update OK")
except:
  # 发生错误时回滚
  db.rollback()

连接关闭

操作完成后，务必调用 db.close() 关闭数据库连接，释放资源。

# 关闭数据库连接
db.close()

执行上述代码后，若未发生异常，控制台将输出 update OK，表示更新成功。

以上就是Python使用PyMySQL更新MySQL数据库的详细内容，更多关于Python数据库操作的技术资料请关注本站其它相关文章！