Python 操作 MySQL：使用 mysql-connector-python 操作 MySQL 数据库

在这里插入图片描述
大家好，我是水滴~~

当涉及到使用 Python 操作 MySQL 数据库时，mysql-connector-python 库是一个强大而常用的选择。该库提供了与 MySQL 数据库的交互功能，使您能够执行各种数据库操作，如连接数据库、执行查询和插入数据等。在本文中，我们将介绍如何使用 mysql-connector-python 库来操作 MySQL 数据库。

文章内容包含大量的示例代码，希望能够帮助新手同学快速入门。

《Python入门核心技术》专栏总目录・点这里

文章目录

  • 前言
  • 一、连接器的版本
  • 二、安装 mysql-connector-python 库
  • 三、连接 MySQL 数据库
    • 3.1 创建一个连接
    • 3.2 使用字典定义连接参数
    • 3.3 从配置文件中获取连接信息
    • 3.4 捕获连接异常
  • 四、执行 SQL 查询
    • 4.1 查询并返回多条数据（元组列表）
    • 4.2 查询并返回一条数据（元组）
    • 4.3 查询时传递参数
  • 五、执行 SQL 插入、更新和删除操作
  • 六、支持事务
  • 七、支持连接池
  • 总结

前言

MySQL Connector/Python 是一个用于在 Python 和 MySQL 数据库之间进行交互的官方 MySQL 驱动程序。它提供了一个简单而强大的接口，使开发人员能够轻松地连接到 MySQL 数据库，并执行查询、插入、更新和删除等操作。

以下是 MySQL Connector/Python 库的一些关键特点和功能：

  • 官方支持：MySQL Connector/Python 是由 MySQL 官方团队开发和维护的，因此它与 MySQL 数据库的兼容性非常好。它遵循最新的 MySQL 协议，并与 MySQL 服务器紧密集成。
  • 简单易用：MySQL Connector/Python 提供了一个直观而简单的 API，使开发人员能够轻松地连接到数据库、执行查询和修改数据。它提供了一组简洁的方法和函数，使数据库操作变得简单而直观。
  • 支持事务：MySQL Connector/Python 支持事务，允许您在多个数据库操作之间维护一致性。您可以开始一个事务、执行一系列操作，并在需要时提交或回滚事务。
  • 支持预处理语句：MySQL Connector/Python 支持预处理语句，可以提高执行相同查询多次的效率。通过使用预处理语句，您可以预先准备查询并多次执行，而不必每次都重新解析和编译查询。
  • 支持连接池：MySQL Connector/Python 支持连接池，允许您在应用程序中管理和重用数据库连接。连接池可以提高性能和可伸缩性，特别是在高并发环境下。
  • SSL/TLS 加密支持：MySQL Connector/Python 支持通过 SSL/TLS 使用加密连接连接到 MySQL 服务器。这提供了对数据传输的安全保护，尤其在通过公共网络连接到数据库时非常重要。
  • 跨平台支持：MySQL Connector/Python 可在多个平台上运行，包括 Windows、Linux 和 macOS。这使得它成为开发人员在不同环境中构建和部署 Python 应用程序时的理想选择。

总之，MySQL Connector/Python 是一个功能强大且易于使用的库，用于在 Python 和 MySQL 数据库之间进行交互。它提供了广泛的功能和选项，使开发人员能够灵活地连接、查询和修改 MySQL 数据库，从而构建出高效和可靠的应用程序。无论是简单的查询还是复杂的数据库操作，MySQL Connector/Python 都是一个值得考虑的工具。

下面是相关链接：

项目链接
官方指南https://dev.mysql.com/doc/connector-python/
PyPI 地址https://pypi.org/project/mysql-connector-python/

一、连接器的版本

在安装 MySQL 连接器之前需要先确定安装的版本，如果你的 MySQL 版本在 5.6 及以上，可以直接安装最新版本的连接器。

下表总结了连接器 与 MySQL、Python的版本对照表：

