之前用的Python2，连接MySQL用的是MySQLdb。现在换成python3.x了，由于 MySQLdb 模块还不支持 Python3.x，所以 Python3.x 如果想连接MySQL需要安装 PyMySQL模块，以下将介绍PyMySQL的安装及常用操作。

一、安装

pip install PyMySQL

二、常用操作

查询数据

import pymysql# 连接数据库conn = pymysql.connect( host='127.0.0.1', user='root', passwd='root', port=3306, db='test', charset='utf8')# 创建一个游标cursor = conn.cursor()# 查询数据sql = "select * from user"cursor.execute(sql) # 执行sql# 查询所有数据，返回结果默认以元组形式，所以可以进行迭代处理for i in cursor.fetchall(): print(i)print('共查询到：', cursor.rowcount, '条数据。')# 获取第一行数据result_1 = cursor.fetchone()print(result_1)# 获取前n行数据result_3 = cursor.fetchmany(3)print(result_3)cursor.close() # 关闭游标conn.close() # 关闭连接

插入数据

执行完插入语句后一定要执行.commit()进行提交事务，可以插入多条后统一提交，否则操作无效

import pymysql# 连接数据库conn = pymysql.connect( host='127.0.0.1', user='root', passwd='root', port=3306, db='test', charset='utf8')# 创建一个游标cursor = conn.cursor()# 插入数据# 数据直接写在sql后面sql = "insert into username(id,name) values(%s, %s)" # 注意是%s,不是s%cursor.execute(sql, [3, '王五']) # 列表格式数据cursor.execute(sql, (4, '马六')) # 元组格式数据# 数据单独赋给一个对象sql = "insert into username values(%s,%s)"data = (5, '老七')cursor.execute(sql, data) #sql和data之间以","隔开sql = "insert into username values(%s,'%s')"data = (6, '小八')cursor.execute(sql % data) #sql和data之间以"%"隔开，此时它的sql中注意要给中文字符对应的占位符加上引号，即"%s",不然会报错：unsupported format characterconn.commit() # 提交，不然无法保存插入或者修改的数据(这个一定不要忘记加上)cursor.close() # 关闭游标conn.close() # 关闭连接

修改数据

执行完修改语句后一定要执行.commit()进行提交事务，可以修改多条后统一提交，否则操作无效

import pymysql# 连接数据库conn = pymysql.connect( host='127.0.0.1', user='root', passwd='root', port=3306, db='test', charset='utf8')# 创建一个游标cursor = conn.cursor()# 修改数据sql = "update username set name='%s' where id=%s" #注意%s什么时候加引号，什么时候不加data = ('改名了', 1)cursor.execute(sql % data)sql = "update username set name=%s where id=%s"data = ('也改名了', 2)cursor.execute(sql, data)conn.commit() # 提交，不然无法保存插入或者修改的数据cursor.close() # 关闭游标conn.close() # 关闭连接

删除数据

执行完删除语句后一定要执行.commit()进行提交事务，可以删除多条后统一提交，否则操作无效

import pymysql# 连接数据库conn = pymysql.connect( host='127.0.0.1', user='root', passwd='root', port=3306, db='test', charset='utf8')# 创建一个游标cursor = conn.cursor()# 删除数据sql = "delete from username where id=%s"data = (2)cursor.execute(sql, data)conn.commit() # 提交，不然删除操作不生效cursor.close() # 关闭游标conn.close() # 关闭连接

总结

以上所述是小编给大家介绍的Python 中使用 PyMySQL操作数据库的方法，希望对大家有所帮助！