在使用 Python 对 MySQL 数据库进行基本的增删改查（CRUD）操作时，需要依赖于数据库连接库，例如 `mysql-connector-python` 或 `pymysql`。以下是一个完整的示例，涵盖连接数据库、创建表、插入数据、查询数据、更新数据和删除数据的操作。 ### 连接 MySQL 数据库 在执行任何数据库操作之前，需要先建立与 MySQL 数据库的连接。假设数据库名为 `test_db`，主机为 `localhost`，用户名为 `root`，密码为空。 ```python import mysql.connector # 建立数据库连接 connection = mysql.connector.connect( host="localhost", user="root", password="", database="test_db" ) # 创建游标对象 cursor = connection.cursor() ``` ### 创建表 如果尚未创建表，可以使用以下 SQL 语句创建一张名为 `cars` 的表[^2]。 ```python # 创建表 create_table_query = """ CREATE TABLE IF NOT EXISTS cars ( id INT AUTO_INCREMENT PRIMARY KEY, car_model VARCHAR(45), car_brand VARCHAR(45) ) """ cursor.execute(create_table_query) connection.commit() ``` ### 插入数据 (Create) 向表中插入新的记录，可以使用 `INSERT INTO` 语句。以下函数用于插入新的汽车记录[^3]。 ```python def create_car(car_model, car_brand): sql = "INSERT INTO cars (car_model, car_brand) VALUES (%s, %s)" values = (car_model, car_brand) cursor.execute(sql, values) connection.commit() print(f"汽车记录 '{car_model}' 已创建。") # 示例用法 create_car("Model S", "Tesla") create_car("Civic", "Honda") ``` ### 查询数据 (Read) 从表中查询记录，可以使用 `SELECT` 语句。以下代码将查询并打印所有汽车记录。 ```python def read_cars(): cursor.execute("SELECT * FROM cars") results = cursor.fetchall() for row in results: print(row) # 示例用法 read_cars() ``` ### 更新数据 (Update) 更新表中的现有记录，可以使用 `UPDATE` 语句。以下函数用于更新特定汽车品牌的信息。 ```python def update_car(car_id, new_model, new_brand): sql = "UPDATE cars SET car_model = %s, car_brand = %s WHERE id = %s" values = (new_model, new_brand, car_id) cursor.execute(sql, values) connection.commit() print(f"汽车记录 ID {car_id} 已更新。") # 示例用法 update_car(1, "Model 3", "Tesla") read_cars() ``` ### 删除数据 (Delete) 从表中删除记录，可以使用 `DELETE` 语句。以下函数用于删除特定 ID 的汽车记录。 ```python def delete_car(car_id): sql = "DELETE FROM cars WHERE id = %s" values = (car_id,) cursor.execute(sql, values) connection.commit() print(f"汽车记录 ID {car_id} 已删除。") # 示例用法 delete_car(2) read_cars() ``` ### 完整代码整合 以下是上述功能的完整整合代码： ```python import mysql.connector # 建立数据库连接 connection = mysql.connector.connect( host="localhost", user="root", password="", database="test_db" ) # 创建游标对象 cursor = connection.cursor() # 创建表 create_table_query = """ CREATE TABLE IF NOT EXISTS cars ( id INT AUTO_INCREMENT PRIMARY KEY, car_model VARCHAR(45), car_brand VARCHAR(45) ) """ cursor.execute(create_table_query) connection.commit() # 插入数据 def create_car(car_model, car_brand): sql = "INSERT INTO cars (car_model, car_brand) VALUES (%s, %s)" values = (car_model, car_brand) cursor.execute(sql, values) connection.commit() print(f"汽车记录 '{car_model}' 已创建。") # 查询数据 def read_cars(): cursor.execute("SELECT * FROM cars") results = cursor.fetchall() for row in results: print(row) # 更新数据 def update_car(car_id, new_model, new_brand): sql = "UPDATE cars SET car_model = %s, car_brand = %s WHERE id = %s" values = (new_model, new_brand, car_id) cursor.execute(sql, values) connection.commit() print(f"汽车记录 ID {car_id} 已更新。") # 删除数据 def delete_car(car_id): sql = "DELETE FROM cars WHERE id = %s" values = (car_id,) cursor.execute(sql, values) connection.commit() print(f"汽车记录 ID {car_id} 已删除。") # 示例用法 create_car("Model S", "Tesla") create_car("Civic", "Honda") read_cars() update_car(1, "Model 3", "Tesla") read_cars() delete_car(2) read_cars() ```