微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

database is locked和SQLITE_BUSY

分类：Sqlite作者：编程之家

这是官方网站找到的解释：http://www.sqlite.org/cvstrac/wiki?p=DatabaseIsLocked


下面我做了几个实验：

1、多个线程（pthread），使用同一个句柄（一次sqlite3_open，同一个数据库文件），在多个线程中同时使用此句柄，这些线程中有的是进行select操作的，有的是进行update操作的，使用的都是sqlite3_exec函数；结果是没有发现database is locked错误；

程序源码（mutitrhead.c）：

#include <sqlite3.h>
#include <stdio.h>
#include <pthread.h>
#include <string.h>
#include "main.h"

#ifdef _WIN32
#include <windows.h>
#define sleep(x) Sleep((x)*1000)
#else
#define sleep(x) sleep(x)
#endif

#define CREATE_sql      \
        "CREATE TABLE IF NOT EXISTS \"mutiprocess\" ("              \
        "\"id\"  INTEGER NOT NULL PRIMARY KEY,"       \
        "\"src\"  TEXT(1024),"                   \
        "\"videotype\"  INTEGER NOT NULL,"              \
        "\"postfiledir\"  TEXT(1024)"                   \
        ");"
#define REPLACE_sql "REPLACE INTO mutiprocess (id,src,videotype,postfiledir) VALUES(NULL,%d,%d)"
#define UPDATE_sql "UPDATE mutiprocess SET videotype = '2' WHERE id = 1"
#define SELECT_sql "SELECT * FROM mutiprocess"

static void* select_cf(void *param)
{
        int rc = -1;
        sqlite3 *db = (sqlite3*)param;
        char *szErrMsg;
        pthread_t tid;

        tid = pthread_self();
        while(1){
                rc = sqlite3_exec(db,SELECT_sql,&szErrMsg);
                if (rc != sqlITE_OK) {
                        printf("tid %u -- select error.[%s] -- rc=[%d]\n",tid,szErrMsg,rc);
                        if(strstr(szErrMsg,"database is locked")){
                                printf("<database is locked> when executing [%s],retry after 1 second.\n",SELECT_sql);
                        }
                }else{
                        printf("tid %u -- successfully execute [%s].\n",SELECT_sql);
                }
                sleep(1);
        }
}

static void* update_cf(void *param)
{
        int rc = -1;
        sqlite3 *db = (sqlite3*)param;
        char *szErrMsg;
        pthread_t tid;

        tid = pthread_self();
        while(1){
                rc = sqlite3_exec(db,UPDATE_sql,&szErrMsg);
                if (rc != sqlITE_OK) {
                        printf("tid %u -- update error.[%s] -- rc=[%d]\n",UPDATE_sql);
                        }
                }else{
                        printf("tid %u -- successfully execute [%s].\n",UPDATE_sql);
                }
                sleep(1);
        }
}

int main()
{
        pthread_t pid[20];
        int rc;
        sqlite3 *db = 0;
        char *szErrMsg;
        int i = 0;
        char sql[1024] = {0};

        rc = sqlite3_open("mutiprocess.db",&db);
        if (rc != sqlITE_OK) {
                printf("open sqlite3 error.\n");
        }

        rc = sqlite3_exec(db,CREATE_sql,&szErrMsg);
        if (rc != sqlITE_OK) {
                printf("create db error-[%s]\n",szErrMsg);
        }

        for(i = 0; i < 4; i++){
                sprintf(sql,REPLACE_sql,i,i);
                rc = sqlite3_exec(db,sql,&szErrMsg);
                if (rc != sqlITE_OK) {
                        printf("replace db error-[%s]\n",szErrMsg);
                }
        }

        for(i = 0; i < 10; i++){
                pthread_create(&(pid[i]),select_cf,db);
                pthread_detach(pid[i]);
        }
        for(; i < 20; i++){
                pthread_create(&(pid[i]),update_cf,db);
                pthread_detach(pid[i]);
        }

        while(1){
                sleep(-1);
        }
        return 0;
}

编译：gcc -o mutitrhead mutitrhead.c -lsqlite3 -lpthread

运行：./mutithread

注意：只运行这一个进程没有发现任何database is locked的错误提示；如果在运行一个./mutithread进程，那么两个进程都会出现database is locked错误；如果kill掉其中一个进程，那么另外一个不再出现database is locked；

注意两个进程和一个进程的区别，一个是进程数不同，一个是使用的数据库句柄连接不同；上述程序虽然在一个进程中使用了多线程，但是多个线程都是使用了同一个数据库连接（使用一个sqlite3_open返回的句柄），不好区分是什么问题（其实官方网站有一句话很重要『sqlITE_BUSY means that another database connection (probably in another process) is using the database in a way that prevents you from using it』）；这其实已经说明了产生database is locked的原因了，就是出在多个连接上，那么我们在做下面的实验；

2、同一个进程，启动多个线程，每个线程中都打开一个连接（connection，使用一个sqlite3_open返回的句柄），并且在其中做select或者update的操作；结果会出现database is locked错误；

程序源码（muticonnection.c）：

#include <sqlite3.h>
#include <stdio.h>
#include <pthread.h>
#include <string.h>
#include "main.h"

