Python 3 教程第33篇（MySQL - mysql-connector 驱动）

Python MySQL - mysql-connector 驱动

MySQL 是最流行的关系型数据库管理系统，如果你不熟悉 MySQL，可以阅读我们的 MySQL 教程。
本章节我们为大家介绍使用 mysql-connector 来连接使用 MySQL， mysql-connector 是 MySQL 官方提供的驱动器。

我们可以使用 pip 命令来安装 mysql-connector：

python -m pip install mysql-connector

使用以下代码测试 mysql-connector 是否安装成功：

demo_mysql_test.py:

import mysql.connector

执行以上代码，如果没有产生错误，表明安装成功。
注意：如果你的 MySQL 是 8.0 版本，密码插件验证方式发生了变化，早期版本为 mysql_native_password，8.0 版本为 caching_sha2_password，所以需要做些改变：

先修改 my.ini 配置：

[mysqld]
default_authentication_plugin=mysql_native_password

然后在 mysql 下执行以下命令来修改密码：

ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '新密码';

更多内容可以参考：Python MySQL8.0 链接问题。

创建数据库连接

可以使用以下代码来连接数据库：
demo_mysql_test.py:

import mysql.connector
mydb = mysql.connector.connect(host="localhost",       # 数据库主机地址user="yourusername",    # 数据库用户名passwd="yourpassword"   # 数据库密码
)
print(mydb)

创建数据库
创建数据库使用 “CREATE DATABASE” 语句，以下创建一个名为 runoob_db 的数据库：

demo_mysql_test.py:

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456"
)
mycursor = mydb.cursor()
mycursor.execute("CREATE DATABASE runoob_db")

创建数据库前我们也可以使用 “SHOW DATABASES” 语句来查看数据库是否存在：
demo_mysql_test.py:
输出所有数据库列表：

import mysql.connectormydb = mysql.connector.connect(host="localhost",user="root",passwd="123456"
)
mycursor = mydb.cursor()
mycursor.execute("SHOW DATABASES")
for x in mycursor:print(x)

或者我们可以直接连接数据库，如果数据库不存在，会输出错误信息：
demo_mysql_test.py:

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)

创建数据表

创建数据表使用 “CREATE TABLE” 语句，创建数据表前，需要确保数据库已存在，以下创建一个名为 sites 的数据表：

demo_mysql_test.py:
import mysql.connectormydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("CREATE TABLE sites (name VARCHAR(255), url VARCHAR(255))")

执行成功后，我们可以看到数据库创建的数据表 sites，字段为 name 和 url。
在这里插入图片描述

我们也可以使用 “SHOW TABLES” 语句来查看数据表是否已存在：
demo_mysql_test.py:

import mysql.connector 
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SHOW TABLES")
for x in mycursor:print(x)

主键设置
创建表的时候我们一般都会设置一个主键（PRIMARY KEY），我们可以使用 “INT AUTO_INCREMENT PRIMARY KEY” 语句来创建一个主键，主键起始值为 1，逐步递增。
如果我们的表已经创建，我们需要使用 ALTER TABLE 来给表添加主键：
demo_mysql_test.py:
给 sites 表添加主键。

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("ALTER TABLE sites ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

如果你还未创建 sites 表，可以直接使用以下代码创建。
demo_mysql_test.py:
给表创建主键。

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("CREATE TABLE sites (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), url VARCHAR(255))")

插入数据

插入数据使用 “INSERT INTO” 语句：
demo_mysql_test.py:
向 sites 表插入一条记录。

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
val = ("RUNOOB", "https://www.runoob.com")
mycursor.execute(sql, val)
mydb.commit()    # 数据表内容有更新，必须使用到该语句
print(mycursor.rowcount, "记录插入成功。")

执行代码，输出结果为：

1 记录插入成功

批量插入
批量插入使用 executemany() 方法，该方法的第二个参数是一个元组列表，包含了我们要插入的数据：
demo_mysql_test.py:
向 sites 表插入多条记录。

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
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/')
]
mycursor.executemany(sql, val)
mydb.commit()    # 数据表内容有更新，必须使用到该语句
print(mycursor.rowcount, "记录插入成功。")

执行代码，输出结果为：

4 记录插入成功。

执行以上代码后，我们可以看看数据表的记录：
在这里插入图片描述

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

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
val = ("Zhihu", "https://www.zhihu.com")
mycursor.execute(sql, val)
mydb.commit()
print("1 条记录已插入, ID:", mycursor.lastrowid)

执行代码，输出结果为：

1 条记录已插入, ID: 6

查询数据

查询数据使用 SELECT 语句：
demo_mysql_test.py:

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM sites")
myresult = mycursor.fetchall()     # fetchall() 获取所有记录
for x in myresult:print(x)

