有时我会偶然遇到：
OperationalError: database is locked
在更新SQLite数据库的过程中，但我发现很难重现这个错误：
SELECT等），但没有提交我已经阅读了OperationalError: database is locked
问题：是否有一种方法，在发生此错误时记录负责锁定的其他进程ID？
更一般地说，如何调试OperationalError: database is locked？
import sqlite3
conn = sqlite3.connect('anothertest.db')
conn.execute("CREATE TABLE IF NOT EXISTS mytable (id int, description text)")
for i in range(100):
conn.execute("INSERT INTO mytable VALUES(%i, 'hello')" % i)
conn.commit()
接着进行一个只读查询：
用于初始化测试。
import sqlite3, time
conn = sqlite3.connect('anothertest.db')
c = conn.cursor()
c.execute('SELECT * FROM mytable')
item = c.fetchone()
print(item)
print('Sleeping 60 seconds but the cursor is not closed...')
time.sleep(60)
在执行下一步操作时，请保持此脚本运行：
然后尝试删除一些内容并提交：
import sqlite3
conn = sqlite3.connect('anothertest.db')
conn.execute("DELETE FROM mytable WHERE id > 90")
conn.commit()
的确会触发这个错误：
sqlite3.OperationalError: database is locked
为什么呢？因为无法删除当前正在被读取查询访问的数据：如果游标仍然处于打开状态，那么数据仍然可以使用 fetchone 或 fetchall 获取。
以下是解决此错误的方法：在第2步中，只需添加：
item = c.fetchone()
print(item)
c.close()
time.sleep(60)
在此同时，启动脚本#3，您会发现没有更多的错误。
import logging
import sys
import time
import threading
from contextlib import contextmanager
from uuid import uuid4
logger = logging.getLogger(__name__)
@contextmanager
def logged_transaction(con, stack_info=False, level=logging.DEBUG):
"""Manage a transaction and log start and end times.
Logged messages include a UUID transaction ID for ease of analysis.
If trace is set to True, also log all statements executed.
If stack_info is set to True, a stack trace is included to record
where the transaction was started (the last two lines will point to this
context manager).
"""
transaction_id = uuid4()
thread_id = threading.get_ident()
def _trace_callback(statement):
logger.log(level, '(txid %s) executing %s', transaction_id, statement)
if trace:
con.set_trace_callback(_trace_callback)
logger.log(level, '(txid %s) starting transaction', transaction_id, stack_info=stack_info)
start = time.time()
try:
with con:
yield con
finally:
# record exception information, if an exception is active
exc_info = sys.exc_info()
if exc_info[0] is None:
exc_info = None
if trace:
con.set_trace_callback(None)
logger.log(level, '(txid %s) transaction closed after %.6f seconds', transaction_id, time.time() - start, exc_info=exc_info)
with logged_transaction(connection):
cursor = connection.cursor()
# ...
也许仅使用这个上下文管理器就可以解决您的问题，此时您需要分析为什么没有这个上下文管理器的代码会留下未提交的事务。
您可能还想在sqlite3.connect()调用中使用较低的timeout值以加快进程速度；您可能不必等待完整的5分钟来检测情况。
关于线程的注意事项：启用跟踪时，假定您为不同的线程使用单独的连接。如果不是这种情况，则需要永久注册跟踪回调，然后解决当前线程要使用哪个事务 ID 的问题。
sqlite3.connect()调用的默认timeout值）。 - Martijn Pieterslsof，您可以使用它来查找打开该文件的每个进程，并查看哪个进程有锁定 - 可能是正在进行 select 操作的那个进程。如果您希望数据库读取器不会阻塞数据库写入器，反之亦然，请查看 WAL 日志模式。 - Shawn