SQLITE_APIint sqlite3_prepare_v2(

sqlite3 *db,              /* Database handle. 成功開啟的資料庫控制代碼*/

constchar *zSql,         /* UTF-8 encoded SQL statement. UTF8編碼的 SQL 語句 */

intnBytes,               /* Length of zSql in bytes. 引數 sql 的位元組數, 包含 '\0'  */

sqlite3_stmt **ppStmt,    /* OUT: A pointer to the prepared statement 輸出:預編譯語句控制代碼 */

constchar **pzTail/* OUT: End of parsed string 輸出:指向 sql 語句中未使用的部分*/

){

int rc;

rc = sqlite3LockAndPrepare(db,zSql,nBytes,SQLITE_PREPARE_SAVESQL,0,

ppStmt,pzTail);

assert( rc==SQLITE_OK || ppStmt==0 || *ppStmt==0 );

return rc;

}

staticint sqlite3LockAndPrepare(

sqlite3 *db,              /* Database handle. */

constchar *zSql,         /* UTF-8 encoded SQL statement.(UTF-8 編碼的 SQL 語句) */

intnBytes,               /* Length of zSql in bytes. (zSql 的位元組數)*/

u32prepFlags,            /* Zero or more SQLITE_PREPARE_* flags（儲存的sql文字） */

Vdbe *pOld,               /* VM being reprepared */

sqlite3_stmt **ppStmt,    /* OUT: A pointer to the prepared statement(指向已準備好的語句的指標 ) */

constchar **pzTail/* OUT: End of parsed string(未處理的 SQL 串) */

){

int rc;

#ifdef SQLITE_ENABLE_API_ARMOR

if( ppStmt==0 ) return SQLITE_MISUSE_BKPT;

#endif

*ppStmt = 0;

if( !sqlite3SafetyCheckOk(db)||zSql==0 ){//確定 db 指標的合法性

returnSQLITE_MISUSE_BKPT;

}

sqlite3_mutex_enter(db->mutex);

sqlite3BtreeEnterAll(db);

 rc = sqlite3Prepare(db, zSql, nBytes, prepFlags, pOld, ppStmt, pzTail);//將 UTF-8 編碼的 SQL 語句 zSql 編譯成

if( rc==SQLITE_SCHEMA ){    // 如果遇到 SCHEMA 改變，定案，再編譯

sqlite3ResetOneSchema(db, -1);

sqlite3_finalize(*ppStmt);

rc = sqlite3Prepare(db, zSql, nBytes, prepFlags, pOld, ppStmt, pzTail);

}

sqlite3BtreeLeaveAll(db);

sqlite3_mutex_leave(db->mutex);

assert( rc==SQLITE_OK || *ppStmt==0 );

return rc;

}