执行代码，输出结果为：

(1, 'RUNOOB', 'https://www.runoob.com')
(2, 'Google', 'https://www.google.com')
(3, 'Github', 'https://www.github.com')
(4, 'Taobao', 'https://www.taobao.com')
(5, 'stackoverflow', 'https://www.stackoverflow.com/')
(6, 'Zhihu', 'https://www.zhihu.com')

也可以读取指定的字段数据：

demo_mysql_test.py:

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT name, url FROM sites")
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

('RUNOOB', 'https://www.runoob.com')
('Google', 'https://www.google.com')
('Github', 'https://www.github.com')
('Taobao', 'https://www.taobao.com')
('stackoverflow', 'https://www.stackoverflow.com/')
('Zhihu', 'https://www.zhihu.com')

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

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM sites")
myresult = mycursor.fetchone()
print(myresult)

执行代码，输出结果为：

(1, 'RUNOOB', 'https://www.runoob.com')

where 条件语句
如果我们要读取指定条件的数据，可以使用 where 语句：
demo_mysql_test.py
读取 name 字段为 RUNOOB 的记录：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "SELECT * FROM sites WHERE name ='RUNOOB'"
mycursor.execute(sql)
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(1, 'RUNOOB', 'https://www.runoob.com')

也可以使用通配符 %：
demo_mysql_test.py

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "SELECT * FROM sites WHERE url LIKE '%oo%'"
mycursor.execute(sql)
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(1, 'RUNOOB', 'https://www.runoob.com')
(2, 'Google', 'https://www.google.com')

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

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "SELECT * FROM sites WHERE name = %s"
na = ("RUNOOB", )
mycursor.execute(sql, na)
myresult = mycursor.fetchall()
for x in myresult:print(x)

排序
查询结果排序可以使用 ORDER BY 语句，默认的排序方式为升序，关键字为 ASC，如果要设置降序排序，可以设置关键字 DESC。
demo_mysql_test.py
按 name 字段字母的升序排序：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "SELECT * FROM sites ORDER BY name"
mycursor.execute(sql)
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(3, 'Github', 'https://www.github.com')
(2, 'Google', 'https://www.google.com')
(1, 'RUNOOB', 'https://www.runoob.com')
(5, 'stackoverflow', 'https://www.stackoverflow.com/')
(4, 'Taobao', 'https://www.taobao.com')
(6, 'Zhihu', 'https://www.zhihu.com')

降序排序实例：

demo_mysql_test.py
按 name 字段字母的降序排序：

import mysql.connectormydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "SELECT * FROM sites ORDER BY name DESC"
mycursor.execute(sql)
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(6, 'Zhihu', 'https://www.zhihu.com')
(4, 'Taobao', 'https://www.taobao.com')
(5, 'stackoverflow', 'https://www.stackoverflow.com/')
(1, 'RUNOOB', 'https://www.runoob.com')
(2, 'Google', 'https://www.google.com')
(3, 'Github', 'https://www.github.com')

Limit
如果我们要设置查询的数据量，可以通过 “LIMIT” 语句来指定
demo_mysql_test.py
读取前 3 条记录：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM sites LIMIT 3")
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(1, 'RUNOOB', 'https://www.runoob.com')
(2, 'Google', 'https://www.google.com')
(3, 'Github', 'https://www.github.com')

也可以指定起始位置，使用的关键字是 OFFSET：
demo_mysql_test.py
从第二条开始读取前 3 条记录：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
mycursor.execute("SELECT * FROM sites LIMIT 3 OFFSET 1")  # 0 为 第一条，1 为第二条，以此类推
myresult = mycursor.fetchall()
for x in myresult:print(x)

执行代码，输出结果为：

(2, 'Google', 'https://www.google.com')
(3, 'Github', 'https://www.github.com')
(4, 'Taobao', 'https://www.taobao.com')

删除记录

删除记录使用 “DELETE FROM” 语句：
demo_mysql_test.py
删除 name 为 stackoverflow 的记录：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "DELETE FROM sites WHERE name = 'stackoverflow'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, " 条记录删除")

执行代码，输出结果为：

1  条记录删除

注意：要慎重使用删除语句，删除语句要确保指定了 WHERE 条件语句，否则会导致整表数据被删除。
为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义删除语句的条件：
demo_mysql_test.py

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "DELETE FROM sites WHERE name = %s"
na = ("stackoverflow", )
mycursor.execute(sql, na)
mydb.commit()
print(mycursor.rowcount, " 条记录删除")

执行代码，输出结果为：

1  条记录删除

更新表数据

