xref: /sqlite-3.40.0/src/test8.c (revision ba39ca40)
1b9bb7c18Sdrh /*
2b9bb7c18Sdrh ** 2006 June 10
3b9bb7c18Sdrh **
4b9bb7c18Sdrh ** The author disclaims copyright to this source code.  In place of
5b9bb7c18Sdrh ** a legal notice, here is a blessing:
6b9bb7c18Sdrh **
7b9bb7c18Sdrh **    May you do good and not evil.
8b9bb7c18Sdrh **    May you find forgiveness for yourself and forgive others.
9b9bb7c18Sdrh **    May you share freely, never taking more than you give.
10b9bb7c18Sdrh **
11b9bb7c18Sdrh *************************************************************************
12b9bb7c18Sdrh ** Code for testing the virtual table interfaces.  This code
13b9bb7c18Sdrh ** is not included in the SQLite library.  It is used for automated
14b9bb7c18Sdrh ** testing of the SQLite library.
15b9bb7c18Sdrh */
16b9bb7c18Sdrh #include "sqliteInt.h"
1752b1dbb5Smistachkin #if defined(INCLUDE_SQLITE_TCL_H)
1852b1dbb5Smistachkin #  include "sqlite_tcl.h"
1952b1dbb5Smistachkin #else
20b9bb7c18Sdrh #  include "tcl.h"
2152b1dbb5Smistachkin #endif
22b9bb7c18Sdrh #include <stdlib.h>
23b9bb7c18Sdrh #include <string.h>
24b9bb7c18Sdrh 
25cc013f89Sdanielk1977 #ifndef SQLITE_OMIT_VIRTUALTABLE
26cc013f89Sdanielk1977 
27b7a7b9a3Sdanielk1977 typedef struct echo_vtab echo_vtab;
28b7a7b9a3Sdanielk1977 typedef struct echo_cursor echo_cursor;
29b7a7b9a3Sdanielk1977 
305fac9f86Sdanielk1977 /*
31780b1d94Sdanielk1977 ** The test module defined in this file uses four global Tcl variables to
32c69cdfd4Sdanielk1977 ** commicate with test-scripts:
33c69cdfd4Sdanielk1977 **
34c69cdfd4Sdanielk1977 **     $::echo_module
35c69cdfd4Sdanielk1977 **     $::echo_module_sync_fail
365017dc38Sdanielk1977 **     $::echo_module_begin_fail
37780b1d94Sdanielk1977 **     $::echo_module_cost
38cc013f89Sdanielk1977 **
39cc013f89Sdanielk1977 ** The variable ::echo_module is a list. Each time one of the following
40cc013f89Sdanielk1977 ** methods is called, one or more elements are appended to the list.
41cc013f89Sdanielk1977 ** This is used for automated testing of virtual table modules.
42cc013f89Sdanielk1977 **
43cc013f89Sdanielk1977 ** The ::echo_module_sync_fail variable is set by test scripts and read
44cc013f89Sdanielk1977 ** by code in this file. If it is set to the name of a real table in the
45cc013f89Sdanielk1977 ** the database, then all xSync operations on echo virtual tables that
46cc013f89Sdanielk1977 ** use the named table as a backing store will fail.
47c69cdfd4Sdanielk1977 */
48c69cdfd4Sdanielk1977 
49c69cdfd4Sdanielk1977 /*
503e3a84d3Sdanielk1977 ** Errors can be provoked within the following echo virtual table methods:
513e3a84d3Sdanielk1977 **
523e3a84d3Sdanielk1977 **   xBestIndex   xOpen     xFilter   xNext
533e3a84d3Sdanielk1977 **   xColumn      xRowid    xUpdate   xSync
54987a00e8Sdanielk1977 **   xBegin       xRename
553e3a84d3Sdanielk1977 **
563e3a84d3Sdanielk1977 ** This is done by setting the global tcl variable:
573e3a84d3Sdanielk1977 **
583e3a84d3Sdanielk1977 **   echo_module_fail($method,$tbl)
593e3a84d3Sdanielk1977 **
603e3a84d3Sdanielk1977 ** where $method is set to the name of the virtual table method to fail
613e3a84d3Sdanielk1977 ** (i.e. "xBestIndex") and $tbl is the name of the table being echoed (not
623e3a84d3Sdanielk1977 ** the name of the virtual table, the name of the underlying real table).
633e3a84d3Sdanielk1977 */
643e3a84d3Sdanielk1977 
653e3a84d3Sdanielk1977 /*
66d6e8dd00Sdanielk1977 ** An echo virtual-table object.
675fac9f86Sdanielk1977 **
68d6e8dd00Sdanielk1977 ** echo.vtab.aIndex is an array of booleans. The nth entry is true if
69d6e8dd00Sdanielk1977 ** the nth column of the real table is the left-most column of an index
70d6e8dd00Sdanielk1977 ** (implicit or otherwise). In other words, if SQLite can optimize
71d6e8dd00Sdanielk1977 ** a query like "SELECT * FROM real_table WHERE col = ?".
72d6e8dd00Sdanielk1977 **
73c69cdfd4Sdanielk1977 ** Member variable aCol[] contains copies of the column names of the real
74c69cdfd4Sdanielk1977 ** table.
755fac9f86Sdanielk1977 */
76b7a7b9a3Sdanielk1977 struct echo_vtab {
77b7a7b9a3Sdanielk1977   sqlite3_vtab base;
78cc013f89Sdanielk1977   Tcl_Interp *interp;     /* Tcl interpreter containing debug variables */
79cc013f89Sdanielk1977   sqlite3 *db;            /* Database connection */
805fac9f86Sdanielk1977 
81182c4ba9Sdanielk1977   int isPattern;
82cd3dd9d3Sdrh   int inTransaction;      /* True if within a transaction */
83182c4ba9Sdanielk1977   char *zThis;            /* Name of the echo table */
84a4e76367Sdanielk1977   char *zTableName;       /* Name of the real table */
85a298e90dSdanielk1977   char *zLogName;         /* Name of the log table */
86a4e76367Sdanielk1977   int nCol;               /* Number of columns in the real table */
87a4e76367Sdanielk1977   int *aIndex;            /* Array of size nCol. True if column has an index */
88a4e76367Sdanielk1977   char **aCol;            /* Array of size nCol. Column names */
89b7a7b9a3Sdanielk1977 };
90b7a7b9a3Sdanielk1977 
91b7a7b9a3Sdanielk1977 /* An echo cursor object */
92b7a7b9a3Sdanielk1977 struct echo_cursor {
93b7a7b9a3Sdanielk1977   sqlite3_vtab_cursor base;
94b7a7b9a3Sdanielk1977   sqlite3_stmt *pStmt;
95b7a7b9a3Sdanielk1977 };
96b7a7b9a3Sdanielk1977 
simulateVtabError(echo_vtab * p,const char * zMethod)973e3a84d3Sdanielk1977 static int simulateVtabError(echo_vtab *p, const char *zMethod){
983e3a84d3Sdanielk1977   const char *zErr;
993e3a84d3Sdanielk1977   char zVarname[128];
1003e3a84d3Sdanielk1977   zVarname[127] = '\0';
101f5eccb69Sshane   sqlite3_snprintf(127, zVarname, "echo_module_fail(%s,%s)", zMethod, p->zTableName);
1023e3a84d3Sdanielk1977   zErr = Tcl_GetVar(p->interp, zVarname, TCL_GLOBAL_ONLY);
1033e3a84d3Sdanielk1977   if( zErr ){
1043e3a84d3Sdanielk1977     p->base.zErrMsg = sqlite3_mprintf("echo-vtab-error: %s", zErr);
1053e3a84d3Sdanielk1977   }
1063e3a84d3Sdanielk1977   return (zErr!=0);
1073e3a84d3Sdanielk1977 }
1083e3a84d3Sdanielk1977 
109cc013f89Sdanielk1977 /*
110182c4ba9Sdanielk1977 ** Convert an SQL-style quoted string into a normal string by removing
111182c4ba9Sdanielk1977 ** the quote characters.  The conversion is done in-place.  If the
112182c4ba9Sdanielk1977 ** input does not begin with a quote character, then this routine
113182c4ba9Sdanielk1977 ** is a no-op.
114182c4ba9Sdanielk1977 **
115182c4ba9Sdanielk1977 ** Examples:
116182c4ba9Sdanielk1977 **
117182c4ba9Sdanielk1977 **     "abc"   becomes   abc
118182c4ba9Sdanielk1977 **     'xyz'   becomes   xyz
119182c4ba9Sdanielk1977 **     [pqr]   becomes   pqr
120182c4ba9Sdanielk1977 **     `mno`   becomes   mno
121182c4ba9Sdanielk1977 */
dequoteString(char * z)122182c4ba9Sdanielk1977 static void dequoteString(char *z){
123182c4ba9Sdanielk1977   int quote;
124182c4ba9Sdanielk1977   int i, j;
125182c4ba9Sdanielk1977   if( z==0 ) return;
126182c4ba9Sdanielk1977   quote = z[0];
127182c4ba9Sdanielk1977   switch( quote ){
128182c4ba9Sdanielk1977     case '\'':  break;
129182c4ba9Sdanielk1977     case '"':   break;
130182c4ba9Sdanielk1977     case '`':   break;                /* For MySQL compatibility */
131182c4ba9Sdanielk1977     case '[':   quote = ']';  break;  /* For MS SqlServer compatibility */
132182c4ba9Sdanielk1977     default:    return;
133182c4ba9Sdanielk1977   }
134182c4ba9Sdanielk1977   for(i=1, j=0; z[i]; i++){
135182c4ba9Sdanielk1977     if( z[i]==quote ){
136182c4ba9Sdanielk1977       if( z[i+1]==quote ){
137182c4ba9Sdanielk1977         z[j++] = quote;
138182c4ba9Sdanielk1977         i++;
139182c4ba9Sdanielk1977       }else{
140182c4ba9Sdanielk1977         z[j++] = 0;
141182c4ba9Sdanielk1977         break;
142182c4ba9Sdanielk1977       }
143182c4ba9Sdanielk1977     }else{
144182c4ba9Sdanielk1977       z[j++] = z[i];
145182c4ba9Sdanielk1977     }
146182c4ba9Sdanielk1977   }
147182c4ba9Sdanielk1977 }
148182c4ba9Sdanielk1977 
149182c4ba9Sdanielk1977 /*
150cc013f89Sdanielk1977 ** Retrieve the column names for the table named zTab via database
151cc013f89Sdanielk1977 ** connection db. SQLITE_OK is returned on success, or an sqlite error
152cc013f89Sdanielk1977 ** code otherwise.
153cc013f89Sdanielk1977 **
154cc013f89Sdanielk1977 ** If successful, the number of columns is written to *pnCol. *paCol is
15517435752Sdrh ** set to point at sqlite3_malloc()'d space containing the array of
15617435752Sdrh ** nCol column names. The caller is responsible for calling sqlite3_free
157cc013f89Sdanielk1977 ** on *paCol.
158cc013f89Sdanielk1977 */
getColumnNames(sqlite3 * db,const char * zTab,char *** paCol,int * pnCol)1595fac9f86Sdanielk1977 static int getColumnNames(
1605fac9f86Sdanielk1977   sqlite3 *db,
1615fac9f86Sdanielk1977   const char *zTab,
1625fac9f86Sdanielk1977   char ***paCol,
1635fac9f86Sdanielk1977   int *pnCol
1645fac9f86Sdanielk1977 ){
1655fac9f86Sdanielk1977   char **aCol = 0;
166cc013f89Sdanielk1977   char *zSql;
1675fac9f86Sdanielk1977   sqlite3_stmt *pStmt = 0;
1685fac9f86Sdanielk1977   int rc = SQLITE_OK;
169be718897Sdanielk1977   int nCol = 0;
1705fac9f86Sdanielk1977 
171cc013f89Sdanielk1977   /* Prepare the statement "SELECT * FROM <tbl>". The column names
172cc013f89Sdanielk1977   ** of the result set of the compiled SELECT will be the same as
173cc013f89Sdanielk1977   ** the column names of table <tbl>.
174cc013f89Sdanielk1977   */
17517435752Sdrh   zSql = sqlite3_mprintf("SELECT * FROM %Q", zTab);
176cc013f89Sdanielk1977   if( !zSql ){
177cc013f89Sdanielk1977     rc = SQLITE_NOMEM;
178cc013f89Sdanielk1977     goto out;
179cc013f89Sdanielk1977   }
180cc013f89Sdanielk1977   rc = sqlite3_prepare(db, zSql, -1, &pStmt, 0);
18117435752Sdrh   sqlite3_free(zSql);
182cc013f89Sdanielk1977 
1835fac9f86Sdanielk1977   if( rc==SQLITE_OK ){
1845fac9f86Sdanielk1977     int ii;
185cc013f89Sdanielk1977     int nBytes;
186cc013f89Sdanielk1977     char *zSpace;
1875fac9f86Sdanielk1977     nCol = sqlite3_column_count(pStmt);
188cc013f89Sdanielk1977 
189cc013f89Sdanielk1977     /* Figure out how much space to allocate for the array of column names
190cc013f89Sdanielk1977     ** (including space for the strings themselves). Then allocate it.
191cc013f89Sdanielk1977     */
192cc013f89Sdanielk1977     nBytes = sizeof(char *) * nCol;
193cc013f89Sdanielk1977     for(ii=0; ii<nCol; ii++){
194a7a8e14bSdanielk1977       const char *zName = sqlite3_column_name(pStmt, ii);
195a7a8e14bSdanielk1977       if( !zName ){
196a7a8e14bSdanielk1977         rc = SQLITE_NOMEM;
197a7a8e14bSdanielk1977         goto out;
198a7a8e14bSdanielk1977       }
19983cc1392Sdrh       nBytes += (int)strlen(zName)+1;
200cc013f89Sdanielk1977     }
20131dad9daSdanielk1977     aCol = (char **)sqlite3MallocZero(nBytes);
2025fac9f86Sdanielk1977     if( !aCol ){
2035fac9f86Sdanielk1977       rc = SQLITE_NOMEM;
204cc013f89Sdanielk1977       goto out;
2055fac9f86Sdanielk1977     }
206cc013f89Sdanielk1977 
207cc013f89Sdanielk1977     /* Copy the column names into the allocated space and set up the
208cc013f89Sdanielk1977     ** pointers in the aCol[] array.
209cc013f89Sdanielk1977     */
210cc013f89Sdanielk1977     zSpace = (char *)(&aCol[nCol]);
2115fac9f86Sdanielk1977     for(ii=0; ii<nCol; ii++){
212cc013f89Sdanielk1977       aCol[ii] = zSpace;
21365545b59Sdrh       sqlite3_snprintf(nBytes, zSpace, "%s", sqlite3_column_name(pStmt,ii));
21465545b59Sdrh       zSpace += (int)strlen(zSpace) + 1;
2155fac9f86Sdanielk1977     }
216cc013f89Sdanielk1977     assert( (zSpace-nBytes)==(char *)aCol );
2175fac9f86Sdanielk1977   }
2185fac9f86Sdanielk1977 
2195fac9f86Sdanielk1977   *paCol = aCol;
2205fac9f86Sdanielk1977   *pnCol = nCol;
2215fac9f86Sdanielk1977 
222cc013f89Sdanielk1977 out:
2235fac9f86Sdanielk1977   sqlite3_finalize(pStmt);
2245fac9f86Sdanielk1977   return rc;
2255fac9f86Sdanielk1977 }
2265fac9f86Sdanielk1977 
227cc013f89Sdanielk1977 /*
228cc013f89Sdanielk1977 ** Parameter zTab is the name of a table in database db with nCol
229cc013f89Sdanielk1977 ** columns. This function allocates an array of integers nCol in
230cc013f89Sdanielk1977 ** size and populates it according to any implicit or explicit
231cc013f89Sdanielk1977 ** indices on table zTab.
232cc013f89Sdanielk1977 **
233cc013f89Sdanielk1977 ** If successful, SQLITE_OK is returned and *paIndex set to point
234cc013f89Sdanielk1977 ** at the allocated array. Otherwise, an error code is returned.
235cc013f89Sdanielk1977 **
236cc013f89Sdanielk1977 ** See comments associated with the member variable aIndex above
237cc013f89Sdanielk1977 ** "struct echo_vtab" for details of the contents of the array.
238cc013f89Sdanielk1977 */
getIndexArray(sqlite3 * db,const char * zTab,int nCol,int ** paIndex)239cc013f89Sdanielk1977 static int getIndexArray(
240cc013f89Sdanielk1977   sqlite3 *db,             /* Database connection */
241cc013f89Sdanielk1977   const char *zTab,        /* Name of table in database db */
242cc013f89Sdanielk1977   int nCol,
243cc013f89Sdanielk1977   int **paIndex
244cc013f89Sdanielk1977 ){
2455fac9f86Sdanielk1977   sqlite3_stmt *pStmt = 0;
2465fac9f86Sdanielk1977   int *aIndex = 0;
2475fac9f86Sdanielk1977   int rc;
248cc013f89Sdanielk1977   char *zSql;
2495fac9f86Sdanielk1977 
250cc013f89Sdanielk1977   /* Allocate space for the index array */
25131dad9daSdanielk1977   aIndex = (int *)sqlite3MallocZero(sizeof(int) * nCol);
2525fac9f86Sdanielk1977   if( !aIndex ){
2535fac9f86Sdanielk1977     rc = SQLITE_NOMEM;
2545fac9f86Sdanielk1977     goto get_index_array_out;
2555fac9f86Sdanielk1977   }
2565fac9f86Sdanielk1977 
257cc013f89Sdanielk1977   /* Compile an sqlite pragma to loop through all indices on table zTab */
258bc6160b0Sdrh   zSql = sqlite3_mprintf("PRAGMA index_list(%s)", zTab);
259cc013f89Sdanielk1977   if( !zSql ){
260cc013f89Sdanielk1977     rc = SQLITE_NOMEM;
261cc013f89Sdanielk1977     goto get_index_array_out;
262cc013f89Sdanielk1977   }
263cc013f89Sdanielk1977   rc = sqlite3_prepare(db, zSql, -1, &pStmt, 0);
26417435752Sdrh   sqlite3_free(zSql);
2655fac9f86Sdanielk1977 
266cc013f89Sdanielk1977   /* For each index, figure out the left-most column and set the
267cc013f89Sdanielk1977   ** corresponding entry in aIndex[] to 1.
268cc013f89Sdanielk1977   */
2695fac9f86Sdanielk1977   while( pStmt && sqlite3_step(pStmt)==SQLITE_ROW ){
27065fd59f7Sdanielk1977     const char *zIdx = (const char *)sqlite3_column_text(pStmt, 1);
2715fac9f86Sdanielk1977     sqlite3_stmt *pStmt2 = 0;
2726b169bd8Sdrh     if( zIdx==0 ) continue;
273bc6160b0Sdrh     zSql = sqlite3_mprintf("PRAGMA index_info(%s)", zIdx);
274cc013f89Sdanielk1977     if( !zSql ){
275cc013f89Sdanielk1977       rc = SQLITE_NOMEM;
276cc013f89Sdanielk1977       goto get_index_array_out;
277cc013f89Sdanielk1977     }
278cc013f89Sdanielk1977     rc = sqlite3_prepare(db, zSql, -1, &pStmt2, 0);
27917435752Sdrh     sqlite3_free(zSql);
2805fac9f86Sdanielk1977     if( pStmt2 && sqlite3_step(pStmt2)==SQLITE_ROW ){
2815fac9f86Sdanielk1977       int cid = sqlite3_column_int(pStmt2, 1);
2825fac9f86Sdanielk1977       assert( cid>=0 && cid<nCol );
2835fac9f86Sdanielk1977       aIndex[cid] = 1;
2845fac9f86Sdanielk1977     }
285be718897Sdanielk1977     if( pStmt2 ){
2865fac9f86Sdanielk1977       rc = sqlite3_finalize(pStmt2);
287be718897Sdanielk1977     }
2885fac9f86Sdanielk1977     if( rc!=SQLITE_OK ){
2895fac9f86Sdanielk1977       goto get_index_array_out;
2905fac9f86Sdanielk1977     }
2915fac9f86Sdanielk1977   }
2925fac9f86Sdanielk1977 
2935fac9f86Sdanielk1977 
2945fac9f86Sdanielk1977 get_index_array_out:
295cc013f89Sdanielk1977   if( pStmt ){
296cc013f89Sdanielk1977     int rc2 = sqlite3_finalize(pStmt);
297cc013f89Sdanielk1977     if( rc==SQLITE_OK ){
298cc013f89Sdanielk1977       rc = rc2;
299cc013f89Sdanielk1977     }
300cc013f89Sdanielk1977   }
3015fac9f86Sdanielk1977   if( rc!=SQLITE_OK ){
30217435752Sdrh     sqlite3_free(aIndex);
3035fac9f86Sdanielk1977     aIndex = 0;
3045fac9f86Sdanielk1977   }
3055fac9f86Sdanielk1977   *paIndex = aIndex;
3065fac9f86Sdanielk1977   return rc;
3075fac9f86Sdanielk1977 }
3085fac9f86Sdanielk1977 
30978efaba1Sdanielk1977 /*
31078efaba1Sdanielk1977 ** Global Tcl variable $echo_module is a list. This routine appends
31178efaba1Sdanielk1977 ** the string element zArg to that list in interpreter interp.
31278efaba1Sdanielk1977 */
appendToEchoModule(Tcl_Interp * interp,const char * zArg)313a967e886Sdrh static void appendToEchoModule(Tcl_Interp *interp, const char *zArg){
31478efaba1Sdanielk1977   int flags = (TCL_APPEND_VALUE | TCL_LIST_ELEMENT | TCL_GLOBAL_ONLY);
3155fac9f86Sdanielk1977   Tcl_SetVar(interp, "echo_module", (zArg?zArg:""), flags);
31678efaba1Sdanielk1977 }
31778efaba1Sdanielk1977 
3187e6ebfb2Sdanielk1977 /*
3197e6ebfb2Sdanielk1977 ** This function is called from within the echo-modules xCreate and
3207e6ebfb2Sdanielk1977 ** xConnect methods. The argc and argv arguments are copies of those
3217e6ebfb2Sdanielk1977 ** passed to the calling method. This function is responsible for
3227e6ebfb2Sdanielk1977 ** calling sqlite3_declare_vtab() to declare the schema of the virtual
3237e6ebfb2Sdanielk1977 ** table being created or connected.
3247e6ebfb2Sdanielk1977 **
3257e6ebfb2Sdanielk1977 ** If the constructor was passed just one argument, i.e.:
3267e6ebfb2Sdanielk1977 **
3277e6ebfb2Sdanielk1977 **   CREATE TABLE t1 AS echo(t2);
3287e6ebfb2Sdanielk1977 **
3297e6ebfb2Sdanielk1977 ** Then t2 is assumed to be the name of a *real* database table. The
3307e6ebfb2Sdanielk1977 ** schema of the virtual table is declared by passing a copy of the
3317e6ebfb2Sdanielk1977 ** CREATE TABLE statement for the real table to sqlite3_declare_vtab().
3327e6ebfb2Sdanielk1977 ** Hence, the virtual table should have exactly the same column names and
3337e6ebfb2Sdanielk1977 ** types as the real table.
3347e6ebfb2Sdanielk1977 */
echoDeclareVtab(echo_vtab * pVtab,sqlite3 * db)335b7a7b9a3Sdanielk1977 static int echoDeclareVtab(
336b7a7b9a3Sdanielk1977   echo_vtab *pVtab,
337182c4ba9Sdanielk1977   sqlite3 *db
338b7a7b9a3Sdanielk1977 ){
3397e6ebfb2Sdanielk1977   int rc = SQLITE_OK;
3407e6ebfb2Sdanielk1977 
341182c4ba9Sdanielk1977   if( pVtab->zTableName ){
3427e6ebfb2Sdanielk1977     sqlite3_stmt *pStmt = 0;
343222a757dSdanielk1977     rc = sqlite3_prepare(db,
3441e32bed3Sdrh         "SELECT sql FROM sqlite_schema WHERE type = 'table' AND name = ?",
3457e6ebfb2Sdanielk1977         -1, &pStmt, 0);
346222a757dSdanielk1977     if( rc==SQLITE_OK ){
347182c4ba9Sdanielk1977       sqlite3_bind_text(pStmt, 1, pVtab->zTableName, -1, 0);
3487e6ebfb2Sdanielk1977       if( sqlite3_step(pStmt)==SQLITE_ROW ){
3497fa5dd1aSdanielk1977         int rc2;
35065fd59f7Sdanielk1977         const char *zCreateTable = (const char *)sqlite3_column_text(pStmt, 0);
3517fa5dd1aSdanielk1977         rc = sqlite3_declare_vtab(db, zCreateTable);
3527fa5dd1aSdanielk1977         rc2 = sqlite3_finalize(pStmt);
3537fa5dd1aSdanielk1977         if( rc==SQLITE_OK ){
3547fa5dd1aSdanielk1977           rc = rc2;
3557fa5dd1aSdanielk1977         }
3567e6ebfb2Sdanielk1977       } else {
357be718897Sdanielk1977         rc = sqlite3_finalize(pStmt);
358be718897Sdanielk1977         if( rc==SQLITE_OK ){
3597e6ebfb2Sdanielk1977           rc = SQLITE_ERROR;
3607e6ebfb2Sdanielk1977         }
361be718897Sdanielk1977       }
3625fac9f86Sdanielk1977       if( rc==SQLITE_OK ){
363182c4ba9Sdanielk1977         rc = getColumnNames(db, pVtab->zTableName, &pVtab->aCol, &pVtab->nCol);
3645fac9f86Sdanielk1977       }
3655fac9f86Sdanielk1977       if( rc==SQLITE_OK ){
366182c4ba9Sdanielk1977         rc = getIndexArray(db, pVtab->zTableName, pVtab->nCol, &pVtab->aIndex);
3675fac9f86Sdanielk1977       }
3687e6ebfb2Sdanielk1977     }
369222a757dSdanielk1977   }
3707e6ebfb2Sdanielk1977 
3717e6ebfb2Sdanielk1977   return rc;
3727e6ebfb2Sdanielk1977 }
3737e6ebfb2Sdanielk1977 
374cc013f89Sdanielk1977 /*
375cc013f89Sdanielk1977 ** This function frees all runtime structures associated with the virtual
376cc013f89Sdanielk1977 ** table pVtab.
377cc013f89Sdanielk1977 */
echoDestructor(sqlite3_vtab * pVtab)378a4e76367Sdanielk1977 static int echoDestructor(sqlite3_vtab *pVtab){
379a4e76367Sdanielk1977   echo_vtab *p = (echo_vtab*)pVtab;
38017435752Sdrh   sqlite3_free(p->aIndex);
38117435752Sdrh   sqlite3_free(p->aCol);
38217435752Sdrh   sqlite3_free(p->zThis);
38317435752Sdrh   sqlite3_free(p->zTableName);
38417435752Sdrh   sqlite3_free(p->zLogName);
38517435752Sdrh   sqlite3_free(p);
386a4e76367Sdanielk1977   return 0;
387a4e76367Sdanielk1977 }
388a4e76367Sdanielk1977 
389860b6cd2Sdanielk1977 typedef struct EchoModule EchoModule;
390860b6cd2Sdanielk1977 struct EchoModule {
391860b6cd2Sdanielk1977   Tcl_Interp *interp;
392*ba39ca40Sdrh   sqlite3 *db;
393860b6cd2Sdanielk1977 };
394860b6cd2Sdanielk1977 
395cc013f89Sdanielk1977 /*
396cc013f89Sdanielk1977 ** This function is called to do the work of the xConnect() method -
397cc013f89Sdanielk1977 ** to allocate the required in-memory structures for a newly connected
398cc013f89Sdanielk1977 ** virtual table.
399cc013f89Sdanielk1977 */
echoConstructor(sqlite3 * db,void * pAux,int argc,const char * const * argv,sqlite3_vtab ** ppVtab,char ** pzErr)400b7a7b9a3Sdanielk1977 static int echoConstructor(
401b7a7b9a3Sdanielk1977   sqlite3 *db,
4029da9d471Sdanielk1977   void *pAux,
403e4102960Sdrh   int argc, const char *const*argv,
4044ca8aac2Sdrh   sqlite3_vtab **ppVtab,
4054ca8aac2Sdrh   char **pzErr
406b7a7b9a3Sdanielk1977 ){
407a1644fd8Sdanielk1977   int rc;
408b7a7b9a3Sdanielk1977   int i;
409b7a7b9a3Sdanielk1977   echo_vtab *pVtab;
410b7a7b9a3Sdanielk1977 
411cc013f89Sdanielk1977   /* Allocate the sqlite3_vtab/echo_vtab structure itself */
41231dad9daSdanielk1977   pVtab = sqlite3MallocZero( sizeof(*pVtab) );
413be718897Sdanielk1977   if( !pVtab ){
414be718897Sdanielk1977     return SQLITE_NOMEM;
415be718897Sdanielk1977   }
416860b6cd2Sdanielk1977   pVtab->interp = ((EchoModule *)pAux)->interp;
417b7a7b9a3Sdanielk1977   pVtab->db = db;
418cc013f89Sdanielk1977 
419182c4ba9Sdanielk1977   /* Allocate echo_vtab.zThis */
420bc6160b0Sdrh   pVtab->zThis = sqlite3_mprintf("%s", argv[2]);
421182c4ba9Sdanielk1977   if( !pVtab->zThis ){
422182c4ba9Sdanielk1977     echoDestructor((sqlite3_vtab *)pVtab);
423182c4ba9Sdanielk1977     return SQLITE_NOMEM;
424182c4ba9Sdanielk1977   }
425182c4ba9Sdanielk1977 
426cc013f89Sdanielk1977   /* Allocate echo_vtab.zTableName */
427182c4ba9Sdanielk1977   if( argc>3 ){
428bc6160b0Sdrh     pVtab->zTableName = sqlite3_mprintf("%s", argv[3]);
429182c4ba9Sdanielk1977     dequoteString(pVtab->zTableName);
430182c4ba9Sdanielk1977     if( pVtab->zTableName && pVtab->zTableName[0]=='*' ){
431bc6160b0Sdrh       char *z = sqlite3_mprintf("%s%s", argv[2], &(pVtab->zTableName[1]));
43217435752Sdrh       sqlite3_free(pVtab->zTableName);
433182c4ba9Sdanielk1977       pVtab->zTableName = z;
434182c4ba9Sdanielk1977       pVtab->isPattern = 1;
435182c4ba9Sdanielk1977     }
436be718897Sdanielk1977     if( !pVtab->zTableName ){
437b7a2f2e8Sdanielk1977       echoDestructor((sqlite3_vtab *)pVtab);
438be718897Sdanielk1977       return SQLITE_NOMEM;
439be718897Sdanielk1977     }
440182c4ba9Sdanielk1977   }
441be718897Sdanielk1977 
442cc013f89Sdanielk1977   /* Log the arguments to this function to Tcl var ::echo_module */
443b7a7b9a3Sdanielk1977   for(i=0; i<argc; i++){
444b7a7b9a3Sdanielk1977     appendToEchoModule(pVtab->interp, argv[i]);
445b7a7b9a3Sdanielk1977   }
446b7a7b9a3Sdanielk1977 
447cc013f89Sdanielk1977   /* Invoke sqlite3_declare_vtab and set up other members of the echo_vtab
448cc013f89Sdanielk1977   ** structure. If an error occurs, delete the sqlite3_vtab structure and
449cc013f89Sdanielk1977   ** return an error code.
450cc013f89Sdanielk1977   */
451a1644fd8Sdanielk1977   rc = echoDeclareVtab(pVtab, db);
452a1644fd8Sdanielk1977   if( rc!=SQLITE_OK ){
453a4e76367Sdanielk1977     echoDestructor((sqlite3_vtab *)pVtab);
454a1644fd8Sdanielk1977     return rc;
455a4e76367Sdanielk1977   }
456a4e76367Sdanielk1977 
457cc013f89Sdanielk1977   /* Success. Set *ppVtab and return */
458a4e76367Sdanielk1977   *ppVtab = &pVtab->base;
459a4e76367Sdanielk1977   return SQLITE_OK;
460b7a7b9a3Sdanielk1977 }
461a967e886Sdrh 
462cc013f89Sdanielk1977 /*
463cc013f89Sdanielk1977 ** Echo virtual table module xCreate method.
464cc013f89Sdanielk1977 */
echoCreate(sqlite3 * db,void * pAux,int argc,const char * const * argv,sqlite3_vtab ** ppVtab,char ** pzErr)465b9bb7c18Sdrh static int echoCreate(
466b9bb7c18Sdrh   sqlite3 *db,
4679da9d471Sdanielk1977   void *pAux,
468e4102960Sdrh   int argc, const char *const*argv,
4694ca8aac2Sdrh   sqlite3_vtab **ppVtab,
4704ca8aac2Sdrh   char **pzErr
471b9bb7c18Sdrh ){
472a298e90dSdanielk1977   int rc = SQLITE_OK;
473860b6cd2Sdanielk1977   appendToEchoModule(((EchoModule *)pAux)->interp, "xCreate");
4744ca8aac2Sdrh   rc = echoConstructor(db, pAux, argc, argv, ppVtab, pzErr);
475cc013f89Sdanielk1977 
476cc013f89Sdanielk1977   /* If there were two arguments passed to the module at the SQL level
477cc013f89Sdanielk1977   ** (i.e. "CREATE VIRTUAL TABLE tbl USING echo(arg1, arg2)"), then
478cc013f89Sdanielk1977   ** the second argument is used as a table name. Attempt to create
479cc013f89Sdanielk1977   ** such a table with a single column, "logmsg". This table will
480cc013f89Sdanielk1977   ** be used to log calls to the xUpdate method. It will be deleted
481cc013f89Sdanielk1977   ** when the virtual table is DROPed.
482cc013f89Sdanielk1977   **
483cc013f89Sdanielk1977   ** Note: The main point of this is to test that we can drop tables
484cc013f89Sdanielk1977   ** from within an xDestroy method call.
485cc013f89Sdanielk1977   */
486a298e90dSdanielk1977   if( rc==SQLITE_OK && argc==5 ){
487a298e90dSdanielk1977     char *zSql;
488a298e90dSdanielk1977     echo_vtab *pVtab = *(echo_vtab **)ppVtab;
489bc6160b0Sdrh     pVtab->zLogName = sqlite3_mprintf("%s", argv[4]);
490bc6160b0Sdrh     zSql = sqlite3_mprintf("CREATE TABLE %Q(logmsg)", pVtab->zLogName);
491a298e90dSdanielk1977     rc = sqlite3_exec(db, zSql, 0, 0, 0);
49217435752Sdrh     sqlite3_free(zSql);
493cd2543b6Sdanielk1977     if( rc!=SQLITE_OK ){
494b975598eSdrh       *pzErr = sqlite3_mprintf("%s", sqlite3_errmsg(db));
495cd2543b6Sdanielk1977     }
496cd2543b6Sdanielk1977   }
497cd2543b6Sdanielk1977 
498cd2543b6Sdanielk1977   if( *ppVtab && rc!=SQLITE_OK ){
499cd2543b6Sdanielk1977     echoDestructor(*ppVtab);
500cd2543b6Sdanielk1977     *ppVtab = 0;
501a298e90dSdanielk1977   }
502cc013f89Sdanielk1977 
503cd3dd9d3Sdrh   if( rc==SQLITE_OK ){
504cd3dd9d3Sdrh     (*(echo_vtab**)ppVtab)->inTransaction = 1;
505cd3dd9d3Sdrh   }
506cd3dd9d3Sdrh 
507a298e90dSdanielk1977   return rc;
508b9bb7c18Sdrh }
509cc013f89Sdanielk1977 
510cc013f89Sdanielk1977 /*
511cc013f89Sdanielk1977 ** Echo virtual table module xConnect method.
512cc013f89Sdanielk1977 */
echoConnect(sqlite3 * db,void * pAux,int argc,const char * const * argv,sqlite3_vtab ** ppVtab,char ** pzErr)513b9bb7c18Sdrh static int echoConnect(
514b9bb7c18Sdrh   sqlite3 *db,
5159da9d471Sdanielk1977   void *pAux,
516e4102960Sdrh   int argc, const char *const*argv,
5174ca8aac2Sdrh   sqlite3_vtab **ppVtab,
5184ca8aac2Sdrh   char **pzErr
519b9bb7c18Sdrh ){
520860b6cd2Sdanielk1977   appendToEchoModule(((EchoModule *)pAux)->interp, "xConnect");
5214ca8aac2Sdrh   return echoConstructor(db, pAux, argc, argv, ppVtab, pzErr);
522b9bb7c18Sdrh }
5237e6ebfb2Sdanielk1977 
524cc013f89Sdanielk1977 /*
525cc013f89Sdanielk1977 ** Echo virtual table module xDisconnect method.
526cc013f89Sdanielk1977 */
echoDisconnect(sqlite3_vtab * pVtab)5275fac9f86Sdanielk1977 static int echoDisconnect(sqlite3_vtab *pVtab){
5285fac9f86Sdanielk1977   appendToEchoModule(((echo_vtab *)pVtab)->interp, "xDisconnect");
5295fac9f86Sdanielk1977   return echoDestructor(pVtab);
5305fac9f86Sdanielk1977 }
531cc013f89Sdanielk1977 
532cc013f89Sdanielk1977 /*
533cc013f89Sdanielk1977 ** Echo virtual table module xDestroy method.
534cc013f89Sdanielk1977 */
echoDestroy(sqlite3_vtab * pVtab)5355fac9f86Sdanielk1977 static int echoDestroy(sqlite3_vtab *pVtab){
536a298e90dSdanielk1977   int rc = SQLITE_OK;
537a298e90dSdanielk1977   echo_vtab *p = (echo_vtab *)pVtab;
5385fac9f86Sdanielk1977   appendToEchoModule(((echo_vtab *)pVtab)->interp, "xDestroy");
539cc013f89Sdanielk1977 
540cc013f89Sdanielk1977   /* Drop the "log" table, if one exists (see echoCreate() for details) */
541a298e90dSdanielk1977   if( p && p->zLogName ){
542a298e90dSdanielk1977     char *zSql;
543bc6160b0Sdrh     zSql = sqlite3_mprintf("DROP TABLE %Q", p->zLogName);
544a298e90dSdanielk1977     rc = sqlite3_exec(p->db, zSql, 0, 0, 0);
54517435752Sdrh     sqlite3_free(zSql);
546a298e90dSdanielk1977   }
547cc013f89Sdanielk1977 
548a298e90dSdanielk1977   if( rc==SQLITE_OK ){
549a298e90dSdanielk1977     rc = echoDestructor(pVtab);
550a298e90dSdanielk1977   }
551a298e90dSdanielk1977   return rc;
5525fac9f86Sdanielk1977 }
5535fac9f86Sdanielk1977 
554cc013f89Sdanielk1977 /*
555cc013f89Sdanielk1977 ** Echo virtual table module xOpen method.
556cc013f89Sdanielk1977 */
echoOpen(sqlite3_vtab * pVTab,sqlite3_vtab_cursor ** ppCursor)5575fac9f86Sdanielk1977 static int echoOpen(sqlite3_vtab *pVTab, sqlite3_vtab_cursor **ppCursor){
558b7a7b9a3Sdanielk1977   echo_cursor *pCur;
5593e3a84d3Sdanielk1977   if( simulateVtabError((echo_vtab *)pVTab, "xOpen") ){
5603e3a84d3Sdanielk1977     return SQLITE_ERROR;
5613e3a84d3Sdanielk1977   }
56231dad9daSdanielk1977   pCur = sqlite3MallocZero(sizeof(echo_cursor));
563b7a7b9a3Sdanielk1977   *ppCursor = (sqlite3_vtab_cursor *)pCur;
564be718897Sdanielk1977   return (pCur ? SQLITE_OK : SQLITE_NOMEM);
565b7a7b9a3Sdanielk1977 }
566b7a7b9a3Sdanielk1977 
567cc013f89Sdanielk1977 /*
568cc013f89Sdanielk1977 ** Echo virtual table module xClose method.
569cc013f89Sdanielk1977 */
echoClose(sqlite3_vtab_cursor * cur)5705fac9f86Sdanielk1977 static int echoClose(sqlite3_vtab_cursor *cur){
571be718897Sdanielk1977   int rc;
572b7a7b9a3Sdanielk1977   echo_cursor *pCur = (echo_cursor *)cur;
573be718897Sdanielk1977   sqlite3_stmt *pStmt = pCur->pStmt;
574be718897Sdanielk1977   pCur->pStmt = 0;
57517435752Sdrh   sqlite3_free(pCur);
576be718897Sdanielk1977   rc = sqlite3_finalize(pStmt);
577be718897Sdanielk1977   return rc;
578b7a7b9a3Sdanielk1977 }
579b7a7b9a3Sdanielk1977 
580a298e90dSdanielk1977 /*
581a298e90dSdanielk1977 ** Return non-zero if the cursor does not currently point to a valid record
582a298e90dSdanielk1977 ** (i.e if the scan has finished), or zero otherwise.
583a298e90dSdanielk1977 */
echoEof(sqlite3_vtab_cursor * cur)584a298e90dSdanielk1977 static int echoEof(sqlite3_vtab_cursor *cur){
585a298e90dSdanielk1977   return (((echo_cursor *)cur)->pStmt ? 0 : 1);
586a298e90dSdanielk1977 }
587a298e90dSdanielk1977 
588cc013f89Sdanielk1977 /*
589cc013f89Sdanielk1977 ** Echo virtual table module xNext method.
590cc013f89Sdanielk1977 */
echoNext(sqlite3_vtab_cursor * cur)5915fac9f86Sdanielk1977 static int echoNext(sqlite3_vtab_cursor *cur){
59231dad9daSdanielk1977   int rc = SQLITE_OK;
593b7a7b9a3Sdanielk1977   echo_cursor *pCur = (echo_cursor *)cur;
594b7a7b9a3Sdanielk1977 
5953e3a84d3Sdanielk1977   if( simulateVtabError((echo_vtab *)(cur->pVtab), "xNext") ){
5963e3a84d3Sdanielk1977     return SQLITE_ERROR;
5973e3a84d3Sdanielk1977   }
5983e3a84d3Sdanielk1977 
59931dad9daSdanielk1977   if( pCur->pStmt ){
60031dad9daSdanielk1977     rc = sqlite3_step(pCur->pStmt);
601b7a7b9a3Sdanielk1977     if( rc==SQLITE_ROW ){
602a298e90dSdanielk1977       rc = SQLITE_OK;
603b7a7b9a3Sdanielk1977     }else{
604a298e90dSdanielk1977       rc = sqlite3_finalize(pCur->pStmt);
605b7a7b9a3Sdanielk1977       pCur->pStmt = 0;
606b7a7b9a3Sdanielk1977     }
60731dad9daSdanielk1977   }
608b7a7b9a3Sdanielk1977 
609b7a7b9a3Sdanielk1977   return rc;
610b7a7b9a3Sdanielk1977 }
611b7a7b9a3Sdanielk1977 
612cc013f89Sdanielk1977 /*
613cc013f89Sdanielk1977 ** Echo virtual table module xColumn method.
614cc013f89Sdanielk1977 */
echoColumn(sqlite3_vtab_cursor * cur,sqlite3_context * ctx,int i)6155fac9f86Sdanielk1977 static int echoColumn(sqlite3_vtab_cursor *cur, sqlite3_context *ctx, int i){
616b7a7b9a3Sdanielk1977   int iCol = i + 1;
617b7a7b9a3Sdanielk1977   sqlite3_stmt *pStmt = ((echo_cursor *)cur)->pStmt;
6183e3a84d3Sdanielk1977 
6193e3a84d3Sdanielk1977   if( simulateVtabError((echo_vtab *)(cur->pVtab), "xColumn") ){
6203e3a84d3Sdanielk1977     return SQLITE_ERROR;
6213e3a84d3Sdanielk1977   }
6223e3a84d3Sdanielk1977 
623fbbe005aSdanielk1977   if( !pStmt ){
624fbbe005aSdanielk1977     sqlite3_result_null(ctx);
625fbbe005aSdanielk1977   }else{
626b7a7b9a3Sdanielk1977     assert( sqlite3_data_count(pStmt)>iCol );
6274be8b51eSdrh     sqlite3_result_value(ctx, sqlite3_column_value(pStmt, iCol));
628fbbe005aSdanielk1977   }
629b7a7b9a3Sdanielk1977   return SQLITE_OK;
630b7a7b9a3Sdanielk1977 }
631b7a7b9a3Sdanielk1977 
632cc013f89Sdanielk1977 /*
633cc013f89Sdanielk1977 ** Echo virtual table module xRowid method.
634cc013f89Sdanielk1977 */
echoRowid(sqlite3_vtab_cursor * cur,sqlite_int64 * pRowid)6355fac9f86Sdanielk1977 static int echoRowid(sqlite3_vtab_cursor *cur, sqlite_int64 *pRowid){
636b7a7b9a3Sdanielk1977   sqlite3_stmt *pStmt = ((echo_cursor *)cur)->pStmt;
6373e3a84d3Sdanielk1977 
6383e3a84d3Sdanielk1977   if( simulateVtabError((echo_vtab *)(cur->pVtab), "xRowid") ){
6393e3a84d3Sdanielk1977     return SQLITE_ERROR;
6403e3a84d3Sdanielk1977   }
6413e3a84d3Sdanielk1977 
642b7a7b9a3Sdanielk1977   *pRowid = sqlite3_column_int64(pStmt, 0);
643b7a7b9a3Sdanielk1977   return SQLITE_OK;
644b7a7b9a3Sdanielk1977 }
645b7a7b9a3Sdanielk1977 
64698331538Sdanielk1977 /*
64798331538Sdanielk1977 ** Compute a simple hash of the null terminated string zString.
64898331538Sdanielk1977 **
64998331538Sdanielk1977 ** This module uses only sqlite3_index_info.idxStr, not
65098331538Sdanielk1977 ** sqlite3_index_info.idxNum. So to test idxNum, when idxStr is set
65198331538Sdanielk1977 ** in echoBestIndex(), idxNum is set to the corresponding hash value.
65298331538Sdanielk1977 ** In echoFilter(), code assert()s that the supplied idxNum value is
65398331538Sdanielk1977 ** indeed the hash of the supplied idxStr.
65498331538Sdanielk1977 */
hashString(const char * zString)65598331538Sdanielk1977 static int hashString(const char *zString){
6564081d5daSdrh   u32 val = 0;
65798331538Sdanielk1977   int ii;
65898331538Sdanielk1977   for(ii=0; zString[ii]; ii++){
65998331538Sdanielk1977     val = (val << 3) + (int)zString[ii];
66098331538Sdanielk1977   }
6614081d5daSdrh   return (int)(val&0x7fffffff);
66298331538Sdanielk1977 }
66398331538Sdanielk1977 
664cc013f89Sdanielk1977 /*
665cc013f89Sdanielk1977 ** Echo virtual table module xFilter method.
666cc013f89Sdanielk1977 */
echoFilter(sqlite3_vtab_cursor * pVtabCursor,int idxNum,const char * idxStr,int argc,sqlite3_value ** argv)6675fac9f86Sdanielk1977 static int echoFilter(
6685fac9f86Sdanielk1977   sqlite3_vtab_cursor *pVtabCursor,
6694be8b51eSdrh   int idxNum, const char *idxStr,
6704be8b51eSdrh   int argc, sqlite3_value **argv
6715fac9f86Sdanielk1977 ){
6725fac9f86Sdanielk1977   int rc;
6734be8b51eSdrh   int i;
6745fac9f86Sdanielk1977 
6755fac9f86Sdanielk1977   echo_cursor *pCur = (echo_cursor *)pVtabCursor;
6765fac9f86Sdanielk1977   echo_vtab *pVtab = (echo_vtab *)pVtabCursor->pVtab;
6775fac9f86Sdanielk1977   sqlite3 *db = pVtab->db;
6785fac9f86Sdanielk1977 
6793e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xFilter") ){
6803e3a84d3Sdanielk1977     return SQLITE_ERROR;
6813e3a84d3Sdanielk1977   }
6823e3a84d3Sdanielk1977 
683cc013f89Sdanielk1977   /* Check that idxNum matches idxStr */
684cc013f89Sdanielk1977   assert( idxNum==hashString(idxStr) );
685cc013f89Sdanielk1977 
686cc013f89Sdanielk1977   /* Log arguments to the ::echo_module Tcl variable */
687be718897Sdanielk1977   appendToEchoModule(pVtab->interp, "xFilter");
688be718897Sdanielk1977   appendToEchoModule(pVtab->interp, idxStr);
689be718897Sdanielk1977   for(i=0; i<argc; i++){
69065fd59f7Sdanielk1977     appendToEchoModule(pVtab->interp, (const char*)sqlite3_value_text(argv[i]));
691be718897Sdanielk1977   }
692be718897Sdanielk1977 
6935fac9f86Sdanielk1977   sqlite3_finalize(pCur->pStmt);
6945fac9f86Sdanielk1977   pCur->pStmt = 0;
695cc013f89Sdanielk1977 
696cc013f89Sdanielk1977   /* Prepare the SQL statement created by echoBestIndex and bind the
697cc013f89Sdanielk1977   ** runtime parameters passed to this function to it.
698cc013f89Sdanielk1977   */
6994be8b51eSdrh   rc = sqlite3_prepare(db, idxStr, -1, &pCur->pStmt, 0);
700fbbe005aSdanielk1977   assert( pCur->pStmt || rc!=SQLITE_OK );
7014b2688abSdanielk1977   for(i=0; rc==SQLITE_OK && i<argc; i++){
7026eacd28aSdanielk1977     rc = sqlite3_bind_value(pCur->pStmt, i+1, argv[i]);
7034be8b51eSdrh   }
704cc013f89Sdanielk1977 
705cc013f89Sdanielk1977   /* If everything was successful, advance to the first row of the scan */
7065fac9f86Sdanielk1977   if( rc==SQLITE_OK ){
707be718897Sdanielk1977     rc = echoNext(pVtabCursor);
7085fac9f86Sdanielk1977   }
7095fac9f86Sdanielk1977 
710be718897Sdanielk1977   return rc;
7115fac9f86Sdanielk1977 }
712b7a7b9a3Sdanielk1977 
713cc013f89Sdanielk1977 
714cc013f89Sdanielk1977 /*
715cc013f89Sdanielk1977 ** A helper function used by echoUpdate() and echoBestIndex() for
716cc013f89Sdanielk1977 ** manipulating strings in concert with the sqlite3_mprintf() function.
717cc013f89Sdanielk1977 **
718cc013f89Sdanielk1977 ** Parameter pzStr points to a pointer to a string allocated with
719cc013f89Sdanielk1977 ** sqlite3_mprintf. The second parameter, zAppend, points to another
720cc013f89Sdanielk1977 ** string. The two strings are concatenated together and *pzStr
721cc013f89Sdanielk1977 ** set to point at the result. The initial buffer pointed to by *pzStr
722cc013f89Sdanielk1977 ** is deallocated via sqlite3_free().
723cc013f89Sdanielk1977 **
724cc013f89Sdanielk1977 ** If the third argument, doFree, is true, then sqlite3_free() is
725cc013f89Sdanielk1977 ** also called to free the buffer pointed to by zAppend.
726cc013f89Sdanielk1977 */
string_concat(char ** pzStr,char * zAppend,int doFree,int * pRc)727a1644fd8Sdanielk1977 static void string_concat(char **pzStr, char *zAppend, int doFree, int *pRc){
728cc013f89Sdanielk1977   char *zIn = *pzStr;
729a1644fd8Sdanielk1977   if( !zAppend && doFree && *pRc==SQLITE_OK ){
730a1644fd8Sdanielk1977     *pRc = SQLITE_NOMEM;
731a1644fd8Sdanielk1977   }
732a1644fd8Sdanielk1977   if( *pRc!=SQLITE_OK ){
733a1644fd8Sdanielk1977     sqlite3_free(zIn);
734a1644fd8Sdanielk1977     zIn = 0;
735a1644fd8Sdanielk1977   }else{
736cc013f89Sdanielk1977     if( zIn ){
737cc013f89Sdanielk1977       char *zTemp = zIn;
738cc013f89Sdanielk1977       zIn = sqlite3_mprintf("%s%s", zIn, zAppend);
739cc013f89Sdanielk1977       sqlite3_free(zTemp);
740cc013f89Sdanielk1977     }else{
741cc013f89Sdanielk1977       zIn = sqlite3_mprintf("%s", zAppend);
742cc013f89Sdanielk1977     }
743a1644fd8Sdanielk1977     if( !zIn ){
744a1644fd8Sdanielk1977       *pRc = SQLITE_NOMEM;
745a1644fd8Sdanielk1977     }
746a1644fd8Sdanielk1977   }
747cc013f89Sdanielk1977   *pzStr = zIn;
748cc013f89Sdanielk1977   if( doFree ){
749cc013f89Sdanielk1977     sqlite3_free(zAppend);
750cc013f89Sdanielk1977   }
751cc013f89Sdanielk1977 }
752cc013f89Sdanielk1977 
753b9bb7c18Sdrh /*
7541acb539fSdan ** This function returns a pointer to an sqlite3_malloc()ed buffer
7551acb539fSdan ** containing the select-list (the thing between keywords SELECT and FROM)
7561acb539fSdan ** to query the underlying real table with for the scan described by
7571acb539fSdan ** argument pIdxInfo.
7581acb539fSdan **
7591acb539fSdan ** If the current SQLite version is earlier than 3.10.0, this is just "*"
7601acb539fSdan ** (select all columns). Or, for version 3.10.0 and greater, the list of
7611acb539fSdan ** columns identified by the pIdxInfo->colUsed mask.
7621acb539fSdan */
echoSelectList(echo_vtab * pTab,sqlite3_index_info * pIdxInfo)7631acb539fSdan static char *echoSelectList(echo_vtab *pTab, sqlite3_index_info *pIdxInfo){
7641acb539fSdan   char *zRet = 0;
7651acb539fSdan   if( sqlite3_libversion_number()<3010000 ){
7661acb539fSdan     zRet = sqlite3_mprintf(", *");
7671acb539fSdan   }else{
7681acb539fSdan     int i;
7691acb539fSdan     for(i=0; i<pTab->nCol; i++){
7701acb539fSdan       if( pIdxInfo->colUsed & ((sqlite3_uint64)1 << (i>=63 ? 63 : i)) ){
7711acb539fSdan         zRet = sqlite3_mprintf("%z, %s", zRet, pTab->aCol[i]);
7721acb539fSdan       }else{
7731acb539fSdan         zRet = sqlite3_mprintf("%z, NULL", zRet);
7741acb539fSdan       }
7751acb539fSdan       if( !zRet ) break;
7761acb539fSdan     }
7771acb539fSdan   }
7781acb539fSdan   return zRet;
7791acb539fSdan }
7801acb539fSdan 
7811acb539fSdan /*
7825fac9f86Sdanielk1977 ** The echo module implements the subset of query constraints and sort
7835fac9f86Sdanielk1977 ** orders that may take advantage of SQLite indices on the underlying
7845fac9f86Sdanielk1977 ** real table. For example, if the real table is declared as:
7855fac9f86Sdanielk1977 **
7865fac9f86Sdanielk1977 **     CREATE TABLE real(a, b, c);
7875fac9f86Sdanielk1977 **     CREATE INDEX real_index ON real(b);
7885fac9f86Sdanielk1977 **
7895fac9f86Sdanielk1977 ** then the echo module handles WHERE or ORDER BY clauses that refer
7905fac9f86Sdanielk1977 ** to the column "b", but not "a" or "c". If a multi-column index is
79185b623f2Sdrh ** present, only its left most column is considered.
792cc013f89Sdanielk1977 **
793cc013f89Sdanielk1977 ** This xBestIndex method encodes the proposed search strategy as
794cc013f89Sdanielk1977 ** an SQL query on the real table underlying the virtual echo module
795cc013f89Sdanielk1977 ** table and stores the query in sqlite3_index_info.idxStr. The SQL
796cc013f89Sdanielk1977 ** statement is of the form:
797cc013f89Sdanielk1977 **
798cc013f89Sdanielk1977 **   SELECT rowid, * FROM <real-table> ?<where-clause>? ?<order-by-clause>?
799cc013f89Sdanielk1977 **
800cc013f89Sdanielk1977 ** where the <where-clause> and <order-by-clause> are determined
801cc013f89Sdanielk1977 ** by the contents of the structure pointed to by the pIdxInfo argument.
802a967e886Sdrh */
echoBestIndex(sqlite3_vtab * tab,sqlite3_index_info * pIdxInfo)8035fac9f86Sdanielk1977 static int echoBestIndex(sqlite3_vtab *tab, sqlite3_index_info *pIdxInfo){
8045fac9f86Sdanielk1977   int ii;
8054be8b51eSdrh   char *zQuery = 0;
8061acb539fSdan   char *zCol = 0;
8074be8b51eSdrh   char *zNew;
8085fac9f86Sdanielk1977   int nArg = 0;
8094be8b51eSdrh   const char *zSep = "WHERE";
8105fac9f86Sdanielk1977   echo_vtab *pVtab = (echo_vtab *)tab;
81174cdba4fSdanielk1977   sqlite3_stmt *pStmt = 0;
812780b1d94Sdanielk1977   Tcl_Interp *interp = pVtab->interp;
81374cdba4fSdanielk1977 
81427b2f053Smistachkin   int nRow = 0;
81574cdba4fSdanielk1977   int useIdx = 0;
81674cdba4fSdanielk1977   int rc = SQLITE_OK;
817780b1d94Sdanielk1977   int useCost = 0;
81827b2f053Smistachkin   double cost = 0;
81939359dc0Sdanielk1977   int isIgnoreUsable = 0;
82039359dc0Sdanielk1977   if( Tcl_GetVar(interp, "echo_module_ignore_usable", TCL_GLOBAL_ONLY) ){
82139359dc0Sdanielk1977     isIgnoreUsable = 1;
82239359dc0Sdanielk1977   }
82339359dc0Sdanielk1977 
8243e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xBestIndex") ){
8253e3a84d3Sdanielk1977     return SQLITE_ERROR;
8263e3a84d3Sdanielk1977   }
8273e3a84d3Sdanielk1977 
82874cdba4fSdanielk1977   /* Determine the number of rows in the table and store this value in local
82974cdba4fSdanielk1977   ** variable nRow. The 'estimated-cost' of the scan will be the number of
83074cdba4fSdanielk1977   ** rows in the table for a linear scan, or the log (base 2) of the
83174cdba4fSdanielk1977   ** number of rows if the proposed scan uses an index.
83274cdba4fSdanielk1977   */
833780b1d94Sdanielk1977   if( Tcl_GetVar(interp, "echo_module_cost", TCL_GLOBAL_ONLY) ){
834780b1d94Sdanielk1977     cost = atof(Tcl_GetVar(interp, "echo_module_cost", TCL_GLOBAL_ONLY));
835780b1d94Sdanielk1977     useCost = 1;
836780b1d94Sdanielk1977   } else {
83774cdba4fSdanielk1977     zQuery = sqlite3_mprintf("SELECT count(*) FROM %Q", pVtab->zTableName);
838a1644fd8Sdanielk1977     if( !zQuery ){
839a1644fd8Sdanielk1977       return SQLITE_NOMEM;
840a1644fd8Sdanielk1977     }
84174cdba4fSdanielk1977     rc = sqlite3_prepare(pVtab->db, zQuery, -1, &pStmt, 0);
842dddb2f23Sdrh     sqlite3_free(zQuery);
84374cdba4fSdanielk1977     if( rc!=SQLITE_OK ){
84474cdba4fSdanielk1977       return rc;
84574cdba4fSdanielk1977     }
84674cdba4fSdanielk1977     sqlite3_step(pStmt);
84774cdba4fSdanielk1977     nRow = sqlite3_column_int(pStmt, 0);
84874cdba4fSdanielk1977     rc = sqlite3_finalize(pStmt);
84974cdba4fSdanielk1977     if( rc!=SQLITE_OK ){
85074cdba4fSdanielk1977       return rc;
85174cdba4fSdanielk1977     }
852780b1d94Sdanielk1977   }
8535fac9f86Sdanielk1977 
8541acb539fSdan   zCol = echoSelectList(pVtab, pIdxInfo);
8551acb539fSdan   if( !zCol ) return SQLITE_NOMEM;
8561acb539fSdan   zQuery = sqlite3_mprintf("SELECT rowid%z FROM %Q", zCol, pVtab->zTableName);
8571acb539fSdan   if( !zQuery ) return SQLITE_NOMEM;
8581acb539fSdan 
8595fac9f86Sdanielk1977   for(ii=0; ii<pIdxInfo->nConstraint; ii++){
8605fac9f86Sdanielk1977     const struct sqlite3_index_constraint *pConstraint;
8615fac9f86Sdanielk1977     struct sqlite3_index_constraint_usage *pUsage;
862383736b7Sdrh     int iCol;
8635fac9f86Sdanielk1977 
8645fac9f86Sdanielk1977     pConstraint = &pIdxInfo->aConstraint[ii];
8655fac9f86Sdanielk1977     pUsage = &pIdxInfo->aConstraintUsage[ii];
8665fac9f86Sdanielk1977 
86739359dc0Sdanielk1977     if( !isIgnoreUsable && !pConstraint->usable ) continue;
86839359dc0Sdanielk1977 
869383736b7Sdrh     iCol = pConstraint->iColumn;
87082ebc2a0Sdrh     if( iCol<0 || pVtab->aIndex[iCol] ){
8718ccdef6bSmistachkin       char *zNewCol = iCol>=0 ? pVtab->aCol[iCol] : "rowid";
8725fac9f86Sdanielk1977       char *zOp = 0;
87374cdba4fSdanielk1977       useIdx = 1;
8745fac9f86Sdanielk1977       switch( pConstraint->op ){
8755fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_EQ:
8765fac9f86Sdanielk1977           zOp = "="; break;
8775fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_LT:
8785fac9f86Sdanielk1977           zOp = "<"; break;
8795fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_GT:
8805fac9f86Sdanielk1977           zOp = ">"; break;
8815fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_LE:
8825fac9f86Sdanielk1977           zOp = "<="; break;
8835fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_GE:
8845fac9f86Sdanielk1977           zOp = ">="; break;
8855fac9f86Sdanielk1977         case SQLITE_INDEX_CONSTRAINT_MATCH:
886a9124d35Smistachkin           /* Purposely translate the MATCH operator into a LIKE, which
887a9124d35Smistachkin           ** will be used by the next block of code to construct a new
888a9124d35Smistachkin           ** query.  It should also be noted here that the next block
889a9124d35Smistachkin           ** of code requires the first letter of this operator to be
890a9124d35Smistachkin           ** in upper-case to trigger the special MATCH handling (i.e.
891a9124d35Smistachkin           ** wrapping the bound parameter with literal '%'s).
892a9124d35Smistachkin           */
8931a90e099Sdrh           zOp = "LIKE"; break;
89407bdba86Sdan         case SQLITE_INDEX_CONSTRAINT_LIKE:
89507bdba86Sdan           zOp = "like"; break;
89607bdba86Sdan         case SQLITE_INDEX_CONSTRAINT_GLOB:
89707bdba86Sdan           zOp = "glob"; break;
89807bdba86Sdan         case SQLITE_INDEX_CONSTRAINT_REGEXP:
89907bdba86Sdan           zOp = "regexp"; break;
9005fac9f86Sdanielk1977       }
901d03024d8Sdan       if( zOp ){
9021a90e099Sdrh         if( zOp[0]=='L' ){
903cc013f89Sdanielk1977           zNew = sqlite3_mprintf(" %s %s LIKE (SELECT '%%'||?||'%%')",
9048ccdef6bSmistachkin               zSep, zNewCol);
9051a90e099Sdrh         } else {
9068ccdef6bSmistachkin           zNew = sqlite3_mprintf(" %s %s %s ?", zSep, zNewCol, zOp);
9071a90e099Sdrh         }
908a1644fd8Sdanielk1977         string_concat(&zQuery, zNew, 1, &rc);
9094be8b51eSdrh         zSep = "AND";
9105fac9f86Sdanielk1977         pUsage->argvIndex = ++nArg;
9115fac9f86Sdanielk1977         pUsage->omit = 1;
9125fac9f86Sdanielk1977       }
9135fac9f86Sdanielk1977     }
914d03024d8Sdan   }
91547d08094Sdanielk1977 
91647d08094Sdanielk1977   /* If there is only one term in the ORDER BY clause, and it is
91747d08094Sdanielk1977   ** on a column that this virtual table has an index for, then consume
91847d08094Sdanielk1977   ** the ORDER BY clause.
91947d08094Sdanielk1977   */
92082ebc2a0Sdrh   if( pIdxInfo->nOrderBy==1 && (
92182ebc2a0Sdrh         pIdxInfo->aOrderBy->iColumn<0 ||
92282ebc2a0Sdrh         pVtab->aIndex[pIdxInfo->aOrderBy->iColumn]) ){
92365fd59f7Sdanielk1977     int iCol = pIdxInfo->aOrderBy->iColumn;
9248ccdef6bSmistachkin     char *zNewCol = iCol>=0 ? pVtab->aCol[iCol] : "rowid";
92547d08094Sdanielk1977     char *zDir = pIdxInfo->aOrderBy->desc?"DESC":"ASC";
9268ccdef6bSmistachkin     zNew = sqlite3_mprintf(" ORDER BY %s %s", zNewCol, zDir);
927a1644fd8Sdanielk1977     string_concat(&zQuery, zNew, 1, &rc);
92847d08094Sdanielk1977     pIdxInfo->orderByConsumed = 1;
92947d08094Sdanielk1977   }
93047d08094Sdanielk1977 
9315fac9f86Sdanielk1977   appendToEchoModule(pVtab->interp, "xBestIndex");;
9324be8b51eSdrh   appendToEchoModule(pVtab->interp, zQuery);
9335fac9f86Sdanielk1977 
934222a757dSdanielk1977   if( !zQuery ){
935a1644fd8Sdanielk1977     return rc;
936222a757dSdanielk1977   }
93798331538Sdanielk1977   pIdxInfo->idxNum = hashString(zQuery);
9384be8b51eSdrh   pIdxInfo->idxStr = zQuery;
9394be8b51eSdrh   pIdxInfo->needToFreeIdxStr = 1;
940780b1d94Sdanielk1977   if( useCost ){
941780b1d94Sdanielk1977     pIdxInfo->estimatedCost = cost;
942780b1d94Sdanielk1977   }else if( useIdx ){
94374cdba4fSdanielk1977     /* Approximation of log2(nRow). */
944693e6719Sdrh     for( ii=0; ii<(sizeof(int)*8)-1; ii++ ){
94574cdba4fSdanielk1977       if( nRow & (1<<ii) ){
94674cdba4fSdanielk1977         pIdxInfo->estimatedCost = (double)ii;
94774cdba4fSdanielk1977       }
94874cdba4fSdanielk1977     }
94974cdba4fSdanielk1977   }else{
95074cdba4fSdanielk1977     pIdxInfo->estimatedCost = (double)nRow;
95174cdba4fSdanielk1977   }
95274cdba4fSdanielk1977   return rc;
953a967e886Sdrh }
954a967e886Sdrh 
955176f4d23Sdanielk1977 /*
956cc013f89Sdanielk1977 ** The xUpdate method for echo module virtual tables.
957cc013f89Sdanielk1977 **
958176f4d23Sdanielk1977 **    apData[0]  apData[1]  apData[2..]
959176f4d23Sdanielk1977 **
960176f4d23Sdanielk1977 **    INTEGER                              DELETE
961176f4d23Sdanielk1977 **
962176f4d23Sdanielk1977 **    INTEGER    NULL       (nCol args)    UPDATE (do not set rowid)
963176f4d23Sdanielk1977 **    INTEGER    INTEGER    (nCol args)    UPDATE (with SET rowid = <arg1>)
964176f4d23Sdanielk1977 **
965176f4d23Sdanielk1977 **    NULL       NULL       (nCol args)    INSERT INTO (automatic rowid value)
966176f4d23Sdanielk1977 **    NULL       INTEGER    (nCol args)    INSERT (incl. rowid value)
967176f4d23Sdanielk1977 **
968176f4d23Sdanielk1977 */
echoUpdate(sqlite3_vtab * tab,int nData,sqlite3_value ** apData,sqlite_int64 * pRowid)9691f6eec54Sdanielk1977 int echoUpdate(
9701f6eec54Sdanielk1977   sqlite3_vtab *tab,
9711f6eec54Sdanielk1977   int nData,
9721f6eec54Sdanielk1977   sqlite3_value **apData,
9731f6eec54Sdanielk1977   sqlite_int64 *pRowid
9741f6eec54Sdanielk1977 ){
97526e4144dSdanielk1977   echo_vtab *pVtab = (echo_vtab *)tab;
97626e4144dSdanielk1977   sqlite3 *db = pVtab->db;
97726e4144dSdanielk1977   int rc = SQLITE_OK;
97826e4144dSdanielk1977 
97927b2f053Smistachkin   sqlite3_stmt *pStmt = 0;
980176f4d23Sdanielk1977   char *z = 0;               /* SQL statement to execute */
981176f4d23Sdanielk1977   int bindArgZero = 0;       /* True to bind apData[0] to sql var no. nData */
982176f4d23Sdanielk1977   int bindArgOne = 0;        /* True to bind apData[1] to sql var no. 1 */
983176f4d23Sdanielk1977   int i;                     /* Counter variable used by for loops */
984176f4d23Sdanielk1977 
98526e4144dSdanielk1977   assert( nData==pVtab->nCol+2 || nData==1 );
98626e4144dSdanielk1977 
987cd3dd9d3Sdrh   /* Ticket #3083 - make sure we always start a transaction prior to
988cd3dd9d3Sdrh   ** making any changes to a virtual table */
989cd3dd9d3Sdrh   assert( pVtab->inTransaction );
990cd3dd9d3Sdrh 
9913e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xUpdate") ){
9923e3a84d3Sdanielk1977     return SQLITE_ERROR;
9933e3a84d3Sdanielk1977   }
9943e3a84d3Sdanielk1977 
9955aec042eSdrh   /* If apData[0] is an integer and nData>1 then do an UPDATE */
9965aec042eSdrh   if( nData>1 && sqlite3_value_type(apData[0])==SQLITE_INTEGER ){
9975aec042eSdrh     char *zSep = " SET";
998383736b7Sdrh     z = sqlite3_mprintf("UPDATE %Q", pVtab->zTableName);
999a1644fd8Sdanielk1977     if( !z ){
1000a1644fd8Sdanielk1977       rc = SQLITE_NOMEM;
1001a1644fd8Sdanielk1977     }
10025aec042eSdrh 
1003176f4d23Sdanielk1977     bindArgOne = (apData[1] && sqlite3_value_type(apData[1])==SQLITE_INTEGER);
1004176f4d23Sdanielk1977     bindArgZero = 1;
1005176f4d23Sdanielk1977 
1006176f4d23Sdanielk1977     if( bindArgOne ){
1007a1644fd8Sdanielk1977        string_concat(&z, " SET rowid=?1 ", 0, &rc);
10085aec042eSdrh        zSep = ",";
10095aec042eSdrh     }
10105aec042eSdrh     for(i=2; i<nData; i++){
10115aec042eSdrh       if( apData[i]==0 ) continue;
1012176f4d23Sdanielk1977       string_concat(&z, sqlite3_mprintf(
1013a1644fd8Sdanielk1977           "%s %Q=?%d", zSep, pVtab->aCol[i-2], i), 1, &rc);
10145aec042eSdrh       zSep = ",";
10155aec042eSdrh     }
1016a1644fd8Sdanielk1977     string_concat(&z, sqlite3_mprintf(" WHERE rowid=?%d", nData), 1, &rc);
10175aec042eSdrh   }
10185aec042eSdrh 
1019176f4d23Sdanielk1977   /* If apData[0] is an integer and nData==1 then do a DELETE */
1020176f4d23Sdanielk1977   else if( nData==1 && sqlite3_value_type(apData[0])==SQLITE_INTEGER ){
1021176f4d23Sdanielk1977     z = sqlite3_mprintf("DELETE FROM %Q WHERE rowid = ?1", pVtab->zTableName);
1022a1644fd8Sdanielk1977     if( !z ){
1023a1644fd8Sdanielk1977       rc = SQLITE_NOMEM;
1024a1644fd8Sdanielk1977     }
1025176f4d23Sdanielk1977     bindArgZero = 1;
102626e4144dSdanielk1977   }
102726e4144dSdanielk1977 
1028176f4d23Sdanielk1977   /* If the first argument is NULL and there are more than two args, INSERT */
1029176f4d23Sdanielk1977   else if( nData>2 && sqlite3_value_type(apData[0])==SQLITE_NULL ){
103026e4144dSdanielk1977     int ii;
103126e4144dSdanielk1977     char *zInsert = 0;
103226e4144dSdanielk1977     char *zValues = 0;
103326e4144dSdanielk1977 
10344b2688abSdanielk1977     zInsert = sqlite3_mprintf("INSERT INTO %Q (", pVtab->zTableName);
1035a1644fd8Sdanielk1977     if( !zInsert ){
1036a1644fd8Sdanielk1977       rc = SQLITE_NOMEM;
1037a1644fd8Sdanielk1977     }
1038176f4d23Sdanielk1977     if( sqlite3_value_type(apData[1])==SQLITE_INTEGER ){
1039176f4d23Sdanielk1977       bindArgOne = 1;
104026e4144dSdanielk1977       zValues = sqlite3_mprintf("?");
1041a1644fd8Sdanielk1977       string_concat(&zInsert, "rowid", 0, &rc);
104226e4144dSdanielk1977     }
104326e4144dSdanielk1977 
1044176f4d23Sdanielk1977     assert((pVtab->nCol+2)==nData);
1045176f4d23Sdanielk1977     for(ii=2; ii<nData; ii++){
1046176f4d23Sdanielk1977       string_concat(&zInsert,
1047a1644fd8Sdanielk1977           sqlite3_mprintf("%s%Q", zValues?", ":"", pVtab->aCol[ii-2]), 1, &rc);
1048176f4d23Sdanielk1977       string_concat(&zValues,
1049a1644fd8Sdanielk1977           sqlite3_mprintf("%s?%d", zValues?", ":"", ii), 1, &rc);
105026e4144dSdanielk1977     }
1051176f4d23Sdanielk1977 
1052a1644fd8Sdanielk1977     string_concat(&z, zInsert, 1, &rc);
1053a1644fd8Sdanielk1977     string_concat(&z, ") VALUES(", 0, &rc);
1054a1644fd8Sdanielk1977     string_concat(&z, zValues, 1, &rc);
1055a1644fd8Sdanielk1977     string_concat(&z, ")", 0, &rc);
105626e4144dSdanielk1977   }
1057176f4d23Sdanielk1977 
1058176f4d23Sdanielk1977   /* Anything else is an error */
1059176f4d23Sdanielk1977   else{
1060176f4d23Sdanielk1977     assert(0);
1061176f4d23Sdanielk1977     return SQLITE_ERROR;
1062176f4d23Sdanielk1977   }
1063176f4d23Sdanielk1977 
1064a1644fd8Sdanielk1977   if( rc==SQLITE_OK ){
1065176f4d23Sdanielk1977     rc = sqlite3_prepare(db, z, -1, &pStmt, 0);
1066a1644fd8Sdanielk1977   }
1067176f4d23Sdanielk1977   assert( rc!=SQLITE_OK || pStmt );
1068176f4d23Sdanielk1977   sqlite3_free(z);
106926e4144dSdanielk1977   if( rc==SQLITE_OK ) {
1070176f4d23Sdanielk1977     if( bindArgZero ){
1071176f4d23Sdanielk1977       sqlite3_bind_value(pStmt, nData, apData[0]);
1072176f4d23Sdanielk1977     }
1073176f4d23Sdanielk1977     if( bindArgOne ){
1074176f4d23Sdanielk1977       sqlite3_bind_value(pStmt, 1, apData[1]);
1075176f4d23Sdanielk1977     }
1076a7a8e14bSdanielk1977     for(i=2; i<nData && rc==SQLITE_OK; i++){
1077a7a8e14bSdanielk1977       if( apData[i] ) rc = sqlite3_bind_value(pStmt, i, apData[i]);
1078176f4d23Sdanielk1977     }
1079a7a8e14bSdanielk1977     if( rc==SQLITE_OK ){
108026e4144dSdanielk1977       sqlite3_step(pStmt);
108126e4144dSdanielk1977       rc = sqlite3_finalize(pStmt);
1082a7a8e14bSdanielk1977     }else{
1083a7a8e14bSdanielk1977       sqlite3_finalize(pStmt);
1084a7a8e14bSdanielk1977     }
108526e4144dSdanielk1977   }
108626e4144dSdanielk1977 
10871f6eec54Sdanielk1977   if( pRowid && rc==SQLITE_OK ){
10881f6eec54Sdanielk1977     *pRowid = sqlite3_last_insert_rowid(db);
10891f6eec54Sdanielk1977   }
10904dc754d9Sdrh   if( rc!=SQLITE_OK ){
10914dc754d9Sdrh     tab->zErrMsg = sqlite3_mprintf("echo-vtab-error: %s", sqlite3_errmsg(db));
10924dc754d9Sdrh   }
10931f6eec54Sdanielk1977 
109426e4144dSdanielk1977   return rc;
109526e4144dSdanielk1977 }
109626e4144dSdanielk1977 
1097a967e886Sdrh /*
1098c69cdfd4Sdanielk1977 ** xBegin, xSync, xCommit and xRollback callbacks for echo module
1099c69cdfd4Sdanielk1977 ** virtual tables. Do nothing other than add the name of the callback
1100c69cdfd4Sdanielk1977 ** to the $::echo_module Tcl variable.
1101c69cdfd4Sdanielk1977 */
echoTransactionCall(sqlite3_vtab * tab,const char * zCall)1102c69cdfd4Sdanielk1977 static int echoTransactionCall(sqlite3_vtab *tab, const char *zCall){
1103c69cdfd4Sdanielk1977   char *z;
1104c69cdfd4Sdanielk1977   echo_vtab *pVtab = (echo_vtab *)tab;
1105c69cdfd4Sdanielk1977   z = sqlite3_mprintf("echo(%s)", pVtab->zTableName);
1106344c38e3Sdrh   if( z==0 ) return SQLITE_NOMEM;
1107c69cdfd4Sdanielk1977   appendToEchoModule(pVtab->interp, zCall);
1108c69cdfd4Sdanielk1977   appendToEchoModule(pVtab->interp, z);
1109c69cdfd4Sdanielk1977   sqlite3_free(z);
1110344c38e3Sdrh   return SQLITE_OK;
1111c69cdfd4Sdanielk1977 }
echoBegin(sqlite3_vtab * tab)1112c69cdfd4Sdanielk1977 static int echoBegin(sqlite3_vtab *tab){
1113a1644fd8Sdanielk1977   int rc;
11145017dc38Sdanielk1977   echo_vtab *pVtab = (echo_vtab *)tab;
11155017dc38Sdanielk1977   Tcl_Interp *interp = pVtab->interp;
11165017dc38Sdanielk1977   const char *zVal;
11175017dc38Sdanielk1977 
1118cd3dd9d3Sdrh   /* Ticket #3083 - do not start a transaction if we are already in
1119cd3dd9d3Sdrh   ** a transaction */
1120cd3dd9d3Sdrh   assert( !pVtab->inTransaction );
1121cd3dd9d3Sdrh 
11223e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xBegin") ){
11233e3a84d3Sdanielk1977     return SQLITE_ERROR;
11243e3a84d3Sdanielk1977   }
11253e3a84d3Sdanielk1977 
1126a1644fd8Sdanielk1977   rc = echoTransactionCall(tab, "xBegin");
11275017dc38Sdanielk1977 
1128a1644fd8Sdanielk1977   if( rc==SQLITE_OK ){
11295017dc38Sdanielk1977     /* Check if the $::echo_module_begin_fail variable is defined. If it is,
11305017dc38Sdanielk1977     ** and it is set to the name of the real table underlying this virtual
11315017dc38Sdanielk1977     ** echo module table, then cause this xSync operation to fail.
11325017dc38Sdanielk1977     */
11335017dc38Sdanielk1977     zVal = Tcl_GetVar(interp, "echo_module_begin_fail", TCL_GLOBAL_ONLY);
11345017dc38Sdanielk1977     if( zVal && 0==strcmp(zVal, pVtab->zTableName) ){
1135a1644fd8Sdanielk1977       rc = SQLITE_ERROR;
11365017dc38Sdanielk1977     }
1137a1644fd8Sdanielk1977   }
1138cd3dd9d3Sdrh   if( rc==SQLITE_OK ){
1139cd3dd9d3Sdrh     pVtab->inTransaction = 1;
1140cd3dd9d3Sdrh   }
1141a1644fd8Sdanielk1977   return rc;
1142c69cdfd4Sdanielk1977 }
echoSync(sqlite3_vtab * tab)1143c69cdfd4Sdanielk1977 static int echoSync(sqlite3_vtab *tab){
1144a1644fd8Sdanielk1977   int rc;
1145c69cdfd4Sdanielk1977   echo_vtab *pVtab = (echo_vtab *)tab;
1146c69cdfd4Sdanielk1977   Tcl_Interp *interp = pVtab->interp;
1147c69cdfd4Sdanielk1977   const char *zVal;
1148c69cdfd4Sdanielk1977 
1149cd3dd9d3Sdrh   /* Ticket #3083 - Only call xSync if we have previously started a
1150cd3dd9d3Sdrh   ** transaction */
1151cd3dd9d3Sdrh   assert( pVtab->inTransaction );
1152cd3dd9d3Sdrh 
11533e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xSync") ){
11543e3a84d3Sdanielk1977     return SQLITE_ERROR;
11553e3a84d3Sdanielk1977   }
11563e3a84d3Sdanielk1977 
1157a1644fd8Sdanielk1977   rc = echoTransactionCall(tab, "xSync");
1158c69cdfd4Sdanielk1977 
1159a1644fd8Sdanielk1977   if( rc==SQLITE_OK ){
1160c69cdfd4Sdanielk1977     /* Check if the $::echo_module_sync_fail variable is defined. If it is,
1161c69cdfd4Sdanielk1977     ** and it is set to the name of the real table underlying this virtual
1162c69cdfd4Sdanielk1977     ** echo module table, then cause this xSync operation to fail.
1163c69cdfd4Sdanielk1977     */
1164c69cdfd4Sdanielk1977     zVal = Tcl_GetVar(interp, "echo_module_sync_fail", TCL_GLOBAL_ONLY);
1165c69cdfd4Sdanielk1977     if( zVal && 0==strcmp(zVal, pVtab->zTableName) ){
1166a1644fd8Sdanielk1977       rc = -1;
1167c69cdfd4Sdanielk1977     }
1168a1644fd8Sdanielk1977   }
1169a1644fd8Sdanielk1977   return rc;
1170c69cdfd4Sdanielk1977 }
echoCommit(sqlite3_vtab * tab)1171c69cdfd4Sdanielk1977 static int echoCommit(sqlite3_vtab *tab){
1172cd3dd9d3Sdrh   echo_vtab *pVtab = (echo_vtab*)tab;
1173643167ffSdrh   int rc;
1174cd3dd9d3Sdrh 
1175cd3dd9d3Sdrh   /* Ticket #3083 - Only call xCommit if we have previously started
1176cd3dd9d3Sdrh   ** a transaction */
1177cd3dd9d3Sdrh   assert( pVtab->inTransaction );
1178cd3dd9d3Sdrh 
11793e3a84d3Sdanielk1977   if( simulateVtabError(pVtab, "xCommit") ){
11803e3a84d3Sdanielk1977     return SQLITE_ERROR;
11813e3a84d3Sdanielk1977   }
11823e3a84d3Sdanielk1977 
11832d1d86fbSdanielk1977   sqlite3BeginBenignMalloc();
1184643167ffSdrh   rc = echoTransactionCall(tab, "xCommit");
11852d1d86fbSdanielk1977   sqlite3EndBenignMalloc();
1186cd3dd9d3Sdrh   pVtab->inTransaction = 0;
1187643167ffSdrh   return rc;
1188c69cdfd4Sdanielk1977 }
echoRollback(sqlite3_vtab * tab)1189c69cdfd4Sdanielk1977 static int echoRollback(sqlite3_vtab *tab){
1190cd3dd9d3Sdrh   int rc;
1191cd3dd9d3Sdrh   echo_vtab *pVtab = (echo_vtab*)tab;
1192cd3dd9d3Sdrh 
1193cd3dd9d3Sdrh   /* Ticket #3083 - Only call xRollback if we have previously started
1194cd3dd9d3Sdrh   ** a transaction */
1195cd3dd9d3Sdrh   assert( pVtab->inTransaction );
1196cd3dd9d3Sdrh 
1197cd3dd9d3Sdrh   rc = echoTransactionCall(tab, "xRollback");
1198cd3dd9d3Sdrh   pVtab->inTransaction = 0;
1199cd3dd9d3Sdrh   return rc;
1200c69cdfd4Sdanielk1977 }
1201c69cdfd4Sdanielk1977 
1202c69cdfd4Sdanielk1977 /*
1203e94b0c39Sdrh ** Implementation of "GLOB" function on the echo module.  Pass
1204e94b0c39Sdrh ** all arguments to the ::echo_glob_overload procedure of TCL
1205e94b0c39Sdrh ** and return the result of that procedure as a string.
1206e94b0c39Sdrh */
overloadedGlobFunction(sqlite3_context * pContext,int nArg,sqlite3_value ** apArg)1207e94b0c39Sdrh static void overloadedGlobFunction(
1208e94b0c39Sdrh   sqlite3_context *pContext,
1209e94b0c39Sdrh   int nArg,
1210e94b0c39Sdrh   sqlite3_value **apArg
1211e94b0c39Sdrh ){
1212e94b0c39Sdrh   Tcl_Interp *interp = sqlite3_user_data(pContext);
1213e94b0c39Sdrh   Tcl_DString str;
1214e94b0c39Sdrh   int i;
1215e94b0c39Sdrh   int rc;
1216e94b0c39Sdrh   Tcl_DStringInit(&str);
1217e94b0c39Sdrh   Tcl_DStringAppendElement(&str, "::echo_glob_overload");
1218e94b0c39Sdrh   for(i=0; i<nArg; i++){
1219e94b0c39Sdrh     Tcl_DStringAppendElement(&str, (char*)sqlite3_value_text(apArg[i]));
1220e94b0c39Sdrh   }
1221e94b0c39Sdrh   rc = Tcl_Eval(interp, Tcl_DStringValue(&str));
1222e94b0c39Sdrh   Tcl_DStringFree(&str);
1223e94b0c39Sdrh   if( rc ){
1224e94b0c39Sdrh     sqlite3_result_error(pContext, Tcl_GetStringResult(interp), -1);
1225e94b0c39Sdrh   }else{
1226e94b0c39Sdrh     sqlite3_result_text(pContext, Tcl_GetStringResult(interp),
1227e94b0c39Sdrh                         -1, SQLITE_TRANSIENT);
1228e94b0c39Sdrh   }
1229e94b0c39Sdrh   Tcl_ResetResult(interp);
1230e94b0c39Sdrh }
1231e94b0c39Sdrh 
1232e94b0c39Sdrh /*
1233e94b0c39Sdrh ** This is the xFindFunction implementation for the echo module.
1234e94b0c39Sdrh ** SQLite calls this routine when the first argument of a function
1235e94b0c39Sdrh ** is a column of an echo virtual table.  This routine can optionally
1236e94b0c39Sdrh ** override the implementation of that function.  It will choose to
1237e94b0c39Sdrh ** do so if the function is named "glob", and a TCL command named
1238e94b0c39Sdrh ** ::echo_glob_overload exists.
1239e94b0c39Sdrh */
echoFindFunction(sqlite3_vtab * vtab,int nArg,const char * zFuncName,void (** pxFunc)(sqlite3_context *,int,sqlite3_value **),void ** ppArg)1240e94b0c39Sdrh static int echoFindFunction(
1241e94b0c39Sdrh   sqlite3_vtab *vtab,
1242e94b0c39Sdrh   int nArg,
1243e94b0c39Sdrh   const char *zFuncName,
1244e94b0c39Sdrh   void (**pxFunc)(sqlite3_context*,int,sqlite3_value**),
1245e94b0c39Sdrh   void **ppArg
1246e94b0c39Sdrh ){
1247e94b0c39Sdrh   echo_vtab *pVtab = (echo_vtab *)vtab;
1248e94b0c39Sdrh   Tcl_Interp *interp = pVtab->interp;
1249e94b0c39Sdrh   Tcl_CmdInfo info;
1250e94b0c39Sdrh   if( strcmp(zFuncName,"glob")!=0 ){
1251e94b0c39Sdrh     return 0;
1252e94b0c39Sdrh   }
1253e94b0c39Sdrh   if( Tcl_GetCommandInfo(interp, "::echo_glob_overload", &info)==0 ){
1254e94b0c39Sdrh     return 0;
1255e94b0c39Sdrh   }
1256e94b0c39Sdrh   *pxFunc = overloadedGlobFunction;
1257e94b0c39Sdrh   *ppArg = interp;
1258e94b0c39Sdrh   return 1;
1259e94b0c39Sdrh }
1260e94b0c39Sdrh 
echoRename(sqlite3_vtab * vtab,const char * zNewName)1261182c4ba9Sdanielk1977 static int echoRename(sqlite3_vtab *vtab, const char *zNewName){
1262182c4ba9Sdanielk1977   int rc = SQLITE_OK;
1263182c4ba9Sdanielk1977   echo_vtab *p = (echo_vtab *)vtab;
1264182c4ba9Sdanielk1977 
1265987a00e8Sdanielk1977   if( simulateVtabError(p, "xRename") ){
1266987a00e8Sdanielk1977     return SQLITE_ERROR;
1267987a00e8Sdanielk1977   }
1268987a00e8Sdanielk1977 
1269182c4ba9Sdanielk1977   if( p->isPattern ){
127083cc1392Sdrh     int nThis = (int)strlen(p->zThis);
1271bc6160b0Sdrh     char *zSql = sqlite3_mprintf("ALTER TABLE %s RENAME TO %s%s",
1272182c4ba9Sdanielk1977         p->zTableName, zNewName, &p->zTableName[nThis]
1273182c4ba9Sdanielk1977     );
1274182c4ba9Sdanielk1977     rc = sqlite3_exec(p->db, zSql, 0, 0, 0);
127517435752Sdrh     sqlite3_free(zSql);
1276182c4ba9Sdanielk1977   }
1277182c4ba9Sdanielk1977 
1278182c4ba9Sdanielk1977   return rc;
1279182c4ba9Sdanielk1977 }
1280182c4ba9Sdanielk1977 
echoSavepoint(sqlite3_vtab * pVTab,int iSavepoint)12813b504df1Sdan static int echoSavepoint(sqlite3_vtab *pVTab, int iSavepoint){
12823b504df1Sdan   assert( pVTab );
12833b504df1Sdan   return SQLITE_OK;
12843b504df1Sdan }
12853b504df1Sdan 
echoRelease(sqlite3_vtab * pVTab,int iSavepoint)12863b504df1Sdan static int echoRelease(sqlite3_vtab *pVTab, int iSavepoint){
12873b504df1Sdan   assert( pVTab );
12883b504df1Sdan   return SQLITE_OK;
12893b504df1Sdan }
12903b504df1Sdan 
echoRollbackTo(sqlite3_vtab * pVTab,int iSavepoint)12913b504df1Sdan static int echoRollbackTo(sqlite3_vtab *pVTab, int iSavepoint){
12923b504df1Sdan   assert( pVTab );
12933b504df1Sdan   return SQLITE_OK;
12943b504df1Sdan }
12953b504df1Sdan 
1296e94b0c39Sdrh /*
1297cc013f89Sdanielk1977 ** A virtual table module that merely "echos" the contents of another
1298cc013f89Sdanielk1977 ** table (like an SQL VIEW).
1299b9bb7c18Sdrh */
1300b9bb7c18Sdrh static sqlite3_module echoModule = {
13013b504df1Sdan   1,                         /* iVersion */
13023b504df1Sdan   echoCreate,
13033b504df1Sdan   echoConnect,
13043b504df1Sdan   echoBestIndex,
13053b504df1Sdan   echoDisconnect,
13063b504df1Sdan   echoDestroy,
13073b504df1Sdan   echoOpen,                  /* xOpen - open a cursor */
13083b504df1Sdan   echoClose,                 /* xClose - close a cursor */
13093b504df1Sdan   echoFilter,                /* xFilter - configure scan constraints */
13103b504df1Sdan   echoNext,                  /* xNext - advance a cursor */
13113b504df1Sdan   echoEof,                   /* xEof */
13123b504df1Sdan   echoColumn,                /* xColumn - read data */
13133b504df1Sdan   echoRowid,                 /* xRowid - read data */
13143b504df1Sdan   echoUpdate,                /* xUpdate - write data */
13153b504df1Sdan   echoBegin,                 /* xBegin - begin transaction */
13163b504df1Sdan   echoSync,                  /* xSync - sync transaction */
13173b504df1Sdan   echoCommit,                /* xCommit - commit transaction */
13183b504df1Sdan   echoRollback,              /* xRollback - rollback transaction */
13193b504df1Sdan   echoFindFunction,          /* xFindFunction - function overloading */
13203b504df1Sdan   echoRename                 /* xRename - rename the table */
13213b504df1Sdan };
13223b504df1Sdan 
13233b504df1Sdan static sqlite3_module echoModuleV2 = {
13243b504df1Sdan   2,                         /* iVersion */
1325b9bb7c18Sdrh   echoCreate,
1326b9bb7c18Sdrh   echoConnect,
1327a967e886Sdrh   echoBestIndex,
1328b9bb7c18Sdrh   echoDisconnect,
1329b9bb7c18Sdrh   echoDestroy,
1330b7a7b9a3Sdanielk1977   echoOpen,                  /* xOpen - open a cursor */
1331b7a7b9a3Sdanielk1977   echoClose,                 /* xClose - close a cursor */
1332b7a7b9a3Sdanielk1977   echoFilter,                /* xFilter - configure scan constraints */
1333b7a7b9a3Sdanielk1977   echoNext,                  /* xNext - advance a cursor */
1334a298e90dSdanielk1977   echoEof,                   /* xEof */
1335b7a7b9a3Sdanielk1977   echoColumn,                /* xColumn - read data */
133626e4144dSdanielk1977   echoRowid,                 /* xRowid - read data */
1337c69cdfd4Sdanielk1977   echoUpdate,                /* xUpdate - write data */
1338c69cdfd4Sdanielk1977   echoBegin,                 /* xBegin - begin transaction */
1339c69cdfd4Sdanielk1977   echoSync,                  /* xSync - sync transaction */
1340c69cdfd4Sdanielk1977   echoCommit,                /* xCommit - commit transaction */
1341b7f6f68fSdrh   echoRollback,              /* xRollback - rollback transaction */
1342e94b0c39Sdrh   echoFindFunction,          /* xFindFunction - function overloading */
1343182c4ba9Sdanielk1977   echoRename,                /* xRename - rename the table */
13443b504df1Sdan   echoSavepoint,
13453b504df1Sdan   echoRelease,
13463b504df1Sdan   echoRollbackTo
1347b9bb7c18Sdrh };
1348b9bb7c18Sdrh 
1349b9bb7c18Sdrh /*
1350b9bb7c18Sdrh ** Decode a pointer to an sqlite3 object.
1351b9bb7c18Sdrh */
135224b58dd7Sdrh extern int getDbPointer(Tcl_Interp *interp, const char *zA, sqlite3 **ppDb);
1353e84d8d32Smistachkin extern const char *sqlite3ErrName(int);
1354b9bb7c18Sdrh 
moduleDestroy(void * p)1355860b6cd2Sdanielk1977 static void moduleDestroy(void *p){
1356*ba39ca40Sdrh   EchoModule *pMod = (EchoModule*)p;
1357*ba39ca40Sdrh   sqlite3_create_function(pMod->db, "function_that_does_not_exist_0982ma98",
1358*ba39ca40Sdrh                           SQLITE_ANY, 1, 0, 0, 0, 0);
1359860b6cd2Sdanielk1977   sqlite3_free(p);
1360860b6cd2Sdanielk1977 }
1361860b6cd2Sdanielk1977 
1362b9bb7c18Sdrh /*
1363b9bb7c18Sdrh ** Register the echo virtual table module.
1364b9bb7c18Sdrh */
register_echo_module(ClientData clientData,Tcl_Interp * interp,int objc,Tcl_Obj * CONST objv[])13657617e4a8Smistachkin static int SQLITE_TCLAPI register_echo_module(
1366b9bb7c18Sdrh   ClientData clientData, /* Pointer to sqlite3_enable_XXX function */
1367b9bb7c18Sdrh   Tcl_Interp *interp,    /* The TCL interpreter that invoked this command */
1368b9bb7c18Sdrh   int objc,              /* Number of arguments */
1369b9bb7c18Sdrh   Tcl_Obj *CONST objv[]  /* Command arguments */
1370b9bb7c18Sdrh ){
1371ca8b9bacSdan   int rc;
1372b9bb7c18Sdrh   sqlite3 *db;
1373860b6cd2Sdanielk1977   EchoModule *pMod;
1374b9bb7c18Sdrh   if( objc!=2 ){
1375b9bb7c18Sdrh     Tcl_WrongNumArgs(interp, 1, objv, "DB");
1376b9bb7c18Sdrh     return TCL_ERROR;
1377b9bb7c18Sdrh   }
1378b9bb7c18Sdrh   if( getDbPointer(interp, Tcl_GetString(objv[1]), &db) ) return TCL_ERROR;
13793b504df1Sdan 
13803b504df1Sdan   /* Virtual table module "echo" */
1381860b6cd2Sdanielk1977   pMod = sqlite3_malloc(sizeof(EchoModule));
1382860b6cd2Sdanielk1977   pMod->interp = interp;
1383*ba39ca40Sdrh   pMod->db = db;
1384ca8b9bacSdan   rc = sqlite3_create_module_v2(
1385ca8b9bacSdan       db, "echo", &echoModule, (void*)pMod, moduleDestroy
1386ca8b9bacSdan   );
13873b504df1Sdan 
13883b504df1Sdan   /* Virtual table module "echo_v2" */
1389ca8b9bacSdan   if( rc==SQLITE_OK ){
13903b504df1Sdan     pMod = sqlite3_malloc(sizeof(EchoModule));
13913b504df1Sdan     pMod->interp = interp;
1392*ba39ca40Sdrh     pMod->db = db;
1393ca8b9bacSdan     rc = sqlite3_create_module_v2(db, "echo_v2",
13943b504df1Sdan         &echoModuleV2, (void*)pMod, moduleDestroy
13953b504df1Sdan     );
1396ca8b9bacSdan   }
1397ca8b9bacSdan 
1398e84d8d32Smistachkin   Tcl_SetResult(interp, (char *)sqlite3ErrName(rc), TCL_STATIC);
1399b9bb7c18Sdrh   return TCL_OK;
1400b9bb7c18Sdrh }
1401b9bb7c18Sdrh 
14025017dc38Sdanielk1977 /*
14035017dc38Sdanielk1977 ** Tcl interface to sqlite3_declare_vtab, invoked as follows from Tcl:
14045017dc38Sdanielk1977 **
14055017dc38Sdanielk1977 ** sqlite3_declare_vtab DB SQL
14065017dc38Sdanielk1977 */
declare_vtab(ClientData clientData,Tcl_Interp * interp,int objc,Tcl_Obj * CONST objv[])14077617e4a8Smistachkin static int SQLITE_TCLAPI declare_vtab(
14085017dc38Sdanielk1977   ClientData clientData, /* Pointer to sqlite3_enable_XXX function */
14095017dc38Sdanielk1977   Tcl_Interp *interp,    /* The TCL interpreter that invoked this command */
14105017dc38Sdanielk1977   int objc,              /* Number of arguments */
14115017dc38Sdanielk1977   Tcl_Obj *CONST objv[]  /* Command arguments */
14125017dc38Sdanielk1977 ){
14135017dc38Sdanielk1977   sqlite3 *db;
14145017dc38Sdanielk1977   int rc;
14155017dc38Sdanielk1977   if( objc!=3 ){
14165017dc38Sdanielk1977     Tcl_WrongNumArgs(interp, 1, objv, "DB SQL");
14175017dc38Sdanielk1977     return TCL_ERROR;
14185017dc38Sdanielk1977   }
14195017dc38Sdanielk1977   if( getDbPointer(interp, Tcl_GetString(objv[1]), &db) ) return TCL_ERROR;
14205017dc38Sdanielk1977   rc = sqlite3_declare_vtab(db, Tcl_GetString(objv[2]));
14215017dc38Sdanielk1977   if( rc!=SQLITE_OK ){
142265fd59f7Sdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_errmsg(db), TCL_VOLATILE);
14235017dc38Sdanielk1977     return TCL_ERROR;
14245017dc38Sdanielk1977   }
14255017dc38Sdanielk1977   return TCL_OK;
14265017dc38Sdanielk1977 }
14275017dc38Sdanielk1977 
1428cc013f89Sdanielk1977 #endif /* ifndef SQLITE_OMIT_VIRTUALTABLE */
1429b9bb7c18Sdrh 
1430b9bb7c18Sdrh /*
1431b9bb7c18Sdrh ** Register commands with the TCL interpreter.
1432b9bb7c18Sdrh */
Sqlitetest8_Init(Tcl_Interp * interp)1433b9bb7c18Sdrh int Sqlitetest8_Init(Tcl_Interp *interp){
14346e89162dSdanielk1977 #ifndef SQLITE_OMIT_VIRTUALTABLE
1435b9bb7c18Sdrh   static struct {
1436b9bb7c18Sdrh      char *zName;
1437b9bb7c18Sdrh      Tcl_ObjCmdProc *xProc;
1438b9bb7c18Sdrh      void *clientData;
1439b9bb7c18Sdrh   } aObjCmd[] = {
1440b9bb7c18Sdrh      { "register_echo_module",       register_echo_module, 0 },
14415017dc38Sdanielk1977      { "sqlite3_declare_vtab",       declare_vtab, 0 },
1442b9bb7c18Sdrh   };
1443b9bb7c18Sdrh   int i;
1444b9bb7c18Sdrh   for(i=0; i<sizeof(aObjCmd)/sizeof(aObjCmd[0]); i++){
1445b9bb7c18Sdrh     Tcl_CreateObjCommand(interp, aObjCmd[i].zName,
1446b9bb7c18Sdrh         aObjCmd[i].xProc, aObjCmd[i].clientData, 0);
1447b9bb7c18Sdrh   }
14486e89162dSdanielk1977 #endif
1449b9bb7c18Sdrh   return TCL_OK;
1450b9bb7c18Sdrh }
1451