如何将pyodbc的cursor.fetchone定位到指定行 读取SQL Server特定范围数据

能否直接让cursor.fetchone从第70000行开始读取？ #

不能。pyodbc的默认游标为前向只读游标，执行查询后会按顺序拉取结果集，没有原生方法直接跳转到指定行位置。如果强行在客户端循环读取前70000行并丢弃，会浪费大量带宽和内存，性能极差完全不推荐。

最优实现方案：在SQL侧完成分页过滤 #

你需要的是10万行数据中第70001到90000行的内容，直接修改查询逻辑在SQL Server侧完成过滤，仅返回需要的行即可，两种常用写法适配不同版本SQL Server：

1. SQL Server 2012及以上版本使用OFFSET/FETCH语法（更简洁）

-- 必须指定唯一排序字段，否则行顺序无固定规则，查询结果可能不一致，示例用OID作为排序字段
SELECT * FROM 你的目标表
ORDER BY OID ASC
OFFSET 70000 ROWS
FETCH NEXT 20000 ROWS ONLY;

2. SQL Server 2008及更低版本使用ROW_NUMBER()窗口函数

SELECT * FROM (
    SELECT *, ROW_NUMBER() OVER (ORDER BY OID ASC) AS 行号
    FROM 你的目标表
) AS 临时结果集
WHERE 行号 BETWEEN 70001 AND 90000;

如果你的查询逻辑封装在存储过程中，可以给存储过程新增@offset、@limit两个输入参数，把分页逻辑写入存储过程内部，执行时传入对应参数即可。

修改后的Python代码示例 #

import pyodbc

try:
    CONNECTION_STRING = f'DRIVER={driver};SERVER={server};DATABASE={databaseName};UID={username};PWD={password}'
    conn = pyodbc.connect(CONNECTION_STRING)
    cursor = conn.cursor()
    
    # 直接执行分页SQL的写法
    sql = """
    SELECT * FROM 你的目标表
    ORDER BY OID ASC
    OFFSET 70000 ROWS
    FETCH NEXT 20000 ROWS ONLY;
    """
    cursor.execute(sql)
    # 用fetchmany一次性读取目标行数，效率比逐行fetchone更高
    rows = cursor.fetchmany(20000)
    for row in rows:
        OID = int(row[1])
        print(OID)
    
    # 存储过程调用示例（假设存储过程接收offset和count两个参数）
    # storedproc = "EXEC 你的存储过程名 @offset=?, @count=?"
    # cursor.execute(storedproc, (70000, 20000))

finally:
    # 及时释放资源避免连接泄露
    if 'cursor' in locals():
        cursor.close()
    if 'conn' in locals():
        conn.close()

补充注意点 #

• 分页必须指定唯一、稳定的排序字段，避免新数据插入导致行顺序变化，出现漏读/多读的问题
• 如果要查询的是最新写入的2-3万行，可以直接按自增ID/写入时间倒序排序，取前2万行即可，不需要计算offset

内容的提问来源于stack exchange，提问作者Beau