本文小编为大家详细介绍“pymysql怎么操作mysql数据库”，内容详细，步骤清晰，细节处理妥当，希望这篇“pymysql怎么操作mysql数据库”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。
用法：创建链接
语法：conn = pymysql.connect(host=‘127.0.0.1’, port=端口号, user=‘数据库用户名’, passwd=‘密码’, db=‘数据库名’)
conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='@123456', db='db4')
用法：创建光标
cursor = conn.cursor()
游标设置为字典类型
# 游标设置为字典类型
cursor = conn.cursor("cursor"=pymysql.cursors.DictCursor)
栗子：
sql = "select * from department;"
# 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入
cursor.execute(sql)
# cursor.scroll(1,mode='relative')
result = cursor.fetchone()
print(result)
输出结果：
{'id': 1, 'title': '财务'}用法：执行sql语句
cursor.execute(sql)
用法：批量执行sql语句
cursor.executemany(sql,[('销售'), ('经理')])用法：SQL执行select默认只是拿一个结果，多次执行该语句可以依次向下拿数据
import pymysql # 创建链接，跟socket服务类似 conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', passwd='@123456', db='db4') # 创建游标(相当与创建一个拿数据的手) cursor = conn.cursor() # 创建要执行的SQL语句 sql = "select * from department;" # 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入 cursor.execute(sql) result = cursor.fetchone() print(result) result = cursor.fetchone() print(result) result = cursor.fetchone() print(result) # 关闭链接 cursor.close() conn.close() · 输出结果： (1, '财务') (2, '公关') (3, '测试')
用法：注：在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：
cursor.scroll(1,mode=‘relative’) # 相对当前位置移动
cursor.scroll(2,mode=‘absolute’) # 相对绝对位置移动
表结构：
栗子：
1、 cursor.execute(sql) result = cursor.fetchone() print(result) 输出结果： (1, '财务') 2、 cursor.execute(sql) cursor.scroll(1,mode='absolute') result = cursor.fetchone() print(result) 输出结果： (2, '公关') 3、 cursor.execute(sql) cursor.scroll(1,mode='relative') result = cursor.fetchone() print(result) 输出结果： (2, '公关')
用法：可以设置返回值的个数cursor.fetchmany(num)
cursor.execute(sql) # cursor.scroll(1,mode='relative') # result = cursor.fetchone() # print(result) result = cursor.fetchmany(2) print(result) 输出结果： ((1, '财务'), (2, '公关'))
用法：顾名思义就是拿到所有的结果
sql = "select * from department;" # 执行sql语句的函数,使用下面函数进行拼接,防止SQL注入 cursor.execute(sql) # cursor.scroll(1,mode='relative') # result = cursor.fetchone() # print(result) # result = cursor.fetchmany(2) # print(result) result = cursor.fetchall() print(result) 输出结果： ((1, '财务'), (2, '公关'), (3, '测试'), (4, '运维'), (5, '销售'))
用法：获取新创建数据自增ID，如果新增加了多条数据只返回最后插入的那条数据的自增id
PS：如果只想一个一个拿id只能够一个一个插入
sql = "insert into department(title) values(%s)"
cursor.executemany(sql,[('经理')])
# 获取插入值的自增id
print(cursor.lastrowid)
# 将执行的结果提交到表中，否则表不会发生变换
conn.commit()
输出结果：
6题目要求：
练习：
权限管理
权限表：
1、订单管理
2、用户管理
3、菜单管理
4、权限分配
5、Bug管理
用户表：
1、蔡徐坤
2、鸡哥
3、坤哥
用户关系权限表：
1 1
1 2
2 1
Python实现：
某个用户登入后，可以查看自己的所有权限
题目答案：
【1、创建权限表】
CREATE TABLE power (
pid INT auto_increment PRIMARY KEY,
purview CHAR(10)
)ENGINE= INNODB DEFAULT CHARSET= utf8;
【2、创建用户表】
CREATE TABLE users (
uid INT auto_increment PRIMARY KEY,
username CHAR(10)
)ENGINE= INNODB DEFAULT CHARSET= utf8;
【3、创建用户权限关系表】
CREATE TABLE use_pow (
upid INT auto_increment PRIMARY KEY,
power_id INT,
user_id INT,
UNIQUE uq_pid_uid(power_id, user_id),
CONSTRAINT fk_pow FOREIGN KEY (power_id) REFERENCES power(pid),
CONSTRAINT fk_user FOREIGN KEY (user_id) REFERENCES users(uid)
)ENGINE= INNODB DEFAULT CHARSET= utf8;
py文件：
import pymysql
user = input('请输入用户名称>>>')
# 连接数据库
conn = pymysql.connect(host='127.0.0.1', port=3306,
user='root', passwd='@123456', db='db_grant')
# 创建光标
cursor = conn.cursor()
# 查询是否存在该用户
sql = "SELECT uid FROM users WHERE username = %(u)s"
cursor.execute(sql, {'u': user})
# 获取到用户的id
uid = cursor.fetchone()
# print(uid[0], type(uid[0]))
if uid:
# 这里的%s如果换成%d就会报错因为execute无论传入什么类型都要用%s来占位
sql2 = "SELECT purview from power WHERE pid in
(SELECT power_id FROM use_pow WHERE user_id = %s)"
cursor.execute(sql2, uid[0])
result = cursor.fetchall()
print(result)
else:
print("没有该用户")
cursor.close()
conn.close()读到这里，这篇“pymysql怎么操作mysql数据库”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
