SQLite入门与分析(四)---Page Cache之事务处理3

11、删除日志文件(Deleting The Rollback Journal)
一旦更改写入设备，日志文件将会被删除，这是事务真正提交的时刻。如果在这之前系统发生崩溃，就会进行恢复处理，使得数据库和没发生改变一样；如果在这之后系统发生崩溃，表明所有的更改都已经写入磁盘。sqlite就是根据日志存在情况决定是否对数据库进行恢复处理。

删除文件本质上不是一个原子操作，但是从用户进程的角度来看是一个原子操作，所以一个事务看起来是一个原子操作。
在许多系统中，删除文件也是一个高代价的操作。作为优化，sqlite可以配置成把日志文件的长度截为0或者把日志文件头清零。

12、释放锁(Releasing The Lock)
作为原子提交的最后一步，释放排斥锁使得其它进程可以开始访问数据库了。
下图中，我们指明了当锁被释放的时候用户空间所拥有的信息已经被清空了.对于老版本的sqlite你可这么认为。但最新的sqlite会保存些用户空间的缓存不会被清空—万一下一个事务开始的时候，这些数据刚好可以用上呢。重新利用这些内存要比再次从操作系统磁盘缓存或者硬盘中读取要来得轻松与快捷得多，何乐而不为呢？在再次使用这些数据之前，我们必须先取得一个共享锁，同时我们还不得不去检查一下，保证还没有其他进程在我们拥有共享锁之前对数据库文件进行了修改。数据库文件的第一页中有一个计数器，数据库文件每做一次修改，这个计数器就会增长一下。我们可以通过检查这个计数器就可得知是否有其他进程修改过数据库文件。如果数据库文件已经被修改过了，那么用户内存空间的缓存就不得不清空，并重新读入。大多数情况下，这种情况不大会发生，因此用户空间的内存缓存将是有效的，这对于性能提高来说作用是显著的。

以上两步是在sqlite3BtreeCommit()---btree.c函数中实现的。

代码如下：

