Cursor 教程（超详细）

什么是 Cursor？初识数据库游标

在编程世界中，Cursor（游标）是一个常被忽视却至关重要的概念。它就像一本厚重词典的书签，帮助开发者在庞大的数据海洋中精准定位操作位置。对于数据库操作而言，Cursor 是连接代码逻辑与数据存储的桥梁，是执行 SQL 语句的核心组件。

理解 Cursor 时，我们可以将其想象成在图书馆检索书籍的工具。当你在数据库中执行查询时，Cursor 会像图书管理员一样，沿着书架逐本检查，最终将符合要求的书籍（数据）整理成有序的列表。这种逐行处理的特性，使得 Cursor 成为处理大数据集时的得力助手。

创建与初始化游标对象

在 Python 3.10 的 MySQL 连接中，创建 Cursor 的过程如同打开图书馆的检索系统：

import mysql.connector

conn = mysql.connector.connect(
    host="localhost",
    user="root",
    password="your_password",
    database="test_db"
)

cursor = conn.cursor()

cursor.execute("SELECT * FROM users")

这段代码中，conn.cursor() 是获取游标对象的核心方法。建议开发者始终使用 with 语句管理游标生命周期，就像图书馆规定必须登记借阅的书签：

with conn.cursor() as cursor:
    cursor.execute("SELECT id, name FROM students")
    result = cursor.fetchall()

执行数据库查询操作

基本查询执行流程

Cursor 的查询执行可分为三步曲：准备-执行-获取，这与烹饪过程类似：

query = "SELECT id, name, age FROM employees WHERE department = %s"

cursor.execute(query, ("IT",))

for record in cursor:
    print(f"员工ID：{record[0]}，姓名：{record[1]}，年龄：{record[2]}")

批量操作技巧

处理大数据时，Cursor 的批量操作能力尤为重要。就像快递分拣员同时处理多个包裹，以下代码展示如何使用 executemany：

insert_sql = "INSERT INTO orders (customer_id, amount) VALUES (%s, %s)"

orders_data = [
    (101, 299.99),
    (102, 599.80),
    (103, 149.50)
]

cursor.executemany(insert_sql, orders_data)

conn.commit()

此方法比逐条插入效率提升 300% 以上（测试数据量 1000 条时），因为减少了数据库连接开销。

处理查询结果数据

单条记录获取

fetchone() 方法如同在货架上按顺序取书：

cursor.execute("SELECT * FROM logs ORDER BY timestamp DESC LIMIT 5")

while True:
    row = cursor.fetchone()  # 获取单条记录
    if row is None:
        break
    print(f"日志ID：{row[0]}，内容：{row[1]}")

批量数据处理

当需要处理大量数据时，建议使用分页方式：

cursor.execute("SELECT id, score FROM exams")
records = cursor.fetchmany(100)

while records:
    for record in records:
        print(f"考试ID：{record[0]}，成绩：{record[1]}")
    records = cursor.fetchmany(100)

这种方式避免了 fetchall() 可能导致的内存溢出问题，特别适合处理百万级数据表。

游标与事务管理

提交与回滚操作

Cursor 的事务管理能力是确保数据一致性的关键。以下代码演示了完整事务流程：

try:
    # 开始事务（隐式）
    cursor.execute("UPDATE accounts SET balance = balance - 100 WHERE id = 1")
    cursor.execute("UPDATE accounts SET balance = balance + 100 WHERE id = 2")
    conn.commit()  # 提交事务
except mysql.connector.Error as err:
    conn.rollback()  # 出错回滚
    print(f"交易失败：{err}")
finally:
    cursor.close()

事务的 ACID 特性

Cursor 教程中必须强调事务的四个特性： | 特性 | 含义 | 示例场景 | |------|------|----------| | 原子性 | 操作不可分割 | 转账必须同时成功或失败 | | 一致性 | 数据始终有效 | 转出账户余额不能为负 | | 隔离性 | 并发操作互不影响 | 多用户同时转账时数据隔离 | | 持久性 | 提交后永久保存 | 服务器重启数据不丢失 |

高级使用技巧与注意事项

性能优化策略

1. 使用 buffered=True 参数避免重复查询
2. 通过 dictionary=True 获取字典格式数据
3. 设置合适的 fetch 数量（通常 100-1000 条为宜）

cursor = conn.cursor(buffered=True, dictionary=True)

cursor.execute("SELECT * FROM products WHERE category = %s", ("Electronics",))

for product in cursor:
    print(f"商品名称：{product['name']}，价格：{product['price']}")

常见错误解决方案

资源管理最佳实践

Cursor 教程中必须强调及时关闭资源，以下代码展示了优雅的关闭方式：

def safe_query():
    conn = mysql.connector.connect(...)
    cursor = conn.cursor()
    try:
        cursor.execute("SELECT * FROM temp_table")
        return cursor.fetchall()
    except:
        conn.rollback()
        raise
    finally:
        cursor.close()  # 确保游标关闭
        conn.close()    # 关闭数据库连接

总结与进阶建议

Cursor 教程中我们探讨了游标的创建、查询执行、结果处理和事务管理等核心内容。作为数据库操作的基础组件，Cursor 的使用直接影响程序的性能和稳定性。建议开发者：

1. 始终使用参数化查询防止 SQL 注入
2. 处理大数据时采用分页方式
3. 掌握事务的提交与回滚机制
4. 在 finally 块中关闭游标和连接
5. 使用字典游标提升代码可读性

对于想要深入学习的读者，可以尝试研究存储过程调用、游标更新操作等进阶内容。记住，就像学习任何新技能一样，Cursor 的掌握需要通过实际项目中的不断实践才能真正精通。建议从简单的 SELECT 查询开始，逐步过渡到复杂的事务处理场景。