blob: c66a154678d003de15ce66f2e5dc06546915424a [file] [log] [blame]
drhb9bb7c12006-06-11 23:41:55 +00001/*
2** 2006 June 10
3**
4** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
6**
7** May you do good and not evil.
8** May you find forgiveness for yourself and forgive others.
9** May you share freely, never taking more than you give.
10**
11*************************************************************************
12** This file contains code used to help implement virtual tables.
drhb9bb7c12006-06-11 23:41:55 +000013*/
14#ifndef SQLITE_OMIT_VIRTUALTABLE
15#include "sqliteInt.h"
16
drh63842412009-04-11 16:27:19 +000017/*
danb061d052011-04-25 18:49:57 +000018** Before a virtual table xCreate() or xConnect() method is invoked, the
19** sqlite3.pVtabCtx member variable is set to point to an instance of
20** this struct allocated on the stack. It is used by the implementation of
21** the sqlite3_declare_vtab() and sqlite3_vtab_config() APIs, both of which
22** are invoked only from within xCreate and xConnect methods.
23*/
24struct VtabCtx {
drh81028a42012-05-15 18:28:27 +000025 VTable *pVTable; /* The virtual table being constructed */
26 Table *pTab; /* The Table object to which the virtual table belongs */
dan75395cc2015-04-10 07:55:07 +000027 VtabCtx *pPrior; /* Parent context (if any) */
28 int bDeclared; /* True after sqlite3_declare_vtab() is called */
danb061d052011-04-25 18:49:57 +000029};
30
31/*
drh2fcc1592016-12-15 20:59:03 +000032** Construct and install a Module object for a virtual table. When this
33** routine is called, it is guaranteed that all appropriate locks are held
34** and the module is not already part of the connection.
drhcc5979d2019-08-16 22:58:29 +000035**
36** If there already exists a module with zName, replace it with the new one.
37** If pModule==0, then delete the module zName if it exists.
drh2fcc1592016-12-15 20:59:03 +000038*/
39Module *sqlite3VtabCreateModule(
40 sqlite3 *db, /* Database in which module is registered */
41 const char *zName, /* Name assigned to this module */
42 const sqlite3_module *pModule, /* The definition of the module */
43 void *pAux, /* Context pointer for xCreate/xConnect */
44 void (*xDestroy)(void *) /* Module destructor function */
45){
46 Module *pMod;
drhcc5979d2019-08-16 22:58:29 +000047 Module *pDel;
48 char *zCopy;
49 if( pModule==0 ){
50 zCopy = (char*)zName;
51 pMod = 0;
drh3ee14162017-10-02 13:20:43 +000052 }else{
drhcc5979d2019-08-16 22:58:29 +000053 int nName = sqlite3Strlen30(zName);
54 pMod = (Module *)sqlite3Malloc(sizeof(Module) + nName + 1);
55 if( pMod==0 ){
56 sqlite3OomFault(db);
57 return 0;
58 }
59 zCopy = (char *)(&pMod[1]);
drh2fcc1592016-12-15 20:59:03 +000060 memcpy(zCopy, zName, nName+1);
61 pMod->zName = zCopy;
62 pMod->pModule = pModule;
63 pMod->pAux = pAux;
64 pMod->xDestroy = xDestroy;
65 pMod->pEpoTab = 0;
drhcc5979d2019-08-16 22:58:29 +000066 pMod->nRefModule = 1;
67 }
68 pDel = (Module *)sqlite3HashInsert(&db->aModule,zCopy,(void*)pMod);
69 if( pDel ){
70 if( pDel==pMod ){
drh2fcc1592016-12-15 20:59:03 +000071 sqlite3OomFault(db);
72 sqlite3DbFree(db, pDel);
drh9a63f092016-12-16 02:14:15 +000073 pMod = 0;
drhcc5979d2019-08-16 22:58:29 +000074 }else{
drh87ca8062019-08-17 19:31:09 +000075 sqlite3VtabEponymousTableClear(db, pDel);
drhcc5979d2019-08-16 22:58:29 +000076 sqlite3VtabModuleUnref(db, pDel);
drh2fcc1592016-12-15 20:59:03 +000077 }
78 }
79 return pMod;
80}
81
82/*
drh63842412009-04-11 16:27:19 +000083** The actual function that does the work of creating a new module.
84** This function implements the sqlite3_create_module() and
85** sqlite3_create_module_v2() interfaces.
86*/
danielk1977832a58a2007-06-22 15:21:15 +000087static int createModule(
88 sqlite3 *db, /* Database in which module is registered */
89 const char *zName, /* Name assigned to this module */
90 const sqlite3_module *pModule, /* The definition of the module */
91 void *pAux, /* Context pointer for xCreate/xConnect */
92 void (*xDestroy)(void *) /* Module destructor function */
danielk1977595a5232009-07-24 17:58:53 +000093){
danca8b9ba2012-05-16 14:29:11 +000094 int rc = SQLITE_OK;
drh27641702007-08-22 02:56:42 +000095
96 sqlite3_mutex_enter(db->mutex);
drhcc5979d2019-08-16 22:58:29 +000097 (void)sqlite3VtabCreateModule(db, zName, pModule, pAux, xDestroy);
danca8b9ba2012-05-16 14:29:11 +000098 rc = sqlite3ApiExit(db, rc);
99 if( rc!=SQLITE_OK && xDestroy ) xDestroy(pAux);
drh27641702007-08-22 02:56:42 +0000100 sqlite3_mutex_leave(db->mutex);
101 return rc;
danielk1977832a58a2007-06-22 15:21:15 +0000102}
103
104
drhb9bb7c12006-06-11 23:41:55 +0000105/*
106** External API function used to create a new virtual-table module.
107*/
108int sqlite3_create_module(
109 sqlite3 *db, /* Database in which module is registered */
110 const char *zName, /* Name assigned to this module */
danielk1977d1ab1ba2006-06-15 04:28:13 +0000111 const sqlite3_module *pModule, /* The definition of the module */
112 void *pAux /* Context pointer for xCreate/xConnect */
drhb9bb7c12006-06-11 23:41:55 +0000113){
drh9ca95732014-10-24 00:35:58 +0000114#ifdef SQLITE_ENABLE_API_ARMOR
115 if( !sqlite3SafetyCheckOk(db) || zName==0 ) return SQLITE_MISUSE_BKPT;
116#endif
danielk1977832a58a2007-06-22 15:21:15 +0000117 return createModule(db, zName, pModule, pAux, 0);
118}
119
120/*
121** External API function used to create a new virtual-table module.
122*/
123int sqlite3_create_module_v2(
124 sqlite3 *db, /* Database in which module is registered */
125 const char *zName, /* Name assigned to this module */
126 const sqlite3_module *pModule, /* The definition of the module */
127 void *pAux, /* Context pointer for xCreate/xConnect */
128 void (*xDestroy)(void *) /* Module destructor function */
129){
drh9ca95732014-10-24 00:35:58 +0000130#ifdef SQLITE_ENABLE_API_ARMOR
131 if( !sqlite3SafetyCheckOk(db) || zName==0 ) return SQLITE_MISUSE_BKPT;
132#endif
danielk1977832a58a2007-06-22 15:21:15 +0000133 return createModule(db, zName, pModule, pAux, xDestroy);
drhb9bb7c12006-06-11 23:41:55 +0000134}
135
drhb9bb7c12006-06-11 23:41:55 +0000136/*
drh5df84282019-08-17 19:45:25 +0000137** External API to drop all virtual-table modules, except those named
138** on the azNames list.
139*/
drh8c754a32019-08-19 20:35:30 +0000140int sqlite3_drop_modules(sqlite3 *db, const char** azNames){
drh5df84282019-08-17 19:45:25 +0000141 HashElem *pThis, *pNext;
142#ifdef SQLITE_ENABLE_API_ARMOR
mistachkin3722b3a2019-08-20 02:19:26 +0000143 if( !sqlite3SafetyCheckOk(db) ) return SQLITE_MISUSE_BKPT;
drh5df84282019-08-17 19:45:25 +0000144#endif
145 for(pThis=sqliteHashFirst(&db->aModule); pThis; pThis=pNext){
146 Module *pMod = (Module*)sqliteHashData(pThis);
147 pNext = sqliteHashNext(pThis);
148 if( azNames ){
149 int ii;
150 for(ii=0; azNames[ii]!=0 && strcmp(azNames[ii],pMod->zName)!=0; ii++){}
151 if( azNames[ii]!=0 ) continue;
152 }
153 createModule(db, pMod->zName, 0, 0, 0);
154 }
155 return SQLITE_OK;
156}
157
158/*
drhcc5979d2019-08-16 22:58:29 +0000159** Decrement the reference count on a Module object. Destroy the
160** module when the reference count reaches zero.
161*/
162void sqlite3VtabModuleUnref(sqlite3 *db, Module *pMod){
163 assert( pMod->nRefModule>0 );
164 pMod->nRefModule--;
165 if( pMod->nRefModule==0 ){
166 if( pMod->xDestroy ){
167 pMod->xDestroy(pMod->pAux);
168 }
169 assert( pMod->pEpoTab==0 );
170 sqlite3DbFree(db, pMod);
171 }
172}
173
174/*
drh189d4af2006-09-02 20:57:52 +0000175** Lock the virtual table so that it cannot be disconnected.
176** Locks nest. Every lock should have a corresponding unlock.
177** If an unlock is omitted, resources leaks will occur.
178**
179** If a disconnect is attempted while a virtual table is locked,
180** the disconnect is deferred until all locks have been removed.
181*/
danielk1977595a5232009-07-24 17:58:53 +0000182void sqlite3VtabLock(VTable *pVTab){
183 pVTab->nRef++;
184}
185
186
187/*
188** pTab is a pointer to a Table structure representing a virtual-table.
189** Return a pointer to the VTable object used by connection db to access
190** this virtual-table, if one has been created, or NULL otherwise.
191*/
192VTable *sqlite3GetVTable(sqlite3 *db, Table *pTab){
193 VTable *pVtab;
194 assert( IsVirtual(pTab) );
drhf38524d2021-08-02 16:41:57 +0000195 for(pVtab=pTab->u.vtab.p; pVtab && pVtab->db!=db; pVtab=pVtab->pNext);
danielk1977595a5232009-07-24 17:58:53 +0000196 return pVtab;
drh189d4af2006-09-02 20:57:52 +0000197}
198
199/*
danielk1977595a5232009-07-24 17:58:53 +0000200** Decrement the ref-count on a virtual table object. When the ref-count
201** reaches zero, call the xDisconnect() method to delete the object.
drh189d4af2006-09-02 20:57:52 +0000202*/
danielk1977595a5232009-07-24 17:58:53 +0000203void sqlite3VtabUnlock(VTable *pVTab){
204 sqlite3 *db = pVTab->db;
205
206 assert( db );
207 assert( pVTab->nRef>0 );
drh04f2e342012-08-27 14:39:47 +0000208 assert( db->magic==SQLITE_MAGIC_OPEN || db->magic==SQLITE_MAGIC_ZOMBIE );
danielk1977595a5232009-07-24 17:58:53 +0000209
210 pVTab->nRef--;
211 if( pVTab->nRef==0 ){
212 sqlite3_vtab *p = pVTab->pVtab;
drhcc5979d2019-08-16 22:58:29 +0000213 sqlite3VtabModuleUnref(pVTab->db, pVTab->pMod);
danielk1977595a5232009-07-24 17:58:53 +0000214 if( p ){
drh9978c972010-02-23 17:36:32 +0000215 p->pModule->xDisconnect(p);
danielk1977a04a34f2007-04-16 15:06:25 +0000216 }
danielk1977595a5232009-07-24 17:58:53 +0000217 sqlite3DbFree(db, pVTab);
218 }
219}
220
221/*
222** Table p is a virtual table. This function moves all elements in the
drhf38524d2021-08-02 16:41:57 +0000223** p->u.vtab.p list to the sqlite3.pDisconnect lists of their associated
danielk1977595a5232009-07-24 17:58:53 +0000224** database connections to be disconnected at the next opportunity.
225** Except, if argument db is not NULL, then the entry associated with
drhf38524d2021-08-02 16:41:57 +0000226** connection db is left in the p->u.vtab.p list.
danielk1977595a5232009-07-24 17:58:53 +0000227*/
228static VTable *vtabDisconnectAll(sqlite3 *db, Table *p){
229 VTable *pRet = 0;
drhf38524d2021-08-02 16:41:57 +0000230 VTable *pVTable = p->u.vtab.p;
231 p->u.vtab.p = 0;
danielk1977595a5232009-07-24 17:58:53 +0000232
233 /* Assert that the mutex (if any) associated with the BtShared database
234 ** that contains table p is held by the caller. See header comments
235 ** above function sqlite3VtabUnlockList() for an explanation of why
236 ** this makes it safe to access the sqlite3.pDisconnect list of any
drhf38524d2021-08-02 16:41:57 +0000237 ** database connection that may have an entry in the p->u.vtab.p list.
drh9bbc2e22011-04-04 20:40:22 +0000238 */
239 assert( db==0 || sqlite3SchemaMutexHeld(db, 0, p->pSchema) );
danielk1977595a5232009-07-24 17:58:53 +0000240
241 while( pVTable ){
242 sqlite3 *db2 = pVTable->db;
243 VTable *pNext = pVTable->pNext;
244 assert( db2 );
245 if( db2==db ){
246 pRet = pVTable;
drhf38524d2021-08-02 16:41:57 +0000247 p->u.vtab.p = pRet;
danielk1977595a5232009-07-24 17:58:53 +0000248 pRet->pNext = 0;
249 }else{
250 pVTable->pNext = db2->pDisconnect;
251 db2->pDisconnect = pVTable;
252 }
253 pVTable = pNext;
254 }
255
256 assert( !db || pRet );
257 return pRet;
258}
259
danbba02a92012-05-15 17:15:34 +0000260/*
261** Table *p is a virtual table. This function removes the VTable object
262** for table *p associated with database connection db from the linked
263** list in p->pVTab. It also decrements the VTable ref count. This is
264** used when closing database connection db to free all of its VTable
265** objects without disturbing the rest of the Schema object (which may
266** be being used by other shared-cache connections).
267*/
268void sqlite3VtabDisconnect(sqlite3 *db, Table *p){
269 VTable **ppVTab;
270
271 assert( IsVirtual(p) );
272 assert( sqlite3BtreeHoldsAllMutexes(db) );
273 assert( sqlite3_mutex_held(db->mutex) );
274
drhf38524d2021-08-02 16:41:57 +0000275 for(ppVTab=&p->u.vtab.p; *ppVTab; ppVTab=&(*ppVTab)->pNext){
danbba02a92012-05-15 17:15:34 +0000276 if( (*ppVTab)->db==db ){
277 VTable *pVTab = *ppVTab;
278 *ppVTab = pVTab->pNext;
279 sqlite3VtabUnlock(pVTab);
280 break;
281 }
282 }
283}
284
danielk1977595a5232009-07-24 17:58:53 +0000285
286/*
287** Disconnect all the virtual table objects in the sqlite3.pDisconnect list.
288**
289** This function may only be called when the mutexes associated with all
290** shared b-tree databases opened using connection db are held by the
291** caller. This is done to protect the sqlite3.pDisconnect list. The
292** sqlite3.pDisconnect list is accessed only as follows:
293**
294** 1) By this function. In this case, all BtShared mutexes and the mutex
295** associated with the database handle itself must be held.
296**
297** 2) By function vtabDisconnectAll(), when it adds a VTable entry to
298** the sqlite3.pDisconnect list. In this case either the BtShared mutex
299** associated with the database the virtual table is stored in is held
300** or, if the virtual table is stored in a non-sharable database, then
301** the database handle mutex is held.
302**
303** As a result, a sqlite3.pDisconnect cannot be accessed simultaneously
304** by multiple threads. It is thread-safe.
305*/
306void sqlite3VtabUnlockList(sqlite3 *db){
307 VTable *p = db->pDisconnect;
danielk1977595a5232009-07-24 17:58:53 +0000308
309 assert( sqlite3BtreeHoldsAllMutexes(db) );
310 assert( sqlite3_mutex_held(db->mutex) );
311
312 if( p ){
drh1de92a62019-10-05 19:24:52 +0000313 db->pDisconnect = 0;
drhba968db2018-07-24 22:02:12 +0000314 sqlite3ExpirePreparedStatements(db, 0);
danielk1977595a5232009-07-24 17:58:53 +0000315 do {
316 VTable *pNext = p->pNext;
317 sqlite3VtabUnlock(p);
318 p = pNext;
319 }while( p );
drh189d4af2006-09-02 20:57:52 +0000320 }
321}
322
323/*
drhb9bb7c12006-06-11 23:41:55 +0000324** Clear any and all virtual-table information from the Table record.
325** This routine is called, for example, just before deleting the Table
326** record.
danielk1977595a5232009-07-24 17:58:53 +0000327**
328** Since it is a virtual-table, the Table structure contains a pointer
329** to the head of a linked list of VTable structures. Each VTable
330** structure is associated with a single sqlite3* user of the schema.
331** The reference count of the VTable structure associated with database
332** connection db is decremented immediately (which may lead to the
333** structure being xDisconnected and free). Any other VTable structures
334** in the list are moved to the sqlite3.pDisconnect list of the associated
335** database connection.
drhb9bb7c12006-06-11 23:41:55 +0000336*/
dan1feeaed2010-07-23 15:41:47 +0000337void sqlite3VtabClear(sqlite3 *db, Table *p){
dand46def72010-07-24 11:28:28 +0000338 if( !db || db->pnBytesFreed==0 ) vtabDisconnectAll(0, p);
drhf38524d2021-08-02 16:41:57 +0000339 if( p->u.vtab.azArg ){
drhb9bb7c12006-06-11 23:41:55 +0000340 int i;
drhf38524d2021-08-02 16:41:57 +0000341 for(i=0; i<p->u.vtab.nArg; i++){
342 if( i!=1 ) sqlite3DbFree(db, p->u.vtab.azArg[i]);
drhb9bb7c12006-06-11 23:41:55 +0000343 }
drhf38524d2021-08-02 16:41:57 +0000344 sqlite3DbFree(db, p->u.vtab.azArg);
drhb9bb7c12006-06-11 23:41:55 +0000345 }
346}
347
348/*
drhf38524d2021-08-02 16:41:57 +0000349** Add a new module argument to pTable->u.vtab.azArg[].
drhb9bb7c12006-06-11 23:41:55 +0000350** The string is not copied - the pointer is stored. The
351** string will be freed automatically when the table is
352** deleted.
353*/
drh0aa32312019-04-13 04:01:12 +0000354static void addModuleArgument(Parse *pParse, Table *pTable, char *zArg){
drhf38524d2021-08-02 16:41:57 +0000355 sqlite3_int64 nBytes = sizeof(char *)*(2+pTable->u.vtab.nArg);
danielk1977b7a2f2e2006-06-23 11:34:54 +0000356 char **azModuleArg;
drh0aa32312019-04-13 04:01:12 +0000357 sqlite3 *db = pParse->db;
drhf38524d2021-08-02 16:41:57 +0000358 if( pTable->u.vtab.nArg+3>=db->aLimit[SQLITE_LIMIT_COLUMN] ){
drh0aa32312019-04-13 04:01:12 +0000359 sqlite3ErrorMsg(pParse, "too many columns on %s", pTable->zName);
360 }
drhf38524d2021-08-02 16:41:57 +0000361 azModuleArg = sqlite3DbRealloc(db, pTable->u.vtab.azArg, nBytes);
danielk1977b7a2f2e2006-06-23 11:34:54 +0000362 if( azModuleArg==0 ){
drh633e6d52008-07-28 19:34:53 +0000363 sqlite3DbFree(db, zArg);
drhb9bb7c12006-06-11 23:41:55 +0000364 }else{
drhf38524d2021-08-02 16:41:57 +0000365 int i = pTable->u.vtab.nArg++;
danielk1977b7a2f2e2006-06-23 11:34:54 +0000366 azModuleArg[i] = zArg;
367 azModuleArg[i+1] = 0;
drhf38524d2021-08-02 16:41:57 +0000368 pTable->u.vtab.azArg = azModuleArg;
drhb9bb7c12006-06-11 23:41:55 +0000369 }
370}
371
372/*
373** The parser calls this routine when it first sees a CREATE VIRTUAL TABLE
374** statement. The module name has been parsed, but the optional list
375** of parameters that follow the module name are still pending.
376*/
377void sqlite3VtabBeginParse(
378 Parse *pParse, /* Parsing context */
379 Token *pName1, /* Name of new table, or database name */
380 Token *pName2, /* Name of new table or NULL */
drhb421b892012-01-28 19:41:53 +0000381 Token *pModuleName, /* Name of the module for the virtual table */
382 int ifNotExists /* No error if the table already exists */
drhb9bb7c12006-06-11 23:41:55 +0000383){
384 Table *pTable; /* The new virtual table */
drh17435752007-08-16 04:30:38 +0000385 sqlite3 *db; /* Database connection */
drhb9bb7c12006-06-11 23:41:55 +0000386
drhb421b892012-01-28 19:41:53 +0000387 sqlite3StartTable(pParse, pName1, pName2, 0, 0, 1, ifNotExists);
drhb9bb7c12006-06-11 23:41:55 +0000388 pTable = pParse->pNewTable;
drh748ce212009-05-20 20:10:47 +0000389 if( pTable==0 ) return;
danielk1977f1a381e2006-06-16 08:01:02 +0000390 assert( 0==pTable->pIndex );
drhf38524d2021-08-02 16:41:57 +0000391 pTable->eTabType = TABTYP_VTAB;
danielk1977f1a381e2006-06-16 08:01:02 +0000392
drh17435752007-08-16 04:30:38 +0000393 db = pParse->db;
danielk197770ba1642006-06-21 16:02:42 +0000394
drhf38524d2021-08-02 16:41:57 +0000395 assert( pTable->u.vtab.nArg==0 );
drh0aa32312019-04-13 04:01:12 +0000396 addModuleArgument(pParse, pTable, sqlite3NameFromToken(db, pModuleName));
397 addModuleArgument(pParse, pTable, 0);
398 addModuleArgument(pParse, pTable, sqlite3DbStrDup(db, pTable->zName));
dand89b8342014-11-27 11:36:36 +0000399 assert( (pParse->sNameToken.z==pName2->z && pName2->z!=0)
400 || (pParse->sNameToken.z==pName1->z && pName2->z==0)
401 );
402 pParse->sNameToken.n = (int)(
403 &pModuleName->z[pModuleName->n] - pParse->sNameToken.z
404 );
danielk1977f1a381e2006-06-16 08:01:02 +0000405
406#ifndef SQLITE_OMIT_AUTHORIZATION
407 /* Creating a virtual table invokes the authorization callback twice.
408 ** The first invocation, to obtain permission to INSERT a row into the
drh1e32bed2020-06-19 13:33:53 +0000409 ** sqlite_schema table, has already been made by sqlite3StartTable().
danielk1977f1a381e2006-06-16 08:01:02 +0000410 ** The second call, to obtain permission to create the table, is made now.
411 */
drhf38524d2021-08-02 16:41:57 +0000412 if( pTable->u.vtab.azArg ){
mistachkin7cc55952018-09-21 23:41:18 +0000413 int iDb = sqlite3SchemaToIndex(db, pTable->pSchema);
414 assert( iDb>=0 ); /* The database the table is being created in */
danielk1977be718892006-06-23 08:05:19 +0000415 sqlite3AuthCheck(pParse, SQLITE_CREATE_VTABLE, pTable->zName,
drhf38524d2021-08-02 16:41:57 +0000416 pTable->u.vtab.azArg[0], pParse->db->aDb[iDb].zDbSName);
danielk1977f1a381e2006-06-16 08:01:02 +0000417 }
418#endif
drhb9bb7c12006-06-11 23:41:55 +0000419}
420
421/*
422** This routine takes the module argument that has been accumulating
423** in pParse->zArg[] and appends it to the list of arguments on the
424** virtual table currently under construction in pParse->pTable.
425*/
426static void addArgumentToVtab(Parse *pParse){
drhb421b892012-01-28 19:41:53 +0000427 if( pParse->sArg.z && pParse->pNewTable ){
drh7c2d87c2006-09-02 14:16:59 +0000428 const char *z = (const char*)pParse->sArg.z;
danielk197733b39332006-06-24 08:51:05 +0000429 int n = pParse->sArg.n;
drh17435752007-08-16 04:30:38 +0000430 sqlite3 *db = pParse->db;
drh0aa32312019-04-13 04:01:12 +0000431 addModuleArgument(pParse, pParse->pNewTable, sqlite3DbStrNDup(db, z, n));
drhb9bb7c12006-06-11 23:41:55 +0000432 }
drhb9bb7c12006-06-11 23:41:55 +0000433}
434
435/*
436** The parser calls this routine after the CREATE VIRTUAL TABLE statement
437** has been completely parsed.
438*/
439void sqlite3VtabFinishParse(Parse *pParse, Token *pEnd){
danielk1977595a5232009-07-24 17:58:53 +0000440 Table *pTab = pParse->pNewTable; /* The table being constructed */
441 sqlite3 *db = pParse->db; /* The database connection */
drhb9bb7c12006-06-11 23:41:55 +0000442
danielk1977595a5232009-07-24 17:58:53 +0000443 if( pTab==0 ) return;
drhb9bb7c12006-06-11 23:41:55 +0000444 addArgumentToVtab(pParse);
danielk197733b39332006-06-24 08:51:05 +0000445 pParse->sArg.z = 0;
drhf38524d2021-08-02 16:41:57 +0000446 if( pTab->u.vtab.nArg<1 ) return;
drhb9bb7c12006-06-11 23:41:55 +0000447
448 /* If the CREATE VIRTUAL TABLE statement is being entered for the
449 ** first time (in other words if the virtual table is actually being
drh1e32bed2020-06-19 13:33:53 +0000450 ** created now instead of just being read out of sqlite_schema) then
drhb9bb7c12006-06-11 23:41:55 +0000451 ** do additional initialization work and store the statement text
drh1e32bed2020-06-19 13:33:53 +0000452 ** in the sqlite_schema table.
drhb9bb7c12006-06-11 23:41:55 +0000453 */
454 if( !db->init.busy ){
455 char *zStmt;
danielk197778efaba2006-06-12 06:09:17 +0000456 char *zWhere;
drhb9bb7c12006-06-11 23:41:55 +0000457 int iDb;
dan73779452015-03-19 18:56:17 +0000458 int iReg;
drhb9bb7c12006-06-11 23:41:55 +0000459 Vdbe *v;
drhb9bb7c12006-06-11 23:41:55 +0000460
drh8e8c8892019-12-10 18:10:12 +0000461 sqlite3MayAbort(pParse);
462
drhb9bb7c12006-06-11 23:41:55 +0000463 /* Compute the complete text of the CREATE VIRTUAL TABLE statement */
464 if( pEnd ){
drhb27b7f52008-12-10 18:03:45 +0000465 pParse->sNameToken.n = (int)(pEnd->z - pParse->sNameToken.z) + pEnd->n;
drhb9bb7c12006-06-11 23:41:55 +0000466 }
danielk19771e536952007-08-16 10:09:01 +0000467 zStmt = sqlite3MPrintf(db, "CREATE VIRTUAL TABLE %T", &pParse->sNameToken);
drhb9bb7c12006-06-11 23:41:55 +0000468
469 /* A slot for the record has already been allocated in the
drh346a70c2020-06-15 20:27:35 +0000470 ** schema table. We just need to update that slot with all
danielk197778efaba2006-06-12 06:09:17 +0000471 ** the information we've collected.
472 **
drhb7654112008-01-12 12:48:07 +0000473 ** The VM register number pParse->regRowid holds the rowid of an
drh1e32bed2020-06-19 13:33:53 +0000474 ** entry in the sqlite_schema table tht was created for this vtab
drhb7654112008-01-12 12:48:07 +0000475 ** by sqlite3StartTable().
drhb9bb7c12006-06-11 23:41:55 +0000476 */
477 iDb = sqlite3SchemaToIndex(db, pTab->pSchema);
478 sqlite3NestedParse(pParse,
drh346a70c2020-06-15 20:27:35 +0000479 "UPDATE %Q." DFLT_SCHEMA_TABLE " "
danielk197778efaba2006-06-12 06:09:17 +0000480 "SET type='table', name=%Q, tbl_name=%Q, rootpage=0, sql=%Q "
drhb7654112008-01-12 12:48:07 +0000481 "WHERE rowid=#%d",
drh346a70c2020-06-15 20:27:35 +0000482 db->aDb[iDb].zDbSName,
drhb9bb7c12006-06-11 23:41:55 +0000483 pTab->zName,
484 pTab->zName,
drhb7654112008-01-12 12:48:07 +0000485 zStmt,
486 pParse->regRowid
drhb9bb7c12006-06-11 23:41:55 +0000487 );
drhb9bb7c12006-06-11 23:41:55 +0000488 v = sqlite3GetVdbe(pParse);
drh9cbf3422008-01-17 16:22:13 +0000489 sqlite3ChangeCookie(pParse, iDb);
danielk197778efaba2006-06-12 06:09:17 +0000490
drh01c736d2016-05-20 15:15:07 +0000491 sqlite3VdbeAddOp0(v, OP_Expire);
drhf4f31df2019-12-21 19:37:09 +0000492 zWhere = sqlite3MPrintf(db, "name=%Q AND sql=%Q", pTab->zName, zStmt);
dan6a5a13d2021-02-17 20:08:22 +0000493 sqlite3VdbeAddParseSchemaOp(v, iDb, zWhere, 0);
drhf4f31df2019-12-21 19:37:09 +0000494 sqlite3DbFree(db, zStmt);
dan73779452015-03-19 18:56:17 +0000495
496 iReg = ++pParse->nMem;
drh076e85f2015-09-03 13:46:12 +0000497 sqlite3VdbeLoadString(v, iReg, pTab->zName);
dan73779452015-03-19 18:56:17 +0000498 sqlite3VdbeAddOp2(v, OP_VCreate, iDb, iReg);
drhb9bb7c12006-06-11 23:41:55 +0000499 }
500
drh1e32bed2020-06-19 13:33:53 +0000501 /* If we are rereading the sqlite_schema table create the in-memory
danielk1977595a5232009-07-24 17:58:53 +0000502 ** record of the table. The xConnect() method is not called until
503 ** the first time the virtual table is used in an SQL statement. This
504 ** allows a schema that contains virtual tables to be loaded before
505 ** the required virtual table implementations are registered. */
danielk197778efaba2006-06-12 06:09:17 +0000506 else {
danielk197778efaba2006-06-12 06:09:17 +0000507 Table *pOld;
508 Schema *pSchema = pTab->pSchema;
509 const char *zName = pTab->zName;
drh21206082011-04-04 18:22:02 +0000510 assert( sqlite3SchemaMutexHeld(db, 0, pSchema) );
drhacbcb7e2014-08-21 20:26:37 +0000511 pOld = sqlite3HashInsert(&pSchema->tblHash, zName, pTab);
danielk197778efaba2006-06-12 06:09:17 +0000512 if( pOld ){
drh4a642b62016-02-05 01:55:27 +0000513 sqlite3OomFault(db);
danielk197778efaba2006-06-12 06:09:17 +0000514 assert( pTab==pOld ); /* Malloc must have failed inside HashInsert() */
515 return;
516 }
danielk19777e6ebfb2006-06-12 11:24:37 +0000517 pParse->pNewTable = 0;
drhb9bb7c12006-06-11 23:41:55 +0000518 }
519}
520
521/*
522** The parser calls this routine when it sees the first token
523** of an argument to the module name in a CREATE VIRTUAL TABLE statement.
524*/
525void sqlite3VtabArgInit(Parse *pParse){
526 addArgumentToVtab(pParse);
danielk197733b39332006-06-24 08:51:05 +0000527 pParse->sArg.z = 0;
528 pParse->sArg.n = 0;
drhb9bb7c12006-06-11 23:41:55 +0000529}
530
531/*
532** The parser calls this routine for each token after the first token
533** in an argument to the module name in a CREATE VIRTUAL TABLE statement.
534*/
535void sqlite3VtabArgExtend(Parse *pParse, Token *p){
danielk197733b39332006-06-24 08:51:05 +0000536 Token *pArg = &pParse->sArg;
537 if( pArg->z==0 ){
538 pArg->z = p->z;
539 pArg->n = p->n;
540 }else{
drh542a1762015-04-19 23:11:10 +0000541 assert(pArg->z <= p->z);
drhb27b7f52008-12-10 18:03:45 +0000542 pArg->n = (int)(&p->z[p->n] - pArg->z);
drhb9bb7c12006-06-11 23:41:55 +0000543 }
drhb9bb7c12006-06-11 23:41:55 +0000544}
545
danielk197778efaba2006-06-12 06:09:17 +0000546/*
danielk19779da9d472006-06-14 06:58:15 +0000547** Invoke a virtual table constructor (either xCreate or xConnect). The
548** pointer to the function to invoke is passed as the fourth parameter
549** to this procedure.
550*/
551static int vtabCallConstructor(
552 sqlite3 *db,
553 Table *pTab,
danielk1977d1ab1ba2006-06-15 04:28:13 +0000554 Module *pMod,
drhe4102962006-09-11 00:34:22 +0000555 int (*xConstruct)(sqlite3*,void*,int,const char*const*,sqlite3_vtab**,char**),
danielk19779da9d472006-06-14 06:58:15 +0000556 char **pzErr
557){
dan75395cc2015-04-10 07:55:07 +0000558 VtabCtx sCtx;
danielk1977595a5232009-07-24 17:58:53 +0000559 VTable *pVTable;
danielk19779da9d472006-06-14 06:58:15 +0000560 int rc;
drhf38524d2021-08-02 16:41:57 +0000561 const char *const*azArg = (const char *const*)pTab->u.vtab.azArg;
562 int nArg = pTab->u.vtab.nArg;
drh4ca8aac2006-09-10 17:31:58 +0000563 char *zErr = 0;
dan75395cc2015-04-10 07:55:07 +0000564 char *zModuleName;
dan41fb5cd2012-10-04 19:33:00 +0000565 int iDb;
dan75395cc2015-04-10 07:55:07 +0000566 VtabCtx *pCtx;
danielk19779da9d472006-06-14 06:58:15 +0000567
dan75395cc2015-04-10 07:55:07 +0000568 /* Check that the virtual-table is not already being initialized */
569 for(pCtx=db->pVtabCtx; pCtx; pCtx=pCtx->pPrior){
570 if( pCtx->pTab==pTab ){
571 *pzErr = sqlite3MPrintf(db,
572 "vtable constructor called recursively: %s", pTab->zName
573 );
574 return SQLITE_LOCKED;
575 }
576 }
577
drh3ee14162017-10-02 13:20:43 +0000578 zModuleName = sqlite3DbStrDup(db, pTab->zName);
danielk197701256832007-04-18 14:24:32 +0000579 if( !zModuleName ){
mistachkinfad30392016-02-13 23:43:46 +0000580 return SQLITE_NOMEM_BKPT;
danielk197701256832007-04-18 14:24:32 +0000581 }
582
drh3ee14162017-10-02 13:20:43 +0000583 pVTable = sqlite3MallocZero(sizeof(VTable));
danielk1977595a5232009-07-24 17:58:53 +0000584 if( !pVTable ){
drh3ee14162017-10-02 13:20:43 +0000585 sqlite3OomFault(db);
danielk1977595a5232009-07-24 17:58:53 +0000586 sqlite3DbFree(db, zModuleName);
mistachkinfad30392016-02-13 23:43:46 +0000587 return SQLITE_NOMEM_BKPT;
danielk1977595a5232009-07-24 17:58:53 +0000588 }
589 pVTable->db = db;
590 pVTable->pMod = pMod;
drh2928a152020-01-06 15:25:41 +0000591 pVTable->eVtabRisk = SQLITE_VTABRISK_Normal;
danielk1977595a5232009-07-24 17:58:53 +0000592
dan41fb5cd2012-10-04 19:33:00 +0000593 iDb = sqlite3SchemaToIndex(db, pTab->pSchema);
drhf38524d2021-08-02 16:41:57 +0000594 pTab->u.vtab.azArg[1] = db->aDb[iDb].zDbSName;
dan41fb5cd2012-10-04 19:33:00 +0000595
danielk1977595a5232009-07-24 17:58:53 +0000596 /* Invoke the virtual table constructor */
danb061d052011-04-25 18:49:57 +0000597 assert( &db->pVtabCtx );
598 assert( xConstruct );
599 sCtx.pTab = pTab;
600 sCtx.pVTable = pVTable;
dan75395cc2015-04-10 07:55:07 +0000601 sCtx.pPrior = db->pVtabCtx;
602 sCtx.bDeclared = 0;
danb061d052011-04-25 18:49:57 +0000603 db->pVtabCtx = &sCtx;
danielk1977595a5232009-07-24 17:58:53 +0000604 rc = xConstruct(db, pMod->pAux, nArg, azArg, &pVTable->pVtab, &zErr);
dan75395cc2015-04-10 07:55:07 +0000605 db->pVtabCtx = sCtx.pPrior;
drh4a642b62016-02-05 01:55:27 +0000606 if( rc==SQLITE_NOMEM ) sqlite3OomFault(db);
dan75395cc2015-04-10 07:55:07 +0000607 assert( sCtx.pTab==pTab );
danielk19779da9d472006-06-14 06:58:15 +0000608
609 if( SQLITE_OK!=rc ){
drh4ca8aac2006-09-10 17:31:58 +0000610 if( zErr==0 ){
danielk19771e536952007-08-16 10:09:01 +0000611 *pzErr = sqlite3MPrintf(db, "vtable constructor failed: %s", zModuleName);
drh4ca8aac2006-09-10 17:31:58 +0000612 }else {
danielk19771e536952007-08-16 10:09:01 +0000613 *pzErr = sqlite3MPrintf(db, "%s", zErr);
drhb9755982010-07-24 16:34:37 +0000614 sqlite3_free(zErr);
drhfe1368e2006-09-10 17:08:29 +0000615 }
danielk1977595a5232009-07-24 17:58:53 +0000616 sqlite3DbFree(db, pVTable);
617 }else if( ALWAYS(pVTable->pVtab) ){
618 /* Justification of ALWAYS(): A correct vtab constructor must allocate
619 ** the sqlite3_vtab object if successful. */
drh5604cc02014-10-14 20:25:43 +0000620 memset(pVTable->pVtab, 0, sizeof(pVTable->pVtab[0]));
danielk1977595a5232009-07-24 17:58:53 +0000621 pVTable->pVtab->pModule = pMod->pModule;
drhcc5979d2019-08-16 22:58:29 +0000622 pMod->nRefModule++;
danielk1977595a5232009-07-24 17:58:53 +0000623 pVTable->nRef = 1;
dan75395cc2015-04-10 07:55:07 +0000624 if( sCtx.bDeclared==0 ){
danielk1977595a5232009-07-24 17:58:53 +0000625 const char *zFormat = "vtable constructor did not declare schema: %s";
626 *pzErr = sqlite3MPrintf(db, zFormat, pTab->zName);
627 sqlite3VtabUnlock(pVTable);
628 rc = SQLITE_ERROR;
629 }else{
630 int iCol;
drhc1431142019-10-17 17:54:05 +0000631 u16 oooHidden = 0;
danielk1977595a5232009-07-24 17:58:53 +0000632 /* If everything went according to plan, link the new VTable structure
drhf38524d2021-08-02 16:41:57 +0000633 ** into the linked list headed by pTab->u.vtab.p. Then loop through the
danielk1977595a5232009-07-24 17:58:53 +0000634 ** columns of the table to see if any of them contain the token "hidden".
drha371ace2012-09-13 14:22:47 +0000635 ** If so, set the Column COLFLAG_HIDDEN flag and remove the token from
danielk1977595a5232009-07-24 17:58:53 +0000636 ** the type string. */
drhf38524d2021-08-02 16:41:57 +0000637 pVTable->pNext = pTab->u.vtab.p;
638 pTab->u.vtab.p = pVTable;
danielk1977034ca142007-06-26 10:38:54 +0000639
danielk1977595a5232009-07-24 17:58:53 +0000640 for(iCol=0; iCol<pTab->nCol; iCol++){
drhd7564862016-03-22 20:05:09 +0000641 char *zType = sqlite3ColumnType(&pTab->aCol[iCol], "");
danielk1977595a5232009-07-24 17:58:53 +0000642 int nType;
643 int i = 0;
danielk1977595a5232009-07-24 17:58:53 +0000644 nType = sqlite3Strlen30(zType);
drhd7564862016-03-22 20:05:09 +0000645 for(i=0; i<nType; i++){
646 if( 0==sqlite3StrNICmp("hidden", &zType[i], 6)
647 && (i==0 || zType[i-1]==' ')
648 && (zType[i+6]=='\0' || zType[i+6]==' ')
649 ){
650 break;
danielk1977034ca142007-06-26 10:38:54 +0000651 }
652 }
danielk1977595a5232009-07-24 17:58:53 +0000653 if( i<nType ){
654 int j;
655 int nDel = 6 + (zType[i+6] ? 1 : 0);
656 for(j=i; (j+nDel)<=nType; j++){
657 zType[j] = zType[j+nDel];
658 }
659 if( zType[i]=='\0' && i>0 ){
660 assert(zType[i-1]==' ');
661 zType[i-1] = '\0';
662 }
drha371ace2012-09-13 14:22:47 +0000663 pTab->aCol[iCol].colFlags |= COLFLAG_HIDDEN;
drh6f6e60d2021-02-18 15:45:34 +0000664 pTab->tabFlags |= TF_HasHidden;
drha21f78b2015-04-19 18:32:43 +0000665 oooHidden = TF_OOOHidden;
666 }else{
667 pTab->tabFlags |= oooHidden;
danielk1977034ca142007-06-26 10:38:54 +0000668 }
danielk1977034ca142007-06-26 10:38:54 +0000669 }
670 }
671 }
danielk1977595a5232009-07-24 17:58:53 +0000672
673 sqlite3DbFree(db, zModuleName);
danielk19779da9d472006-06-14 06:58:15 +0000674 return rc;
675}
676
677/*
danielk19777e6ebfb2006-06-12 11:24:37 +0000678** This function is invoked by the parser to call the xConnect() method
danielk1977fe3fcbe22006-06-12 12:08:45 +0000679** of the virtual table pTab. If an error occurs, an error code is returned
680** and an error left in pParse.
681**
682** This call is a no-op if table pTab is not a virtual table.
danielk19777e6ebfb2006-06-12 11:24:37 +0000683*/
684int sqlite3VtabCallConnect(Parse *pParse, Table *pTab){
danielk1977595a5232009-07-24 17:58:53 +0000685 sqlite3 *db = pParse->db;
686 const char *zMod;
danielk1977d1ab1ba2006-06-15 04:28:13 +0000687 Module *pMod;
danielk1977595a5232009-07-24 17:58:53 +0000688 int rc;
danielk19777e6ebfb2006-06-12 11:24:37 +0000689
drh748ce212009-05-20 20:10:47 +0000690 assert( pTab );
drh44266ec2017-02-16 14:48:08 +0000691 if( !IsVirtual(pTab) || sqlite3GetVTable(db, pTab) ){
danielk19777e6ebfb2006-06-12 11:24:37 +0000692 return SQLITE_OK;
693 }
694
danielk1977595a5232009-07-24 17:58:53 +0000695 /* Locate the required virtual table module */
drhf38524d2021-08-02 16:41:57 +0000696 zMod = pTab->u.vtab.azArg[0];
drhacbcb7e2014-08-21 20:26:37 +0000697 pMod = (Module*)sqlite3HashFind(&db->aModule, zMod);
danielk1977595a5232009-07-24 17:58:53 +0000698
danielk1977d1ab1ba2006-06-15 04:28:13 +0000699 if( !pMod ){
drhf38524d2021-08-02 16:41:57 +0000700 const char *zModule = pTab->u.vtab.azArg[0];
danielk1977a4e76362006-06-14 06:31:28 +0000701 sqlite3ErrorMsg(pParse, "no such module: %s", zModule);
danielk19777e6ebfb2006-06-12 11:24:37 +0000702 rc = SQLITE_ERROR;
danielk1977595a5232009-07-24 17:58:53 +0000703 }else{
danielk19779da9d472006-06-14 06:58:15 +0000704 char *zErr = 0;
danielk1977d1ab1ba2006-06-15 04:28:13 +0000705 rc = vtabCallConstructor(db, pTab, pMod, pMod->pModule->xConnect, &zErr);
danielk19779da9d472006-06-14 06:58:15 +0000706 if( rc!=SQLITE_OK ){
707 sqlite3ErrorMsg(pParse, "%s", zErr);
drh7524b612017-08-09 22:55:09 +0000708 pParse->rc = rc;
danielk19777e6ebfb2006-06-12 11:24:37 +0000709 }
drh633e6d52008-07-28 19:34:53 +0000710 sqlite3DbFree(db, zErr);
danielk19777e6ebfb2006-06-12 11:24:37 +0000711 }
712
713 return rc;
714}
danielk19779da9d472006-06-14 06:58:15 +0000715/*
dan2cac2072011-05-25 18:46:22 +0000716** Grow the db->aVTrans[] array so that there is room for at least one
717** more v-table. Return SQLITE_NOMEM if a malloc fails, or SQLITE_OK otherwise.
danielk1977e7ff4032006-06-17 11:30:32 +0000718*/
dan2cac2072011-05-25 18:46:22 +0000719static int growVTrans(sqlite3 *db){
danielk1977e7ff4032006-06-17 11:30:32 +0000720 const int ARRAY_INCR = 5;
721
722 /* Grow the sqlite3.aVTrans array if required */
723 if( (db->nVTrans%ARRAY_INCR)==0 ){
danielk1977595a5232009-07-24 17:58:53 +0000724 VTable **aVTrans;
drh0aa32312019-04-13 04:01:12 +0000725 sqlite3_int64 nBytes = sizeof(sqlite3_vtab*)*
726 ((sqlite3_int64)db->nVTrans + ARRAY_INCR);
danielk197726783a52007-08-29 14:06:22 +0000727 aVTrans = sqlite3DbRealloc(db, (void *)db->aVTrans, nBytes);
danielk1977e7ff4032006-06-17 11:30:32 +0000728 if( !aVTrans ){
mistachkinfad30392016-02-13 23:43:46 +0000729 return SQLITE_NOMEM_BKPT;
danielk1977e7ff4032006-06-17 11:30:32 +0000730 }
731 memset(&aVTrans[db->nVTrans], 0, sizeof(sqlite3_vtab *)*ARRAY_INCR);
732 db->aVTrans = aVTrans;
733 }
734
dan2cac2072011-05-25 18:46:22 +0000735 return SQLITE_OK;
736}
737
738/*
739** Add the virtual table pVTab to the array sqlite3.aVTrans[]. Space should
740** have already been reserved using growVTrans().
741*/
742static void addToVTrans(sqlite3 *db, VTable *pVTab){
danielk1977e7ff4032006-06-17 11:30:32 +0000743 /* Add pVtab to the end of sqlite3.aVTrans */
danielk1977595a5232009-07-24 17:58:53 +0000744 db->aVTrans[db->nVTrans++] = pVTab;
745 sqlite3VtabLock(pVTab);
danielk1977e7ff4032006-06-17 11:30:32 +0000746}
747
748/*
danielk19779da9d472006-06-14 06:58:15 +0000749** This function is invoked by the vdbe to call the xCreate method
750** of the virtual table named zTab in database iDb.
751**
drh2e5c5052016-08-27 20:21:51 +0000752** If an error occurs, *pzErr is set to point to an English language
danielk19779da9d472006-06-14 06:58:15 +0000753** description of the error and an SQLITE_XXX error code is returned.
drh633e6d52008-07-28 19:34:53 +0000754** In this case the caller must call sqlite3DbFree(db, ) on *pzErr.
danielk19779da9d472006-06-14 06:58:15 +0000755*/
756int sqlite3VtabCallCreate(sqlite3 *db, int iDb, const char *zTab, char **pzErr){
757 int rc = SQLITE_OK;
758 Table *pTab;
danielk1977d1ab1ba2006-06-15 04:28:13 +0000759 Module *pMod;
danielk1977595a5232009-07-24 17:58:53 +0000760 const char *zMod;
danielk19779da9d472006-06-14 06:58:15 +0000761
drh69c33822016-08-18 14:33:11 +0000762 pTab = sqlite3FindTable(db, zTab, db->aDb[iDb].zDbSName);
drhf38524d2021-08-02 16:41:57 +0000763 assert( pTab && IsVirtual(pTab) && !pTab->u.vtab.p );
danielk1977595a5232009-07-24 17:58:53 +0000764
765 /* Locate the required virtual table module */
drhf38524d2021-08-02 16:41:57 +0000766 zMod = pTab->u.vtab.azArg[0];
drhacbcb7e2014-08-21 20:26:37 +0000767 pMod = (Module*)sqlite3HashFind(&db->aModule, zMod);
danielk19779da9d472006-06-14 06:58:15 +0000768
769 /* If the module has been registered and includes a Create method,
770 ** invoke it now. If the module has not been registered, return an
771 ** error. Otherwise, do nothing.
772 */
drhd8b1bfc2015-08-20 23:21:34 +0000773 if( pMod==0 || pMod->pModule->xCreate==0 || pMod->pModule->xDestroy==0 ){
danielk1977595a5232009-07-24 17:58:53 +0000774 *pzErr = sqlite3MPrintf(db, "no such module: %s", zMod);
danielk19779da9d472006-06-14 06:58:15 +0000775 rc = SQLITE_ERROR;
776 }else{
danielk1977d1ab1ba2006-06-15 04:28:13 +0000777 rc = vtabCallConstructor(db, pTab, pMod, pMod->pModule->xCreate, pzErr);
danielk19779da9d472006-06-14 06:58:15 +0000778 }
779
drh748ce212009-05-20 20:10:47 +0000780 /* Justification of ALWAYS(): The xConstructor method is required to
781 ** create a valid sqlite3_vtab if it returns SQLITE_OK. */
danielk1977595a5232009-07-24 17:58:53 +0000782 if( rc==SQLITE_OK && ALWAYS(sqlite3GetVTable(db, pTab)) ){
dan2cac2072011-05-25 18:46:22 +0000783 rc = growVTrans(db);
784 if( rc==SQLITE_OK ){
785 addToVTrans(db, sqlite3GetVTable(db, pTab));
786 }
danielk1977e7ff4032006-06-17 11:30:32 +0000787 }
788
danielk19779da9d472006-06-14 06:58:15 +0000789 return rc;
790}
danielk1977be8a7832006-06-13 15:00:54 +0000791
792/*
danielk1977fe3fcbe22006-06-12 12:08:45 +0000793** This function is used to set the schema of a virtual table. It is only
794** valid to call this function from within the xCreate() or xConnect() of a
795** virtual table module.
796*/
danielk19777e6ebfb2006-06-12 11:24:37 +0000797int sqlite3_declare_vtab(sqlite3 *db, const char *zCreateTable){
dan4e235362015-04-10 16:05:33 +0000798 VtabCtx *pCtx;
danielk19777e6ebfb2006-06-12 11:24:37 +0000799 int rc = SQLITE_OK;
drh27641702007-08-22 02:56:42 +0000800 Table *pTab;
danielk19777e6ebfb2006-06-12 11:24:37 +0000801 char *zErr = 0;
drh6903bf62017-08-01 20:59:41 +0000802 Parse sParse;
danielk19777e6ebfb2006-06-12 11:24:37 +0000803
drh9ca95732014-10-24 00:35:58 +0000804#ifdef SQLITE_ENABLE_API_ARMOR
drh96c707a2015-02-13 16:36:14 +0000805 if( !sqlite3SafetyCheckOk(db) || zCreateTable==0 ){
806 return SQLITE_MISUSE_BKPT;
807 }
drh9ca95732014-10-24 00:35:58 +0000808#endif
drh27641702007-08-22 02:56:42 +0000809 sqlite3_mutex_enter(db->mutex);
dan4e235362015-04-10 16:05:33 +0000810 pCtx = db->pVtabCtx;
dan75395cc2015-04-10 07:55:07 +0000811 if( !pCtx || pCtx->bDeclared ){
drh13f40da2014-08-22 18:00:11 +0000812 sqlite3Error(db, SQLITE_MISUSE);
drh27641702007-08-22 02:56:42 +0000813 sqlite3_mutex_leave(db->mutex);
drh413c3d32010-02-23 20:11:56 +0000814 return SQLITE_MISUSE_BKPT;
danielk19777e6ebfb2006-06-12 11:24:37 +0000815 }
dan75395cc2015-04-10 07:55:07 +0000816 pTab = pCtx->pTab;
drh44266ec2017-02-16 14:48:08 +0000817 assert( IsVirtual(pTab) );
danielk19777e6ebfb2006-06-12 11:24:37 +0000818
drh6903bf62017-08-01 20:59:41 +0000819 memset(&sParse, 0, sizeof(sParse));
dancf8f2892018-08-09 20:47:01 +0000820 sParse.eParseMode = PARSE_MODE_DECLARE_VTAB;
drh6903bf62017-08-01 20:59:41 +0000821 sParse.db = db;
822 sParse.nQueryLoop = 1;
823 if( SQLITE_OK==sqlite3RunParser(&sParse, zCreateTable, &zErr)
824 && sParse.pNewTable
825 && !db->mallocFailed
drhf38524d2021-08-02 16:41:57 +0000826 && IsOrdinaryTable(sParse.pNewTable)
drh6903bf62017-08-01 20:59:41 +0000827 ){
828 if( !pTab->aCol ){
829 Table *pNew = sParse.pNewTable;
830 Index *pIdx;
831 pTab->aCol = pNew->aCol;
drhf38524d2021-08-02 16:41:57 +0000832 sqlite3ExprListDelete(db, pNew->u.tab.pDfltList);
drh7dec8042021-02-04 22:59:19 +0000833 pTab->nNVCol = pTab->nCol = pNew->nCol;
drh6903bf62017-08-01 20:59:41 +0000834 pTab->tabFlags |= pNew->tabFlags & (TF_WithoutRowid|TF_NoVisibleRowid);
835 pNew->nCol = 0;
836 pNew->aCol = 0;
837 assert( pTab->pIndex==0 );
drhe3740f22017-08-10 15:19:39 +0000838 assert( HasRowid(pNew) || sqlite3PrimaryKeyIndex(pNew)!=0 );
839 if( !HasRowid(pNew)
840 && pCtx->pVTable->pMod->pModule->xUpdate!=0
841 && sqlite3PrimaryKeyIndex(pNew)->nKeyCol!=1
842 ){
843 /* WITHOUT ROWID virtual tables must either be read-only (xUpdate==0)
844 ** or else must have a single-column PRIMARY KEY */
drh6903bf62017-08-01 20:59:41 +0000845 rc = SQLITE_ERROR;
danielk1977595a5232009-07-24 17:58:53 +0000846 }
drh6903bf62017-08-01 20:59:41 +0000847 pIdx = pNew->pIndex;
848 if( pIdx ){
849 assert( pIdx->pNext==0 );
850 pTab->pIndex = pIdx;
851 pNew->pIndex = 0;
852 pIdx->pTable = pTab;
853 }
drhe98c9042009-06-02 21:31:38 +0000854 }
drh6903bf62017-08-01 20:59:41 +0000855 pCtx->bDeclared = 1;
856 }else{
857 sqlite3ErrorWithMsg(db, SQLITE_ERROR, (zErr ? "%s" : 0), zErr);
858 sqlite3DbFree(db, zErr);
859 rc = SQLITE_ERROR;
danielk19777e6ebfb2006-06-12 11:24:37 +0000860 }
dancf8f2892018-08-09 20:47:01 +0000861 sParse.eParseMode = PARSE_MODE_NORMAL;
drh6903bf62017-08-01 20:59:41 +0000862
863 if( sParse.pVdbe ){
864 sqlite3VdbeFinalize(sParse.pVdbe);
865 }
866 sqlite3DeleteTable(db, sParse.pNewTable);
867 sqlite3ParserReset(&sParse);
danielk19777e6ebfb2006-06-12 11:24:37 +0000868
drh4ac285a2006-09-15 07:28:50 +0000869 assert( (rc&0xff)==rc );
drh27641702007-08-22 02:56:42 +0000870 rc = sqlite3ApiExit(db, rc);
871 sqlite3_mutex_leave(db->mutex);
872 return rc;
danielk19777e6ebfb2006-06-12 11:24:37 +0000873}
874
875/*
danielk19779e39ce82006-06-12 16:01:21 +0000876** This function is invoked by the vdbe to call the xDestroy method
877** of the virtual table named zTab in database iDb. This occurs
878** when a DROP TABLE is mentioned.
879**
880** This call is a no-op if zTab is not a virtual table.
881*/
drh748ce212009-05-20 20:10:47 +0000882int sqlite3VtabCallDestroy(sqlite3 *db, int iDb, const char *zTab){
danielk19779e39ce82006-06-12 16:01:21 +0000883 int rc = SQLITE_OK;
884 Table *pTab;
danielk19779e39ce82006-06-12 16:01:21 +0000885
drh69c33822016-08-18 14:33:11 +0000886 pTab = sqlite3FindTable(db, zTab, db->aDb[iDb].zDbSName);
drhf38524d2021-08-02 16:41:57 +0000887 if( pTab!=0 && ALWAYS(pTab->u.vtab.p!=0) ){
drha68d6282015-03-24 13:32:53 +0000888 VTable *p;
mistachkin197d59f2015-08-20 21:14:31 +0000889 int (*xDestroy)(sqlite3_vtab *);
drhf38524d2021-08-02 16:41:57 +0000890 for(p=pTab->u.vtab.p; p; p=p->pNext){
drha68d6282015-03-24 13:32:53 +0000891 assert( p->pVtab );
892 if( p->pVtab->nRef>0 ){
893 return SQLITE_LOCKED;
894 }
895 }
896 p = vtabDisconnectAll(db, pTab);
mistachkin197d59f2015-08-20 21:14:31 +0000897 xDestroy = p->pMod->pModule->xDestroy;
drha1ca00e2019-12-11 15:07:09 +0000898 if( xDestroy==0 ) xDestroy = p->pMod->pModule->xDisconnect;
899 assert( xDestroy!=0 );
danc589acb2019-04-30 15:36:32 +0000900 pTab->nTabRef++;
drha1ca00e2019-12-11 15:07:09 +0000901 rc = xDestroy(p->pVtab);
danielk1977595a5232009-07-24 17:58:53 +0000902 /* Remove the sqlite3_vtab* from the aVTrans[] array, if applicable */
danielk19779e39ce82006-06-12 16:01:21 +0000903 if( rc==SQLITE_OK ){
drhf38524d2021-08-02 16:41:57 +0000904 assert( pTab->u.vtab.p==p && p->pNext==0 );
danielk1977595a5232009-07-24 17:58:53 +0000905 p->pVtab = 0;
drhf38524d2021-08-02 16:41:57 +0000906 pTab->u.vtab.p = 0;
danielk1977595a5232009-07-24 17:58:53 +0000907 sqlite3VtabUnlock(p);
danielk19779e39ce82006-06-12 16:01:21 +0000908 }
danc589acb2019-04-30 15:36:32 +0000909 sqlite3DeleteTable(db, pTab);
danielk19779e39ce82006-06-12 16:01:21 +0000910 }
911
912 return rc;
913}
914
danielk1977f9e7dda2006-06-16 16:08:53 +0000915/*
danielk1977e7ff4032006-06-17 11:30:32 +0000916** This function invokes either the xRollback or xCommit method
917** of each of the virtual tables in the sqlite3.aVTrans array. The method
918** called is identified by the second argument, "offset", which is
919** the offset of the method to call in the sqlite3_module structure.
920**
921** The array is cleared after invoking the callbacks.
922*/
drh7209c692008-04-27 18:40:11 +0000923static void callFinaliser(sqlite3 *db, int offset){
danielk1977e7ff4032006-06-17 11:30:32 +0000924 int i;
danielk19770b83fa82007-04-19 14:48:37 +0000925 if( db->aVTrans ){
dane4bec372014-12-18 18:25:48 +0000926 VTable **aVTrans = db->aVTrans;
927 db->aVTrans = 0;
drh748ce212009-05-20 20:10:47 +0000928 for(i=0; i<db->nVTrans; i++){
dane4bec372014-12-18 18:25:48 +0000929 VTable *pVTab = aVTrans[i];
danielk1977595a5232009-07-24 17:58:53 +0000930 sqlite3_vtab *p = pVTab->pVtab;
931 if( p ){
932 int (*x)(sqlite3_vtab *);
933 x = *(int (**)(sqlite3_vtab *))((char *)p->pModule + offset);
934 if( x ) x(p);
935 }
drh346506f2011-05-25 01:16:42 +0000936 pVTab->iSavepoint = 0;
danielk1977595a5232009-07-24 17:58:53 +0000937 sqlite3VtabUnlock(pVTab);
danielk19770b83fa82007-04-19 14:48:37 +0000938 }
dane4bec372014-12-18 18:25:48 +0000939 sqlite3DbFree(db, aVTrans);
danielk19770b83fa82007-04-19 14:48:37 +0000940 db->nVTrans = 0;
danielk1977e7ff4032006-06-17 11:30:32 +0000941 }
danielk1977e7ff4032006-06-17 11:30:32 +0000942}
943
944/*
danielk19773e3a84d2008-08-01 17:37:40 +0000945** Invoke the xSync method of all virtual tables in the sqlite3.aVTrans
946** array. Return the error code for the first error that occurs, or
947** SQLITE_OK if all xSync operations are successful.
948**
dan016f7812013-08-21 17:35:48 +0000949** If an error message is available, leave it in p->zErrMsg.
danielk1977f9e7dda2006-06-16 16:08:53 +0000950*/
dan016f7812013-08-21 17:35:48 +0000951int sqlite3VtabSync(sqlite3 *db, Vdbe *p){
danielk1977e7ff4032006-06-17 11:30:32 +0000952 int i;
953 int rc = SQLITE_OK;
danielk1977595a5232009-07-24 17:58:53 +0000954 VTable **aVTrans = db->aVTrans;
danielk197720b1eaf2006-07-26 16:22:14 +0000955
danielk197720b1eaf2006-07-26 16:22:14 +0000956 db->aVTrans = 0;
drh748ce212009-05-20 20:10:47 +0000957 for(i=0; rc==SQLITE_OK && i<db->nVTrans; i++){
danielk1977e7ff4032006-06-17 11:30:32 +0000958 int (*x)(sqlite3_vtab *);
danielk1977595a5232009-07-24 17:58:53 +0000959 sqlite3_vtab *pVtab = aVTrans[i]->pVtab;
960 if( pVtab && (x = pVtab->pModule->xSync)!=0 ){
danielk1977e7ff4032006-06-17 11:30:32 +0000961 rc = x(pVtab);
dan016f7812013-08-21 17:35:48 +0000962 sqlite3VtabImportErrmsg(p, pVtab);
danielk1977e7ff4032006-06-17 11:30:32 +0000963 }
964 }
danielk197720b1eaf2006-07-26 16:22:14 +0000965 db->aVTrans = aVTrans;
danielk1977e7ff4032006-06-17 11:30:32 +0000966 return rc;
danielk1977f9e7dda2006-06-16 16:08:53 +0000967}
968
969/*
970** Invoke the xRollback method of all virtual tables in the
971** sqlite3.aVTrans array. Then clear the array itself.
972*/
973int sqlite3VtabRollback(sqlite3 *db){
drh7209c692008-04-27 18:40:11 +0000974 callFinaliser(db, offsetof(sqlite3_module,xRollback));
danielk1977e7ff4032006-06-17 11:30:32 +0000975 return SQLITE_OK;
danielk1977f9e7dda2006-06-16 16:08:53 +0000976}
977
978/*
979** Invoke the xCommit method of all virtual tables in the
980** sqlite3.aVTrans array. Then clear the array itself.
981*/
982int sqlite3VtabCommit(sqlite3 *db){
drh7209c692008-04-27 18:40:11 +0000983 callFinaliser(db, offsetof(sqlite3_module,xCommit));
danielk1977e7ff4032006-06-17 11:30:32 +0000984 return SQLITE_OK;
danielk1977f9e7dda2006-06-16 16:08:53 +0000985}
986
987/*
988** If the virtual table pVtab supports the transaction interface
989** (xBegin/xRollback/xCommit and optionally xSync) and a transaction is
990** not currently open, invoke the xBegin method now.
991**
992** If the xBegin call is successful, place the sqlite3_vtab pointer
993** in the sqlite3.aVTrans array.
994*/
danielk1977595a5232009-07-24 17:58:53 +0000995int sqlite3VtabBegin(sqlite3 *db, VTable *pVTab){
danielk1977f9e7dda2006-06-16 16:08:53 +0000996 int rc = SQLITE_OK;
danielk197720b1eaf2006-07-26 16:22:14 +0000997 const sqlite3_module *pModule;
998
999 /* Special case: If db->aVTrans is NULL and db->nVTrans is greater
1000 ** than zero, then this function is being called from within a
1001 ** virtual module xSync() callback. It is illegal to write to
drh748ce212009-05-20 20:10:47 +00001002 ** virtual module tables in this case, so return SQLITE_LOCKED.
danielk197720b1eaf2006-07-26 16:22:14 +00001003 */
danielk1977093e0f62008-11-13 18:00:14 +00001004 if( sqlite3VtabInSync(db) ){
danielk197720b1eaf2006-07-26 16:22:14 +00001005 return SQLITE_LOCKED;
1006 }
danielk1977595a5232009-07-24 17:58:53 +00001007 if( !pVTab ){
danielk197720b1eaf2006-07-26 16:22:14 +00001008 return SQLITE_OK;
1009 }
danielk1977595a5232009-07-24 17:58:53 +00001010 pModule = pVTab->pVtab->pModule;
danielk197720b1eaf2006-07-26 16:22:14 +00001011
danielk1977f9e7dda2006-06-16 16:08:53 +00001012 if( pModule->xBegin ){
1013 int i;
1014
1015 /* If pVtab is already in the aVTrans array, return early */
drh748ce212009-05-20 20:10:47 +00001016 for(i=0; i<db->nVTrans; i++){
danielk1977595a5232009-07-24 17:58:53 +00001017 if( db->aVTrans[i]==pVTab ){
danielk1977f9e7dda2006-06-16 16:08:53 +00001018 return SQLITE_OK;
1019 }
1020 }
1021
dan2cac2072011-05-25 18:46:22 +00001022 /* Invoke the xBegin method. If successful, add the vtab to the
1023 ** sqlite3.aVTrans[] array. */
1024 rc = growVTrans(db);
danielk19773e3a84d2008-08-01 17:37:40 +00001025 if( rc==SQLITE_OK ){
dan2cac2072011-05-25 18:46:22 +00001026 rc = pModule->xBegin(pVTab->pVtab);
1027 if( rc==SQLITE_OK ){
dan65c4f592015-09-29 16:41:23 +00001028 int iSvpt = db->nStatement + db->nSavepoint;
dan2cac2072011-05-25 18:46:22 +00001029 addToVTrans(db, pVTab);
dan914b7e42016-08-02 11:29:16 +00001030 if( iSvpt && pModule->xSavepoint ){
1031 pVTab->iSavepoint = iSvpt;
1032 rc = pModule->xSavepoint(pVTab->pVtab, iSvpt-1);
1033 }
dan2cac2072011-05-25 18:46:22 +00001034 }
danielk1977f9e7dda2006-06-16 16:08:53 +00001035 }
danielk1977f9e7dda2006-06-16 16:08:53 +00001036 }
1037 return rc;
1038}
1039
dand9495cd2011-04-27 12:08:04 +00001040/*
1041** Invoke either the xSavepoint, xRollbackTo or xRelease method of all
1042** virtual tables that currently have an open transaction. Pass iSavepoint
1043** as the second argument to the virtual table method invoked.
1044**
1045** If op is SAVEPOINT_BEGIN, the xSavepoint method is invoked. If it is
1046** SAVEPOINT_ROLLBACK, the xRollbackTo method. Otherwise, if op is
1047** SAVEPOINT_RELEASE, then the xRelease method of each virtual table with
1048** an open transaction is invoked.
1049**
1050** If any virtual table method returns an error code other than SQLITE_OK,
1051** processing is abandoned and the error returned to the caller of this
1052** function immediately. If all calls to virtual table methods are successful,
1053** SQLITE_OK is returned.
1054*/
dana311b802011-04-26 19:21:34 +00001055int sqlite3VtabSavepoint(sqlite3 *db, int op, int iSavepoint){
dana311b802011-04-26 19:21:34 +00001056 int rc = SQLITE_OK;
1057
1058 assert( op==SAVEPOINT_RELEASE||op==SAVEPOINT_ROLLBACK||op==SAVEPOINT_BEGIN );
danea8562e2015-04-18 16:25:54 +00001059 assert( iSavepoint>=-1 );
dand9495cd2011-04-27 12:08:04 +00001060 if( db->aVTrans ){
1061 int i;
1062 for(i=0; rc==SQLITE_OK && i<db->nVTrans; i++){
drhe4855222011-05-24 15:36:01 +00001063 VTable *pVTab = db->aVTrans[i];
1064 const sqlite3_module *pMod = pVTab->pMod->pModule;
dan341cade2011-10-29 11:43:04 +00001065 if( pVTab->pVtab && pMod->iVersion>=2 ){
dand9495cd2011-04-27 12:08:04 +00001066 int (*xMethod)(sqlite3_vtab *, int);
dan83a635a2019-02-04 16:25:40 +00001067 sqlite3VtabLock(pVTab);
dand9495cd2011-04-27 12:08:04 +00001068 switch( op ){
1069 case SAVEPOINT_BEGIN:
1070 xMethod = pMod->xSavepoint;
drh346506f2011-05-25 01:16:42 +00001071 pVTab->iSavepoint = iSavepoint+1;
dand9495cd2011-04-27 12:08:04 +00001072 break;
1073 case SAVEPOINT_ROLLBACK:
1074 xMethod = pMod->xRollbackTo;
1075 break;
1076 default:
1077 xMethod = pMod->xRelease;
1078 break;
1079 }
drh346506f2011-05-25 01:16:42 +00001080 if( xMethod && pVTab->iSavepoint>iSavepoint ){
dan341cade2011-10-29 11:43:04 +00001081 rc = xMethod(pVTab->pVtab, iSavepoint);
drh346506f2011-05-25 01:16:42 +00001082 }
dan83a635a2019-02-04 16:25:40 +00001083 sqlite3VtabUnlock(pVTab);
dana311b802011-04-26 19:21:34 +00001084 }
1085 }
1086 }
1087 return rc;
1088}
1089
drhb7f6f682006-07-08 17:06:43 +00001090/*
1091** The first parameter (pDef) is a function implementation. The
1092** second parameter (pExpr) is the first argument to this function.
1093** If pExpr is a column in a virtual table, then let the virtual
1094** table implementation have an opportunity to overload the function.
1095**
1096** This routine is used to allow virtual table implementations to
1097** overload MATCH, LIKE, GLOB, and REGEXP operators.
1098**
1099** Return either the pDef argument (indicating no change) or a
1100** new FuncDef structure that is marked as ephemeral using the
1101** SQLITE_FUNC_EPHEM flag.
1102*/
1103FuncDef *sqlite3VtabOverloadFunction(
drh17435752007-08-16 04:30:38 +00001104 sqlite3 *db, /* Database connection for reporting malloc problems */
drhb7f6f682006-07-08 17:06:43 +00001105 FuncDef *pDef, /* Function to possibly overload */
1106 int nArg, /* Number of arguments to the function */
1107 Expr *pExpr /* First argument to the function */
1108){
1109 Table *pTab;
1110 sqlite3_vtab *pVtab;
1111 sqlite3_module *pMod;
drh2d801512016-01-14 22:19:58 +00001112 void (*xSFunc)(sqlite3_context*,int,sqlite3_value**) = 0;
drhdc5ea5c2008-12-10 17:19:59 +00001113 void *pArg = 0;
drhb7f6f682006-07-08 17:06:43 +00001114 FuncDef *pNew;
drh777b17a2007-09-20 10:02:54 +00001115 int rc = 0;
drhb7f6f682006-07-08 17:06:43 +00001116
1117 /* Check to see the left operand is a column in a virtual table */
drh748ce212009-05-20 20:10:47 +00001118 if( NEVER(pExpr==0) ) return pDef;
drhb7f6f682006-07-08 17:06:43 +00001119 if( pExpr->op!=TK_COLUMN ) return pDef;
drheda079c2018-09-20 19:02:15 +00001120 pTab = pExpr->y.pTab;
dan39c9d3a2017-04-21 17:03:32 +00001121 if( pTab==0 ) return pDef;
drh44266ec2017-02-16 14:48:08 +00001122 if( !IsVirtual(pTab) ) return pDef;
danielk1977595a5232009-07-24 17:58:53 +00001123 pVtab = sqlite3GetVTable(db, pTab)->pVtab;
drhb7f6f682006-07-08 17:06:43 +00001124 assert( pVtab!=0 );
1125 assert( pVtab->pModule!=0 );
danielk19775bd270b2006-07-25 15:14:52 +00001126 pMod = (sqlite3_module *)pVtab->pModule;
drhb7f6f682006-07-08 17:06:43 +00001127 if( pMod->xFindFunction==0 ) return pDef;
1128
rseb72e88d2007-09-20 11:32:18 +00001129 /* Call the xFindFunction method on the virtual table implementation
drh92011842018-05-26 16:00:26 +00001130 ** to see if the implementation wants to overload this function.
1131 **
1132 ** Though undocumented, we have historically always invoked xFindFunction
1133 ** with an all lower-case function name. Continue in this tradition to
1134 ** avoid any chance of an incompatibility.
drha70034d2006-09-18 20:24:02 +00001135 */
drh92011842018-05-26 16:00:26 +00001136#ifdef SQLITE_DEBUG
1137 {
1138 int i;
1139 for(i=0; pDef->zName[i]; i++){
1140 unsigned char x = (unsigned char)pDef->zName[i];
1141 assert( x==sqlite3UpperToLower[x] );
drh17435752007-08-16 04:30:38 +00001142 }
drha70034d2006-09-18 20:24:02 +00001143 }
drh92011842018-05-26 16:00:26 +00001144#endif
1145 rc = pMod->xFindFunction(pVtab, nArg, pDef->zName, &xSFunc, &pArg);
drha70034d2006-09-18 20:24:02 +00001146 if( rc==0 ){
drhb7f6f682006-07-08 17:06:43 +00001147 return pDef;
1148 }
1149
1150 /* Create a new ephemeral function definition for the overloaded
1151 ** function */
drhea678832008-12-10 19:26:22 +00001152 pNew = sqlite3DbMallocZero(db, sizeof(*pNew)
danielk1977e25a50b2009-07-01 18:04:20 +00001153 + sqlite3Strlen30(pDef->zName) + 1);
drhb7f6f682006-07-08 17:06:43 +00001154 if( pNew==0 ){
1155 return pDef;
1156 }
1157 *pNew = *pDef;
drh6ad224e2016-02-24 19:57:11 +00001158 pNew->zName = (const char*)&pNew[1];
1159 memcpy((char*)&pNew[1], pDef->zName, sqlite3Strlen30(pDef->zName)+1);
drh2d801512016-01-14 22:19:58 +00001160 pNew->xSFunc = xSFunc;
drhb7f6f682006-07-08 17:06:43 +00001161 pNew->pUserData = pArg;
drhd36e1042013-09-06 13:10:12 +00001162 pNew->funcFlags |= SQLITE_FUNC_EPHEM;
drhb7f6f682006-07-08 17:06:43 +00001163 return pNew;
1164}
1165
drh4f3dd152008-04-28 18:46:43 +00001166/*
1167** Make sure virtual table pTab is contained in the pParse->apVirtualLock[]
1168** array so that an OP_VBegin will get generated for it. Add pTab to the
1169** array if it is missing. If pTab is already in the array, this routine
1170** is a no-op.
1171*/
1172void sqlite3VtabMakeWritable(Parse *pParse, Table *pTab){
dan65a7cd12009-09-01 12:16:01 +00001173 Parse *pToplevel = sqlite3ParseToplevel(pParse);
drh4f3dd152008-04-28 18:46:43 +00001174 int i, n;
drh748ce212009-05-20 20:10:47 +00001175 Table **apVtabLock;
1176
drh4f3dd152008-04-28 18:46:43 +00001177 assert( IsVirtual(pTab) );
dan65a7cd12009-09-01 12:16:01 +00001178 for(i=0; i<pToplevel->nVtabLock; i++){
1179 if( pTab==pToplevel->apVtabLock[i] ) return;
drh4f3dd152008-04-28 18:46:43 +00001180 }
dan65a7cd12009-09-01 12:16:01 +00001181 n = (pToplevel->nVtabLock+1)*sizeof(pToplevel->apVtabLock[0]);
drhd924e7b2020-05-17 00:26:44 +00001182 apVtabLock = sqlite3Realloc(pToplevel->apVtabLock, n);
drh748ce212009-05-20 20:10:47 +00001183 if( apVtabLock ){
dan65a7cd12009-09-01 12:16:01 +00001184 pToplevel->apVtabLock = apVtabLock;
1185 pToplevel->apVtabLock[pToplevel->nVtabLock++] = pTab;
drh344c38e2008-05-05 13:23:04 +00001186 }else{
drh4a642b62016-02-05 01:55:27 +00001187 sqlite3OomFault(pToplevel->db);
drh4f3dd152008-04-28 18:46:43 +00001188 }
1189}
1190
drhef45bb72011-05-05 15:39:50 +00001191/*
drh0b2c1402016-06-03 18:21:04 +00001192** Check to see if virtual table module pMod can be have an eponymous
drh51be3872015-08-19 02:32:25 +00001193** virtual table instance. If it can, create one if one does not already
danbd24e8f2021-07-08 18:29:25 +00001194** exist. Return non-zero if either the eponymous virtual table instance
1195** exists when this routine returns or if an attempt to create it failed
1196** and an error message was left in pParse.
drh51be3872015-08-19 02:32:25 +00001197**
1198** An eponymous virtual table instance is one that is named after its
1199** module, and more importantly, does not require a CREATE VIRTUAL TABLE
1200** statement in order to come into existance. Eponymous virtual table
1201** instances always exist. They cannot be DROP-ed.
1202**
1203** Any virtual table module for which xConnect and xCreate are the same
1204** method can have an eponymous virtual table instance.
1205*/
1206int sqlite3VtabEponymousTableInit(Parse *pParse, Module *pMod){
1207 const sqlite3_module *pModule = pMod->pModule;
1208 Table *pTab;
1209 char *zErr = 0;
drh51be3872015-08-19 02:32:25 +00001210 int rc;
1211 sqlite3 *db = pParse->db;
1212 if( pMod->pEpoTab ) return 1;
drh398f8722015-08-19 13:54:20 +00001213 if( pModule->xCreate!=0 && pModule->xCreate!=pModule->xConnect ) return 0;
drh0b2c1402016-06-03 18:21:04 +00001214 pTab = sqlite3DbMallocZero(db, sizeof(Table));
drh51be3872015-08-19 02:32:25 +00001215 if( pTab==0 ) return 0;
drh0b2c1402016-06-03 18:21:04 +00001216 pTab->zName = sqlite3DbStrDup(db, pMod->zName);
1217 if( pTab->zName==0 ){
1218 sqlite3DbFree(db, pTab);
1219 return 0;
1220 }
drh51be3872015-08-19 02:32:25 +00001221 pMod->pEpoTab = pTab;
drh79df7782016-12-14 14:07:35 +00001222 pTab->nTabRef = 1;
drhf38524d2021-08-02 16:41:57 +00001223 pTab->eTabType = TABTYP_VTAB;
drh51be3872015-08-19 02:32:25 +00001224 pTab->pSchema = db->aDb[0].pSchema;
drhf38524d2021-08-02 16:41:57 +00001225 assert( pTab->u.vtab.nArg==0 );
drh509c3fc2015-08-19 19:01:28 +00001226 pTab->iPKey = -1;
drh3d8c92d2021-04-22 18:02:48 +00001227 pTab->tabFlags |= TF_Eponymous;
drh0aa32312019-04-13 04:01:12 +00001228 addModuleArgument(pParse, pTab, sqlite3DbStrDup(db, pTab->zName));
1229 addModuleArgument(pParse, pTab, 0);
1230 addModuleArgument(pParse, pTab, sqlite3DbStrDup(db, pTab->zName));
drh51be3872015-08-19 02:32:25 +00001231 rc = vtabCallConstructor(db, pTab, pMod, pModule->xConnect, &zErr);
1232 if( rc ){
1233 sqlite3ErrorMsg(pParse, "%s", zErr);
1234 sqlite3DbFree(db, zErr);
1235 sqlite3VtabEponymousTableClear(db, pMod);
drh51be3872015-08-19 02:32:25 +00001236 }
1237 return 1;
1238}
1239
1240/*
1241** Erase the eponymous virtual table instance associated with
1242** virtual table module pMod, if it exists.
1243*/
1244void sqlite3VtabEponymousTableClear(sqlite3 *db, Module *pMod){
1245 Table *pTab = pMod->pEpoTab;
drhd7fd6aa2015-10-08 02:44:42 +00001246 if( pTab!=0 ){
drh0b2c1402016-06-03 18:21:04 +00001247 /* Mark the table as Ephemeral prior to deleting it, so that the
1248 ** sqlite3DeleteTable() routine will know that it is not stored in
1249 ** the schema. */
1250 pTab->tabFlags |= TF_Ephemeral;
1251 sqlite3DeleteTable(db, pTab);
drh51be3872015-08-19 02:32:25 +00001252 pMod->pEpoTab = 0;
1253 }
1254}
1255
1256/*
drhef45bb72011-05-05 15:39:50 +00001257** Return the ON CONFLICT resolution mode in effect for the virtual
1258** table update operation currently in progress.
1259**
1260** The results of this routine are undefined unless it is called from
1261** within an xUpdate method.
1262*/
danb061d052011-04-25 18:49:57 +00001263int sqlite3_vtab_on_conflict(sqlite3 *db){
drhef45bb72011-05-05 15:39:50 +00001264 static const unsigned char aMap[] = {
drh87f67bf2011-05-05 17:41:58 +00001265 SQLITE_ROLLBACK, SQLITE_ABORT, SQLITE_FAIL, SQLITE_IGNORE, SQLITE_REPLACE
danb061d052011-04-25 18:49:57 +00001266 };
drh9ca95732014-10-24 00:35:58 +00001267#ifdef SQLITE_ENABLE_API_ARMOR
1268 if( !sqlite3SafetyCheckOk(db) ) return SQLITE_MISUSE_BKPT;
1269#endif
danb061d052011-04-25 18:49:57 +00001270 assert( OE_Rollback==1 && OE_Abort==2 && OE_Fail==3 );
1271 assert( OE_Ignore==4 && OE_Replace==5 );
1272 assert( db->vtabOnConflict>=1 && db->vtabOnConflict<=5 );
drhef45bb72011-05-05 15:39:50 +00001273 return (int)aMap[db->vtabOnConflict-1];
danb061d052011-04-25 18:49:57 +00001274}
1275
drhef45bb72011-05-05 15:39:50 +00001276/*
1277** Call from within the xCreate() or xConnect() methods to provide
1278** the SQLite core with additional information about the behavior
1279** of the virtual table being implemented.
1280*/
danb061d052011-04-25 18:49:57 +00001281int sqlite3_vtab_config(sqlite3 *db, int op, ...){
1282 va_list ap;
1283 int rc = SQLITE_OK;
drh2928a152020-01-06 15:25:41 +00001284 VtabCtx *p;
danb061d052011-04-25 18:49:57 +00001285
drh9ca95732014-10-24 00:35:58 +00001286#ifdef SQLITE_ENABLE_API_ARMOR
1287 if( !sqlite3SafetyCheckOk(db) ) return SQLITE_MISUSE_BKPT;
1288#endif
danb061d052011-04-25 18:49:57 +00001289 sqlite3_mutex_enter(db->mutex);
drh2928a152020-01-06 15:25:41 +00001290 p = db->pVtabCtx;
1291 if( !p ){
1292 rc = SQLITE_MISUSE_BKPT;
1293 }else{
1294 assert( p->pTab==0 || IsVirtual(p->pTab) );
1295 va_start(ap, op);
1296 switch( op ){
1297 case SQLITE_VTAB_CONSTRAINT_SUPPORT: {
danb061d052011-04-25 18:49:57 +00001298 p->pVTable->bConstraint = (u8)va_arg(ap, int);
drh2928a152020-01-06 15:25:41 +00001299 break;
danb061d052011-04-25 18:49:57 +00001300 }
drh2928a152020-01-06 15:25:41 +00001301 case SQLITE_VTAB_INNOCUOUS: {
1302 p->pVTable->eVtabRisk = SQLITE_VTABRISK_Low;
1303 break;
1304 }
1305 case SQLITE_VTAB_DIRECTONLY: {
1306 p->pVTable->eVtabRisk = SQLITE_VTABRISK_High;
1307 break;
1308 }
1309 default: {
1310 rc = SQLITE_MISUSE_BKPT;
1311 break;
1312 }
danb061d052011-04-25 18:49:57 +00001313 }
drh2928a152020-01-06 15:25:41 +00001314 va_end(ap);
danb061d052011-04-25 18:49:57 +00001315 }
danb061d052011-04-25 18:49:57 +00001316
drh13f40da2014-08-22 18:00:11 +00001317 if( rc!=SQLITE_OK ) sqlite3Error(db, rc);
danb061d052011-04-25 18:49:57 +00001318 sqlite3_mutex_leave(db->mutex);
1319 return rc;
1320}
1321
drhb9bb7c12006-06-11 23:41:55 +00001322#endif /* SQLITE_OMIT_VIRTUALTABLE */