Code @H_301_62@*@H_301_62@p){
BtShared@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@p@H_301_62@->@H_301_62@pBt;

btreeIntegrity(p);

/*Ifthehandlehasawrite-transactionopen,committheshared-btrees
**transactionandsetthesharedstatetoTRANS_READ.
*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@inTrans@H_301_62@==@H_301_62@TRANS_WRITE){
int@H_301_62@rc;
assert(pBt@H_301_62@->@H_301_62@inTransaction@H_301_62@==@H_301_62@TRANS_WRITE);
assert(pBt@H_301_62@->@H_301_62@nTransaction@H_301_62@>0@H_301_62@);

//调用pager，提交事务
@H_301_62@rc@H_301_62@=@H_301_62@sqlite3pager_commit(pBt@H_301_62@->@H_301_62@pPager);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
return@H_301_62@rc;
}
pBt@H_301_62@->@H_301_62@inTransaction@H_301_62@=@H_301_62@TRANS_READ;
pBt@H_301_62@->@H_301_62@inStmt@H_301_62@=@H_301_62@0@H_301_62@;
}
unlockAllTables(p);

/*Ifthehandlehasanykindoftransactionopen,decrementthetransaction
**countofthesharedbtree.Ifthetransactioncountreaches0,set
**thesharedstatetoTRANS_NONE.TheunlockBtreeIfUnused()callbelow
**willunlockthepager.
*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@inTrans@H_301_62@!=@H_301_62@TRANS_NONE){
pBt@H_301_62@->@H_301_62@nTransaction@H_301_62@--@H_301_62@;
if@H_301_62@(0@H_301_62@==@H_301_62@pBt@H_301_62@->@H_301_62@nTransaction){
pBt@H_301_62@->@H_301_62@inTransaction@H_301_62@=@H_301_62@TRANS_NONE;
}
}
}

//提交事务，主要调用pager_unwritelock()函数
int@H_301_62@sqlite3pager_commit(Pager@H_301_62@*@H_301_62@pPager){
int@H_301_62@rc;
PgHdr@H_301_62@*@H_301_62@pPg;

if@H_301_62@(pPager@H_301_62@->@H_301_62@errCode){
return@H_301_62@pPager@H_301_62@->@H_301_62@errCode;
}
if@H_301_62@(pPager@H_301_62@->@H_301_62@state@H_301_62@<@H_301_62@PAGER_RESERVED){
return@H_301_62@sqlITE_ERROR;
}
TRACE2("COMMIT%d/n"@H_301_62@,PAGERID(pPager));
if@H_301_62@(MEMDB){
pPg@H_301_62@=@H_301_62@pager_get_all_dirty_pages(pPager);
while@H_301_62@(pPg){
clearHistory(PGHDR_TO_HIST(pPg,pPager));
pPg@H_301_62@->@H_301_62@dirty@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@inJournal@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@inStmt@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@needSync@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@pPrevStmt@H_301_62@=@H_301_62@pPg@H_301_62@->@H_301_62@pNextStmt@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@=@H_301_62@pPg@H_301_62@->@H_301_62@pDirty;
}
pPager@H_301_62@->@H_301_62@pDirty@H_301_62@=@H_301_62@0@H_301_62@;
#ifndefNDEBUG
for@H_301_62@(pPg@H_301_62@=@H_301_62@pPager@H_301_62@->@H_301_62@pAll;pPg;pPg@H_301_62@=@H_301_62@pPg@H_301_62@->@H_301_62@pNextAll){
PgHistory@H_301_62@*@H_301_62@pHist@H_301_62@=@H_301_62@PGHDR_TO_HIST(pPg,pPager);
assert(@H_301_62@!@H_301_62@pPg@H_301_62@->@H_301_62@alwaysRollback);
assert(@H_301_62@!@H_301_62@pHist@H_301_62@->@H_301_62@pOrig);
assert(@H_301_62@!@H_301_62@pHist@H_301_62@->@H_301_62@pStmt);
}
#endif@H_301_62@
pPager@H_301_62@->@H_301_62@pStmt@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@state@H_301_62@=@H_301_62@PAGER_SHARED;
return@H_301_62@sqlITE_OK;
}
if@H_301_62@(pPager@H_301_62@->@H_301_62@dirtyCache@H_301_62@==0@H_301_62@){
/*Exitearly(withoutdoingthetime-consumingsqlite3OsSync()calls)
**iftherehavebeennochangestothedatabasefile.*/@H_301_62@
assert(pPager@H_301_62@->@H_301_62@needSync@H_301_62@==0@H_301_62@);
rc@H_301_62@=@H_301_62@pager_unwritelock(pPager);
pPager@H_301_62@->@H_301_62@dbSize@H_301_62@=@H_301_62@@H_301_62@-1@H_301_62@;
return@H_301_62@rc;
}
assert(pPager@H_301_62@->@H_301_62@journalOpen);
rc@H_301_62@=@H_301_62@sqlite3pager_sync(pPager,0@H_301_62@,0@H_301_62@);

//删除文件,释放写锁
@H_301_62@if@H_301_62@(rc@H_301_62@==@H_301_62@sqlITE_OK){
rc@H_301_62@=@H_301_62@pager_unwritelock(pPager);
pPager@H_301_62@->@H_301_62@dbSize@H_301_62@=@H_301_62@@H_301_62@-1@H_301_62@;
}
return@H_301_62@rc;
}

