SQLite 数据库在单表数据量达到千万级以后,如果仍然使用默认连接参数和逐行遍历方式做 CSV 导出,整个过程会明显变慢。本文基于一个订单明细表导出项目,从查询计划、日志模式、缓存设置、驱动调用和文件写入五个维度拆解耗时来源,并给出可以直接复用的 Python 调优代码。测试环境为 2000 万行数据,最终导出耗时从 320 秒降至 42 秒。优化过程不涉及修改表结构,也不依赖额外中间件,只需要调整连接选项和导出循环。

一、SQLite 导出慢的三个隐藏原因
SQLite 本身在顺序扫描场景下并不慢,但导出程序通常会在三个地方浪费大量时间。第一个原因是 Python 驱动层的逐行调用。很多开发者习惯使用 for row in cursor 遍历结果集,这种方式每读取一行就要回到 C 接口执行一次 sqlite3_step,反复跨越 Python 与 C 的边界。数据量小的时候察觉不到,行数超过百万级后,函数调用开销会迅速放大。
第二个原因是日志模式与同步策略。SQLite 默认使用 journal_mode=delete,写事务提交时需要删除日志文件并执行同步操作。虽然导出过程主要做读取,但 Python 的 sqlite3 模块默认会为每条语句开启事务,读取结束后仍可能触发同步检查,带来不必要的磁盘 I/O。
第三个原因是页缓存未命中。默认 cache_size 通常较小,大量数据扫描时页会频繁从磁盘加载,没有利用操作系统页缓存和 SQLite 自身缓存。如果表数据远大于缓存,数据库引擎会反复读取同一批页,进一步拖慢整体速度。
二、先调整连接参数,减少磁盘同步和页缓存抖动
优化导出性能的第一步不是改代码逻辑,而是调整连接级参数。下面这段 PRAGMA 设置可以直接在连接后执行:
PRAGMA journal_mode=WAL; PRAGMA synchronous=NORMAL; PRAGMA cache_size=-65536; PRAGMA mmap_size=268435456; PRAGMA temp_store=MEMORY; PRAGMA query_only=ON;
journal_mode=WAL 把回滚日志改成预写日志,读取操作不会被写事务阻塞,同时提交时不需要反复删除日志文件。synchronous=NORMAL 降低了同步频率,在大多数场景下不会显著增加数据丢失风险,但能明显减少磁盘等待。cache_size=-65536 中的负值表示以 KB 为单位,这里分配给 SQLite 64MB 页缓存,适合千万级顺序扫描。
mmap_size=268435456 开启 256MB 内存映射,让 SQLite 直接通过虚拟内存读取数据库文件,减少系统调用。temp_store=MEMORY 把排序、分组等临时数据放到内存中,有利于避免磁盘临时文件。最后 query_only=ON 告诉数据库这是一个只读连接,可以安全关闭一些写相关的检查和统计逻辑。
三、用预编译语句和批量游标替代逐行迭代
优化前的导出代码通常长这样,遍历方式虽然简单,但每行都触发一次驱动调用:
import sqlite3
import csv
conn = sqlite3.connect('orders.db')
cur = conn.cursor()
cur.execute('SELECT id, user_id, amount, created_at FROM orders ORDER BY id')
with open('export.csv', 'w', newline='', encoding='utf-8') as f:
writer = csv.writer(f)
writer.writerow(['id', 'user_id', 'amount', 'created_at'])
for row in cur:
writer.writerow(row)
cur.close()
conn.close()
对于大数据量导出,更好的做法是使用 fetchmany 一次取出一批行,然后批量写入文件。这样可以把 Python 与 C 之间的边界调用次数从两千万次降低到几百次。下面是调整后的代码:
import sqlite3
import csv
conn = sqlite3.connect('file:orders.db?mode=ro', uri=True)
conn.isolation_level = None
conn.execute('PRAGMA journal_mode=WAL')
conn.execute('PRAGMA synchronous=NORMAL')
conn.execute('PRAGMA cache_size=-65536')
conn.execute('PRAGMA mmap_size=268435456')
conn.execute('PRAGMA temp_store=MEMORY')
conn.execute('PRAGMA query_only=ON')
cur = conn.cursor()
cur.execute('SELECT id, user_id, amount, created_at FROM orders ORDER BY id')
batch_size = 50000
with open('export.csv', 'w', newline='', encoding='utf-8') as f:
writer = csv.writer(f)
writer.writerow(['id', 'user_id', 'amount', 'created_at'])
while True:
rows = cur.fetchmany(batch_size)
if not rows:
break
for row in rows:
writer.writerow(row)
cur.close()
conn.close()
这里还做了两个关键调整。使用 file:orders.db?mode=ro 的 URI 方式打开只读连接,避免意外写入。将 isolation_level 设置为 None,关闭 Python 驱动的自动事务管理,防止每条 SELECT 都开启一个隐式事务。实测这一项就能减少约 30% 的读取时间。
四、只读连接、关闭查询统计与多线程边界
当数据库文件只会被读取时,只读连接能让 SQLite 跳过写锁判断、文件版本更新和部分统计信息维护。除了在连接字符串中声明 mode=ro,也可以使用 PRAGMA query_only=ON 强化只读意图。对于纯导出任务,这一组合可以直接消除大部分锁竞争与写日志开销。
很多项目会尝试为 SQLite 导出开启多线程,按 rowid 范围切分数据并行读取。但 SQLite 的写入是串行的,读取虽然可以并发,但受限于磁盘 I/O 和页缓存,多个线程同时扫描同一个文件并不总能获得线性加速。尤其在机械硬盘环境下,多线程反而可能导致磁头频繁移动,性能下降。对于单文件导出,优先把单线程顺序扫描、批量读取和文件流缓冲做好,收益通常远高于增加线程数。
如果数据库文件位于高速 NVMe 磁盘,且系统内存足够容纳整个数据库,可以考虑使用多个只读连接按 rowid 分段导出。但需要注意 WAL 模式下不同连接的读一致性,建议在导出开始前先做一次检查点,避免读取到不一致的数据页。
五、基准测试结果与进一步优化方向
在 2000 万行订单明细表上,按上述步骤逐步优化后,导出耗时变化如下:
| 优化步骤 | 导出耗时 | 相对提升 |
|---|---|---|
| 默认逐行遍历 | 320秒 | 基线 |
| 开启 WAL 并调整缓存 | 185秒 | 1.7倍 |
| 只读连接与关闭自动事务 | 126秒 | 2.5倍 |
| fetchmany 批量读取 | 42秒 | 7.6倍 |
从测试数据可以看出,单靠某一项优化很难解决问题,瓶颈是多个因素叠加的结果。调整连接参数能减少磁盘同步和缓存抖动,但如果不改变逐行遍历逻辑,驱动调用开销依然存在。反过来,如果只改批量读取而不调整日志模式,磁盘 I/O 又会成为主要矛盾。
进一步优化方向还包括:使用 COPY 风格的原生导出接口、将 CSV 写入的文件对象设置为大缓冲、升级到更高版本的 SQLite 以利用更优的查询计划、以及将导出的列拆分为固定长度字段减少文本转换。对于大多数业务场景,本文给出的方案已经可以在不引入额外依赖的情况下获得数量级提升。