【Python】从入门到上头—mysql数据库操作模块mysql-connector和PyMySQL应用场景 （15）

news2024/11/30 6:38:01

mysql-connector

MySQL官方提供了mysql-connector-python驱动

  1. 安装驱动

    python -m pip install mysql-connector

  2. 连接数据库获取连接

    import mysql.connector

db = mysql.connector.connect(
    host="localhost", #ip
    user="root", #用户名
    passwd="root",#密码
    database="python_test",#连接数据库
    auth_plugin='mysql_native_password'
)
#获取游标
cursor = db.cursor()

创建数据库

cursor.execute("CREATE DATABASE python_test")

输出所有数据库列表：

cursor.execute("SHOW DATABASES")
for x in cursor:
    print(x)
"""
('basic_project',)
('ceam_mall2',)
('information_schema',)
('jwt-demo',)
('liugh',)
('mysql',)
('niu_b_xx_hou',)
"""

创建数据表

cursor.execute("CREATE TABLE sites (name VARCHAR(255), url VARCHAR(255))")

输出所有数据库表：

cursor.execute("SHOW TABLES")
for x in cursor:
    print(x)
#('sites',)

主键设置

cursor.execute("ALTER TABLE sites ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

插入数据

#sql
sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
#占位符插入数据
val = ("RUNOOB", "https://www.baidu.com")
#执行sql
cursor.execute(sql, val)

db.commit()
print(cursor.rowcount, "记录插入成功。")

批量插入

  • 批量插入使用 executemany() 方法，该方法的第二个参数是一个元组列表，包含了我们要插入的数据：
sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
val = [
    ('Google', 'https://www.google.com'),
    ('Github', 'https://www.github.com'),
    ('Taobao', 'https://www.taobao.com'),
    ('stackoverflow', 'https://www.stackoverflow.com/')
]
#执行sql
cursor.executemany(sql, val)
#提交事务: 数据表内容有更新，必须使用到该语句
db.commit()
print(cursor.rowcount, "记录插入成功。")

如果我们想在数据记录插入后，获取该记录的 ID ，可以使用以下代码：

sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
val = ("Zhihu", "https://www.zhihu.com")
cursor.execute(sql, val)
db.commit()
print("1 条记录已插入, ID:", cursor.lastrowid)

查询数据

cursor.execute("SELECT * FROM sites")
result = cursor.fetchall()  # fetchall() 获取所有记录
for x in result:
	print(x)
"""
('RUNOOB', 'https://www.runoob.com', 1)
('Google', 'https://www.google.com', 2)
('Github', 'https://www.github.com', 3)
('Taobao', 'https://www.taobao.com', 4)
('stackoverflow', 'https://www.stackoverflow.com/', 5)
('Zhihu', 'https://www.zhihu.com', 6)
"""

如果我们只想读取一条数据，可以使用 fetchone() 方法：

cursor.execute("SELECT * FROM sites")
result = cursor.fetchone()
print(result)

为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义查询的条件：

sql = "SELECT * FROM sites WHERE name = %s"
na = ("RUNOOB",)
cursor.execute(sql, na)
result = cursor.fetchall()
for x in result:
    print(x)

删除

sql = "DELETE FROM sites WHERE name = %s"
na = ("stackoverflow",)
cursor.execute(sql, na)
db.commit()
print(cursor.rowcount, " 条记录删除")

更新

sql = "UPDATE sites SET name = %s WHERE name = %s"
val = ("Zhihu", "ZH")
cursor.execute(sql, val)
db.commit()
print(cursor.rowcount, " 条记录被修改")

关闭连接

#最后一定要关闭数据库连接
db.close()

Python连接MySQL报错：mysql.connector.errors.NotSupportedError: Authentication plugin ‘caching_sha2_password’ is not supported

  • 添加一句语句（auth_plugin=‘mysql_native_password’），添加位置如下代码：

在这里插入图片描述

小结

  • 执行INSERT/UPDATE/DELETE等操作后要调用commit()提交事务；
  • MySQL的SQL占位符是%s。

PyMySQL

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2 中则使用 mysqldb。

  • PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。

  1. 安装

    pip3 install PyMySQL

  2. 数据库连接

    import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='root',
                     password='root',
                     database='python_test')
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
 
# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")
 
# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
 
print ("Database version : %s " % data)
 
# 关闭数据库连接
db.close()

创建数据库表

import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
 
# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
 
# 使用预处理语句创建表
sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""
 
cursor.execute(sql)
 
# 关闭数据库连接
db.close()

数据库插入操作

import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()
 
# 关闭数据库连接
db.close()

以上例子也可以写成如下形式：

import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 插入语句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
       LAST_NAME, AGE, SEX, INCOME) \
       VALUES ('%s', '%s',  %s,  '%s',  %s)" % \
       ('Mac', 'Mohan', 20, 'M', 2000)
try:
   # 执行sql语句
   cursor.execute(sql)
   # 执行sql语句
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
 