//对数据库加readlock，删除日志文件
static@H_301_62@int@H_301_62@pager_unwritelock(Pager@H_301_62@*@H_301_62@pPager){
PgHdr@H_301_62@*@H_301_62@pPg;
int@H_301_62@rc;
assert(@H_301_62@!@H_301_62@MEMDB);
if@H_301_62@(pPager@H_301_62@->@H_301_62@state@H_301_62@<@H_301_62@PAGER_RESERVED){
return@H_301_62@sqlITE_OK;
}
sqlite3pager_stmt_commit(pPager);
if@H_301_62@(pPager@H_301_62@->@H_301_62@stmtOpen){
sqlite3OsClose(@H_301_62@&@H_301_62@pPager@H_301_62@->@H_301_62@stfd);
pPager@H_301_62@->@H_301_62@stmtOpen@H_301_62@=@H_301_62@0@H_301_62@;
}
if@H_301_62@(pPager@H_301_62@->@H_301_62@journalOpen){

//关闭日志文件
@H_301_62@sqlite3OsClose(@H_301_62@&@H_301_62@pPager@H_301_62@->@H_301_62@jfd);
pPager@H_301_62@->@H_301_62@journalOpen@H_301_62@=@H_301_62@0@H_301_62@;
//删除日志文件
@H_301_62@sqlite3OsDelete(pPager@H_301_62@->@H_301_62@zJournal);
sqliteFree(pPager@H_301_62@->@H_301_62@aInJournal);
pPager@H_301_62@->@H_301_62@aInJournal@H_301_62@=@H_301_62@0@H_301_62@;
for@H_301_62@(pPg@H_301_62@=@H_301_62@pPager@H_301_62@->@H_301_62@pAll;pPg;pPg@H_301_62@=@H_301_62@pPg@H_301_62@->@H_301_62@pNextAll){
pPg@H_301_62@->@H_301_62@inJournal@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@dirty@H_301_62@=@H_301_62@0@H_301_62@;
pPg@H_301_62@->@H_301_62@needSync@H_301_62@=@H_301_62@0@H_301_62@;
#ifdefsqlITE_CHECK_PAGES
pPg@H_301_62@->@H_301_62@pageHash@H_301_62@=@H_301_62@pager_pagehash(pPg);
#endif@H_301_62@
}
pPager@H_301_62@->@H_301_62@pDirty@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@dirtyCache@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@nRec@H_301_62@=@H_301_62@0@H_301_62@;
}else@H_301_62@{
assert(pPager@H_301_62@->@H_301_62@aInJournal@H_301_62@==0@H_301_62@);
assert(pPager@H_301_62@->@H_301_62@dirtyCache@H_301_62@==0@H_301_62@@H_301_62@||@H_301_62@pPager@H_301_62@->@H_301_62@useJournal@H_301_62@==0@H_301_62@);
}

//释放写锁，加读锁
@H_301_62@rc@H_301_62@=@H_301_62@sqlite3OsUnlock(pPager@H_301_62@->@H_301_62@fd,SHARED_LOCK);
pPager@H_301_62@->@H_301_62@state@H_301_62@=@H_301_62@PAGER_SHARED;
pPager@H_301_62@->@H_301_62@origDbSize@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@setMaster@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@needSync@H_301_62@=@H_301_62@0@H_301_62@;
pPager@H_301_62@->@H_301_62@pFirstSynced@H_301_62@=@H_301_62@pPager@H_301_62@->@H_301_62@pFirst;
return@H_301_62@rc;
}

下图可进一步描述该过程：

最后来看看sqlite3BtreeSync()和sqlite3BtreeCommit()是如何被调用的。

一般来说，事务提交方式为自动提交的话，在虚拟机中的OP_Halt指令实现提交事务，相关代码如下：

Code /*no-push*/@H_301_62@
p@H_301_62@->@H_301_62@pTos@H_301_62@=@H_301_62@pTos;
p@H_301_62@->@H_301_62@rc@H_301_62@=@H_301_62@pOp@H_301_62@->@H_301_62@p1;
p@H_301_62@->@H_301_62@pc@H_301_62@=@H_301_62@pc;
p@H_301_62@->@H_301_62@errorAction@H_301_62@=@H_301_62@pOp@H_301_62@->@H_301_62@p2;
if@H_301_62@(pOp@H_301_62@->@H_301_62@p3){
sqlite3SetString(@H_301_62@&@H_301_62@p@H_301_62@->@H_301_62@zErrMsg,pOp@H_301_62@->@H_301_62@p3,(char@H_301_62@*@H_301_62@)0@H_301_62@);
}
//设置虚拟机状态sqlITE_MAGIC_RUN为sqlITE_MAGIC_HALT,
//并提交事务
@H_301_62@rc@H_301_62@=@H_301_62@sqlite3VdbeHalt(p);
assert(rc@H_301_62@==@H_301_62@sqlITE_BUSY@H_301_62@||@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_OK);
if@H_301_62@(rc@H_301_62@==@H_301_62@sqlITE_BUSY){
p@H_301_62@->@H_301_62@rc@H_301_62@=@H_301_62@sqlITE_BUSY;
return@H_301_62@sqlITE_BUSY;
}
return@H_301_62@p@H_301_62@->@H_301_62@rc@H_301_62@?@H_301_62@sqlITE_ERROR:sqlITE_DONE;
}

