13 pymysql模块

pymysql模块

pymysql是一个第三方库，如果自己的计算机上没有可以在终端使用命令进行安装。

sudo pip3 install pymysql
  • pymysql使用流程
  1. 建立数据库连接：db = pymysql.connect(…)
  2. 创建游标对象：cur = db.cursor()
  3. 游标方法: cur.execute(“insert …”)
  4. 提交到数据库或者获取数据 : db.commit() / cur.fetchall()
  5. 关闭游标对象 ：cur.close()
  6. 断开数据库连接 ：db.close()
  • 常用函数
db = pymysql.connect(参数列表)
功能: 链接数据库host ：主机地址,本地 localhost
port ：端口号,默认3306
user ：用户名
password ：密码
database ：库
charset ：编码方式,推荐使用 utf8cur = db.cursor() 
功能： 创建游标
返回值：返回游标对象,用于执行具体SQL命令

cur.execute(sql,args_list) 
功能： 执行SQL命令
参数： sql sql语句args_list  列表，用于给sql语句传递参量cur.executemany(sql命令,args_list)
功能： 多次执行SQL命令，执行次数由列表中元组数量决定
参数： sql sql语句args_list  列表中包含元组 每个元组用于给sql语句传递参量，一般用于写操作。
db.commit() 提交到数据库执行，必须支持事务操作才有效
db.rollback() 回到原来的数据形态，必须支持事务操作才有效
cur.fetchone() 获取查询结果集的第一条数据，查找到返回一个元组否则返回None
cur.fetchmany(n) 获取前n条查找到的记录，返回结果为元组嵌套元组， ((记录1),(记录2))，查询不到内容返回空元组。
cur.fetchall() 获取所有查找到的记录，返回结果形式同上。
cur.close() 关闭游标对象
db.close() 关闭数据库连接
连接关闭数据库示例："""
数据库操作基本结构示例
"""
import pymysqlkwargs = {"host": "localhost","port": 3306,"user": "root","passwd": "123456","database": "stu","charset": "utf8"
}
# 链接数据库
db = pymysql.connect(**kwargs)# 生成游标  游标：调用sql操作数据得到操作结果的对象
cur = db.cursor()# 操作数据 读 / 写# 关闭
cur.close()
db.close()

数据库读操作示例：
"""
数据库读操作示例
"""
import pymysqlkwargs = {"host": "localhost","port": 3306,"user": "root","passwd": "123456","database": "stu","charset": "utf8"
}
# 链接数据库
db = pymysql.connect(**kwargs)# 生成游标  游标：调用sql操作数据得到操作结果的对象
cur = db.cursor()# 操作数据 读
# sql = "select name,age,score from class where score>80;"
# cur.execute(sql) # 执行语句# 给sql语句传值 使用第二个参数按照位置给sql语句%s传值
sql = "select name,age,score from class " \"where score>%s and sex=%s;"
cur.execute(sql,[80,'m'])# 一个查询结果
one = cur.fetchone()
print(one)# 多个查询结果
many = cur.fetchmany(2)
print(many)# 所有查询结果
all = cur.fetchall()
print(all)# 迭代获取结果
# for row in cur:
#     print(row)# 关闭
cur.close()
db.close()

