### 如何在编程中实现和使用游标 #### 创建游标对象 为了能够执行 SQL 查询并处理返回的数据，在 Python 中可以利用 `pymysql` 或者其他 MySQL 驱动库来建立与数据库之间的连接，并通过调用该连接上的 `cursor()` 方法创建一个新的游标实例[^3]。 ```python import pymysql connection = pymysql.connect( host='localhost', user='root', password='', database='testdb' ) try: with connection.cursor() as cursor: pass # 游标在此处被定义并且可以在with语句的作用域内使用 finally: connection.close() ``` #### 执行查询并获取单条记录 当拥有一个有效的游标之后，就可以编写 SQL 查询并通过 `execute()` 函数发送给服务器。接着可以通过 `fetchone()` 来逐行读取结果集中的每一项数据[^1]。 ```python sql_query = "SELECT id, name FROM users LIMIT 1" affected_rows = cursor.execute(sql_query) if affected_rows > 0: result = cursor.fetchone() print(f'User ID: {result["id"]}, Name: {result["name"]}') else: print('No data found.') ``` #### 使用循环遍历多条记录 对于需要迭代整个结果集的情况，则应该采用 `fetchall()` 或者在一个 while 循环里不断调用 `fetchone()` 直至无更多可用的结果为止。另一种方式是在每次 fetch 的时候直接将数据放入预先准备好的容器中，如下所示： ```python # 方式一：一次性取出全部结果 cursor.execute("SELECT * FROM users") results = cursor.fetchall() for row in results: print(row) # 方式二：逐步抓取每行数据into到变量 while True: record = cursor.fetchone() if not record: break print(record) ``` #### 处理批量插入或更新操作 如果要向表中添加新纪录或是修改现有内容，同样也是先准备好相应的 INSERT/UPDATE 语句模板，再借助于游标的 execute 方法完成实际的任务。需要注意的是，这类变更类的操作往往还需要配合 commit 调用来确保更改生效。 ```python insert_sql = "INSERT INTO users (name) VALUES (%s)" data_to_insert = [ ('Alice',), ('Bob',) ] try: for item in data_to_insert: cursor.execute(insert_sql, item) connection.commit() except Exception as e: connection.rollback() raise e ``` #### 正确关闭游标及断开连接 最后一步是要记得清理资源——即关闭游标以及终止同数据库间的会话链接。这不仅有助于防止潜在的安全风险，也能提高系统的性能表现。 ```python cursor.close() connection.close() ```