数据表更新使用 “UPDATE” 语句：
demo_mysql_test.py
将 name 为 Zhihu 的字段数据改为 ZH：

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "UPDATE sites SET name = 'ZH' WHERE name = 'Zhihu'"
mycursor.execute(sql)
mydb.commit()
print(mycursor.rowcount, " 条记录被修改")

执行代码，输出结果为：

1  条记录被修改

注意：UPDATE 语句要确保指定了 WHERE 条件语句，否则会导致整表数据被更新。
为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义更新语句的条件：
demo_mysql_test.py

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "UPDATE sites SET name = %s WHERE name = %s"
val = ("Zhihu", "ZH")
mycursor.execute(sql, val)
mydb.commit()
print(mycursor.rowcount, " 条记录被修改")

执行代码，输出结果为：

1  条记录被修改

删除表
删除表使用 “DROP TABLE” 语句， IF EXISTS 关键字是用于判断表是否存在，只有在存在的情况才删除：
demo_mysql_test.py

import mysql.connector
mydb = mysql.connector.connect(host="localhost",user="root",passwd="123456",database="runoob_db"
)
mycursor = mydb.cursor()
sql = "DROP TABLE IF EXISTS sites"  # 删除数据表 sites
mycursor.execute(sql)

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

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

相关文章

LLM*：路径规划的大型语言模型增强增量启发式搜索

LLM*：路径规划的大型语言模型增强增量启发式搜索

路径规划是机器人技术和自主导航中的一个基本科学问题，需要从起点到目的地推导出有效的路线，同时避开障碍物。A* 及其变体等传统算法能够确保路径有效性，但随着状态空间的增长，计算和内存效率会严重降低。相反，大型语言…
阅读更多...
【Db First】.NET开源 ORM 框架 SqlSugar 系列

【Db First】.NET开源 ORM 框架 SqlSugar 系列

.NET开源 ORM 框架 SqlSugar 系列 【开篇】.NET开源 ORM 框架 SqlSugar 系列【入门必看】.NET开源 ORM 框架 SqlSugar 系列【实体配置】.NET开源 ORM 框架 SqlSugar 系列【Db First】.NET开源 ORM 框架 SqlSugar 系列【Code First】.NET开源 ORM 框架 SqlSugar 系列【数据事务…
阅读更多...
企业品牌曝光的新策略：短视频矩阵系统

企业品牌曝光的新策略：短视频矩阵系统

企业品牌曝光的新策略：短视频矩阵系统 在当今数字化时代，短视频已经渗透到我们的日常生活之中，成为连接品牌与消费者的关键渠道。然而，随着平台于7月20日全面下线了短视频矩阵的官方接口，许多依赖于此接口的小公司和内…
阅读更多...
006 MATLAB编程基础

006 MATLAB编程基础

01 M文件 MATLAB输入命令有两种方法： 一是在MATLAB主窗口逐行输入命令，每个命令之间用分号或逗号分隔，每行可包含多个命令。 二是将命令组织成一个命令语句文集，使用扩展名“.m”，称为M文件。它由一系列的命令和语句…
阅读更多...
Java基于SpringBoot+Vue的IT技术交流和分享平台（附源码+lw+部署）

Java基于SpringBoot+Vue的IT技术交流和分享平台（附源码+lw+部署）

博主介绍：✌程序员徐师兄、7年大厂程序员经历。全网粉丝30W、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专栏推荐订阅👇…
阅读更多...
【计算机网络】实验3：集线器和交换器的区别及交换器的自学习算法

【计算机网络】实验3：集线器和交换器的区别及交换器的自学习算法

实验 3：集线器和交换器的区别及交换器的自学习算法 一、 实验目的 加深对集线器和交换器的区别的理解。 了解交换器的自学习算法。 二、 实验环境 • Cisco Packet Tracer 模拟器 三、 实验内容 1、熟悉集线器和交换器的区别 (1) 第一步：构建网络…
阅读更多...
UICollectionView在xcode16编译闪退问题

UICollectionView在xcode16编译闪退问题

使用xcode15运行工程，控制台会出现如下提示： Expected dequeued view to be returned to the collection view in preparation for display. When the collection views data source is asked to provide a view for a given index path, ensure that a …
阅读更多...
Proteus8.17下载安装教程

Proteus8.17下载安装教程

Proteus是一款嵌入式系统仿真开发软件，实现了从原理图设计、单片机编程、系统仿真到PCB设计，真正实现了从概念到产品的完整设计，其处理器模型支持8051、HC11、PIC10/12/16/18/24/30/DsPIC33、AVR、ARM、8086和MSP430等，能够帮助用…
阅读更多...
Vue教程｜搭建vue项目｜Vue-CLI2.x 模板脚手架

Vue教程｜搭建vue项目｜Vue-CLI2.x 模板脚手架