//当虚拟机要停机时,调用该函数,如果VDBE改变了数据库且为自动
//提交模式，则提交这些改变
int@H_301_62@sqlite3VdbeHalt(Vdbe@H_301_62@*@H_301_62@p){
sqlite3@H_301_62@*@H_301_62@db@H_301_62@=@H_301_62@p@H_301_62@->@H_301_62@db;
int@H_301_62@i;
int@H_301_62@(@H_301_62@*@H_301_62@xFunc)(Btree@H_301_62@*@H_301_62@pBt)@H_301_62@=@H_301_62@0@H_301_62@;/*Functiontocalloneachbtreebackend*/@H_301_62@
int@H_301_62@isSpecialError;/*SettotrueifsqlITE_NOMEMorIOERR*/@H_301_62@

/*Thisfunctioncontainsthelogicthatdeterminesifastatementor
**transactionwillbecommittedorrolledbackasaresultofthe
**executionofthisvirtualmachine.
**
**Specialerrors:
**
**IfansqlITE_NOMEMerrorhasoccuredinastatementthatwritesto
**thedatabase,theneitherastatementortransactionmustberolled
**backtoensurethetree-structuresareinaconsistentstate.A
**statementtransactionisrolledbackifoneisopen,otherwisethe
**entiretransactionmustberolledback.
**
**IfansqlITE_IOERRerrorhasoccuredinastatementthatwritesto
**thedatabase,thentheentiretransactionmustberolledback.The
**I/Oerrormayhavecausedgarbagetobewrittentothejournal
**file.Werethetransactiontocontinueandeventuallyberolled
**backthatgarbagemightendupinthedatabasefile.
**
**Inbothoftheabovecases,theVdbe.errorActionvariableis
**ignored.Ifthesqlite3.autoCommitflagisfalseandatransaction
**isrolledback,itwillbesettotrue.
**
**Othererrors:
**
**Noerror:
**
*/@H_301_62@

if@H_301_62@(sqlite3MallocFailed()){
p@H_301_62@->@H_301_62@rc@H_301_62@=@H_301_62@sqlITE_NOMEM;
}
if@H_301_62@(p@H_301_62@->@H_301_62@magic@H_301_62@!=@H_301_62@VDBE_MAGIC_RUN){
/*Alreadyhalted.Nothingtodo.*/@H_301_62@
assert(p@H_301_62@->@H_301_62@magic@H_301_62@==@H_301_62@VDBE_MAGIC_HALT);
return@H_301_62@sqlITE_OK;
}
//释放虚拟机中所有的游标
@H_301_62@closeAllCursors(p);
checkActiveVdbeCnt(db);

/*Nocommitorrollbackneedediftheprogramneverstarted*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@pc@H_301_62@>=0@H_301_62@){

/*Checkforoneofthespecialerrors-sqlITE_NOMEMorsqlITE_IOERR*/@H_301_62@
isSpecialError@H_301_62@=@H_301_62@((p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_NOMEM@H_301_62@||@H_301_62@p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_IOERR)@H_301_62@?1@H_301_62@:0@H_301_62@);
if@H_301_62@(isSpecialError){
/*Thisloopdoesstaticanalysisofthequerytoseewhichofthe
**followingthreecategoriesitfallsinto:
**
**Read-only
**Querywithstatementjournal
**Querywithoutstatementjournal
**
**Wecoulddosomethingmoreelegantthanthisstaticanalysis(i.e.
**storethetypeofqueryaspartofthecompliationphase),but
**handlingmalloc()orIOfailureisafairlyobscureedgecaseso
**thisisprobablyeasier.Todo:Mightbeanopportunitytoreduce
**codesizeaverysmallamountthough
*/@H_301_62@
int@H_301_62@isReadOnly@H_301_62@=@H_301_62@1@H_301_62@;
int@H_301_62@isStatement@H_301_62@=@H_301_62@0@H_301_62@;
assert(p@H_301_62@->@H_301_62@aOp@H_301_62@||@H_301_62@p@H_301_62@->@H_301_62@nOp@H_301_62@==0@H_301_62@);
for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@p@H_301_62@->@H_301_62@nOp;i@H_301_62@++@H_301_62@){
switch@H_301_62@(p@H_301_62@->@H_301_62@aOp[i].opcode){
case@H_301_62@OP_Transaction:
isReadOnly@H_301_62@=@H_301_62@0@H_301_62@;
break@H_301_62@;
case@H_301_62@OP_Statement:
isStatement@H_301_62@=@H_301_62@1@H_301_62@;
break@H_301_62@;
}
}

/*Ifthequerywasread-only,weneeddonorollbackatall.Otherwise,
**proceedwiththespecialhandling.
*/@H_301_62@
if@H_301_62@(@H_301_62@!@H_301_62@isReadOnly){
if@H_301_62@(p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_NOMEM@H_301_62@&&@H_301_62@isStatement){
xFunc@H_301_62@=@H_301_62@sqlite3BtreeRollbackStmt;
}else@H_301_62@{
/*Weareforcedtorollbacktheactivetransaction.Beforedoing
**so,abortanyotherstatementsthishandlecurrentlyhasactive.
*/@H_301_62@
sqlite3AbortOtherActiveVdbes(db,p);
sqlite3RollbackAll(db);
db@H_301_62@->@H_301_62@autoCommit@H_301_62@=@H_301_62@1@H_301_62@;
}
}
}