连接器版本MySQL 版本Python 版本
8.x8.1, 8.0, 5.7, 5.63.12 (8.2.0), 3.11, 3.10, 3.9, 3.8
8.08.0, 5.7, 5.6, 5.53.11, 3.10, 3.9, 3.8, 3.7, (在 8.0.29 之前的 3.6), ( 在 8.0.24 之前的 2.7 和 3.5)
2.2 (后续为 8.0)5.7, 5.6, 5.53.5, 3.4, 2.7
2.15.7, 5.6, 5.53.5, 3.4, 2.7, 2.6
2.05.7, 5.6, 5.53.5, 3.4, 2.7, 2.6
1.25.7, 5.6, 5.5 (5.1, 5.0, 4.1)3.4, 3.3, 3.2, 3.1, 2.7, 2.6

二、安装 mysql-connector-python 库

在使用之前，需要先安装 mysql-connector-python 库，下面列出一些常用的 pip 命令。

安装最新版本：

pip install mysql-connector-python

安装到指定版本：

pip install mysql-connector-python==8.0.26

请注意，确保指定的版本在PyPI（Python软件包索引）上可用。你可以在PyPI网站上搜索mysql-connector-python来查找可用的版本列表。

升级到最新版本：

pip install mysql-connector-python --upgrade

升级到指定版本：

pip install mysql-connector-python==8.0.26 --upgrade

三、连接 MySQL 数据库

使用 mysql-connector-python 库连接 MySQL 数据库，需要使用 connect() 函数，该函数会创建与 MySQL 服务器的连接并返回一个 MySQLConnection对象。

3.1 创建一个连接

以下示例展示了如何连接到 MySQL 服务器：

import mysql.connector# 连接 MySQL
cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database"
)# 关闭连接
cnx.close()

在上述代码中，host 表示数据库主机地址，user 表示用户名，password 表示密码，database 表示要连接的数据库名称。

3.2 使用字典定义连接参数

也可以将连接参数封装到字典中，然后以这个字典传递参数：

import mysql.connector# 将连接信息存入字典中
conn_params = {'host': 'your_host','user': 'your_username','password': 'your_password','database': 'your_database'
}# 使用 ** 运算符传递字典参数
cnx = mysql.connector.connect(**conn_params)# 关闭连接
cnx.close()

3.3 从配置文件中获取连接信息

在生产环境中，通常是将连接信息写在配置文件中的，需要从配置文件中获取，然后连接 MySQL。

创建一个配置文件（例如，config.ini），其中包含MySQL数据库的连接参数。配置文件的示例内容如下：

[mysql]
host = your_host
user = your_username
password = your_password
database = your_database

使用configparser模块来解析配置文件并获取连接参数。以下是示例代码：

import configparser
import mysql.connector# 创建配置解析器对象
config = configparser.ConfigParser()
# 读取配置文件
config.read('config.ini')# 从配置文件中获取连接参数，并封装至字典中
conn_params = {'host': config.get('mysql', 'host'),'user': config.get('mysql', 'user'),'password': config.get('mysql', 'password'),'database': config.get('mysql', 'database')
}# 连接到MySQL数据库
cnx = mysql.connector.connect(**conn_params)# 关闭连接
cnx.close()

3.4 捕获连接异常

在连接数据库时也可能因为意外而发生异常，我们需要捕获它：

import mysql.connector
from mysql.connector import errorcodetry:# 连接 MySQL 数据库cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database")# 捕获异常
except mysql.connector.Error as err:if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:print("账号或密码错误")elif err.errno == errorcode.ER_BAD_DB_ERROR:print("数据库不存在")else:print(err)
else:# 关闭连接cnx.close()

获取更多连接参数，请参见官网：https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html

四、执行 SQL 查询

连接成功后，可以使用 cursor() 函数获取游标对象，然后使用游标对象执行 SQL 查询。

4.1 查询并返回多条数据（元组列表）

下面示例将演示如何执行查询语句，并将查询结果放到列表中，代码如下：

