【MySQL速通篇002】pymysql简单操作mysql数据库的方法

2023-06-05 170 发布于吉林

版权

举报

版权声明：

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS PostgreSQL，高可用系列 2核4GB

RDS MySQL Serverless 高可用系列，价值2615元额度，1个月

简介： 【MySQL速通篇002】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"=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语句

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，如果新增加了多条数据只返回最后插入的那条数据的自增id

PS：如果只想一个一个拿id只能够一个一个插入

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

10、今日练习

题目要求：

练习： 权限管理 权限表： 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()

相关实践学习

如何快速连接云数据库RDS MySQL

本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL，然后进行数据表的CRUD操作。

全面了解阿里云能为你做什么

阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs

相关文章

MySQL下载安装全攻略！小白也能轻松上手，从此数据库不再难搞！

这是一份详细的MySQL安装与配置教程，适合初学者快速上手。内容涵盖从下载到安装的每一步操作，包括选择版本、设置路径、配置端口及密码等。同时提供基础操作指南，如数据库管理、数据表增删改查、用户权限设置等。还介绍了备份恢复、图形化工具使用和性能优化技巧，帮助用户全面掌握MySQL的使用方法。附带常见问题解决方法，保姆级教学让你无忧入门！

实现不同数据库的表间的 JOIN 运算的极简方法

跨库计算是数据分析中的常见难题，尤其涉及多数据库系统时，表间 JOIN 操作复杂度显著提升。esProc 提供了一种高效解决方案，能够简化跨库 JOIN 的实现。例如，在车辆管理、交管和公民信息系统中，通过 esProc 可轻松完成如下任务：按城市统计有车公民事件数量、找出近一年获表彰的车主信息，以及按年份和品牌统计车辆违章次数。esProc 支持不同关联场景（如维表关联与主子表关联）的优化算法，如内存索引、游标处理和有序归并，从而大幅提升编码和运算效率。无论是同构还是异构数据源，esProc 均能灵活应对，为复杂数据分析提供强大支持。

【MySQL】SQL分析的几种方法

以上就是SQL分析的几种方法。需要注意的是，这些方法并不是孤立的，而是相互关联的。在实际的SQL分析中，我们通常需要结合使用这些方法，才能找出最佳的优化策略。同时，SQL分析也需要对数据库管理系统，数据，业务需求有深入的理解，这需要时间和经验的积累。

目录

1、pymysql.connent 2、conn.cursor() 3、cursor.execute() 4、cursor.executemany() 5、cursor.fetchone() 6、cursor.scroll() 7、cursor.fetchmany() 8、cursor.fetchall() 9、cursor.lastrowid() 10、今日练习

网址：【MySQL速通篇002】pymysql简单操作mysql数据库的方法 https://m.mxgxt.com/news/view/1368670

相关内容

如何可视化MySQL数据库的表关联结构？
MySQL 如何设计电影数据库
MySQL：开源数据库的璀璨明星
如何查看mysql数据库表之间的关系
mysql怎么创建数据库关系图
mysql数据库表关系图怎么生成
centos7 mysql数据库安装和配置
MySQL 入门：如何设计电影数据库
mysql怎么建表关系图,数据库表关系怎么建
如何使用Flink,通过CTAS语句同步MySQL数据至StarRocks

随便看看