### Python 编写 SQL 查询、删除和插入操作示例 以下是关于如何在 Python 中使用 `pymysql` 库完成对 MySQL 数据库的查询、删除和插入操作的具体实现。代码中包含了详细的注释以便于理解。 --- #### 1. 导入库并连接数据库 首先需要导入必要的模块，并建立与数据库的连接。 ```python import pymysql # 建立数据库连接 conn = pymysql.connect( host='localhost', # 数据库地址 user='root', # 用户名 passwd='password', # 密码 db='test_db', # 数据库名称 port=3306, # 端口号，默认为3306 charset='utf8', # 字符集 cursorclass=pymysql.cursors.DictCursor # 返回结果为字典形式 ) cur = conn.cursor() # 创建游标对象 ``` --- #### 2. 执行查询操作 下面是一个简单的查询操作示例，展示如何从表中读取数据。 ```python try: # 定义SQL语句 query_sql = "SELECT * FROM users WHERE id > %s" # 执行查询 cur.execute(query_sql, (10,)) # 获取所有结果 results = cur.fetchall() # 输出结果 for row in results: print(row) except Exception as e: print(f"Error during query execution: {e}") finally: cur.close() # 关闭游标 ``` 此部分展示了如何通过占位符 `%s` 防止 SQL 注入攻击[^1]。 --- #### 3. 执行插入操作 接下来演示如何向表中插入新记录。 ```python try: # 定义SQL语句 insert_sql = "INSERT INTO users (id, username, password) VALUES (%s, %s, %s)" # 准备插入的数据 data_to_insert = [ (15, 'wangwu', 'pwd_wangwu'), (16, 'zhuliu', 'pwd_zhuliu') ] # 批量执行插入 cur.executemany(insert_sql, data_to_insert) # 提交事务 conn.commit() print("Insert operation completed successfully.") except Exception as e: conn.rollback() # 如果发生异常则回滚事务 print(f"Error during insertion: {e}") ``` 这里利用了 `executemany()` 方法来高效地批量插入多条记录[^3]。 --- #### 4. 执行删除操作 最后介绍如何安全地删除某些记录。 ```python try: # 定义SQL语句 delete_sql = "DELETE FROM users WHERE id IN (%s, %s)" # 执行删除 cur.execute(delete_sql, (15, 16)) # 提交事务 conn.commit() print(f"{cur.rowcount} records deleted.") # 显示受影响的行数 except Exception as e: conn.rollback() # 发生错误时回滚 print(f"Error during deletion: {e}") finally: conn.close() # 断开数据库连接 ``` 注意，在删除之前最好先确认待删记录的存在性以避免意外丢失重要数据[^4]。 --- ### 总结 以上就是使用 Python 实现基本 SQL 操作的方法概述。每一步都强调了安全性（如防止注入）、效率性和健壮性的原则。