利用Python操作Mysql数据库

news2025/2/25 15:07:29

我们在进行Python编程的时候，时常要将一些数据保存起来，其中最方便的莫过于保存在文本文件了。但是如果保存的文件太大，用文本文件就不太现实了，毕竟打开都是个问题，这个时候我们需要用到数据库。提到数据库，相信大部分人都不会陌生，今天我们要学的就是数据库中小编自认为最棒的Mysql数据库了。

一、下载导入模块

为了让Python与Mysql 交互，这里我们需要用到Pymsql模块才行。

下载模块：

pip install pymysql

导入模块:

 import pymysql

二、创建数据库

打开数据库连接软件 SqlYong，如图：

在这里插入图片描述

输入命令：

CREATE DATABASE IF NOT EXISTS people;

这样就创建了一个people 数据库。

三、创建数据表，并写入数据

USE people;
CREATE TABLE IF NOT EXISTS student(id INT PRIMARY KEY AUTO_INCREMENT,NAME CHAR(10) UNIQUE,score INT NOT NULL,tim DATETIME)ENGINE=INNOBASE CHARSET utf8;
INSERT INTO student(NAME,score,tim)VALUES('fasd',60,'2020-06-01')
SELECT * FROM student;

通过上述操作便创建了一个数据表Student并向其中写入了数据，结果如下：

在这里插入图片描述

我们可以一行代码删除这个插入的 数据：

TRUNCATE student;

四、Mysql与Python建立连接

将下图中的参数依次填入初始化参数中，

在这里插入图片描述

db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')

这样就连接到了people数据库，可以看下连接成功的打印信息：

在这里插入图片描述

可以看到我们打印了Mysql的版本和Host信息。

五、创建游标执行操作

1、创建游标

cur=db.cursor

2、编写插入数据表达式

sql="INSERT INTO student(NAME,score,tim)VALUES('任性的90后boy',100,now())"

3、开启游标事件

cur.begin()

4、执行数据库语句，异常判断

try:
    cur.execute(sql) 执行数据库语句
except Exception as e:
    print(e)
    db.rollback()   发生异常进行游标回滚操作
else:
    db.commit()   提交数据库操作
finally:
    cur.close()  关闭游标
    db.close()  关闭数据库

5、执行插入操作

数据库建立好后，我们可以对它们进行插入数据的操作。

import time
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
sql="INSERT INTO student(NAME,score,tim) VALUES ('%s',%d,'%s')"
data=('HW',90,tt)
try:
  cur.execute(sql%data)
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  cur.close()
  db.close()

在这里插入图片描述

这样就可以将数据插入进去了。我们还可以自定义插入：

import pymysql
import time
tt=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
s=input('string:')
d=input('number:')
sql="INSERT INTO student(NAME,score,tim)VALUES('%s','%s','%s')"
try:
  data=(s,d,tt)
  cur.execute(sql%data)
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  cur.close()
  db.close()

在这里插入图片描述

另外，我们也可以同时插入多条数据，只需先定义好所有的数据，然后在调用即可，这里需要用到插入多条数据的函数Executemany，在这里我插入十万条数据，并测试插入时间，步骤如下：

import pymysql
import time
start=time.time()
tt=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
sql="insert into student(NAME,score,tim)values(%s,%s,%s)"
def get():
  ab=[]
  for y in range(1,100000):
    if y>=100:
      data=('user-'+str(y),str(str(float('%.f'%(y%100)))),tt)
    else:
      data=('user-'+str(y),str(y),tt)
    ab.append(data)
  return ab

try:
  data=get()
  cur.executemany(sql,data)
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  print('插入数据完毕')
  cur.close()
  db.close()
  end=time.time()
  print('用时：',str(end-start))

6、执行更新操作

有些数据我们觉得它过时了，想更改，就要更新它的数据。

import time
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
sql="update student set name='zjj' where score=100 " 当分数是100分的时候将名字改为zjj
try:
  cur.execute(sql%data)
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  cur.close()
  db.close()

在这里插入图片描述

7、执行删除操作

有时候一些数据如果对于我们来说没有任何作用了的话了，我们就可以将它删除了，不过这里是删除数据表中的一条记录。

import pymysql
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
sql="delete from student where name='fasd';" 当名字等于‘fasd’的时候删除这个记录
try:
  cur.execute(sql)
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  cur.close()
  db.close()

在这里插入图片描述

你也可以删除表中所有的数据，只需将Sql语句改为:

sql='TRUNCATE student;'

当然你也可以删除表，但是一般不建议这样做，以免误删：

 DROP TABLE IF EXISTS  student;

8、执行查询操作

有时候我们需要对数据库中的数据进行查询，Python也能轻松帮我们搞定。

