### 使用 Python 进行 MySQL 数据库的增删改查操作 #### 导入必要的模块并建立连接 为了能够通过 Python 操作 MySQL 数据库，需要先安装 `pymysql` 或者其他的 MySQL 驱动程序。之后可以利用这些驱动来创建到数据库的连接。 ```python import pymysql connection = pymysql.connect( host='localhost', # 主机地址 port=3306, # 端口，默认为 3306 user='your_username', # 用户名 passwd='your_password',// 密码 db='test_db', // 要使用的数据库名称 charset='utf8' // 字符编码集 ) ``` #### 创建游标对象执行 SQL 命令 一旦建立了与数据库之间的连接，则可以通过该连接获得一个游标对象用于发送命令给服务器端以及接收返回的结果。 ```python cursor = connection.cursor() ``` #### 查询单条记录 当只需要检索一条特定的信息时，可采用如下方式： ```sql SELECT * FROM table_name WHERE condition LIMIT 1; ``` 对应的 Python 实现如下所示： ```python query_single_sql = "SELECT * FROM users WHERE id=%s" cursor.execute(query_single_sql, (user_id,)) result = cursor.fetchone() print(result) # 输出查询结果 ``` #### 查询多条记录 如果要获取满足条件的所有项，应该这样写： ```sql SELECT * FROM table_name WHERE condition; ``` 相应的 Python 代码片段如下： ```python query_multiple_sql = "SELECT * FROM orders WHERE status=%s" cursor.execute(query_multiple_sql, ('completed',)) results = cursor.fetchall() for row in results: print(row) ``` #### 插入新纪录 向表内添加新的数据行可通过下面的方式完成： ```sql INSERT INTO table_name(column_list) VALUES(value_list); ``` 这里给出具体的例子： ```python insert_data_sql = "INSERT INTO employees(firstname, lastname, age) VALUES (%s, %s, %s)" data_to_insert = ('John', 'Doe', 25) try: with connection.cursor() as cursor: affected_rows = cursor.execute(insert_data_sql, data_to_insert) finally: connection.commit() ``` #### 更新现有记录 修改已存在的某一行或多行的内容可以用 UPDATE 语句实现： ```sql UPDATE table_name SET column=value,...WHERE conditions; ``` 以下是更新操作的一个实例： ```python update_record_sql = "UPDATE products SET price=%s WHERE product_id=%s" new_price_and_product_id = (9.99, 102) with connection.cursor() as cursor: updated_count = cursor.execute(update_record_sql, new_price_and_product_id) connection.commit() ``` #### 删除指定记录 最后，删除不需要的数据则需要用到 DELETE 语句： ```sql DELETE FROM table_name WHERE conditions; ``` 下面是实际应用中的做法： ```python delete_item_sql = "DELETE FROM items WHERE item_code=%s AND quantity<%s" item_info_for_deletion = ('A123456789', 10) with connection.cursor() as cursor: deleted_items = cursor.execute(delete_item_sql, item_info_for_deletion) connection.commit() ``` 以上就是使用 Python 对 MySQL 执行基本 CRUD（Create/Read/Update/Delete）操作的主要过程[^1]。