import mysql.connector# 获取连接
cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database"
)# 获取游标
cursor = cnx.cursor()# 执行查询
cursor.execute("SELECT * FROM oss_file")# 将查询结果放到列表中
rows = cursor.fetchall()# 遍历查询结果
for row in rows:print(row)# 关闭游标和连接
cursor.close()
cnx.close()

在上述代码中，execute() 函数用于执行 SQL 查询，fetchall() 函数用于获取查询结果集，其返回值为列表，列表中存储的是元组，每个元组就是一条数据。

4.2 查询并返回一条数据（元组）

下面示例将演示如何执行查询语句，并返回一条查询结果，代码如下：

import mysql.connector# 获取连接
cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database"
)# 获取游标
cursor = cnx.cursor()# 执行查询
cursor.execute("SELECT * FROM oss_file limit 1")# 获取查询结果
row = cursor.fetchone()
print(row)# 关闭游标和连接
cursor.close()
cnx.close()

在上述代码中，execute() 函数用于执行 SQL 查询，fetchone() 函数用于获取一条查询结果，其返回值为元组。

4.3 查询时传递参数

执行查询时也可以进行参数传递，可以将参数组织为元组或列表，并将其作为execute()方法的第二个参数传递。以下是一个示例：

import mysql.connector# 获取连接
cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database"
)# 获取游标
cursor = cnx.cursor()# 查询参数，参数可以是元组或列表
params = ('app/', 1)
# 执行查询
cursor.execute("SELECT * FROM oss_file where prefix = %s and status = %s", params=params)# 将查询结果放到列表中
rows = cursor.fetchall()# 遍历查询结果
for row in rows:print(row)# 关闭游标和连接
cursor.close()
cnx.close()

上述示例中，传递了两个参数，而SQL中使用 %s 作为点位符，表示参数的位置 。在SQL查询语句中，%s占位符通常是按照出现的顺序进行参数替换的。当你在查询语句中使用多个%s占位符时，传递给数据库驱动程序的参数值应按照相应的顺序进行传递。

参数也可以是字典类型，如下示例：

import mysql.connector# 获取连接
cnx = mysql.connector.connect(host="localhost",user="root",password="root",database="oss"
)# 获取游标
cursor = cnx.cursor()# 定义字典类型的参数
params = {'prefix': 'app/','status': 1
}
# 执行查询
cursor.execute("SELECT * FROM oss_file where prefix = %(prefix)s and status = %(status)s", params=params)# 将查询结果放到列表中
rows = cursor.fetchall()# 遍历查询结果
for row in rows:print(row)# 关闭游标和连接
cursor.close()
cnx.close()

当传递字典类型的参数，占位符就需要指明具体的参数了，如上面的 %(prefix)s 和 %(status)s。

五、执行 SQL 插入、更新和删除操作

可以使用 execute() 函数来执行 SQL 插入、更新和删除操作。

示例代码如下：

import mysql.connector# 获取连接
cnx = mysql.connector.connect(host="your_host",user="your_username",password="your_password",database="your_database"
)# 获取游标
cursor = cnx.cursor()# SQL 语句和参数
sql = "INSERT INTO customers (name, address) VALUES (%s, %s)"
params = ("水滴", "青岛")# 执行插入语句
cursor.execute(sql, params)# 提交事务
cnx.commit()# 获取受影响的行数
print('插入行数', cursor.rowcount)# 关闭游标和连接
cursor.close()
cnx.close()

在上述代码中，execute() 函数用于执行 SQL 插入操作，commit() 函数用于提交事务。而更新、删除和插入是一样的，这里就不演示了。

六、支持事务

mysql-connector-python 库支持事务功能。可以使用 start_transaction() 函数开始一个事务，使用 commit() 函数提交事务，使用 rollback() 函数回滚事务。

示例代码如下：