/*Iftheauto-commitflagissetandthisistheonlyactivevdbe,then
**wedoeitheracommitorrollbackofthecurrenttransaction.
**
**Note:Thisblockalsorunsifoneofthespecialerrorshandled
**abovehasoccured.
*/@H_301_62@
//如果自动提交事务，则提交事务
@H_301_62@if@H_301_62@(db@H_301_62@->@H_301_62@autoCommit@H_301_62@&&@H_301_62@db@H_301_62@->@H_301_62@activeVdbeCnt@H_301_62@==1@H_301_62@){
if@H_301_62@(p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_OK@H_301_62@||@H_301_62@(p@H_301_62@->@H_301_62@errorAction@H_301_62@==@H_301_62@OE_Fail@H_301_62@&&@H_301_62@@H_301_62@!@H_301_62@isSpecialError)){
/*Theauto-commitflagistrue,andthevdbeprogramwas
**successfulorhitan'ORFAIL'constraint.Thismeansacommit
**isrequired.
*/@H_301_62@
//提交事务
@H_301_62@int@H_301_62@rc@H_301_62@=@H_301_62@vdbeCommit(db);
if@H_301_62@(rc@H_301_62@==@H_301_62@sqlITE_BUSY){
return@H_301_62@sqlITE_BUSY;
}else@H_301_62@if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
p@H_301_62@->@H_301_62@rc@H_301_62@=@H_301_62@rc;
sqlite3RollbackAll(db);
}else@H_301_62@{
sqlite3CommitInternalChanges(db);
}
}else@H_301_62@{
sqlite3RollbackAll(db);
}
}else@H_301_62@if@H_301_62@(@H_301_62@!@H_301_62@xFunc){
if@H_301_62@(p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_OK@H_301_62@||@H_301_62@p@H_301_62@->@H_301_62@errorAction@H_301_62@==@H_301_62@OE_Fail){
xFunc@H_301_62@=@H_301_62@sqlite3BtreeCommitStmt;
}else@H_301_62@if@H_301_62@(p@H_301_62@->@H_301_62@errorAction@H_301_62@==@H_301_62@OE_Abort){
xFunc@H_301_62@=@H_301_62@sqlite3BtreeRollbackStmt;
}else@H_301_62@{
sqlite3AbortOtherActiveVdbes(db,p);
sqlite3RollbackAll(db);
db@H_301_62@->@H_301_62@autoCommit@H_301_62@=@H_301_62@1@H_301_62@;
}
}

/*IfxFuncisnotNULL,thenitisoneofsqlite3BtreeRollbackStmtor
**sqlite3BtreeCommitStmt.Callitonceoneachbackend.Ifanerroroccurs
**andthereturncodeisstillsqlITE_OK,setthereturncodetothenew
**errorvalue.
*/@H_301_62@
assert(@H_301_62@!@H_301_62@xFunc@H_301_62@||@H_301_62@
xFunc@H_301_62@==@H_301_62@sqlite3BtreeCommitStmt@H_301_62@||@H_301_62@
xFunc@H_301_62@==@H_301_62@sqlite3BtreeRollbackStmt
);
for@H_301_62@(i@H_301_62@=0@H_301_62@;xFunc@H_301_62@&&@H_301_62@i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
int@H_301_62@rc;
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt){
rc@H_301_62@=@H_301_62@xFunc(pBt);
if@H_301_62@(rc@H_301_62@&&@H_301_62@(p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_OK@H_301_62@||@H_301_62@p@H_301_62@->@H_301_62@rc@H_301_62@==@H_301_62@sqlITE_CONSTRAINT)){
p@H_301_62@->@H_301_62@rc@H_301_62@=@H_301_62@rc;
sqlite3SetString(@H_301_62@&@H_301_62@p@H_301_62@->@H_301_62@zErrMsg,0@H_301_62@);
}
}
}

