pymysql查询操作

<think>好的，我现在需要帮助用户了解如何使用pymysql执行SQL查询操作。首先，我得回顾一下pymysql的基本用法，确保自己记得正确。用户可能已经安装了pymysql，但或许需要确认安装步骤，不过问题重点在查询操作，所以安装部分可以简要提及。 接下来，用户需要的是执行查询的示例，所以我应该分步骤说明，比如连接数据库、创建游标、执行SQL语句、获取结果和关闭连接这些基本步骤。代码示例是必要的，这样用户可以直接看到如何应用。需要确保代码正确，比如使用execute方法，fetchall或fetchone的区别，以及游标的关闭和连接关闭的重要性。 另外，用户可能关心如何处理查询参数，防止SQL注入，所以参数化查询是关键。示例中应该展示如何用占位符%s，并用元组传递参数，这样既安全又清晰。比如查询特定id的记录，演示如何安全地传入参数。 然后，考虑到用户可能需要处理结果集，应该解释如何遍历结果，获取每一行的数据。比如使用for循环处理fetchall返回的结果，并访问各个字段。 还要注意异常处理，但用户的问题可能不需要深入这个部分，不过可以稍微提及，或者放在注意事项里。比如在代码中使用try...except块来捕获可能的错误，确保资源释放，比如在finally块中关闭连接。 参考引用中的内容，比如引用[1]和[2]提到了记录SQL语句和调试，这可能和查询操作相关，但用户的问题更基础，所以可能不需要深入日志记录部分，但可以作为一个扩展点，比如在注意事项里提到如何启用日志来调试查询。 另外，引用[5]提到了事务和SQL注入，所以在参数化查询部分需要强调使用占位符而不是拼接字符串，以防止注入攻击，这非常重要，必须包含在示例中。 最后，用户可能需要相关的问题，比如如何插入数据、事务处理或防止注入，所以生成的问题应该围绕这些扩展点，帮助用户进一步学习。 现在需要确保步骤清晰，代码正确，并且符合用户的需求。检查是否有遗漏的部分，比如游标的创建和关闭，连接信息的正确性（比如主机、用户、密码、数据库名需要替换为实际值），以及结果处理的说明是否明确。 可能还需要提到不同的fetch方法，比如fetchone和fetchmany，但根据用户的问题，可能只需要展示fetchall即可，其他方法可以作为扩展。 总之，结构应该是：安装库（简要）、连接数据库、执行查询、处理结果、关闭连接，加上参数化查询和防止注入的注意事项，最后给出相关问题和参考引用。</think>### 使用 pymysql 执行 SQL 查询操作分步说明 #### 1. 安装 PyMySQL ```bash pip install pymysql ``` #### 2. 基础查询流程 ```python import pymysql # 连接数据库 connection = pymysql.connect( host='localhost', user='your_username', password='your_password', database='your_database' ) try: # 创建游标对象 with connection.cursor() as cursor: # 编写 SQL 查询语句 sql = "SELECT * FROM users WHERE age > %s" # 执行查询（参数化防止 SQL 注入） cursor.execute(sql, (18,)) # 获取所有结果 results = cursor.fetchall() # 遍历结果 for row in results: print(f"ID: {row[0]}, Name: {row[1]}, Age: {row[2]}") finally: # 关闭数据库连接 connection.close() ``` #### 3. 核心方法说明 1. **`cursor.execute(sql, params)`** 执行 SQL 查询，支持参数化输入（使用 `%s` 占位符），避免 SQL 注入攻击[^5]。 2. **`cursor.fetchall()`** 获取所有查询结果，返回元组格式的列表。 3. **`cursor.fetchone()`** 获取单条查询结果，适用于大数据集分批次处理。 #### 4. 参数化查询示例 ```python # 按条件查询特定字段 sql = "SELECT name, email FROM products WHERE price > %s AND category = %s" cursor.execute(sql, (100, 'electronics')) ``` #### 5. 注意事项 - 始终使用参数化查询（`%s` 占位符），禁止直接拼接 SQL 字符串[^5] - 查询完成后及时关闭游标和连接释放资源 - 可使用 `cursor.description` 获取字段名称 ```python columns = [col[0] for col in cursor.description] ```