PyMySQL:连接Python与MySQL的桥梁

server/2024/9/23 9:34:38/

在这里插入图片描述

系列文章目录

更新ing...

  1. MySQL操作全攻略:库、表、数据、事务全面指南
  2. 深入探索MySQL SELECT查询:从基础到高级,解锁数据宝藏的密钥
  3. MySQL SELECT查询实战:练习题精选,提升你的数据库查询技能
  4. PyMySQL:连接Python与MySQL的桥梁

文章目录

  • 系列文章目录
  • 前言
  • 一、初识pymysql
  • 二、pymysql实现数据的操作
    • 1.pymysql实现增加数据
    • 2.pymysql实现修改数据
    • 3.pymysql实现删除数据
    • 4.pymysql实现查询数据
  • 三、Pymysql 封装
    • 1.封装思路
    • 2.封装实现


前言

    在数据驱动的时代,Python与MySQL数据库的交互变得至关重要。PyMySQL,作为连接Python与MySQL的桥梁,让数据操作变得更加简单和高效。本文将带您快速了解PyMySQL的安装、配置及基本使用方法,让您轻松实现Python与MySQL的交互,为数据驱动的项目提供强大的支持。


mysql_23">一、初识pymysql

    pymysql是一个纯Python编写的MySQL客户端库,用于连接和操作MySQL数据库。它实现了Python DB API v2.0规范,并提供了与MySQL服务器进行通信所需的所有基本功能。

下载安装第三方模块

1. 通过命令行进行下载安装   输入命令:pip install pymysql
2. pycharm找到Terminal终端   输入命令:pip install pymysql
3. pycharm中左上角File-->Settings-->project Interpreter-->找到+号-->搜索pymysql模块-->取消下面勾选-->install

mysql_33">pymysql连接数据库

python">import pymysql# pymysql实现python连接mysql-->pymysql模块中connect
# host:主机 ip     localhost/127.0.0.1    要连接mysql在本机上
# port:端口         3306                   mysql默认端口
# user:mysql用户名   root
# password:mysql密码   自己的密码
# database:要连接的库   已存在的库
# charset:编码方法      utf8
# con:数据库连接对象
con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test",charset="utf8")

mysql_48">pymysql实现表结构的操作

python">import pymysql# python连接mysql-->使用pymysql模块中的connect()
# host:主机、ip      localhost     要连接mysql在本机
# port:端口          3306         mysql默认端口3306
# user:mysql用户名   root
# password:密码     自己的密码
# database:数据库   已存在的库
# charset:编码方式   utf8
# con:数据库连接对象
con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test",charset="utf8")# 获取游标对象-->数据库连接对象.cursor()
# c1:游标对象
c1 = con.cursor()# 编写sql语句--》表结构的操作、创建表、删除表
sql = """insert into people(id) value(50)"""# 游标对象执行sql语句--》游标对象.execute(sql)
c1.execute(sql)# 关闭数据库连接-->数据库连接对象.close()
con.close()

mysql_77">二、pymysql实现数据的操作

触发事务的操作:增加数据 i n s e r t 、修改数据 u p d a t e 、删除数据 d e l e t e \color{red}{触发事务的操作:增加数据insert 、修改数据update、删除数据delete} 触发事务的操作:增加数据insert、修改数据update、删除数据delete

mysql_79">1.pymysql实现增加数据

代码如下(示例):

python">import pymysql
# pymysql实现数据增加# 1.连接mysql-->使用pymysql模块connect
# host:ip            localhost            要连接mysql在本机
# port:端口           3306                 mysql默认端口3306
# user:用户名         root
# password:密码       自己的密码
# database:数据库名   已存在的库
# charset:编码方式     utf8
# con:数据库连接对象
con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test",charset="utf8")# 2.获取游标对象-->数据库对象.cursor()
c1 = con.cursor()# 3.编写sql语句
sql = """insert into aa value(5,500)"""try:# 4.游标对象执行sql语句-->游标对象.execute(sql)c1.execute(sql)# 如果sql语句执行成功,将事务进行提交-->数据库对象.commit()con.commit()print("执行成功")
except Exception as e:# 如果sql语句执行失败,将事务进行回滚-->数据库对象.rollback()con.rollback()print("执行失败")# 5.关闭
con.close()

