PHP下SQLite并发读写及先读后写SQL实现技术问询

阿华AIGC实验室

2026-5-20

嘿，我来帮你搞定这两个SQLite+PHP的问题，都是实际开发里常遇到的场景，咱们一个个说清楚：

1. PHP实现SQLite数据库的并发读写

首先得明确：SQLite是文件型数据库，它的并发模型和MySQL这类客户端-服务器数据库不一样——默认情况下，写操作会抢占独占锁，这时候所有其他读写请求都会被阻塞，直到写锁释放。所以要优化并发读写，核心是减少锁的持有时间，合理利用事务机制：

缩短写事务的执行时间：别在事务里做非数据库操作（比如调用外部API、做大量计算），写完立刻提交/回滚，别让锁占着资源不放。
选对事务模式：SQLite支持三种事务模式，默认是DEFERRED（延迟加锁，直到真正执行写操作才加锁），如果想提前锁定避免后续冲突，可以用IMMEDIATE（立即获取写锁，允许其他读操作）或者EXCLUSIVE（完全独占，阻塞所有其他操作）。
读操作尽量用只读连接：如果只是查数据，打开连接时指定只读模式，这样不会和写操作抢锁，效率更高。

给你个PHP+PDO的代码示例：

// 读写连接示例
$db = new PDO('sqlite:/path/to/your/animal.db');
// 开启异常模式，方便捕获错误
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

try {
    // 用IMMEDIATE模式开启事务，提前获取写锁，避免中途被其他写操作打断
    $db->beginTransaction('IMMEDIATE');

    // 执行写操作（比如更新数据）
    $updateStmt = $db->prepare("UPDATE Animal SET localStatus = 'updated' WHERE id = ?");
    $updateStmt->execute([1]);

    // 同一个事务里执行读操作
    $selectStmt = $db->prepare("SELECT * FROM Animal WHERE id = ?");
    $selectStmt->execute([1]);
    $animal = $selectStmt->fetch(PDO::FETCH_ASSOC);

    // 提交事务，释放锁
    $db->commit();
} catch (PDOException $e) {
    // 出错回滚，避免数据不一致
    $db->rollBack();
    echo "操作翻车了: " . $e->getMessage();
}

// 只读连接示例（纯查询场景用这个）
$readOnlyDb = new PDO('sqlite:/path/to/your/animal.db', '', '', [
    PDO::SQLITE_ATTR_OPEN_FLAGS => PDO::SQLITE_OPEN_READONLY
]);
$stmt = $readOnlyDb->prepare("SELECT * FROM Animal WHERE localStatus = 'locallyDisplayed'");
$stmt->execute();
$results = $stmt->fetchAll(PDO::FETCH_ASSOC);

注意：如果是高并发写的场景（比如每秒几十上百次写），SQLite可能不是最优选择，毕竟单文件锁的瓶颈摆在那。但中小流量的话，上面的方法完全够用。

2. 实现先读后写的SQL操作（事务安全版）

首先给你提个醒：你原始的查询语句有个小坑——WHERE子句里不能直接用SELECT里定义的别名diff！因为SQL的执行顺序是先处理WHERE，再处理SELECT的别名，所以WHERE根本不知道diff是什么。得先修正这个问题，然后再实现安全的先读后写。

核心思路：把读和写放到同一个事务里，这样能保证读取的数据在写操作时不会被其他进程修改，避免脏写。

修正后的实现步骤：

开启事务（用IMMEDIATE模式提前锁表，防止并发冲突）
读取符合条件的数据（修正查询语句，或者用CTE简化逻辑）
执行更新操作（用和读取一致的条件，或者用主键定位更精准）
提交事务

给你写个完整的PHP代码示例：

$db = new PDO('sqlite:/path/to/your/animal.db');
$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

try {
    $db->beginTransaction('IMMEDIATE');

    // 第一步：读取符合条件的数据，这里用CTE避免重复写计算逻辑
    $query = "
        WITH TargetAnimals AS (
            SELECT id, animalName, longitude, latitude,
                   cast(((strftime('%s', CURRENT_TIMESTAMP) - strftime('%s', time)) / 60) as INTEGER) as diff
            FROM Animal
            WHERE localStatus = 'locallyDisplayed'
        )
        SELECT * FROM TargetAnimals WHERE diff > 30;
    ";
    $stmt = $db->prepare($query);
    $stmt->execute();
    $targetAnimals = $stmt->fetchAll(PDO::FETCH_ASSOC);

    // 可以在这里处理读取到的数据，比如打个日志
    echo "找到 " . count($targetAnimals) . " 条需要更新的数据\n";

    // 第二步：执行更新操作，用主键ID定位更精准
    if (!empty($targetAnimals)) {
        $ids = array_column($targetAnimals, 'id');
        $placeholders = implode(',', array_fill(0, count($ids), '?'));
        $updateStmt = $db->prepare("
            UPDATE Animal
            SET localStatus = 'notlocallyDisplayed'
            WHERE id IN ($placeholders)
        ");
        $updateStmt->execute($ids);
        echo "成功更新 " . $updateStmt->rowCount() . " 条数据\n";
    }

    $db->commit();
} catch (PDOException $e) {
    $db->rollBack();
    echo "操作失败: " . $e->getMessage();
}