/*IfthiswasanINSERT,UPDATEorDELETEandthestatementwascommitted,
**setthechangecounter.
*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@changeCntOn@H_301_62@&&@H_301_62@p@H_301_62@->@H_301_62@pc@H_301_62@>=0@H_301_62@){
if@H_301_62@(@H_301_62@!@H_301_62@xFunc@H_301_62@||@H_301_62@xFunc@H_301_62@==@H_301_62@sqlite3BtreeCommitStmt){
sqlite3VdbeSetChanges(db,p@H_301_62@->@H_301_62@nChange);
}else@H_301_62@{
sqlite3VdbeSetChanges(db,0@H_301_62@);
}
p@H_301_62@->@H_301_62@nChange@H_301_62@=@H_301_62@0@H_301_62@;
}

/*Rollbackorcommitanyschemachangesthatoccurred.*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@rc@H_301_62@!=@H_301_62@sqlITE_OK@H_301_62@&&@H_301_62@db@H_301_62@->@H_301_62@flags@H_301_62@&@H_301_62@sqlITE_InternChanges){
sqlite3ResetInternalSchema(db,0@H_301_62@);
db@H_301_62@->@H_301_62@flags@H_301_62@=@H_301_62@(db@H_301_62@->@H_301_62@flags@H_301_62@|@H_301_62@sqlITE_InternChanges);
}
}

/*WehavesuccessfullyhaltedandclosedtheVM.Recordthisfact.*/@H_301_62@
if@H_301_62@(p@H_301_62@->@H_301_62@pc@H_301_62@>=0@H_301_62@){
db@H_301_62@->@H_301_62@activeVdbeCnt@H_301_62@--@H_301_62@;
}
p@H_301_62@->@H_301_62@magic@H_301_62@=@H_301_62@VDBE_MAGIC_HALT;
checkActiveVdbeCnt(db);

return@H_301_62@sqlITE_OK;
}

//提交事务,主要调用:
//sqlite3BtreeSync()---同步btree,sqlite3BtreeCommit()---提交事务
static@H_301_62@int@H_301_62@vdbeCommit(sqlite3@H_301_62@*@H_301_62@db){
int@H_301_62@i;
int@H_301_62@nTrans@H_301_62@=@H_301_62@0@H_301_62@;/*Numberofdatabaseswithanactivewrite-transaction*/@H_301_62@
int@H_301_62@rc@H_301_62@=@H_301_62@sqlITE_OK;
int@H_301_62@needXcommit@H_301_62@=@H_301_62@0@H_301_62@;

for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt@H_301_62@&&@H_301_62@sqlite3BtreeIsInTrans(pBt)){
needXcommit@H_301_62@=@H_301_62@1@H_301_62@;
if@H_301_62@(i@H_301_62@!=1@H_301_62@)nTrans@H_301_62@++@H_301_62@;
}
}

/*Ifthereareanywrite-transactionsatall,invokethecommithook*/@H_301_62@
if@H_301_62@(needXcommit@H_301_62@&&@H_301_62@db@H_301_62@->@H_301_62@xCommitCallback){
sqlite3SafetyOff(db);
rc@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@xCommitCallback(db@H_301_62@->@H_301_62@pCommitArg);
sqlite3SafetyOn(db);
if@H_301_62@(rc){
return@H_301_62@sqlITE_CONSTRAINT;
}
}