mysql_117">2.pymysql实现修改数据

代码如下(示例):

python">import pymysql
# pymysql实现修改数据
# 触发事务:增加数据insert 、修改数据update、删除数据delete# 1.连接mysql
# con:数据库连接对象
con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test",charset="utf8")# 2.获取游标对象
# c1:游标对象
c1 = con.cursor()# 3.编写sql语句
sql = """update aa set money = 2000 where id=2"""try:# 4.让游标对象执行sql语句c1.execute(sql)# 如果sql语句执行成功,让数据库对象提交事务con.commit()print("执行成功")
except Exception as e:print(e)# 如果sql语句执行失败,让数据库对象将事务进行回滚con.rollback()print("执行失败")# 5.关闭
con.close()

mysql_153">3.pymysql实现删除数据

代码如下(示例):

python">import pymysql
# pymysql实现修改数据
# 触发事务:增加数据insert 、修改数据update、删除数据delete# 1.连接mysql
# con:数据库连接对象
con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test",charset="utf8")# 2.获取游标对象
# c1:游标对象
c1 = con.cursor()# 3.编写sql语句
sql = """delete from aa where id=3"""try:# 4.让游标对象执行sql语句c1.execute(sql)# 如果sql语句执行成功,让数据库对象提交事务con.commit()print("执行成功")
except Exception as e:print(e)# 如果sql语句执行失败,让数据库对象将事务进行回滚con.rollback()print("执行失败")# 5.关闭
con.close()

mysql_187">4.pymysql实现查询数据

  • fetchone()
  • fetchmany()
  • fetchall()
python"># pymysql 实现数据查询
# 会触发事务:增加数据insert,修改数据update,删除数据delete
import pymysqlconn = pymysql.connect(host='localhost', port=3306, user='root', passwd='123456', db='test', charset='utf8')
cur = conn.cursor()
sql = """select * from stu"""# ret : 接收的是查询到的数据条数
ret = cur.execute(sql)# 获取打印的结果-->获取到的结果在游标对象中
# 需要从游标对象中获取数据--->调用方法获取
# 第一个方法:
# fetchone()
# 语法格式:游标对象.fetchone()
# 作用:一次获取一条数据,数据以元组的形式返回
"""for i in range(ret):print(cur.fetchone())
"""
# 第二个方法:
# fetchmany()
# 语法格式:游标对象.fetchmany(num)
# 作用:获取num条数据,所有的数据存放在元组中返回,如果不指定num,则默认获取1条;
#       如果num超出ret数据条数,则获取所有数据,不会报错
"""print(cur.fetchmany(30))"""
# 第三个方法:
# fetchall()
# 语法格式:游标对象.fetchall()
# 作用:获取查询到的所有的数据,以元组的形式返回
print(cur.fetchall())
conn.close()

mysql__228">三、Pymysql 封装

1.封装思路

不触发事务的操作:表结构的操作、创建表……
触发事务的操作:增加数据insert、修改数据update、删除数据delete
调用方法的操作:查询操作


公共:连接数据库、创建游标对象
单独:只执行、执行之后提交、执行之后调用方法获取输出


公共的内容:init初始化方法实现公共的内容
单独的内容:单独的实例方法实现

2.封装实现

