首页 > 数据库 > Mysql > MySQL mysql-connector

MySQL mysql-connector的具体实现

2025-11-27 08:58:14 作者：愚戏师

本文主要介绍了MySQL mysql-connector的具体实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

一、安装与 MySQL 8.0 适配

1. 驱动安装

安装命令：python -m pip install mysql-connector

验证安装（无报错即成功）：

import mysql.connector

2. MySQL 8.0 版本用户创建与远程连接

MySQL 8.0 及以上版本（主流版本）需先创建用户，再单独授权（8.0 + 不再支持 GRANT 语句中直接设置密码）：

步骤 1：创建用户（指定允许远程访问的 IP）

-- 示例：创建用户user_test，允许IP为xx.xx.xxx.xxx的主机远程访问
CREATE USER 'user_test'@'xx.xx.xxx.xxx' IDENTIFIED BY '你的复杂密码';

若需允许任意 IP 远程访问（存在安全风险），将 IP 改为 %：

CREATE USER 'user_test'@'%' IDENTIFIED BY '你的复杂密码';

步骤 2：授予远程访问权限

-- 示例：授予用户对所有数据库的所有操作权限（可根据需求缩小权限范围）
GRANT ALL PRIVILEGES ON *.* TO 'user_test'@'xx.xx.xxx.xxx' WITH GRANT OPTION;

步骤 3：刷新权限使配置生效

FLUSH PRIVILEGES;

二、数据库基础操作

1. 创建数据库

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

2. 查看所有数据库

mycursor.execute("SHOW DATABASES")
for x in mycursor:
    print(x)

3. 直接连接指定数据库

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

三、数据表操作

1. 创建数据表（需先连指定数据库）

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

2. 查看数据表

mycursor.execute("SHOW TABLES")
for x in mycursor:
    print(x)

3. 主键设置

创建表时设置：mycursor.execute("CREATE TABLE sites (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), url VARCHAR(255))")
表已创建后添加：mycursor.execute("ALTER TABLE sites ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

四、数据操作（增删改查）

1. 插入数据

单条插入（需 commit() 提交）：

sql = "INSERT INTO sites (name, url) VALUES (%s, %s)"
val = ("RUNOOB", "https://www.runoob.com")
mycursor.execute(sql, val)
mydb.commit()

批量插入（executemany()）：

val = [('Google','https://www.google.com'), ('Github','https://www.github.com')]
mycursor.executemany(sql, val)
mydb.commit()

获取插入记录 ID：print(mycursor.lastrowid)

2. 查询数据

查询所有 / 指定字段：

mycursor.execute("SELECT * FROM sites")  # 所有字段
mycursor.execute("SELECT name, url FROM sites")  # 指定字段
myresult = mycursor.fetchall()  # 所有结果
for x in myresult: print(x)

单条结果：myresult = mycursor.fetchone()

条件查询（防 SQL 注入用 % s 占位符）：

sql = "SELECT * FROM sites WHERE name = %s"
mycursor.execute(sql, ("RUNOOB",))

排序：ORDER BY 字段 [ASC/DESC]（默认升序）
限制条数：LIMIT 数量 [OFFSET 起始位置]（起始位从 0 开始）

3. 删除数据（务必加 WHERE 条件）

sql = "DELETE FROM sites WHERE name = %s"
mycursor.execute(sql, ("stackoverflow",))
mydb.commit()

4. 更新数据（务必加 WHERE 条件）

sql = "UPDATE sites SET name = %s WHERE name = %s"
mycursor.execute(sql, ("Zhihu", "ZH"))
mydb.commit()

五、删除数据表

mycursor.execute("DROP TABLE IF EXISTS sites") 
# IF EXISTS 避免表不存在报错

六、核心注意事项

增 / 删 / 改数据后，必须执行 mydb.commit() 才能生效；
MySQL 8.0 需适配认证插件，否则无法正常连接；
条件操作（查 / 删 / 改）用 % s 占位符，防止 SQL 注入；
删除 / 更新操作必须加 WHERE 条件，避免误操作全表数据。

到此这篇关于MySQL mysql-connector的具体实现的文章就介绍到这了,更多相关MySQL mysql-connector内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！