【Python学习笔记】第二十五节 Python MySQL

news2024/11/27 22:26:31

Python 连接到 MySQL 数据库有几种不同的连接方法，而且不是所有的方法都能与不同的操作系统很好地配合.

MySQL connector/Python模块是Oracle支持的官方驱动，用于通过Python连接MySQL。该连接器完全是Python语言，而mysqlclient是用C语言编写的。它也是独立的，意味着它不需要MySQL客户端库或标准库以外的任何Python模块。

注意，MySQL Connector/Python不支持旧的MySQL服务器认证方法，这意味着4.1之前的MySQL版本不能工作。

本文实例的运行环境：

  • Windows 10

  • MySQL 8.0

一、创建数据库连接

1、首先安装mysql-connector-python模块。

python -m pip install mysql-connector

2、连接数据库：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

运行结果

<mysql.connector.connection.MySQLConnection object at 0x000002B399503AC0>

二、创建数据库

1、创建数据库使用 "CREATE DATABASE" 语句，以下创建一个名为 python_demo 的数据库：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

myCursor = mydb.cursor()

myCursor.execute("CREATE DATABASE python_demo")

2、使用 "SHOW DATABASES" 语句来查看数据库是否存在：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

myCursor = mydb.cursor()

# myCursor.execute("CREATE DATABASE python_demo")
myCursor.execute("SHOW DATABASES")

for x in myCursor:
    print(x)

  • 我们可以直接连接数据库，如果数据库不存在，会输出错误信息：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

print(mydb)

三、创建数据表

创建数据表使用 "CREATE TABLE" 语句，创建数据表前，需要确保数据库已存在，以下创建一个名为 user 自增主键的数据表：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()
myCursor.execute("CREATE TABLE user (id int(11) primary key not null auto_increment,name VARCHAR(64), mobile VARCHAR(32), address VARCHAR(255))")

  • 如果我们的表已经创建，我们需要使用 ALTER TABLE 来给表添加主键：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()
