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()