Lines Matching full:pvtab
4681 int (*xBestIndex)(sqlite3_vtab *pVTab, sqlite3_index_info*);
4682 int (*xDisconnect)(sqlite3_vtab *pVTab);
4683 int (*xDestroy)(sqlite3_vtab *pVTab);
4684 int (*xOpen)(sqlite3_vtab *pVTab, sqlite3_vtab_cursor **ppCursor);
4693 int (*xBegin)(sqlite3_vtab *pVTab);
4694 int (*xSync)(sqlite3_vtab *pVTab);
4695 int (*xCommit)(sqlite3_vtab *pVTab);
4696 int (*xRollback)(sqlite3_vtab *pVTab);
4697 int (*xFindFunction)(sqlite3_vtab *pVtab, int nArg, const char *zName,
4700 int (*xRename)(sqlite3_vtab *pVtab, const char *zNew);
4869 sqlite3_vtab *pVtab; /* Virtual table of this cursor */
7132 VTable *pVtab; /* Used when p4type is P4_VTAB */
8382 Table *pVTab; /* vtab with active Connect/Create method */
8715 sqlite3_vtab *pVtab; /* Pointer to vtab instance */
48348 sqlite3_vtab *pVtab = pOp->p4.pVtab->pVtab;
48349 sqlite3_snprintf(nTemp, zTemp, "vtab:%p:%p", pVtab, pVtab->pModule);
52818 sqlite3_vtab *pVtab;
52929 VTable *pVTab;
52934 sqlite3_vtab *pVtab;
52944 sqlite3_vtab *pVtab;
52951 sqlite3_vtab *pVtab;
52957 sqlite3_vtab *pVtab;
52963 sqlite3_vtab *pVtab;
52967 sqlite3_vtab *pVtab;
56511 sqlite3_vtab *pVtab;
56526 u.bi.pVtab = u.bi.pC->pVtabCursor->pVtab;
56527 u.bi.pModule = u.bi.pVtab->pModule;
56531 p->zErrMsg = u.bi.pVtab->zErrMsg;
56532 u.bi.pVtab->zErrMsg = 0;
57776 VTable *pVTab;
57778 u.ce.pVTab = pOp->p4.pVtab;
57779 rc = sqlite3VtabBegin(db, u.ce.pVTab);
57780 if( u.ce.pVTab ){
57782 p->zErrMsg = u.ce.pVTab->pVtab->zErrMsg;
57783 u.ce.pVTab->pVtab->zErrMsg = 0;
57826 sqlite3_vtab *pVtab;
57832 u.cf.pVtab = pOp->p4.pVtab->pVtab;
57833 u.cf.pModule = (sqlite3_module *)u.cf.pVtab->pModule;
57834 assert(u.cf.pVtab && u.cf.pModule);
57835 rc = u.cf.pModule->xOpen(u.cf.pVtab, &u.cf.pVtabCursor);
57837 p->zErrMsg = u.cf.pVtab->zErrMsg;
57838 u.cf.pVtab->zErrMsg = 0;
57841 u.cf.pVtabCursor->pVtab = u.cf.pVtab;
57847 u.cf.pCur->pModule = u.cf.pVtabCursor->pVtab->pModule;
57884 sqlite3_vtab *pVtab;
57897 u.cg.pVtab = u.cg.pVtabCursor->pVtab;
57898 u.cg.pModule = u.cg.pVtab->pModule;
57918 p->zErrMsg = u.cg.pVtab->zErrMsg;
57919 u.cg.pVtab->zErrMsg = 0;
57943 sqlite3_vtab *pVtab;
57957 u.ch.pVtab = pCur->pVtabCursor->pVtab;
57958 u.ch.pModule = u.ch.pVtab->pModule;
57972 p->zErrMsg = u.ch.pVtab->zErrMsg;
57973 u.ch.pVtab->zErrMsg = 0;
58003 sqlite3_vtab *pVtab;
58015 u.ci.pVtab = u.ci.pCur->pVtabCursor->pVtab;
58016 u.ci.pModule = u.ci.pVtab->pModule;
58029 p->zErrMsg = u.ci.pVtab->zErrMsg;
58030 u.ci.pVtab->zErrMsg = 0;
58052 sqlite3_vtab *pVtab;
58056 u.cj.pVtab = pOp->p4.pVtab->pVtab;
58058 assert( u.cj.pVtab->pModule->xRename );
58061 rc = u.cj.pVtab->pModule->xRename(u.cj.pVtab, u.cj.pName->z);
58063 p->zErrMsg = u.cj.pVtab->zErrMsg;
58064 u.cj.pVtab->zErrMsg = 0;
58096 sqlite3_vtab *pVtab;
58105 u.ck.pVtab = pOp->p4.pVtab->pVtab;
58106 u.ck.pModule = (sqlite3_module *)u.ck.pVtab->pModule;
58117 rc = u.ck.pModule->xUpdate(u.ck.pVtab, u.ck.nArg, u.ck.apArg, &u.ck.rowid);
58119 p->zErrMsg = u.ck.pVtab->zErrMsg;
58120 u.ck.pVtab->zErrMsg = 0;
64633 VTable *pVTab = 0; /* Non-zero if this is a v-tab with an xRename() */
64689 pVTab = sqlite3GetVTable(db, pTab);
64690 if( pVTab->pVtab->pModule->xRename==0 ){
64691 pVTab = 0;
64705 sqlite3BeginWriteOperation(pParse, pVTab!=0, iDb);
64714 if( pVTab ){
64717 sqlite3VdbeAddOp4(v, OP_VRename, i, 0, 0,(const char*)pVTab, P4_VTAB);
71032 const char *pVTab = (const char *)sqlite3GetVTable(db, pTab);
71034 sqlite3VdbeAddOp4(v, OP_VUpdate, 0, 1, iRowid, pVTab, P4_VTAB);
74137 VTable *pVTab = IsVirtual(pTab) ? sqlite3GetVTable(p->db, pTab) : 0;
74156 if( pOp->opcode==OP_VOpen && pOp->p4.pVtab==pVTab ){
74157 assert( pOp->p4.pVtab!=0 );
74965 const char *pVTab = (const char *)sqlite3GetVTable(db, pTab);
74967 sqlite3VdbeAddOp4(v, OP_VUpdate, 1, pTab->nCol+2, regIns, pVTab, P4_VTAB);
85429 const char *pVTab = (const char*)sqlite3GetVTable(db, pTab);
85473 sqlite3VdbeAddOp4(v, OP_VUpdate, 0, pTab->nCol+2, iReg, pVTab, P4_VTAB);
85906 SQLITE_PRIVATE void sqlite3VtabLock(VTable *pVTab){
85907 pVTab->nRef++;
85917 VTable *pVtab;
85919 for(pVtab=pTab->pVTable; pVtab && pVtab->db!=db; pVtab=pVtab->pNext);
85920 return pVtab;
85927 SQLITE_PRIVATE void sqlite3VtabUnlock(VTable *pVTab){
85928 sqlite3 *db = pVTab->db;
85931 assert( pVTab->nRef>0 );
85934 pVTab->nRef--;
85935 if( pVTab->nRef==0 ){
85936 sqlite3_vtab *p = pVTab->pVtab;
85940 sqlite3DbFree(db, pVTab);
86269 assert( !db->pVTab );
86271 db->pVTab = pTab;
86274 rc = xConstruct(db, pMod->pAux, nArg, azArg, &pVTable->pVtab, &zErr);
86285 }else if( ALWAYS(pVTable->pVtab) ){
86288 pVTable->pVtab->pModule = pMod->pModule;
86290 if( db->pVTab ){
86338 db->pVTab = 0;
86381 ** Add the virtual table pVTab to the array sqlite3.aVTrans[].
86383 static int addToVTrans(sqlite3 *db, VTable *pVTab){
86398 /* Add pVtab to the end of sqlite3.aVTrans */
86399 db->aVTrans[db->nVTrans++] = pVTab;
86400 sqlite3VtabLock(pVTab);
86458 pTab = db->pVTab;
86485 db->pVTab = 0;
86522 rc = p->pMod->pModule->xDestroy(p->pVtab);
86527 p->pVtab = 0;
86548 VTable *pVTab = db->aVTrans[i];
86549 sqlite3_vtab *p = pVTab->pVtab;
86555 sqlite3VtabUnlock(pVTab);
86579 sqlite3_vtab *pVtab = aVTrans[i]->pVtab;
86580 if( pVtab && (x = pVtab->pModule->xSync)!=0 ){
86581 rc = x(pVtab);
86583 *pzErrmsg = pVtab->zErrMsg;
86584 pVtab->zErrMsg = 0;
86610 ** If the virtual table pVtab supports the transaction interface
86617 SQLITE_PRIVATE int sqlite3VtabBegin(sqlite3 *db, VTable *pVTab){
86629 if( !pVTab ){
86632 pModule = pVTab->pVtab->pModule;
86638 /* If pVtab is already in the aVTrans array, return early */
86640 if( db->aVTrans[i]==pVTab ){
86646 rc = pModule->xBegin(pVTab->pVtab);
86648 rc = addToVTrans(db, pVTab);
86674 sqlite3_vtab *pVtab;
86690 pVtab = sqlite3GetVTable(db, pTab)->pVtab;
86691 assert( pVtab!=0 );
86692 assert( pVtab->pModule!=0 );
86693 pMod = (sqlite3_module *)pVtab->pModule;
86704 rc = pMod->xFindFunction(pVtab, nArg, zLowerName, &xFunc, &pArg);
88511 sqlite3_vtab *pVtab = sqlite3GetVTable(pParse->db, pTab)->pVtab;
88517 rc = pVtab->pModule->xBestIndex(pVtab, p);
88523 }else if( !pVtab->zErrMsg ){
88526 sqlite3ErrorMsg(pParse, "%s", pVtab->zErrMsg);
88529 sqlite3DbFree(pParse->db, pVtab->zErrMsg);
88530 pVtab->zErrMsg = 0;
90638 const char *pVTab = (const char *)sqlite3GetVTable(db, pTab);
90640 sqlite3VdbeAddOp4(v, OP_VOpen, iCur, 0, 0, pVTab, P4_VTAB);
99144 static int fts3DisconnectMethod(sqlite3_vtab *pVtab){
99145 Fts3Table *p = (Fts3Table *)pVtab;
99170 static int fts3DestroyMethod(sqlite3_vtab *pVtab){
99172 Fts3Table *p = (Fts3Table *)pVtab;
99196 return (rc==SQLITE_OK ? fts3DisconnectMethod(pVtab) : rc);
99451 static int fts3BestIndexMethod(sqlite3_vtab *pVTab, sqlite3_index_info *pInfo){
99452 Fts3Table *p = (Fts3Table *)pVTab;
99504 static int fts3OpenMethod(sqlite3_vtab *pVTab, sqlite3_vtab_cursor **ppCsr){
99507 UNUSED_PARAMETER(pVTab);
100588 Fts3Table *p = (Fts3Table *)pCursor->pVtab;
100678 Fts3Table *p = (Fts3Table *)pCursor->pVtab;
100711 sqlite3_vtab *pVtab, /* Virtual table handle */
100716 return sqlite3Fts3UpdateMethod(pVtab, nArg, apVal, pRowid);
100723 static int fts3SyncMethod(sqlite3_vtab *pVtab){
100724 return sqlite3Fts3PendingTermsFlush((Fts3Table *)pVtab);
100730 static int fts3BeginMethod(sqlite3_vtab *pVtab){
100731 UNUSED_PARAMETER(pVtab);
100732 assert( ((Fts3Table *)pVtab)->nPendingData==0 );
100741 static int fts3CommitMethod(sqlite3_vtab *pVtab){
100742 UNUSED_PARAMETER(pVtab);
100743 assert( ((Fts3Table *)pVtab)->nPendingData==0 );
100751 static int fts3RollbackMethod(sqlite3_vtab *pVtab){
100752 sqlite3Fts3PendingTermsClear((Fts3Table *)pVtab);
100963 p = (Fts3Table *)pCursor->base.pVtab;
101007 sqlite3_vtab *pVtab, /* Virtual table handle */
101025 UNUSED_PARAMETER(pVtab);
101044 sqlite3_vtab *pVtab, /* Virtual table handle */
101047 Fts3Table *p = (Fts3Table *)pVtab;
106124 sqlite3_vtab *pVtab, /* FTS3 vtab object */
106129 Fts3Table *p = (Fts3Table *)pVtab;
106445 Fts3Table *pVtab; /* The full text index */
106460 pVtab = (Fts3Table *)pCur->base.pVtab;
106461 nColumn = pVtab->nColumn;
106462 pTokenizer = pVtab->pTokenizer;
106642 Fts3Table *p = (Fts3Table *)pCsr->base.pVtab; /* The FTS3 virtual table */
107001 sCtx.pTab = (Fts3Table *)pCsr->base.pVtab;
107266 Fts3Table *pTab = (Fts3Table *)pCsr->base.pVtab;
107456 Fts3Table *pTab = (Fts3Table *)pCsr->base.pVtab;
108206 static int rtreeDisconnect(sqlite3_vtab *pVtab){
108207 rtreeRelease((Rtree *)pVtab);
108214 static int rtreeDestroy(sqlite3_vtab *pVtab){
108215 Rtree *pRtree = (Rtree *)pVtab;
108241 static int rtreeOpen(sqlite3_vtab *pVTab, sqlite3_vtab_cursor **ppCursor){
108248 pCsr->base.pVtab = pVTab;
108260 Rtree *pRtree = (Rtree *)(cur->pVtab);
108436 Rtree *pRtree = (Rtree *)(pVtabCursor->pVtab);
108474 Rtree *pRtree = (Rtree *)pVtabCursor->pVtab;
108487 Rtree *pRtree = (Rtree *)cur->pVtab;
108537 Rtree *pRtree = (Rtree *)pVtabCursor->pVtab;
109888 sqlite3_vtab *pVtab,
109893 Rtree *pRtree = (Rtree *)pVtab;
110049 static int rtreeRename(sqlite3_vtab *pVtab, const char *zNewName){
110050 Rtree *pRtree = (Rtree *)pVtab;