myCursor.execute("ALTER TABLE user ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

四、插入数据

  • 插入数据使用 "INSERT INTO" 语句：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()

sql = "INSERT INTO user (name, mobile,address) VALUES (%s, %s, %s)"
val = ("Lily", "13866669999", "America")
myCursor.execute(sql, val)
mydb.commit()  # 提交

print(myCursor.rowcount, "插入成功。")

  • 批量插入

批量插入使用 executemany() 方法，该方法的第二个参数是一个元组列表，包含了我们要插入的数据：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()

sql = "INSERT INTO user (name, mobile,address) VALUES (%s, %s, %s)"
# val = ("Lily", "13866669999", "America")

val = [
    ("LiLei", "13866668888", "China"),
    ("Jim", "13855558888", "America"),
    ("HanMeimei", "13811113333", "China")
]
# myCursor.execute(sql, val)
myCursor.executemany(sql, val)

mydb.commit()  # 提交

print(myCursor.rowcount, "插入成功。")

3 插入成功。

五、查询数据

1、查询数据使用 SELECT 语句：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

myCursor.execute("SELECT * FROM user")

result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

  • 读取指定的字段数据：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT name, mobile, address FROM user")
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

  • 读取一条数据，可以使用 fetchone() 方法：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT name, mobile, address FROM user")
# result = myCursor.fetchall()  # fetchall() 获取所有记录
result = myCursor.fetchone()  # fetchall() 获取一条记录
print(result)


('Lily', '13866669999', 'America')

2、where 条件语句

如果我们要读取指定条件的数据，可以使用 where 语句：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT * FROM user where address ='America'")
result = myCursor.fetchall()  # fetchall() 获取所有记录
# result = myCursor.fetchone()  # fetchall() 获取一条记录
# print(result)
for x in result:
    print(x)

(1, 'Lily', '13866669999', 'America')
(3, 'Jim', '13855558888', 'America')

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

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user where address ='America'")

sql = "SELECT * FROM user where address = %s"
param = ("China",)

myCursor.execute(sql, param)


result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

(2, 'LiLei', '13866668888', 'China')
(4, 'HanMeimei', '13811113333', 'China')

3、排序

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

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user ORDER BY name"
myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

(4, 'HanMeimei', '13811113333', 'China')
(3, 'Jim', '13855558888', 'America')
(2, 'LiLei', '13866668888', 'China')
(1, 'Lily', '13866669999', 'America')

  • 降序排序实例：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user ORDER BY address DESC "
myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

(2, 'LiLei', '13866668888', 'China')
(4, 'HanMeimei', '13811113333', 'China')
(1, 'Lily', '13866669999', 'America')
(3, 'Jim', '13855558888', 'America')

4、Limit

如果我们要设置查询的数据量，可以通过 "LIMIT" 语句来指定

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user LIMIT 2 "

myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

(1, 'Lily', '13866669999', 'America')
(2, 'LiLei', '13866668888', 'China')

  • 指定起始位置，使用的关键字是 OFFSET：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# sql = "SELECT * FROM user LIMIT 2 "
sql = "SELECT * FROM user LIMIT 2 OFFSET 1"

myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

(2, 'LiLei', '13866668888', 'China')
(3, 'Jim', '13855558888', 'America')

六、删除记录

删除记录使用 "DELETE FROM" 语句：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
sql = "DELETE FROM user WHERE name = 'Jim'"

myCursor.execute(sql)
mydb.commit()

print(myCursor.rowcount, " 条记录删除")

1  条记录删除

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

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "DELETE FROM user WHERE name = %s"
param = ("HanMeimei",)

myCursor.execute(sql, param)
mydb.commit()

print(myCursor.rowcount, " 条记录删除")

1  条记录删除

七、更新表数据

数据表更新使用 "UPDATE" 语句：

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "UPDATE user SET name = 'Lucy' WHERE name = 'Lily'"

myCursor.execute(sql)
mydb.commit()

print(myCursor.rowcount, " 条记录被修改")

1  条记录被修改

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

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "UPDATE user SET name = %s WHERE name = %s"
param = ("HanMeimei", "LiLei")

myCursor.execute(sql, param)
mydb.commit()

print(myCursor.rowcount, " 条记录被修改")

1  条记录被修改

八、删除表

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

# coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

myCursor.execute("SHOW TABLES")

for x in myCursor:
    print(x)

sql = "DROP TABLE IF EXISTS user_info"  # 删除数据表 user_info
myCursor.execute(sql)

print(" 删除数据表 user_info")

myCursor.execute("SHOW TABLES")

for x in myCursor:
    print(x)

('user',)
('user_info',)
 删除数据表 user_info
('user',)

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

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

相关文章

Java的开发工具有哪些？这十款工具大厂都在用！

Java的开发工具有哪些？这十款工具大厂都在用！

工欲善其事必先利其器&#xff0c;各位同学大家好&#xff0c;我是小源~本期文章&#xff0c;给大家推荐十款Java的开发工具。一、 文本编辑器主要推荐三款&#xff1a;notepad、editplus、sublime text。这三款编辑工具&#xff0c;在我们的开发工作中几乎是相差无几&#xff…
阅读更多...
3. 字符设备驱动---上篇

3. 字符设备驱动---上篇

文章目录引言一、字符设备驱动工作原理1.1 系统整体工作原理1.2 字符驱动模型1.2.1 file_operations结构体1.2.2 注册字符设备驱动 --- 申请主设备号1.2.3 内核如何管理字符设备驱动二、字符设备驱动代码实践2.1 编写字符设备驱动的步骤和规范2.2 实践写驱动代码2.3 代码实现2.…
阅读更多...
Matplotlib精品学习笔记001——绘制3D图形详解+实例讲解

Matplotlib精品学习笔记001——绘制3D图形详解+实例讲解

3D图片更生动&#xff0c;或许在时间序列数据的展示上更胜一筹 想法&#xff1a; 学习3D绘图的想法来自科研绘图中。我从事的专业是古植物学&#xff0c;也就是和植物化石打交道。化石有三大信息&#xff1a;1.物种信息&#xff0c;也就是它的分类学价值&#xff1b;2.时间信息…
阅读更多...
RealBasicVSR模型转成ONNX以及用c++推理

RealBasicVSR模型转成ONNX以及用c++推理

文章目录安装RealBasicVSR的环境1. 新建一个conda环境2. 安装pytorch(官网上选择合适的版本)版本太低会有问题3. 安装 mim 和 mmcv-full4. 安装 mmedit下载RealBasicVSR源码下载模型文件写一个模型转换的脚步测试生成的模型安装RealBasicVSR的环境 1. 新建一个conda环境 cond…
阅读更多...
第一次做性能测试，有亿点点紧张

第一次做性能测试，有亿点点紧张

确认需求 确定性能需求和性能测试方案、需要确定性能测试范围&#xff08;覆盖哪些场景&#xff09;、性能测试策略、并发用户数和加压方式。 时间、人员、任务的分配安排&#xff0c;一般在总体测试计划中会预留性能测试的时间。性能测试方案是开展性能测试前的核心内容&…
阅读更多...
时序预测 | MATLAB实现Rmsprop算法优化LSTM长短期记忆神经网络时间序列多步预测(滚动预测未来，多指标，含验证Loss曲线)

时序预测 | MATLAB实现Rmsprop算法优化LSTM长短期记忆神经网络时间序列多步预测(滚动预测未来，多指标，含验证Loss曲线)

时序预测 | MATLAB实现Rmsprop算法优化LSTM长短期记忆神经网络时间序列多步预测(滚动预测未来，多指标，含训练和验证Loss曲线) 目录 时序预测 | MATLAB实现Rmsprop算法优化LSTM长短期记忆神经网络时间序列多步预测(滚动预测未来，多指标，含训练和验证Loss曲线)效果一览基本描…
阅读更多...
Flume使用入门

Flume使用入门

目录 一. Flume简单介绍 1. Agent 2. Source 3. Sink 4. Channel 5. Event 二. 环境安装 1. 创建日志目录 2. 修改日志配置文件 3.修改运行堆内存 4. 确定日志打印的位置 5. 修改flume使用内存 内存调大 三. 校验flume 1. 安装netcat工具和net-tools工具 2. 判…
阅读更多...
MySQL服务端与客户端之间的连接过程

MySQL服务端与客户端之间的连接过程

服务器程序和客户端程序本质上是两个进程&#xff0c;所以连接过程的本质就是两个进程直接的通信&#xff0c;MySQL支持下面三种方式来进行通信。一&#xff1a;TCP/IP数据库服务器进程和客户端进程可能运行在不同的主机中&#xff0c;需要通过网络来进行通信二&#xff1a;命名…
阅读更多...
初识scrapy

初识scrapy

认识scrapyscrapy是一个为了爬取网站数据&#xff0c;提取结构性数据而编写的应用框架&#xff0c;我们只需实现少量的代码&#xff0c;就能实现数据的快速抓取scrapy使用了Twisted异步网络架构&#xff0c;可以加快下载速度 pip install twisted安装&#xff1a;pip install s…
阅读更多...
进程控制（详解）

进程控制（详解）

进程控制上篇文章介绍了进程的相关概念&#xff0c;形如进程的内核数据结构task_struct 、进程是如何被操作系统管理的、进程的查看、进程标识符、进程状态、进程优先级、已经环境变量和进程地址空间等知识点&#xff1b; 本篇文章接着上篇文章继续对进程的控制进行展开&#x…
阅读更多...
Spark 内存运用

Spark 内存运用

RDD Cache 当同一个 RDD 被引用多次时&#xff0c;就可以考虑进行 Cache&#xff0c;从而提升作业的执行效率 // 用 cache 对 wordCounts 加缓存 wordCounts.cache // cache 后要用 action 才能触发 RDD 内存物化 wordCounts.count// 自定义 Cache 的存储介质、存储形式、副本…
阅读更多...
【OJ比赛日历】快周末了，不来一场比赛吗？ #03.04-03.10 #12场

【OJ比赛日历】快周末了，不来一场比赛吗？ #03.04-03.10 #12场

CompHub 实时聚合多平台的数据类(Kaggle、天池…)和OJ类(Leetcode、牛客…&#xff09;比赛。本账号同时会推送最新的比赛消息&#xff0c;欢迎关注&#xff01;更多比赛信息见 CompHub主页 或 点击文末阅读原文以下信息仅供参考&#xff0c;以比赛官网为准目录2023-03-04&…
阅读更多...
从100%进口到自主可控，从600块降到10块，中科院攻克重要芯片

从100%进口到自主可控，从600块降到10块，中科院攻克重要芯片

前言 2月28日&#xff0c;“20多位中科院专家把芯片价格打到10块”冲上微博热搜&#xff0c;据河南省官媒大象新闻报道&#xff0c;热搜中提到的中科院专家所在企业为全球最大的PLC分路器芯片制造商仕佳光子&#xff0c;坐落于河南鹤壁。 为实现芯片技术自主可控自立自强&#…
阅读更多...
根据栅格数据的范围和像元大小生成等比例的矢量数据

根据栅格数据的范围和像元大小生成等比例的矢量数据

为啥会有这么一个需求呢&#xff0c;后面要是继续写的话会详细说&#xff0c;首先是有一个栅格数据&#xff0c;比如这样的&#xff1a;我的目标是这样的&#xff08;矢量&#xff09;&#xff0c;就是这样&#xff0c;上面的栅格数据像大小是2*2的&#xff0c;直接上代码&…
阅读更多...
【JAVA程序设计】【C00109】基于SSM（非maven）的员工工资管理系统

【JAVA程序设计】【C00109】基于SSM（非maven）的员工工资管理系统

基于SSM&#xff08;非maven&#xff09;的员工工资管理系统项目简介项目获取开发环境项目技术运行截图项目简介 基于ssm框架非maven开发的企业工资管理系统共分为二个角色&#xff1a;系统管理员、员工 管理员角色包含以下功能&#xff1a; 系统后台登陆、管理员管理、员工信…
阅读更多...
Linux基础命令-nice调整进程的优先级

Linux基础命令-nice调整进程的优先级

文章目录 Nice 命令介绍 语法格式 常用参数 参考实例 1 调整bash的优先级为-10 2 调整脚本的优先级为6 3 调整指令的优先级 4 默认使用nice命令调整优先级 命令总结 Nice 命令介绍 nice命令的主要功能是用于调整进程的优先级&#xff0c;合理分配系统资源。Linux系…
阅读更多...
torchaudio的I/O函数

torchaudio的I/O函数

info、load、save1.1 infotorchaudio.info(filepath: str, ...)Fetch meta data of an audio file. Refer to torchaudio.backend for the detail.返回音频文件的meta信息这里的meta元信息包括采样率、帧数、通道数、量化位数、音频格式info torchaudio.info(rE:\adins\data\2…
阅读更多...
Java使用DFA算法实现敏感词过滤

Java使用DFA算法实现敏感词过滤

1 前言敏感词过滤就是你在项目中输入某些字&#xff08;比如输入xxoo相关的文字时&#xff09;时要能检测出来&#xff0c;很多项目中都会有一个敏感词管理模块&#xff0c;在敏感词管理模块中你可以加入敏感词&#xff0c;然后根据加入的敏感词去过滤输入内容中的敏感词并进行…
阅读更多...
测试软件5

测试软件5

一 css基础 css定义&#xff1a;可以设置网页中的样式&#xff0c;外观&#xff0c;美化 css中文名字&#xff1a;级联样式表&#xff0c;层叠样式表&#xff0c;样式表 二 css基础语法 1.style标签写在title标签后面 2.选择器{属性名1&#xff1a;属性值1&#xff1b;属性名…
阅读更多...
ChatGPT最牛应用，让它帮你更新网站新闻吧！

ChatGPT最牛应用，让它帮你更新网站新闻吧！

谁能想到&#xff0c;ChatGPT火了&#xff01;既能对话入流&#xff0c;又能写诗歌论文、出面试题、编代码&#xff0c;甚至还通过了谷歌面试拿到L3工程师offer&#xff0c;放在一年之前&#xff0c;没人相信这是当前AI能够达到的水平。ChatGPT自面世以来&#xff0c;凭借其极为…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023