数据库读操作示例：在stu下创建一个数据表user 有三个字段 ：id  user  passwordcreate table user(
id int primary key auto_increment,
user varchar(30),
password char(16));其中有若干数据：insert into user values
(1,"Tom",'abc'),
(2,"Abby","321");编写一个函数，使用input分别输入用户名和密码
验证是否可以登录成功，如果可以则返回True
不可以返回False
"""
import pymysqlclass User:def __init__(self):kwargs = {"host": "localhost","port": 3306,"user": "root","passwd": "123456","database": "stu","charset": "utf8"}self.db = pymysql.connect(**kwargs)self.cur = self.db.cursor()def close(self):self.cur.close()self.db.close()def login(self,name, passwd):sql="select user from user " \"where user=%s and password=%s;"self.cur.execute(sql,[name,passwd])# (name,) or  Noneif self.cur.fetchone():return Trueelse:return Falseif __name__ == '__main__':user = User()# 登录验证name=input("用户名：")passwd=input("密 码：")print(user.login(name,passwd))user.close()

文件写操作示例：
"""
数据库写操作示例
pymysql进行写操作如果数据表支持事务会自动开启事务
需要commit提交才能生效
如果数据表不支持事务则直接execute执行则生效
"""
import pymysqlkwargs = {"host": "localhost","port": 3306,"user": "root","passwd": "123456","database": "stu","charset": "utf8"
}
# 链接数据库
db = pymysql.connect(**kwargs)# 生成游标  游标：调用sql操作数据得到操作结果的对象
cur = db.cursor()# 操作数据  写  insert delete update
# try:
#     sql = "update class set score=%s where name=%s;"
#     cur.execute(sql,[99,"Tom"])
#     db.commit() # 提交事务
# except Exception as e:
#     print(e)
#     db.rollback()# 批量写操作
data = [("zhang",'19','w',70),("wang",'18','m',71),("li",'20','w',72)
]
try:sql = "insert into class " \"(name,age,sex,score) " \"values (%s,%s,%s,%s);"cur.executemany(sql,data) # 多次执行语句db.commit() # 提交事务
except Exception as e:print(e)db.rollback()# 关闭
cur.close()
db.close()

写操作示例：
创建数据库 dict，数据库中创建数据表 words 字段为 ： id  word  mean
编写一个程序，将dict.txt单词本中的单词存储到这个数据表里库 ： dict
create database dict charset=utf8;表 ： words -->  id  word  mean
create table words (
id int primary key auto_increment,
word char(30),
mean varchar(512)
);import pymysql
import reclass Dict:def __init__(self):self.kwargs = {"host": "localhost","port": 3306,"user": "root","password": "123456","database": "dict","charset": "utf8"}self.connect()# 完成数据库连接def connect(self):self.db = pymysql.connect(**self.kwargs)self.cur = self.db.cursor()# 关闭def close(self):self.cur.close()self.db.close()# 插入数据  提取文件中的单词def insert_words(self, filename):file = open(filename)words = []  # [(word,mean),(word,mean)...]for line in file:tmp = re.findall(r"(\w+)\s+(.*)", line)words += tmp  # 大列表file.close()self.insert_data(words)def insert_data(self, words):try:sql = "insert into words (word,mean) values (%s,%s);"self.cur.executemany(sql, words)self.db.commit()  # 提交事务except Exception as e:print(e)self.db.rollback()  # 事务回滚if __name__ == '__main__':dict = Dict()dict.insert_words("dict.txt")  # 插入单词数据dict.close()
  • 文件存储
    • 存储文件路径
      • 优点：节省数据库空间，提取方便
      • 缺点：文件或者数据库发生迁移会导致文件丢失
    • 存储文件本身
      • 优点：安全可靠，数据库在文件就在
      • 缺点：占用数据库空间大，文件存取效率低
静态文件存储示例："""
存取二进制数据
"""import pymysqlkwargs = {"host": "localhost","port": 3306,"user": "root","password": "123456","database": "stu","charset": "utf8"
}# 连接数据库
db = pymysql.connect(**kwargs)# 创建游标  使用sql操作数据得到结果的对象
cur = db.cursor()# 存储图片
# with open("left.png",'rb') as f:
#     data = f.read()
# sql = "update class set image=%s where id=4;"
# cur.execute(sql,[data])
# db.commit()# 取出图片
sql = "select image from class where id=4;"
cur.execute(sql)
data = cur.fetchone()[0]
with open("xxx.png",'wb') as f:f.write(data)# 关闭
cur.close()
db.close()

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/734323.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

亲测：腾讯云8核16G服务器价格1668元一年送3个月，购买需谨慎

亲测：腾讯云8核16G服务器价格1668元一年送3个月，购买需谨慎

腾讯云8核16G轻量服务器CPU性能如何？18M带宽支持多少人在线？轻量应用服务器具有100%CPU性能，18M带宽下载速度2304KB/秒，折合2.25M/s，系统盘为270GB SSD盘，月流量3500GB，折合每天116.6GB流量&…
阅读更多...
【c++11线程库的使用】

【c++11线程库的使用】

#include<iostream> #include<thread> #include<string> using namespace std; void hello(string msg) { for (int i 0; i < 1000; i) { cout << i; cout << endl; } } int main() { //1.创建线程 thread …
阅读更多...
STM32---通用定时器（一）理论基础

STM32---通用定时器（一）理论基础

写在前面&#xff1a;在STM32F103中有众多的定时器&#xff0c;其中包括两个基本定时器&#xff0c;基本定时器的内容已经在上节进行了介绍&#xff0c;基本定时器的功能、结构、使用都较为简单。而STM32F1中还含有4个通用定时器&#xff08;TIM2\3\4\5&#xff09;,这些定时器…
阅读更多...
GEE案例——如何对矢量集合（面状）提取中心点并返回给矢量（添加经纬度属性信息）

GEE案例——如何对矢量集合（面状）提取中心点并返回给矢量（添加经纬度属性信息）

简介 很多时候我们会遇到一个需求，就是将我们已经获取的矢量集合进行一个中心点经纬度的获取，这个过程，最简单的方式就是通过我们一个个通过交互式的地图去点击，查看获取，但是这样的工作量有点大，而很多时候我们分解出的矢量是超级多的，比如说上百个成千个，这对于我们…
阅读更多...
探讨系统测试的最佳实践与思维模式！

探讨系统测试的最佳实践与思维模式！

这是测试活动过程详解系列的最后一篇文章。之前的想法&#xff0c;是对测试过程各重要环节进行拆解&#xff0c;然后介绍这个环节重点要做的事情&#xff0c;为什么要做这些事&#xff0c;以及注意事项。 前面几篇文章分别介绍了单元测试、集成测试、回归测试阶段要解决的问题…
阅读更多...
WebStorm 开启 eslint 自动格式化配置

WebStorm 开启 eslint 自动格式化配置

之后在 ctrl s保存之后&#xff0c;webstorm 都会根据eslint 的规则自动格式化。
阅读更多...
长见识了Python闭包函数

长见识了Python闭包函数

1.闭包 如果一个函数内部定义了另外一个函数&#xff0c;那么外边的函数叫做外函数&#xff0c;内部的函数叫做内函数 如果在一个外部函数当中定义了一个内部函数&#xff0c;并且外部函数的返回值是内部函数&#xff0c;这就构成了一个闭包&#xff0c;内部函数被称为闭包函数…
阅读更多...
计算机等级考试：信息安全技术 知识的四

计算机等级考试：信息安全技术 知识的四

1、ISMS所体现的思想是预防控制为主 2、电子认证服务提供者应当妥善保存与认证相关的信息&#xff0c;信息保存期限至少为电子签名认证证书失效后5年。 3、《电子签名法》 第二十三条&#xff0c;电子认证服务提供者拟暂停或者终止电子认证服务的&#xff0c;应当在暂停或者终…
阅读更多...
子类的继承性

子类的继承性

继承性 类有两种重要的成员&#xff1a; 成员变量和方法 子类的成员 ① 自己声明定义 ②从父类继承 ① 成员变量的继 把继承来的变量作为 自己的一个成员变量 &#xff08;如同在子类中直接声明一样&#xff09;&#xff1b; 可被子类中自定义的任何实例方法操作 。 ② 方法…
阅读更多...
实验一：华为VRP系统的基本操作

实验一：华为VRP系统的基本操作

1.1实验介绍 1.1.1关于本实验 本实验通过配置华为设备&#xff0c;了解并熟悉华为VRP系统的基本操作 1.1.2实验目的 理解命令行视图的含义以及进入离开命令行视图的方法 掌握一些常见的命令 掌握命令行在线帮助的方法 掌握如何撤销命令 掌握如何使用命令快捷键 1.1.3实验组网 …
阅读更多...
Java算法-力扣leetcode-45. 跳跃游戏 II

Java算法-力扣leetcode-45. 跳跃游戏 II

一、java8原子类LongAdder 在Java并发编程(2)中有关于AtomicInteger的介绍. AtomicInteger通过CAS非阻塞的原子操作提升了并发性能. 但随着线程数量增大对共享资源的竞争提升,大量线程竞争失败会进入到自旋中,消耗了cpu资源. JDK8中新增了原子类LongAdder, 弥补AtomicLong的上…
阅读更多...
人不想做事情的时候，可能是他/她正在经历情绪

人不想做事情的时候，可能是他/她正在经历情绪

目录 情绪是什么？ 计算机也有“情绪”？ 情绪如何影响人的行为？ 受情绪困扰时人为何不想做事？ 如何排解情绪困扰？
阅读更多...
基于javaweb+springboot开发的城市地名地址信息管理系统设计和实现

基于javaweb+springboot开发的城市地名地址信息管理系统设计和实现

基于javaweb(springboot)城市地名地址信息管理系统设计和实现 博主介绍&#xff1a;多年java开发经验&#xff0c;专注Java开发、定制、远程、文档编写指导等,csdn特邀作者、专注于Java技术领域 作者主页 央顺技术团队 Java毕设项目精品实战案例《1000套》 欢迎点赞 收藏 ⭐留言…
阅读更多...
基于GAN对抗网进行图像修复

基于GAN对抗网进行图像修复

一、简介 使用PyTorch实现的生成对抗网络&#xff08;GAN&#xff09;模型&#xff0c;包括编码器&#xff08;Encoder&#xff09;、解码器&#xff08;Decoder&#xff09;、生成器&#xff08;ResnetGenerator&#xff09;和判别器&#xff08;Discriminator&#xff09;。…
阅读更多...
Dubbo的线程池策略

Dubbo的线程池策略

1 Dubbo的线程池概述 这里将要讲述的线程池指Dubbo服务端使用某些线程模型&#xff08;如 all 模型&#xff09;时用到的业务线程池。ThreadPool 是一个扩展接口SPI。 SPI(value "fixed", scope ExtensionScope.FRAMEWORK) public interface ThreadPool {/*** Th…
阅读更多...
基于深度学习的苹果叶片病害检测系统（含UI界面、yolov8、Python代码、数据集）

基于深度学习的苹果叶片病害检测系统（含UI界面、yolov8、Python代码、数据集）

项目介绍 项目中所用到的算法模型和数据集等信息如下&#xff1a; 算法模型&#xff1a;     yolov8 yolov8主要包含以下几种创新&#xff1a;         1. 可以任意更换主干结构&#xff0c;支持几百种网络主干。 数据集&#xff1a;     网上下载的数据集&#x…
阅读更多...
基于极大似然算法的系统参数辨识matlab仿真

基于极大似然算法的系统参数辨识matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.本算法原理 5.完整程序 1.程序功能描述 基于极大似然算法的系统参数辨识。对系统的参数a1&#xff0c;b1&#xff0c;a2&#xff0c;b2分别进行估计&#xff0c;计算估计误差以及估计收敛曲线&#xff0…
阅读更多...
使用yarn创建vite+vue3electron多端运行

使用yarn创建vite+vue3electron多端运行

文章目录 第一步 使用yarn创建vite+vue3项目遇到创建报错看第二步 引入electron第三步 创建main.js在electron下面的main.js写入下面代码第四步 安装同时运行多条命令npm包&&修改package.json文件npm包增加一条electron运行脚本命令效果图第一步 使用yarn创建vite+vue3…
阅读更多...
【pytorch可视化工具】

【pytorch可视化工具】

TensorboardX 在PyTorch中&#xff0c;模型训练的可视化通常通过TensorBoard或Visdom等工具实现。以下是如何使用TensorBoard进行模型训练可视化的步骤&#xff1a; 使用TensorboardX与PyTorch配合 确保已经安装了tensorboard和tensorboardX库。 pip install tensorboard p…
阅读更多...
springboot Mongo大数据查询优化方案

springboot Mongo大数据查询优化方案

前言 因为项目需要把传感器的数据保存起来&#xff0c;当时设计的时是mongo来存储&#xff0c;后期需要从mongo DB里查询传感器的数据记录。由于传感器每秒都会像mongo数据库存500条左右的数据&#xff0c;1天就有4320万条数据&#xff0c;要想按照时间条件去查询&#xff0c;…
阅读更多...
最新文章

Copyright @ 2022~2023