第4节，mysql.connector修改删除mysql数据

1. 修改数据

新增，修改，删除，查询这些操作对于mysql.connector驱动来说用法都一样，关键是编写正确的sql并调用execute方法执行。

import mysql.connector

# 第一步，创建连接
mydb = mysql.connector.connect(
    host="10.110.30.3",     # 数据库主机地址
    user="flink_user",      # 数据库用户名
    passwd="123456",        # 数据库密码
    port=6606,
    database='flink_db'
)

sql = "update city set name='beijing' where id = 11"        # update语句
mycursor = mydb.cursor()        # 第二步，创建cursor
mycursor.execute(sql)           # 第三步，执行sql
mydb.commit()                   # commit 提交

同新增操作一样，必须调用commit方法提交。

2. 删除数据

import mysql.connector

# 第一步，创建连接
mydb = mysql.connector.connect(
    host="10.110.30.3",     # 数据库主机地址
    user="flink_user",      # 数据库用户名
    passwd="123456",        # 数据库密码
    port=6606,
    database='flink_db'
)

sql = "delete from city  where id = 11"        # delete语句
mycursor = mydb.cursor()        # 第二步，创建cursor
mycursor.execute(sql)           # 第三步，执行sql
mydb.commit()                   # commit 提交