staticint sqlite3Prepare(

sqlite3 *db,              /* Database handle. */

constchar *zSql,         /* UTF-8 encoded SQL statement. */

intnBytes,               /* Length of zSql in bytes. */

u32prepFlags,            /* Zero or more SQLITE_PREPARE_* flags */

Vdbe *pReprepare,         /* VM being reprepared */

sqlite3_stmt **ppStmt,    /* OUT: A pointer to the prepared statement (輸出經過處理的準備語句)*/

constchar **pzTail/* OUT: End of parsed string */

){

char *zErrMsg = 0;        /* Error message */

int rc = SQLITE_OK;       /* Result code */

int i;                    /* Loop counter */

Parse sParse;             /* Parsing context（解析語境） */

memset(&sParse, 0, PARSE_HDR_SZ);

memset(PARSE_TAIL(&sParse), 0, PARSE_TAIL_SZ);//初始化記憶體空間

sParse.pReprepare = pReprepare;

assert( ppStmt && *ppStmt==0 );

/* assert( !db->mallocFailed ); // not true with SQLITE_USE_ALLOCA */

assert( sqlite3_mutex_held(db->mutex) );

/* For a long-term use prepared statement avoid the use of

** lookaside memory.

（長期使用事先準備好的宣告避免後備儲存器的使用。）

*/

if( prepFlags & SQLITE_PREPARE_PERSISTENT ){

sParse.disableLookaside++;//禁用後備記憶體 來使需要重複使用的準備語句可以多次使用

db->lookaside.bDisable++;//同時禁止db中後備記憶體分配的引數

}

/*

**(檢查以驗證是否可以在所有資料庫模式上獲得讀鎖 .無法獲得讀鎖，表明某些其他資料庫連線持有寫鎖。

這反過來意味著另一個連線對模式做出了未提交的更改。 )

**(我們是否要繼續和準備對未提交的模式更改的宣告，如果這些模式更改隨後回滾，並在其位置進行不同的更改

然後，當準備好的語句執行時，模式cookie將無法檢測模式更改。災難會隨之發生。

*/

for(i=0; i<db->nDb; i++) {//依此遍歷連線的資料庫

Btree *pBt = db->aDb[i].pBt;

if( pBt ){

assert( sqlite3BtreeHoldsMutex(pBt) );

rc = sqlite3BtreeSchemaLocked(pBt);//判斷這個btree是否被鎖

if( rc ){ //如果是就提示該資料庫已被加鎖

constchar *zDb = db->aDb[i].zDbSName;

sqlite3ErrorWithMsg(db, rc, "database schema is locked: %s", zDb);

testcase( db->flags & SQLITE_ReadUncommit );

goto end_prepare;

}

}

}

sqlite3VtabUnlockList(db);//然後解鎖

sParse.db = db;

if( nBytes>=0 && (nBytes==0 || zSql[nBytes-1]!=0) ){

char *zSqlCopy;

int mxLen = db->aLimit[SQLITE_LIMIT_SQL_LENGTH]; //準備語句最大長度

testcase( nBytes==mxLen );

testcase( nBytes==mxLen+1 );

if( nBytes>mxLen ){//如果超過了這個長度就提示

sqlite3ErrorWithMsg(db, SQLITE_TOOBIG, "statement too long");

rc = sqlite3ApiExit(db, SQLITE_TOOBIG);

goto end_prepare;//結束準備階段

}

zSqlCopy = sqlite3DbStrNDup(db, zSql, nBytes);//複製zSql字串

if( zSqlCopy ){

sqlite3RunParser(&sParse, zSqlCopy, &zErrMsg);

sParse.zTail = &zSql[sParse.zTail-zSqlCopy];

sqlite3DbFree(db, zSqlCopy);

}else{

sParse.zTail = &zSql[nBytes];

}

}else{

sqlite3RunParser(&sParse, zSql, &zErrMsg);

}

assert( 0==sParse.nQueryLoop );

if( sParse.rc==SQLITE_DONE ) sParse.rc = SQLITE_OK;

if( sParse.checkSchema ){

schemaIsValid(&sParse);

}

if( db->mallocFailed ){

sParse.rc = SQLITE_NOMEM_BKPT;

}

if( pzTail ){

*pzTail = sParse.zTail;

}

rc = sParse.rc;

#ifndef SQLITE_OMIT_EXPLAIN

if( rc==SQLITE_OK && sParse.pVdbe && sParse.explain ){

staticconstchar * const azColName[] = {

"addr", "opcode", "p1", "p2", "p3", "p4", "p5", "comment",

"selectid", "order", "from", "detail"

};

int iFirst, mx;

if( sParse.explain==2 ){

sqlite3VdbeSetNumCols(sParse.pVdbe, 4);

iFirst = 8;

mx = 12;

}else{

sqlite3VdbeSetNumCols(sParse.pVdbe, 8);

iFirst = 0;

mx = 8;

}

for(i=iFirst; i<mx; i++){

sqlite3VdbeSetColName(sParse.pVdbe, i-iFirst, COLNAME_NAME,

azColName[i], SQLITE_STATIC);

}

}

#endif

if( db->init.busy==0 ){

sqlite3VdbeSetSql(sParse.pVdbe, zSql, (int)(sParse.zTail-zSql), prepFlags);

}

if( sParse.pVdbe && (rc!=SQLITE_OK || db->mallocFailed) ){

sqlite3VdbeFinalize(sParse.pVdbe);

assert(!(*ppStmt));

}else{

*ppStmt = (sqlite3_stmt*)sParse.pVdbe;

}

if( zErrMsg ){

sqlite3ErrorWithMsg(db, rc, "%s", zErrMsg);

sqlite3DbFree(db, zErrMsg);

}else{

sqlite3Error(db, rc);

}

/* Delete any TriggerPrg structures allocated while parsing this statement. */

while( sParse.pTriggerPrg ){

TriggerPrg *pT = sParse.pTriggerPrg;

sParse.pTriggerPrg = pT->pNext;

sqlite3DbFree(db, pT);

}

end_prepare:

sqlite3ParserReset(&sParse);

rc = sqlite3ApiExit(db, rc);

assert( (rc&db->errMask)==rc );

return rc;

}