import pymysql
import time
tt=time.strftime('%Y-%m-%d %H:%M:%S',time.localtime(time.time()))
db=pymysql.connect(host='localhost',user='root',password='123456',port=3306,db='people')
cur=db.cursor()
db.begin()
sql="select * from student;"
try:
  cur.execute(sql)
  res=cur.fetchall() 查询数据库中的数据
  for y in res:
    print(y) 打印数据库中标的所有数据，以元祖的形式
except Exception as e:
  print(e)
  db.rollback()
else:
  db.commit()
finally:
  cur.close()
  db.close()

六、总结

在我们进行网络爬虫的时候，需要保存大量数据，这个时候数据库就派上用场了，可以更方便而且更快捷保存数据。

在这里插入图片描述

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

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

相关文章

怎样从零开始编译一个魔兽世界开源服务端Windows

怎样从零开始编译一个魔兽世界开源服务端Windows

怎样从零开始编译一个魔兽世界开源服务端Windows 第二章：编译和安装 我是艾西，上期我们讲述到编译一个魔兽世界开源服务端环境准备，那么今天跟大家聊聊怎么编译和安装我们直接进入正题（上一章没有看到的小伙伴可以点我主页查看&…
阅读更多...
haproxy负载均衡+keepalived高可用

haproxy负载均衡+keepalived高可用

LVS和haproxy、nginx做负载均衡时的区别 调度算法 LVS:轮询(rr)、加权轮询(wrr)、最少连接(lc)、加权最少连接(wlc)、源地址哈希值(sh)、目的地址哈希（dh） haproxy:轮询（roundrobin)、加权轮询（static-rr)、最少连接&#xff08…
阅读更多...
2023有潜力的新药都有哪些？新药筛选方法总结

2023有潜力的新药都有哪些？新药筛选方法总结

2023有潜力的新药都有哪些？这是一道蕴含无限可能性和未知挑战的问题。新药研发是制药公司不断追求的目标，每一次成功都可以带来巨额利润，改善患者生命质量，成就公司声誉。但与此同时，新药研发风险也是极大的&#xff0…
阅读更多...
电梯导航栏的实现

电梯导航栏的实现