/*Thesimplecase-nomorethanonedatabasefile(notcountingthe
**TEMPdatabase)hasatransactionactive.Thereisnoneedforthe
**master-journal.
**
**Ifthereturnvalueofsqlite3BtreeGetFilename()isazerolength
**string,itmeansthemaindatabaseis:memory:.Inthatcasewedo
**notsupportatomicmulti-filecommits,sousethesimplecasethen
**too.
*/@H_301_62@
//简单的情况,只有一个数据库文件,不需要master-journal
@H_301_62@if@H_301_62@(0@H_301_62@==@H_301_62@strlen(sqlite3BtreeGetFilename(db@H_301_62@->@H_301_62@aDb[0@H_301_62@].pBt))@H_301_62@||@H_301_62@nTrans@H_301_62@<=1@H_301_62@){
for@H_301_62@(i@H_301_62@=0@H_301_62@;rc@H_301_62@==@H_301_62@sqlITE_OK@H_301_62@&&@H_301_62@i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt){
//同步btree
@H_301_62@rc@H_301_62@=@H_301_62@sqlite3BtreeSync(pBt,0@H_301_62@);
}
}

/*Dothecommitonlyifalldatabasessuccessfullysynced*/@H_301_62@
//commite事务
@H_301_62@if@H_301_62@(rc@H_301_62@==@H_301_62@sqlITE_OK){
for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt){
sqlite3BtreeCommit(pBt);
}
}
}
}

/*Thecomplexcase-Thereisamulti-filewrite-transactionactive.
**Thisrequiresamasterjournalfiletoensurethetransactionis
**committedatomicly.
*/@H_301_62@
#ifndefsqlITE_OMIT_DISKIO
else@H_301_62@{
int@H_301_62@needSync@H_301_62@=@H_301_62@0@H_301_62@;
char@H_301_62@@H_301_62@*@H_301_62@zMaster@H_301_62@=@H_301_62@0@H_301_62@;/*File-nameforthemasterjournal*/@H_301_62@
char@H_301_62@const@H_301_62@@H_301_62@*@H_301_62@zMainFile@H_301_62@=@H_301_62@sqlite3BtreeGetFilename(db@H_301_62@->@H_301_62@aDb[0@H_301_62@].pBt);
OsFile@H_301_62@*@H_301_62@master@H_301_62@=@H_301_62@0@H_301_62@;

/*Selectamasterjournalfilename*/@H_301_62@
do@H_301_62@{
u32random;
sqliteFree(zMaster);
sqlite3Randomness(sizeof@H_301_62@(random),@H_301_62@&@H_301_62@random);
zMaster@H_301_62@=@H_301_62@sqlite3MPrintf("%s-mj%08X"@H_301_62@,zMainFile,random@H_301_62@&0x7fffffff@H_301_62@);
if@H_301_62@(@H_301_62@!@H_301_62@zMaster){
return@H_301_62@sqlITE_NOMEM;
}
}while@H_301_62@(sqlite3OsFileExists(zMaster));

/*Openthemasterjournal.*/@H_301_62@
rc@H_301_62@=@H_301_62@sqlite3OsOpenExclusive(zMaster,@H_301_62@&@H_301_62@master,0@H_301_62@);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
sqliteFree(zMaster);
return@H_301_62@rc;
}

/*Writethenameofeachdatabasefileinthetransactionintothenew
**masterjournalfile.Ifanerroroccursatthispointclose
**anddeletethemasterjournalfile.Alltheindividualjournalfiles
**stillhave'null'asthemasterjournalpointer,sotheywillroll
**backindependentlyifafailureoccurs.
*/@H_301_62@
for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(i@H_301_62@==1@H_301_62@)continue@H_301_62@;/*IgnoretheTEMPdatabase*/@H_301_62@
if@H_301_62@(pBt@H_301_62@&&@H_301_62@sqlite3BtreeIsInTrans(pBt)){
char@H_301_62@const@H_301_62@@H_301_62@*@H_301_62@zFile@H_301_62@=@H_301_62@sqlite3BtreeGetJournalname(pBt);
if@H_301_62@(zFile[0@H_301_62@]@H_301_62@==0@H_301_62@)continue@H_301_62@;/*Ignore:memory:databases*/@H_301_62@
if@H_301_62@(@H_301_62@!@H_301_62@needSync@H_301_62@&&@H_301_62@@H_301_62@!@H_301_62@sqlite3BtreeSyncDisabled(pBt)){
needSync@H_301_62@=@H_301_62@1@H_301_62@;
}
rc@H_301_62@=@H_301_62@sqlite3OsWrite(master,zFile,strlen(zFile)@H_301_62@+1@H_301_62@);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
sqlite3OsClose(@H_301_62@&@H_301_62@master);
sqlite3OsDelete(zMaster);
sqliteFree(zMaster);
return@H_301_62@rc;
}
}
}