import mysql.connector# 建立与数据库的连接
cnx = mysql.connector.connect(user='your_username',password='your_password',host='your_host',database='your_database'
)try:# 开始事务cnx.start_transaction()# 创建游标对象cursor = cnx.cursor()# 执行第一个插入操作insert_query1 = "INSERT INTO table1 (column1, column2) VALUES (%s, %s)"data1 = ('value1', 'value2')cursor.execute(insert_query1, data1)# 执行第二个插入操作insert_query2 = "INSERT INTO table2 (column1, column2) VALUES (%s, %s)"data2 = ('value3', 'value4')cursor.execute(insert_query2, data2)# 提交事务cnx.commit()# 关闭游标和连接cursor.close()cnx.close()print("事务执行成功")except mysql.connector.Error as error:# 回滚事务cnx.rollback()# 关闭游标和连接cursor.close()cnx.close()print(f"事务执行失败: {error}")

在示例代码中，我们首先建立与数据库的连接。然后，在 try 块中开始事务，并创建游标对象。接下来，我们执行两个插入操作，分别向 table1 和 table2 表插入数据。如果所有的操作都执行成功，我们通过调用 cnx.commit() 提交事务。如果任何一个操作失败，我们通过调用 cnx.rollback() 回滚事务。最后，我们关闭游标和连接。

七、支持连接池

mysql-connector-python 库还支持连接池功能，可以使用 mysql.connector.pooling 模块来创建连接池。

示例代码如下：

import mysql.connector
from mysql.connector import pooling# 创建连接池配置
pool_config = {"pool_name": "my_pool","pool_size": 5,"user": "your_username","password": "your_password","host": "your_host","database": "your_database"
}# 创建连接池
cnx_pool = mysql.connector.pooling.MySQLConnectionPool(**pool_config)# 从连接池获取连接
cnx = cnx_pool.get_connection()try:# 创建游标对象cursor = cnx.cursor()# 执行查询操作query = "SELECT * FROM your_table"cursor.execute(query)# 获取查询结果result = cursor.fetchall()for row in result:print(row)# 关闭游标cursor.close()except mysql.connector.Error as error:print(f"查询执行出错: {error}")finally:# 将连接返回给连接池cnx.close()

在示例代码中，我们首先创建连接池配置，其中包括连接池的名称、大小以及数据库连接的相关信息。然后，我们使用这些配置创建连接池对象 cnx_pool。接下来，我们通过调用 cnx_pool.get_connection() 从连接池中获取一个连接对象 cnx。在 try 块中，我们创建游标对象并执行查询操作。最后，无论查询是否成功，我们都通过调用 cnx_pool.release_connection(cnx) 将连接返回给连接池。

总结

这样，我们就完成了使用 mysql-connector-python 库来操作 MySQL 数据库的流程。
总结起来，使用 mysql-connector-python 库操作 MySQL 数据库包括建立数据库连接、执行查询操作、执行插入操作、提交事务和关闭连接等步骤。通过这个强大的库，您可以轻松地与 MySQL 数据库进行交互，并实现各种数据库操作。
希望本文能够帮助您入门使用 mysql-connector-python 库来操作 MySQL 数据库。祝你在使用 Python 进行数据库操作时取得成功！

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

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

相关文章

第十一章 Stream消息驱动

第十一章 Stream消息驱动

Stream消息驱动 gitee:springcloud_study: springcloud：服务集群、注册中心、配置中心（热更新）、服务网关（校验、路由、负载均衡）、分布式缓存、分布式搜索、消息队列（异步通信）、数据库集群、…
阅读更多...
maven命令行安装依赖测试

maven命令行安装依赖测试

mvn dependency:get -DgroupIdorg.springframework -DartifactIdspring-core -Dversion5.3.9作用：可用于测试配置环境变量后，能否下载依赖到本地仓库
阅读更多...
前后端分离架构的特点以及优缺点

前后端分离架构的特点以及优缺点

文章目录 一、前后端不分离架构(传统单体结构)1.1 什么是前后端不分离1.2 工作原理1.3 前后端不分离的优缺点1.4 应用场景 二、前后端分离架构2.1 为什么要前后端分离2.2 什么是前后端分离2.3 工作原理2.4 前后端分离的优缺点 参考资料 一、前后端不分离架构(传统单体结构) 首…
阅读更多...
【linux】cut的基本使用