python"># pymysql封装
import pymysqlclass MyPyMsql:# 公共内容编写到init中,init在方法前被调用def __init__(self):try:# try中存放可能出现问题的代码# 1.连接数据库self.con = pymysql.connect(host="localhost",port=3306,user="root",password="123456",database="test01",charset="utf8")print("数据库连接成功")except Exception as e:# 如果代码真的出现问题执行except中的代码print(e)print("数据库连接失败")else:# 如果代码没有出现问题则执行else中的代码# 2.获取游标对象self.c1 = self.con.cursor()print("游标对象获取成功")# 单独操作编写到实例方法中# 1.执行即可def only_exe(self,sql):# 让游标对象执行sql语句self.c1.execute(sql)print("执行成功")# 2.执行判断是否成功,进行提交回滚def need_com(self,sql):try:self.c1.execute(sql)self.con.commit()print("执行成功")except Exception as e:print(e)print("执行失败")self.con.rollback()# 3.执行结束需要调用方法获取数据def need_fet(self,sql):self.c1.execute(sql)data = self.c1.fetchall()# 由于具体功能中可能会获取数据并对数据进行操作# 所以数据返回方便获取数据;直接打印无法获取return datamy = MyPyMsql()
my.only_exe("create table a1(id tinyint,name varchar(10))")
my.only_exe("alter table a1 add age tinyint")
my.need_com("insert into a1 value(1,'张三',18),(2,'李四',16)")
my.need_com("update a1 set age=20 where id=2")
print(my.need_fet("select * from a1"))

在这里插入图片描述


http://www.ppmy.cn/server/44863.html

相关文章

pytorch要点和难点具体应用案例

PyTorch是一个开源的Python机器学习库,由Facebook人工智能研究院(FAIR)开发并维护。它基于 Torch,是一个为深度学习而设计的动态图计算框架,特别适用于自然语言处理(NLP)等应用。 PyTorch的主要…

Python散点图矩阵代码模版

本文分享Python seaborn实现散点图矩阵代码模版,节选自👉嫌Matplotlib繁琐?试试Seaborn! 散点图矩阵(scatterplot matrix)展示原始数据中所有变量两两之间关系,可以规避单一统计指标的偏差&…

leetcode——169.多数元素(多解法)

169. 多数元素 题目描述 给定一个大小为 n 的数组 nums ,返回其中的多数元素。多数元素是指在数组中出现次数 大于 ⌊ n/2 ⌋ 的元素。 你可以假设数组是非空的,并且给定的数组总是存在多数元素。 示例 1: 输入:nums [3,2,3]…

使用Golang开发一个HTTP客户端请求命令行工具

什么是Golang Golang,也被称为Go语言,是由Google开发的一种开源的编程语言。它于2007年开始设计,于2009年首次公开发布。Golang被设计成一种通用的编程语言,旨在提供简单、高效和可靠的软件开发方式。Golang具有静态类型、垃圾回…

机械行业工程设计资质乙级需要哪些人员

申请机械行业工程设计资质乙级需要的人员主要包括以下几个方面,具体要求和数量根据参考文章归纳如下: 一、主要专业技术人员 数量要求:主要专业技术人员数量应不少于所申请行业资质标准中主要专业技术人员配备表规定的人数。学历和职称要求…

【赠书第25期】C#项目开发实战(微视频版)

文章目录 前言 1 项目构思与需求分析 1.1 项目构思 1.2 需求分析 2 系统设计 2.1 系统架构设计 2.2 数据库设计 2.3 接口设计 3 编码实现 3.1 环境搭建 3.2 编码规范 3.3 编码实现 4 测试与部署 4.1 单元测试 4.2 系统测试 4.3 部署与上线 5 总结与展望 6 推…

UE5 读取本地图片并转换为base64字符串

调试网址&#xff1a;在线图像转Base64 - 码工具 (matools.com) 注意要加&#xff08;data:image/png;base64,&#xff09; FString UBasicFuncLib::LoadImageToBase64(const FString& ImagePath) {TArray<uint8> ImageData;// Step 1: 读取图片文件到字节数组if (!…

AI创作未来无人驾驶汽车设计的灵感和创意

为了更好地为您的新产品撰写广告文案&#xff0c;请提供以下信息&#xff1a; 产品名称和简要描述目标受众您希望传达的主要信息或卖点文案风格&#xff08;如正式、幽默、亲切等&#xff09;任何特别的品牌元素或口号 这些信息将帮助我为您定制一个吸引人的广告文案。 请为画…