天天看點

sqlite遇到database is locked問題的完美解決

這兩天在項目中用大強度大頻率的方法測試時遇到sqlite報database is locked的問題,

分析下來原因是sqlite對資料庫做修改操作時會做(檔案)鎖使得其它程序同一時間使用時會報該錯誤(也就是

SQLITE_BUSY),但如果僅是多程序或多線程查詢sqlite是支援的。(也有可能是做sql開啟事務查詢等發生異常,資料庫沒有關閉,然後再去打開就鎖定了)

解決方法有:

1。使用程序或線程間的同步機制以避免同時操作;如用信号量,互斥鎖等(pthread_mutex_lock,

pthread_mutex_unlock),如果你的項目工程較大要求較高的話建議用此方法自行封裝函數處理同步

2。使用sqlite提供的兩個busy handler函數,但對于一個連接配接來說,隻能有一個busy handle,兩個函數會互相影響,設

置一個的同時會清除另一個,應根據需要來選擇。

int sqlite3_busy_handler(sqlite3 *, int (*)(void *, int), void *)

不注冊此函數時預設回調函數為NULL,清除busy handle,申請不到鎖直接傳回;

函數可以定義一個回調函數,當出現資料庫忙時sqlite會調用該函數進行延時并傳回非0會重試本次操作,回調函數的第二個

參數會被傳遞為此次因BUSY忙事件而調用該函數的次數,是以你完全可以自行控制多少次後(也就是延時多少後)才真正傳回

BUSY;

回調函數傳回非0,資料庫會重試目前操作,傳回0則目前操作傳回SQLITE_BUSY;

int sqlite3_busy_timeout(sqlite3*, int ms);

不注冊此函數時預設逾時等待為0,當ms<=0時,清除busy handle,申請不到鎖直接傳回;

定義一個毫秒數,當未到達該毫秒數時,sqlite會sleep并重試目前操作,

如果超過ms毫秒,仍然申請不到需要的鎖,目前操作傳回SQLITE_BUSY;

很多人用這個函數沒有成功,其實隻要你仔細檢視sqlite的源碼就會發現,

這個函數實際上注冊了一個預設的sqlite3_busy_handler(sqliteDefaultBusyCallback),而這個回調函數在你的編譯

環境下可能使得第二個ms參數必需要大于1000且是他的整數倍才有意義,由于此預設callback函數延時較大,建議自己寫回

調函數然後用slite3_busy_handler注冊,這樣就可以自己用自己的延時函數或方法進行處理了.

附:===================================================================

static int sqliteDefaultBusyCallback(

void *ptr, /* Database connection */

int count /* Number of times table has been busy */

)

{

#if SQLITE_OS_WIN || (defined(HAVE_USLEEP) && HAVE_USLEEP)

static const u8 delays[] =

{ 1, 2, 5, 10, 15, 20, 25, 25, 25, 50, 50, 100 };

static const u8 totals[] =

{ 0, 1, 3, 8, 18, 33, 53, 78, 103, 128, 178, 228 };

# define NDELAY (sizeof(delays)/sizeof(delays[0]))

sqlite3 *db = (sqlite3 *)ptr;

int timeout = db->busyTimeout;

int delay, prior;

assert( count>=0 );

if( count < NDELAY ){

delay = delays[count];

prior = totals[count];

}else{

delay = delays[NDELAY-1];

prior = totals[NDELAY-1] + delay*(count-(NDELAY-1));

}

if( prior + delay > timeout ){

delay = timeout - prior;

if( delay<=0 ) return 0;

sqlite3OsSleep(db->pVfs, delay*1000);

return 1;

#else

int timeout = ((sqlite3 *)ptr)->busyTimeout;

if( (count+1)*1000 > timeout ){

return 0;//1000>timeout,so timeout must bigger than 1000

sqlite3OsSleep(db->pVfs, 1000000);//1000ms

#endif

int sqlite3_busy_timeout(sqlite3 *db, int ms){

if( ms>0 ){

db->busyTimeout = ms;

sqlite3_busy_handler(db, sqliteDefaultBusyCallback, (void*)db);

}else{13-11-27 sqlite遇到database is locked問題的完美解決

www.360doc.com/content/10/1214/12/87000_77984300.shtml 2/2

sqlite3_busy_handler(db, 0, 0);

return SQLITE_OK;

3、解決方法二

加上一個循環判斷。

while( 1 )

if( SQLITE_OK != sqlite3_exec( myconn, sql, 0, 0, &m_sqlerr_msg) )

if( strstr(m_sqlerr_msg, "database is locked") )

sleep(1);

continue;

break;

4、解決方法三

用信号量做PV操作

sem_p(semid,0);

sqlite3_exec( myconn, sql, 0, 0, &m_sqlerr_msg);

sem_v(semid,0);

QQ:519841366

本頁版權歸作者和部落格園所有,歡迎轉載,但未經作者同意必須保留此段聲明,

且在文章頁面明顯位置給出原文連結,否則保留追究法律責任的權利