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
sqlite3 *db = (sqlite3 *)ptr;
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
return 1;
#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;
}
三、解決方法二
加上一個循環判斷。
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;
}
}
四、解決方法三
用信號量作PV操做
sem_p(semid,0);
sqlite3_exec( myconn, sql, 0, 0, &m_sqlerr_msg);
sem_v(semid,0);html

 

http://www.360doc.com/content/10/1214/12/87000_77984300.shtmlsql

相關文章
相關標籤/搜索