点击跳到指定位置类似于电梯导航 .w {width: 1200px;margin: 0 auto; } .fixedtool {position: fixed;top: 100px;left: 50%;margin-left: -676px;width: 66px;background-color: #fff;display: none; }.fixedtool li {height: 32px;line-height: 32px;text-align: center;fo…
阅读更多...
基于dsp+fpga的半导体运动台高速数据采集FPGA endac设计（三）

基于dsp+fpga的半导体运动台高速数据采集FPGA endac设计（三）

EnDat 双向串行通信协议的实现 数据（测量值或参数）可以在位置编码器和 EnDat 协议内核之间进行双向传输， EnDat 协议内核的收发单元支持 RS-485 差分信号传输，数据传输与传感伺服控制系统 生成的时钟脉冲同步。传输的数据…
阅读更多...
如何将Postman API测试转换为JMeter以进行扩展

如何将Postman API测试转换为JMeter以进行扩展

许多测试工程师使用Postman进行API测试自动化。他们发现端点，发出请求，创建测试数据，运行回归测试，使用Newman等实现API测试的持续集成。但是，Postman有一定的测试限制。希望获得更多负载测试能力的开发人员&#xff0…
阅读更多...
系统集成项目管理工程师 笔记（第10章：项目质量管理）

系统集成项目管理工程师 笔记（第10章：项目质量管理）

文章目录 10.1.2 质量管理及其 发展史 35610.1.3 项目质量管理 35810.2.2 规划质量管理的输入 35910.2.3 规划质量管理的工具与技术 3601、成本效益分析法2、质量成本法（一致性成本【预防、评价】 和 非一致性成本【内部、外部】）3、七种基本质量工具&am…
阅读更多...
数字设计小思 - 谈谈时钟：数字系统的心脏

数字设计小思 - 谈谈时钟：数字系统的心脏

前言 本系列整理数字系统设计的相关知识体系架构，为了方便后续自己查阅与求职准备。时钟作为数字系统中的“心脏”，其设计的质量好坏直接关乎整个系统的稳定性，本文主要介绍了数字设计中的常见的时钟产生电路和时钟类型，并进行相…
阅读更多...
音视频八股文（7）-- 音频aac adts

音视频八股文（7）-- 音频aac adts

AAC介绍 AAC（Advanced Audio Coding）是一种现代的音频编码技术，用于数字音频的传输和存储领域。AAC是MPEG-2和MPEG-4标准中的一部分，可提供更高质量的音频数据，并且相比于MP3等旧有音频格式，AAC需要更少的…
阅读更多...
【经典题】二叉搜索树与双向链表

【经典题】二叉搜索树与双向链表

二叉搜索树与双向链表链接 解题思路 思路1 ： 中序遍历，将节点放进vector中，再改链接关系，这很容易想出并解决，但这样明显不符合题意。 思路2： 这道题目要求将一个二叉搜索树转换成一个排序的双向链表&a…
阅读更多...
php连接sqlserver

php连接sqlserver

1.使用工具 Wampserver--3.3 sqlserver2023 php7.4.33 2.连接流程 1.下载Microsoft Drivers for PHP for SQL Server 下载地址：下载 Microsoft Drivers for PHP for SQL Server - PHP drivers for SQL Server | Microsoft Learn 2.下载Microsoft ODBC Driver …
阅读更多...
简记二分算法模板与代码案例：整数二分和浮点数二分

简记二分算法模板与代码案例：整数二分和浮点数二分

本文以 Java 语言实现，整理的代码模板适用于编程竞赛。对代码模板原理的讲解不多，主要记录一下如何使用。 目录 一、算法模板 （1）整数二分 （2）浮点数二分 二、例题 例题：acwing-789.数的范…
阅读更多...
开源网安入选“2023年中国信通院开源供应商名录”

开源网安入选“2023年中国信通院开源供应商名录”

近日，为进一步推进开源供应链安全合规发展，中国信息通信研究院云大所发布了“2023年中国信通院开源供应商名录”（简称名录），名录供应商均为通过可信开源供应链系列评估的企业。名录范围涵盖云计算、大数据、中间件、数…
阅读更多...
【致敬未来的攻城狮计划】第1期 作业汇总贴 + 获奖公布

【致敬未来的攻城狮计划】第1期 作业汇总贴 + 获奖公布

​ 文章目录 一、写在前面二、种子学员介绍三、作业贴汇总四、小小总结五、获奖公布六、学员有话说七、特别致谢 一、写在前面 时间过得真快，距离 【致敬未来的攻城狮计划】第1期 的发起，已经过去一个多月了，而第1期的真正学习考核期也将在…
阅读更多...
虹科案例 | 如何通过智能、非接触式测量解决方案，提高起重机的安全和效率？

虹科案例 | 如何通过智能、非接触式测量解决方案，提高起重机的安全和效率？

PART 1 案例详情 自建造初期以来，起重机行业已经走了很长一段路。技术的使用在行业进步中发挥了重要作用，降低了使用桥式起重机的危险性。特别是，智能、非接触式测量解决方案通过使用高架升降机更安全、更高效、更高效，为行业的进…
阅读更多...
如何将化学分子SMILES字符串转化为Pytorch图数据结构——ESOL分子水溶性数据集解析

如何将化学分子SMILES字符串转化为Pytorch图数据结构——ESOL分子水溶性数据集解析

硬核原创，转载请注明出处： https://leytton.blog.csdn.net/article/details/130406553 一、前言 在用Pytorch图神经网络对化学分子进行数据分析的时候，经常使用现有的数据集。看到自动处理完毕的数据结构，里面的特征值让我们一脸…
阅读更多...
springsecurity工作流程

springsecurity工作流程

Spring Security 的工作流程如下: 1.当用户请求一个受保护的资源时,Spring Security 的过滤器链会拦截该请求。 2.然后 Spring Security 会判断该请求是否认证(authenticated)和授权(authorized)。 认证(Authentication):验证用户身份,判断用户是否能登录系统。Spring Securi…
阅读更多...
Linux应用编程（线程同步）（互斥锁）

Linux应用编程（线程同步）（互斥锁）

对于一个单线程进程来说，它不需要处理线程同步的问题，所以线程同步是在多线程环境下可能需要注意的一个问题。线程的主要优势在于，资源的共享性，譬如通过全局变量来实现信息共享，不过这种便捷的共享是有代价的&#xf…
阅读更多...
docker网桥冲突解决方法

docker网桥冲突解决方法

Docker网桥网段冲突导致访问不到容器问题 三种情况 一、docker0所用网段与局域网所用网段相同，导致网桥冲突，这会造成冲突网段无法访问docker服务。 解决办法： 1.停止docker，删除冲突网桥 systemctl stop docker ip link del doc…
阅读更多...
干货 | 中科院心理所考研复试经验分享

干货 | 中科院心理所考研复试经验分享

Hello，大家好！ 这里是壹脑云科研圈，我是喵君姐姐～ 此时此刻，23年考研的小伙伴估计正在为复试进行准备吧，大家都准备得怎么样了呢？ 今天为大家带来的就是我国顶级心理学研究结构—中科院心理所…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023