SQLITE_PRIVATEint sqlite3RunParser(Parse *pParse, constchar *zSql, char **pzErrMsg){

int nErr = 0;                   /* Number of errors encountered（遇到的錯誤數） */

void *pEngine;                  /* The LEMON-generated LALR(1) parser（lemon演算法解析器） */

int n = 0;                      /* Length of the next token token（下一個token的長度） */

int tokenType;                  /* type of the next token （下一個token的型別）*/

int lastTokenParsed = -1;       /* type of the previous token （上一個token的型別）*/

sqlite3 *db = pParse->db;       /* The database connection */

int mxSqlLen;                   /* Max length of an SQL string（sql字串的最大長度） */

#ifdefsqlite3Parser_ENGINEALWAYSONSTACK

yyParser sEngine;    /* Space to hold the Lemon-generated Parser object（儲存lemon生成的解析器物件的空間 ） */

#endif

assert( zSql!=0 );

mxSqlLen = db->aLimit[SQLITE_LIMIT_SQL_LENGTH];//     mxSqlLen 1000000000   int

if( db->nVdbeActive==0 ){//虛擬機器活動數量為0

db->u1.isInterrupted = 0;//sqlite3_interrupt不被執行（我猜是中斷執行）

}

pParse->rc = SQLITE_OK;

pParse->zTail = zSql;

assert( pzErrMsg!=0 );

/* sqlite3ParserTrace(stdout, "parser: "); */

#ifdefsqlite3Parser_ENGINEALWAYSONSTACK

pEngine = &sEngine;

 sqlite3ParserInit(pEngine);//初始化已分配的解析器（初始化解析器物件各個欄位）

#else

pEngine = sqlite3ParserAlloc(sqlite3Malloc);

if( pEngine==0 ){

sqlite3OomFault(db);

return SQLITE_NOMEM_BKPT;

}

#endif

assert( pParse->pNewTable==0 );

assert( pParse->pNewTrigger==0 );

assert( pParse->nVar==0 );

assert( pParse->pVList==0 );

while( 1 ){

if( zSql[0]!=0 ){// zSql[0]表示一個token 開頭（比如select就為s）

   n = sqlite3GetToken((u8*)zSql, &tokenType);

mxSqlLen -= n;

if( mxSqlLen<0 ){

pParse->rc = SQLITE_TOOBIG;

break;

}

}else{

if( lastTokenParsed==TK_SEMI ){

tokenType = 0;

}elseif( lastTokenParsed==0 ){

break;

}else{

tokenType = TK_SEMI;

}

zSql -= n;

}

if( tokenType>=TK_SPACE ){

assert( tokenType==TK_SPACE || tokenType==TK_ILLEGAL );

if( db->u1.isInterrupted ){

pParse->rc = SQLITE_INTERRUPT;

break;

}

if( tokenType==TK_ILLEGAL ){

sqlite3ErrorMsg(pParse, "unrecognized token: \"%.*s\"", n, zSql);

break;

}

zSql += n;

}else{

pParse->sLastToken.z = zSql;//0x0070808f "id,name from stu" const char *

pParse->sLastToken.n = n;

  sqlite3Parser(pEngine, tokenType, pParse->sLastToken, pParse);

lastTokenParsed = tokenType;

zSql += n;

if( pParse->rc!=SQLITE_OK || db->mallocFailed ) break;

}

}

assert( nErr==0 );

pParse->zTail = zSql;

#ifdef YYTRACKMAXSTACKDEPTH

sqlite3_mutex_enter(sqlite3MallocMutex());

sqlite3StatusHighwater(SQLITE_STATUS_PARSER_STACK,

sqlite3ParserStackPeak(pEngine)

);

sqlite3_mutex_leave(sqlite3MallocMutex());

#endif/* YYDEBUG */

#ifdefsqlite3Parser_ENGINEALWAYSONSTACK

sqlite3ParserFinalize(pEngine);

#else

sqlite3ParserFree(pEngine, sqlite3_free);

#endif

if( db->mallocFailed ){

pParse->rc = SQLITE_NOMEM_BKPT;

}

if( pParse->rc!=SQLITE_OK && pParse->rc!=SQLITE_DONE && pParse->zErrMsg==0 ){

pParse->zErrMsg = sqlite3MPrintf(db, "%s", sqlite3ErrStr(pParse->rc));

}

assert( pzErrMsg!=0 );

if( pParse->zErrMsg ){

*pzErrMsg = pParse->zErrMsg;

sqlite3_log(pParse->rc, "%s", *pzErrMsg);

pParse->zErrMsg = 0;

nErr++;

}

if( pParse->pVdbe && pParse->nErr>0 && pParse->nested==0 ){

sqlite3VdbeDelete(pParse->pVdbe);

pParse

相關推薦