Python知识分享:pymysql批量更新踩坑
import pymysql
# 假设db_config是包含数据库连接信息的字典
db_config = {
'host': 'localhost',
'user': 'your_username',
'password': 'your_password',
'db': 'your_dbname',
'charset': 'utf8mb4'
}
# 连接数据库
connection = pymysql.connect(**db_config)
try:
# 使用with语句自动管理游标的关闭
with connection.cursor() as cursor:
# 准备SQL语句,注意%s占位符
sql = "UPDATE your_table SET your_column = %s WHERE your_condition_column = %s"
# 准备要更新的数据,这里以列表的形式给出
data = [(new_value, condition_value) for condition_value in condition_values]
# 执行批量更新
cursor.executemany(sql, data)
# 提交事务
connection.commit()
finally:
# 无论成功还是异常,最终都应关闭数据库连接
connection.close()
这段代码展示了如何使用pymysql库来执行批量更新操作。它首先建立了数据库连接,然后定义了SQL语句和要更新的数据,接着使用executemany
方法执行批量更新,并在操作完成后关闭数据库连接。注意,这里的new_value
和condition_value
应该替换为实际的值或者从某处获取这些值。
评论已关闭