学习如何使用python的pymysql模块来操作mysql数据库

这里的基本用法主要借鉴了该篇博客:IT虾米网

因为这个作者总结的很全面,也很简洁,看完很容易上手

一.pymysql的主要方法

pymysql.connect()参数说明:(连接数据库时需要添加的参数) 
host(str):      MySQL服务器地址 
port(int):      MySQL服务器端口号 
user(str):      用户名 
passwd(str):    密码 
db(str):        数据库名称 
charset(str):   连接编码 
 
connect()对象支持的方法: 
cursor()        使用该连接创建并返回游标 
commit()        提交当前事务 
rollback()      回滚当前事务 
close()         关闭连接 
 
cursor对象支持的方法: 
execute(op)     执行一个数据库的查询命令 
fetchone()      取得结果集的下一行 
fetchmany(size) 获取结果集的下几行 
fetchall()      获取结果集中的所有行 
rowcount()      返回数据条数或影响行数 
close()         关闭游标对象

二.常用操作

1.查询数据

# coding: utf-8 
# author: hmk 
 
import pymysql.cursors 
 
# 连接数据库 
conn = pymysql.connect(host='localhost', 
                       user='root', 
                       password='123456', 
                       db='test', 
                       charset='utf8') 
 
# 创建一个游标 
cursor = conn.cursor() 
 
# 查询数据 
sql = "select * from maoyan_movie" 
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() # 关闭连接

2.插入数据

# coding: utf-8
# author: hmk

import pymysql.cursors

# 连接数据库
conn = pymysql.connect(host='localhost',
user='root',
password='123456',
db='test',
charset='utf8')

# 创建一个游标
cursor = conn.cursor()
# 插入数据 
# 数据直接写在sql后面 
sql = "insert into maoyan_movie(ranking,movie,release_time,score) values(%s, %s, %s, %s)"  # 注意是%s,不是s% 
cursor.execute(sql, ['101', '头号玩家', '上映时间:2018-05-21', '9.2'])  # 列表格式数据 
cursor.execute(sql, ('102', '马里奥', '上映时间:2018-01-21', '9.2'))  # 元组格式数据 
 
# 数据单独赋给一个对象 
sql = "insert into maoyan_movie values(%s,%s,%s,%s)" 
data = ('102', '铁蛋超人', '上映时间:2019-01-21', '9.5') 
cursor.execute(sql, data)  #sql和data之间以","隔开
sql = "insert into maoyan_movie values(%s,'%s','%s',%s)"
data = (102, '铁蛋超人', '上映时间:2019-01-21', 9.5)
cursor.execute(sql % data) #sql和data之间以"%"隔开,此时它的sql中注意要给中文字符对应的占位符加上引号,即"%s",不然会报错:unsupported format character  
 
conn.commit()   # 提交,不然无法保存插入或者修改的数据(这个一定不要忘记加上)
cursor.close()  # 关闭游标
conn.close() # 关闭连接

 3.修改数据

# coding: utf-8 
# author: hmk 
 
import pymysql.cursors 
 
# 连接数据库 
conn = pymysql.connect(host='localhost', 
                       user='root', 
                       password='123456', 
                       db='test', 
                       charset='utf8') 
# 创建一个游标
cursor = conn.cursor()
# 修改数据 
sql = "update maoyan_movie set movie='%s' where ranking=%s"  #注意%s什么时候加引号,什么时候不加 
data = ('返老还童', 1) 
cursor.execute(sql % data) 
 
sql = "update maoyan_movie set movie=%s where ranking=%s" 
data = ('寂静之地', 1) 
cursor.execute(sql, data)
conn.commit()   # 提交,不然无法保存插入或者修改的数据
cursor.close()  # 关闭游标
conn.close() # 关闭连接

4.删除数据

# coding: utf-8 
# author: hmk 
 
import pymysql.cursors 
 
# 连接数据库 
conn = pymysql.connect(host='localhost', 
                       user='root', 
                       password='123456', 
                       db='test', 
                       charset='utf8') 
 
# 创建一个游标 
cursor = conn.cursor() 
 
# 删除数据 
sql = "delete from maoyan_movie where ranking=%s" 
data = (2) 
cursor.execute(sql, data) 
 
conn.commit()   # 提交,不然删除操作不生效
cursor.close()  # 关闭游标
conn.close() # 关闭连接

附上使用的表:

create table `maoyan_movie` ( 
    `ranking` double , 
    `movie` varchar (150), 
    `release_time` blob , 
    `score` float  
); 


发布评论
IT序号网

微信公众号号:IT虾米 (左侧二维码扫一扫)欢迎添加!

python之os模块知识解答
你是第一个吃螃蟹的人
发表评论

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。