【linux】cut的基本使用

cut主要用于按列切分文本行，并输出指定的字段，这是类unix系统中常用的文本处理工具。 基本使用 首先随便去网上找个文本或者列表文件 如果使用cat看文本的话就是这样的 sh-3.2# cat data.csv Name,Age,City,Salary Alice,30,New York,70000 Bob,25,L…
阅读更多...
C++ 侯捷 内存管理

C++ 侯捷 内存管理

C 的内存获取机制&#xff1a; void* p1 malloc(512); free(p1);complex<int>* p2 new complex<int>; delete p2;void* p3 ::operator new(512); ::operator delete(p3);//GNUC void* p4 alloc::allocate(512); alloc::deallocate(p4, 512);//GNUC4.9 void* p5…
阅读更多...
Hbase详解

Hbase详解

Hbase 概念 base 是分布式、面向列的开源数据库&#xff08;其实准确的说是面向列族&#xff09;。HDFS 为 Hbase 提供可靠的底层数据存储服务&#xff0c;MapReduce 为 Hbase 提供高性能的计算能力&#xff0c;Zookeeper 为 Hbase 提供稳定服务和 Failover 机制&#xff0c;…
阅读更多...
OR-NeRF论文笔记

OR-NeRF论文笔记

OR-NeRF论文笔记 文章目录 OR-NeRF论文笔记论文概述Abstract1 Introduction2 Related Work3 Background4 Method4.1 Multiview Segmentation4.2 Scene Object Removal 5 ExperimentsDatasetsMetricsMultiview SegmentationScene Object Removal 6 Conclusion 论文概述 目的&am…
阅读更多...
【软件工程】漫谈增量过程模型：软件开发的逐步之道

【软件工程】漫谈增量过程模型：软件开发的逐步之道

&#x1f34e;个人博客&#xff1a;个人主页 &#x1f3c6;个人专栏&#xff1a; 软件工程 ⛳️ 功不唐捐&#xff0c;玉汝于成 目录 前言&#xff1a; 正文 增量过程模型&#xff08;Incremental Process Model&#xff09; 主要特点和阶段&#xff1a; 优点&#xff1…
阅读更多...
TCP 协议为什么要设计三次握手 TCP 协议，是一种可靠的，基于字节流的，面向连接的传输层协议。

TCP 协议为什么要设计三次握手 TCP 协议，是一种可靠的，基于字节流的，面向连接的传输层协议。

文章目录 TCP 协议为什么要设计三次握手TCP 协议&#xff0c;是一种可靠的&#xff0c;基于字节流的&#xff0c;面向连接的传输层协议。TCP 通信双方的数据传输是通过字节流来实现传输的客户端向服务端发送连接请求并携带同步序列号 SYN。 今天我们来谈谈tcp的三次握手 TCP 协…
阅读更多...
Vue2+element-ui 实现select选择器结合Tree树形控件实现下拉树效果

Vue2+element-ui 实现select选择器结合Tree树形控件实现下拉树效果

效果&#xff1a; DOM部分 &#xff1a; // 设置el-option隐藏的下拉选项&#xff0c;选项显示的是汉字label&#xff0c;值是value // 如果不设置一个下拉选项&#xff0c;下面的树形组件将无法正常使用 <el-form-item label"报警区域" prop"monitorId"…
阅读更多...
如何让python在手机上运行,python程序在手机上运行

如何让python在手机上运行,python程序在手机上运行

大家好&#xff0c;给大家分享一下python怎么在手机上运行爱心代码&#xff0c;很多人还不知道这一点。下面详细解释一下。现在让我们来看看&#xff01; 1. 写在前面的话 天天都在PC端运行Python代码的我&#xff0c;今天突然灵光一现&#xff0c;想着是不是能够在移动端运行P…
阅读更多...
CSS 缩减顶部

CSS 缩减顶部

