xref: /sqlite-3.40.0/src/tclsqlite.c (revision cfb8f8d6)
175897234Sdrh /*
2b19a2bc6Sdrh ** 2001 September 15
375897234Sdrh **
4b19a2bc6Sdrh ** The author disclaims copyright to this source code.  In place of
5b19a2bc6Sdrh ** a legal notice, here is a blessing:
675897234Sdrh **
7b19a2bc6Sdrh **    May you do good and not evil.
8b19a2bc6Sdrh **    May you find forgiveness for yourself and forgive others.
9b19a2bc6Sdrh **    May you share freely, never taking more than you give.
1075897234Sdrh **
1175897234Sdrh *************************************************************************
12bd08af48Sdrh ** A TCL Interface to SQLite.  Append this file to sqlite3.c and
13bd08af48Sdrh ** compile the whole thing to build a TCL-enabled version of SQLite.
1457a0227fSdrh **
1557a0227fSdrh ** Compile-time options:
1657a0227fSdrh **
1757a0227fSdrh **  -DTCLSH=1             Add a "main()" routine that works as a tclsh.
1857a0227fSdrh **
1957a0227fSdrh **  -DSQLITE_TCLMD5       When used in conjuction with -DTCLSH=1, add
2057a0227fSdrh **                        four new commands to the TCL interpreter for
2157a0227fSdrh **                        generating MD5 checksums:  md5, md5file,
2257a0227fSdrh **                        md5-10x8, and md5file-10x8.
2357a0227fSdrh **
2457a0227fSdrh **  -DSQLITE_TEST         When used in conjuction with -DTCLSH=1, add
2557a0227fSdrh **                        hundreds of new commands used for testing
2657a0227fSdrh **                        SQLite.  This option implies -DSQLITE_TCLMD5.
2775897234Sdrh */
2827b2f053Smistachkin 
2927b2f053Smistachkin /*
3027b2f053Smistachkin ** If requested, include the SQLite compiler options file for MSVC.
3127b2f053Smistachkin */
3227b2f053Smistachkin #if defined(INCLUDE_MSVC_H)
3327b2f053Smistachkin #include "msvc.h"
3427b2f053Smistachkin #endif
3527b2f053Smistachkin 
36bd08af48Sdrh #include "tcl.h"
37b4e9af9fSdanielk1977 #include <errno.h>
386d31316cSdrh 
39bd08af48Sdrh /*
40bd08af48Sdrh ** Some additional include files are needed if this file is not
41bd08af48Sdrh ** appended to the amalgamation.
42bd08af48Sdrh */
43bd08af48Sdrh #ifndef SQLITE_AMALGAMATION
4465e8c82eSdrh # include "sqlite3.h"
4575897234Sdrh # include <stdlib.h>
4675897234Sdrh # include <string.h>
47ce927065Sdrh # include <assert.h>
4865e8c82eSdrh   typedef unsigned char u8;
49bd08af48Sdrh #endif
50eb206381Sdrh #include <ctype.h>
5175897234Sdrh 
521f28e070Smistachkin /* Used to get the current process ID */
531f28e070Smistachkin #if !defined(_WIN32)
541f28e070Smistachkin # include <unistd.h>
551f28e070Smistachkin # define GETPID getpid
561f28e070Smistachkin #elif !defined(_WIN32_WCE)
571f28e070Smistachkin # ifndef SQLITE_AMALGAMATION
581f28e070Smistachkin #  define WIN32_LEAN_AND_MEAN
591f28e070Smistachkin #  include <windows.h>
601f28e070Smistachkin # endif
611f28e070Smistachkin # define GETPID (int)GetCurrentProcessId
621f28e070Smistachkin #endif
631f28e070Smistachkin 
64ad6e1370Sdrh /*
65ad6e1370Sdrh  * Windows needs to know which symbols to export.  Unix does not.
66ad6e1370Sdrh  * BUILD_sqlite should be undefined for Unix.
67ad6e1370Sdrh  */
68ad6e1370Sdrh #ifdef BUILD_sqlite
69ad6e1370Sdrh #undef TCL_STORAGE_CLASS
70ad6e1370Sdrh #define TCL_STORAGE_CLASS DLLEXPORT
71ad6e1370Sdrh #endif /* BUILD_sqlite */
7229bc4615Sdrh 
73a21c6b6fSdanielk1977 #define NUM_PREPARED_STMTS 10
74fb7e7651Sdrh #define MAX_PREPARED_STMTS 100
75fb7e7651Sdrh 
76c45e6716Sdrh /* Forward declaration */
77c45e6716Sdrh typedef struct SqliteDb SqliteDb;
7898808babSdrh 
7998808babSdrh /*
80cabb0819Sdrh ** New SQL functions can be created as TCL scripts.  Each such function
81cabb0819Sdrh ** is described by an instance of the following structure.
82cabb0819Sdrh */
83cabb0819Sdrh typedef struct SqlFunc SqlFunc;
84cabb0819Sdrh struct SqlFunc {
85cabb0819Sdrh   Tcl_Interp *interp;   /* The TCL interpret to execute the function */
86d1e4733dSdrh   Tcl_Obj *pScript;     /* The Tcl_Obj representation of the script */
87c45e6716Sdrh   SqliteDb *pDb;        /* Database connection that owns this function */
88d1e4733dSdrh   int useEvalObjv;      /* True if it is safe to use Tcl_EvalObjv */
89d1e4733dSdrh   char *zName;          /* Name of this function */
90cabb0819Sdrh   SqlFunc *pNext;       /* Next function on the list of them all */
91cabb0819Sdrh };
92cabb0819Sdrh 
93cabb0819Sdrh /*
940202b29eSdanielk1977 ** New collation sequences function can be created as TCL scripts.  Each such
950202b29eSdanielk1977 ** function is described by an instance of the following structure.
960202b29eSdanielk1977 */
970202b29eSdanielk1977 typedef struct SqlCollate SqlCollate;
980202b29eSdanielk1977 struct SqlCollate {
990202b29eSdanielk1977   Tcl_Interp *interp;   /* The TCL interpret to execute the function */
1000202b29eSdanielk1977   char *zScript;        /* The script to be run */
1010202b29eSdanielk1977   SqlCollate *pNext;    /* Next function on the list of them all */
1020202b29eSdanielk1977 };
1030202b29eSdanielk1977 
1040202b29eSdanielk1977 /*
105fb7e7651Sdrh ** Prepared statements are cached for faster execution.  Each prepared
106fb7e7651Sdrh ** statement is described by an instance of the following structure.
107fb7e7651Sdrh */
108fb7e7651Sdrh typedef struct SqlPreparedStmt SqlPreparedStmt;
109fb7e7651Sdrh struct SqlPreparedStmt {
110fb7e7651Sdrh   SqlPreparedStmt *pNext;  /* Next in linked list */
111fb7e7651Sdrh   SqlPreparedStmt *pPrev;  /* Previous on the list */
112fb7e7651Sdrh   sqlite3_stmt *pStmt;     /* The prepared statement */
113fb7e7651Sdrh   int nSql;                /* chars in zSql[] */
114d0e2a854Sdanielk1977   const char *zSql;        /* Text of the SQL statement */
1154a4c11aaSdan   int nParm;               /* Size of apParm array */
1164a4c11aaSdan   Tcl_Obj **apParm;        /* Array of referenced object pointers */
117fb7e7651Sdrh };
118fb7e7651Sdrh 
119d0441796Sdanielk1977 typedef struct IncrblobChannel IncrblobChannel;
120d0441796Sdanielk1977 
121fb7e7651Sdrh /*
122bec3f402Sdrh ** There is one instance of this structure for each SQLite database
123bec3f402Sdrh ** that has been opened by the SQLite TCL interface.
124c431fd55Sdan **
125c431fd55Sdan ** If this module is built with SQLITE_TEST defined (to create the SQLite
126c431fd55Sdan ** testfixture executable), then it may be configured to use either
127c431fd55Sdan ** sqlite3_prepare_v2() or sqlite3_prepare() to prepare SQL statements.
128c431fd55Sdan ** If SqliteDb.bLegacyPrepare is true, sqlite3_prepare() is used.
129bec3f402Sdrh */
130bec3f402Sdrh struct SqliteDb {
131dddca286Sdrh   sqlite3 *db;               /* The "real" database structure. MUST BE FIRST */
132bec3f402Sdrh   Tcl_Interp *interp;        /* The interpreter used for this database */
1336d31316cSdrh   char *zBusy;               /* The busy callback routine */
134aa940eacSdrh   char *zCommit;             /* The commit hook callback routine */
135b5a20d3cSdrh   char *zTrace;              /* The trace callback routine */
13619e2d37fSdrh   char *zProfile;            /* The profile callback routine */
137348bb5d6Sdanielk1977   char *zProgress;           /* The progress callback routine */
138e22a334bSdrh   char *zAuth;               /* The authorization callback routine */
1391f1549f8Sdrh   int disableAuth;           /* Disable the authorizer if it exists */
14055c45f2eSdanielk1977   char *zNull;               /* Text to substitute for an SQL NULL value */
141cabb0819Sdrh   SqlFunc *pFunc;            /* List of SQL functions */
14294eb6a14Sdanielk1977   Tcl_Obj *pUpdateHook;      /* Update hook script (if any) */
14371fd80bfSdanielk1977   Tcl_Obj *pRollbackHook;    /* Rollback hook script (if any) */
1445def0843Sdrh   Tcl_Obj *pWalHook;         /* WAL hook script (if any) */
145404ca075Sdanielk1977   Tcl_Obj *pUnlockNotify;    /* Unlock notify script (if any) */
1460202b29eSdanielk1977   SqlCollate *pCollate;      /* List of SQL collation functions */
1476f8a503dSdanielk1977   int rc;                    /* Return code of most recent sqlite3_exec() */
1487cedc8d4Sdanielk1977   Tcl_Obj *pCollateNeeded;   /* Collation needed script */
149fb7e7651Sdrh   SqlPreparedStmt *stmtList; /* List of prepared statements*/
150fb7e7651Sdrh   SqlPreparedStmt *stmtLast; /* Last statement in the list */
151fb7e7651Sdrh   int maxStmt;               /* The next maximum number of stmtList */
152fb7e7651Sdrh   int nStmt;                 /* Number of statements in stmtList */
153d0441796Sdanielk1977   IncrblobChannel *pIncrblob;/* Linked list of open incrblob channels */
1543c379b01Sdrh   int nStep, nSort, nIndex;  /* Statistics for most recent operation */
155cd38d520Sdanielk1977   int nTransaction;          /* Number of nested [transaction] methods */
156c431fd55Sdan #ifdef SQLITE_TEST
157c431fd55Sdan   int bLegacyPrepare;        /* True to use sqlite3_prepare() */
158c431fd55Sdan #endif
15998808babSdrh };
160297ecf14Sdrh 
161b4e9af9fSdanielk1977 struct IncrblobChannel {
162d0441796Sdanielk1977   sqlite3_blob *pBlob;      /* sqlite3 blob handle */
163dcbb5d3fSdanielk1977   SqliteDb *pDb;            /* Associated database connection */
164b4e9af9fSdanielk1977   int iSeek;                /* Current seek offset */
165d0441796Sdanielk1977   Tcl_Channel channel;      /* Channel identifier */
166d0441796Sdanielk1977   IncrblobChannel *pNext;   /* Linked list of all open incrblob channels */
167d0441796Sdanielk1977   IncrblobChannel *pPrev;   /* Linked list of all open incrblob channels */
168b4e9af9fSdanielk1977 };
169b4e9af9fSdanielk1977 
170ea678832Sdrh /*
171ea678832Sdrh ** Compute a string length that is limited to what can be stored in
172ea678832Sdrh ** lower 30 bits of a 32-bit signed integer.
173ea678832Sdrh */
1744f21c4afSdrh static int strlen30(const char *z){
175ea678832Sdrh   const char *z2 = z;
176ea678832Sdrh   while( *z2 ){ z2++; }
177ea678832Sdrh   return 0x3fffffff & (int)(z2 - z);
178ea678832Sdrh }
179ea678832Sdrh 
180ea678832Sdrh 
18132a0d8bbSdanielk1977 #ifndef SQLITE_OMIT_INCRBLOB
182b4e9af9fSdanielk1977 /*
183d0441796Sdanielk1977 ** Close all incrblob channels opened using database connection pDb.
184d0441796Sdanielk1977 ** This is called when shutting down the database connection.
185d0441796Sdanielk1977 */
186d0441796Sdanielk1977 static void closeIncrblobChannels(SqliteDb *pDb){
187d0441796Sdanielk1977   IncrblobChannel *p;
188d0441796Sdanielk1977   IncrblobChannel *pNext;
189d0441796Sdanielk1977 
190d0441796Sdanielk1977   for(p=pDb->pIncrblob; p; p=pNext){
191d0441796Sdanielk1977     pNext = p->pNext;
192d0441796Sdanielk1977 
193d0441796Sdanielk1977     /* Note: Calling unregister here call Tcl_Close on the incrblob channel,
194d0441796Sdanielk1977     ** which deletes the IncrblobChannel structure at *p. So do not
195d0441796Sdanielk1977     ** call Tcl_Free() here.
196d0441796Sdanielk1977     */
197d0441796Sdanielk1977     Tcl_UnregisterChannel(pDb->interp, p->channel);
198d0441796Sdanielk1977   }
199d0441796Sdanielk1977 }
200d0441796Sdanielk1977 
201d0441796Sdanielk1977 /*
202b4e9af9fSdanielk1977 ** Close an incremental blob channel.
203b4e9af9fSdanielk1977 */
204b4e9af9fSdanielk1977 static int incrblobClose(ClientData instanceData, Tcl_Interp *interp){
205b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
20692d4d7a9Sdanielk1977   int rc = sqlite3_blob_close(p->pBlob);
20792d4d7a9Sdanielk1977   sqlite3 *db = p->pDb->db;
208d0441796Sdanielk1977 
209d0441796Sdanielk1977   /* Remove the channel from the SqliteDb.pIncrblob list. */
210d0441796Sdanielk1977   if( p->pNext ){
211d0441796Sdanielk1977     p->pNext->pPrev = p->pPrev;
212d0441796Sdanielk1977   }
213d0441796Sdanielk1977   if( p->pPrev ){
214d0441796Sdanielk1977     p->pPrev->pNext = p->pNext;
215d0441796Sdanielk1977   }
216d0441796Sdanielk1977   if( p->pDb->pIncrblob==p ){
217d0441796Sdanielk1977     p->pDb->pIncrblob = p->pNext;
218d0441796Sdanielk1977   }
219d0441796Sdanielk1977 
22092d4d7a9Sdanielk1977   /* Free the IncrblobChannel structure */
221b4e9af9fSdanielk1977   Tcl_Free((char *)p);
22292d4d7a9Sdanielk1977 
22392d4d7a9Sdanielk1977   if( rc!=SQLITE_OK ){
22492d4d7a9Sdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_errmsg(db), TCL_VOLATILE);
22592d4d7a9Sdanielk1977     return TCL_ERROR;
22692d4d7a9Sdanielk1977   }
227b4e9af9fSdanielk1977   return TCL_OK;
228b4e9af9fSdanielk1977 }
229b4e9af9fSdanielk1977 
230b4e9af9fSdanielk1977 /*
231b4e9af9fSdanielk1977 ** Read data from an incremental blob channel.
232b4e9af9fSdanielk1977 */
233b4e9af9fSdanielk1977 static int incrblobInput(
234b4e9af9fSdanielk1977   ClientData instanceData,
235b4e9af9fSdanielk1977   char *buf,
236b4e9af9fSdanielk1977   int bufSize,
237b4e9af9fSdanielk1977   int *errorCodePtr
238b4e9af9fSdanielk1977 ){
239b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
240b4e9af9fSdanielk1977   int nRead = bufSize;         /* Number of bytes to read */
241b4e9af9fSdanielk1977   int nBlob;                   /* Total size of the blob */
242b4e9af9fSdanielk1977   int rc;                      /* sqlite error code */
243b4e9af9fSdanielk1977 
244b4e9af9fSdanielk1977   nBlob = sqlite3_blob_bytes(p->pBlob);
245b4e9af9fSdanielk1977   if( (p->iSeek+nRead)>nBlob ){
246b4e9af9fSdanielk1977     nRead = nBlob-p->iSeek;
247b4e9af9fSdanielk1977   }
248b4e9af9fSdanielk1977   if( nRead<=0 ){
249b4e9af9fSdanielk1977     return 0;
250b4e9af9fSdanielk1977   }
251b4e9af9fSdanielk1977 
252b4e9af9fSdanielk1977   rc = sqlite3_blob_read(p->pBlob, (void *)buf, nRead, p->iSeek);
253b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
254b4e9af9fSdanielk1977     *errorCodePtr = rc;
255b4e9af9fSdanielk1977     return -1;
256b4e9af9fSdanielk1977   }
257b4e9af9fSdanielk1977 
258b4e9af9fSdanielk1977   p->iSeek += nRead;
259b4e9af9fSdanielk1977   return nRead;
260b4e9af9fSdanielk1977 }
261b4e9af9fSdanielk1977 
262d0441796Sdanielk1977 /*
263d0441796Sdanielk1977 ** Write data to an incremental blob channel.
264d0441796Sdanielk1977 */
265b4e9af9fSdanielk1977 static int incrblobOutput(
266b4e9af9fSdanielk1977   ClientData instanceData,
267b4e9af9fSdanielk1977   CONST char *buf,
268b4e9af9fSdanielk1977   int toWrite,
269b4e9af9fSdanielk1977   int *errorCodePtr
270b4e9af9fSdanielk1977 ){
271b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
272b4e9af9fSdanielk1977   int nWrite = toWrite;        /* Number of bytes to write */
273b4e9af9fSdanielk1977   int nBlob;                   /* Total size of the blob */
274b4e9af9fSdanielk1977   int rc;                      /* sqlite error code */
275b4e9af9fSdanielk1977 
276b4e9af9fSdanielk1977   nBlob = sqlite3_blob_bytes(p->pBlob);
277b4e9af9fSdanielk1977   if( (p->iSeek+nWrite)>nBlob ){
278b4e9af9fSdanielk1977     *errorCodePtr = EINVAL;
279b4e9af9fSdanielk1977     return -1;
280b4e9af9fSdanielk1977   }
281b4e9af9fSdanielk1977   if( nWrite<=0 ){
282b4e9af9fSdanielk1977     return 0;
283b4e9af9fSdanielk1977   }
284b4e9af9fSdanielk1977 
285b4e9af9fSdanielk1977   rc = sqlite3_blob_write(p->pBlob, (void *)buf, nWrite, p->iSeek);
286b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
287b4e9af9fSdanielk1977     *errorCodePtr = EIO;
288b4e9af9fSdanielk1977     return -1;
289b4e9af9fSdanielk1977   }
290b4e9af9fSdanielk1977 
291b4e9af9fSdanielk1977   p->iSeek += nWrite;
292b4e9af9fSdanielk1977   return nWrite;
293b4e9af9fSdanielk1977 }
294b4e9af9fSdanielk1977 
295b4e9af9fSdanielk1977 /*
296b4e9af9fSdanielk1977 ** Seek an incremental blob channel.
297b4e9af9fSdanielk1977 */
298b4e9af9fSdanielk1977 static int incrblobSeek(
299b4e9af9fSdanielk1977   ClientData instanceData,
300b4e9af9fSdanielk1977   long offset,
301b4e9af9fSdanielk1977   int seekMode,
302b4e9af9fSdanielk1977   int *errorCodePtr
303b4e9af9fSdanielk1977 ){
304b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
305b4e9af9fSdanielk1977 
306b4e9af9fSdanielk1977   switch( seekMode ){
307b4e9af9fSdanielk1977     case SEEK_SET:
308b4e9af9fSdanielk1977       p->iSeek = offset;
309b4e9af9fSdanielk1977       break;
310b4e9af9fSdanielk1977     case SEEK_CUR:
311b4e9af9fSdanielk1977       p->iSeek += offset;
312b4e9af9fSdanielk1977       break;
313b4e9af9fSdanielk1977     case SEEK_END:
314b4e9af9fSdanielk1977       p->iSeek = sqlite3_blob_bytes(p->pBlob) + offset;
315b4e9af9fSdanielk1977       break;
316b4e9af9fSdanielk1977 
317b4e9af9fSdanielk1977     default: assert(!"Bad seekMode");
318b4e9af9fSdanielk1977   }
319b4e9af9fSdanielk1977 
320b4e9af9fSdanielk1977   return p->iSeek;
321b4e9af9fSdanielk1977 }
322b4e9af9fSdanielk1977 
323b4e9af9fSdanielk1977 
324b4e9af9fSdanielk1977 static void incrblobWatch(ClientData instanceData, int mode){
325b4e9af9fSdanielk1977   /* NO-OP */
326b4e9af9fSdanielk1977 }
327b4e9af9fSdanielk1977 static int incrblobHandle(ClientData instanceData, int dir, ClientData *hPtr){
328b4e9af9fSdanielk1977   return TCL_ERROR;
329b4e9af9fSdanielk1977 }
330b4e9af9fSdanielk1977 
331b4e9af9fSdanielk1977 static Tcl_ChannelType IncrblobChannelType = {
332b4e9af9fSdanielk1977   "incrblob",                        /* typeName                             */
333b4e9af9fSdanielk1977   TCL_CHANNEL_VERSION_2,             /* version                              */
334b4e9af9fSdanielk1977   incrblobClose,                     /* closeProc                            */
335b4e9af9fSdanielk1977   incrblobInput,                     /* inputProc                            */
336b4e9af9fSdanielk1977   incrblobOutput,                    /* outputProc                           */
337b4e9af9fSdanielk1977   incrblobSeek,                      /* seekProc                             */
338b4e9af9fSdanielk1977   0,                                 /* setOptionProc                        */
339b4e9af9fSdanielk1977   0,                                 /* getOptionProc                        */
340b4e9af9fSdanielk1977   incrblobWatch,                     /* watchProc (this is a no-op)          */
341b4e9af9fSdanielk1977   incrblobHandle,                    /* getHandleProc (always returns error) */
342b4e9af9fSdanielk1977   0,                                 /* close2Proc                           */
343b4e9af9fSdanielk1977   0,                                 /* blockModeProc                        */
344b4e9af9fSdanielk1977   0,                                 /* flushProc                            */
345b4e9af9fSdanielk1977   0,                                 /* handlerProc                          */
346b4e9af9fSdanielk1977   0,                                 /* wideSeekProc                         */
347b4e9af9fSdanielk1977 };
348b4e9af9fSdanielk1977 
349b4e9af9fSdanielk1977 /*
350b4e9af9fSdanielk1977 ** Create a new incrblob channel.
351b4e9af9fSdanielk1977 */
352b4e9af9fSdanielk1977 static int createIncrblobChannel(
353b4e9af9fSdanielk1977   Tcl_Interp *interp,
354b4e9af9fSdanielk1977   SqliteDb *pDb,
355b4e9af9fSdanielk1977   const char *zDb,
356b4e9af9fSdanielk1977   const char *zTable,
357b4e9af9fSdanielk1977   const char *zColumn,
3588cbadb02Sdanielk1977   sqlite_int64 iRow,
3598cbadb02Sdanielk1977   int isReadonly
360b4e9af9fSdanielk1977 ){
361b4e9af9fSdanielk1977   IncrblobChannel *p;
3628cbadb02Sdanielk1977   sqlite3 *db = pDb->db;
363b4e9af9fSdanielk1977   sqlite3_blob *pBlob;
364b4e9af9fSdanielk1977   int rc;
3658cbadb02Sdanielk1977   int flags = TCL_READABLE|(isReadonly ? 0 : TCL_WRITABLE);
366b4e9af9fSdanielk1977 
367b4e9af9fSdanielk1977   /* This variable is used to name the channels: "incrblob_[incr count]" */
368b4e9af9fSdanielk1977   static int count = 0;
369b4e9af9fSdanielk1977   char zChannel[64];
370b4e9af9fSdanielk1977 
3718cbadb02Sdanielk1977   rc = sqlite3_blob_open(db, zDb, zTable, zColumn, iRow, !isReadonly, &pBlob);
372b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
373b4e9af9fSdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
374b4e9af9fSdanielk1977     return TCL_ERROR;
375b4e9af9fSdanielk1977   }
376b4e9af9fSdanielk1977 
377b4e9af9fSdanielk1977   p = (IncrblobChannel *)Tcl_Alloc(sizeof(IncrblobChannel));
378b4e9af9fSdanielk1977   p->iSeek = 0;
379b4e9af9fSdanielk1977   p->pBlob = pBlob;
380b4e9af9fSdanielk1977 
3815bb3eb9bSdrh   sqlite3_snprintf(sizeof(zChannel), zChannel, "incrblob_%d", ++count);
382d0441796Sdanielk1977   p->channel = Tcl_CreateChannel(&IncrblobChannelType, zChannel, p, flags);
383d0441796Sdanielk1977   Tcl_RegisterChannel(interp, p->channel);
384b4e9af9fSdanielk1977 
385d0441796Sdanielk1977   /* Link the new channel into the SqliteDb.pIncrblob list. */
386d0441796Sdanielk1977   p->pNext = pDb->pIncrblob;
387d0441796Sdanielk1977   p->pPrev = 0;
388d0441796Sdanielk1977   if( p->pNext ){
389d0441796Sdanielk1977     p->pNext->pPrev = p;
390d0441796Sdanielk1977   }
391d0441796Sdanielk1977   pDb->pIncrblob = p;
392d0441796Sdanielk1977   p->pDb = pDb;
393d0441796Sdanielk1977 
394d0441796Sdanielk1977   Tcl_SetResult(interp, (char *)Tcl_GetChannelName(p->channel), TCL_VOLATILE);
395b4e9af9fSdanielk1977   return TCL_OK;
396b4e9af9fSdanielk1977 }
39732a0d8bbSdanielk1977 #else  /* else clause for "#ifndef SQLITE_OMIT_INCRBLOB" */
39832a0d8bbSdanielk1977   #define closeIncrblobChannels(pDb)
39932a0d8bbSdanielk1977 #endif
400b4e9af9fSdanielk1977 
4016d31316cSdrh /*
402d1e4733dSdrh ** Look at the script prefix in pCmd.  We will be executing this script
403d1e4733dSdrh ** after first appending one or more arguments.  This routine analyzes
404d1e4733dSdrh ** the script to see if it is safe to use Tcl_EvalObjv() on the script
405d1e4733dSdrh ** rather than the more general Tcl_EvalEx().  Tcl_EvalObjv() is much
406d1e4733dSdrh ** faster.
407d1e4733dSdrh **
408d1e4733dSdrh ** Scripts that are safe to use with Tcl_EvalObjv() consists of a
409d1e4733dSdrh ** command name followed by zero or more arguments with no [...] or $
410d1e4733dSdrh ** or {...} or ; to be seen anywhere.  Most callback scripts consist
411d1e4733dSdrh ** of just a single procedure name and they meet this requirement.
412d1e4733dSdrh */
413d1e4733dSdrh static int safeToUseEvalObjv(Tcl_Interp *interp, Tcl_Obj *pCmd){
414d1e4733dSdrh   /* We could try to do something with Tcl_Parse().  But we will instead
415d1e4733dSdrh   ** just do a search for forbidden characters.  If any of the forbidden
416d1e4733dSdrh   ** characters appear in pCmd, we will report the string as unsafe.
417d1e4733dSdrh   */
418d1e4733dSdrh   const char *z;
419d1e4733dSdrh   int n;
420d1e4733dSdrh   z = Tcl_GetStringFromObj(pCmd, &n);
421d1e4733dSdrh   while( n-- > 0 ){
422d1e4733dSdrh     int c = *(z++);
423d1e4733dSdrh     if( c=='$' || c=='[' || c==';' ) return 0;
424d1e4733dSdrh   }
425d1e4733dSdrh   return 1;
426d1e4733dSdrh }
427d1e4733dSdrh 
428d1e4733dSdrh /*
429d1e4733dSdrh ** Find an SqlFunc structure with the given name.  Or create a new
430d1e4733dSdrh ** one if an existing one cannot be found.  Return a pointer to the
431d1e4733dSdrh ** structure.
432d1e4733dSdrh */
433d1e4733dSdrh static SqlFunc *findSqlFunc(SqliteDb *pDb, const char *zName){
434d1e4733dSdrh   SqlFunc *p, *pNew;
4350425f189Sdrh   int nName = strlen30(zName);
4360425f189Sdrh   pNew = (SqlFunc*)Tcl_Alloc( sizeof(*pNew) + nName + 1 );
437d1e4733dSdrh   pNew->zName = (char*)&pNew[1];
4380425f189Sdrh   memcpy(pNew->zName, zName, nName+1);
439d1e4733dSdrh   for(p=pDb->pFunc; p; p=p->pNext){
4400425f189Sdrh     if( sqlite3_stricmp(p->zName, pNew->zName)==0 ){
441d1e4733dSdrh       Tcl_Free((char*)pNew);
442d1e4733dSdrh       return p;
443d1e4733dSdrh     }
444d1e4733dSdrh   }
445d1e4733dSdrh   pNew->interp = pDb->interp;
446c45e6716Sdrh   pNew->pDb = pDb;
447d1e4733dSdrh   pNew->pScript = 0;
448d1e4733dSdrh   pNew->pNext = pDb->pFunc;
449d1e4733dSdrh   pDb->pFunc = pNew;
450d1e4733dSdrh   return pNew;
451d1e4733dSdrh }
452d1e4733dSdrh 
453d1e4733dSdrh /*
454c431fd55Sdan ** Free a single SqlPreparedStmt object.
455c431fd55Sdan */
456c431fd55Sdan static void dbFreeStmt(SqlPreparedStmt *pStmt){
457c431fd55Sdan #ifdef SQLITE_TEST
458c431fd55Sdan   if( sqlite3_sql(pStmt->pStmt)==0 ){
459c431fd55Sdan     Tcl_Free((char *)pStmt->zSql);
460c431fd55Sdan   }
461c431fd55Sdan #endif
462c431fd55Sdan   sqlite3_finalize(pStmt->pStmt);
463c431fd55Sdan   Tcl_Free((char *)pStmt);
464c431fd55Sdan }
465c431fd55Sdan 
466c431fd55Sdan /*
467fb7e7651Sdrh ** Finalize and free a list of prepared statements
468fb7e7651Sdrh */
469fb7e7651Sdrh static void flushStmtCache(SqliteDb *pDb){
470fb7e7651Sdrh   SqlPreparedStmt *pPreStmt;
471c431fd55Sdan   SqlPreparedStmt *pNext;
472fb7e7651Sdrh 
473c431fd55Sdan   for(pPreStmt = pDb->stmtList; pPreStmt; pPreStmt=pNext){
474c431fd55Sdan     pNext = pPreStmt->pNext;
475c431fd55Sdan     dbFreeStmt(pPreStmt);
476fb7e7651Sdrh   }
477fb7e7651Sdrh   pDb->nStmt = 0;
478fb7e7651Sdrh   pDb->stmtLast = 0;
479c431fd55Sdan   pDb->stmtList = 0;
480fb7e7651Sdrh }
481fb7e7651Sdrh 
482fb7e7651Sdrh /*
483895d7472Sdrh ** TCL calls this procedure when an sqlite3 database command is
484895d7472Sdrh ** deleted.
48575897234Sdrh */
48675897234Sdrh static void DbDeleteCmd(void *db){
487bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)db;
488fb7e7651Sdrh   flushStmtCache(pDb);
489d0441796Sdanielk1977   closeIncrblobChannels(pDb);
4906f8a503dSdanielk1977   sqlite3_close(pDb->db);
491cabb0819Sdrh   while( pDb->pFunc ){
492cabb0819Sdrh     SqlFunc *pFunc = pDb->pFunc;
493cabb0819Sdrh     pDb->pFunc = pFunc->pNext;
494c45e6716Sdrh     assert( pFunc->pDb==pDb );
495d1e4733dSdrh     Tcl_DecrRefCount(pFunc->pScript);
496cabb0819Sdrh     Tcl_Free((char*)pFunc);
497cabb0819Sdrh   }
4980202b29eSdanielk1977   while( pDb->pCollate ){
4990202b29eSdanielk1977     SqlCollate *pCollate = pDb->pCollate;
5000202b29eSdanielk1977     pDb->pCollate = pCollate->pNext;
5010202b29eSdanielk1977     Tcl_Free((char*)pCollate);
5020202b29eSdanielk1977   }
503bec3f402Sdrh   if( pDb->zBusy ){
504bec3f402Sdrh     Tcl_Free(pDb->zBusy);
505bec3f402Sdrh   }
506b5a20d3cSdrh   if( pDb->zTrace ){
507b5a20d3cSdrh     Tcl_Free(pDb->zTrace);
5080d1a643aSdrh   }
50919e2d37fSdrh   if( pDb->zProfile ){
51019e2d37fSdrh     Tcl_Free(pDb->zProfile);
51119e2d37fSdrh   }
512e22a334bSdrh   if( pDb->zAuth ){
513e22a334bSdrh     Tcl_Free(pDb->zAuth);
514e22a334bSdrh   }
51555c45f2eSdanielk1977   if( pDb->zNull ){
51655c45f2eSdanielk1977     Tcl_Free(pDb->zNull);
51755c45f2eSdanielk1977   }
51894eb6a14Sdanielk1977   if( pDb->pUpdateHook ){
51994eb6a14Sdanielk1977     Tcl_DecrRefCount(pDb->pUpdateHook);
52094eb6a14Sdanielk1977   }
52171fd80bfSdanielk1977   if( pDb->pRollbackHook ){
52271fd80bfSdanielk1977     Tcl_DecrRefCount(pDb->pRollbackHook);
52371fd80bfSdanielk1977   }
5245def0843Sdrh   if( pDb->pWalHook ){
5255def0843Sdrh     Tcl_DecrRefCount(pDb->pWalHook);
5268d22a174Sdan   }
52794eb6a14Sdanielk1977   if( pDb->pCollateNeeded ){
52894eb6a14Sdanielk1977     Tcl_DecrRefCount(pDb->pCollateNeeded);
52994eb6a14Sdanielk1977   }
530bec3f402Sdrh   Tcl_Free((char*)pDb);
531bec3f402Sdrh }
532bec3f402Sdrh 
533bec3f402Sdrh /*
534bec3f402Sdrh ** This routine is called when a database file is locked while trying
535bec3f402Sdrh ** to execute SQL.
536bec3f402Sdrh */
5372a764eb0Sdanielk1977 static int DbBusyHandler(void *cd, int nTries){
538bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)cd;
539bec3f402Sdrh   int rc;
540bec3f402Sdrh   char zVal[30];
541bec3f402Sdrh 
5425bb3eb9bSdrh   sqlite3_snprintf(sizeof(zVal), zVal, "%d", nTries);
543d1e4733dSdrh   rc = Tcl_VarEval(pDb->interp, pDb->zBusy, " ", zVal, (char*)0);
544bec3f402Sdrh   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
545bec3f402Sdrh     return 0;
546bec3f402Sdrh   }
547bec3f402Sdrh   return 1;
54875897234Sdrh }
54975897234Sdrh 
55026e4a8b1Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK
55175897234Sdrh /*
552348bb5d6Sdanielk1977 ** This routine is invoked as the 'progress callback' for the database.
553348bb5d6Sdanielk1977 */
554348bb5d6Sdanielk1977 static int DbProgressHandler(void *cd){
555348bb5d6Sdanielk1977   SqliteDb *pDb = (SqliteDb*)cd;
556348bb5d6Sdanielk1977   int rc;
557348bb5d6Sdanielk1977 
558348bb5d6Sdanielk1977   assert( pDb->zProgress );
559348bb5d6Sdanielk1977   rc = Tcl_Eval(pDb->interp, pDb->zProgress);
560348bb5d6Sdanielk1977   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
561348bb5d6Sdanielk1977     return 1;
562348bb5d6Sdanielk1977   }
563348bb5d6Sdanielk1977   return 0;
564348bb5d6Sdanielk1977 }
56526e4a8b1Sdrh #endif
566348bb5d6Sdanielk1977 
567d1167393Sdrh #ifndef SQLITE_OMIT_TRACE
568348bb5d6Sdanielk1977 /*
569b5a20d3cSdrh ** This routine is called by the SQLite trace handler whenever a new
570b5a20d3cSdrh ** block of SQL is executed.  The TCL script in pDb->zTrace is executed.
5710d1a643aSdrh */
572b5a20d3cSdrh static void DbTraceHandler(void *cd, const char *zSql){
5730d1a643aSdrh   SqliteDb *pDb = (SqliteDb*)cd;
574b5a20d3cSdrh   Tcl_DString str;
5750d1a643aSdrh 
576b5a20d3cSdrh   Tcl_DStringInit(&str);
577b5a20d3cSdrh   Tcl_DStringAppend(&str, pDb->zTrace, -1);
578b5a20d3cSdrh   Tcl_DStringAppendElement(&str, zSql);
579b5a20d3cSdrh   Tcl_Eval(pDb->interp, Tcl_DStringValue(&str));
580b5a20d3cSdrh   Tcl_DStringFree(&str);
581b5a20d3cSdrh   Tcl_ResetResult(pDb->interp);
5820d1a643aSdrh }
583d1167393Sdrh #endif
5840d1a643aSdrh 
585d1167393Sdrh #ifndef SQLITE_OMIT_TRACE
5860d1a643aSdrh /*
58719e2d37fSdrh ** This routine is called by the SQLite profile handler after a statement
58819e2d37fSdrh ** SQL has executed.  The TCL script in pDb->zProfile is evaluated.
58919e2d37fSdrh */
59019e2d37fSdrh static void DbProfileHandler(void *cd, const char *zSql, sqlite_uint64 tm){
59119e2d37fSdrh   SqliteDb *pDb = (SqliteDb*)cd;
59219e2d37fSdrh   Tcl_DString str;
59319e2d37fSdrh   char zTm[100];
59419e2d37fSdrh 
59519e2d37fSdrh   sqlite3_snprintf(sizeof(zTm)-1, zTm, "%lld", tm);
59619e2d37fSdrh   Tcl_DStringInit(&str);
59719e2d37fSdrh   Tcl_DStringAppend(&str, pDb->zProfile, -1);
59819e2d37fSdrh   Tcl_DStringAppendElement(&str, zSql);
59919e2d37fSdrh   Tcl_DStringAppendElement(&str, zTm);
60019e2d37fSdrh   Tcl_Eval(pDb->interp, Tcl_DStringValue(&str));
60119e2d37fSdrh   Tcl_DStringFree(&str);
60219e2d37fSdrh   Tcl_ResetResult(pDb->interp);
60319e2d37fSdrh }
604d1167393Sdrh #endif
60519e2d37fSdrh 
60619e2d37fSdrh /*
607aa940eacSdrh ** This routine is called when a transaction is committed.  The
608aa940eacSdrh ** TCL script in pDb->zCommit is executed.  If it returns non-zero or
609aa940eacSdrh ** if it throws an exception, the transaction is rolled back instead
610aa940eacSdrh ** of being committed.
611aa940eacSdrh */
612aa940eacSdrh static int DbCommitHandler(void *cd){
613aa940eacSdrh   SqliteDb *pDb = (SqliteDb*)cd;
614aa940eacSdrh   int rc;
615aa940eacSdrh 
616aa940eacSdrh   rc = Tcl_Eval(pDb->interp, pDb->zCommit);
617aa940eacSdrh   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
618aa940eacSdrh     return 1;
619aa940eacSdrh   }
620aa940eacSdrh   return 0;
621aa940eacSdrh }
622aa940eacSdrh 
62371fd80bfSdanielk1977 static void DbRollbackHandler(void *clientData){
62471fd80bfSdanielk1977   SqliteDb *pDb = (SqliteDb*)clientData;
62571fd80bfSdanielk1977   assert(pDb->pRollbackHook);
62671fd80bfSdanielk1977   if( TCL_OK!=Tcl_EvalObjEx(pDb->interp, pDb->pRollbackHook, 0) ){
62771fd80bfSdanielk1977     Tcl_BackgroundError(pDb->interp);
62871fd80bfSdanielk1977   }
62971fd80bfSdanielk1977 }
63071fd80bfSdanielk1977 
6315def0843Sdrh /*
6325def0843Sdrh ** This procedure handles wal_hook callbacks.
6335def0843Sdrh */
6345def0843Sdrh static int DbWalHandler(
6358d22a174Sdan   void *clientData,
6368d22a174Sdan   sqlite3 *db,
6378d22a174Sdan   const char *zDb,
6388d22a174Sdan   int nEntry
6398d22a174Sdan ){
6405def0843Sdrh   int ret = SQLITE_OK;
6418d22a174Sdan   Tcl_Obj *p;
6428d22a174Sdan   SqliteDb *pDb = (SqliteDb*)clientData;
6438d22a174Sdan   Tcl_Interp *interp = pDb->interp;
6445def0843Sdrh   assert(pDb->pWalHook);
6458d22a174Sdan 
6466e45e0c8Sdan   assert( db==pDb->db );
6475def0843Sdrh   p = Tcl_DuplicateObj(pDb->pWalHook);
6488d22a174Sdan   Tcl_IncrRefCount(p);
6498d22a174Sdan   Tcl_ListObjAppendElement(interp, p, Tcl_NewStringObj(zDb, -1));
6508d22a174Sdan   Tcl_ListObjAppendElement(interp, p, Tcl_NewIntObj(nEntry));
6518d22a174Sdan   if( TCL_OK!=Tcl_EvalObjEx(interp, p, 0)
6528d22a174Sdan    || TCL_OK!=Tcl_GetIntFromObj(interp, Tcl_GetObjResult(interp), &ret)
6538d22a174Sdan   ){
6548d22a174Sdan     Tcl_BackgroundError(interp);
6558d22a174Sdan   }
6568d22a174Sdan   Tcl_DecrRefCount(p);
6578d22a174Sdan 
6588d22a174Sdan   return ret;
6598d22a174Sdan }
6608d22a174Sdan 
661bcf4f484Sdrh #if defined(SQLITE_TEST) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
662404ca075Sdanielk1977 static void setTestUnlockNotifyVars(Tcl_Interp *interp, int iArg, int nArg){
663404ca075Sdanielk1977   char zBuf[64];
66465545b59Sdrh   sqlite3_snprintf(sizeof(zBuf), zBuf, "%d", iArg);
665404ca075Sdanielk1977   Tcl_SetVar(interp, "sqlite_unlock_notify_arg", zBuf, TCL_GLOBAL_ONLY);
66665545b59Sdrh   sqlite3_snprintf(sizeof(zBuf), zBuf, "%d", nArg);
667404ca075Sdanielk1977   Tcl_SetVar(interp, "sqlite_unlock_notify_argcount", zBuf, TCL_GLOBAL_ONLY);
668404ca075Sdanielk1977 }
669404ca075Sdanielk1977 #else
670404ca075Sdanielk1977 # define setTestUnlockNotifyVars(x,y,z)
671404ca075Sdanielk1977 #endif
672404ca075Sdanielk1977 
67369910da9Sdrh #ifdef SQLITE_ENABLE_UNLOCK_NOTIFY
674404ca075Sdanielk1977 static void DbUnlockNotify(void **apArg, int nArg){
675404ca075Sdanielk1977   int i;
676404ca075Sdanielk1977   for(i=0; i<nArg; i++){
677404ca075Sdanielk1977     const int flags = (TCL_EVAL_GLOBAL|TCL_EVAL_DIRECT);
678404ca075Sdanielk1977     SqliteDb *pDb = (SqliteDb *)apArg[i];
679404ca075Sdanielk1977     setTestUnlockNotifyVars(pDb->interp, i, nArg);
680404ca075Sdanielk1977     assert( pDb->pUnlockNotify);
681404ca075Sdanielk1977     Tcl_EvalObjEx(pDb->interp, pDb->pUnlockNotify, flags);
682404ca075Sdanielk1977     Tcl_DecrRefCount(pDb->pUnlockNotify);
683404ca075Sdanielk1977     pDb->pUnlockNotify = 0;
684404ca075Sdanielk1977   }
685404ca075Sdanielk1977 }
68669910da9Sdrh #endif
687404ca075Sdanielk1977 
68894eb6a14Sdanielk1977 static void DbUpdateHandler(
68994eb6a14Sdanielk1977   void *p,
69094eb6a14Sdanielk1977   int op,
69194eb6a14Sdanielk1977   const char *zDb,
69294eb6a14Sdanielk1977   const char *zTbl,
69394eb6a14Sdanielk1977   sqlite_int64 rowid
69494eb6a14Sdanielk1977 ){
69594eb6a14Sdanielk1977   SqliteDb *pDb = (SqliteDb *)p;
69694eb6a14Sdanielk1977   Tcl_Obj *pCmd;
69794eb6a14Sdanielk1977 
69894eb6a14Sdanielk1977   assert( pDb->pUpdateHook );
69994eb6a14Sdanielk1977   assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE );
70094eb6a14Sdanielk1977 
70194eb6a14Sdanielk1977   pCmd = Tcl_DuplicateObj(pDb->pUpdateHook);
70294eb6a14Sdanielk1977   Tcl_IncrRefCount(pCmd);
70394eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(
70494eb6a14Sdanielk1977     ( (op==SQLITE_INSERT)?"INSERT":(op==SQLITE_UPDATE)?"UPDATE":"DELETE"), -1));
70594eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zDb, -1));
70694eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zTbl, -1));
70794eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewWideIntObj(rowid));
70894eb6a14Sdanielk1977   Tcl_EvalObjEx(pDb->interp, pCmd, TCL_EVAL_DIRECT);
709efdde169Sdrh   Tcl_DecrRefCount(pCmd);
71094eb6a14Sdanielk1977 }
71194eb6a14Sdanielk1977 
7127cedc8d4Sdanielk1977 static void tclCollateNeeded(
7137cedc8d4Sdanielk1977   void *pCtx,
7149bb575fdSdrh   sqlite3 *db,
7157cedc8d4Sdanielk1977   int enc,
7167cedc8d4Sdanielk1977   const char *zName
7177cedc8d4Sdanielk1977 ){
7187cedc8d4Sdanielk1977   SqliteDb *pDb = (SqliteDb *)pCtx;
7197cedc8d4Sdanielk1977   Tcl_Obj *pScript = Tcl_DuplicateObj(pDb->pCollateNeeded);
7207cedc8d4Sdanielk1977   Tcl_IncrRefCount(pScript);
7217cedc8d4Sdanielk1977   Tcl_ListObjAppendElement(0, pScript, Tcl_NewStringObj(zName, -1));
7227cedc8d4Sdanielk1977   Tcl_EvalObjEx(pDb->interp, pScript, 0);
7237cedc8d4Sdanielk1977   Tcl_DecrRefCount(pScript);
7247cedc8d4Sdanielk1977 }
7257cedc8d4Sdanielk1977 
726aa940eacSdrh /*
7270202b29eSdanielk1977 ** This routine is called to evaluate an SQL collation function implemented
7280202b29eSdanielk1977 ** using TCL script.
7290202b29eSdanielk1977 */
7300202b29eSdanielk1977 static int tclSqlCollate(
7310202b29eSdanielk1977   void *pCtx,
7320202b29eSdanielk1977   int nA,
7330202b29eSdanielk1977   const void *zA,
7340202b29eSdanielk1977   int nB,
7350202b29eSdanielk1977   const void *zB
7360202b29eSdanielk1977 ){
7370202b29eSdanielk1977   SqlCollate *p = (SqlCollate *)pCtx;
7380202b29eSdanielk1977   Tcl_Obj *pCmd;
7390202b29eSdanielk1977 
7400202b29eSdanielk1977   pCmd = Tcl_NewStringObj(p->zScript, -1);
7410202b29eSdanielk1977   Tcl_IncrRefCount(pCmd);
7420202b29eSdanielk1977   Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zA, nA));
7430202b29eSdanielk1977   Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zB, nB));
744d1e4733dSdrh   Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT);
7450202b29eSdanielk1977   Tcl_DecrRefCount(pCmd);
7460202b29eSdanielk1977   return (atoi(Tcl_GetStringResult(p->interp)));
7470202b29eSdanielk1977 }
7480202b29eSdanielk1977 
7490202b29eSdanielk1977 /*
750cabb0819Sdrh ** This routine is called to evaluate an SQL function implemented
751cabb0819Sdrh ** using TCL script.
752cabb0819Sdrh */
7530ae8b831Sdanielk1977 static void tclSqlFunc(sqlite3_context *context, int argc, sqlite3_value**argv){
7546f8a503dSdanielk1977   SqlFunc *p = sqlite3_user_data(context);
755d1e4733dSdrh   Tcl_Obj *pCmd;
756cabb0819Sdrh   int i;
757cabb0819Sdrh   int rc;
758cabb0819Sdrh 
759d1e4733dSdrh   if( argc==0 ){
760d1e4733dSdrh     /* If there are no arguments to the function, call Tcl_EvalObjEx on the
761d1e4733dSdrh     ** script object directly.  This allows the TCL compiler to generate
762d1e4733dSdrh     ** bytecode for the command on the first invocation and thus make
763d1e4733dSdrh     ** subsequent invocations much faster. */
764d1e4733dSdrh     pCmd = p->pScript;
765d1e4733dSdrh     Tcl_IncrRefCount(pCmd);
766d1e4733dSdrh     rc = Tcl_EvalObjEx(p->interp, pCmd, 0);
767d1e4733dSdrh     Tcl_DecrRefCount(pCmd);
76851ad0ecdSdanielk1977   }else{
769d1e4733dSdrh     /* If there are arguments to the function, make a shallow copy of the
770d1e4733dSdrh     ** script object, lappend the arguments, then evaluate the copy.
771d1e4733dSdrh     **
77260ec914cSpeter.d.reid     ** By "shallow" copy, we mean only the outer list Tcl_Obj is duplicated.
773d1e4733dSdrh     ** The new Tcl_Obj contains pointers to the original list elements.
774d1e4733dSdrh     ** That way, when Tcl_EvalObjv() is run and shimmers the first element
775d1e4733dSdrh     ** of the list to tclCmdNameType, that alternate representation will
776d1e4733dSdrh     ** be preserved and reused on the next invocation.
777d1e4733dSdrh     */
778d1e4733dSdrh     Tcl_Obj **aArg;
779d1e4733dSdrh     int nArg;
780d1e4733dSdrh     if( Tcl_ListObjGetElements(p->interp, p->pScript, &nArg, &aArg) ){
781d1e4733dSdrh       sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
782d1e4733dSdrh       return;
783d1e4733dSdrh     }
784d1e4733dSdrh     pCmd = Tcl_NewListObj(nArg, aArg);
785d1e4733dSdrh     Tcl_IncrRefCount(pCmd);
786d1e4733dSdrh     for(i=0; i<argc; i++){
787d1e4733dSdrh       sqlite3_value *pIn = argv[i];
788d1e4733dSdrh       Tcl_Obj *pVal;
789d1e4733dSdrh 
790d1e4733dSdrh       /* Set pVal to contain the i'th column of this row. */
791d1e4733dSdrh       switch( sqlite3_value_type(pIn) ){
792d1e4733dSdrh         case SQLITE_BLOB: {
793d1e4733dSdrh           int bytes = sqlite3_value_bytes(pIn);
794d1e4733dSdrh           pVal = Tcl_NewByteArrayObj(sqlite3_value_blob(pIn), bytes);
795d1e4733dSdrh           break;
796d1e4733dSdrh         }
797d1e4733dSdrh         case SQLITE_INTEGER: {
798d1e4733dSdrh           sqlite_int64 v = sqlite3_value_int64(pIn);
799d1e4733dSdrh           if( v>=-2147483647 && v<=2147483647 ){
8007fd33929Sdrh             pVal = Tcl_NewIntObj((int)v);
801d1e4733dSdrh           }else{
802d1e4733dSdrh             pVal = Tcl_NewWideIntObj(v);
803d1e4733dSdrh           }
804d1e4733dSdrh           break;
805d1e4733dSdrh         }
806d1e4733dSdrh         case SQLITE_FLOAT: {
807d1e4733dSdrh           double r = sqlite3_value_double(pIn);
808d1e4733dSdrh           pVal = Tcl_NewDoubleObj(r);
809d1e4733dSdrh           break;
810d1e4733dSdrh         }
811d1e4733dSdrh         case SQLITE_NULL: {
812c45e6716Sdrh           pVal = Tcl_NewStringObj(p->pDb->zNull, -1);
813d1e4733dSdrh           break;
814d1e4733dSdrh         }
815d1e4733dSdrh         default: {
816d1e4733dSdrh           int bytes = sqlite3_value_bytes(pIn);
81700fd957bSdanielk1977           pVal = Tcl_NewStringObj((char *)sqlite3_value_text(pIn), bytes);
818d1e4733dSdrh           break;
81951ad0ecdSdanielk1977         }
820cabb0819Sdrh       }
821d1e4733dSdrh       rc = Tcl_ListObjAppendElement(p->interp, pCmd, pVal);
822d1e4733dSdrh       if( rc ){
823d1e4733dSdrh         Tcl_DecrRefCount(pCmd);
824d1e4733dSdrh         sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
825d1e4733dSdrh         return;
826d1e4733dSdrh       }
827d1e4733dSdrh     }
828d1e4733dSdrh     if( !p->useEvalObjv ){
829d1e4733dSdrh       /* Tcl_EvalObjEx() will automatically call Tcl_EvalObjv() if pCmd
830d1e4733dSdrh       ** is a list without a string representation.  To prevent this from
831d1e4733dSdrh       ** happening, make sure pCmd has a valid string representation */
832d1e4733dSdrh       Tcl_GetString(pCmd);
833d1e4733dSdrh     }
834d1e4733dSdrh     rc = Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT);
835d1e4733dSdrh     Tcl_DecrRefCount(pCmd);
836d1e4733dSdrh   }
837562e8d3cSdanielk1977 
838c7f269d5Sdrh   if( rc && rc!=TCL_RETURN ){
8397e18c259Sdanielk1977     sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
840cabb0819Sdrh   }else{
841c7f269d5Sdrh     Tcl_Obj *pVar = Tcl_GetObjResult(p->interp);
842c7f269d5Sdrh     int n;
843c7f269d5Sdrh     u8 *data;
8444a4c11aaSdan     const char *zType = (pVar->typePtr ? pVar->typePtr->name : "");
845c7f269d5Sdrh     char c = zType[0];
846df0bddaeSdrh     if( c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0 ){
847d1e4733dSdrh       /* Only return a BLOB type if the Tcl variable is a bytearray and
848df0bddaeSdrh       ** has no string representation. */
849c7f269d5Sdrh       data = Tcl_GetByteArrayFromObj(pVar, &n);
850c7f269d5Sdrh       sqlite3_result_blob(context, data, n, SQLITE_TRANSIENT);
851985e0c63Sdrh     }else if( c=='b' && strcmp(zType,"boolean")==0 ){
852c7f269d5Sdrh       Tcl_GetIntFromObj(0, pVar, &n);
853c7f269d5Sdrh       sqlite3_result_int(context, n);
854c7f269d5Sdrh     }else if( c=='d' && strcmp(zType,"double")==0 ){
855c7f269d5Sdrh       double r;
856c7f269d5Sdrh       Tcl_GetDoubleFromObj(0, pVar, &r);
857c7f269d5Sdrh       sqlite3_result_double(context, r);
858985e0c63Sdrh     }else if( (c=='w' && strcmp(zType,"wideInt")==0) ||
859985e0c63Sdrh           (c=='i' && strcmp(zType,"int")==0) ){
860df0bddaeSdrh       Tcl_WideInt v;
861df0bddaeSdrh       Tcl_GetWideIntFromObj(0, pVar, &v);
862df0bddaeSdrh       sqlite3_result_int64(context, v);
863c7f269d5Sdrh     }else{
86400fd957bSdanielk1977       data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n);
86500fd957bSdanielk1977       sqlite3_result_text(context, (char *)data, n, SQLITE_TRANSIENT);
866c7f269d5Sdrh     }
867cabb0819Sdrh   }
868cabb0819Sdrh }
869895d7472Sdrh 
870e22a334bSdrh #ifndef SQLITE_OMIT_AUTHORIZATION
871e22a334bSdrh /*
872e22a334bSdrh ** This is the authentication function.  It appends the authentication
873e22a334bSdrh ** type code and the two arguments to zCmd[] then invokes the result
874e22a334bSdrh ** on the interpreter.  The reply is examined to determine if the
875e22a334bSdrh ** authentication fails or succeeds.
876e22a334bSdrh */
877e22a334bSdrh static int auth_callback(
878e22a334bSdrh   void *pArg,
879e22a334bSdrh   int code,
880e22a334bSdrh   const char *zArg1,
881e22a334bSdrh   const char *zArg2,
882e22a334bSdrh   const char *zArg3,
883e22a334bSdrh   const char *zArg4
88432c6a48bSdrh #ifdef SQLITE_USER_AUTHENTICATION
88532c6a48bSdrh   ,const char *zArg5
88632c6a48bSdrh #endif
887e22a334bSdrh ){
8886ef5e12eSmistachkin   const char *zCode;
889e22a334bSdrh   Tcl_DString str;
890e22a334bSdrh   int rc;
891e22a334bSdrh   const char *zReply;
892e22a334bSdrh   SqliteDb *pDb = (SqliteDb*)pArg;
8931f1549f8Sdrh   if( pDb->disableAuth ) return SQLITE_OK;
894e22a334bSdrh 
895e22a334bSdrh   switch( code ){
896e22a334bSdrh     case SQLITE_COPY              : zCode="SQLITE_COPY"; break;
897e22a334bSdrh     case SQLITE_CREATE_INDEX      : zCode="SQLITE_CREATE_INDEX"; break;
898e22a334bSdrh     case SQLITE_CREATE_TABLE      : zCode="SQLITE_CREATE_TABLE"; break;
899e22a334bSdrh     case SQLITE_CREATE_TEMP_INDEX : zCode="SQLITE_CREATE_TEMP_INDEX"; break;
900e22a334bSdrh     case SQLITE_CREATE_TEMP_TABLE : zCode="SQLITE_CREATE_TEMP_TABLE"; break;
901e22a334bSdrh     case SQLITE_CREATE_TEMP_TRIGGER: zCode="SQLITE_CREATE_TEMP_TRIGGER"; break;
902e22a334bSdrh     case SQLITE_CREATE_TEMP_VIEW  : zCode="SQLITE_CREATE_TEMP_VIEW"; break;
903e22a334bSdrh     case SQLITE_CREATE_TRIGGER    : zCode="SQLITE_CREATE_TRIGGER"; break;
904e22a334bSdrh     case SQLITE_CREATE_VIEW       : zCode="SQLITE_CREATE_VIEW"; break;
905e22a334bSdrh     case SQLITE_DELETE            : zCode="SQLITE_DELETE"; break;
906e22a334bSdrh     case SQLITE_DROP_INDEX        : zCode="SQLITE_DROP_INDEX"; break;
907e22a334bSdrh     case SQLITE_DROP_TABLE        : zCode="SQLITE_DROP_TABLE"; break;
908e22a334bSdrh     case SQLITE_DROP_TEMP_INDEX   : zCode="SQLITE_DROP_TEMP_INDEX"; break;
909e22a334bSdrh     case SQLITE_DROP_TEMP_TABLE   : zCode="SQLITE_DROP_TEMP_TABLE"; break;
910e22a334bSdrh     case SQLITE_DROP_TEMP_TRIGGER : zCode="SQLITE_DROP_TEMP_TRIGGER"; break;
911e22a334bSdrh     case SQLITE_DROP_TEMP_VIEW    : zCode="SQLITE_DROP_TEMP_VIEW"; break;
912e22a334bSdrh     case SQLITE_DROP_TRIGGER      : zCode="SQLITE_DROP_TRIGGER"; break;
913e22a334bSdrh     case SQLITE_DROP_VIEW         : zCode="SQLITE_DROP_VIEW"; break;
914e22a334bSdrh     case SQLITE_INSERT            : zCode="SQLITE_INSERT"; break;
915e22a334bSdrh     case SQLITE_PRAGMA            : zCode="SQLITE_PRAGMA"; break;
916e22a334bSdrh     case SQLITE_READ              : zCode="SQLITE_READ"; break;
917e22a334bSdrh     case SQLITE_SELECT            : zCode="SQLITE_SELECT"; break;
918e22a334bSdrh     case SQLITE_TRANSACTION       : zCode="SQLITE_TRANSACTION"; break;
919e22a334bSdrh     case SQLITE_UPDATE            : zCode="SQLITE_UPDATE"; break;
92081e293b4Sdrh     case SQLITE_ATTACH            : zCode="SQLITE_ATTACH"; break;
92181e293b4Sdrh     case SQLITE_DETACH            : zCode="SQLITE_DETACH"; break;
9221c8c23ccSdanielk1977     case SQLITE_ALTER_TABLE       : zCode="SQLITE_ALTER_TABLE"; break;
9231d54df88Sdanielk1977     case SQLITE_REINDEX           : zCode="SQLITE_REINDEX"; break;
924e6e04969Sdrh     case SQLITE_ANALYZE           : zCode="SQLITE_ANALYZE"; break;
925f1a381e7Sdanielk1977     case SQLITE_CREATE_VTABLE     : zCode="SQLITE_CREATE_VTABLE"; break;
926f1a381e7Sdanielk1977     case SQLITE_DROP_VTABLE       : zCode="SQLITE_DROP_VTABLE"; break;
9275169bbc6Sdrh     case SQLITE_FUNCTION          : zCode="SQLITE_FUNCTION"; break;
928ab9b703fSdanielk1977     case SQLITE_SAVEPOINT         : zCode="SQLITE_SAVEPOINT"; break;
92965a2aaa6Sdrh     case SQLITE_RECURSIVE         : zCode="SQLITE_RECURSIVE"; break;
930e22a334bSdrh     default                       : zCode="????"; break;
931e22a334bSdrh   }
932e22a334bSdrh   Tcl_DStringInit(&str);
933e22a334bSdrh   Tcl_DStringAppend(&str, pDb->zAuth, -1);
934e22a334bSdrh   Tcl_DStringAppendElement(&str, zCode);
935e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg1 ? zArg1 : "");
936e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg2 ? zArg2 : "");
937e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg3 ? zArg3 : "");
938e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg4 ? zArg4 : "");
93932c6a48bSdrh #ifdef SQLITE_USER_AUTHENTICATION
94032c6a48bSdrh   Tcl_DStringAppendElement(&str, zArg5 ? zArg5 : "");
94132c6a48bSdrh #endif
942e22a334bSdrh   rc = Tcl_GlobalEval(pDb->interp, Tcl_DStringValue(&str));
943e22a334bSdrh   Tcl_DStringFree(&str);
944b07028f7Sdrh   zReply = rc==TCL_OK ? Tcl_GetStringResult(pDb->interp) : "SQLITE_DENY";
945e22a334bSdrh   if( strcmp(zReply,"SQLITE_OK")==0 ){
946e22a334bSdrh     rc = SQLITE_OK;
947e22a334bSdrh   }else if( strcmp(zReply,"SQLITE_DENY")==0 ){
948e22a334bSdrh     rc = SQLITE_DENY;
949e22a334bSdrh   }else if( strcmp(zReply,"SQLITE_IGNORE")==0 ){
950e22a334bSdrh     rc = SQLITE_IGNORE;
951e22a334bSdrh   }else{
952e22a334bSdrh     rc = 999;
953e22a334bSdrh   }
954e22a334bSdrh   return rc;
955e22a334bSdrh }
956e22a334bSdrh #endif /* SQLITE_OMIT_AUTHORIZATION */
957cabb0819Sdrh 
958cabb0819Sdrh /*
9591067fe11Stpoindex ** This routine reads a line of text from FILE in, stores
9601067fe11Stpoindex ** the text in memory obtained from malloc() and returns a pointer
9611067fe11Stpoindex ** to the text.  NULL is returned at end of file, or if malloc()
9621067fe11Stpoindex ** fails.
9631067fe11Stpoindex **
9641067fe11Stpoindex ** The interface is like "readline" but no command-line editing
9651067fe11Stpoindex ** is done.
9661067fe11Stpoindex **
9671067fe11Stpoindex ** copied from shell.c from '.import' command
9681067fe11Stpoindex */
9691067fe11Stpoindex static char *local_getline(char *zPrompt, FILE *in){
9701067fe11Stpoindex   char *zLine;
9711067fe11Stpoindex   int nLine;
9721067fe11Stpoindex   int n;
9731067fe11Stpoindex 
9741067fe11Stpoindex   nLine = 100;
9751067fe11Stpoindex   zLine = malloc( nLine );
9761067fe11Stpoindex   if( zLine==0 ) return 0;
9771067fe11Stpoindex   n = 0;
978b07028f7Sdrh   while( 1 ){
9791067fe11Stpoindex     if( n+100>nLine ){
9801067fe11Stpoindex       nLine = nLine*2 + 100;
9811067fe11Stpoindex       zLine = realloc(zLine, nLine);
9821067fe11Stpoindex       if( zLine==0 ) return 0;
9831067fe11Stpoindex     }
9841067fe11Stpoindex     if( fgets(&zLine[n], nLine - n, in)==0 ){
9851067fe11Stpoindex       if( n==0 ){
9861067fe11Stpoindex         free(zLine);
9871067fe11Stpoindex         return 0;
9881067fe11Stpoindex       }
9891067fe11Stpoindex       zLine[n] = 0;
9901067fe11Stpoindex       break;
9911067fe11Stpoindex     }
9921067fe11Stpoindex     while( zLine[n] ){ n++; }
9931067fe11Stpoindex     if( n>0 && zLine[n-1]=='\n' ){
9941067fe11Stpoindex       n--;
9951067fe11Stpoindex       zLine[n] = 0;
996b07028f7Sdrh       break;
9971067fe11Stpoindex     }
9981067fe11Stpoindex   }
9991067fe11Stpoindex   zLine = realloc( zLine, n+1 );
10001067fe11Stpoindex   return zLine;
10011067fe11Stpoindex }
10021067fe11Stpoindex 
10038e556520Sdanielk1977 
10048e556520Sdanielk1977 /*
10054a4c11aaSdan ** This function is part of the implementation of the command:
10068e556520Sdanielk1977 **
10074a4c11aaSdan **   $db transaction [-deferred|-immediate|-exclusive] SCRIPT
10088e556520Sdanielk1977 **
10094a4c11aaSdan ** It is invoked after evaluating the script SCRIPT to commit or rollback
10104a4c11aaSdan ** the transaction or savepoint opened by the [transaction] command.
10114a4c11aaSdan */
10124a4c11aaSdan static int DbTransPostCmd(
10134a4c11aaSdan   ClientData data[],                   /* data[0] is the Sqlite3Db* for $db */
10144a4c11aaSdan   Tcl_Interp *interp,                  /* Tcl interpreter */
10154a4c11aaSdan   int result                           /* Result of evaluating SCRIPT */
10164a4c11aaSdan ){
10176ef5e12eSmistachkin   static const char *const azEnd[] = {
10184a4c11aaSdan     "RELEASE _tcl_transaction",        /* rc==TCL_ERROR, nTransaction!=0 */
10194a4c11aaSdan     "COMMIT",                          /* rc!=TCL_ERROR, nTransaction==0 */
10204a4c11aaSdan     "ROLLBACK TO _tcl_transaction ; RELEASE _tcl_transaction",
10214a4c11aaSdan     "ROLLBACK"                         /* rc==TCL_ERROR, nTransaction==0 */
10224a4c11aaSdan   };
10234a4c11aaSdan   SqliteDb *pDb = (SqliteDb*)data[0];
10244a4c11aaSdan   int rc = result;
10254a4c11aaSdan   const char *zEnd;
10264a4c11aaSdan 
10274a4c11aaSdan   pDb->nTransaction--;
10284a4c11aaSdan   zEnd = azEnd[(rc==TCL_ERROR)*2 + (pDb->nTransaction==0)];
10294a4c11aaSdan 
10304a4c11aaSdan   pDb->disableAuth++;
10314a4c11aaSdan   if( sqlite3_exec(pDb->db, zEnd, 0, 0, 0) ){
10324a4c11aaSdan       /* This is a tricky scenario to handle. The most likely cause of an
10334a4c11aaSdan       ** error is that the exec() above was an attempt to commit the
10344a4c11aaSdan       ** top-level transaction that returned SQLITE_BUSY. Or, less likely,
103548864df9Smistachkin       ** that an IO-error has occurred. In either case, throw a Tcl exception
10364a4c11aaSdan       ** and try to rollback the transaction.
10374a4c11aaSdan       **
10384a4c11aaSdan       ** But it could also be that the user executed one or more BEGIN,
10394a4c11aaSdan       ** COMMIT, SAVEPOINT, RELEASE or ROLLBACK commands that are confusing
10404a4c11aaSdan       ** this method's logic. Not clear how this would be best handled.
10414a4c11aaSdan       */
10424a4c11aaSdan     if( rc!=TCL_ERROR ){
1043a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
10444a4c11aaSdan       rc = TCL_ERROR;
10454a4c11aaSdan     }
10464a4c11aaSdan     sqlite3_exec(pDb->db, "ROLLBACK", 0, 0, 0);
10474a4c11aaSdan   }
10484a4c11aaSdan   pDb->disableAuth--;
10494a4c11aaSdan 
10504a4c11aaSdan   return rc;
10514a4c11aaSdan }
10524a4c11aaSdan 
10534a4c11aaSdan /*
1054c431fd55Sdan ** Unless SQLITE_TEST is defined, this function is a simple wrapper around
1055c431fd55Sdan ** sqlite3_prepare_v2(). If SQLITE_TEST is defined, then it uses either
1056c431fd55Sdan ** sqlite3_prepare_v2() or legacy interface sqlite3_prepare(), depending
1057c431fd55Sdan ** on whether or not the [db_use_legacy_prepare] command has been used to
1058c431fd55Sdan ** configure the connection.
1059c431fd55Sdan */
1060c431fd55Sdan static int dbPrepare(
1061c431fd55Sdan   SqliteDb *pDb,                  /* Database object */
1062c431fd55Sdan   const char *zSql,               /* SQL to compile */
1063c431fd55Sdan   sqlite3_stmt **ppStmt,          /* OUT: Prepared statement */
1064c431fd55Sdan   const char **pzOut              /* OUT: Pointer to next SQL statement */
1065c431fd55Sdan ){
1066c431fd55Sdan #ifdef SQLITE_TEST
1067c431fd55Sdan   if( pDb->bLegacyPrepare ){
1068c431fd55Sdan     return sqlite3_prepare(pDb->db, zSql, -1, ppStmt, pzOut);
1069c431fd55Sdan   }
1070c431fd55Sdan #endif
1071c431fd55Sdan   return sqlite3_prepare_v2(pDb->db, zSql, -1, ppStmt, pzOut);
1072c431fd55Sdan }
1073c431fd55Sdan 
1074c431fd55Sdan /*
10754a4c11aaSdan ** Search the cache for a prepared-statement object that implements the
10764a4c11aaSdan ** first SQL statement in the buffer pointed to by parameter zIn. If
10774a4c11aaSdan ** no such prepared-statement can be found, allocate and prepare a new
10784a4c11aaSdan ** one. In either case, bind the current values of the relevant Tcl
10794a4c11aaSdan ** variables to any $var, :var or @var variables in the statement. Before
10804a4c11aaSdan ** returning, set *ppPreStmt to point to the prepared-statement object.
10814a4c11aaSdan **
10824a4c11aaSdan ** Output parameter *pzOut is set to point to the next SQL statement in
10834a4c11aaSdan ** buffer zIn, or to the '\0' byte at the end of zIn if there is no
10844a4c11aaSdan ** next statement.
10854a4c11aaSdan **
10864a4c11aaSdan ** If successful, TCL_OK is returned. Otherwise, TCL_ERROR is returned
10874a4c11aaSdan ** and an error message loaded into interpreter pDb->interp.
10884a4c11aaSdan */
10894a4c11aaSdan static int dbPrepareAndBind(
10904a4c11aaSdan   SqliteDb *pDb,                  /* Database object */
10914a4c11aaSdan   char const *zIn,                /* SQL to compile */
10924a4c11aaSdan   char const **pzOut,             /* OUT: Pointer to next SQL statement */
10934a4c11aaSdan   SqlPreparedStmt **ppPreStmt     /* OUT: Object used to cache statement */
10944a4c11aaSdan ){
10954a4c11aaSdan   const char *zSql = zIn;         /* Pointer to first SQL statement in zIn */
10967bb22ac7Smistachkin   sqlite3_stmt *pStmt = 0;        /* Prepared statement object */
10974a4c11aaSdan   SqlPreparedStmt *pPreStmt;      /* Pointer to cached statement */
10984a4c11aaSdan   int nSql;                       /* Length of zSql in bytes */
10997bb22ac7Smistachkin   int nVar = 0;                   /* Number of variables in statement */
11004a4c11aaSdan   int iParm = 0;                  /* Next free entry in apParm */
11010425f189Sdrh   char c;
11024a4c11aaSdan   int i;
11034a4c11aaSdan   Tcl_Interp *interp = pDb->interp;
11044a4c11aaSdan 
11054a4c11aaSdan   *ppPreStmt = 0;
11064a4c11aaSdan 
11074a4c11aaSdan   /* Trim spaces from the start of zSql and calculate the remaining length. */
11080425f189Sdrh   while( (c = zSql[0])==' ' || c=='\t' || c=='\r' || c=='\n' ){ zSql++; }
11094a4c11aaSdan   nSql = strlen30(zSql);
11104a4c11aaSdan 
11114a4c11aaSdan   for(pPreStmt = pDb->stmtList; pPreStmt; pPreStmt=pPreStmt->pNext){
11124a4c11aaSdan     int n = pPreStmt->nSql;
11134a4c11aaSdan     if( nSql>=n
11144a4c11aaSdan         && memcmp(pPreStmt->zSql, zSql, n)==0
11154a4c11aaSdan         && (zSql[n]==0 || zSql[n-1]==';')
11164a4c11aaSdan     ){
11174a4c11aaSdan       pStmt = pPreStmt->pStmt;
11184a4c11aaSdan       *pzOut = &zSql[pPreStmt->nSql];
11194a4c11aaSdan 
11204a4c11aaSdan       /* When a prepared statement is found, unlink it from the
11214a4c11aaSdan       ** cache list.  It will later be added back to the beginning
11224a4c11aaSdan       ** of the cache list in order to implement LRU replacement.
11234a4c11aaSdan       */
11244a4c11aaSdan       if( pPreStmt->pPrev ){
11254a4c11aaSdan         pPreStmt->pPrev->pNext = pPreStmt->pNext;
11264a4c11aaSdan       }else{
11274a4c11aaSdan         pDb->stmtList = pPreStmt->pNext;
11284a4c11aaSdan       }
11294a4c11aaSdan       if( pPreStmt->pNext ){
11304a4c11aaSdan         pPreStmt->pNext->pPrev = pPreStmt->pPrev;
11314a4c11aaSdan       }else{
11324a4c11aaSdan         pDb->stmtLast = pPreStmt->pPrev;
11334a4c11aaSdan       }
11344a4c11aaSdan       pDb->nStmt--;
11354a4c11aaSdan       nVar = sqlite3_bind_parameter_count(pStmt);
11364a4c11aaSdan       break;
11374a4c11aaSdan     }
11384a4c11aaSdan   }
11394a4c11aaSdan 
11404a4c11aaSdan   /* If no prepared statement was found. Compile the SQL text. Also allocate
11414a4c11aaSdan   ** a new SqlPreparedStmt structure.  */
11424a4c11aaSdan   if( pPreStmt==0 ){
11434a4c11aaSdan     int nByte;
11444a4c11aaSdan 
1145c431fd55Sdan     if( SQLITE_OK!=dbPrepare(pDb, zSql, &pStmt, pzOut) ){
1146c45e6716Sdrh       Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
11474a4c11aaSdan       return TCL_ERROR;
11484a4c11aaSdan     }
11494a4c11aaSdan     if( pStmt==0 ){
11504a4c11aaSdan       if( SQLITE_OK!=sqlite3_errcode(pDb->db) ){
11514a4c11aaSdan         /* A compile-time error in the statement. */
1152c45e6716Sdrh         Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
11534a4c11aaSdan         return TCL_ERROR;
11544a4c11aaSdan       }else{
11554a4c11aaSdan         /* The statement was a no-op.  Continue to the next statement
11564a4c11aaSdan         ** in the SQL string.
11574a4c11aaSdan         */
11584a4c11aaSdan         return TCL_OK;
11594a4c11aaSdan       }
11604a4c11aaSdan     }
11614a4c11aaSdan 
11624a4c11aaSdan     assert( pPreStmt==0 );
11634a4c11aaSdan     nVar = sqlite3_bind_parameter_count(pStmt);
11644a4c11aaSdan     nByte = sizeof(SqlPreparedStmt) + nVar*sizeof(Tcl_Obj *);
11654a4c11aaSdan     pPreStmt = (SqlPreparedStmt*)Tcl_Alloc(nByte);
11664a4c11aaSdan     memset(pPreStmt, 0, nByte);
11674a4c11aaSdan 
11684a4c11aaSdan     pPreStmt->pStmt = pStmt;
11697ed243b7Sdrh     pPreStmt->nSql = (int)(*pzOut - zSql);
11704a4c11aaSdan     pPreStmt->zSql = sqlite3_sql(pStmt);
11714a4c11aaSdan     pPreStmt->apParm = (Tcl_Obj **)&pPreStmt[1];
1172c431fd55Sdan #ifdef SQLITE_TEST
1173c431fd55Sdan     if( pPreStmt->zSql==0 ){
1174c431fd55Sdan       char *zCopy = Tcl_Alloc(pPreStmt->nSql + 1);
1175c431fd55Sdan       memcpy(zCopy, zSql, pPreStmt->nSql);
1176c431fd55Sdan       zCopy[pPreStmt->nSql] = '\0';
1177c431fd55Sdan       pPreStmt->zSql = zCopy;
1178c431fd55Sdan     }
1179c431fd55Sdan #endif
11804a4c11aaSdan   }
11814a4c11aaSdan   assert( pPreStmt );
11824a4c11aaSdan   assert( strlen30(pPreStmt->zSql)==pPreStmt->nSql );
11834a4c11aaSdan   assert( 0==memcmp(pPreStmt->zSql, zSql, pPreStmt->nSql) );
11844a4c11aaSdan 
11854a4c11aaSdan   /* Bind values to parameters that begin with $ or : */
11864a4c11aaSdan   for(i=1; i<=nVar; i++){
11874a4c11aaSdan     const char *zVar = sqlite3_bind_parameter_name(pStmt, i);
11884a4c11aaSdan     if( zVar!=0 && (zVar[0]=='$' || zVar[0]==':' || zVar[0]=='@') ){
11894a4c11aaSdan       Tcl_Obj *pVar = Tcl_GetVar2Ex(interp, &zVar[1], 0, 0);
11904a4c11aaSdan       if( pVar ){
11914a4c11aaSdan         int n;
11924a4c11aaSdan         u8 *data;
11934a4c11aaSdan         const char *zType = (pVar->typePtr ? pVar->typePtr->name : "");
11948e18922fSmistachkin         c = zType[0];
11954a4c11aaSdan         if( zVar[0]=='@' ||
11964a4c11aaSdan            (c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0) ){
11974a4c11aaSdan           /* Load a BLOB type if the Tcl variable is a bytearray and
11984a4c11aaSdan           ** it has no string representation or the host
11994a4c11aaSdan           ** parameter name begins with "@". */
12004a4c11aaSdan           data = Tcl_GetByteArrayFromObj(pVar, &n);
12014a4c11aaSdan           sqlite3_bind_blob(pStmt, i, data, n, SQLITE_STATIC);
12024a4c11aaSdan           Tcl_IncrRefCount(pVar);
12034a4c11aaSdan           pPreStmt->apParm[iParm++] = pVar;
12044a4c11aaSdan         }else if( c=='b' && strcmp(zType,"boolean")==0 ){
12054a4c11aaSdan           Tcl_GetIntFromObj(interp, pVar, &n);
12064a4c11aaSdan           sqlite3_bind_int(pStmt, i, n);
12074a4c11aaSdan         }else if( c=='d' && strcmp(zType,"double")==0 ){
12084a4c11aaSdan           double r;
12094a4c11aaSdan           Tcl_GetDoubleFromObj(interp, pVar, &r);
12104a4c11aaSdan           sqlite3_bind_double(pStmt, i, r);
12114a4c11aaSdan         }else if( (c=='w' && strcmp(zType,"wideInt")==0) ||
12124a4c11aaSdan               (c=='i' && strcmp(zType,"int")==0) ){
12134a4c11aaSdan           Tcl_WideInt v;
12144a4c11aaSdan           Tcl_GetWideIntFromObj(interp, pVar, &v);
12154a4c11aaSdan           sqlite3_bind_int64(pStmt, i, v);
12164a4c11aaSdan         }else{
12174a4c11aaSdan           data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n);
12184a4c11aaSdan           sqlite3_bind_text(pStmt, i, (char *)data, n, SQLITE_STATIC);
12194a4c11aaSdan           Tcl_IncrRefCount(pVar);
12204a4c11aaSdan           pPreStmt->apParm[iParm++] = pVar;
12214a4c11aaSdan         }
12224a4c11aaSdan       }else{
12234a4c11aaSdan         sqlite3_bind_null(pStmt, i);
12244a4c11aaSdan       }
12254a4c11aaSdan     }
12264a4c11aaSdan   }
12274a4c11aaSdan   pPreStmt->nParm = iParm;
12284a4c11aaSdan   *ppPreStmt = pPreStmt;
1229937d0deaSdan 
12304a4c11aaSdan   return TCL_OK;
12314a4c11aaSdan }
12324a4c11aaSdan 
12334a4c11aaSdan /*
12344a4c11aaSdan ** Release a statement reference obtained by calling dbPrepareAndBind().
12354a4c11aaSdan ** There should be exactly one call to this function for each call to
12364a4c11aaSdan ** dbPrepareAndBind().
12374a4c11aaSdan **
12384a4c11aaSdan ** If the discard parameter is non-zero, then the statement is deleted
12394a4c11aaSdan ** immediately. Otherwise it is added to the LRU list and may be returned
12404a4c11aaSdan ** by a subsequent call to dbPrepareAndBind().
12414a4c11aaSdan */
12424a4c11aaSdan static void dbReleaseStmt(
12434a4c11aaSdan   SqliteDb *pDb,                  /* Database handle */
12444a4c11aaSdan   SqlPreparedStmt *pPreStmt,      /* Prepared statement handle to release */
12454a4c11aaSdan   int discard                     /* True to delete (not cache) the pPreStmt */
12464a4c11aaSdan ){
12474a4c11aaSdan   int i;
12484a4c11aaSdan 
12494a4c11aaSdan   /* Free the bound string and blob parameters */
12504a4c11aaSdan   for(i=0; i<pPreStmt->nParm; i++){
12514a4c11aaSdan     Tcl_DecrRefCount(pPreStmt->apParm[i]);
12524a4c11aaSdan   }
12534a4c11aaSdan   pPreStmt->nParm = 0;
12544a4c11aaSdan 
12554a4c11aaSdan   if( pDb->maxStmt<=0 || discard ){
12564a4c11aaSdan     /* If the cache is turned off, deallocated the statement */
1257c431fd55Sdan     dbFreeStmt(pPreStmt);
12584a4c11aaSdan   }else{
12594a4c11aaSdan     /* Add the prepared statement to the beginning of the cache list. */
12604a4c11aaSdan     pPreStmt->pNext = pDb->stmtList;
12614a4c11aaSdan     pPreStmt->pPrev = 0;
12624a4c11aaSdan     if( pDb->stmtList ){
12634a4c11aaSdan      pDb->stmtList->pPrev = pPreStmt;
12644a4c11aaSdan     }
12654a4c11aaSdan     pDb->stmtList = pPreStmt;
12664a4c11aaSdan     if( pDb->stmtLast==0 ){
12674a4c11aaSdan       assert( pDb->nStmt==0 );
12684a4c11aaSdan       pDb->stmtLast = pPreStmt;
12694a4c11aaSdan     }else{
12704a4c11aaSdan       assert( pDb->nStmt>0 );
12714a4c11aaSdan     }
12724a4c11aaSdan     pDb->nStmt++;
12734a4c11aaSdan 
12744a4c11aaSdan     /* If we have too many statement in cache, remove the surplus from
12754a4c11aaSdan     ** the end of the cache list.  */
12764a4c11aaSdan     while( pDb->nStmt>pDb->maxStmt ){
1277c431fd55Sdan       SqlPreparedStmt *pLast = pDb->stmtLast;
1278c431fd55Sdan       pDb->stmtLast = pLast->pPrev;
12794a4c11aaSdan       pDb->stmtLast->pNext = 0;
12804a4c11aaSdan       pDb->nStmt--;
1281c431fd55Sdan       dbFreeStmt(pLast);
12824a4c11aaSdan     }
12834a4c11aaSdan   }
12844a4c11aaSdan }
12854a4c11aaSdan 
12864a4c11aaSdan /*
12874a4c11aaSdan ** Structure used with dbEvalXXX() functions:
12884a4c11aaSdan **
12894a4c11aaSdan **   dbEvalInit()
12904a4c11aaSdan **   dbEvalStep()
12914a4c11aaSdan **   dbEvalFinalize()
12924a4c11aaSdan **   dbEvalRowInfo()
12934a4c11aaSdan **   dbEvalColumnValue()
12944a4c11aaSdan */
12954a4c11aaSdan typedef struct DbEvalContext DbEvalContext;
12964a4c11aaSdan struct DbEvalContext {
12974a4c11aaSdan   SqliteDb *pDb;                  /* Database handle */
12984a4c11aaSdan   Tcl_Obj *pSql;                  /* Object holding string zSql */
12994a4c11aaSdan   const char *zSql;               /* Remaining SQL to execute */
13004a4c11aaSdan   SqlPreparedStmt *pPreStmt;      /* Current statement */
13014a4c11aaSdan   int nCol;                       /* Number of columns returned by pStmt */
13024a4c11aaSdan   Tcl_Obj *pArray;                /* Name of array variable */
13034a4c11aaSdan   Tcl_Obj **apColName;            /* Array of column names */
13044a4c11aaSdan };
13054a4c11aaSdan 
13064a4c11aaSdan /*
13074a4c11aaSdan ** Release any cache of column names currently held as part of
13084a4c11aaSdan ** the DbEvalContext structure passed as the first argument.
13094a4c11aaSdan */
13104a4c11aaSdan static void dbReleaseColumnNames(DbEvalContext *p){
13114a4c11aaSdan   if( p->apColName ){
13124a4c11aaSdan     int i;
13134a4c11aaSdan     for(i=0; i<p->nCol; i++){
13144a4c11aaSdan       Tcl_DecrRefCount(p->apColName[i]);
13154a4c11aaSdan     }
13164a4c11aaSdan     Tcl_Free((char *)p->apColName);
13174a4c11aaSdan     p->apColName = 0;
13184a4c11aaSdan   }
13194a4c11aaSdan   p->nCol = 0;
13204a4c11aaSdan }
13214a4c11aaSdan 
13224a4c11aaSdan /*
13234a4c11aaSdan ** Initialize a DbEvalContext structure.
13248e556520Sdanielk1977 **
13258e556520Sdanielk1977 ** If pArray is not NULL, then it contains the name of a Tcl array
13268e556520Sdanielk1977 ** variable. The "*" member of this array is set to a list containing
13274a4c11aaSdan ** the names of the columns returned by the statement as part of each
13284a4c11aaSdan ** call to dbEvalStep(), in order from left to right. e.g. if the names
13294a4c11aaSdan ** of the returned columns are a, b and c, it does the equivalent of the
13304a4c11aaSdan ** tcl command:
13318e556520Sdanielk1977 **
13328e556520Sdanielk1977 **     set ${pArray}(*) {a b c}
13338e556520Sdanielk1977 */
13344a4c11aaSdan static void dbEvalInit(
13354a4c11aaSdan   DbEvalContext *p,               /* Pointer to structure to initialize */
13364a4c11aaSdan   SqliteDb *pDb,                  /* Database handle */
13374a4c11aaSdan   Tcl_Obj *pSql,                  /* Object containing SQL script */
13384a4c11aaSdan   Tcl_Obj *pArray                 /* Name of Tcl array to set (*) element of */
13398e556520Sdanielk1977 ){
13404a4c11aaSdan   memset(p, 0, sizeof(DbEvalContext));
13414a4c11aaSdan   p->pDb = pDb;
13424a4c11aaSdan   p->zSql = Tcl_GetString(pSql);
13434a4c11aaSdan   p->pSql = pSql;
13444a4c11aaSdan   Tcl_IncrRefCount(pSql);
13454a4c11aaSdan   if( pArray ){
13464a4c11aaSdan     p->pArray = pArray;
13474a4c11aaSdan     Tcl_IncrRefCount(pArray);
13484a4c11aaSdan   }
13494a4c11aaSdan }
13508e556520Sdanielk1977 
13514a4c11aaSdan /*
13524a4c11aaSdan ** Obtain information about the row that the DbEvalContext passed as the
13534a4c11aaSdan ** first argument currently points to.
13544a4c11aaSdan */
13554a4c11aaSdan static void dbEvalRowInfo(
13564a4c11aaSdan   DbEvalContext *p,               /* Evaluation context */
13574a4c11aaSdan   int *pnCol,                     /* OUT: Number of column names */
13584a4c11aaSdan   Tcl_Obj ***papColName           /* OUT: Array of column names */
13594a4c11aaSdan ){
13608e556520Sdanielk1977   /* Compute column names */
13614a4c11aaSdan   if( 0==p->apColName ){
13624a4c11aaSdan     sqlite3_stmt *pStmt = p->pPreStmt->pStmt;
13634a4c11aaSdan     int i;                        /* Iterator variable */
13644a4c11aaSdan     int nCol;                     /* Number of columns returned by pStmt */
13654a4c11aaSdan     Tcl_Obj **apColName = 0;      /* Array of column names */
13664a4c11aaSdan 
13674a4c11aaSdan     p->nCol = nCol = sqlite3_column_count(pStmt);
13684a4c11aaSdan     if( nCol>0 && (papColName || p->pArray) ){
13694a4c11aaSdan       apColName = (Tcl_Obj**)Tcl_Alloc( sizeof(Tcl_Obj*)*nCol );
13708e556520Sdanielk1977       for(i=0; i<nCol; i++){
1371c45e6716Sdrh         apColName[i] = Tcl_NewStringObj(sqlite3_column_name(pStmt,i), -1);
13728e556520Sdanielk1977         Tcl_IncrRefCount(apColName[i]);
13738e556520Sdanielk1977       }
13744a4c11aaSdan       p->apColName = apColName;
13754a4c11aaSdan     }
13768e556520Sdanielk1977 
13778e556520Sdanielk1977     /* If results are being stored in an array variable, then create
13788e556520Sdanielk1977     ** the array(*) entry for that array
13798e556520Sdanielk1977     */
13804a4c11aaSdan     if( p->pArray ){
13814a4c11aaSdan       Tcl_Interp *interp = p->pDb->interp;
13828e556520Sdanielk1977       Tcl_Obj *pColList = Tcl_NewObj();
13838e556520Sdanielk1977       Tcl_Obj *pStar = Tcl_NewStringObj("*", -1);
13844a4c11aaSdan 
13858e556520Sdanielk1977       for(i=0; i<nCol; i++){
13868e556520Sdanielk1977         Tcl_ListObjAppendElement(interp, pColList, apColName[i]);
13878e556520Sdanielk1977       }
13888e556520Sdanielk1977       Tcl_IncrRefCount(pStar);
13894a4c11aaSdan       Tcl_ObjSetVar2(interp, p->pArray, pStar, pColList, 0);
13908e556520Sdanielk1977       Tcl_DecrRefCount(pStar);
13918e556520Sdanielk1977     }
13928e556520Sdanielk1977   }
13938e556520Sdanielk1977 
13944a4c11aaSdan   if( papColName ){
13954a4c11aaSdan     *papColName = p->apColName;
13964a4c11aaSdan   }
13974a4c11aaSdan   if( pnCol ){
13984a4c11aaSdan     *pnCol = p->nCol;
13994a4c11aaSdan   }
14004a4c11aaSdan }
14014a4c11aaSdan 
14024a4c11aaSdan /*
14034a4c11aaSdan ** Return one of TCL_OK, TCL_BREAK or TCL_ERROR. If TCL_ERROR is
14044a4c11aaSdan ** returned, then an error message is stored in the interpreter before
14054a4c11aaSdan ** returning.
14064a4c11aaSdan **
14074a4c11aaSdan ** A return value of TCL_OK means there is a row of data available. The
14084a4c11aaSdan ** data may be accessed using dbEvalRowInfo() and dbEvalColumnValue(). This
14094a4c11aaSdan ** is analogous to a return of SQLITE_ROW from sqlite3_step(). If TCL_BREAK
14104a4c11aaSdan ** is returned, then the SQL script has finished executing and there are
14114a4c11aaSdan ** no further rows available. This is similar to SQLITE_DONE.
14124a4c11aaSdan */
14134a4c11aaSdan static int dbEvalStep(DbEvalContext *p){
1414c431fd55Sdan   const char *zPrevSql = 0;       /* Previous value of p->zSql */
1415c431fd55Sdan 
14164a4c11aaSdan   while( p->zSql[0] || p->pPreStmt ){
14174a4c11aaSdan     int rc;
14184a4c11aaSdan     if( p->pPreStmt==0 ){
1419c431fd55Sdan       zPrevSql = (p->zSql==zPrevSql ? 0 : p->zSql);
14204a4c11aaSdan       rc = dbPrepareAndBind(p->pDb, p->zSql, &p->zSql, &p->pPreStmt);
14214a4c11aaSdan       if( rc!=TCL_OK ) return rc;
14224a4c11aaSdan     }else{
14234a4c11aaSdan       int rcs;
14244a4c11aaSdan       SqliteDb *pDb = p->pDb;
14254a4c11aaSdan       SqlPreparedStmt *pPreStmt = p->pPreStmt;
14264a4c11aaSdan       sqlite3_stmt *pStmt = pPreStmt->pStmt;
14274a4c11aaSdan 
14284a4c11aaSdan       rcs = sqlite3_step(pStmt);
14294a4c11aaSdan       if( rcs==SQLITE_ROW ){
14304a4c11aaSdan         return TCL_OK;
14314a4c11aaSdan       }
14324a4c11aaSdan       if( p->pArray ){
14334a4c11aaSdan         dbEvalRowInfo(p, 0, 0);
14344a4c11aaSdan       }
14354a4c11aaSdan       rcs = sqlite3_reset(pStmt);
14364a4c11aaSdan 
14374a4c11aaSdan       pDb->nStep = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_FULLSCAN_STEP,1);
14384a4c11aaSdan       pDb->nSort = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_SORT,1);
14393c379b01Sdrh       pDb->nIndex = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_AUTOINDEX,1);
14404a4c11aaSdan       dbReleaseColumnNames(p);
14414a4c11aaSdan       p->pPreStmt = 0;
14424a4c11aaSdan 
14434a4c11aaSdan       if( rcs!=SQLITE_OK ){
14444a4c11aaSdan         /* If a run-time error occurs, report the error and stop reading
14454a4c11aaSdan         ** the SQL.  */
14464a4c11aaSdan         dbReleaseStmt(pDb, pPreStmt, 1);
1447c431fd55Sdan #if SQLITE_TEST
1448c431fd55Sdan         if( p->pDb->bLegacyPrepare && rcs==SQLITE_SCHEMA && zPrevSql ){
1449c431fd55Sdan           /* If the runtime error was an SQLITE_SCHEMA, and the database
1450c431fd55Sdan           ** handle is configured to use the legacy sqlite3_prepare()
1451c431fd55Sdan           ** interface, retry prepare()/step() on the same SQL statement.
1452c431fd55Sdan           ** This only happens once. If there is a second SQLITE_SCHEMA
1453c431fd55Sdan           ** error, the error will be returned to the caller. */
1454c431fd55Sdan           p->zSql = zPrevSql;
1455c431fd55Sdan           continue;
1456c431fd55Sdan         }
1457c431fd55Sdan #endif
1458c45e6716Sdrh         Tcl_SetObjResult(pDb->interp,
1459c45e6716Sdrh                          Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
14604a4c11aaSdan         return TCL_ERROR;
14614a4c11aaSdan       }else{
14624a4c11aaSdan         dbReleaseStmt(pDb, pPreStmt, 0);
14634a4c11aaSdan       }
14644a4c11aaSdan     }
14654a4c11aaSdan   }
14664a4c11aaSdan 
14674a4c11aaSdan   /* Finished */
14684a4c11aaSdan   return TCL_BREAK;
14694a4c11aaSdan }
14704a4c11aaSdan 
14714a4c11aaSdan /*
14724a4c11aaSdan ** Free all resources currently held by the DbEvalContext structure passed
14734a4c11aaSdan ** as the first argument. There should be exactly one call to this function
14744a4c11aaSdan ** for each call to dbEvalInit().
14754a4c11aaSdan */
14764a4c11aaSdan static void dbEvalFinalize(DbEvalContext *p){
14774a4c11aaSdan   if( p->pPreStmt ){
14784a4c11aaSdan     sqlite3_reset(p->pPreStmt->pStmt);
14794a4c11aaSdan     dbReleaseStmt(p->pDb, p->pPreStmt, 0);
14804a4c11aaSdan     p->pPreStmt = 0;
14814a4c11aaSdan   }
14824a4c11aaSdan   if( p->pArray ){
14834a4c11aaSdan     Tcl_DecrRefCount(p->pArray);
14844a4c11aaSdan     p->pArray = 0;
14854a4c11aaSdan   }
14864a4c11aaSdan   Tcl_DecrRefCount(p->pSql);
14874a4c11aaSdan   dbReleaseColumnNames(p);
14884a4c11aaSdan }
14894a4c11aaSdan 
14904a4c11aaSdan /*
14914a4c11aaSdan ** Return a pointer to a Tcl_Obj structure with ref-count 0 that contains
14924a4c11aaSdan ** the value for the iCol'th column of the row currently pointed to by
14934a4c11aaSdan ** the DbEvalContext structure passed as the first argument.
14944a4c11aaSdan */
14954a4c11aaSdan static Tcl_Obj *dbEvalColumnValue(DbEvalContext *p, int iCol){
14964a4c11aaSdan   sqlite3_stmt *pStmt = p->pPreStmt->pStmt;
14974a4c11aaSdan   switch( sqlite3_column_type(pStmt, iCol) ){
14984a4c11aaSdan     case SQLITE_BLOB: {
14994a4c11aaSdan       int bytes = sqlite3_column_bytes(pStmt, iCol);
15004a4c11aaSdan       const char *zBlob = sqlite3_column_blob(pStmt, iCol);
15014a4c11aaSdan       if( !zBlob ) bytes = 0;
15024a4c11aaSdan       return Tcl_NewByteArrayObj((u8*)zBlob, bytes);
15034a4c11aaSdan     }
15044a4c11aaSdan     case SQLITE_INTEGER: {
15054a4c11aaSdan       sqlite_int64 v = sqlite3_column_int64(pStmt, iCol);
15064a4c11aaSdan       if( v>=-2147483647 && v<=2147483647 ){
15077fd33929Sdrh         return Tcl_NewIntObj((int)v);
15084a4c11aaSdan       }else{
15094a4c11aaSdan         return Tcl_NewWideIntObj(v);
15104a4c11aaSdan       }
15114a4c11aaSdan     }
15124a4c11aaSdan     case SQLITE_FLOAT: {
15134a4c11aaSdan       return Tcl_NewDoubleObj(sqlite3_column_double(pStmt, iCol));
15144a4c11aaSdan     }
15154a4c11aaSdan     case SQLITE_NULL: {
1516c45e6716Sdrh       return Tcl_NewStringObj(p->pDb->zNull, -1);
15174a4c11aaSdan     }
15184a4c11aaSdan   }
15194a4c11aaSdan 
1520325eff58Sdrh   return Tcl_NewStringObj((char*)sqlite3_column_text(pStmt, iCol), -1);
15214a4c11aaSdan }
15224a4c11aaSdan 
15234a4c11aaSdan /*
15244a4c11aaSdan ** If using Tcl version 8.6 or greater, use the NR functions to avoid
15254a4c11aaSdan ** recursive evalution of scripts by the [db eval] and [db trans]
15264a4c11aaSdan ** commands. Even if the headers used while compiling the extension
15274a4c11aaSdan ** are 8.6 or newer, the code still tests the Tcl version at runtime.
15284a4c11aaSdan ** This allows stubs-enabled builds to be used with older Tcl libraries.
15294a4c11aaSdan */
15304a4c11aaSdan #if TCL_MAJOR_VERSION>8 || (TCL_MAJOR_VERSION==8 && TCL_MINOR_VERSION>=6)
1531a2c8a95bSdrh # define SQLITE_TCL_NRE 1
15324a4c11aaSdan static int DbUseNre(void){
15334a4c11aaSdan   int major, minor;
15344a4c11aaSdan   Tcl_GetVersion(&major, &minor, 0, 0);
15354a4c11aaSdan   return( (major==8 && minor>=6) || major>8 );
15364a4c11aaSdan }
15374a4c11aaSdan #else
15384a4c11aaSdan /*
15394a4c11aaSdan ** Compiling using headers earlier than 8.6. In this case NR cannot be
15404a4c11aaSdan ** used, so DbUseNre() to always return zero. Add #defines for the other
15414a4c11aaSdan ** Tcl_NRxxx() functions to prevent them from causing compilation errors,
15424a4c11aaSdan ** even though the only invocations of them are within conditional blocks
15434a4c11aaSdan ** of the form:
15444a4c11aaSdan **
15454a4c11aaSdan **   if( DbUseNre() ) { ... }
15464a4c11aaSdan */
1547a2c8a95bSdrh # define SQLITE_TCL_NRE 0
15484a4c11aaSdan # define DbUseNre() 0
1549a47941feSdrh # define Tcl_NRAddCallback(a,b,c,d,e,f) (void)0
15504a4c11aaSdan # define Tcl_NREvalObj(a,b,c) 0
1551a47941feSdrh # define Tcl_NRCreateCommand(a,b,c,d,e,f) (void)0
15524a4c11aaSdan #endif
15534a4c11aaSdan 
15544a4c11aaSdan /*
15554a4c11aaSdan ** This function is part of the implementation of the command:
15564a4c11aaSdan **
15574a4c11aaSdan **   $db eval SQL ?ARRAYNAME? SCRIPT
15584a4c11aaSdan */
15594a4c11aaSdan static int DbEvalNextCmd(
15604a4c11aaSdan   ClientData data[],                   /* data[0] is the (DbEvalContext*) */
15614a4c11aaSdan   Tcl_Interp *interp,                  /* Tcl interpreter */
15624a4c11aaSdan   int result                           /* Result so far */
15634a4c11aaSdan ){
15644a4c11aaSdan   int rc = result;                     /* Return code */
15654a4c11aaSdan 
15664a4c11aaSdan   /* The first element of the data[] array is a pointer to a DbEvalContext
15674a4c11aaSdan   ** structure allocated using Tcl_Alloc(). The second element of data[]
15684a4c11aaSdan   ** is a pointer to a Tcl_Obj containing the script to run for each row
15694a4c11aaSdan   ** returned by the queries encapsulated in data[0]. */
15704a4c11aaSdan   DbEvalContext *p = (DbEvalContext *)data[0];
15714a4c11aaSdan   Tcl_Obj *pScript = (Tcl_Obj *)data[1];
15724a4c11aaSdan   Tcl_Obj *pArray = p->pArray;
15734a4c11aaSdan 
15744a4c11aaSdan   while( (rc==TCL_OK || rc==TCL_CONTINUE) && TCL_OK==(rc = dbEvalStep(p)) ){
15754a4c11aaSdan     int i;
15764a4c11aaSdan     int nCol;
15774a4c11aaSdan     Tcl_Obj **apColName;
15784a4c11aaSdan     dbEvalRowInfo(p, &nCol, &apColName);
15794a4c11aaSdan     for(i=0; i<nCol; i++){
15804a4c11aaSdan       Tcl_Obj *pVal = dbEvalColumnValue(p, i);
15814a4c11aaSdan       if( pArray==0 ){
15824a4c11aaSdan         Tcl_ObjSetVar2(interp, apColName[i], 0, pVal, 0);
15834a4c11aaSdan       }else{
15844a4c11aaSdan         Tcl_ObjSetVar2(interp, pArray, apColName[i], pVal, 0);
15854a4c11aaSdan       }
15864a4c11aaSdan     }
15874a4c11aaSdan 
15884a4c11aaSdan     /* The required interpreter variables are now populated with the data
15894a4c11aaSdan     ** from the current row. If using NRE, schedule callbacks to evaluate
15904a4c11aaSdan     ** script pScript, then to invoke this function again to fetch the next
15914a4c11aaSdan     ** row (or clean up if there is no next row or the script throws an
15924a4c11aaSdan     ** exception). After scheduling the callbacks, return control to the
15934a4c11aaSdan     ** caller.
15944a4c11aaSdan     **
15954a4c11aaSdan     ** If not using NRE, evaluate pScript directly and continue with the
15964a4c11aaSdan     ** next iteration of this while(...) loop.  */
15974a4c11aaSdan     if( DbUseNre() ){
15984a4c11aaSdan       Tcl_NRAddCallback(interp, DbEvalNextCmd, (void*)p, (void*)pScript, 0, 0);
15994a4c11aaSdan       return Tcl_NREvalObj(interp, pScript, 0);
16004a4c11aaSdan     }else{
16014a4c11aaSdan       rc = Tcl_EvalObjEx(interp, pScript, 0);
16024a4c11aaSdan     }
16034a4c11aaSdan   }
16044a4c11aaSdan 
16054a4c11aaSdan   Tcl_DecrRefCount(pScript);
16064a4c11aaSdan   dbEvalFinalize(p);
16074a4c11aaSdan   Tcl_Free((char *)p);
16084a4c11aaSdan 
16094a4c11aaSdan   if( rc==TCL_OK || rc==TCL_BREAK ){
16104a4c11aaSdan     Tcl_ResetResult(interp);
16114a4c11aaSdan     rc = TCL_OK;
16124a4c11aaSdan   }
16134a4c11aaSdan   return rc;
16148e556520Sdanielk1977 }
16158e556520Sdanielk1977 
16161067fe11Stpoindex /*
161775897234Sdrh ** The "sqlite" command below creates a new Tcl command for each
161875897234Sdrh ** connection it opens to an SQLite database.  This routine is invoked
161975897234Sdrh ** whenever one of those connection-specific commands is executed
162075897234Sdrh ** in Tcl.  For example, if you run Tcl code like this:
162175897234Sdrh **
16229bb575fdSdrh **       sqlite3 db1  "my_database"
162375897234Sdrh **       db1 close
162475897234Sdrh **
162575897234Sdrh ** The first command opens a connection to the "my_database" database
162675897234Sdrh ** and calls that connection "db1".  The second command causes this
162775897234Sdrh ** subroutine to be invoked.
162875897234Sdrh */
16296d31316cSdrh static int DbObjCmd(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){
1630bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)cd;
16316d31316cSdrh   int choice;
163222fbcb8dSdrh   int rc = TCL_OK;
16330de8c112Sdrh   static const char *DB_strs[] = {
1634dc2c4915Sdrh     "authorizer",         "backup",            "busy",
1635dc2c4915Sdrh     "cache",              "changes",           "close",
1636dc2c4915Sdrh     "collate",            "collation_needed",  "commit_hook",
1637dc2c4915Sdrh     "complete",           "copy",              "enable_load_extension",
1638dc2c4915Sdrh     "errorcode",          "eval",              "exists",
1639dc2c4915Sdrh     "function",           "incrblob",          "interrupt",
1640833bf968Sdrh     "last_insert_rowid",  "nullvalue",         "onecolumn",
1641833bf968Sdrh     "profile",            "progress",          "rekey",
1642833bf968Sdrh     "restore",            "rollback_hook",     "status",
1643833bf968Sdrh     "timeout",            "total_changes",     "trace",
1644833bf968Sdrh     "transaction",        "unlock_notify",     "update_hook",
1645833bf968Sdrh     "version",            "wal_hook",          0
16466d31316cSdrh   };
1647411995dcSdrh   enum DB_enum {
1648dc2c4915Sdrh     DB_AUTHORIZER,        DB_BACKUP,           DB_BUSY,
1649dc2c4915Sdrh     DB_CACHE,             DB_CHANGES,          DB_CLOSE,
1650dc2c4915Sdrh     DB_COLLATE,           DB_COLLATION_NEEDED, DB_COMMIT_HOOK,
1651dc2c4915Sdrh     DB_COMPLETE,          DB_COPY,             DB_ENABLE_LOAD_EXTENSION,
1652dc2c4915Sdrh     DB_ERRORCODE,         DB_EVAL,             DB_EXISTS,
1653dc2c4915Sdrh     DB_FUNCTION,          DB_INCRBLOB,         DB_INTERRUPT,
1654833bf968Sdrh     DB_LAST_INSERT_ROWID, DB_NULLVALUE,        DB_ONECOLUMN,
1655833bf968Sdrh     DB_PROFILE,           DB_PROGRESS,         DB_REKEY,
1656833bf968Sdrh     DB_RESTORE,           DB_ROLLBACK_HOOK,    DB_STATUS,
1657833bf968Sdrh     DB_TIMEOUT,           DB_TOTAL_CHANGES,    DB_TRACE,
1658833bf968Sdrh     DB_TRANSACTION,       DB_UNLOCK_NOTIFY,    DB_UPDATE_HOOK,
1659833bf968Sdrh     DB_VERSION,           DB_WAL_HOOK
16606d31316cSdrh   };
16611067fe11Stpoindex   /* don't leave trailing commas on DB_enum, it confuses the AIX xlc compiler */
16626d31316cSdrh 
16636d31316cSdrh   if( objc<2 ){
16646d31316cSdrh     Tcl_WrongNumArgs(interp, 1, objv, "SUBCOMMAND ...");
166575897234Sdrh     return TCL_ERROR;
166675897234Sdrh   }
1667411995dcSdrh   if( Tcl_GetIndexFromObj(interp, objv[1], DB_strs, "option", 0, &choice) ){
16686d31316cSdrh     return TCL_ERROR;
16696d31316cSdrh   }
16706d31316cSdrh 
1671411995dcSdrh   switch( (enum DB_enum)choice ){
167275897234Sdrh 
1673e22a334bSdrh   /*    $db authorizer ?CALLBACK?
1674e22a334bSdrh   **
1675e22a334bSdrh   ** Invoke the given callback to authorize each SQL operation as it is
1676e22a334bSdrh   ** compiled.  5 arguments are appended to the callback before it is
1677e22a334bSdrh   ** invoked:
1678e22a334bSdrh   **
1679e22a334bSdrh   **   (1) The authorization type (ex: SQLITE_CREATE_TABLE, SQLITE_INSERT, ...)
1680e22a334bSdrh   **   (2) First descriptive name (depends on authorization type)
1681e22a334bSdrh   **   (3) Second descriptive name
1682e22a334bSdrh   **   (4) Name of the database (ex: "main", "temp")
1683e22a334bSdrh   **   (5) Name of trigger that is doing the access
1684e22a334bSdrh   **
1685e22a334bSdrh   ** The callback should return on of the following strings: SQLITE_OK,
1686e22a334bSdrh   ** SQLITE_IGNORE, or SQLITE_DENY.  Any other return value is an error.
1687e22a334bSdrh   **
1688e22a334bSdrh   ** If this method is invoked with no arguments, the current authorization
1689e22a334bSdrh   ** callback string is returned.
1690e22a334bSdrh   */
1691e22a334bSdrh   case DB_AUTHORIZER: {
16921211de37Sdrh #ifdef SQLITE_OMIT_AUTHORIZATION
1693a198f2b5Sdrh     Tcl_AppendResult(interp, "authorization not available in this build",
1694a198f2b5Sdrh                      (char*)0);
16951211de37Sdrh     return TCL_ERROR;
16961211de37Sdrh #else
1697e22a334bSdrh     if( objc>3 ){
1698e22a334bSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
16990f14e2ebSdrh       return TCL_ERROR;
1700e22a334bSdrh     }else if( objc==2 ){
1701b5a20d3cSdrh       if( pDb->zAuth ){
1702a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zAuth, (char*)0);
1703e22a334bSdrh       }
1704e22a334bSdrh     }else{
1705e22a334bSdrh       char *zAuth;
1706e22a334bSdrh       int len;
1707e22a334bSdrh       if( pDb->zAuth ){
1708e22a334bSdrh         Tcl_Free(pDb->zAuth);
1709e22a334bSdrh       }
1710e22a334bSdrh       zAuth = Tcl_GetStringFromObj(objv[2], &len);
1711e22a334bSdrh       if( zAuth && len>0 ){
1712e22a334bSdrh         pDb->zAuth = Tcl_Alloc( len + 1 );
17135bb3eb9bSdrh         memcpy(pDb->zAuth, zAuth, len+1);
1714e22a334bSdrh       }else{
1715e22a334bSdrh         pDb->zAuth = 0;
1716e22a334bSdrh       }
1717e22a334bSdrh       if( pDb->zAuth ){
171832c6a48bSdrh         typedef int (*sqlite3_auth_cb)(
171932c6a48bSdrh            void*,int,const char*,const char*,
172032c6a48bSdrh            const char*,const char*);
1721e22a334bSdrh         pDb->interp = interp;
172232c6a48bSdrh         sqlite3_set_authorizer(pDb->db,(sqlite3_auth_cb)auth_callback,pDb);
1723e22a334bSdrh       }else{
17246f8a503dSdanielk1977         sqlite3_set_authorizer(pDb->db, 0, 0);
1725e22a334bSdrh       }
1726e22a334bSdrh     }
17271211de37Sdrh #endif
1728e22a334bSdrh     break;
1729e22a334bSdrh   }
1730e22a334bSdrh 
1731dc2c4915Sdrh   /*    $db backup ?DATABASE? FILENAME
1732dc2c4915Sdrh   **
1733dc2c4915Sdrh   ** Open or create a database file named FILENAME.  Transfer the
1734dc2c4915Sdrh   ** content of local database DATABASE (default: "main") into the
1735dc2c4915Sdrh   ** FILENAME database.
1736dc2c4915Sdrh   */
1737dc2c4915Sdrh   case DB_BACKUP: {
1738dc2c4915Sdrh     const char *zDestFile;
1739dc2c4915Sdrh     const char *zSrcDb;
1740dc2c4915Sdrh     sqlite3 *pDest;
1741dc2c4915Sdrh     sqlite3_backup *pBackup;
1742dc2c4915Sdrh 
1743dc2c4915Sdrh     if( objc==3 ){
1744dc2c4915Sdrh       zSrcDb = "main";
1745dc2c4915Sdrh       zDestFile = Tcl_GetString(objv[2]);
1746dc2c4915Sdrh     }else if( objc==4 ){
1747dc2c4915Sdrh       zSrcDb = Tcl_GetString(objv[2]);
1748dc2c4915Sdrh       zDestFile = Tcl_GetString(objv[3]);
1749dc2c4915Sdrh     }else{
1750dc2c4915Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "?DATABASE? FILENAME");
1751dc2c4915Sdrh       return TCL_ERROR;
1752dc2c4915Sdrh     }
1753dc2c4915Sdrh     rc = sqlite3_open(zDestFile, &pDest);
1754dc2c4915Sdrh     if( rc!=SQLITE_OK ){
1755dc2c4915Sdrh       Tcl_AppendResult(interp, "cannot open target database: ",
1756dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1757dc2c4915Sdrh       sqlite3_close(pDest);
1758dc2c4915Sdrh       return TCL_ERROR;
1759dc2c4915Sdrh     }
1760dc2c4915Sdrh     pBackup = sqlite3_backup_init(pDest, "main", pDb->db, zSrcDb);
1761dc2c4915Sdrh     if( pBackup==0 ){
1762dc2c4915Sdrh       Tcl_AppendResult(interp, "backup failed: ",
1763dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1764dc2c4915Sdrh       sqlite3_close(pDest);
1765dc2c4915Sdrh       return TCL_ERROR;
1766dc2c4915Sdrh     }
1767dc2c4915Sdrh     while(  (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK ){}
1768dc2c4915Sdrh     sqlite3_backup_finish(pBackup);
1769dc2c4915Sdrh     if( rc==SQLITE_DONE ){
1770dc2c4915Sdrh       rc = TCL_OK;
1771dc2c4915Sdrh     }else{
1772dc2c4915Sdrh       Tcl_AppendResult(interp, "backup failed: ",
1773dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1774dc2c4915Sdrh       rc = TCL_ERROR;
1775dc2c4915Sdrh     }
1776dc2c4915Sdrh     sqlite3_close(pDest);
1777dc2c4915Sdrh     break;
1778dc2c4915Sdrh   }
1779dc2c4915Sdrh 
1780bec3f402Sdrh   /*    $db busy ?CALLBACK?
1781bec3f402Sdrh   **
1782bec3f402Sdrh   ** Invoke the given callback if an SQL statement attempts to open
1783bec3f402Sdrh   ** a locked database file.
1784bec3f402Sdrh   */
17856d31316cSdrh   case DB_BUSY: {
17866d31316cSdrh     if( objc>3 ){
17876d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "CALLBACK");
1788bec3f402Sdrh       return TCL_ERROR;
17896d31316cSdrh     }else if( objc==2 ){
1790bec3f402Sdrh       if( pDb->zBusy ){
1791a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zBusy, (char*)0);
1792bec3f402Sdrh       }
1793bec3f402Sdrh     }else{
17946d31316cSdrh       char *zBusy;
17956d31316cSdrh       int len;
1796bec3f402Sdrh       if( pDb->zBusy ){
1797bec3f402Sdrh         Tcl_Free(pDb->zBusy);
17986d31316cSdrh       }
17996d31316cSdrh       zBusy = Tcl_GetStringFromObj(objv[2], &len);
18006d31316cSdrh       if( zBusy && len>0 ){
18016d31316cSdrh         pDb->zBusy = Tcl_Alloc( len + 1 );
18025bb3eb9bSdrh         memcpy(pDb->zBusy, zBusy, len+1);
18036d31316cSdrh       }else{
1804bec3f402Sdrh         pDb->zBusy = 0;
1805bec3f402Sdrh       }
1806bec3f402Sdrh       if( pDb->zBusy ){
1807bec3f402Sdrh         pDb->interp = interp;
18086f8a503dSdanielk1977         sqlite3_busy_handler(pDb->db, DbBusyHandler, pDb);
18096d31316cSdrh       }else{
18106f8a503dSdanielk1977         sqlite3_busy_handler(pDb->db, 0, 0);
1811bec3f402Sdrh       }
1812bec3f402Sdrh     }
18136d31316cSdrh     break;
18146d31316cSdrh   }
1815bec3f402Sdrh 
1816fb7e7651Sdrh   /*     $db cache flush
1817fb7e7651Sdrh   **     $db cache size n
1818fb7e7651Sdrh   **
1819fb7e7651Sdrh   ** Flush the prepared statement cache, or set the maximum number of
1820fb7e7651Sdrh   ** cached statements.
1821fb7e7651Sdrh   */
1822fb7e7651Sdrh   case DB_CACHE: {
1823fb7e7651Sdrh     char *subCmd;
1824fb7e7651Sdrh     int n;
1825fb7e7651Sdrh 
1826fb7e7651Sdrh     if( objc<=2 ){
1827fb7e7651Sdrh       Tcl_WrongNumArgs(interp, 1, objv, "cache option ?arg?");
1828fb7e7651Sdrh       return TCL_ERROR;
1829fb7e7651Sdrh     }
1830fb7e7651Sdrh     subCmd = Tcl_GetStringFromObj( objv[2], 0 );
1831fb7e7651Sdrh     if( *subCmd=='f' && strcmp(subCmd,"flush")==0 ){
1832fb7e7651Sdrh       if( objc!=3 ){
1833fb7e7651Sdrh         Tcl_WrongNumArgs(interp, 2, objv, "flush");
1834fb7e7651Sdrh         return TCL_ERROR;
1835fb7e7651Sdrh       }else{
1836fb7e7651Sdrh         flushStmtCache( pDb );
1837fb7e7651Sdrh       }
1838fb7e7651Sdrh     }else if( *subCmd=='s' && strcmp(subCmd,"size")==0 ){
1839fb7e7651Sdrh       if( objc!=4 ){
1840fb7e7651Sdrh         Tcl_WrongNumArgs(interp, 2, objv, "size n");
1841fb7e7651Sdrh         return TCL_ERROR;
1842fb7e7651Sdrh       }else{
1843fb7e7651Sdrh         if( TCL_ERROR==Tcl_GetIntFromObj(interp, objv[3], &n) ){
1844fb7e7651Sdrh           Tcl_AppendResult( interp, "cannot convert \"",
1845a198f2b5Sdrh                Tcl_GetStringFromObj(objv[3],0), "\" to integer", (char*)0);
1846fb7e7651Sdrh           return TCL_ERROR;
1847fb7e7651Sdrh         }else{
1848fb7e7651Sdrh           if( n<0 ){
1849fb7e7651Sdrh             flushStmtCache( pDb );
1850fb7e7651Sdrh             n = 0;
1851fb7e7651Sdrh           }else if( n>MAX_PREPARED_STMTS ){
1852fb7e7651Sdrh             n = MAX_PREPARED_STMTS;
1853fb7e7651Sdrh           }
1854fb7e7651Sdrh           pDb->maxStmt = n;
1855fb7e7651Sdrh         }
1856fb7e7651Sdrh       }
1857fb7e7651Sdrh     }else{
1858fb7e7651Sdrh       Tcl_AppendResult( interp, "bad option \"",
1859a198f2b5Sdrh           Tcl_GetStringFromObj(objv[2],0), "\": must be flush or size",
1860a198f2b5Sdrh           (char*)0);
1861fb7e7651Sdrh       return TCL_ERROR;
1862fb7e7651Sdrh     }
1863fb7e7651Sdrh     break;
1864fb7e7651Sdrh   }
1865fb7e7651Sdrh 
1866b28af71aSdanielk1977   /*     $db changes
1867c8d30ac1Sdrh   **
1868c8d30ac1Sdrh   ** Return the number of rows that were modified, inserted, or deleted by
1869b28af71aSdanielk1977   ** the most recent INSERT, UPDATE or DELETE statement, not including
1870b28af71aSdanielk1977   ** any changes made by trigger programs.
1871c8d30ac1Sdrh   */
1872c8d30ac1Sdrh   case DB_CHANGES: {
1873c8d30ac1Sdrh     Tcl_Obj *pResult;
1874c8d30ac1Sdrh     if( objc!=2 ){
1875c8d30ac1Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
1876c8d30ac1Sdrh       return TCL_ERROR;
1877c8d30ac1Sdrh     }
1878c8d30ac1Sdrh     pResult = Tcl_GetObjResult(interp);
1879b28af71aSdanielk1977     Tcl_SetIntObj(pResult, sqlite3_changes(pDb->db));
1880f146a776Srdc     break;
1881f146a776Srdc   }
1882f146a776Srdc 
188375897234Sdrh   /*    $db close
188475897234Sdrh   **
188575897234Sdrh   ** Shutdown the database
188675897234Sdrh   */
18876d31316cSdrh   case DB_CLOSE: {
18886d31316cSdrh     Tcl_DeleteCommand(interp, Tcl_GetStringFromObj(objv[0], 0));
18896d31316cSdrh     break;
18906d31316cSdrh   }
189175897234Sdrh 
18920f14e2ebSdrh   /*
18930f14e2ebSdrh   **     $db collate NAME SCRIPT
18940f14e2ebSdrh   **
18950f14e2ebSdrh   ** Create a new SQL collation function called NAME.  Whenever
18960f14e2ebSdrh   ** that function is called, invoke SCRIPT to evaluate the function.
18970f14e2ebSdrh   */
18980f14e2ebSdrh   case DB_COLLATE: {
18990f14e2ebSdrh     SqlCollate *pCollate;
19000f14e2ebSdrh     char *zName;
19010f14e2ebSdrh     char *zScript;
19020f14e2ebSdrh     int nScript;
19030f14e2ebSdrh     if( objc!=4 ){
19040f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "NAME SCRIPT");
19050f14e2ebSdrh       return TCL_ERROR;
19060f14e2ebSdrh     }
19070f14e2ebSdrh     zName = Tcl_GetStringFromObj(objv[2], 0);
19080f14e2ebSdrh     zScript = Tcl_GetStringFromObj(objv[3], &nScript);
19090f14e2ebSdrh     pCollate = (SqlCollate*)Tcl_Alloc( sizeof(*pCollate) + nScript + 1 );
19100f14e2ebSdrh     if( pCollate==0 ) return TCL_ERROR;
19110f14e2ebSdrh     pCollate->interp = interp;
19120f14e2ebSdrh     pCollate->pNext = pDb->pCollate;
19130f14e2ebSdrh     pCollate->zScript = (char*)&pCollate[1];
19140f14e2ebSdrh     pDb->pCollate = pCollate;
19155bb3eb9bSdrh     memcpy(pCollate->zScript, zScript, nScript+1);
19160f14e2ebSdrh     if( sqlite3_create_collation(pDb->db, zName, SQLITE_UTF8,
19170f14e2ebSdrh         pCollate, tclSqlCollate) ){
19189636c4e1Sdanielk1977       Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
19190f14e2ebSdrh       return TCL_ERROR;
19200f14e2ebSdrh     }
19210f14e2ebSdrh     break;
19220f14e2ebSdrh   }
19230f14e2ebSdrh 
19240f14e2ebSdrh   /*
19250f14e2ebSdrh   **     $db collation_needed SCRIPT
19260f14e2ebSdrh   **
19270f14e2ebSdrh   ** Create a new SQL collation function called NAME.  Whenever
19280f14e2ebSdrh   ** that function is called, invoke SCRIPT to evaluate the function.
19290f14e2ebSdrh   */
19300f14e2ebSdrh   case DB_COLLATION_NEEDED: {
19310f14e2ebSdrh     if( objc!=3 ){
19320f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "SCRIPT");
19330f14e2ebSdrh       return TCL_ERROR;
19340f14e2ebSdrh     }
19350f14e2ebSdrh     if( pDb->pCollateNeeded ){
19360f14e2ebSdrh       Tcl_DecrRefCount(pDb->pCollateNeeded);
19370f14e2ebSdrh     }
19380f14e2ebSdrh     pDb->pCollateNeeded = Tcl_DuplicateObj(objv[2]);
19390f14e2ebSdrh     Tcl_IncrRefCount(pDb->pCollateNeeded);
19400f14e2ebSdrh     sqlite3_collation_needed(pDb->db, pDb, tclCollateNeeded);
19410f14e2ebSdrh     break;
19420f14e2ebSdrh   }
19430f14e2ebSdrh 
194419e2d37fSdrh   /*    $db commit_hook ?CALLBACK?
194519e2d37fSdrh   **
194619e2d37fSdrh   ** Invoke the given callback just before committing every SQL transaction.
194719e2d37fSdrh   ** If the callback throws an exception or returns non-zero, then the
194819e2d37fSdrh   ** transaction is aborted.  If CALLBACK is an empty string, the callback
194919e2d37fSdrh   ** is disabled.
195019e2d37fSdrh   */
195119e2d37fSdrh   case DB_COMMIT_HOOK: {
195219e2d37fSdrh     if( objc>3 ){
195319e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
195419e2d37fSdrh       return TCL_ERROR;
195519e2d37fSdrh     }else if( objc==2 ){
195619e2d37fSdrh       if( pDb->zCommit ){
1957a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zCommit, (char*)0);
195819e2d37fSdrh       }
195919e2d37fSdrh     }else{
19606ef5e12eSmistachkin       const char *zCommit;
196119e2d37fSdrh       int len;
196219e2d37fSdrh       if( pDb->zCommit ){
196319e2d37fSdrh         Tcl_Free(pDb->zCommit);
196419e2d37fSdrh       }
196519e2d37fSdrh       zCommit = Tcl_GetStringFromObj(objv[2], &len);
196619e2d37fSdrh       if( zCommit && len>0 ){
196719e2d37fSdrh         pDb->zCommit = Tcl_Alloc( len + 1 );
19685bb3eb9bSdrh         memcpy(pDb->zCommit, zCommit, len+1);
196919e2d37fSdrh       }else{
197019e2d37fSdrh         pDb->zCommit = 0;
197119e2d37fSdrh       }
197219e2d37fSdrh       if( pDb->zCommit ){
197319e2d37fSdrh         pDb->interp = interp;
197419e2d37fSdrh         sqlite3_commit_hook(pDb->db, DbCommitHandler, pDb);
197519e2d37fSdrh       }else{
197619e2d37fSdrh         sqlite3_commit_hook(pDb->db, 0, 0);
197719e2d37fSdrh       }
197819e2d37fSdrh     }
197919e2d37fSdrh     break;
198019e2d37fSdrh   }
198119e2d37fSdrh 
198275897234Sdrh   /*    $db complete SQL
198375897234Sdrh   **
198475897234Sdrh   ** Return TRUE if SQL is a complete SQL statement.  Return FALSE if
198575897234Sdrh   ** additional lines of input are needed.  This is similar to the
198675897234Sdrh   ** built-in "info complete" command of Tcl.
198775897234Sdrh   */
19886d31316cSdrh   case DB_COMPLETE: {
1989ccae6026Sdrh #ifndef SQLITE_OMIT_COMPLETE
19906d31316cSdrh     Tcl_Obj *pResult;
19916d31316cSdrh     int isComplete;
19926d31316cSdrh     if( objc!=3 ){
19936d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "SQL");
199475897234Sdrh       return TCL_ERROR;
199575897234Sdrh     }
19966f8a503dSdanielk1977     isComplete = sqlite3_complete( Tcl_GetStringFromObj(objv[2], 0) );
19976d31316cSdrh     pResult = Tcl_GetObjResult(interp);
19986d31316cSdrh     Tcl_SetBooleanObj(pResult, isComplete);
1999ccae6026Sdrh #endif
20006d31316cSdrh     break;
20016d31316cSdrh   }
200275897234Sdrh 
200319e2d37fSdrh   /*    $db copy conflict-algorithm table filename ?SEPARATOR? ?NULLINDICATOR?
200419e2d37fSdrh   **
200519e2d37fSdrh   ** Copy data into table from filename, optionally using SEPARATOR
200619e2d37fSdrh   ** as column separators.  If a column contains a null string, or the
200719e2d37fSdrh   ** value of NULLINDICATOR, a NULL is inserted for the column.
200819e2d37fSdrh   ** conflict-algorithm is one of the sqlite conflict algorithms:
200919e2d37fSdrh   **    rollback, abort, fail, ignore, replace
201019e2d37fSdrh   ** On success, return the number of lines processed, not necessarily same
201119e2d37fSdrh   ** as 'db changes' due to conflict-algorithm selected.
201219e2d37fSdrh   **
201319e2d37fSdrh   ** This code is basically an implementation/enhancement of
201419e2d37fSdrh   ** the sqlite3 shell.c ".import" command.
201519e2d37fSdrh   **
201619e2d37fSdrh   ** This command usage is equivalent to the sqlite2.x COPY statement,
201719e2d37fSdrh   ** which imports file data into a table using the PostgreSQL COPY file format:
201819e2d37fSdrh   **   $db copy $conflit_algo $table_name $filename \t \\N
201919e2d37fSdrh   */
202019e2d37fSdrh   case DB_COPY: {
202119e2d37fSdrh     char *zTable;               /* Insert data into this table */
202219e2d37fSdrh     char *zFile;                /* The file from which to extract data */
202319e2d37fSdrh     char *zConflict;            /* The conflict algorithm to use */
202419e2d37fSdrh     sqlite3_stmt *pStmt;        /* A statement */
202519e2d37fSdrh     int nCol;                   /* Number of columns in the table */
202619e2d37fSdrh     int nByte;                  /* Number of bytes in an SQL string */
202719e2d37fSdrh     int i, j;                   /* Loop counters */
202819e2d37fSdrh     int nSep;                   /* Number of bytes in zSep[] */
202919e2d37fSdrh     int nNull;                  /* Number of bytes in zNull[] */
203019e2d37fSdrh     char *zSql;                 /* An SQL statement */
203119e2d37fSdrh     char *zLine;                /* A single line of input from the file */
203219e2d37fSdrh     char **azCol;               /* zLine[] broken up into columns */
20336ef5e12eSmistachkin     const char *zCommit;        /* How to commit changes */
203419e2d37fSdrh     FILE *in;                   /* The input file */
203519e2d37fSdrh     int lineno = 0;             /* Line number of input file */
203619e2d37fSdrh     char zLineNum[80];          /* Line number print buffer */
203719e2d37fSdrh     Tcl_Obj *pResult;           /* interp result */
203819e2d37fSdrh 
20396ef5e12eSmistachkin     const char *zSep;
20406ef5e12eSmistachkin     const char *zNull;
204119e2d37fSdrh     if( objc<5 || objc>7 ){
204219e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv,
204319e2d37fSdrh          "CONFLICT-ALGORITHM TABLE FILENAME ?SEPARATOR? ?NULLINDICATOR?");
204419e2d37fSdrh       return TCL_ERROR;
204519e2d37fSdrh     }
204619e2d37fSdrh     if( objc>=6 ){
204719e2d37fSdrh       zSep = Tcl_GetStringFromObj(objv[5], 0);
204819e2d37fSdrh     }else{
204919e2d37fSdrh       zSep = "\t";
205019e2d37fSdrh     }
205119e2d37fSdrh     if( objc>=7 ){
205219e2d37fSdrh       zNull = Tcl_GetStringFromObj(objv[6], 0);
205319e2d37fSdrh     }else{
205419e2d37fSdrh       zNull = "";
205519e2d37fSdrh     }
205619e2d37fSdrh     zConflict = Tcl_GetStringFromObj(objv[2], 0);
205719e2d37fSdrh     zTable = Tcl_GetStringFromObj(objv[3], 0);
205819e2d37fSdrh     zFile = Tcl_GetStringFromObj(objv[4], 0);
20594f21c4afSdrh     nSep = strlen30(zSep);
20604f21c4afSdrh     nNull = strlen30(zNull);
206119e2d37fSdrh     if( nSep==0 ){
2062a198f2b5Sdrh       Tcl_AppendResult(interp,"Error: non-null separator required for copy",
2063a198f2b5Sdrh                        (char*)0);
206419e2d37fSdrh       return TCL_ERROR;
206519e2d37fSdrh     }
20663e59c012Sdrh     if(strcmp(zConflict, "rollback") != 0 &&
20673e59c012Sdrh        strcmp(zConflict, "abort"   ) != 0 &&
20683e59c012Sdrh        strcmp(zConflict, "fail"    ) != 0 &&
20693e59c012Sdrh        strcmp(zConflict, "ignore"  ) != 0 &&
20703e59c012Sdrh        strcmp(zConflict, "replace" ) != 0 ) {
207119e2d37fSdrh       Tcl_AppendResult(interp, "Error: \"", zConflict,
207219e2d37fSdrh             "\", conflict-algorithm must be one of: rollback, "
2073a198f2b5Sdrh             "abort, fail, ignore, or replace", (char*)0);
207419e2d37fSdrh       return TCL_ERROR;
207519e2d37fSdrh     }
207619e2d37fSdrh     zSql = sqlite3_mprintf("SELECT * FROM '%q'", zTable);
207719e2d37fSdrh     if( zSql==0 ){
2078a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: no such table: ", zTable, (char*)0);
207919e2d37fSdrh       return TCL_ERROR;
208019e2d37fSdrh     }
20814f21c4afSdrh     nByte = strlen30(zSql);
20823e701a18Sdrh     rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0);
208319e2d37fSdrh     sqlite3_free(zSql);
208419e2d37fSdrh     if( rc ){
2085a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), (char*)0);
208619e2d37fSdrh       nCol = 0;
208719e2d37fSdrh     }else{
208819e2d37fSdrh       nCol = sqlite3_column_count(pStmt);
208919e2d37fSdrh     }
209019e2d37fSdrh     sqlite3_finalize(pStmt);
209119e2d37fSdrh     if( nCol==0 ) {
209219e2d37fSdrh       return TCL_ERROR;
209319e2d37fSdrh     }
209419e2d37fSdrh     zSql = malloc( nByte + 50 + nCol*2 );
209519e2d37fSdrh     if( zSql==0 ) {
2096a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: can't malloc()", (char*)0);
209719e2d37fSdrh       return TCL_ERROR;
209819e2d37fSdrh     }
209919e2d37fSdrh     sqlite3_snprintf(nByte+50, zSql, "INSERT OR %q INTO '%q' VALUES(?",
210019e2d37fSdrh          zConflict, zTable);
21014f21c4afSdrh     j = strlen30(zSql);
210219e2d37fSdrh     for(i=1; i<nCol; i++){
210319e2d37fSdrh       zSql[j++] = ',';
210419e2d37fSdrh       zSql[j++] = '?';
210519e2d37fSdrh     }
210619e2d37fSdrh     zSql[j++] = ')';
210719e2d37fSdrh     zSql[j] = 0;
21083e701a18Sdrh     rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0);
210919e2d37fSdrh     free(zSql);
211019e2d37fSdrh     if( rc ){
2111a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), (char*)0);
211219e2d37fSdrh       sqlite3_finalize(pStmt);
211319e2d37fSdrh       return TCL_ERROR;
211419e2d37fSdrh     }
211519e2d37fSdrh     in = fopen(zFile, "rb");
211619e2d37fSdrh     if( in==0 ){
211719e2d37fSdrh       Tcl_AppendResult(interp, "Error: cannot open file: ", zFile, NULL);
211819e2d37fSdrh       sqlite3_finalize(pStmt);
211919e2d37fSdrh       return TCL_ERROR;
212019e2d37fSdrh     }
212119e2d37fSdrh     azCol = malloc( sizeof(azCol[0])*(nCol+1) );
212219e2d37fSdrh     if( azCol==0 ) {
2123a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: can't malloc()", (char*)0);
212443617e9aSdrh       fclose(in);
212519e2d37fSdrh       return TCL_ERROR;
212619e2d37fSdrh     }
21273752785fSdrh     (void)sqlite3_exec(pDb->db, "BEGIN", 0, 0, 0);
212819e2d37fSdrh     zCommit = "COMMIT";
212919e2d37fSdrh     while( (zLine = local_getline(0, in))!=0 ){
213019e2d37fSdrh       char *z;
213119e2d37fSdrh       lineno++;
213219e2d37fSdrh       azCol[0] = zLine;
213319e2d37fSdrh       for(i=0, z=zLine; *z; z++){
213419e2d37fSdrh         if( *z==zSep[0] && strncmp(z, zSep, nSep)==0 ){
213519e2d37fSdrh           *z = 0;
213619e2d37fSdrh           i++;
213719e2d37fSdrh           if( i<nCol ){
213819e2d37fSdrh             azCol[i] = &z[nSep];
213919e2d37fSdrh             z += nSep-1;
214019e2d37fSdrh           }
214119e2d37fSdrh         }
214219e2d37fSdrh       }
214319e2d37fSdrh       if( i+1!=nCol ){
214419e2d37fSdrh         char *zErr;
21454f21c4afSdrh         int nErr = strlen30(zFile) + 200;
21465bb3eb9bSdrh         zErr = malloc(nErr);
2147c1f4494eSdrh         if( zErr ){
21485bb3eb9bSdrh           sqlite3_snprintf(nErr, zErr,
2149955de52cSdanielk1977              "Error: %s line %d: expected %d columns of data but found %d",
215019e2d37fSdrh              zFile, lineno, nCol, i+1);
2151a198f2b5Sdrh           Tcl_AppendResult(interp, zErr, (char*)0);
215219e2d37fSdrh           free(zErr);
2153c1f4494eSdrh         }
215419e2d37fSdrh         zCommit = "ROLLBACK";
215519e2d37fSdrh         break;
215619e2d37fSdrh       }
215719e2d37fSdrh       for(i=0; i<nCol; i++){
215819e2d37fSdrh         /* check for null data, if so, bind as null */
2159ea678832Sdrh         if( (nNull>0 && strcmp(azCol[i], zNull)==0)
21604f21c4afSdrh           || strlen30(azCol[i])==0
2161ea678832Sdrh         ){
216219e2d37fSdrh           sqlite3_bind_null(pStmt, i+1);
216319e2d37fSdrh         }else{
216419e2d37fSdrh           sqlite3_bind_text(pStmt, i+1, azCol[i], -1, SQLITE_STATIC);
216519e2d37fSdrh         }
216619e2d37fSdrh       }
216719e2d37fSdrh       sqlite3_step(pStmt);
216819e2d37fSdrh       rc = sqlite3_reset(pStmt);
216919e2d37fSdrh       free(zLine);
217019e2d37fSdrh       if( rc!=SQLITE_OK ){
2171a198f2b5Sdrh         Tcl_AppendResult(interp,"Error: ", sqlite3_errmsg(pDb->db), (char*)0);
217219e2d37fSdrh         zCommit = "ROLLBACK";
217319e2d37fSdrh         break;
217419e2d37fSdrh       }
217519e2d37fSdrh     }
217619e2d37fSdrh     free(azCol);
217719e2d37fSdrh     fclose(in);
217819e2d37fSdrh     sqlite3_finalize(pStmt);
21793752785fSdrh     (void)sqlite3_exec(pDb->db, zCommit, 0, 0, 0);
218019e2d37fSdrh 
218119e2d37fSdrh     if( zCommit[0] == 'C' ){
218219e2d37fSdrh       /* success, set result as number of lines processed */
218319e2d37fSdrh       pResult = Tcl_GetObjResult(interp);
218419e2d37fSdrh       Tcl_SetIntObj(pResult, lineno);
218519e2d37fSdrh       rc = TCL_OK;
218619e2d37fSdrh     }else{
218719e2d37fSdrh       /* failure, append lineno where failed */
21885bb3eb9bSdrh       sqlite3_snprintf(sizeof(zLineNum), zLineNum,"%d",lineno);
2189a198f2b5Sdrh       Tcl_AppendResult(interp,", failed while processing line: ",zLineNum,
2190a198f2b5Sdrh                        (char*)0);
219119e2d37fSdrh       rc = TCL_ERROR;
219219e2d37fSdrh     }
219319e2d37fSdrh     break;
219419e2d37fSdrh   }
219519e2d37fSdrh 
219675897234Sdrh   /*
21974144905bSdrh   **    $db enable_load_extension BOOLEAN
21984144905bSdrh   **
21994144905bSdrh   ** Turn the extension loading feature on or off.  It if off by
22004144905bSdrh   ** default.
22014144905bSdrh   */
22024144905bSdrh   case DB_ENABLE_LOAD_EXTENSION: {
2203f533acc0Sdrh #ifndef SQLITE_OMIT_LOAD_EXTENSION
22044144905bSdrh     int onoff;
22054144905bSdrh     if( objc!=3 ){
22064144905bSdrh       Tcl_WrongNumArgs(interp, 2, objv, "BOOLEAN");
22074144905bSdrh       return TCL_ERROR;
22084144905bSdrh     }
22094144905bSdrh     if( Tcl_GetBooleanFromObj(interp, objv[2], &onoff) ){
22104144905bSdrh       return TCL_ERROR;
22114144905bSdrh     }
22124144905bSdrh     sqlite3_enable_load_extension(pDb->db, onoff);
22134144905bSdrh     break;
2214f533acc0Sdrh #else
2215f533acc0Sdrh     Tcl_AppendResult(interp, "extension loading is turned off at compile-time",
2216a198f2b5Sdrh                      (char*)0);
2217f533acc0Sdrh     return TCL_ERROR;
2218f533acc0Sdrh #endif
22194144905bSdrh   }
22204144905bSdrh 
22214144905bSdrh   /*
2222dcd997eaSdrh   **    $db errorcode
2223dcd997eaSdrh   **
2224dcd997eaSdrh   ** Return the numeric error code that was returned by the most recent
22256f8a503dSdanielk1977   ** call to sqlite3_exec().
2226dcd997eaSdrh   */
2227dcd997eaSdrh   case DB_ERRORCODE: {
2228f3ce83f5Sdanielk1977     Tcl_SetObjResult(interp, Tcl_NewIntObj(sqlite3_errcode(pDb->db)));
2229dcd997eaSdrh     break;
2230dcd997eaSdrh   }
2231dcd997eaSdrh 
2232dcd997eaSdrh   /*
22334a4c11aaSdan   **    $db exists $sql
22341807ce37Sdrh   **    $db onecolumn $sql
223575897234Sdrh   **
22364a4c11aaSdan   ** The onecolumn method is the equivalent of:
22374a4c11aaSdan   **     lindex [$db eval $sql] 0
22384a4c11aaSdan   */
22394a4c11aaSdan   case DB_EXISTS:
22404a4c11aaSdan   case DB_ONECOLUMN: {
22414a4c11aaSdan     DbEvalContext sEval;
22424a4c11aaSdan     if( objc!=3 ){
22434a4c11aaSdan       Tcl_WrongNumArgs(interp, 2, objv, "SQL");
22444a4c11aaSdan       return TCL_ERROR;
22454a4c11aaSdan     }
22464a4c11aaSdan 
22474a4c11aaSdan     dbEvalInit(&sEval, pDb, objv[2], 0);
22484a4c11aaSdan     rc = dbEvalStep(&sEval);
22494a4c11aaSdan     if( choice==DB_ONECOLUMN ){
22504a4c11aaSdan       if( rc==TCL_OK ){
22514a4c11aaSdan         Tcl_SetObjResult(interp, dbEvalColumnValue(&sEval, 0));
2252d5f12cd5Sdan       }else if( rc==TCL_BREAK ){
2253d5f12cd5Sdan         Tcl_ResetResult(interp);
22544a4c11aaSdan       }
22554a4c11aaSdan     }else if( rc==TCL_BREAK || rc==TCL_OK ){
22564a4c11aaSdan       Tcl_SetObjResult(interp, Tcl_NewBooleanObj(rc==TCL_OK));
22574a4c11aaSdan     }
22584a4c11aaSdan     dbEvalFinalize(&sEval);
22594a4c11aaSdan 
22604a4c11aaSdan     if( rc==TCL_BREAK ){
22614a4c11aaSdan       rc = TCL_OK;
22624a4c11aaSdan     }
22634a4c11aaSdan     break;
22644a4c11aaSdan   }
22654a4c11aaSdan 
22664a4c11aaSdan   /*
22674a4c11aaSdan   **    $db eval $sql ?array? ?{  ...code... }?
22684a4c11aaSdan   **
226975897234Sdrh   ** The SQL statement in $sql is evaluated.  For each row, the values are
2270bec3f402Sdrh   ** placed in elements of the array named "array" and ...code... is executed.
227175897234Sdrh   ** If "array" and "code" are omitted, then no callback is every invoked.
227275897234Sdrh   ** If "array" is an empty string, then the values are placed in variables
227375897234Sdrh   ** that have the same name as the fields extracted by the query.
227475897234Sdrh   */
22754a4c11aaSdan   case DB_EVAL: {
227692febd92Sdrh     if( objc<3 || objc>5 ){
2277895d7472Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "SQL ?ARRAY-NAME? ?SCRIPT?");
227830ccda10Sdanielk1977       return TCL_ERROR;
227930ccda10Sdanielk1977     }
22804a4c11aaSdan 
228192febd92Sdrh     if( objc==3 ){
22824a4c11aaSdan       DbEvalContext sEval;
22834a4c11aaSdan       Tcl_Obj *pRet = Tcl_NewObj();
22844a4c11aaSdan       Tcl_IncrRefCount(pRet);
22854a4c11aaSdan       dbEvalInit(&sEval, pDb, objv[2], 0);
22864a4c11aaSdan       while( TCL_OK==(rc = dbEvalStep(&sEval)) ){
22874a4c11aaSdan         int i;
22884a4c11aaSdan         int nCol;
22894a4c11aaSdan         dbEvalRowInfo(&sEval, &nCol, 0);
229092febd92Sdrh         for(i=0; i<nCol; i++){
22914a4c11aaSdan           Tcl_ListObjAppendElement(interp, pRet, dbEvalColumnValue(&sEval, i));
229292febd92Sdrh         }
229330ccda10Sdanielk1977       }
22944a4c11aaSdan       dbEvalFinalize(&sEval);
229590b6bb19Sdrh       if( rc==TCL_BREAK ){
22964a4c11aaSdan         Tcl_SetObjResult(interp, pRet);
229790b6bb19Sdrh         rc = TCL_OK;
229890b6bb19Sdrh       }
2299ef2cb63eSdanielk1977       Tcl_DecrRefCount(pRet);
23004a4c11aaSdan     }else{
23018e18922fSmistachkin       ClientData cd2[2];
23024a4c11aaSdan       DbEvalContext *p;
23034a4c11aaSdan       Tcl_Obj *pArray = 0;
23044a4c11aaSdan       Tcl_Obj *pScript;
23054a4c11aaSdan 
23064a4c11aaSdan       if( objc==5 && *(char *)Tcl_GetString(objv[3]) ){
23074a4c11aaSdan         pArray = objv[3];
23084a4c11aaSdan       }
23094a4c11aaSdan       pScript = objv[objc-1];
23104a4c11aaSdan       Tcl_IncrRefCount(pScript);
23114a4c11aaSdan 
23124a4c11aaSdan       p = (DbEvalContext *)Tcl_Alloc(sizeof(DbEvalContext));
23134a4c11aaSdan       dbEvalInit(p, pDb, objv[2], pArray);
23144a4c11aaSdan 
23158e18922fSmistachkin       cd2[0] = (void *)p;
23168e18922fSmistachkin       cd2[1] = (void *)pScript;
23178e18922fSmistachkin       rc = DbEvalNextCmd(cd2, interp, TCL_OK);
23181807ce37Sdrh     }
231930ccda10Sdanielk1977     break;
232030ccda10Sdanielk1977   }
2321bec3f402Sdrh 
2322bec3f402Sdrh   /*
23233df30592Sdan   **     $db function NAME [-argcount N] [-deterministic] SCRIPT
2324cabb0819Sdrh   **
2325cabb0819Sdrh   ** Create a new SQL function called NAME.  Whenever that function is
2326cabb0819Sdrh   ** called, invoke SCRIPT to evaluate the function.
2327cabb0819Sdrh   */
2328cabb0819Sdrh   case DB_FUNCTION: {
23293df30592Sdan     int flags = SQLITE_UTF8;
2330cabb0819Sdrh     SqlFunc *pFunc;
2331d1e4733dSdrh     Tcl_Obj *pScript;
2332cabb0819Sdrh     char *zName;
2333e3602be8Sdrh     int nArg = -1;
23343df30592Sdan     int i;
23353df30592Sdan     if( objc<4 ){
23363df30592Sdan       Tcl_WrongNumArgs(interp, 2, objv, "NAME ?SWITCHES? SCRIPT");
23373df30592Sdan       return TCL_ERROR;
23383df30592Sdan     }
23393df30592Sdan     for(i=3; i<(objc-1); i++){
23403df30592Sdan       const char *z = Tcl_GetString(objv[i]);
23414f21c4afSdrh       int n = strlen30(z);
2342e3602be8Sdrh       if( n>2 && strncmp(z, "-argcount",n)==0 ){
23433df30592Sdan         if( i==(objc-2) ){
23443df30592Sdan           Tcl_AppendResult(interp, "option requires an argument: ", z, 0);
23453df30592Sdan           return TCL_ERROR;
23463df30592Sdan         }
23473df30592Sdan         if( Tcl_GetIntFromObj(interp, objv[i+1], &nArg) ) return TCL_ERROR;
2348e3602be8Sdrh         if( nArg<0 ){
2349e3602be8Sdrh           Tcl_AppendResult(interp, "number of arguments must be non-negative",
2350e3602be8Sdrh                            (char*)0);
2351cabb0819Sdrh           return TCL_ERROR;
2352cabb0819Sdrh         }
23533df30592Sdan         i++;
23543df30592Sdan       }else
23553df30592Sdan       if( n>2 && strncmp(z, "-deterministic",n)==0 ){
23563df30592Sdan         flags |= SQLITE_DETERMINISTIC;
2357e3602be8Sdrh       }else{
23583df30592Sdan         Tcl_AppendResult(interp, "bad option \"", z,
23593df30592Sdan             "\": must be -argcount or -deterministic", 0
23603df30592Sdan         );
23613df30592Sdan         return TCL_ERROR;
2362e3602be8Sdrh       }
23633df30592Sdan     }
23643df30592Sdan 
23653df30592Sdan     pScript = objv[objc-1];
2366e3602be8Sdrh     zName = Tcl_GetStringFromObj(objv[2], 0);
2367d1e4733dSdrh     pFunc = findSqlFunc(pDb, zName);
2368cabb0819Sdrh     if( pFunc==0 ) return TCL_ERROR;
2369d1e4733dSdrh     if( pFunc->pScript ){
2370d1e4733dSdrh       Tcl_DecrRefCount(pFunc->pScript);
2371d1e4733dSdrh     }
2372d1e4733dSdrh     pFunc->pScript = pScript;
2373d1e4733dSdrh     Tcl_IncrRefCount(pScript);
2374d1e4733dSdrh     pFunc->useEvalObjv = safeToUseEvalObjv(interp, pScript);
23753df30592Sdan     rc = sqlite3_create_function(pDb->db, zName, nArg, flags,
2376d8123366Sdanielk1977         pFunc, tclSqlFunc, 0, 0);
2377fb7e7651Sdrh     if( rc!=SQLITE_OK ){
2378fb7e7651Sdrh       rc = TCL_ERROR;
23799636c4e1Sdanielk1977       Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
2380fb7e7651Sdrh     }
2381cabb0819Sdrh     break;
2382cabb0819Sdrh   }
2383cabb0819Sdrh 
2384cabb0819Sdrh   /*
23858cbadb02Sdanielk1977   **     $db incrblob ?-readonly? ?DB? TABLE COLUMN ROWID
2386b4e9af9fSdanielk1977   */
2387b4e9af9fSdanielk1977   case DB_INCRBLOB: {
238832a0d8bbSdanielk1977 #ifdef SQLITE_OMIT_INCRBLOB
2389a198f2b5Sdrh     Tcl_AppendResult(interp, "incrblob not available in this build", (char*)0);
239032a0d8bbSdanielk1977     return TCL_ERROR;
239132a0d8bbSdanielk1977 #else
23928cbadb02Sdanielk1977     int isReadonly = 0;
2393b4e9af9fSdanielk1977     const char *zDb = "main";
2394b4e9af9fSdanielk1977     const char *zTable;
2395b4e9af9fSdanielk1977     const char *zColumn;
2396b3f787f4Sdrh     Tcl_WideInt iRow;
2397b4e9af9fSdanielk1977 
23988cbadb02Sdanielk1977     /* Check for the -readonly option */
23998cbadb02Sdanielk1977     if( objc>3 && strcmp(Tcl_GetString(objv[2]), "-readonly")==0 ){
24008cbadb02Sdanielk1977       isReadonly = 1;
24018cbadb02Sdanielk1977     }
24028cbadb02Sdanielk1977 
24038cbadb02Sdanielk1977     if( objc!=(5+isReadonly) && objc!=(6+isReadonly) ){
24048cbadb02Sdanielk1977       Tcl_WrongNumArgs(interp, 2, objv, "?-readonly? ?DB? TABLE COLUMN ROWID");
2405b4e9af9fSdanielk1977       return TCL_ERROR;
2406b4e9af9fSdanielk1977     }
2407b4e9af9fSdanielk1977 
24088cbadb02Sdanielk1977     if( objc==(6+isReadonly) ){
2409b4e9af9fSdanielk1977       zDb = Tcl_GetString(objv[2]);
2410b4e9af9fSdanielk1977     }
2411b4e9af9fSdanielk1977     zTable = Tcl_GetString(objv[objc-3]);
2412b4e9af9fSdanielk1977     zColumn = Tcl_GetString(objv[objc-2]);
2413b4e9af9fSdanielk1977     rc = Tcl_GetWideIntFromObj(interp, objv[objc-1], &iRow);
2414b4e9af9fSdanielk1977 
2415b4e9af9fSdanielk1977     if( rc==TCL_OK ){
24168cbadb02Sdanielk1977       rc = createIncrblobChannel(
2417edf5b165Sdan           interp, pDb, zDb, zTable, zColumn, (sqlite3_int64)iRow, isReadonly
24188cbadb02Sdanielk1977       );
2419b4e9af9fSdanielk1977     }
242032a0d8bbSdanielk1977 #endif
2421b4e9af9fSdanielk1977     break;
2422b4e9af9fSdanielk1977   }
2423b4e9af9fSdanielk1977 
2424b4e9af9fSdanielk1977   /*
2425f11bded5Sdrh   **     $db interrupt
2426f11bded5Sdrh   **
2427f11bded5Sdrh   ** Interrupt the execution of the inner-most SQL interpreter.  This
2428f11bded5Sdrh   ** causes the SQL statement to return an error of SQLITE_INTERRUPT.
2429f11bded5Sdrh   */
2430f11bded5Sdrh   case DB_INTERRUPT: {
2431f11bded5Sdrh     sqlite3_interrupt(pDb->db);
2432f11bded5Sdrh     break;
2433f11bded5Sdrh   }
2434f11bded5Sdrh 
2435f11bded5Sdrh   /*
243619e2d37fSdrh   **     $db nullvalue ?STRING?
243719e2d37fSdrh   **
243819e2d37fSdrh   ** Change text used when a NULL comes back from the database. If ?STRING?
243919e2d37fSdrh   ** is not present, then the current string used for NULL is returned.
244019e2d37fSdrh   ** If STRING is present, then STRING is returned.
244119e2d37fSdrh   **
244219e2d37fSdrh   */
244319e2d37fSdrh   case DB_NULLVALUE: {
244419e2d37fSdrh     if( objc!=2 && objc!=3 ){
244519e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "NULLVALUE");
244619e2d37fSdrh       return TCL_ERROR;
244719e2d37fSdrh     }
244819e2d37fSdrh     if( objc==3 ){
244919e2d37fSdrh       int len;
245019e2d37fSdrh       char *zNull = Tcl_GetStringFromObj(objv[2], &len);
245119e2d37fSdrh       if( pDb->zNull ){
245219e2d37fSdrh         Tcl_Free(pDb->zNull);
245319e2d37fSdrh       }
245419e2d37fSdrh       if( zNull && len>0 ){
245519e2d37fSdrh         pDb->zNull = Tcl_Alloc( len + 1 );
24567fd33929Sdrh         memcpy(pDb->zNull, zNull, len);
245719e2d37fSdrh         pDb->zNull[len] = '\0';
245819e2d37fSdrh       }else{
245919e2d37fSdrh         pDb->zNull = 0;
246019e2d37fSdrh       }
246119e2d37fSdrh     }
2462c45e6716Sdrh     Tcl_SetObjResult(interp, Tcl_NewStringObj(pDb->zNull, -1));
246319e2d37fSdrh     break;
246419e2d37fSdrh   }
246519e2d37fSdrh 
246619e2d37fSdrh   /*
2467af9ff33aSdrh   **     $db last_insert_rowid
2468af9ff33aSdrh   **
2469af9ff33aSdrh   ** Return an integer which is the ROWID for the most recent insert.
2470af9ff33aSdrh   */
2471af9ff33aSdrh   case DB_LAST_INSERT_ROWID: {
2472af9ff33aSdrh     Tcl_Obj *pResult;
2473f7e678d6Sdrh     Tcl_WideInt rowid;
2474af9ff33aSdrh     if( objc!=2 ){
2475af9ff33aSdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
2476af9ff33aSdrh       return TCL_ERROR;
2477af9ff33aSdrh     }
24786f8a503dSdanielk1977     rowid = sqlite3_last_insert_rowid(pDb->db);
2479af9ff33aSdrh     pResult = Tcl_GetObjResult(interp);
2480f7e678d6Sdrh     Tcl_SetWideIntObj(pResult, rowid);
2481af9ff33aSdrh     break;
2482af9ff33aSdrh   }
2483af9ff33aSdrh 
2484af9ff33aSdrh   /*
24854a4c11aaSdan   ** The DB_ONECOLUMN method is implemented together with DB_EXISTS.
24865d9d7576Sdrh   */
24871807ce37Sdrh 
24881807ce37Sdrh   /*    $db progress ?N CALLBACK?
24891807ce37Sdrh   **
24901807ce37Sdrh   ** Invoke the given callback every N virtual machine opcodes while executing
24911807ce37Sdrh   ** queries.
24921807ce37Sdrh   */
24931807ce37Sdrh   case DB_PROGRESS: {
24941807ce37Sdrh     if( objc==2 ){
24951807ce37Sdrh       if( pDb->zProgress ){
2496a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zProgress, (char*)0);
24975d9d7576Sdrh       }
24981807ce37Sdrh     }else if( objc==4 ){
24991807ce37Sdrh       char *zProgress;
25001807ce37Sdrh       int len;
25011807ce37Sdrh       int N;
25021807ce37Sdrh       if( TCL_OK!=Tcl_GetIntFromObj(interp, objv[2], &N) ){
25031807ce37Sdrh         return TCL_ERROR;
25041807ce37Sdrh       };
25051807ce37Sdrh       if( pDb->zProgress ){
25061807ce37Sdrh         Tcl_Free(pDb->zProgress);
25071807ce37Sdrh       }
25081807ce37Sdrh       zProgress = Tcl_GetStringFromObj(objv[3], &len);
25091807ce37Sdrh       if( zProgress && len>0 ){
25101807ce37Sdrh         pDb->zProgress = Tcl_Alloc( len + 1 );
25115bb3eb9bSdrh         memcpy(pDb->zProgress, zProgress, len+1);
25121807ce37Sdrh       }else{
25131807ce37Sdrh         pDb->zProgress = 0;
25141807ce37Sdrh       }
25151807ce37Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK
25161807ce37Sdrh       if( pDb->zProgress ){
25171807ce37Sdrh         pDb->interp = interp;
25181807ce37Sdrh         sqlite3_progress_handler(pDb->db, N, DbProgressHandler, pDb);
25191807ce37Sdrh       }else{
25201807ce37Sdrh         sqlite3_progress_handler(pDb->db, 0, 0, 0);
25211807ce37Sdrh       }
25221807ce37Sdrh #endif
25231807ce37Sdrh     }else{
25241807ce37Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "N CALLBACK");
25251807ce37Sdrh       return TCL_ERROR;
25265d9d7576Sdrh     }
25275d9d7576Sdrh     break;
25285d9d7576Sdrh   }
25295d9d7576Sdrh 
253019e2d37fSdrh   /*    $db profile ?CALLBACK?
253119e2d37fSdrh   **
253219e2d37fSdrh   ** Make arrangements to invoke the CALLBACK routine after each SQL statement
253319e2d37fSdrh   ** that has run.  The text of the SQL and the amount of elapse time are
253419e2d37fSdrh   ** appended to CALLBACK before the script is run.
253519e2d37fSdrh   */
253619e2d37fSdrh   case DB_PROFILE: {
253719e2d37fSdrh     if( objc>3 ){
253819e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
253919e2d37fSdrh       return TCL_ERROR;
254019e2d37fSdrh     }else if( objc==2 ){
254119e2d37fSdrh       if( pDb->zProfile ){
2542a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zProfile, (char*)0);
254319e2d37fSdrh       }
254419e2d37fSdrh     }else{
254519e2d37fSdrh       char *zProfile;
254619e2d37fSdrh       int len;
254719e2d37fSdrh       if( pDb->zProfile ){
254819e2d37fSdrh         Tcl_Free(pDb->zProfile);
254919e2d37fSdrh       }
255019e2d37fSdrh       zProfile = Tcl_GetStringFromObj(objv[2], &len);
255119e2d37fSdrh       if( zProfile && len>0 ){
255219e2d37fSdrh         pDb->zProfile = Tcl_Alloc( len + 1 );
25535bb3eb9bSdrh         memcpy(pDb->zProfile, zProfile, len+1);
255419e2d37fSdrh       }else{
255519e2d37fSdrh         pDb->zProfile = 0;
255619e2d37fSdrh       }
2557bb201344Sshaneh #if !defined(SQLITE_OMIT_TRACE) && !defined(SQLITE_OMIT_FLOATING_POINT)
255819e2d37fSdrh       if( pDb->zProfile ){
255919e2d37fSdrh         pDb->interp = interp;
256019e2d37fSdrh         sqlite3_profile(pDb->db, DbProfileHandler, pDb);
256119e2d37fSdrh       }else{
256219e2d37fSdrh         sqlite3_profile(pDb->db, 0, 0);
256319e2d37fSdrh       }
256419e2d37fSdrh #endif
256519e2d37fSdrh     }
256619e2d37fSdrh     break;
256719e2d37fSdrh   }
256819e2d37fSdrh 
25695d9d7576Sdrh   /*
257022fbcb8dSdrh   **     $db rekey KEY
257122fbcb8dSdrh   **
257222fbcb8dSdrh   ** Change the encryption key on the currently open database.
257322fbcb8dSdrh   */
257422fbcb8dSdrh   case DB_REKEY: {
2575b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
257622fbcb8dSdrh     int nKey;
257722fbcb8dSdrh     void *pKey;
2578b07028f7Sdrh #endif
257922fbcb8dSdrh     if( objc!=3 ){
258022fbcb8dSdrh       Tcl_WrongNumArgs(interp, 2, objv, "KEY");
258122fbcb8dSdrh       return TCL_ERROR;
258222fbcb8dSdrh     }
25839eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
2584b07028f7Sdrh     pKey = Tcl_GetByteArrayFromObj(objv[2], &nKey);
25852011d5f5Sdrh     rc = sqlite3_rekey(pDb->db, pKey, nKey);
258622fbcb8dSdrh     if( rc ){
2587a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errstr(rc), (char*)0);
258822fbcb8dSdrh       rc = TCL_ERROR;
258922fbcb8dSdrh     }
259022fbcb8dSdrh #endif
259122fbcb8dSdrh     break;
259222fbcb8dSdrh   }
259322fbcb8dSdrh 
2594dc2c4915Sdrh   /*    $db restore ?DATABASE? FILENAME
2595dc2c4915Sdrh   **
2596dc2c4915Sdrh   ** Open a database file named FILENAME.  Transfer the content
2597dc2c4915Sdrh   ** of FILENAME into the local database DATABASE (default: "main").
2598dc2c4915Sdrh   */
2599dc2c4915Sdrh   case DB_RESTORE: {
2600dc2c4915Sdrh     const char *zSrcFile;
2601dc2c4915Sdrh     const char *zDestDb;
2602dc2c4915Sdrh     sqlite3 *pSrc;
2603dc2c4915Sdrh     sqlite3_backup *pBackup;
2604dc2c4915Sdrh     int nTimeout = 0;
2605dc2c4915Sdrh 
2606dc2c4915Sdrh     if( objc==3 ){
2607dc2c4915Sdrh       zDestDb = "main";
2608dc2c4915Sdrh       zSrcFile = Tcl_GetString(objv[2]);
2609dc2c4915Sdrh     }else if( objc==4 ){
2610dc2c4915Sdrh       zDestDb = Tcl_GetString(objv[2]);
2611dc2c4915Sdrh       zSrcFile = Tcl_GetString(objv[3]);
2612dc2c4915Sdrh     }else{
2613dc2c4915Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "?DATABASE? FILENAME");
2614dc2c4915Sdrh       return TCL_ERROR;
2615dc2c4915Sdrh     }
2616dc2c4915Sdrh     rc = sqlite3_open_v2(zSrcFile, &pSrc, SQLITE_OPEN_READONLY, 0);
2617dc2c4915Sdrh     if( rc!=SQLITE_OK ){
2618dc2c4915Sdrh       Tcl_AppendResult(interp, "cannot open source database: ",
2619dc2c4915Sdrh            sqlite3_errmsg(pSrc), (char*)0);
2620dc2c4915Sdrh       sqlite3_close(pSrc);
2621dc2c4915Sdrh       return TCL_ERROR;
2622dc2c4915Sdrh     }
2623dc2c4915Sdrh     pBackup = sqlite3_backup_init(pDb->db, zDestDb, pSrc, "main");
2624dc2c4915Sdrh     if( pBackup==0 ){
2625dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: ",
2626dc2c4915Sdrh            sqlite3_errmsg(pDb->db), (char*)0);
2627dc2c4915Sdrh       sqlite3_close(pSrc);
2628dc2c4915Sdrh       return TCL_ERROR;
2629dc2c4915Sdrh     }
2630dc2c4915Sdrh     while( (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK
2631dc2c4915Sdrh               || rc==SQLITE_BUSY ){
2632dc2c4915Sdrh       if( rc==SQLITE_BUSY ){
2633dc2c4915Sdrh         if( nTimeout++ >= 3 ) break;
2634dc2c4915Sdrh         sqlite3_sleep(100);
2635dc2c4915Sdrh       }
2636dc2c4915Sdrh     }
2637dc2c4915Sdrh     sqlite3_backup_finish(pBackup);
2638dc2c4915Sdrh     if( rc==SQLITE_DONE ){
2639dc2c4915Sdrh       rc = TCL_OK;
2640dc2c4915Sdrh     }else if( rc==SQLITE_BUSY || rc==SQLITE_LOCKED ){
2641dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: source database busy",
2642dc2c4915Sdrh                        (char*)0);
2643dc2c4915Sdrh       rc = TCL_ERROR;
2644dc2c4915Sdrh     }else{
2645dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: ",
2646dc2c4915Sdrh            sqlite3_errmsg(pDb->db), (char*)0);
2647dc2c4915Sdrh       rc = TCL_ERROR;
2648dc2c4915Sdrh     }
2649dc2c4915Sdrh     sqlite3_close(pSrc);
2650dc2c4915Sdrh     break;
2651dc2c4915Sdrh   }
2652dc2c4915Sdrh 
265322fbcb8dSdrh   /*
26543c379b01Sdrh   **     $db status (step|sort|autoindex)
2655d1d38488Sdrh   **
2656d1d38488Sdrh   ** Display SQLITE_STMTSTATUS_FULLSCAN_STEP or
2657d1d38488Sdrh   ** SQLITE_STMTSTATUS_SORT for the most recent eval.
2658d1d38488Sdrh   */
2659d1d38488Sdrh   case DB_STATUS: {
2660d1d38488Sdrh     int v;
2661d1d38488Sdrh     const char *zOp;
2662d1d38488Sdrh     if( objc!=3 ){
26631c320a43Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "(step|sort|autoindex)");
2664d1d38488Sdrh       return TCL_ERROR;
2665d1d38488Sdrh     }
2666d1d38488Sdrh     zOp = Tcl_GetString(objv[2]);
2667d1d38488Sdrh     if( strcmp(zOp, "step")==0 ){
2668d1d38488Sdrh       v = pDb->nStep;
2669d1d38488Sdrh     }else if( strcmp(zOp, "sort")==0 ){
2670d1d38488Sdrh       v = pDb->nSort;
26713c379b01Sdrh     }else if( strcmp(zOp, "autoindex")==0 ){
26723c379b01Sdrh       v = pDb->nIndex;
2673d1d38488Sdrh     }else{
26743c379b01Sdrh       Tcl_AppendResult(interp,
26753c379b01Sdrh             "bad argument: should be autoindex, step, or sort",
2676d1d38488Sdrh             (char*)0);
2677d1d38488Sdrh       return TCL_ERROR;
2678d1d38488Sdrh     }
2679d1d38488Sdrh     Tcl_SetObjResult(interp, Tcl_NewIntObj(v));
2680d1d38488Sdrh     break;
2681d1d38488Sdrh   }
2682d1d38488Sdrh 
2683d1d38488Sdrh   /*
2684bec3f402Sdrh   **     $db timeout MILLESECONDS
2685bec3f402Sdrh   **
2686bec3f402Sdrh   ** Delay for the number of milliseconds specified when a file is locked.
2687bec3f402Sdrh   */
26886d31316cSdrh   case DB_TIMEOUT: {
2689bec3f402Sdrh     int ms;
26906d31316cSdrh     if( objc!=3 ){
26916d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "MILLISECONDS");
2692bec3f402Sdrh       return TCL_ERROR;
269375897234Sdrh     }
26946d31316cSdrh     if( Tcl_GetIntFromObj(interp, objv[2], &ms) ) return TCL_ERROR;
26956f8a503dSdanielk1977     sqlite3_busy_timeout(pDb->db, ms);
26966d31316cSdrh     break;
269775897234Sdrh   }
2698b5a20d3cSdrh 
26990f14e2ebSdrh   /*
27000f14e2ebSdrh   **     $db total_changes
27010f14e2ebSdrh   **
27020f14e2ebSdrh   ** Return the number of rows that were modified, inserted, or deleted
27030f14e2ebSdrh   ** since the database handle was created.
27040f14e2ebSdrh   */
27050f14e2ebSdrh   case DB_TOTAL_CHANGES: {
27060f14e2ebSdrh     Tcl_Obj *pResult;
27070f14e2ebSdrh     if( objc!=2 ){
27080f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
27090f14e2ebSdrh       return TCL_ERROR;
27100f14e2ebSdrh     }
27110f14e2ebSdrh     pResult = Tcl_GetObjResult(interp);
27120f14e2ebSdrh     Tcl_SetIntObj(pResult, sqlite3_total_changes(pDb->db));
27130f14e2ebSdrh     break;
27140f14e2ebSdrh   }
27150f14e2ebSdrh 
2716b5a20d3cSdrh   /*    $db trace ?CALLBACK?
2717b5a20d3cSdrh   **
2718b5a20d3cSdrh   ** Make arrangements to invoke the CALLBACK routine for each SQL statement
2719b5a20d3cSdrh   ** that is executed.  The text of the SQL is appended to CALLBACK before
2720b5a20d3cSdrh   ** it is executed.
2721b5a20d3cSdrh   */
2722b5a20d3cSdrh   case DB_TRACE: {
2723b5a20d3cSdrh     if( objc>3 ){
2724b5a20d3cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
2725b97759edSdrh       return TCL_ERROR;
2726b5a20d3cSdrh     }else if( objc==2 ){
2727b5a20d3cSdrh       if( pDb->zTrace ){
2728a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zTrace, (char*)0);
2729b5a20d3cSdrh       }
2730b5a20d3cSdrh     }else{
2731b5a20d3cSdrh       char *zTrace;
2732b5a20d3cSdrh       int len;
2733b5a20d3cSdrh       if( pDb->zTrace ){
2734b5a20d3cSdrh         Tcl_Free(pDb->zTrace);
2735b5a20d3cSdrh       }
2736b5a20d3cSdrh       zTrace = Tcl_GetStringFromObj(objv[2], &len);
2737b5a20d3cSdrh       if( zTrace && len>0 ){
2738b5a20d3cSdrh         pDb->zTrace = Tcl_Alloc( len + 1 );
27395bb3eb9bSdrh         memcpy(pDb->zTrace, zTrace, len+1);
2740b5a20d3cSdrh       }else{
2741b5a20d3cSdrh         pDb->zTrace = 0;
2742b5a20d3cSdrh       }
2743bb201344Sshaneh #if !defined(SQLITE_OMIT_TRACE) && !defined(SQLITE_OMIT_FLOATING_POINT)
2744b5a20d3cSdrh       if( pDb->zTrace ){
2745b5a20d3cSdrh         pDb->interp = interp;
27466f8a503dSdanielk1977         sqlite3_trace(pDb->db, DbTraceHandler, pDb);
2747b5a20d3cSdrh       }else{
27486f8a503dSdanielk1977         sqlite3_trace(pDb->db, 0, 0);
2749b5a20d3cSdrh       }
275019e2d37fSdrh #endif
2751b5a20d3cSdrh     }
2752b5a20d3cSdrh     break;
2753b5a20d3cSdrh   }
2754b5a20d3cSdrh 
27553d21423cSdrh   /*    $db transaction [-deferred|-immediate|-exclusive] SCRIPT
27563d21423cSdrh   **
27573d21423cSdrh   ** Start a new transaction (if we are not already in the midst of a
27583d21423cSdrh   ** transaction) and execute the TCL script SCRIPT.  After SCRIPT
27593d21423cSdrh   ** completes, either commit the transaction or roll it back if SCRIPT
27603d21423cSdrh   ** throws an exception.  Or if no new transation was started, do nothing.
27613d21423cSdrh   ** pass the exception on up the stack.
27623d21423cSdrh   **
27633d21423cSdrh   ** This command was inspired by Dave Thomas's talk on Ruby at the
27643d21423cSdrh   ** 2005 O'Reilly Open Source Convention (OSCON).
27653d21423cSdrh   */
27663d21423cSdrh   case DB_TRANSACTION: {
27673d21423cSdrh     Tcl_Obj *pScript;
2768cd38d520Sdanielk1977     const char *zBegin = "SAVEPOINT _tcl_transaction";
27693d21423cSdrh     if( objc!=3 && objc!=4 ){
27703d21423cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "[TYPE] SCRIPT");
27713d21423cSdrh       return TCL_ERROR;
27723d21423cSdrh     }
2773cd38d520Sdanielk1977 
27744a4c11aaSdan     if( pDb->nTransaction==0 && objc==4 ){
27753d21423cSdrh       static const char *TTYPE_strs[] = {
2776ce604012Sdrh         "deferred",   "exclusive",  "immediate", 0
27773d21423cSdrh       };
27783d21423cSdrh       enum TTYPE_enum {
27793d21423cSdrh         TTYPE_DEFERRED, TTYPE_EXCLUSIVE, TTYPE_IMMEDIATE
27803d21423cSdrh       };
27813d21423cSdrh       int ttype;
2782b5555e7eSdrh       if( Tcl_GetIndexFromObj(interp, objv[2], TTYPE_strs, "transaction type",
27833d21423cSdrh                               0, &ttype) ){
27843d21423cSdrh         return TCL_ERROR;
27853d21423cSdrh       }
27863d21423cSdrh       switch( (enum TTYPE_enum)ttype ){
27873d21423cSdrh         case TTYPE_DEFERRED:    /* no-op */;                 break;
27883d21423cSdrh         case TTYPE_EXCLUSIVE:   zBegin = "BEGIN EXCLUSIVE";  break;
27893d21423cSdrh         case TTYPE_IMMEDIATE:   zBegin = "BEGIN IMMEDIATE";  break;
27903d21423cSdrh       }
27913d21423cSdrh     }
2792cd38d520Sdanielk1977     pScript = objv[objc-1];
2793cd38d520Sdanielk1977 
27944a4c11aaSdan     /* Run the SQLite BEGIN command to open a transaction or savepoint. */
27951f1549f8Sdrh     pDb->disableAuth++;
2796cd38d520Sdanielk1977     rc = sqlite3_exec(pDb->db, zBegin, 0, 0, 0);
27971f1549f8Sdrh     pDb->disableAuth--;
2798cd38d520Sdanielk1977     if( rc!=SQLITE_OK ){
2799a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
2800cd38d520Sdanielk1977       return TCL_ERROR;
28013d21423cSdrh     }
2802cd38d520Sdanielk1977     pDb->nTransaction++;
2803cd38d520Sdanielk1977 
28044a4c11aaSdan     /* If using NRE, schedule a callback to invoke the script pScript, then
28054a4c11aaSdan     ** a second callback to commit (or rollback) the transaction or savepoint
28064a4c11aaSdan     ** opened above. If not using NRE, evaluate the script directly, then
28074a4c11aaSdan     ** call function DbTransPostCmd() to commit (or rollback) the transaction
28084a4c11aaSdan     ** or savepoint.  */
28094a4c11aaSdan     if( DbUseNre() ){
28104a4c11aaSdan       Tcl_NRAddCallback(interp, DbTransPostCmd, cd, 0, 0, 0);
2811a47941feSdrh       (void)Tcl_NREvalObj(interp, pScript, 0);
28123d21423cSdrh     }else{
28134a4c11aaSdan       rc = DbTransPostCmd(&cd, interp, Tcl_EvalObjEx(interp, pScript, 0));
28143d21423cSdrh     }
28153d21423cSdrh     break;
28163d21423cSdrh   }
28173d21423cSdrh 
281894eb6a14Sdanielk1977   /*
2819404ca075Sdanielk1977   **    $db unlock_notify ?script?
2820404ca075Sdanielk1977   */
2821404ca075Sdanielk1977   case DB_UNLOCK_NOTIFY: {
2822404ca075Sdanielk1977 #ifndef SQLITE_ENABLE_UNLOCK_NOTIFY
2823a198f2b5Sdrh     Tcl_AppendResult(interp, "unlock_notify not available in this build",
2824a198f2b5Sdrh                      (char*)0);
2825404ca075Sdanielk1977     rc = TCL_ERROR;
2826404ca075Sdanielk1977 #else
2827404ca075Sdanielk1977     if( objc!=2 && objc!=3 ){
2828404ca075Sdanielk1977       Tcl_WrongNumArgs(interp, 2, objv, "?SCRIPT?");
2829404ca075Sdanielk1977       rc = TCL_ERROR;
2830404ca075Sdanielk1977     }else{
2831404ca075Sdanielk1977       void (*xNotify)(void **, int) = 0;
2832404ca075Sdanielk1977       void *pNotifyArg = 0;
2833404ca075Sdanielk1977 
2834404ca075Sdanielk1977       if( pDb->pUnlockNotify ){
2835404ca075Sdanielk1977         Tcl_DecrRefCount(pDb->pUnlockNotify);
2836404ca075Sdanielk1977         pDb->pUnlockNotify = 0;
2837404ca075Sdanielk1977       }
2838404ca075Sdanielk1977 
2839404ca075Sdanielk1977       if( objc==3 ){
2840404ca075Sdanielk1977         xNotify = DbUnlockNotify;
2841404ca075Sdanielk1977         pNotifyArg = (void *)pDb;
2842404ca075Sdanielk1977         pDb->pUnlockNotify = objv[2];
2843404ca075Sdanielk1977         Tcl_IncrRefCount(pDb->pUnlockNotify);
2844404ca075Sdanielk1977       }
2845404ca075Sdanielk1977 
2846404ca075Sdanielk1977       if( sqlite3_unlock_notify(pDb->db, xNotify, pNotifyArg) ){
2847a198f2b5Sdrh         Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
2848404ca075Sdanielk1977         rc = TCL_ERROR;
2849404ca075Sdanielk1977       }
2850404ca075Sdanielk1977     }
2851404ca075Sdanielk1977 #endif
2852404ca075Sdanielk1977     break;
2853404ca075Sdanielk1977   }
2854404ca075Sdanielk1977 
2855404ca075Sdanielk1977   /*
2856833bf968Sdrh   **    $db wal_hook ?script?
285794eb6a14Sdanielk1977   **    $db update_hook ?script?
285871fd80bfSdanielk1977   **    $db rollback_hook ?script?
285994eb6a14Sdanielk1977   */
2860833bf968Sdrh   case DB_WAL_HOOK:
286171fd80bfSdanielk1977   case DB_UPDATE_HOOK:
286271fd80bfSdanielk1977   case DB_ROLLBACK_HOOK: {
286371fd80bfSdanielk1977 
286471fd80bfSdanielk1977     /* set ppHook to point at pUpdateHook or pRollbackHook, depending on
286571fd80bfSdanielk1977     ** whether [$db update_hook] or [$db rollback_hook] was invoked.
286671fd80bfSdanielk1977     */
286771fd80bfSdanielk1977     Tcl_Obj **ppHook;
286871fd80bfSdanielk1977     if( choice==DB_UPDATE_HOOK ){
286971fd80bfSdanielk1977       ppHook = &pDb->pUpdateHook;
2870833bf968Sdrh     }else if( choice==DB_WAL_HOOK ){
28715def0843Sdrh       ppHook = &pDb->pWalHook;
287271fd80bfSdanielk1977     }else{
287371fd80bfSdanielk1977       ppHook = &pDb->pRollbackHook;
287471fd80bfSdanielk1977     }
287571fd80bfSdanielk1977 
287694eb6a14Sdanielk1977     if( objc!=2 && objc!=3 ){
287794eb6a14Sdanielk1977        Tcl_WrongNumArgs(interp, 2, objv, "?SCRIPT?");
287894eb6a14Sdanielk1977        return TCL_ERROR;
287994eb6a14Sdanielk1977     }
288071fd80bfSdanielk1977     if( *ppHook ){
288171fd80bfSdanielk1977       Tcl_SetObjResult(interp, *ppHook);
288294eb6a14Sdanielk1977       if( objc==3 ){
288371fd80bfSdanielk1977         Tcl_DecrRefCount(*ppHook);
288471fd80bfSdanielk1977         *ppHook = 0;
288594eb6a14Sdanielk1977       }
288694eb6a14Sdanielk1977     }
288794eb6a14Sdanielk1977     if( objc==3 ){
288871fd80bfSdanielk1977       assert( !(*ppHook) );
288994eb6a14Sdanielk1977       if( Tcl_GetCharLength(objv[2])>0 ){
289071fd80bfSdanielk1977         *ppHook = objv[2];
289171fd80bfSdanielk1977         Tcl_IncrRefCount(*ppHook);
289294eb6a14Sdanielk1977       }
289394eb6a14Sdanielk1977     }
289471fd80bfSdanielk1977 
289571fd80bfSdanielk1977     sqlite3_update_hook(pDb->db, (pDb->pUpdateHook?DbUpdateHandler:0), pDb);
289671fd80bfSdanielk1977     sqlite3_rollback_hook(pDb->db,(pDb->pRollbackHook?DbRollbackHandler:0),pDb);
28975def0843Sdrh     sqlite3_wal_hook(pDb->db,(pDb->pWalHook?DbWalHandler:0),pDb);
289871fd80bfSdanielk1977 
289994eb6a14Sdanielk1977     break;
290094eb6a14Sdanielk1977   }
290194eb6a14Sdanielk1977 
29024397de57Sdanielk1977   /*    $db version
29034397de57Sdanielk1977   **
29044397de57Sdanielk1977   ** Return the version string for this database.
29054397de57Sdanielk1977   */
29064397de57Sdanielk1977   case DB_VERSION: {
29074397de57Sdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_libversion(), TCL_STATIC);
29084397de57Sdanielk1977     break;
29094397de57Sdanielk1977   }
29104397de57Sdanielk1977 
29111067fe11Stpoindex 
29126d31316cSdrh   } /* End of the SWITCH statement */
291322fbcb8dSdrh   return rc;
291475897234Sdrh }
291575897234Sdrh 
2916a2c8a95bSdrh #if SQLITE_TCL_NRE
2917a2c8a95bSdrh /*
2918a2c8a95bSdrh ** Adaptor that provides an objCmd interface to the NRE-enabled
2919a2c8a95bSdrh ** interface implementation.
2920a2c8a95bSdrh */
2921a2c8a95bSdrh static int DbObjCmdAdaptor(
2922a2c8a95bSdrh   void *cd,
2923a2c8a95bSdrh   Tcl_Interp *interp,
2924a2c8a95bSdrh   int objc,
2925a2c8a95bSdrh   Tcl_Obj *const*objv
2926a2c8a95bSdrh ){
2927a2c8a95bSdrh   return Tcl_NRCallObjProc(interp, DbObjCmd, cd, objc, objv);
2928a2c8a95bSdrh }
2929a2c8a95bSdrh #endif /* SQLITE_TCL_NRE */
2930a2c8a95bSdrh 
293175897234Sdrh /*
29323570ad93Sdrh **   sqlite3 DBNAME FILENAME ?-vfs VFSNAME? ?-key KEY? ?-readonly BOOLEAN?
29339a6284c1Sdanielk1977 **                           ?-create BOOLEAN? ?-nomutex BOOLEAN?
293475897234Sdrh **
293575897234Sdrh ** This is the main Tcl command.  When the "sqlite" Tcl command is
293675897234Sdrh ** invoked, this routine runs to process that command.
293775897234Sdrh **
293875897234Sdrh ** The first argument, DBNAME, is an arbitrary name for a new
293975897234Sdrh ** database connection.  This command creates a new command named
294075897234Sdrh ** DBNAME that is used to control that connection.  The database
294175897234Sdrh ** connection is deleted when the DBNAME command is deleted.
294275897234Sdrh **
29433570ad93Sdrh ** The second argument is the name of the database file.
2944fbc3eab8Sdrh **
294575897234Sdrh */
294622fbcb8dSdrh static int DbMain(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){
2947bec3f402Sdrh   SqliteDb *p;
294822fbcb8dSdrh   const char *zArg;
294975897234Sdrh   char *zErrMsg;
29503570ad93Sdrh   int i;
295122fbcb8dSdrh   const char *zFile;
29523570ad93Sdrh   const char *zVfs = 0;
2953d9da78a2Sdrh   int flags;
2954882e8e4dSdrh   Tcl_DString translatedFilename;
2955b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
2956b07028f7Sdrh   void *pKey = 0;
2957b07028f7Sdrh   int nKey = 0;
2958b07028f7Sdrh #endif
2959540ebf82Smistachkin   int rc;
2960d9da78a2Sdrh 
2961d9da78a2Sdrh   /* In normal use, each TCL interpreter runs in a single thread.  So
2962d9da78a2Sdrh   ** by default, we can turn of mutexing on SQLite database connections.
2963d9da78a2Sdrh   ** However, for testing purposes it is useful to have mutexes turned
2964d9da78a2Sdrh   ** on.  So, by default, mutexes default off.  But if compiled with
2965d9da78a2Sdrh   ** SQLITE_TCL_DEFAULT_FULLMUTEX then mutexes default on.
2966d9da78a2Sdrh   */
2967d9da78a2Sdrh #ifdef SQLITE_TCL_DEFAULT_FULLMUTEX
2968d9da78a2Sdrh   flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_FULLMUTEX;
2969d9da78a2Sdrh #else
2970d9da78a2Sdrh   flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_NOMUTEX;
2971d9da78a2Sdrh #endif
2972d9da78a2Sdrh 
297322fbcb8dSdrh   if( objc==2 ){
297422fbcb8dSdrh     zArg = Tcl_GetStringFromObj(objv[1], 0);
297522fbcb8dSdrh     if( strcmp(zArg,"-version")==0 ){
2976a198f2b5Sdrh       Tcl_AppendResult(interp,sqlite3_libversion(), (char*)0);
2977647cb0e1Sdrh       return TCL_OK;
2978647cb0e1Sdrh     }
29799eb9e26bSdrh     if( strcmp(zArg,"-has-codec")==0 ){
29809eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
2981a198f2b5Sdrh       Tcl_AppendResult(interp,"1",(char*)0);
298222fbcb8dSdrh #else
2983a198f2b5Sdrh       Tcl_AppendResult(interp,"0",(char*)0);
298422fbcb8dSdrh #endif
298522fbcb8dSdrh       return TCL_OK;
298622fbcb8dSdrh     }
2987fbc3eab8Sdrh   }
29883570ad93Sdrh   for(i=3; i+1<objc; i+=2){
29893570ad93Sdrh     zArg = Tcl_GetString(objv[i]);
299022fbcb8dSdrh     if( strcmp(zArg,"-key")==0 ){
2991b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
29923570ad93Sdrh       pKey = Tcl_GetByteArrayFromObj(objv[i+1], &nKey);
2993b07028f7Sdrh #endif
29943570ad93Sdrh     }else if( strcmp(zArg, "-vfs")==0 ){
29953c3dd7b9Sdan       zVfs = Tcl_GetString(objv[i+1]);
29963570ad93Sdrh     }else if( strcmp(zArg, "-readonly")==0 ){
29973570ad93Sdrh       int b;
29983570ad93Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
29993570ad93Sdrh       if( b ){
300033f4e02aSdrh         flags &= ~(SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE);
30013570ad93Sdrh         flags |= SQLITE_OPEN_READONLY;
30023570ad93Sdrh       }else{
30033570ad93Sdrh         flags &= ~SQLITE_OPEN_READONLY;
30043570ad93Sdrh         flags |= SQLITE_OPEN_READWRITE;
30053570ad93Sdrh       }
30063570ad93Sdrh     }else if( strcmp(zArg, "-create")==0 ){
30073570ad93Sdrh       int b;
30083570ad93Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
300933f4e02aSdrh       if( b && (flags & SQLITE_OPEN_READONLY)==0 ){
30103570ad93Sdrh         flags |= SQLITE_OPEN_CREATE;
30113570ad93Sdrh       }else{
30123570ad93Sdrh         flags &= ~SQLITE_OPEN_CREATE;
30133570ad93Sdrh       }
30149a6284c1Sdanielk1977     }else if( strcmp(zArg, "-nomutex")==0 ){
30159a6284c1Sdanielk1977       int b;
30169a6284c1Sdanielk1977       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
30179a6284c1Sdanielk1977       if( b ){
30189a6284c1Sdanielk1977         flags |= SQLITE_OPEN_NOMUTEX;
3019039963adSdrh         flags &= ~SQLITE_OPEN_FULLMUTEX;
30209a6284c1Sdanielk1977       }else{
30219a6284c1Sdanielk1977         flags &= ~SQLITE_OPEN_NOMUTEX;
30229a6284c1Sdanielk1977       }
3023039963adSdrh     }else if( strcmp(zArg, "-fullmutex")==0 ){
3024039963adSdrh       int b;
3025039963adSdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
3026039963adSdrh       if( b ){
3027039963adSdrh         flags |= SQLITE_OPEN_FULLMUTEX;
3028039963adSdrh         flags &= ~SQLITE_OPEN_NOMUTEX;
3029039963adSdrh       }else{
3030039963adSdrh         flags &= ~SQLITE_OPEN_FULLMUTEX;
3031039963adSdrh       }
3032f12b3f60Sdrh     }else if( strcmp(zArg, "-uri")==0 ){
3033f12b3f60Sdrh       int b;
3034f12b3f60Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
3035f12b3f60Sdrh       if( b ){
3036f12b3f60Sdrh         flags |= SQLITE_OPEN_URI;
3037f12b3f60Sdrh       }else{
3038f12b3f60Sdrh         flags &= ~SQLITE_OPEN_URI;
3039f12b3f60Sdrh       }
30403570ad93Sdrh     }else{
30413570ad93Sdrh       Tcl_AppendResult(interp, "unknown option: ", zArg, (char*)0);
30423570ad93Sdrh       return TCL_ERROR;
304322fbcb8dSdrh     }
304422fbcb8dSdrh   }
30453570ad93Sdrh   if( objc<3 || (objc&1)!=1 ){
304622fbcb8dSdrh     Tcl_WrongNumArgs(interp, 1, objv,
30473570ad93Sdrh       "HANDLE FILENAME ?-vfs VFSNAME? ?-readonly BOOLEAN? ?-create BOOLEAN?"
304868bd4aa2Sdrh       " ?-nomutex BOOLEAN? ?-fullmutex BOOLEAN? ?-uri BOOLEAN?"
30499eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
30503570ad93Sdrh       " ?-key CODECKEY?"
305122fbcb8dSdrh #endif
305222fbcb8dSdrh     );
305375897234Sdrh     return TCL_ERROR;
305475897234Sdrh   }
305575897234Sdrh   zErrMsg = 0;
30564cdc9e84Sdrh   p = (SqliteDb*)Tcl_Alloc( sizeof(*p) );
305775897234Sdrh   if( p==0 ){
30586ef5e12eSmistachkin     Tcl_SetResult(interp, (char *)"malloc failed", TCL_STATIC);
3059bec3f402Sdrh     return TCL_ERROR;
3060bec3f402Sdrh   }
3061bec3f402Sdrh   memset(p, 0, sizeof(*p));
306222fbcb8dSdrh   zFile = Tcl_GetStringFromObj(objv[2], 0);
3063882e8e4dSdrh   zFile = Tcl_TranslateFileName(interp, zFile, &translatedFilename);
3064540ebf82Smistachkin   rc = sqlite3_open_v2(zFile, &p->db, flags, zVfs);
3065882e8e4dSdrh   Tcl_DStringFree(&translatedFilename);
3066540ebf82Smistachkin   if( p->db ){
306780290863Sdanielk1977     if( SQLITE_OK!=sqlite3_errcode(p->db) ){
30689404d50eSdrh       zErrMsg = sqlite3_mprintf("%s", sqlite3_errmsg(p->db));
306980290863Sdanielk1977       sqlite3_close(p->db);
307080290863Sdanielk1977       p->db = 0;
307180290863Sdanielk1977     }
3072540ebf82Smistachkin   }else{
30735dac8432Smistachkin     zErrMsg = sqlite3_mprintf("%s", sqlite3_errstr(rc));
3074540ebf82Smistachkin   }
30752011d5f5Sdrh #ifdef SQLITE_HAS_CODEC
3076f3a65f7eSdrh   if( p->db ){
30772011d5f5Sdrh     sqlite3_key(p->db, pKey, nKey);
3078f3a65f7eSdrh   }
3079eb8ed70dSdrh #endif
3080bec3f402Sdrh   if( p->db==0 ){
308175897234Sdrh     Tcl_SetResult(interp, zErrMsg, TCL_VOLATILE);
3082bec3f402Sdrh     Tcl_Free((char*)p);
30839404d50eSdrh     sqlite3_free(zErrMsg);
308475897234Sdrh     return TCL_ERROR;
308575897234Sdrh   }
3086fb7e7651Sdrh   p->maxStmt = NUM_PREPARED_STMTS;
30875169bbc6Sdrh   p->interp = interp;
308822fbcb8dSdrh   zArg = Tcl_GetStringFromObj(objv[1], 0);
30894a4c11aaSdan   if( DbUseNre() ){
3090a2c8a95bSdrh     Tcl_NRCreateCommand(interp, zArg, DbObjCmdAdaptor, DbObjCmd,
3091a2c8a95bSdrh                         (char*)p, DbDeleteCmd);
30924a4c11aaSdan   }else{
309322fbcb8dSdrh     Tcl_CreateObjCommand(interp, zArg, DbObjCmd, (char*)p, DbDeleteCmd);
30944a4c11aaSdan   }
309575897234Sdrh   return TCL_OK;
309675897234Sdrh }
309775897234Sdrh 
309875897234Sdrh /*
309990ca9753Sdrh ** Provide a dummy Tcl_InitStubs if we are using this as a static
310090ca9753Sdrh ** library.
310190ca9753Sdrh */
310290ca9753Sdrh #ifndef USE_TCL_STUBS
310390ca9753Sdrh # undef  Tcl_InitStubs
31040e85ccfcSdrh # define Tcl_InitStubs(a,b,c) TCL_VERSION
310590ca9753Sdrh #endif
310690ca9753Sdrh 
310790ca9753Sdrh /*
310829bc4615Sdrh ** Make sure we have a PACKAGE_VERSION macro defined.  This will be
310929bc4615Sdrh ** defined automatically by the TEA makefile.  But other makefiles
311029bc4615Sdrh ** do not define it.
311129bc4615Sdrh */
311229bc4615Sdrh #ifndef PACKAGE_VERSION
311329bc4615Sdrh # define PACKAGE_VERSION SQLITE_VERSION
311429bc4615Sdrh #endif
311529bc4615Sdrh 
311629bc4615Sdrh /*
311775897234Sdrh ** Initialize this module.
311875897234Sdrh **
311975897234Sdrh ** This Tcl module contains only a single new Tcl command named "sqlite".
312075897234Sdrh ** (Hence there is no namespace.  There is no point in using a namespace
312175897234Sdrh ** if the extension only supplies one new name!)  The "sqlite" command is
312275897234Sdrh ** used to open a new SQLite database.  See the DbMain() routine above
312375897234Sdrh ** for additional information.
3124b652f432Sdrh **
3125b652f432Sdrh ** The EXTERN macros are required by TCL in order to work on windows.
312675897234Sdrh */
3127b652f432Sdrh EXTERN int Sqlite3_Init(Tcl_Interp *interp){
312827b2f053Smistachkin   int rc = Tcl_InitStubs(interp, "8.4", 0) ? TCL_OK : TCL_ERROR;
31296dc8cbe0Sdrh   if( rc==TCL_OK ){
3130ef4ac8f9Sdrh     Tcl_CreateObjCommand(interp, "sqlite3", (Tcl_ObjCmdProc*)DbMain, 0, 0);
31311cca0d22Sdrh #ifndef SQLITE_3_SUFFIX_ONLY
31321cca0d22Sdrh     /* The "sqlite" alias is undocumented.  It is here only to support
31331cca0d22Sdrh     ** legacy scripts.  All new scripts should use only the "sqlite3"
31346dc8cbe0Sdrh     ** command. */
313549766d6cSdrh     Tcl_CreateObjCommand(interp, "sqlite", (Tcl_ObjCmdProc*)DbMain, 0, 0);
31364c0f1649Sdrh #endif
31376dc8cbe0Sdrh     rc = Tcl_PkgProvide(interp, "sqlite3", PACKAGE_VERSION);
31386dc8cbe0Sdrh   }
31396dc8cbe0Sdrh   return rc;
314090ca9753Sdrh }
3141b652f432Sdrh EXTERN int Tclsqlite3_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3142b652f432Sdrh EXTERN int Sqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3143b652f432Sdrh EXTERN int Tclsqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3144e2c3a659Sdrh 
3145d878cab5Sdrh /* Because it accesses the file-system and uses persistent state, SQLite
3146d878cab5Sdrh ** is not considered appropriate for safe interpreters.  Hence, we deliberately
3147d878cab5Sdrh ** omit the _SafeInit() interfaces.
3148d878cab5Sdrh */
314949766d6cSdrh 
315049766d6cSdrh #ifndef SQLITE_3_SUFFIX_ONLY
3151a3e63c4aSdan int Sqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3152a3e63c4aSdan int Tclsqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3153a3e63c4aSdan int Sqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3154a3e63c4aSdan int Tclsqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
315549766d6cSdrh #endif
315675897234Sdrh 
31573e27c026Sdrh #ifdef TCLSH
31583e27c026Sdrh /*****************************************************************************
315957a0227fSdrh ** All of the code that follows is used to build standalone TCL interpreters
316057a0227fSdrh ** that are statically linked with SQLite.  Enable these by compiling
316157a0227fSdrh ** with -DTCLSH=n where n can be 1 or 2.  An n of 1 generates a standard
316257a0227fSdrh ** tclsh but with SQLite built in.  An n of 2 generates the SQLite space
316357a0227fSdrh ** analysis program.
316475897234Sdrh */
3165348784efSdrh 
316657a0227fSdrh #if defined(SQLITE_TEST) || defined(SQLITE_TCLMD5)
316757a0227fSdrh /*
316857a0227fSdrh  * This code implements the MD5 message-digest algorithm.
316957a0227fSdrh  * The algorithm is due to Ron Rivest.  This code was
317057a0227fSdrh  * written by Colin Plumb in 1993, no copyright is claimed.
317157a0227fSdrh  * This code is in the public domain; do with it what you wish.
317257a0227fSdrh  *
317357a0227fSdrh  * Equivalent code is available from RSA Data Security, Inc.
317457a0227fSdrh  * This code has been tested against that, and is equivalent,
317557a0227fSdrh  * except that you don't need to include two pages of legalese
317657a0227fSdrh  * with every copy.
317757a0227fSdrh  *
317857a0227fSdrh  * To compute the message digest of a chunk of bytes, declare an
317957a0227fSdrh  * MD5Context structure, pass it to MD5Init, call MD5Update as
318057a0227fSdrh  * needed on buffers full of bytes, and then call MD5Final, which
318157a0227fSdrh  * will fill a supplied 16-byte array with the digest.
318257a0227fSdrh  */
318357a0227fSdrh 
318457a0227fSdrh /*
318557a0227fSdrh  * If compiled on a machine that doesn't have a 32-bit integer,
318657a0227fSdrh  * you just set "uint32" to the appropriate datatype for an
318757a0227fSdrh  * unsigned 32-bit integer.  For example:
318857a0227fSdrh  *
318957a0227fSdrh  *       cc -Duint32='unsigned long' md5.c
319057a0227fSdrh  *
319157a0227fSdrh  */
319257a0227fSdrh #ifndef uint32
319357a0227fSdrh #  define uint32 unsigned int
319457a0227fSdrh #endif
319557a0227fSdrh 
319657a0227fSdrh struct MD5Context {
319757a0227fSdrh   int isInit;
319857a0227fSdrh   uint32 buf[4];
319957a0227fSdrh   uint32 bits[2];
320057a0227fSdrh   unsigned char in[64];
320157a0227fSdrh };
320257a0227fSdrh typedef struct MD5Context MD5Context;
320357a0227fSdrh 
320457a0227fSdrh /*
320557a0227fSdrh  * Note: this code is harmless on little-endian machines.
320657a0227fSdrh  */
320757a0227fSdrh static void byteReverse (unsigned char *buf, unsigned longs){
320857a0227fSdrh         uint32 t;
320957a0227fSdrh         do {
321057a0227fSdrh                 t = (uint32)((unsigned)buf[3]<<8 | buf[2]) << 16 |
321157a0227fSdrh                             ((unsigned)buf[1]<<8 | buf[0]);
321257a0227fSdrh                 *(uint32 *)buf = t;
321357a0227fSdrh                 buf += 4;
321457a0227fSdrh         } while (--longs);
321557a0227fSdrh }
321657a0227fSdrh /* The four core functions - F1 is optimized somewhat */
321757a0227fSdrh 
321857a0227fSdrh /* #define F1(x, y, z) (x & y | ~x & z) */
321957a0227fSdrh #define F1(x, y, z) (z ^ (x & (y ^ z)))
322057a0227fSdrh #define F2(x, y, z) F1(z, x, y)
322157a0227fSdrh #define F3(x, y, z) (x ^ y ^ z)
322257a0227fSdrh #define F4(x, y, z) (y ^ (x | ~z))
322357a0227fSdrh 
322457a0227fSdrh /* This is the central step in the MD5 algorithm. */
322557a0227fSdrh #define MD5STEP(f, w, x, y, z, data, s) \
322657a0227fSdrh         ( w += f(x, y, z) + data,  w = w<<s | w>>(32-s),  w += x )
322757a0227fSdrh 
322857a0227fSdrh /*
322957a0227fSdrh  * The core of the MD5 algorithm, this alters an existing MD5 hash to
323057a0227fSdrh  * reflect the addition of 16 longwords of new data.  MD5Update blocks
323157a0227fSdrh  * the data and converts bytes into longwords for this routine.
323257a0227fSdrh  */
323357a0227fSdrh static void MD5Transform(uint32 buf[4], const uint32 in[16]){
323457a0227fSdrh         register uint32 a, b, c, d;
323557a0227fSdrh 
323657a0227fSdrh         a = buf[0];
323757a0227fSdrh         b = buf[1];
323857a0227fSdrh         c = buf[2];
323957a0227fSdrh         d = buf[3];
324057a0227fSdrh 
324157a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 0]+0xd76aa478,  7);
324257a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 1]+0xe8c7b756, 12);
324357a0227fSdrh         MD5STEP(F1, c, d, a, b, in[ 2]+0x242070db, 17);
324457a0227fSdrh         MD5STEP(F1, b, c, d, a, in[ 3]+0xc1bdceee, 22);
324557a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 4]+0xf57c0faf,  7);
324657a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 5]+0x4787c62a, 12);
324757a0227fSdrh         MD5STEP(F1, c, d, a, b, in[ 6]+0xa8304613, 17);
324857a0227fSdrh         MD5STEP(F1, b, c, d, a, in[ 7]+0xfd469501, 22);
324957a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 8]+0x698098d8,  7);
325057a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 9]+0x8b44f7af, 12);
325157a0227fSdrh         MD5STEP(F1, c, d, a, b, in[10]+0xffff5bb1, 17);
325257a0227fSdrh         MD5STEP(F1, b, c, d, a, in[11]+0x895cd7be, 22);
325357a0227fSdrh         MD5STEP(F1, a, b, c, d, in[12]+0x6b901122,  7);
325457a0227fSdrh         MD5STEP(F1, d, a, b, c, in[13]+0xfd987193, 12);
325557a0227fSdrh         MD5STEP(F1, c, d, a, b, in[14]+0xa679438e, 17);
325657a0227fSdrh         MD5STEP(F1, b, c, d, a, in[15]+0x49b40821, 22);
325757a0227fSdrh 
325857a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 1]+0xf61e2562,  5);
325957a0227fSdrh         MD5STEP(F2, d, a, b, c, in[ 6]+0xc040b340,  9);
326057a0227fSdrh         MD5STEP(F2, c, d, a, b, in[11]+0x265e5a51, 14);
326157a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 0]+0xe9b6c7aa, 20);
326257a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 5]+0xd62f105d,  5);
326357a0227fSdrh         MD5STEP(F2, d, a, b, c, in[10]+0x02441453,  9);
326457a0227fSdrh         MD5STEP(F2, c, d, a, b, in[15]+0xd8a1e681, 14);
326557a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 4]+0xe7d3fbc8, 20);
326657a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 9]+0x21e1cde6,  5);
326757a0227fSdrh         MD5STEP(F2, d, a, b, c, in[14]+0xc33707d6,  9);
326857a0227fSdrh         MD5STEP(F2, c, d, a, b, in[ 3]+0xf4d50d87, 14);
326957a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 8]+0x455a14ed, 20);
327057a0227fSdrh         MD5STEP(F2, a, b, c, d, in[13]+0xa9e3e905,  5);
327157a0227fSdrh         MD5STEP(F2, d, a, b, c, in[ 2]+0xfcefa3f8,  9);
327257a0227fSdrh         MD5STEP(F2, c, d, a, b, in[ 7]+0x676f02d9, 14);
327357a0227fSdrh         MD5STEP(F2, b, c, d, a, in[12]+0x8d2a4c8a, 20);
327457a0227fSdrh 
327557a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 5]+0xfffa3942,  4);
327657a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 8]+0x8771f681, 11);
327757a0227fSdrh         MD5STEP(F3, c, d, a, b, in[11]+0x6d9d6122, 16);
327857a0227fSdrh         MD5STEP(F3, b, c, d, a, in[14]+0xfde5380c, 23);
327957a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 1]+0xa4beea44,  4);
328057a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 4]+0x4bdecfa9, 11);
328157a0227fSdrh         MD5STEP(F3, c, d, a, b, in[ 7]+0xf6bb4b60, 16);
328257a0227fSdrh         MD5STEP(F3, b, c, d, a, in[10]+0xbebfbc70, 23);
328357a0227fSdrh         MD5STEP(F3, a, b, c, d, in[13]+0x289b7ec6,  4);
328457a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 0]+0xeaa127fa, 11);
328557a0227fSdrh         MD5STEP(F3, c, d, a, b, in[ 3]+0xd4ef3085, 16);
328657a0227fSdrh         MD5STEP(F3, b, c, d, a, in[ 6]+0x04881d05, 23);
328757a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 9]+0xd9d4d039,  4);
328857a0227fSdrh         MD5STEP(F3, d, a, b, c, in[12]+0xe6db99e5, 11);
328957a0227fSdrh         MD5STEP(F3, c, d, a, b, in[15]+0x1fa27cf8, 16);
329057a0227fSdrh         MD5STEP(F3, b, c, d, a, in[ 2]+0xc4ac5665, 23);
329157a0227fSdrh 
329257a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 0]+0xf4292244,  6);
329357a0227fSdrh         MD5STEP(F4, d, a, b, c, in[ 7]+0x432aff97, 10);
329457a0227fSdrh         MD5STEP(F4, c, d, a, b, in[14]+0xab9423a7, 15);
329557a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 5]+0xfc93a039, 21);
329657a0227fSdrh         MD5STEP(F4, a, b, c, d, in[12]+0x655b59c3,  6);
329757a0227fSdrh         MD5STEP(F4, d, a, b, c, in[ 3]+0x8f0ccc92, 10);
329857a0227fSdrh         MD5STEP(F4, c, d, a, b, in[10]+0xffeff47d, 15);
329957a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 1]+0x85845dd1, 21);
330057a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 8]+0x6fa87e4f,  6);
330157a0227fSdrh         MD5STEP(F4, d, a, b, c, in[15]+0xfe2ce6e0, 10);
330257a0227fSdrh         MD5STEP(F4, c, d, a, b, in[ 6]+0xa3014314, 15);
330357a0227fSdrh         MD5STEP(F4, b, c, d, a, in[13]+0x4e0811a1, 21);
330457a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 4]+0xf7537e82,  6);
330557a0227fSdrh         MD5STEP(F4, d, a, b, c, in[11]+0xbd3af235, 10);
330657a0227fSdrh         MD5STEP(F4, c, d, a, b, in[ 2]+0x2ad7d2bb, 15);
330757a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 9]+0xeb86d391, 21);
330857a0227fSdrh 
330957a0227fSdrh         buf[0] += a;
331057a0227fSdrh         buf[1] += b;
331157a0227fSdrh         buf[2] += c;
331257a0227fSdrh         buf[3] += d;
331357a0227fSdrh }
331457a0227fSdrh 
331557a0227fSdrh /*
331657a0227fSdrh  * Start MD5 accumulation.  Set bit count to 0 and buffer to mysterious
331757a0227fSdrh  * initialization constants.
331857a0227fSdrh  */
331957a0227fSdrh static void MD5Init(MD5Context *ctx){
332057a0227fSdrh         ctx->isInit = 1;
332157a0227fSdrh         ctx->buf[0] = 0x67452301;
332257a0227fSdrh         ctx->buf[1] = 0xefcdab89;
332357a0227fSdrh         ctx->buf[2] = 0x98badcfe;
332457a0227fSdrh         ctx->buf[3] = 0x10325476;
332557a0227fSdrh         ctx->bits[0] = 0;
332657a0227fSdrh         ctx->bits[1] = 0;
332757a0227fSdrh }
332857a0227fSdrh 
332957a0227fSdrh /*
333057a0227fSdrh  * Update context to reflect the concatenation of another buffer full
333157a0227fSdrh  * of bytes.
333257a0227fSdrh  */
333357a0227fSdrh static
333457a0227fSdrh void MD5Update(MD5Context *ctx, const unsigned char *buf, unsigned int len){
333557a0227fSdrh         uint32 t;
333657a0227fSdrh 
333757a0227fSdrh         /* Update bitcount */
333857a0227fSdrh 
333957a0227fSdrh         t = ctx->bits[0];
334057a0227fSdrh         if ((ctx->bits[0] = t + ((uint32)len << 3)) < t)
334157a0227fSdrh                 ctx->bits[1]++; /* Carry from low to high */
334257a0227fSdrh         ctx->bits[1] += len >> 29;
334357a0227fSdrh 
334457a0227fSdrh         t = (t >> 3) & 0x3f;    /* Bytes already in shsInfo->data */
334557a0227fSdrh 
334657a0227fSdrh         /* Handle any leading odd-sized chunks */
334757a0227fSdrh 
334857a0227fSdrh         if ( t ) {
334957a0227fSdrh                 unsigned char *p = (unsigned char *)ctx->in + t;
335057a0227fSdrh 
335157a0227fSdrh                 t = 64-t;
335257a0227fSdrh                 if (len < t) {
335357a0227fSdrh                         memcpy(p, buf, len);
335457a0227fSdrh                         return;
335557a0227fSdrh                 }
335657a0227fSdrh                 memcpy(p, buf, t);
335757a0227fSdrh                 byteReverse(ctx->in, 16);
335857a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
335957a0227fSdrh                 buf += t;
336057a0227fSdrh                 len -= t;
336157a0227fSdrh         }
336257a0227fSdrh 
336357a0227fSdrh         /* Process data in 64-byte chunks */
336457a0227fSdrh 
336557a0227fSdrh         while (len >= 64) {
336657a0227fSdrh                 memcpy(ctx->in, buf, 64);
336757a0227fSdrh                 byteReverse(ctx->in, 16);
336857a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
336957a0227fSdrh                 buf += 64;
337057a0227fSdrh                 len -= 64;
337157a0227fSdrh         }
337257a0227fSdrh 
337357a0227fSdrh         /* Handle any remaining bytes of data. */
337457a0227fSdrh 
337557a0227fSdrh         memcpy(ctx->in, buf, len);
337657a0227fSdrh }
337757a0227fSdrh 
337857a0227fSdrh /*
337957a0227fSdrh  * Final wrapup - pad to 64-byte boundary with the bit pattern
338057a0227fSdrh  * 1 0* (64-bit count of bits processed, MSB-first)
338157a0227fSdrh  */
338257a0227fSdrh static void MD5Final(unsigned char digest[16], MD5Context *ctx){
338357a0227fSdrh         unsigned count;
338457a0227fSdrh         unsigned char *p;
338557a0227fSdrh 
338657a0227fSdrh         /* Compute number of bytes mod 64 */
338757a0227fSdrh         count = (ctx->bits[0] >> 3) & 0x3F;
338857a0227fSdrh 
338957a0227fSdrh         /* Set the first char of padding to 0x80.  This is safe since there is
339057a0227fSdrh            always at least one byte free */
339157a0227fSdrh         p = ctx->in + count;
339257a0227fSdrh         *p++ = 0x80;
339357a0227fSdrh 
339457a0227fSdrh         /* Bytes of padding needed to make 64 bytes */
339557a0227fSdrh         count = 64 - 1 - count;
339657a0227fSdrh 
339757a0227fSdrh         /* Pad out to 56 mod 64 */
339857a0227fSdrh         if (count < 8) {
339957a0227fSdrh                 /* Two lots of padding:  Pad the first block to 64 bytes */
340057a0227fSdrh                 memset(p, 0, count);
340157a0227fSdrh                 byteReverse(ctx->in, 16);
340257a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
340357a0227fSdrh 
340457a0227fSdrh                 /* Now fill the next block with 56 bytes */
340557a0227fSdrh                 memset(ctx->in, 0, 56);
340657a0227fSdrh         } else {
340757a0227fSdrh                 /* Pad block to 56 bytes */
340857a0227fSdrh                 memset(p, 0, count-8);
340957a0227fSdrh         }
341057a0227fSdrh         byteReverse(ctx->in, 14);
341157a0227fSdrh 
341257a0227fSdrh         /* Append length in bits and transform */
3413a47941feSdrh         memcpy(ctx->in + 14*4, ctx->bits, 8);
341457a0227fSdrh 
341557a0227fSdrh         MD5Transform(ctx->buf, (uint32 *)ctx->in);
341657a0227fSdrh         byteReverse((unsigned char *)ctx->buf, 4);
341757a0227fSdrh         memcpy(digest, ctx->buf, 16);
341857a0227fSdrh }
341957a0227fSdrh 
342057a0227fSdrh /*
342157a0227fSdrh ** Convert a 128-bit MD5 digest into a 32-digit base-16 number.
342257a0227fSdrh */
342357a0227fSdrh static void MD5DigestToBase16(unsigned char *digest, char *zBuf){
342457a0227fSdrh   static char const zEncode[] = "0123456789abcdef";
342557a0227fSdrh   int i, j;
342657a0227fSdrh 
342757a0227fSdrh   for(j=i=0; i<16; i++){
342857a0227fSdrh     int a = digest[i];
342957a0227fSdrh     zBuf[j++] = zEncode[(a>>4)&0xf];
343057a0227fSdrh     zBuf[j++] = zEncode[a & 0xf];
343157a0227fSdrh   }
343257a0227fSdrh   zBuf[j] = 0;
343357a0227fSdrh }
343457a0227fSdrh 
343557a0227fSdrh 
343657a0227fSdrh /*
343757a0227fSdrh ** Convert a 128-bit MD5 digest into sequency of eight 5-digit integers
343857a0227fSdrh ** each representing 16 bits of the digest and separated from each
343957a0227fSdrh ** other by a "-" character.
344057a0227fSdrh */
344157a0227fSdrh static void MD5DigestToBase10x8(unsigned char digest[16], char zDigest[50]){
344257a0227fSdrh   int i, j;
344357a0227fSdrh   unsigned int x;
344457a0227fSdrh   for(i=j=0; i<16; i+=2){
344557a0227fSdrh     x = digest[i]*256 + digest[i+1];
344657a0227fSdrh     if( i>0 ) zDigest[j++] = '-';
344705f6c67cSdrh     sqlite3_snprintf(50-j, &zDigest[j], "%05u", x);
344857a0227fSdrh     j += 5;
344957a0227fSdrh   }
345057a0227fSdrh   zDigest[j] = 0;
345157a0227fSdrh }
345257a0227fSdrh 
345357a0227fSdrh /*
345457a0227fSdrh ** A TCL command for md5.  The argument is the text to be hashed.  The
345557a0227fSdrh ** Result is the hash in base64.
345657a0227fSdrh */
345757a0227fSdrh static int md5_cmd(void*cd, Tcl_Interp *interp, int argc, const char **argv){
345857a0227fSdrh   MD5Context ctx;
345957a0227fSdrh   unsigned char digest[16];
346057a0227fSdrh   char zBuf[50];
346157a0227fSdrh   void (*converter)(unsigned char*, char*);
346257a0227fSdrh 
346357a0227fSdrh   if( argc!=2 ){
346457a0227fSdrh     Tcl_AppendResult(interp,"wrong # args: should be \"", argv[0],
3465a198f2b5Sdrh         " TEXT\"", (char*)0);
346657a0227fSdrh     return TCL_ERROR;
346757a0227fSdrh   }
346857a0227fSdrh   MD5Init(&ctx);
346957a0227fSdrh   MD5Update(&ctx, (unsigned char*)argv[1], (unsigned)strlen(argv[1]));
347057a0227fSdrh   MD5Final(digest, &ctx);
347157a0227fSdrh   converter = (void(*)(unsigned char*,char*))cd;
347257a0227fSdrh   converter(digest, zBuf);
347357a0227fSdrh   Tcl_AppendResult(interp, zBuf, (char*)0);
347457a0227fSdrh   return TCL_OK;
347557a0227fSdrh }
347657a0227fSdrh 
347757a0227fSdrh /*
347857a0227fSdrh ** A TCL command to take the md5 hash of a file.  The argument is the
347957a0227fSdrh ** name of the file.
348057a0227fSdrh */
348157a0227fSdrh static int md5file_cmd(void*cd, Tcl_Interp*interp, int argc, const char **argv){
348257a0227fSdrh   FILE *in;
348357a0227fSdrh   MD5Context ctx;
348457a0227fSdrh   void (*converter)(unsigned char*, char*);
348557a0227fSdrh   unsigned char digest[16];
348657a0227fSdrh   char zBuf[10240];
348757a0227fSdrh 
348857a0227fSdrh   if( argc!=2 ){
348957a0227fSdrh     Tcl_AppendResult(interp,"wrong # args: should be \"", argv[0],
3490a198f2b5Sdrh         " FILENAME\"", (char*)0);
349157a0227fSdrh     return TCL_ERROR;
349257a0227fSdrh   }
349357a0227fSdrh   in = fopen(argv[1],"rb");
349457a0227fSdrh   if( in==0 ){
349557a0227fSdrh     Tcl_AppendResult(interp,"unable to open file \"", argv[1],
3496a198f2b5Sdrh          "\" for reading", (char*)0);
349757a0227fSdrh     return TCL_ERROR;
349857a0227fSdrh   }
349957a0227fSdrh   MD5Init(&ctx);
350057a0227fSdrh   for(;;){
350157a0227fSdrh     int n;
350283cc1392Sdrh     n = (int)fread(zBuf, 1, sizeof(zBuf), in);
350357a0227fSdrh     if( n<=0 ) break;
350457a0227fSdrh     MD5Update(&ctx, (unsigned char*)zBuf, (unsigned)n);
350557a0227fSdrh   }
350657a0227fSdrh   fclose(in);
350757a0227fSdrh   MD5Final(digest, &ctx);
350857a0227fSdrh   converter = (void(*)(unsigned char*,char*))cd;
350957a0227fSdrh   converter(digest, zBuf);
351057a0227fSdrh   Tcl_AppendResult(interp, zBuf, (char*)0);
351157a0227fSdrh   return TCL_OK;
351257a0227fSdrh }
351357a0227fSdrh 
351457a0227fSdrh /*
351557a0227fSdrh ** Register the four new TCL commands for generating MD5 checksums
351657a0227fSdrh ** with the TCL interpreter.
351757a0227fSdrh */
351857a0227fSdrh int Md5_Init(Tcl_Interp *interp){
351957a0227fSdrh   Tcl_CreateCommand(interp, "md5", (Tcl_CmdProc*)md5_cmd,
352057a0227fSdrh                     MD5DigestToBase16, 0);
352157a0227fSdrh   Tcl_CreateCommand(interp, "md5-10x8", (Tcl_CmdProc*)md5_cmd,
352257a0227fSdrh                     MD5DigestToBase10x8, 0);
352357a0227fSdrh   Tcl_CreateCommand(interp, "md5file", (Tcl_CmdProc*)md5file_cmd,
352457a0227fSdrh                     MD5DigestToBase16, 0);
352557a0227fSdrh   Tcl_CreateCommand(interp, "md5file-10x8", (Tcl_CmdProc*)md5file_cmd,
352657a0227fSdrh                     MD5DigestToBase10x8, 0);
352757a0227fSdrh   return TCL_OK;
352857a0227fSdrh }
352957a0227fSdrh #endif /* defined(SQLITE_TEST) || defined(SQLITE_TCLMD5) */
353057a0227fSdrh 
353157a0227fSdrh #if defined(SQLITE_TEST)
353257a0227fSdrh /*
353357a0227fSdrh ** During testing, the special md5sum() aggregate function is available.
353457a0227fSdrh ** inside SQLite.  The following routines implement that function.
353557a0227fSdrh */
353657a0227fSdrh static void md5step(sqlite3_context *context, int argc, sqlite3_value **argv){
353757a0227fSdrh   MD5Context *p;
353857a0227fSdrh   int i;
353957a0227fSdrh   if( argc<1 ) return;
354057a0227fSdrh   p = sqlite3_aggregate_context(context, sizeof(*p));
354157a0227fSdrh   if( p==0 ) return;
354257a0227fSdrh   if( !p->isInit ){
354357a0227fSdrh     MD5Init(p);
354457a0227fSdrh   }
354557a0227fSdrh   for(i=0; i<argc; i++){
354657a0227fSdrh     const char *zData = (char*)sqlite3_value_text(argv[i]);
354757a0227fSdrh     if( zData ){
354883cc1392Sdrh       MD5Update(p, (unsigned char*)zData, (int)strlen(zData));
354957a0227fSdrh     }
355057a0227fSdrh   }
355157a0227fSdrh }
355257a0227fSdrh static void md5finalize(sqlite3_context *context){
355357a0227fSdrh   MD5Context *p;
355457a0227fSdrh   unsigned char digest[16];
355557a0227fSdrh   char zBuf[33];
355657a0227fSdrh   p = sqlite3_aggregate_context(context, sizeof(*p));
355757a0227fSdrh   MD5Final(digest,p);
355857a0227fSdrh   MD5DigestToBase16(digest, zBuf);
355957a0227fSdrh   sqlite3_result_text(context, zBuf, -1, SQLITE_TRANSIENT);
356057a0227fSdrh }
356157a0227fSdrh int Md5_Register(sqlite3 *db){
356257a0227fSdrh   int rc = sqlite3_create_function(db, "md5sum", -1, SQLITE_UTF8, 0, 0,
356357a0227fSdrh                                  md5step, md5finalize);
356457a0227fSdrh   sqlite3_overload_function(db, "md5sum", -1);  /* To exercise this API */
356557a0227fSdrh   return rc;
356657a0227fSdrh }
356757a0227fSdrh #endif /* defined(SQLITE_TEST) */
356857a0227fSdrh 
356957a0227fSdrh 
3570348784efSdrh /*
35713e27c026Sdrh ** If the macro TCLSH is one, then put in code this for the
35723e27c026Sdrh ** "main" routine that will initialize Tcl and take input from
35733570ad93Sdrh ** standard input, or if a file is named on the command line
35743570ad93Sdrh ** the TCL interpreter reads and evaluates that file.
3575348784efSdrh */
35763e27c026Sdrh #if TCLSH==1
35770ae479dfSdan static const char *tclsh_main_loop(void){
35780ae479dfSdan   static const char zMainloop[] =
3579348784efSdrh     "set line {}\n"
3580348784efSdrh     "while {![eof stdin]} {\n"
3581348784efSdrh       "if {$line!=\"\"} {\n"
3582348784efSdrh         "puts -nonewline \"> \"\n"
3583348784efSdrh       "} else {\n"
3584348784efSdrh         "puts -nonewline \"% \"\n"
3585348784efSdrh       "}\n"
3586348784efSdrh       "flush stdout\n"
3587348784efSdrh       "append line [gets stdin]\n"
3588348784efSdrh       "if {[info complete $line]} {\n"
3589348784efSdrh         "if {[catch {uplevel #0 $line} result]} {\n"
3590348784efSdrh           "puts stderr \"Error: $result\"\n"
3591348784efSdrh         "} elseif {$result!=\"\"} {\n"
3592348784efSdrh           "puts $result\n"
3593348784efSdrh         "}\n"
3594348784efSdrh         "set line {}\n"
3595348784efSdrh       "} else {\n"
3596348784efSdrh         "append line \\n\n"
3597348784efSdrh       "}\n"
3598348784efSdrh     "}\n"
3599348784efSdrh   ;
36000ae479dfSdan   return zMainloop;
36010ae479dfSdan }
36023e27c026Sdrh #endif
36033a0f13ffSdrh #if TCLSH==2
36040ae479dfSdan static const char *tclsh_main_loop(void);
36053a0f13ffSdrh #endif
36063e27c026Sdrh 
3607c1a60c51Sdan #ifdef SQLITE_TEST
3608c1a60c51Sdan static void init_all(Tcl_Interp *);
3609c1a60c51Sdan static int init_all_cmd(
3610c1a60c51Sdan   ClientData cd,
3611c1a60c51Sdan   Tcl_Interp *interp,
3612c1a60c51Sdan   int objc,
3613c1a60c51Sdan   Tcl_Obj *CONST objv[]
3614c1a60c51Sdan ){
36150a549071Sdanielk1977 
3616c1a60c51Sdan   Tcl_Interp *slave;
3617c1a60c51Sdan   if( objc!=2 ){
3618c1a60c51Sdan     Tcl_WrongNumArgs(interp, 1, objv, "SLAVE");
3619c1a60c51Sdan     return TCL_ERROR;
3620c1a60c51Sdan   }
36210a549071Sdanielk1977 
3622c1a60c51Sdan   slave = Tcl_GetSlave(interp, Tcl_GetString(objv[1]));
3623c1a60c51Sdan   if( !slave ){
3624c1a60c51Sdan     return TCL_ERROR;
3625c1a60c51Sdan   }
3626c1a60c51Sdan 
3627c1a60c51Sdan   init_all(slave);
3628c1a60c51Sdan   return TCL_OK;
3629c1a60c51Sdan }
3630c431fd55Sdan 
3631c431fd55Sdan /*
3632c431fd55Sdan ** Tclcmd: db_use_legacy_prepare DB BOOLEAN
3633c431fd55Sdan **
3634c431fd55Sdan **   The first argument to this command must be a database command created by
3635c431fd55Sdan **   [sqlite3]. If the second argument is true, then the handle is configured
3636c431fd55Sdan **   to use the sqlite3_prepare_v2() function to prepare statements. If it
3637c431fd55Sdan **   is false, sqlite3_prepare().
3638c431fd55Sdan */
3639c431fd55Sdan static int db_use_legacy_prepare_cmd(
3640c431fd55Sdan   ClientData cd,
3641c431fd55Sdan   Tcl_Interp *interp,
3642c431fd55Sdan   int objc,
3643c431fd55Sdan   Tcl_Obj *CONST objv[]
3644c431fd55Sdan ){
3645c431fd55Sdan   Tcl_CmdInfo cmdInfo;
3646c431fd55Sdan   SqliteDb *pDb;
3647c431fd55Sdan   int bPrepare;
3648c431fd55Sdan 
3649c431fd55Sdan   if( objc!=3 ){
3650c431fd55Sdan     Tcl_WrongNumArgs(interp, 1, objv, "DB BOOLEAN");
3651c431fd55Sdan     return TCL_ERROR;
3652c431fd55Sdan   }
3653c431fd55Sdan 
3654c431fd55Sdan   if( !Tcl_GetCommandInfo(interp, Tcl_GetString(objv[1]), &cmdInfo) ){
3655c431fd55Sdan     Tcl_AppendResult(interp, "no such db: ", Tcl_GetString(objv[1]), (char*)0);
3656c431fd55Sdan     return TCL_ERROR;
3657c431fd55Sdan   }
3658c431fd55Sdan   pDb = (SqliteDb*)cmdInfo.objClientData;
3659c431fd55Sdan   if( Tcl_GetBooleanFromObj(interp, objv[2], &bPrepare) ){
3660c431fd55Sdan     return TCL_ERROR;
3661c431fd55Sdan   }
3662c431fd55Sdan 
3663c431fd55Sdan   pDb->bLegacyPrepare = bPrepare;
3664c431fd55Sdan 
3665c431fd55Sdan   Tcl_ResetResult(interp);
3666c431fd55Sdan   return TCL_OK;
3667c431fd55Sdan }
366804489b6dSdan 
366904489b6dSdan /*
367004489b6dSdan ** Tclcmd: db_last_stmt_ptr DB
367104489b6dSdan **
367204489b6dSdan **   If the statement cache associated with database DB is not empty,
367304489b6dSdan **   return the text representation of the most recently used statement
367404489b6dSdan **   handle.
367504489b6dSdan */
367604489b6dSdan static int db_last_stmt_ptr(
367704489b6dSdan   ClientData cd,
367804489b6dSdan   Tcl_Interp *interp,
367904489b6dSdan   int objc,
368004489b6dSdan   Tcl_Obj *CONST objv[]
368104489b6dSdan ){
368204489b6dSdan   extern int sqlite3TestMakePointerStr(Tcl_Interp*, char*, void*);
368304489b6dSdan   Tcl_CmdInfo cmdInfo;
368404489b6dSdan   SqliteDb *pDb;
368504489b6dSdan   sqlite3_stmt *pStmt = 0;
368604489b6dSdan   char zBuf[100];
368704489b6dSdan 
368804489b6dSdan   if( objc!=2 ){
368904489b6dSdan     Tcl_WrongNumArgs(interp, 1, objv, "DB");
369004489b6dSdan     return TCL_ERROR;
369104489b6dSdan   }
369204489b6dSdan 
369304489b6dSdan   if( !Tcl_GetCommandInfo(interp, Tcl_GetString(objv[1]), &cmdInfo) ){
369404489b6dSdan     Tcl_AppendResult(interp, "no such db: ", Tcl_GetString(objv[1]), (char*)0);
369504489b6dSdan     return TCL_ERROR;
369604489b6dSdan   }
369704489b6dSdan   pDb = (SqliteDb*)cmdInfo.objClientData;
369804489b6dSdan 
369904489b6dSdan   if( pDb->stmtList ) pStmt = pDb->stmtList->pStmt;
370004489b6dSdan   if( sqlite3TestMakePointerStr(interp, zBuf, pStmt) ){
370104489b6dSdan     return TCL_ERROR;
370204489b6dSdan   }
370304489b6dSdan   Tcl_SetResult(interp, zBuf, TCL_VOLATILE);
370404489b6dSdan 
370504489b6dSdan   return TCL_OK;
370604489b6dSdan }
37071a4a680aSdrh #endif /* SQLITE_TEST */
3708c1a60c51Sdan 
3709c1a60c51Sdan /*
3710c1a60c51Sdan ** Configure the interpreter passed as the first argument to have access
3711c1a60c51Sdan ** to the commands and linked variables that make up:
3712c1a60c51Sdan **
3713c1a60c51Sdan **   * the [sqlite3] extension itself,
3714c1a60c51Sdan **
3715c1a60c51Sdan **   * If SQLITE_TCLMD5 or SQLITE_TEST is defined, the Md5 commands, and
3716c1a60c51Sdan **
3717c1a60c51Sdan **   * If SQLITE_TEST is set, the various test interfaces used by the Tcl
3718c1a60c51Sdan **     test suite.
3719c1a60c51Sdan */
3720c1a60c51Sdan static void init_all(Tcl_Interp *interp){
372138f8271fSdrh   Sqlite3_Init(interp);
3722c1a60c51Sdan 
372357a0227fSdrh #if defined(SQLITE_TEST) || defined(SQLITE_TCLMD5)
372457a0227fSdrh   Md5_Init(interp);
372557a0227fSdrh #endif
3726c1a60c51Sdan 
3727d9b0257aSdrh #ifdef SQLITE_TEST
3728d1bf3512Sdrh   {
37292f999a67Sdrh     extern int Sqliteconfig_Init(Tcl_Interp*);
3730d1bf3512Sdrh     extern int Sqlitetest1_Init(Tcl_Interp*);
37315c4d9703Sdrh     extern int Sqlitetest2_Init(Tcl_Interp*);
37325c4d9703Sdrh     extern int Sqlitetest3_Init(Tcl_Interp*);
3733a6064dcfSdrh     extern int Sqlitetest4_Init(Tcl_Interp*);
3734998b56c3Sdanielk1977     extern int Sqlitetest5_Init(Tcl_Interp*);
37359c06c953Sdrh     extern int Sqlitetest6_Init(Tcl_Interp*);
373629c636bcSdrh     extern int Sqlitetest7_Init(Tcl_Interp*);
3737b9bb7c18Sdrh     extern int Sqlitetest8_Init(Tcl_Interp*);
3738a713f2c3Sdanielk1977     extern int Sqlitetest9_Init(Tcl_Interp*);
37392366940dSdrh     extern int Sqlitetestasync_Init(Tcl_Interp*);
37401409be69Sdrh     extern int Sqlitetest_autoext_Init(Tcl_Interp*);
3741b391b944Sdan     extern int Sqlitetest_blob_Init(Tcl_Interp*);
37420a7a9155Sdan     extern int Sqlitetest_demovfs_Init(Tcl_Interp *);
3743984bfaa4Sdrh     extern int Sqlitetest_func_Init(Tcl_Interp*);
374415926590Sdrh     extern int Sqlitetest_hexio_Init(Tcl_Interp*);
3745e1ab2193Sdan     extern int Sqlitetest_init_Init(Tcl_Interp*);
37462f999a67Sdrh     extern int Sqlitetest_malloc_Init(Tcl_Interp*);
37471a9ed0b2Sdanielk1977     extern int Sqlitetest_mutex_Init(Tcl_Interp*);
37482f999a67Sdrh     extern int Sqlitetestschema_Init(Tcl_Interp*);
37492f999a67Sdrh     extern int Sqlitetestsse_Init(Tcl_Interp*);
37502f999a67Sdrh     extern int Sqlitetesttclvar_Init(Tcl_Interp*);
37519f5ff371Sdan     extern int Sqlitetestfs_Init(Tcl_Interp*);
375244918fa0Sdanielk1977     extern int SqlitetestThread_Init(Tcl_Interp*);
3753a15db353Sdanielk1977     extern int SqlitetestOnefile_Init();
37545d1f5aa6Sdanielk1977     extern int SqlitetestOsinst_Init(Tcl_Interp*);
37550410302eSdanielk1977     extern int Sqlitetestbackup_Init(Tcl_Interp*);
3756522efc62Sdrh     extern int Sqlitetestintarray_Init(Tcl_Interp*);
3757c7991bdfSdan     extern int Sqlitetestvfs_Init(Tcl_Interp *);
37589508daa9Sdan     extern int Sqlitetestrtree_Init(Tcl_Interp*);
37598cf35eb4Sdan     extern int Sqlitequota_Init(Tcl_Interp*);
37608a922f75Sshaneh     extern int Sqlitemultiplex_Init(Tcl_Interp*);
3761e336b001Sdan     extern int SqliteSuperlock_Init(Tcl_Interp*);
3762213ca0a8Sdan     extern int SqlitetestSyscall_Init(Tcl_Interp*);
376389a89560Sdan     extern int Fts5tcl_Init(Tcl_Interp *);
3764*cfb8f8d6Sdrh     extern int SqliteRbu_Init(Tcl_Interp*);
37656764a700Sdan #if defined(SQLITE_ENABLE_FTS3) || defined(SQLITE_ENABLE_FTS4)
376699ebad90Sdan     extern int Sqlitetestfts3_Init(Tcl_Interp *interp);
376799ebad90Sdan #endif
376899ebad90Sdan 
3769b29010cdSdan #ifdef SQLITE_ENABLE_ZIPVFS
3770b29010cdSdan     extern int Zipvfs_Init(Tcl_Interp*);
3771b29010cdSdan     Zipvfs_Init(interp);
3772b29010cdSdan #endif
3773b29010cdSdan 
37742f999a67Sdrh     Sqliteconfig_Init(interp);
37756490bebdSdanielk1977     Sqlitetest1_Init(interp);
37765c4d9703Sdrh     Sqlitetest2_Init(interp);
3777de647130Sdrh     Sqlitetest3_Init(interp);
3778fc57d7bfSdanielk1977     Sqlitetest4_Init(interp);
3779998b56c3Sdanielk1977     Sqlitetest5_Init(interp);
37809c06c953Sdrh     Sqlitetest6_Init(interp);
378129c636bcSdrh     Sqlitetest7_Init(interp);
3782b9bb7c18Sdrh     Sqlitetest8_Init(interp);
3783a713f2c3Sdanielk1977     Sqlitetest9_Init(interp);
37842366940dSdrh     Sqlitetestasync_Init(interp);
37851409be69Sdrh     Sqlitetest_autoext_Init(interp);
3786b391b944Sdan     Sqlitetest_blob_Init(interp);
37870a7a9155Sdan     Sqlitetest_demovfs_Init(interp);
3788984bfaa4Sdrh     Sqlitetest_func_Init(interp);
378915926590Sdrh     Sqlitetest_hexio_Init(interp);
3790e1ab2193Sdan     Sqlitetest_init_Init(interp);
37912f999a67Sdrh     Sqlitetest_malloc_Init(interp);
37921a9ed0b2Sdanielk1977     Sqlitetest_mutex_Init(interp);
37932f999a67Sdrh     Sqlitetestschema_Init(interp);
37942f999a67Sdrh     Sqlitetesttclvar_Init(interp);
37959f5ff371Sdan     Sqlitetestfs_Init(interp);
379644918fa0Sdanielk1977     SqlitetestThread_Init(interp);
3797a15db353Sdanielk1977     SqlitetestOnefile_Init(interp);
37985d1f5aa6Sdanielk1977     SqlitetestOsinst_Init(interp);
37990410302eSdanielk1977     Sqlitetestbackup_Init(interp);
3800522efc62Sdrh     Sqlitetestintarray_Init(interp);
3801c7991bdfSdan     Sqlitetestvfs_Init(interp);
38029508daa9Sdan     Sqlitetestrtree_Init(interp);
38038cf35eb4Sdan     Sqlitequota_Init(interp);
38048a922f75Sshaneh     Sqlitemultiplex_Init(interp);
3805e336b001Sdan     SqliteSuperlock_Init(interp);
3806213ca0a8Sdan     SqlitetestSyscall_Init(interp);
380789a89560Sdan     Fts5tcl_Init(interp);
3808*cfb8f8d6Sdrh     SqliteRbu_Init(interp);
3809a15db353Sdanielk1977 
38106764a700Sdan #if defined(SQLITE_ENABLE_FTS3) || defined(SQLITE_ENABLE_FTS4)
381199ebad90Sdan     Sqlitetestfts3_Init(interp);
381299ebad90Sdan #endif
381399ebad90Sdan 
3814c431fd55Sdan     Tcl_CreateObjCommand(
3815c431fd55Sdan         interp, "load_testfixture_extensions", init_all_cmd, 0, 0
3816c431fd55Sdan     );
3817c431fd55Sdan     Tcl_CreateObjCommand(
3818c431fd55Sdan         interp, "db_use_legacy_prepare", db_use_legacy_prepare_cmd, 0, 0
3819c431fd55Sdan     );
382004489b6dSdan     Tcl_CreateObjCommand(
382104489b6dSdan         interp, "db_last_stmt_ptr", db_last_stmt_ptr, 0, 0
382204489b6dSdan     );
3823c1a60c51Sdan 
382489dec819Sdrh #ifdef SQLITE_SSE
38252e66f0b9Sdrh     Sqlitetestsse_Init(interp);
38262e66f0b9Sdrh #endif
3827d1bf3512Sdrh   }
3828d1bf3512Sdrh #endif
3829c1a60c51Sdan }
3830c1a60c51Sdan 
3831db6bafaeSdrh /* Needed for the setrlimit() system call on unix */
3832db6bafaeSdrh #if defined(unix)
3833db6bafaeSdrh #include <sys/resource.h>
3834db6bafaeSdrh #endif
3835db6bafaeSdrh 
3836c1a60c51Sdan #define TCLSH_MAIN main   /* Needed to fake out mktclapp */
3837c1a60c51Sdan int TCLSH_MAIN(int argc, char **argv){
3838c1a60c51Sdan   Tcl_Interp *interp;
3839c1a60c51Sdan 
38401f28e070Smistachkin #if !defined(_WIN32_WCE)
38411f28e070Smistachkin   if( getenv("BREAK") ){
38421f28e070Smistachkin     fprintf(stderr,
38431f28e070Smistachkin         "attach debugger to process %d and press any key to continue.\n",
38441f28e070Smistachkin         GETPID());
38451f28e070Smistachkin     fgetc(stdin);
38461f28e070Smistachkin   }
38471f28e070Smistachkin #endif
38481f28e070Smistachkin 
3849db6bafaeSdrh   /* Since the primary use case for this binary is testing of SQLite,
3850db6bafaeSdrh   ** be sure to generate core files if we crash */
3851db6bafaeSdrh #if defined(SQLITE_TEST) && defined(unix)
3852db6bafaeSdrh   { struct rlimit x;
3853db6bafaeSdrh     getrlimit(RLIMIT_CORE, &x);
3854db6bafaeSdrh     x.rlim_cur = x.rlim_max;
3855db6bafaeSdrh     setrlimit(RLIMIT_CORE, &x);
3856db6bafaeSdrh   }
3857db6bafaeSdrh #endif /* SQLITE_TEST && unix */
3858db6bafaeSdrh 
3859db6bafaeSdrh 
3860c1a60c51Sdan   /* Call sqlite3_shutdown() once before doing anything else. This is to
3861c1a60c51Sdan   ** test that sqlite3_shutdown() can be safely called by a process before
3862c1a60c51Sdan   ** sqlite3_initialize() is. */
3863c1a60c51Sdan   sqlite3_shutdown();
3864c1a60c51Sdan 
38650ae479dfSdan   Tcl_FindExecutable(argv[0]);
38662953ba9eSmistachkin   Tcl_SetSystemEncoding(NULL, "utf-8");
38670ae479dfSdan   interp = Tcl_CreateInterp();
38680ae479dfSdan 
38693a0f13ffSdrh #if TCLSH==2
38703a0f13ffSdrh   sqlite3_config(SQLITE_CONFIG_SINGLETHREAD);
38713a0f13ffSdrh #endif
3872c1a60c51Sdan 
3873c1a60c51Sdan   init_all(interp);
3874c7285978Sdrh   if( argc>=2 ){
3875348784efSdrh     int i;
3876ad42c3a3Sshess     char zArgc[32];
3877ad42c3a3Sshess     sqlite3_snprintf(sizeof(zArgc), zArgc, "%d", argc-(3-TCLSH));
3878ad42c3a3Sshess     Tcl_SetVar(interp,"argc", zArgc, TCL_GLOBAL_ONLY);
3879348784efSdrh     Tcl_SetVar(interp,"argv0",argv[1],TCL_GLOBAL_ONLY);
3880348784efSdrh     Tcl_SetVar(interp,"argv", "", TCL_GLOBAL_ONLY);
388161212b69Sdrh     for(i=3-TCLSH; i<argc; i++){
3882348784efSdrh       Tcl_SetVar(interp, "argv", argv[i],
3883348784efSdrh           TCL_GLOBAL_ONLY | TCL_LIST_ELEMENT | TCL_APPEND_VALUE);
3884348784efSdrh     }
38853a0f13ffSdrh     if( TCLSH==1 && Tcl_EvalFile(interp, argv[1])!=TCL_OK ){
38860de8c112Sdrh       const char *zInfo = Tcl_GetVar(interp, "errorInfo", TCL_GLOBAL_ONLY);
3887a81c64a2Sdrh       if( zInfo==0 ) zInfo = Tcl_GetStringResult(interp);
3888c61053b7Sdrh       fprintf(stderr,"%s: %s\n", *argv, zInfo);
3889348784efSdrh       return 1;
3890348784efSdrh     }
38913e27c026Sdrh   }
38923a0f13ffSdrh   if( TCLSH==2 || argc<=1 ){
38930ae479dfSdan     Tcl_GlobalEval(interp, tclsh_main_loop());
3894348784efSdrh   }
3895348784efSdrh   return 0;
3896348784efSdrh }
3897348784efSdrh #endif /* TCLSH */
3898