pymysql怎么操作mysql数据库

pymysql怎么操作mysql数据库

1、pymysql.connent

用法：创建链接语法：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')登录后复制

2、conn.cursor()

用法：创建光标

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': '财务'}登录后复制

3、cursor.execute()

用法：执行sql语句

cursor.execute(sql)登录后复制

4、cursor.executemany()

用法：批量执行sql语句

cursor.executemany(sql,[('销售'), ('经理')])登录后复制

5、cursor.fetchone()

用法：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, '测试')登录后复制

6、cursor.scroll()

用法：注：在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, '公关')登录后复制

7、cursor.fetchmany()

用法：可以设置返回值的个数cursor.fetchmany(num)

cursor.execute(sql)# cursor.scroll(1,mode='relative')# result = cursor.fetchone()# print(result)result = cursor.fetchmany(2)print(result)输出结果：((1, '财务'), (2, '公关'))登录后复制

8、cursor.fetchall()

用法：顾名思义就是拿到所有的结果

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, '销售'))登录后复制

9、cursor.lastrowid()

用法：获取新创建数据自增ID，如果新增加了多条数据只返回最后插入的那条数据的自增idPS：如果只想一个一个拿id只能够一个一个插入

sql = "insert into department(title) values(%s)"cursor.executemany(sql,[('经理')])# 获取插入值的自增idprint(cursor.lastrowid)# 将执行的结果提交到表中，否则表不会发生变换conn.commit()输出结果：6登录后复制

10、今日练习

题目要求：

练习： 权限管理 权限表： 1、订单管理 2、用户管理 3、菜单管理 4、权限分配 5、Bug管理 用户表： 1、蔡徐坤 2、鸡哥 3、坤哥 用户关系权限表： 1 1 1 2 2 1Python实现： 某个用户登入后，可以查看自己的所有权限

题目答案：

【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 pymysqluser = 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})# 获取到用户的iduid = 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()登录后复制

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。