zwo*_*wol 3 python sqlite multithreading journal
SQLite 文档说(这里)您可以通过在单独的线程上运行检查点来避免 WAL 模式下的检查点暂停。我试过这个,但它似乎不起作用:“ -wal”文件无限制地增长,不清楚是否真的有任何东西被复制回主数据库文件,并且(最重要的是)在-wal文件变得足够大之后(超过 1 GB)主线程开始不得不等待检查指针。
在我的应用程序中,主线程不断地做一些本质上与此等效的事情,其中generate_data将吐出要插入的一百万行的顺序:
db = sqlite3.connect("database.db")
cursor = db.cursor()
cursor.execute("PRAGMA wal_autocheckpoint = 0")
for datum in generate_data():
# It is a damned shame that there is no way to do this in one operation.
cursor.execute("SELECT id FROM strings WHERE str = ?", (datum.text,))
row = cursor.fetchone()
if row is not None:
id = row[0]
else:
cur.execute("INSERT INTO strings VALUES(NULL, ?)", (datum.text,))
id = cur.lastrowid
cursor.execute("INSERT INTO data VALUES (?, ?, ?)",
(id, datum.foo, datum.bar))
batch_size += 1
if batch_size > batch_limit:
db.commit()
batch_size = 0
Run Code Online (Sandbox Code Playgroud)
并且检查点线程执行以下操作:
db = sqlite3.connect("database.db")
cursor = db.cursor()
cursor.execute("PRAGMA wal_autocheckpoint = 0")
while True:
time.sleep(10)
cursor.execute("PRAGMA wal_checkpoint(PASSIVE)")
Run Code Online (Sandbox Code Playgroud)
(在单独的线程上,它们必须与数据库建立单独的连接,因为 pysqlite 不支持在多个线程之间共享连接。)更改为 FULL 或 RESTART 检查点无济于事 - 然后检查点就会失败。
我如何使这真正起作用?需要的是:1)主线程永远不必等待,2)日志文件不会无限制地增长。
检查点需要锁定整个数据库,因此必须阻止所有其他读取和写入。(被动检查点只是中止。)
因此,在单独的线程中运行检查点不会增加并发性。(SQLite 文档建议这样做只是因为主线程可能没有设计为在空闲时刻处理检查点。)
如果连续访问数据库,则无法检查点。如果您的批处理操作使 WAL 文件变得太大,您应该在该循环中插入显式检查点(或依赖自动检查点)。