Python 中使用 PyMySQL模块操作数据库的方法

时间:2021-05-22

之前用的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操作数据库的方法,希望对大家有所帮助!

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章