当前位置：首页 > news >正文

Python 3 与 MySQL 数据库连接：mysql-connector 模块详解

news 来源：原创 2025/6/23 2:48:16

Python 3 与 MySQL 数据库连接：mysql-connector 模块详解

概述

在Python 3中，与MySQL数据库进行交互是一个常见的需求。mysql-connector是一个流行的Python模块，它提供了与MySQL数据库连接和交互的接口。本文将详细介绍mysql-connector模块的安装、使用方法以及一些高级特性。

安装

首先，确保你的Python环境中已经安装了mysql-connector模块。可以使用以下命令进行安装：

pip install mysql-connector-python

连接MySQL数据库

使用mysql-connector模块连接到MySQL数据库非常简单。以下是一个基本的示例：

import mysql.connector

# 创建连接对象
conn = mysql.connector.connect(
    host='localhost',        # 数据库主机地址
    user='yourusername',     # 数据库用户名
    passwd='yourpassword',   # 数据库密码
    database='yourdatabase'  # 数据库名
)

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

# 执行查询
cursor.execute("SELECT DATABASE()")

# 获取并打印结果
data = cursor.fetchone()
print("你连接到了：", data[0])

# 关闭游标和连接
cursor.close()
conn.close()

创建数据库和表

mysql-connector模块也支持创建数据库和表。以下是一个示例：

import mysql.connector

# 创建连接对象
conn = mysql.connector.connect(
    host='localhost',
    user='yourusername',
    passwd='yourpassword',
    database='yourdatabase'
)

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

# 创建数据库
cursor.execute("CREATE DATABASE IF NOT EXISTS mynewdb")

# 使用新创建的数据库
cursor.execute("USE mynewdb")

# 创建表
cursor.execute("""
CREATE TABLE IF NOT EXISTS employees (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100),
    email VARCHAR(100),
    age INT
)
""")

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

插入、更新和删除数据

使用mysql-connector模块进行数据操作也很直观。以下是一个插入、更新和删除数据的示例：

import mysql.connector

# 创建连接对象
conn = mysql.connector.connect(
    host='localhost',
    user='yourusername',
    passwd='yourpassword',
    database='mynewdb'
)

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

# 插入数据
cursor.execute("""
INSERT INTO employees (name, email, age) 
VALUES (%s, %s, %s)
""", ("John Doe", "john.doe@example.com", 25))

# 提交事务
conn.commit()

# 更新数据
cursor.execute("""
UPDATE employees 
SET age = %s 
WHERE name = %s
""", (30, "John Doe"))

# 删除数据
cursor.execute("""
DELETE FROM employees 
WHERE name = %s
""", ("John Doe",))

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()

高级特性

mysql-connector模块还提供了一些高级特性，例如事务管理、存储过程调用和自定义函数等。以下是一个示例：

import mysql.connector

# 创建连接对象
conn = mysql.connector.connect(
    host='localhost',
    user='yourusername',
    passwd='yourpassword',
    database='mynewdb'
)

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

# 开启事务
conn.start_transaction()

# 调用存储过程
cursor.callproc('get_employee_count', args=())

# 获取结果
cursor.execute("SELECT @employee_count")
for (employee_count,) in cursor:
    print("Employee Count: ", employee_count)

# 提交事务
conn.commit()

# 关闭游标和连接
cursor.close()
conn.close()