Python sqlite3多进程共享数据库锁检测异常，求正确操作语句

嘿，我来帮你理清楚这个问题！首先得明确：SQLite的锁机制是文件级的，和多线程场景完全不一样——多进程之间完全独立，不能共享连接对象，而且默认的事务行为很容易导致锁被长时间持有，看起来像是“独占”的情况。

下面直接给你能实现多进程合理共享数据库的语句序列，再拆解关键点：

核心原则先记牢 #

• 每个进程必须单独创建数据库连接，绝对不能在进程间传递或共享sqlite3.Connection对象，它完全不具备进程安全性。
• 及时提交/回滚事务，别让锁一直攥在手里！
• 开启WAL模式（Write-Ahead Logging），这是提升多进程并发能力的关键。

示例1：读进程的正确语句序列 #

如果你的进程只做读操作，可以用自动提交模式，避免持有共享锁太久：

import sqlite3

def read_from_db():
    # 独立创建连接，设置自动提交（isolation_level=None）
    conn = sqlite3.connect('your_shared_db.db', isolation_level=None)
    cursor = conn.cursor()
    
    # 开启WAL模式（只需在第一次连接时执行，后续执行也不会有问题）
    cursor.execute("PRAGMA journal_mode=WAL;")
    
    try:
        # 执行读操作
        cursor.execute("SELECT * FROM your_table WHERE some_condition;")
        results = cursor.fetchall()
        # 处理结果
        print(f"读取到数据：{results}")
    finally:
        # 一定要关闭连接，释放资源
        conn.close()

示例2：写进程的正确语句序列 #

写操作需要确保事务及时提交，避免长时间持有独占锁：

import sqlite3

def write_to_db(data):
    # 独立创建连接，设置READ COMMITTED隔离级别
    conn = sqlite3.connect('your_shared_db.db', isolation_level='READ COMMITTED')
    cursor = conn.cursor()
    
    cursor.execute("PRAGMA journal_mode=WAL;")
    
    try:
        # 执行写操作
        cursor.execute("INSERT INTO your_table (col1, col2) VALUES (?, ?);", data)
        # 立即提交事务！这一步会释放独占锁，让其他进程能访问数据库
        conn.commit()
        print("数据写入成功")
    except Exception as e:
        # 出错时回滚，同样要释放锁
        conn.rollback()
        print(f"写入失败：{e}")
    finally:
        conn.close()

为什么你之前的测试会出现“双独占”？ #

大概率是这两个原因：

1. 事务没及时提交/回滚：如果某个进程开启了事务（默认隔离级别是DEFERRED，执行第一条SQL时就会启动事务）但没提交，锁会一直被持有。另一个进程尝试操作时，会等待锁释放，看起来像是“也独占了”，其实是阻塞等待。
2. 没开启WAL模式：默认的DELETE日志模式下，写操作会立即获取独占锁，完全阻塞所有读操作，很容易让你误以为两个进程都在独占。

额外小贴士 #

• 如果你的场景是多进程频繁读写，WAL模式几乎是必须的——它允许读和写并发执行，读操作不会被写阻塞，写操作也只会短暂持有锁。
• 避免长时间运行的事务：不管是读还是写，事务越短，锁被持有的时间就越短，冲突概率越低。

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