正文

pymysql操作mysql数据库的方法(pymysql连接mysql)奔走相告

在这里插入图片描述

文章摘要

这篇文章介绍了使用Pymysql进行MySQL数据库操作的常见方法与技巧,内容涵盖Pymysql的基础操作,包括: 1. **Pymysql连接数据库**:如何通过Pymysql创建数据库连接,使用`pymysql.connect()`函数配置连接参数(如主机、端口号、用户名、密码和数据库名)。 2. **游标操作**:如何使用`cursor.execute()`执行SQL语句,以及如何通过`cursor.fetchone()`、`cursor.fetchmany()`、`cursor.scroll()`等方法逐行或批量获取数据。 3. **SQL语句执行**:如何使用`cursor.execute()`执行SQL语句,并通过`cursor.fetchall()`获取所有结果。 4. **权限管理**:通过创建权限表、用户表及用户权限关系表,实现用户根据权限信息查询其权限的逻辑,包括用户权限关系的建立与查询。 5. **代码示例**:提供了完整的Python代码示例,演示如何通过Pymysql实现用户登录后查看自身权限的功能,包括: - 连接数据库 - 查询用户信息 - 查询权限信息 - 处理数据库操作(如提交事务) 文章重点介绍了Pymysql的基本操作方法,适合初学者学习和参考。


目录前言1、pymysql.connent2、conn.cursor()3、cursor.execute()4、cursor.executemany()5、cursor.fetchone()6、cursor.scroll()7、cursor.fetchmany()8、cursor.fetchall()9、cursor.lastrowid()10、今日练习

本篇博客主要讲的是一些基础的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数据库的方法的文章就介绍到这了,更多相关pymysql操作mysql数据库内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:python?实现?pymysql?数据库操作方法python pymysql链接数据库查询结果转为Dataframe实例使用pymysql查询数据库,把结果保存为列表并获取指定元素下标实例python数据库操作mysql:pymysql、sqlalchemy常见用法详解在python中使用pymysql往mysql数据库中插入(insert)数据实例Python使用pymysql从MySQL数据库中读出数据的方法python3.6使用pymysql连接Mysql数据库