一、项目构建环境准备 在构建Vue项目之前，需要搭建Node环境以及Vue-CLI脚手架，由于本篇文章为上一篇文章的补充，也是为了给大家分享更为完整的搭建vue项目方式，所以环境准备部分采用Vue教程｜搭建vue项目｜V…
阅读更多...
一款支持80+语言，包括：拉丁文、中文、阿拉伯文、梵文等开源OCR库

一款支持80+语言，包括：拉丁文、中文、阿拉伯文、梵文等开源OCR库

大家好，今天给大家分享一个基于PyTorch的OCR库EasyOCR，它允许开发者通过简单的API调用来读取图片中的文本，无需复杂的模型训练过程。 项目介绍 EasyOCR 是一个基于Python的开源项目，它提供了一个简单易用的光学字符识别&#xff…
阅读更多...
cocotb pytest

cocotb pytest

打印python中的print ， 应该使用 pytest -s
阅读更多...
【C++】STL——map和set

【C++】STL——map和set

目录 1、序列式容器和关联式容器前 2、set 2.1 set类的介绍 2.2 set的构造和迭代器 2.3 set的增删查 set 的插入 set的查找 set的删除 2.4 multiset和set的差异 3、map 3 .1 pair类型 3.2 map的构造 3.3 map的增删查 map的构造遍历 map的插入 map的删除 map的查…
阅读更多...
java基础概念46-数据结构1

java基础概念46-数据结构1

一、引入 List集合的三种实现类使用了不同的数据结构！ 二、数据结构的定义 三、常见的数据结构 3-1、栈 特点：先进后出，后进先出。 java内存容器： 3-2、队列 特点：先进先出、后进后出。 栈VS队列-小结 3-3、数组 3-…
阅读更多...
Docker：在 ubuntu 系统上生成和加载 Docker 镜像

Docker：在 ubuntu 系统上生成和加载 Docker 镜像

本文将介绍在 ubuntu系统上进行 Docker 镜像的生成和加载方法和代码。 文章目录 一、下载和安装 docker二、加载 docker 文件三、保存你的镜像四、将镜像上传到云端并通过连接下载和加载 Docker 镜像五、Docker 容器和本地的文件交互5.1 从容器复制文件到本地宿主机5.1.1 单个文…
阅读更多...
《数据挖掘：概念、模型、方法与算法（第三版）》

《数据挖掘：概念、模型、方法与算法（第三版）》

嘿，数据挖掘的小伙伴们！今天我要给你们介绍一本超级实用的书——《数据挖掘：概念、模型、方法与算法》第三版。这本书是数据挖掘领域的经典之作，由该领域的知名专家编写，系统性地介绍了在高维数据空间中分析和提取大量…
阅读更多...
做异端中的异端 -- Emacs裸奔之路4: 你不需要IDE

做异端中的异端 -- Emacs裸奔之路4: 你不需要IDE

确切地说，你不需要在IDE里面编写或者阅读代码。 IDE用于Render资源文件比较合适，但处理文本，并不划算。 这的文本文件，包括源代码，配置文件，文档等非二进制文件。 先说说IDE带的便利: 函数或者变量的自动…
阅读更多...
【C++】编程题目分析与实现回顾：从浮点数运算到整型转换的全面解读

【C++】编程题目分析与实现回顾：从浮点数运算到整型转换的全面解读

博客主页： [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: C 文章目录 💯前言💯题目一：计算成绩问题分析与优化实现优化后的实现优势 💯题目二：浮点数向零舍入不同实现方式的比较1. 使用强制类型转换 (int)2. 使用标准…
阅读更多...
时间表格Java

时间表格Java

输入：XXX XXX 小时 分钟 输出： XXX：XXX ~ XXX: XXX XXX：XXX ~ XXX: XXX XXX：XXX ~ XXX: XXX 处理：间隔五分钟、区间45分钟 14:15 ~ 15:0 15:5 ~ 15:50 15:55 ~ 16:40 16:45 ~ 17:30 17:35 ~ 18:20…
阅读更多...
Spring AOP 的实现和切点表达式的介绍

Spring AOP 的实现和切点表达式的介绍

1. 快速入手 AOP：就是面相切面编程，切面指的就是某一类特定的问题，也可以理解为面相特定方法编程，例如之前使用的拦截器，就是 AOP 思想的一种应用，统一数据返回格式和统一异常处理也是 AOP 思想的实现方式…
阅读更多...
shell脚本30个案例（五）

shell脚本30个案例（五）

前言： 通过一个多月的shell学习，总共写出30个案例，分批次进行发布，这次总共发布了5个案例，希望能够对大家的学习和使用有所帮助，更多案例会在下期进行发布。 案例二十一、系统内核优化 1.问题&#xff1…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023