Python利用PyMySQL操作MySQL数据库

参考资料
利用Python操作MySQL数据库

pip install PyMySQL

• 建立数据库连接
• 通过 cursor() 创建游标对象（pymysql通过游标来执行sql和获取结果）
• 使用 execute() 执行sql
• 获取结果（查询）/提交事务（增删改）
• 关闭游标
• 关闭连接

import pymysql

def update_db(update_sql):
    """更新"""
    # 建立数据库连接
    db = pymysql.connect(
        host="192.168.89.128",
        port=3306,
        user="root",
        passwd="123456",
        db="test2020"
    )
    # 通过 cursor() 创建游标对象
    cur = db.cursor()
    try:
        # 使用 execute() 执行sql
        cur.execute(update_sql)
        # 提交事务
        db.commit()
    except Exception as e:
        print("操作出现错误：{}".format(e))
        # 回滚所有更改
        db.rollback()
    finally:
        # 关闭游标
        cur.close()
        # 关闭数据库连接
        db.close()

update_sql = 'UPDATE user SET username = "张三2" WHERe id = 1'
update_db(update_sql)

在执行更新操作sql时，需要使用事务处理，即使用创建的连接进行提交事务 db.commit() ，使当前更改生效。当执行sql语句出现错误时，还应该支持事务回滚操作 db.rollback() 。