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", "john@example.com"),     ("jane_doe", "jane@example.com"),     ("bob_smith", "bob@example.com") ]  # 执行 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 = ("new_email@example.com", "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 数据库。务必根据实际情况调整代码，以适应你的具体需求。