多线程下的Sqlite(三)

在多线程下每个线程使用各自的句柄

#include <stdio.h>
#include "sqlite3/sqlite3.h"
#include <thread>
#include <mutex>

std::mutex mutex;

void func1()
{
    int i = 1;

    sqlite3 *db; 
    sqlite3_open("./testdb", &db);

    const char *insert_sql = "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) "  \
                                "VALUES (1, 'zhangsan', 32, 'China', 100) "; 
    const char *update_sql = "UPDATE COMPANY set SALARY = 200 where ID = 2";

    char *errmsg = NULL;
    while(i < 100)
    {
        errmsg = NULL;
        sqlite3_exec(db, insert_sql, NULL, 0, &errmsg);
        if(errmsg)
        {
            printf("func1 1 %s\n", errmsg);
        }
        errmsg = NULL;
        sqlite3_exec(db, update_sql, NULL, 0, &errmsg);
        if(errmsg)
        {
            printf("func1 2 %s\n", errmsg);
        }
        i++;
    }   
}

void func2()
{
    int i = 1;

    sqlite3 *db; 
    sqlite3_open("./testdb", &db);

    const char *insert_sql = "INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) "  \
                                "VALUES (2, 'zhangsan', 32, 'China', 100) "; 
    const char *update_sql = "UPDATE COMPANY set SALARY = 200 where ID = 1";

    char *errmsg = NULL;
    while(i < 100)
    {
        errmsg = NULL;
        sqlite3_exec(db, insert_sql, NULL, 0, &errmsg);
        if(errmsg)
        {
            printf("func2 1 %s\n", errmsg);
        }
        errmsg = NULL;
        sqlite3_exec(db, update_sql, NULL, 0, &errmsg);
        if(errmsg)
        {
            printf("func2 2 %s\n", errmsg);
        }
        i++;
    }   
}

int main()
{
    int status = sqlite3_config(SQLITE_CONFIG_MULTITHREAD);
    int mode = sqlite3_threadsafe();

    printf("status: %d mode: %d\n", status, mode);

    sqlite3 *db; 
    sqlite3_open("./testdb", &db);

    const char *create_sql = "CREATE TABLE COMPANY("
                                "ID             INT     NOT NULL,"
                                "NAME           TEXT,"
                                "AGE            INT,"
                                "ADDRESS        CHAR(50),"
                                "SALARY         INT);";
    sqlite3_exec(db, create_sql, NULL, 0, NULL);

    sqlite3_close(db);

    std::thread t1(func1);
    std::thread t2(func2);


    t1.join();
    t2.join();

    
    //system("pause");
    return 0;
}

测试结果:
频繁: database is locked错误

序列化模型下使用唯一的数据库连接呢?

测试结果: 代码差别不大就不贴了, 在序列化模型中使用同一个数据库连接能够保证每条SQL语句正确执行
ps: 多个句柄会出现database is locked错误

结论

  In this mode, SQLite can be safely used by multiple threads provided that no single database connection is used simultaneously in two or more threads.在多线程模型下官方指明的线程安全指的是应当不会出现磁盘错误这种的问题(导致数据库出问题), 而不是说能够保证SQL语句正常执行(会被驳回请求)

  必须明确的一点是: 多线程模式下不应当在不同的线程中使用相同的句柄, 如果不加锁的话甚至可能导致数据库出现问题

  对于序列化来说, 无论怎么样都不会出现 database disk image is malformed这样的错误, 但如果在多线程中使用多个数据库句柄仅仅是会被驳回请求

bCoreMutex和bFullMutex

在多线程模型下仅开启bCoreMutex, 那么我们可以猜测一下这两个锁的用途?

bCoreMutex: 该锁保证了不同数据库句柄不会同时对数据库修改(多线程模型多连接情况仅仅会被驳回请求)
不会有多个数据库句柄同时执行数据库修改语句
bFullMutex: 保证了单个数据库句柄中不会多个SQL语句同时对数据库修改(序列化模型但数据库连接被多个线程使用仅仅会被驳回请求)
不会有多条SQL语句同时修改数据库