/*Syncthemasterjournalfile.Beforedoingthis,openthedirectory
**themasterjournalfileisstoreinsothatitgetssyncedtoo.
*/@H_301_62@
zMainFile@H_301_62@=@H_301_62@sqlite3BtreeGetDirname(db@H_301_62@->@H_301_62@aDb[0@H_301_62@].pBt);
rc@H_301_62@=@H_301_62@sqlite3OsOpenDirectory(master,zMainFile);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK@H_301_62@||@H_301_62@
(needSync@H_301_62@&&@H_301_62@(rc@H_301_62@=@H_301_62@sqlite3OsSync(master,0@H_301_62@))@H_301_62@!=@H_301_62@sqlITE_OK)){
sqlite3OsClose(@H_301_62@&@H_301_62@master);
sqlite3OsDelete(zMaster);
sqliteFree(zMaster);
return@H_301_62@rc;
}

/*Syncallthedbfilesinvolvedinthetransaction.Thesamecall
**setsthemasterjournalpointerineachindividualjournal.If
**anerroroccurshere,donotdeletethemasterjournalfile.
**
**Iftheerroroccursduringthefirstcalltosqlite3BtreeSync(),
**thenthereisachancethatthemasterjournalfilewillbe
**orphaned.Butwecannotdeleteit,incasethemasterjournal
**filenamewaswrittenintothejournalfilebeforethefailure
**occured.
*/@H_301_62@
for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt@H_301_62@&&@H_301_62@sqlite3BtreeIsInTrans(pBt)){
rc@H_301_62@=@H_301_62@sqlite3BtreeSync(pBt,zMaster);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
sqlite3OsClose(@H_301_62@&@H_301_62@master);
sqliteFree(zMaster);
return@H_301_62@rc;
}
}
}
sqlite3OsClose(@H_301_62@&@H_301_62@master);

/*Deletethemasterjournalfile.Thiscommitsthetransaction.After
**doingthisthedirectoryissyncedagainbeforeanyindividual
**transactionfilesaredeleted.
*/@H_301_62@
rc@H_301_62@=@H_301_62@sqlite3OsDelete(zMaster);
assert(rc@H_301_62@==@H_301_62@sqlITE_OK);
sqliteFree(zMaster);
zMaster@H_301_62@=@H_301_62@0@H_301_62@;
rc@H_301_62@=@H_301_62@sqlite3OsSyncDirectory(zMainFile);
if@H_301_62@(rc@H_301_62@!=@H_301_62@sqlITE_OK){
/*Thisisnotgood.Themasterjournalfilehasbeendeleted,but
**thedirectorysyncFailed.ThereisnocompletelysafecourSEOf
**actionfromhere.Theindividualjournalscontainthenameofthe
**masterjournalfile,butthereisnowayofknowingifthat
**masterjournalexistsnoworifitwillexistaftertheoperating
**systemcrashthatmayfollowthefsync()failure.
*/@H_301_62@
return@H_301_62@rc;
}

/*Allfilesanddirectorieshavealreadybeensynced,sothefollowing
**callstosqlite3BtreeCommit()areonlyclosingfilesanddeleting
**journals.Ifsomethinggoeswrongwhilethisishappeningwedon't
**reallycare.Theintegrityofthetransactionisalreadyguaranteed,
**butsomestray'cold'journalsmaybelyingaround.Returningan
**errorcodewon'thelpmatters.
*/@H_301_62@
for@H_301_62@(i@H_301_62@=0@H_301_62@;i@H_301_62@<@H_301_62@db@H_301_62@->@H_301_62@nDb;i@H_301_62@++@H_301_62@){
Btree@H_301_62@*@H_301_62@pBt@H_301_62@=@H_301_62@db@H_301_62@->@H_301_62@aDb[i].pBt;
if@H_301_62@(pBt){
sqlite3BtreeCommit(pBt);
}
}
}
#endif@H_301_62@

return@H_301_62@rc;
}

(请您对文章做出评价)

SQLite入门与分析(四)---Page Cache之事务处理3

猜你在找的Sqlite相关文章