#ifdef _WIN32
#include <windows.h>
#define sleep(x) Sleep((x)*1000)
#else
#define sleep(x) sleep(x)
#endif

#define CREATE_sql      \
        "CREATE TABLE IF NOT EXISTS \"mutiprocess\" ("              \
        "\"id\"  INTEGER NOT NULL PRIMARY KEY,%d)"
#define UPDATE_sql "UPDATE mutiprocess SET videotype = '2' WHERE id = 1"
#define SELECT_sql "SELECT * FROM mutiprocess"

static void* select_cf(void *param)
{
        int rc;
        sqlite3 *db = 0;
        char *szErrMsg;
        int i = 0;
        char sql[1024] = {0};
        pthread_t tid;

        rc = sqlite3_open("mutiprocess.db",szErrMsg);
                }
        }

        tid = pthread_self();
        while(1){
                rc = sqlite3_exec(db,SELECT_sql);
                }
                sleep(1);
        }
}

static void* update_cf(void *param)
{
        int rc;
        sqlite3 *db = 0;
        char *szErrMsg;
        int i = 0;
        char sql[1024] = {0};
        pthread_t tid;

        rc = sqlite3_open("mutiprocess.db",UPDATE_sql);
                }
                sleep(1);
        }
}

int main()
{
        pthread_t pid[20];
        int i = 0;

        for(i = 0; i < 10; i++){
                pthread_create(&(pid[i]),0);
                pthread_detach(pid[i]);
        }
        for(; i < 20; i++){
                pthread_create(&(pid[i]),0);
                pthread_detach(pid[i]);
        }

        while(1){
                sleep(-1);
        }
        return 0;
}

编译：gcc -o muticonnection muticonnection.c -lsqlite3 -lpthread

运行：./muticonnection


总结：看来出现这个错误是因为多数是因为使用了多个连接(多个sqlite3_open返回的句柄)导致的，这里我的说法是“多数”，因为还有别的原因，请见官方网站的解释：http://www.sqlite.org/cvstrac/wiki?p=DatabaseIsLocked

还有一点要注意：

database is locked是sqlITE_BUSY的错误，不要和sqlITE_LOCKED混淆；

sqlITE_LOCKED（6） means the source of contention is internal and comes from the same database connection that received the sqlITE_LOCKED error.

sqlITE_BUSY（5） means that another database connection (probably in another process) is using the database in a way that prevents you from using it.

附：sqlITE_LOCKED(6)错误见：http://sqlite.1065341.n5.nabble.com/Begin-immediate-transaction-gt-SQLITE-BUSY-database-is-locked-td64878.html

原文地址：https://www.jb51.cc/sqlite/200788.html

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Java 嵌入数据处理引擎：SQLite 的挑战者 esProc SPL
SQLite架构简单，又有Json计算能力，有时会承担Json文件/RESTful的计算功能，但SQLite不能直接解析Json文件/RESTful，需要用Java代码硬写，或借助第三方类库，最后再拼成insert语句插入数据表，代码非常繁琐，这里就不展示了。参考前面的代码可知，入库的过程比较麻烦，不能只用SQL，还要借助Java或命令行。SPL是现代的数据计算语言，属于简化的面向对象的语言风格，有对象的概念，可以用点号访问属性并进行多步骤计算，但没有继承重载这些内容，不算彻底的面向对象语言。...
五、使用Python操作数据库
使用Python操作内置数据库SQLite以及MySQL数据库。
AndroidStudio-实现登录界面数据存储在SQLite
登陆界面
一文教会你导出微信聊天记录
破解微信数据库密码，用python导出微信聊天记录
UnitySqlite持久化数据
（Unity）SQLite 是一个软件库，实现了自给自足的、无服务器的、零配置的、事务性的 SQL 数据库引擎。SQLite 是在世界上最广泛部署的 SQL 数据库引擎。SQLite 源代码不受版权限制。本教程将告诉您如何使用 SQLite 编程，并让你迅速上手。.................................
Android用户登陆与注册功能的简单实现SQLite
安卓开发，利用SQLite实现登陆注册功能
SQLite——Java使用SQLite初体验
相比大多数数据库而言，具有等优势，广泛应用于、等领域。
使用SqlSugar连接多个数据库sqlserver，sqlite，mysql
有时候，一个项目只有一个数据库，比如只有SQLite，或者MySQL数据库，那么我们只需要使用一个固定的数据库即可。但是一个项目如果写好了，有多个用户使用，但是多个用户使用不同的数据库，这个时候，我们就需要把软件设计成可以连接多个数据库的模式，用什么数据库，就配置什么数据库即可。4.Users实体类，这个实体类要和数据库一样的，形成一一对应的关系。11.Sqlite数据库，需要在代码里面创建数据库，建立表，再建立数据。8.我们开启MySQL数据库，然后进行调试，看程序的结果。2.安装SqlSugar。
基于Android的背单词软件【源码+文档+答辩PPT】
基于Android的背单词软件，功能强大完整。
python ——操作sqlite 数据库
SQLite，是一款轻型的数据库，是遵守ACID的关系型数据库管理系统。说白了就是使用起来轻便简单，
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot