03 Python进阶：MySQL - mysql-connector

news2024/11/19 4:24:18

mysql-connector安装

在这里插入图片描述

要在 Python 中使用 MySQL 数据库，你需要安装 MySQL 官方提供的 MySQL Connector/Python。下面是安装 MySQL Connector/Python 的步骤：

  1. 首先，确保你已经安装了 Python，如果没有安装，可以在 Python 官网（https://www.python.org）下载并安装最新版本的 Python。

  2. 打开命令行或终端，在命令行中运行以下命令安装 MySQL Connector/Python：

在这里插入图片描述

这将会从 PyPI 上下载并安装 MySQL Connector/Python。

注意：如果你的 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 脚本中使用 MySQL Connector/Python 来连接和操作 MySQL 数据库了。下面是一个简单的示例代码：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建游标对象
mycursor = mydb.cursor()

# 执行 SQL 查询
mycursor.execute("SELECT * FROM mytable")

# 获取查询结果
for x in mycursor:
  print(x)

在上面的代码中，你需要将 host、user、password 和 database 替换为实际的数据库连接信息，然后根据需求执行相应的 SQL 查询。

这样，你就可以在 Python 中使用 MySQL Connector/Python 来连接、查询和操作 MySQL 数据库了。

创建数据库

在 Python 中，你可以使用 MySQL Connector/Python 来创建数据库。以下是一个简单的示例代码：

import mysql.connector

# 连接到 MySQL 服务器
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword"
)

# 创建一个名为 'mydatabase' 的数据库
mycursor = mydb.cursor()
mycursor.execute("CREATE DATABASE mydatabase")

在上面的示例中，你需要将 host、user 和 password 替换为实际的数据库连接信息。运行这段代码后，将在 MySQL 服务器上创建一个名为 mydatabase 的数据库。

确保你的账户有足够的权限来创建数据库。另外，如果你想指定数据库的字符集和校对规则，可以在创建数据库时加上参数，例如：

mycursor.execute("CREATE DATABASE mydatabase CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci")

这将创建一个使用 UTF-8 字符集和 utf8mb4_unicode_ci 校对规则的数据库。

创建数据表

在 Python 中使用 MySQL Connector/Python 创建数据表的方法与在 MySQL 命令行中创建数据表的方法类似。以下是一个示例代码，演示如何在 Python 中创建一个名为 users 的数据表：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"  # 已存在的数据库
)

# 创建一个数据表
mycursor = mydb.cursor()

