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

在现代应用程序中，与数据库的交互是不可或缺的一部分。Python 提供了许多库来连接和操作各种数据库，其中最常用的之一就是

mysql-connector-python

。本篇博客将介绍如何使用 Python 操作 MySQL 数据库，包括连接数据库、创建表、插入数据、查询数据以及更新和删除数据等操作。

1. 安装 MySQL Connector

首先，需要安装

mysql-connector-python

库。可以使用以下命令：

pip install mysql-connector-python

2. 连接到 MySQL 数据库

import mysql.connector

# 连接到 MySQL 数据库
conn = mysql.connector.connect(
    host="your_host",
    user="your_user",
    password="your_password",
    database="your_database")# 创建游标
cursor = conn.cursor()# 执行 SQL 查询
cursor.execute("SELECT * FROM your_table")# 获取查询结果
result = cursor.fetchall()# 输出结果for row in result:print(row)# 关闭游标和连接
cursor.close()
conn.close()

请替换

your_host

、

your_user

、

your_password

、

your_database

和

your_table

为你的实际数据库连接信息。

3. 创建表

# 创建表的 SQL 语句
create_table_query ="""
CREATE TABLE IF NOT EXISTS users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(255) NOT NULL,
    email VARCHAR(255) NOT NULL
)
"""# 执行 SQL 语句
cursor.execute(create_table_query)# 提交更改
conn.commit()

4. 插入数据

# 插入数据的 SQL 语句
insert_data_query ="INSERT INTO users (username, email) VALUES (%s, %s)"# 数据
user_data =[("john_doe","[email protected]"),("jane_doe","[email protected]"),("bob_smith","[email protected]")]# 执行 SQL 语句
cursor.executemany(insert_data_query, user_data)# 提交更改
conn.commit()

5. 查询数据

# 查询数据的 SQL 语句
select_data_query ="SELECT * FROM users"# 执行 SQL 语句
cursor.execute(select_data_query)# 获取查询结果
result = cursor.fetchall()# 输出结果for row in result:print(row)

6. 更新数据

# 更新数据的 SQL 语句
update_data_query ="UPDATE users SET email = %s WHERE username = %s"# 新数据
new_data =("[email protected]","john_doe")# 执行 SQL 语句
cursor.execute(update_data_query, new_data)# 提交更改
conn.commit()

7. 删除数据

# 删除数据的 SQL 语句
delete_data_query ="DELETE FROM users WHERE username = %s"# 要删除的数据
data_to_delete =("bob_smith",)# 执行 SQL 语句
cursor.execute(delete_data_query, data_to_delete)# 提交更改
conn.commit()

8. 异常处理

在实际应用中，应该添加适当的异常处理以处理可能发生的错误。以下是一个简单的例子：

try:# 尝试连接数据库
    conn = mysql.connector.connect(
        host="your_host",
        user="your_user",
        password="your_password",
        database="your_database")# ...except mysql.connector.Error as err:# 处理连接错误print(f"Error: {err}")finally:# 关闭连接if conn.is_connected():
        cursor.close()
        conn.close()print("Connection closed")

结语

通过这篇博客，你应该对如何使用 Python 操作 MySQL 数据库有了一个基本的了解。从连接到执行 CRUD 操作，这些例子提供了一个全面的视图，帮助你在实际项目中更好地使用 MySQL 数据库。务必根据实际情况调整代码，以适应你的具体需求。