# 关闭数据库连接
db.close()

数据库查询操作

  • Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。

    • fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
    • fetchall(): 接收全部的返回结果行.
    • rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。

查询EMPLOYEE表中salary（工资）字段大于1000的所有数据：

import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE \
       WHERE INCOME > %s" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
       # 打印结果
      print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \
             (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fetch data")
 
# 关闭数据库连接
db.close()

数据库更新操作

  • 将 TESTDB 表中 SEX 为 ‘M’ 的 AGE 字段递增 1：
import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
 
# 关闭数据库连接
db.close()

删除操作

  • 删除数据表 EMPLOYEE 中 AGE 大于 20 的所有数据：
import pymysql
 
# 打开数据库连接
db = pymysql.connect(host='localhost',
                     user='testuser',
                     password='test123',
                     database='TESTDB')
 
# 使用cursor()方法获取操作游标 
cursor = db.cursor()
 
# SQL 删除语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
 
# 关闭连接
db.close()

执行事务

  • Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。
# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

  • 对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。

    • commit()方法提交当前游标所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

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

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

相关文章

Python的命令行参数

Python的命令行参数

Python的命令行参数，提供了很多有用的功能，可以方便调试和运行，通过man python就能查看，以下是一些常用参数使用实例和场景: 1. -B参数 在import时候，不产生pyc或者pyo文件: 比如有程序main.py如下: from Hello im…
阅读更多...
SSM - Springboot - MyBatis-Plus 全栈体系（七）

SSM - Springboot - MyBatis-Plus 全栈体系（七）

第二章 SpringFramework 四、SpringIoC 实践和应用 3. 基于 注解 方式管理 Bean 3.4 实验四：Bean 属性赋值：基本类型属性赋值（DI） Value 通常用于注入外部化属性 3.4.1 声明外部配置 application.properties catalog.nameM…
阅读更多...
UG\NX二次开发 获取装配部件的相关信息UF_ASSEM_ask_component_data

UG\NX二次开发 获取装配部件的相关信息UF_ASSEM_ask_component_data

文章作者：里海 来源网站：王牌飞行员_里海_里海NX二次开发3000例,里海BlockUI专栏,C\C++-CSDN博客 简介： UG\NX二次开发 获取装配部件的相关信息UF_ASSEM_ask_component_data 包括：零件名称、引用集名称、实例名称、组件的位置、坐标系矩阵、转换矩阵。 效果： 代…
阅读更多...
Docker基础学习

Docker基础学习

Docker 学习目标： 掌握Docker基础知识，能够理解Docker镜像与容器的概念 完成Docker安装与启动 掌握Docker镜像与容器相关命令 掌握Tomcat Nginx 等软件的常用应用的安装 掌握docker迁移与备份相关命令 能够运用Dockerfile编写创建容器的脚本 能够…
阅读更多...
并联电容器交流耐压试验方法

并联电容器交流耐压试验方法

对被试并联电容器两极进行充分放电。 检查电容器外观、 污秽等情况, 判断电容器是否满足试验要求状态。 用端接线将并联电容器两极短接连接湖北众拓高试工频耐压装置高压端, 外壳接地。 接线完成后经检查确认无误, 人员退出试验范围。 接入符合测试设备的工作电源，…
阅读更多...
Java（二）--面向对象

Java（二）--面向对象

十.封装 1.访问权限不用加 在c中是访问权限&#xff1a; 属性/行为&#xff1a; class Person{public:void speak(){cout<<"666";} }; 在Java中是访问权限 属性/行为&#xff1a; class Person{public void speak(){cout<<"666";} }; 2.…
阅读更多...
管理类联考——数学——汇总篇——知识点突破——代数——数列

管理类联考——数学——汇总篇——知识点突破——代数——数列

⛲️ 一、考点讲解 1.数列的定义 按一定次序排列的一列数称为数列。 一般形式&#xff1a; a 1 &#xff0c; a 2 &#xff0c; a 3 &#xff0c; … &#xff0c; a n &#xff0c; … &#xff0c; a_1&#xff0c;a_2&#xff0c;a_3&#xff0c;…&#xff0c;a_n&#xf…
阅读更多...
ICCV 2023 | 沉浸式体验3D室内设计装修，基于三维布局可控生成最新技术

ICCV 2023 | 沉浸式体验3D室内设计装修，基于三维布局可控生成最新技术

文章链接&#xff1a; https://arxiv.org/abs/2307.09621 360场景布局可控合成&#xff08;360-degree Image Synthesis&#xff09;目前已成为三维计算机视觉领域一个非常有趣的研究方向&#xff0c;在虚拟三维空间中沉浸式的调整和摆放场景对象&#xff0c;可以为用户带来身临…
阅读更多...
线性代数的本质(八)——内积空间

线性代数的本质(八)——内积空间

文章目录 内积空间内积空间正交矩阵与正交变换正交投影施密特正交化实对称矩阵的对角化 内积空间 内积空间 三维几何空间是线性空间的一个重要例子&#xff0c;如果分析一下三维几何空间&#xff0c;我们就会发现它还具有一般线性空间不具备的重要性质&#xff1a;三维几何空…
阅读更多...
Java项目-苍穹外卖-Day12-Apache POI及Excel数据报表

Java项目-苍穹外卖-Day12-Apache POI及Excel数据报表

文章目录 前言工作台需求分析代码导入功能测试 Apache POI介绍入门案例写入excel文件内容读取excel文件 导出运营数据Excel表需求分析代码开发功能测试 前言 最后一天&#xff0c;主要就是数据怎么从后端导出到excel表格&#xff0c;以及工作台内容的开发 工作台 需求分析 代…
阅读更多...
中秋国庆双节邮件营销怎么做？看这里！

中秋国庆双节邮件营销怎么做？看这里！

今年的国庆节恰逢中秋节&#xff0c;因此国家假日办安排国庆中秋连放8天。对于打工人来说&#xff0c;超长的假期是外出旅游、回家探亲好时机&#xff0c;可是对于企业来说&#xff0c;却是一次仅次于春节的营销大战。这个时候企业营销人员当然是要借助各种营销手段来获取流量和…
阅读更多...
高阶导数的概念与公式

高阶导数的概念与公式

目录 高阶导数的概念 常用的高阶导数的公式 隐函数补充 反函数补充 高阶导数的概念 高阶导数是指一阶或二阶及以上的导数。这些导数可以通过连续进行一阶导数的计算来得到。然而&#xff0c;实际计算高阶导数时&#xff0c;存在一些问题&#xff0c;例如对抽象函数高阶导数…
阅读更多...
测试-----selenuim webDriver

测试-----selenuim webDriver

文章目录 1.页面导航2.元素定位3. 浏览器操作4.获取元素信息5. 鼠标的操作6. 键盘操作7. 元素等待8.下拉框9.弹出框10.滚动条11.frame处理12.验证码处理&#xff08;cookie&#xff09; 1.页面导航 首先是导入对应的包 :from selenium import webdriver然后实例化:driver web…
阅读更多...
为什么大家都在用 WebP？

为什么大家都在用 WebP？

WebP 是谷歌在 2010 年提出的一种新型的图片格式&#xff0c;放到现在来讲&#xff0c;已经不算是“新”技术了&#xff0c;毕竟已经有了更新的 JPEG XL 和 AVIF 。但是在日常工作中&#xff0c;大家时常会碰到保存下来的图片的后缀是 .webp。那么 WebP 到底有什么魔力&#xf…
阅读更多...
Explain 性能分析

Explain 性能分析

目录 1. 能干什么 2. 如何分析 3. 各字段解释 1. 能干什么 使用 explainsql 的方式&#xff0c;分析查询语句的性能瓶颈。 ① 表的读取顺序&#xff1b; ② 数据读取操作的操作类型&#xff1b; ③ 哪些索引可以使用&#xff1b; ④ 哪些索引被实际使用&#xff1b; ⑤ 表之…
阅读更多...
Latex之在作者名字后面加上OCRID的图标

Latex之在作者名字后面加上OCRID的图标

\usepackage{orcidlink} \author{Bob\textsuperscript{\orcidlink{0000-0000-0000-0000}}}效果如图
阅读更多...
Java8实战-总结27

Java8实战-总结27

Java8实战-总结27 用流收集数据分区分区的优势将数字按质数和非质数分区 用流收集数据 分区 分区是分组的特殊情况&#xff1a;由一个谓词(返回一个布尔值的函数)作为分类函数&#xff0c;它称分区函数。分区函数返回一个布尔值&#xff0c;这意味着得到的分组Map的键类型是B…
阅读更多...
浅谈C++|STL初识篇

浅谈C++|STL初识篇

一.STL的诞生 长久以来&#xff0c;软件界一直希望建立一种可重复利用的东西。 .C的面向对象和泛型编程思想&#xff0c;目的就是复用性的提升 大多情况下&#xff0c;数据结构和算法都未能有一套标准,导致被迫从事大量重复工作 为了建立数据结构和算法的一套标准&#xff0c;诞…
阅读更多...
linux入门---命名管道

linux入门---命名管道

如何创建命名管道 使用mkfifo函数就可以在程序里面创建管道文件&#xff0c;该函数的声明如下&#xff1a; 该函数需要两个参数&#xff0c;第一个参数表示要在哪个路径下创建管道文件并且这个路径得待上管道文件的名字&#xff0c;因为每个文件都有对应的权限&#xff0c;所…
阅读更多...
基于springboot+vue的网络海鲜商城

基于springboot+vue的网络海鲜商城

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战 主要内容&#xff1a;毕业设计(Javaweb项目|小程序等)、简历模板、学习资料、面试题库、技术咨询 文末联系获取 项目介绍…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023