mycursor.execute("CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

在上面的示例中，我们连接到了已存在的数据库 mydatabase，然后使用 CREATE TABLE 语句创建了一个名为 users 的数据表，其中包含 id、name 和 age 三个字段。

你可以根据需要定义数据表的字段及其类型。运行这段代码后，将在数据库中创建一个名为 users 的数据表。

注意：确保你具有足够的权限来创建数据表。另外，你也可以为表中的列指定约束、默认值等其他属性，具体语法可以根据需要调整。

主键设置

在 MySQL 中，可以使用 PRIMARY KEY 来定义表中的主键。在 Python 中使用 MySQL Connector/Python，也可以通过以下方式为数据表设置主键：

# 创建一个数据表，并指定主键
mycursor.execute("CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

在上面的示例中，我们在 id 字段上使用了 AUTO_INCREMENT PRIMARY KEY，这意味着 id 是主键，并且会自动递增。

如果你想在多个字段上定义复合主键，可以使用如下方式：

# 创建一个数据表，并指定复合主键
mycursor.execute("CREATE TABLE users (id1 INT, id2 INT, PRIMARY KEY (id1, id2))")

在这个例子中，我们将 id1 和 id2 作为复合主键。无论是单个字段还是复合主键，都需要确保它们能唯一标识表中的每一行数据。

通过以上方法，你可以在 Python 中使用 MySQL Connector/Python 为数据表设置主键。如果需要更复杂的约束或索引，也可以通过相应的 SQL 语句进行设置。

插入数据

当使用 MySQL Connector/Python 向数据库中的数据表插入数据时，可以使用如下方法：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 插入数据
sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
val = ("John", 30)
mycursor.execute(sql, val)

# 提交执行
mydb.commit()

print(mycursor.rowcount, "记录插入成功。")

在上面的示例中，我们向名为 users 的数据表中插入了一条数据，这条数据包含了 name 和 age 两个字段的值。通过使用 %s 占位符和元组 val 传递数据，我们可以避免 SQL 注入攻击，并使代码更加安全。

在执行 execute() 后，我们调用了 commit() 方法来提交事务。只有在调用 commit() 后，数据才会真正被插入到数据库中。

以上就是使用 MySQL Connector/Python 向数据表插入数据的简单示例。你可以根据需要修改 val 中的数据以及 SQL 语句来插入更多的记录。

批量插入

如果需要批量插入多条数据到数据库中，可以使用 MySQL Connector/Python 的 executemany() 方法。以下是一个示例代码，演示如何批量插入多条数据：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 插入多条数据
sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
values = [
    ("Alice", 25),
    ("Bob", 30),
    ("Charlie", 28)
]

mycursor.executemany(sql, values)

# 提交执行
mydb.commit()

print(mycursor.rowcount, "记录插入成功。")

在上面的示例中，我们定义了一个包含多个元组的 values 列表，每个元组表示要插入的一条数据。然后，我们使用 executemany() 方法将这些数据批量插入到数据库中。

与单条插入相同，执行 commit() 语句来提交事务，确保数据被正确插入到数据库中。

通过这种方式，你可以方便地批量插入多条数据到数据库中。记得根据实际需求调整数据和 SQL 语句。

查询数据

无条件查询

要在 Python 中使用 MySQL Connector/Python 查询数据，你可以通过以下方式实现：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行查询
mycursor.execute("SELECT * FROM users")

# 获取查询结果
result = mycursor.fetchall()
for row in result:
  print(row)

在上面的示例中，我们首先连接到了数据库，然后创建了一个游标对象。游标对象允许我们执行 SQL 查询并获取结果。在这个例子中，我们执行了一个简单的 SELECT 查询来获取 users 表中的所有记录，并通过 fetchall() 方法获取查询结果。

最后，我们遍历查询结果，并打印出每一行数据。

条件查询

如果需要添加查询条件或者只获取部分字段的数据，可以根据需要修改 SQL 查询语句。
要在 Python 中进行带有条件的查询，只需在 SQL 查询语句中添加条件即可。以下是一个示例代码，演示如何使用 MySQL Connector/Python 进行条件查询：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行带有条件的查询
sql = "SELECT * FROM users WHERE age > %s"
val = (25, )  # 查询年龄大于25的用户
mycursor.execute(sql, val)

# 获取查询结果
result = mycursor.fetchall()
for row in result:
  print(row)

在上面的示例中，我们执行了一个带有条件的查询，通过 WHERE 子句筛选出了年龄大于25的用户。我们将条件值(这里是 25)作为元组传递给 execute() 方法，以避免 SQL 注入攻击。

你可以根据需要修改查询条件，例如更改比较运算符、添加多个条件等。通过在 SQL 查询语句中灵活添加条件，你可以实现不同类型的查询操作。

删除记录

要在 Python 中使用 MySQL Connector/Python 删除记录，你可以按照以下步骤进行操作：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行删除操作
sql = "DELETE FROM users WHERE name = %s"
val = ("Alice",)  # 删除名为 Alice 的记录
mycursor.execute(sql, val)

# 提交执行
mydb.commit()

print(mycursor.rowcount, "条记录已被删除。")

在上面的示例中，我们执行了一个删除操作，通过 DELETE FROM 语句删除了名为 “Alice” 的记录。类似于条件查询，我们将需要删除的记录的条件值作为元组传递给 execute() 方法。

在执行 delete 操作后，一定要调用 commit() 方法提交事务，确保删除操作生效。如果不调用 commit()，记录将不会被真正删除。

表记录清空

要在Python中使用MySQL Connector/Python清空表中的所有记录，你可以按照以下步骤进行操作：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行清空表记录操作
sql = "TRUNCATE TABLE yourtablename"
mycursor.execute(sql)

print("表记录已成功清空")

在上面的示例中，我们使用TRUNCATE TABLE语句清空了名为"yourtablename"的表中的所有记录。这条语句会立即删除表中的所有记录，但是保留表结构不变。请谨慎操作，因为一旦清空操作完成，将无法恢复数据。

请确保你明确了解清空表记录的后果，并在需要清空表记录时再执行该操作。

更新表数据

在 Python 中使用 MySQL Connector/Python 更新表数据的方法如下所示：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行更新操作
sql = "UPDATE users SET age = %s WHERE name = %s"
val = (32, "Alice")  # 更新名为 Alice 的记录的年龄为 32
mycursor.execute(sql, val)

# 提交执行
mydb.commit()

print(mycursor.rowcount, "条记录已被更新。")

在上面的示例中，我们执行了一个更新操作，通过 UPDATE 语句将名为 “Alice” 的记录的年龄更新为 32。我们将更新操作的条件值和新值作为元组传递给 execute() 方法。

和删除操作类似，需要调用 commit() 方法提交事务，确保更新操作生效。

删除表

要在Python中使用MySQL Connector/Python删除表，你可以按照以下步骤进行操作：

import mysql.connector

# 连接到 MySQL 数据库
mydb = mysql.connector.connect(
  host="localhost",
  user="yourusername",
  password="yourpassword",
  database="mydatabase"
)

# 创建一个游标对象
mycursor = mydb.cursor()

# 执行删除表操作
sql = "DROP TABLE IF EXISTS yourtablename"
mycursor.execute(sql)

print("表已成功删除")

在上面的示例中，我们执行了一个删除表的操作，通过DROP TABLE语句删除了名为"yourtablename"的表。如果你确信表存在可以不添加IF EXISTS部分。

在执行DROP TABLE操作后，表将被立即删除，所以请谨慎操作。该操作无法撤销，并且会永久删除表及其数据，因此请在明确知道删除目的时再执行该操作。

数据库事务

使用 mysql-connector 库执行事务与使用 pymysql 类似，需要在 Python 中连接到 MySQL 数据库，并利用 connection 对象的方法来执行事务的提交和回滚。

以下是一个示例代码，演示了如何在 mysql-connector 中执行事务：

import mysql.connector

# 连接到数据库
connection = mysql.connector.connect(
    host='your_host',
    user='your_username',
    password='your_password',
    database='your_database_name'
)

try:
    # 开始事务
    connection.start_transaction()

    # 创建游标
    cursor = connection.cursor()

    # 执行多个 SQL 命令，这里仅作示例
    insert_sql_1 = "INSERT INTO table1 (column1, column2) VALUES (%s, %s)"
    insert_sql_2 = "INSERT INTO table2 (column3, column4) VALUES (%s, %s)"

    # 执行第一个插入操作
    cursor.execute(insert_sql_1, ('value1', 'value2'))

    # 执行第二个插入操作
    cursor.execute(insert_sql_2, ('value3', 'value4'))

    # 提交事务
    connection.commit()

except mysql.connector.Error as e:
    # 如果出现异常，回滚事务
    connection.rollback()
    print(f"An error occurred: {e}")

finally:
    # 关闭游标和连接
    cursor.close()
    connection.close()

在上述示例中，我们首先通过 connection.start_transaction() 开启了一个事务。然后，在 try 块中执行了两个插入操作。如果所有操作顺利完成，就会通过 connection.commit() 提交事务。如果其中任何一步出现了异常，connection.rollback() 会回滚事务，使所有操作都不会生效。

通过使用事务，可以确保在执行一系列相关操作时，要么全部成功，要么全部失败。这对于确保数据的完整性和一致性非常重要。

关注我，不迷路，共学习，同进步

关注我，不迷路，共学习，同进步

在这里插入图片描述

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

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

相关文章

OpenHarmony实战：轻量级系统之配置其他子系统

OpenHarmony实战：轻量级系统之配置其他子系统

除上述子系统之外，还有一些必要但是无需进行移植的子系统。如：分布式任务调度子系统、DFX子系统。 这些子系统添加方式比较简单，在“vendor/MyVendorCompany/MyProduct/config.json”文件中进行如下配置即可： {"subsystem&…
阅读更多...
Nginx是什么？

Nginx是什么？

一、什么是Nginx? Nginx是一个高性能的HTTP和反向代理Web服务器 二、Nginx有什么优点 Nginx稳定性好、资源消耗低、配置简单、功能丰富 1、作为Web服务器，Nginx处理静态文件、索引文件，自动索引的效率非常高 2、作为代理服务器，Nginx可以…
阅读更多...
大创项目推荐 深度学习 python opencv 火焰检测识别 火灾检测

大创项目推荐 深度学习 python opencv 火焰检测识别 火灾检测

文章目录 0 前言1 基于YOLO的火焰检测与识别2 课题背景3 卷积神经网络3.1 卷积层3.2 池化层3.3 激活函数：3.4 全连接层3.5 使用tensorflow中keras模块实现卷积神经网络 4 YOLOV54.1 网络架构图4.2 输入端4.3 基准网络4.4 Neck网络4.5 Head输出层 5 数据集准备5.1 数…
阅读更多...
Linux：ip和ip协议的初步认识

Linux：ip和ip协议的初步认识

文章目录 ip协议基本认识ip协议的报头网段划分ip的类型划分 ip协议基本认识 前面对于TCP的内容已经基本结束了，那么这也就意味着在传输层也已经结束了，那么下一步要进入的是的是网络层，网络层中也有很多种协议，这里主要进行解析的…
阅读更多...
uniapp微信小程序真机图片不显示

uniapp微信小程序真机图片不显示

不同设备可能出现部分设备显示不了图片，解决办法：图片地址直接使用，不要拼接： https://images.weserv.nl/?urlhttp
阅读更多...
Leetcode442. 数组中重复的数据

Leetcode442. 数组中重复的数据

Every day a Leetcode 题目来源：442. 数组中重复的数据 解法1：将元素交换到对应的位置 由于给定的 n 个数都在 [1,n] 的范围内，如果有数字出现了两次，就意味着 [1,n] 中有数字没有出现过。 因此，我们可以尝试将每一…
阅读更多...
【fastadmin】脚本模式下，日志钩子函数执行出现死循环，导致内存溢出奔溃

【fastadmin】脚本模式下，日志钩子函数执行出现死循环，导致内存溢出奔溃

问题出现原因是想对项目中error级别的日志，接入钉钉告警，方便查看 于是使用钩子方法，日志写入完成后，自动调用自定义的告警方法中 1、在application/tags.php 中添加log_write_done > [app\\common\\behavior\\Common, ],2、在…
阅读更多...
JavaAgent 技术原理及实战

JavaAgent 技术原理及实战

JavaAgent 技术原理及实战 1、引子2、JavaAgent 简单示例：方法开始和结束时打印日志2.1 创建 Agent2.2 编写验证 agent 功能的测试类2.2.1 使用JavaAgent 静态加载方式2.2.2 使用 JavaAgent 动态加载方式 2.3、小结 3、JavaAgent3.1 JavaAgent是什么？3.2…
阅读更多...
搞学术研究好用免费的学术版ChatGPT网站-学术AI

搞学术研究好用免费的学术版ChatGPT网站-学术AI

https://chat.uaskgpt.com/mobile/?user_sn88&channelcsdn&sceneloginhttps://chat.uaskgpt.com/mobile/?user_sn88&channelcsdn&scenelogin 推荐一个非常适合中国本科硕士博士等学生老师使用的学术版ChatGPT， 对接了超大型学术模型&#xff0c…
阅读更多...
考研数学｜《1800题》基础练习基本不会，怎么办?

考研数学｜《1800题》基础练习基本不会，怎么办?

这其实是因为，知识点之间没有形成联结 这样只要题目难度提升，一个题目的知识点综合度变高，就不知道该怎么做了。 不要害怕，其实考研复习早起阶段，大家基本上都经过这个阶段，不过有的同学能够快速找到做题…
阅读更多...
Vue ElementPlus Input 输入框

Vue ElementPlus Input 输入框

Input 输入框 通过鼠标或键盘输入字符 input 为受控组件，它总会显示 Vue 绑定值。 通常情况下，应当处理 input 事件，并更新组件的绑定值（或使用v-model）。否则，输入框内显示的值将不会改变，不支…
阅读更多...
[C#]winform使用OpenCvSharp实现透视变换功能支持自定义选位置和删除位置

[C#]winform使用OpenCvSharp实现透视变换功能支持自定义选位置和删除位置

【透视变换基本原理】 OpenCvSharp 是一个.NET环境下对OpenCV原生库的封装，它提供了大量的计算机视觉和图像处理的功能。要使用OpenCvSharp实现透视变换（Perspective Transformation），你首先需要理解透视变换的原理和它在图像处理…
阅读更多...
WPF中动画教程（DoubleAnimation的基本使用）

WPF中动画教程（DoubleAnimation的基本使用）

实现效果 今天以一个交互式小球的例子跟大家分享一下wpf动画中DoubleAnimation的基本使用。该小球会移动到我们鼠标左键或右键点击的地方。 该示例的实现效果如下所示&#xff1a; 页面设计 xaml如下所示&#xff1a; <Window x:Class"AnimationDemo.MainWindow&qu…
阅读更多...
mysql 正则表达式查询

mysql 正则表达式查询

学习了mysql 连接查询和子查询和myql join连接&#xff0c;接下来学习下正则表达式查询。正则表达式的规则都是相似的。 8&#xff0c;使用正则表达式查询 正则表达式通常被用来检索或替换那些符合某个模式的文本内容,根据指定的匹配模式匹配文本中符合要求的特殊字符串。例如从…
阅读更多...
Android 高德地图

Android 高德地图

1.获取Key 进入高德开放平台控制台&#xff0c;创建一个新应用。在创建的应用上点击"添加key"按钮&#xff0c;在弹出的对话框中&#xff0c;依次输入key名称&#xff0c;选择服务平台为“Android平台”&#xff0c;输入发布版安全码 SHA1、以及 Package。 获取 S…
阅读更多...
flutter获取手机中的系统路径信息

flutter获取手机中的系统路径信息

https://www.bilibili.com/video/BV1wE421g7sw获取系统中的路径 获取系统中的路径&#xff0c;并在这个路径中创建一个文本文件【str.txt】 然后进行写入【str.txt】 再读取这个文件【str.txt】 手机没有开通root权限无法看到写入到【应用程序文档目录】路径中的文件 用来…
阅读更多...
案例分析-程序的机器级表示

案例分析-程序的机器级表示

案例一&#xff1a;关于编译优化 请自写一段if- else简单分支程序&#xff0c;分别尝试对它进行不带优化、-O1优化和-O2优化&#xff0c;比较它们的机器级表达&#xff0c;并讨论优劣。 图一为不带优化、图二为O1优化、图三为O2优化、图四为原始C代码。 &#xff08;1&#xff…
阅读更多...
x-cmd-pkg | broot 是基于 Rust 开发的一个终端文件管理器

x-cmd-pkg | broot 是基于 Rust 开发的一个终端文件管理器

简介 broot 是基于 Rust 开发的一个终端文件管理器&#xff0c;它设计用于帮助用户在终端中更轻松地管理文件和目录&#xff0c;使用树状视图探索文件层次结构、操作文件、启动操作以及定义您自己的快捷方式。 同时它还集成了 ls, tree, find, grep, du, fzf 等工具的常用功能…
阅读更多...
IDEA连接SqlServer数据库

IDEA连接SqlServer数据库

目录 下载jar包 下载sqljdbc_12.6压缩包 解压 导入IDEA 新建文件夹 复制粘贴进JDBC文件夹并设为library 编写类及方法 代码 下载jar包 以sqljdbc_12.6为例 下载sqljdbc_12.6压缩包 最新地址&#xff1a;sqljdbc 官方最新地址 解压 解压即用 导入IDEA 新建文件夹 复制…
阅读更多...
标题：探索AI绘画：使用深度学习生成艺术

标题：探索AI绘画：使用深度学习生成艺术

正文&#xff1a; 随着计算机技术的发展&#xff0c;人工智能在各个领域取得了显著的成果。通过训练深度学习模型&#xff0c;AI可以学习大量的艺术作品&#xff0c;从而生成具有独特风格和创意的新作品。 本文将介绍如何使用Python和TensorFlow实现一个简单的AI绘画程序。 二、…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023