要使用 Python 连接 MySQL 并执行 SQL 操作，我们可以使用 `mysql-connector-python` 或 `pymysql` 这两个常用的库。这里我们以 `mysql-connector-python` 为例，来演示如何连接 MySQL 数据库并执行前面的 SQL 操作。 --- ### ✅ 安装依赖 首先需要安装 `mysql-connector-python`： ```bash pip install mysql-connector-python ``` --- ### ✅ Python 连接 MySQL 并执行 SQL 示例代码 ```python import mysql.connector from mysql.connector import Error try: # 连接 MySQL 数据库 connection = mysql.connector.connect( host='localhost', # 数据库地址 user='root', # 数据库用户名 password='your_password',# 数据库密码 database='your_database' # 数据库名称（需提前创建） ) if connection.is_connected(): cursor = connection.cursor() # 1. 创建 employee 表 create_table_query = """ CREATE TABLE IF NOT EXISTS employee ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100) NOT NULL, department VARCHAR(100), salary DECIMAL(10, 2) ) """ cursor.execute(create_table_query) print("✅ 表 employee 创建成功") # 2. 插入数据 insert_query = """ INSERT INTO employee (name, department, salary) VALUES (%s, %s, %s) """ record = ('John Doe', 'HR', 5000.00) cursor.execute(insert_query, record) connection.commit() print("✅ 数据插入成功") # 3. 更新数据 update_query = """ UPDATE employee SET salary = %s WHERE name = %s """ update_values = (5500.00, 'John Doe') cursor.execute(update_query, update_values) connection.commit() print("✅ 数据更新成功") # 4. 删除数据 delete_query = "DELETE FROM employee WHERE name = %s" delete_value = ('John Doe',) cursor.execute(delete_query, delete_value) connection.commit() print("✅ 数据删除成功") except Error as e: print("❌ 数据库操作出错：", e) finally: if connection.is_connected(): cursor.close() connection.close() print("🔌 数据库连接已关闭") ``` --- ### 🔍 代码说明 - 使用 `mysql.connector.connect()` 方法连接数据库。 - `cursor.execute()` 用于执行 SQL 语句。 - `connection.commit()` 是必须的，用于提交事务（插入、更新、删除）。 - 使用参数化查询（`%s`）防止 SQL 注入。 - `try...except...finally` 结构确保异常时程序不会崩溃，并能关闭连接。 --- ###