Lines Matching refs:pTab
9786 static void zipfileCleanupTransaction(ZipfileTab *pTab){ in zipfileCleanupTransaction() argument
9790 if( pTab->pWriteFd ){ in zipfileCleanupTransaction()
9791 fclose(pTab->pWriteFd); in zipfileCleanupTransaction()
9792 pTab->pWriteFd = 0; in zipfileCleanupTransaction()
9794 for(pEntry=pTab->pFirstEntry; pEntry; pEntry=pNext){ in zipfileCleanupTransaction()
9798 pTab->pFirstEntry = 0; in zipfileCleanupTransaction()
9799 pTab->pLastEntry = 0; in zipfileCleanupTransaction()
9800 pTab->szCurrent = 0; in zipfileCleanupTransaction()
9801 pTab->szOrig = 0; in zipfileCleanupTransaction()
9817 ZipfileTab *pTab = (ZipfileTab*)p; in zipfileOpen() local
9825 pCsr->iId = ++pTab->iNextCsrid; in zipfileOpen()
9826 pCsr->pCsrNext = pTab->pCsrList; in zipfileOpen()
9827 pTab->pCsrList = pCsr; in zipfileOpen()
9858 ZipfileTab *pTab = (ZipfileTab*)(pCsr->base.pVtab); in zipfileClose() local
9863 for(pp=&pTab->pCsrList; *pp!=pCsr; pp=&((*pp)->pCsrNext)); in zipfileClose()
9874 static void zipfileTableErr(ZipfileTab *pTab, const char *zFmt, ...){ in zipfileTableErr() argument
9877 sqlite3_free(pTab->base.zErrMsg); in zipfileTableErr()
9878 pTab->base.zErrMsg = sqlite3_vmprintf(zFmt, ap); in zipfileTableErr()
9917 ZipfileTab *pTab, in zipfileAppendData() argument
9923 fseek(pTab->pWriteFd, (long)pTab->szCurrent, SEEK_SET); in zipfileAppendData()
9924 n = fwrite(aWrite, 1, nWrite, pTab->pWriteFd); in zipfileAppendData()
9926 pTab->base.zErrMsg = sqlite3_mprintf("error in fwrite()"); in zipfileAppendData()
9929 pTab->szCurrent += nWrite; in zipfileAppendData()
10179 ZipfileTab *pTab, /* Store any error message here */ in zipfileGetEntry() argument
10187 char **pzErr = &pTab->base.zErrMsg; in zipfileGetEntry()
10192 aRead = pTab->aBuffer; in zipfileGetEntry()
10289 ZipfileTab *pTab = (ZipfileTab*)(cur->pVtab); in zipfileNext() local
10290 rc = zipfileGetEntry(pTab, 0, 0, pCsr->pFile, pCsr->iNextOff, &p); in zipfileNext()
10518 ZipfileTab *pTab, /* Return errors here */ in zipfileReadEOCD() argument
10524 u8 *aRead = pTab->aBuffer; /* Temporary buffer */ in zipfileReadEOCD()
10539 rc = zipfileReadData(pFile, aRead, nRead, iOff, &pTab->base.zErrMsg); in zipfileReadEOCD()
10557 pTab->base.zErrMsg = sqlite3_mprintf( in zipfileReadEOCD()
10582 ZipfileTab *pTab, in zipfileAddEntry() argument
10586 assert( (pTab->pFirstEntry==0)==(pTab->pLastEntry==0) ); in zipfileAddEntry()
10589 if( pTab->pFirstEntry==0 ){ in zipfileAddEntry()
10590 pTab->pFirstEntry = pTab->pLastEntry = pNew; in zipfileAddEntry()
10592 assert( pTab->pLastEntry->pNext==0 ); in zipfileAddEntry()
10593 pTab->pLastEntry->pNext = pNew; in zipfileAddEntry()
10594 pTab->pLastEntry = pNew; in zipfileAddEntry()
10598 for(pp=&pTab->pFirstEntry; *pp!=pBefore; pp=&((*pp)->pNext)); in zipfileAddEntry()
10604 static int zipfileLoadDirectory(ZipfileTab *pTab, const u8 *aBlob, int nBlob){ in zipfileLoadDirectory() argument
10610 rc = zipfileReadEOCD(pTab, aBlob, nBlob, pTab->pWriteFd, &eocd); in zipfileLoadDirectory()
10614 rc = zipfileGetEntry(pTab, aBlob, nBlob, pTab->pWriteFd, iOff, &pNew); in zipfileLoadDirectory()
10617 zipfileAddEntry(pTab, 0, pNew); in zipfileLoadDirectory()
10633 ZipfileTab *pTab = (ZipfileTab*)cur->pVtab; in zipfileFilter() local
10644 if( pTab->zFile ){ in zipfileFilter()
10645 zFile = pTab->zFile; in zipfileFilter()
10653 assert( pTab->pFirstEntry==0 ); in zipfileFilter()
10658 rc = zipfileLoadDirectory(pTab, aBlob, nBlob); in zipfileFilter()
10659 pCsr->pFreeEntry = pTab->pFirstEntry; in zipfileFilter()
10660 pTab->pFirstEntry = pTab->pLastEntry = 0; in zipfileFilter()
10667 if( 0==pTab->pWriteFd && 0==bInMemory ){ in zipfileFilter()
10673 rc = zipfileReadEOCD(pTab, 0, 0, pCsr->pFile, &pCsr->eocd); in zipfileFilter()
10685 pCsr->pCurrent = pCsr->pFreeEntry ? pCsr->pFreeEntry : pTab->pFirstEntry; in zipfileFilter()
10772 ZipfileTab *pTab, in zipfileAppendEntry() argument
10777 u8 *aBuf = pTab->aBuffer; in zipfileAppendEntry()
10782 rc = zipfileAppendData(pTab, aBuf, nBuf); in zipfileAppendEntry()
10784 pEntry->iDataOff = pTab->szCurrent; in zipfileAppendEntry()
10785 rc = zipfileAppendData(pTab, pData, nData); in zipfileAppendEntry()
10845 ZipfileTab *pTab = (ZipfileTab*)pVtab; in zipfileBegin() local
10848 assert( pTab->pWriteFd==0 ); in zipfileBegin()
10849 if( pTab->zFile==0 || pTab->zFile[0]==0 ){ in zipfileBegin()
10850 pTab->base.zErrMsg = sqlite3_mprintf("zipfile: missing filename"); in zipfileBegin()
10858 pTab->pWriteFd = fopen(pTab->zFile, "ab+"); in zipfileBegin()
10859 if( pTab->pWriteFd==0 ){ in zipfileBegin()
10860 pTab->base.zErrMsg = sqlite3_mprintf( in zipfileBegin()
10861 "zipfile: failed to open file %s for writing", pTab->zFile in zipfileBegin()
10865 fseek(pTab->pWriteFd, 0, SEEK_END); in zipfileBegin()
10866 pTab->szCurrent = pTab->szOrig = (i64)ftell(pTab->pWriteFd); in zipfileBegin()
10867 rc = zipfileLoadDirectory(pTab, 0, 0); in zipfileBegin()
10871 zipfileCleanupTransaction(pTab); in zipfileBegin()
10915 static void zipfileRemoveEntryFromList(ZipfileTab *pTab, ZipfileEntry *pOld){ in zipfileRemoveEntryFromList() argument
10917 if( pTab->pFirstEntry==pOld ){ in zipfileRemoveEntryFromList()
10918 pTab->pFirstEntry = pOld->pNext; in zipfileRemoveEntryFromList()
10919 if( pTab->pLastEntry==pOld ) pTab->pLastEntry = 0; in zipfileRemoveEntryFromList()
10922 for(p=pTab->pFirstEntry; p; p=p->pNext){ in zipfileRemoveEntryFromList()
10925 if( pTab->pLastEntry==pOld ) pTab->pLastEntry = p; in zipfileRemoveEntryFromList()
10943 ZipfileTab *pTab = (ZipfileTab*)pVtab; in zipfileUpdate() local
10965 if( pTab->pWriteFd==0 ){ in zipfileUpdate()
10980 for(pOld=pTab->pFirstEntry; 1; pOld=pOld->pNext){ in zipfileUpdate()
10991 zipfileTableErr(pTab, "sz must be NULL"); in zipfileUpdate()
10995 zipfileTableErr(pTab, "rawdata must be NULL"); in zipfileUpdate()
11015 zipfileTableErr(pTab, "unknown compression method: %d", iMethod); in zipfileUpdate()
11020 rc = zipfileDeflate(aIn, nIn, &pFree, &nCmp, &pTab->base.zErrMsg); in zipfileUpdate()
11035 rc = zipfileGetMode(apVal[3], bIsDir, &mode, &pTab->base.zErrMsg); in zipfileUpdate()
11066 for(p=pTab->pFirstEntry; p; p=p->pNext){ in zipfileUpdate()
11068 switch( sqlite3_vtab_on_conflict(pTab->db) ){ in zipfileUpdate()
11077 zipfileTableErr(pTab, "duplicate name: \"%s\"", zPath); in zipfileUpdate()
11102 pNew->cds.iOffset = (u32)pTab->szCurrent; in zipfileUpdate()
11105 rc = zipfileAppendEntry(pTab, pNew, pData, nData); in zipfileUpdate()
11106 zipfileAddEntry(pTab, pOld, pNew); in zipfileUpdate()
11113 for(pCsr=pTab->pCsrList; pCsr; pCsr=pCsr->pCsrNext){ in zipfileUpdate()
11120 zipfileRemoveEntryFromList(pTab, pOld); in zipfileUpdate()
11121 zipfileRemoveEntryFromList(pTab, pOld2); in zipfileUpdate()
11144 static int zipfileAppendEOCD(ZipfileTab *pTab, ZipfileEOCD *p){ in zipfileAppendEOCD() argument
11145 int nBuf = zipfileSerializeEOCD(p, pTab->aBuffer); in zipfileAppendEOCD()
11147 return zipfileAppendData(pTab, pTab->aBuffer, nBuf); in zipfileAppendEOCD()
11200 ZipfileTab *pTab = (ZipfileTab*)pVtab; in zipfileCommit() local
11202 if( pTab->pWriteFd ){ in zipfileCommit()
11203 i64 iOffset = pTab->szCurrent; in zipfileCommit()
11209 for(p=pTab->pFirstEntry; rc==SQLITE_OK && p; p=p->pNext){ in zipfileCommit()
11210 int n = zipfileSerializeCDS(p, pTab->aBuffer); in zipfileCommit()
11211 rc = zipfileAppendData(pTab, pTab->aBuffer, n); in zipfileCommit()
11220 eocd.nSize = (u32)(pTab->szCurrent - iOffset); in zipfileCommit()
11222 rc = zipfileAppendEOCD(pTab, &eocd); in zipfileCommit()
11224 zipfileCleanupTransaction(pTab); in zipfileCommit()
11233 static ZipfileCsr *zipfileFindCursor(ZipfileTab *pTab, i64 iId){ in zipfileFindCursor() argument
11235 for(pCsr=pTab->pCsrList; pCsr; pCsr=pCsr->pCsrNext){ in zipfileFindCursor()
11247 ZipfileTab *pTab = (ZipfileTab*)sqlite3_user_data(context); in zipfileFunctionCds() local
11250 pCsr = zipfileFindCursor(pTab, sqlite3_value_int64(argv[0])); in zipfileFunctionCds()
11994 IdxTable *pTab; /* Associated table object */ member
12025 IdxTable *pTab; member
12286 IdxTable *pTab; member
12351 p->pTab = pExpert->pTable; in expertConnect()
12352 assert( sqlite3_stricmp(p->pTab->zName, argv[2])==0 ); in expertConnect()
12385 pScan->pTab = p->pTab; in expertBestIndex()
12394 && p->pTab->aCol[pCons->iColumn].iPk==0 in expertBestIndex()
12420 IdxConstraint *pNew = idxNewConstraint(&rc, p->pTab->aCol[iCol].zColl); in expertBestIndex()
12545 "SELECT * FROM main.%Q WHERE sqlite_expert_sample()", pVtab->pTab->zName in expertFilter()
12763 IdxTable *pTab, /* Table index will be created on */ in idxAppendColDefn() argument
12767 IdxColumn *p = &pTab->aCol[pCons->iCol]; in idxAppendColDefn()
12805 const char *zTbl = pScan->pTab->zName; in idxFindCompatible()
12888 IdxTable *pTab = pScan->pTab; in idxCreateFromCons() local
12896 zCols = idxAppendColDefn(&rc, zCols, pTab, pCons); in idxCreateFromCons()
12899 zCols = idxAppendColDefn(&rc, zCols, pTab, pCons); in idxCreateFromCons()
12904 const char *zTable = pScan->pTab->zName; in idxCreateFromCons()
13075 static void idxTableFree(IdxTable *pTab){ in idxTableFree() argument
13078 for(pIter=pTab; pIter; pIter=pNext){ in idxTableFree()
13087 static void idxWriteFree(IdxWrite *pTab){ in idxWriteFree() argument
13090 for(pIter=pTab; pIter; pIter=pNext){ in idxWriteFree()
13187 IdxTable *pTab; in idxAuthCallback() local
13188 for(pTab=p->pTable; pTab; pTab=pTab->pNext){ in idxAuthCallback()
13189 if( 0==sqlite3_stricmp(z3, pTab->zName) ) break; in idxAuthCallback()
13191 if( pTab ){ in idxAuthCallback()
13194 if( pWrite->pTab==pTab && pWrite->eOp==eOp ) break; in idxAuthCallback()
13199 pWrite->pTab = pTab; in idxAuthCallback()
13218 IdxTable *pTab = pWrite->pTab; in idxProcessOneTrigger() local
13219 const char *zTab = pTab->zName; in idxProcessOneTrigger()
13252 for(i=0; i<pTab->nCol; i++){ in idxProcessOneTrigger()
13261 for(i=0; i<pTab->nCol; i++){ in idxProcessOneTrigger()
13263 pTab->aCol[i].zName in idxProcessOneTrigger()
13339 IdxTable *pTab; in idxCreateVtabSchema() local
13340 rc = idxGetTableInfo(p->db, zName, &pTab, pzErrmsg); in idxCreateVtabSchema()
13345 pTab->pNext = p->pTable; in idxCreateVtabSchema()
13346 p->pTable = pTab; in idxCreateVtabSchema()
13350 for(i=0; i<pTab->nCol; i++){ in idxCreateVtabSchema()
13352 (i==0 ? "" : ", "), pTab->aCol[i].zName, pTab->aCol[i].zColl in idxCreateVtabSchema()
15647 DbdataTable *pTab = 0; in dbdataConnect() local
15655 pTab = (DbdataTable*)sqlite3_malloc64(sizeof(DbdataTable)); in dbdataConnect()
15656 if( pTab==0 ){ in dbdataConnect()
15659 memset(pTab, 0, sizeof(DbdataTable)); in dbdataConnect()
15660 pTab->db = db; in dbdataConnect()
15661 pTab->bPtr = (pAux!=0); in dbdataConnect()
15665 *ppVtab = (sqlite3_vtab*)pTab; in dbdataConnect()
15673 DbdataTable *pTab = (DbdataTable*)pVtab; in dbdataDisconnect() local
15674 if( pTab ){ in dbdataDisconnect()
15675 sqlite3_finalize(pTab->pStmt); in dbdataDisconnect()
15695 DbdataTable *pTab = (DbdataTable*)tab; in dbdataBestIndex() local
15699 int colSchema = (pTab->bPtr ? DBPTR_COLUMN_SCHEMA : DBDATA_COLUMN_SCHEMA); in dbdataBestIndex()
15724 if( pTab->bPtr==0 && pIdx->nOrderBy && pIdx->aOrderBy[0].desc==0 ){ in dbdataBestIndex()
15764 DbdataTable *pTab = (DbdataTable*)(pCsr->base.pVtab); in dbdataResetCursor() local
15765 if( pTab->pStmt==0 ){ in dbdataResetCursor()
15766 pTab->pStmt = pCsr->pStmt; in dbdataResetCursor()
16007 DbdataTable *pTab = (DbdataTable*)pCursor->pVtab; in dbdataNext() local
16028 pCsr->iCell = pTab->bPtr ? -2 : 0; in dbdataNext()
16035 if( pTab->bPtr ){ in dbdataNext()
16243 DbdataTable *pTab = (DbdataTable*)pCsr->base.pVtab; in dbdataDbsize() local
16256 rc = sqlite3_prepare_v2(pTab->db, zSql, -1, &pStmt, 0); in dbdataDbsize()
16293 DbdataTable *pTab = (DbdataTable*)pCursor->pVtab; in dbdataFilter() local
16314 if( pTab->pStmt ){ in dbdataFilter()
16315 pCsr->pStmt = pTab->pStmt; in dbdataFilter()
16316 pTab->pStmt = 0; in dbdataFilter()
16322 rc = sqlite3_prepare_v2(pTab->db, zSql, -1, &pCsr->pStmt, 0); in dbdataFilter()
16326 rc = sqlite3_prepare_v2(pTab->db, in dbdataFilter()
16343 pTab->base.zErrMsg = sqlite3_mprintf("%s", sqlite3_errmsg(pTab->db)); in dbdataFilter()
16361 DbdataTable *pTab = (DbdataTable*)pCursor->pVtab; in dbdataColumn() local
16362 if( pTab->bPtr ){ in dbdataColumn()
16630 RecoverTable *pTab; /* Table currently being written */ member
17758 RecoverTable *pTab, in recoverInsertStmt() argument
17772 assert( nField<=pTab->nCol ); in recoverInsertStmt()
17774 zSql = recoverMPrintf(p, "INSERT OR IGNORE INTO %Q(", pTab->zTab); in recoverInsertStmt()
17776 if( pTab->iRowidBind ){ in recoverInsertStmt()
17777 assert( pTab->bIntkey ); in recoverInsertStmt()
17780 zBind = recoverMPrintf(p, "%zquote(?%d)", zBind, pTab->iRowidBind); in recoverInsertStmt()
17782 zBind = recoverMPrintf(p, "%z?%d", zBind, pTab->iRowidBind); in recoverInsertStmt()
17789 int eHidden = pTab->aCol[ii].eHidden; in recoverInsertStmt()
17793 assert( pTab->aCol[ii].iField>=0 && pTab->aCol[ii].iBind>=1 ); in recoverInsertStmt()
17794 zSql = recoverMPrintf(p, "%z%s%Q", zSql, zSep, pTab->aCol[ii].zCol); in recoverInsertStmt()
17798 "%z%sescape_crnl(quote(?%d))", zBind, zSqlSep, pTab->aCol[ii].iBind in recoverInsertStmt()
17802 zBind = recoverMPrintf(p, "%z%s?%d", zBind, zSep, pTab->aCol[ii].iBind); in recoverInsertStmt()
18196 if( p->errCode==SQLITE_OK && p1->pTab==0 ){ in recoverWriteDataStep()
18199 p1->pTab = recoverFindTable(p, iRoot); in recoverWriteDataStep()
18206 if( p1->pTab==0 ) return p->errCode; in recoverWriteDataStep()
18213 if( sqlite3_stricmp("sqlite_sequence", p1->pTab->zTab)==0 ){ in recoverWriteDataStep()
18231 assert( p->errCode!=SQLITE_OK || p1->pTab ); in recoverWriteDataStep()
18234 RecoverTable *pTab = p1->pTab; in recoverWriteDataStep() local
18243 assert( bNewCell || iField==p1->nVal || p1->nVal==pTab->nCol ); in recoverWriteDataStep()
18250 p1->pInsert = recoverInsertStmt(p, pTab, p1->nVal); in recoverWriteDataStep()
18255 for(ii=0; ii<pTab->nCol; ii++){ in recoverWriteDataStep()
18256 RecoverColumn *pCol = &pTab->aCol[ii]; in recoverWriteDataStep()
18266 if( p->bRecoverRowid && pTab->iRowidBind>0 && p1->bHaveRowid ){ in recoverWriteDataStep()
18267 sqlite3_bind_int64(pInsert, pTab->iRowidBind, p1->iRowid); in recoverWriteDataStep()
18293 }else if( iField<pTab->nCol ){ in recoverWriteDataStep()
18306 p1->pTab = 0; in recoverWriteDataStep()
18482 RecoverTable *pTab = 0; in recoverFinalCleanup() local
18488 for(pTab=p->pTblList; pTab; pTab=pNext){ in recoverFinalCleanup()
18489 pNext = pTab->pNext; in recoverFinalCleanup()
18490 sqlite3_free(pTab); in recoverFinalCleanup()