### Python 脚本实现 MySQL 数据库的增删改查操作 在 Python 中，可以通过 `MySQL Connector/Python` 库来实现对 MySQL 数据库的基本操作（增、删、改、查）。以下是详细的实现方法： #### 1. 安装 MySQL Connector 首先需要安装 MySQL 的官方驱动程序 `mysql-connector-python`。可以使用以下命令进行安装： ```bash pip install mysql-connector-python ``` #### 2. 连接数据库 在进行任何操作之前，必须先连接到 MySQL 数据库。示例如下： ```python import mysql.connector # 创建连接 db = mysql.connector.connect( host="localhost", # 数据库服务器地址 user="your_username", # 用户名 password="your_password", # 密码 database="your_database" # 数据库名称 ) cursor = db.cursor() # 创建游标对象 ``` #### 3. 插入数据 插入数据时，通常使用 `INSERT INTO` 语句，并通过参数化查询防止 SQL 注入攻击。 ```python sql = "INSERT INTO EMPLOYEE (NAME, AGE, SALARY) VALUES (%s, %s, %s)" values = ("John Doe", 30, 50000) try: cursor.execute(sql, values) # 执行SQL语句 db.commit() # 提交事务 print(f"{cursor.rowcount} 条记录已插入") except Exception as e: db.rollback() # 回滚事务 print(f"发生错误：{e}") ``` [^1] #### 4. 查询数据 查询数据时，可以使用 `SELECT` 语句。结果可以通过游标的 `fetchall()` 或 `fetchone()` 方法获取。 ```python sql = "SELECT * FROM EMPLOYEE WHERE AGE > %s" param = (25,) try: cursor.execute(sql, param) # 执行SQL语句 results = cursor.fetchall() # 获取所有结果 for row in results: name = row[0] age = row[1] salary = row[2] print(f"Name: {name}, Age: {age}, Salary: {salary}") except Exception as e: print(f"查询失败：{e}") ``` [^2] #### 5. 更新数据 更新数据时，使用 `UPDATE` 语句，并确保提交事务以保存更改。 ```python sql = "UPDATE EMPLOYEE SET SALARY = %s WHERE NAME = %s" values = (60000, "John Doe") try: cursor.execute(sql, values) # 执行SQL语句 db.commit() # 提交事务 print(f"{cursor.rowcount} 条记录已更新") except Exception as e: db.rollback() # 回滚事务 print(f"更新失败：{e}") ``` [^3] #### 6. 删除数据 删除数据时，使用 `DELETE` 语句，并同样需要提交事务。 ```python sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" param = (30,) try: cursor.execute(sql, param) # 执行SQL语句 db.commit() # 提交事务 print(f"{cursor.rowcount} 条记录已删除") except Exception as e: db.rollback() # 回滚事务 print(f"删除失败：{e}") ``` #### 7. 关闭连接 完成所有操作后，记得关闭游标和数据库连接。 ```python cursor.close() db.close() ``` ---