<template><!-- mouseenter"startAnimation" 表示在鼠标进入元素时触发 startAnimation 方法。mouseleave"stopAnimation" 表示在鼠标离开元素时触发 stopAnimation 方法。 --><!-- 容器元素 --><div class"container" mou…
阅读更多...
通用搜索的工作原理

通用搜索的工作原理

了解 Google 的通用搜索结果为何如此重要&#xff0c;通用搜索的发展方向&#xff0c;以及它对您意味着什么。 让我们从回答一个显而易见的问题开始&#xff1a; 什么是通用搜索&#xff1f; 网络上有一些通用搜索的定义&#xff0c;但我更喜欢从马的嘴里听到这样的事情。 …
阅读更多...
与擎创科技共建一体化“数智”运维体系，实现数字化转型

与擎创科技共建一体化“数智”运维体系，实现数字化转型

小窗滴滴小编获取最新版公司简介 前言&#xff1a; 哈喽大家好&#xff0c;最近分享的互联网IT热讯大家都挺喜欢&#xff0c;小编看着数据着实开心&#xff0c;感谢大家支持&#xff0c;小编会继续给大家推送。 新岁即将启封&#xff0c;我们一年一期的运维干货年末大讲也要…
阅读更多...
【halcon深度学习】dev_display_dl_data 移植到C# 上篇

【halcon深度学习】dev_display_dl_data 移植到C# 上篇

效果展示 前言 在研究halcon深度学习的时候，会发现halcon的例程里面用到了大量的二次封装库函数。这些库函数内部也是由基础的算子组成。我们在halcon的开发环境里面用的很爽，但是一旦要在C#中使用，就会报错。 一开始，我想避开这个移植过程，直接使用halcon引擎(HDevEngi…
阅读更多...
深入Mybatis数据源

深入Mybatis数据源

数据源是持久层框架中最核心的组件之一&#xff0c;在实际工作中比较常见的数据源有 C3P0、Apache Common DBCP、Proxool 等。作为一款成熟的持久化框架&#xff0c;MyBatis 不仅自己提供了一套数据源实现&#xff0c;而且还能够方便地集成第三方数据源。 javax.sql.DataSourc…
阅读更多...
C++系列-第1章顺序结构-3-输出类cout

C++系列-第1章顺序结构-3-输出类cout

C系列-第1章顺序结构-3-输出类cout 在线练习&#xff1a; http://noi.openjudge.cn/ https://www.luogu.com.cn/ 总结 本文是C系列博客&#xff0c;主要讲述输出类cout的用法 cout介绍与基本用法 在C中&#xff0c;cout 是用于输出&#xff08;打印&#xff09;数据的工具&…
阅读更多...
文华财经鬼谷数据期货量化分析系统指标公式

文华财经鬼谷数据期货量化分析系统指标公式

鬼谷数据量化主图源码 安装流程——打开文华财经软件——右上角指标管理器——新建指标——复制源码——安装成功 鬼谷数据主图源码 安装流程——打开文华财经软件——右上角指标管理器——新建指标——复制源码——安装成功文华财经期货软件擒龙量化主图指标公式HH:HHV(HIGH…
阅读更多...
系列四、Eureka自我保护

系列四、Eureka自我保护

一、Eureka自我保护 1.1、故障现象 保护模式主要用于一组客户端和Eureka Server之间存在网络分区场景下的保护。一旦进入保护模式&#xff0c;Eureka Server将会尝试保护其服务注册表中的信息&#xff0c;不再删除服务注册表中的数据&#xff0c;也就是不会注销任何微服务。如…
阅读更多...
交叉编译aarch64架构支持openssl的curl、libcurl

交叉编译aarch64架构支持openssl的curl、libcurl

本文档旨在指导读者在x86_64平台上交叉编译curl和openssl库以支持aarch64架构。在开始之前&#xff0c;请确保您的系统环境已正确配置。 1. 系统环境准备 系统是基于Ubuntu 20.04 LTS&#xff0c;高版本可能会有问题。首页&#xff0c;安装必要的开发工具和库文件。打开终端并…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023