xref: /sqlite-3.40.0/src/tclsqlite.c (revision db6bafae)
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 */
28bd08af48Sdrh #include "tcl.h"
29b4e9af9fSdanielk1977 #include <errno.h>
306d31316cSdrh 
31bd08af48Sdrh /*
32bd08af48Sdrh ** Some additional include files are needed if this file is not
33bd08af48Sdrh ** appended to the amalgamation.
34bd08af48Sdrh */
35bd08af48Sdrh #ifndef SQLITE_AMALGAMATION
3665e8c82eSdrh # include "sqlite3.h"
3775897234Sdrh # include <stdlib.h>
3875897234Sdrh # include <string.h>
39ce927065Sdrh # include <assert.h>
4065e8c82eSdrh   typedef unsigned char u8;
41bd08af48Sdrh #endif
42eb206381Sdrh #include <ctype.h>
4375897234Sdrh 
441f28e070Smistachkin /* Used to get the current process ID */
451f28e070Smistachkin #if !defined(_WIN32)
461f28e070Smistachkin # include <unistd.h>
471f28e070Smistachkin # define GETPID getpid
481f28e070Smistachkin #elif !defined(_WIN32_WCE)
491f28e070Smistachkin # ifndef SQLITE_AMALGAMATION
501f28e070Smistachkin #  define WIN32_LEAN_AND_MEAN
511f28e070Smistachkin #  include <windows.h>
521f28e070Smistachkin # endif
531f28e070Smistachkin # define GETPID (int)GetCurrentProcessId
541f28e070Smistachkin #endif
551f28e070Smistachkin 
56ad6e1370Sdrh /*
57ad6e1370Sdrh  * Windows needs to know which symbols to export.  Unix does not.
58ad6e1370Sdrh  * BUILD_sqlite should be undefined for Unix.
59ad6e1370Sdrh  */
60ad6e1370Sdrh #ifdef BUILD_sqlite
61ad6e1370Sdrh #undef TCL_STORAGE_CLASS
62ad6e1370Sdrh #define TCL_STORAGE_CLASS DLLEXPORT
63ad6e1370Sdrh #endif /* BUILD_sqlite */
6429bc4615Sdrh 
65a21c6b6fSdanielk1977 #define NUM_PREPARED_STMTS 10
66fb7e7651Sdrh #define MAX_PREPARED_STMTS 100
67fb7e7651Sdrh 
68c45e6716Sdrh /* Forward declaration */
69c45e6716Sdrh typedef struct SqliteDb SqliteDb;
7098808babSdrh 
7198808babSdrh /*
72cabb0819Sdrh ** New SQL functions can be created as TCL scripts.  Each such function
73cabb0819Sdrh ** is described by an instance of the following structure.
74cabb0819Sdrh */
75cabb0819Sdrh typedef struct SqlFunc SqlFunc;
76cabb0819Sdrh struct SqlFunc {
77cabb0819Sdrh   Tcl_Interp *interp;   /* The TCL interpret to execute the function */
78d1e4733dSdrh   Tcl_Obj *pScript;     /* The Tcl_Obj representation of the script */
79c45e6716Sdrh   SqliteDb *pDb;        /* Database connection that owns this function */
80d1e4733dSdrh   int useEvalObjv;      /* True if it is safe to use Tcl_EvalObjv */
81d1e4733dSdrh   char *zName;          /* Name of this function */
82cabb0819Sdrh   SqlFunc *pNext;       /* Next function on the list of them all */
83cabb0819Sdrh };
84cabb0819Sdrh 
85cabb0819Sdrh /*
860202b29eSdanielk1977 ** New collation sequences function can be created as TCL scripts.  Each such
870202b29eSdanielk1977 ** function is described by an instance of the following structure.
880202b29eSdanielk1977 */
890202b29eSdanielk1977 typedef struct SqlCollate SqlCollate;
900202b29eSdanielk1977 struct SqlCollate {
910202b29eSdanielk1977   Tcl_Interp *interp;   /* The TCL interpret to execute the function */
920202b29eSdanielk1977   char *zScript;        /* The script to be run */
930202b29eSdanielk1977   SqlCollate *pNext;    /* Next function on the list of them all */
940202b29eSdanielk1977 };
950202b29eSdanielk1977 
960202b29eSdanielk1977 /*
97fb7e7651Sdrh ** Prepared statements are cached for faster execution.  Each prepared
98fb7e7651Sdrh ** statement is described by an instance of the following structure.
99fb7e7651Sdrh */
100fb7e7651Sdrh typedef struct SqlPreparedStmt SqlPreparedStmt;
101fb7e7651Sdrh struct SqlPreparedStmt {
102fb7e7651Sdrh   SqlPreparedStmt *pNext;  /* Next in linked list */
103fb7e7651Sdrh   SqlPreparedStmt *pPrev;  /* Previous on the list */
104fb7e7651Sdrh   sqlite3_stmt *pStmt;     /* The prepared statement */
105fb7e7651Sdrh   int nSql;                /* chars in zSql[] */
106d0e2a854Sdanielk1977   const char *zSql;        /* Text of the SQL statement */
1074a4c11aaSdan   int nParm;               /* Size of apParm array */
1084a4c11aaSdan   Tcl_Obj **apParm;        /* Array of referenced object pointers */
109fb7e7651Sdrh };
110fb7e7651Sdrh 
111d0441796Sdanielk1977 typedef struct IncrblobChannel IncrblobChannel;
112d0441796Sdanielk1977 
113fb7e7651Sdrh /*
114bec3f402Sdrh ** There is one instance of this structure for each SQLite database
115bec3f402Sdrh ** that has been opened by the SQLite TCL interface.
116c431fd55Sdan **
117c431fd55Sdan ** If this module is built with SQLITE_TEST defined (to create the SQLite
118c431fd55Sdan ** testfixture executable), then it may be configured to use either
119c431fd55Sdan ** sqlite3_prepare_v2() or sqlite3_prepare() to prepare SQL statements.
120c431fd55Sdan ** If SqliteDb.bLegacyPrepare is true, sqlite3_prepare() is used.
121bec3f402Sdrh */
122bec3f402Sdrh struct SqliteDb {
123dddca286Sdrh   sqlite3 *db;               /* The "real" database structure. MUST BE FIRST */
124bec3f402Sdrh   Tcl_Interp *interp;        /* The interpreter used for this database */
1256d31316cSdrh   char *zBusy;               /* The busy callback routine */
126aa940eacSdrh   char *zCommit;             /* The commit hook callback routine */
127b5a20d3cSdrh   char *zTrace;              /* The trace callback routine */
12819e2d37fSdrh   char *zProfile;            /* The profile callback routine */
129348bb5d6Sdanielk1977   char *zProgress;           /* The progress callback routine */
130e22a334bSdrh   char *zAuth;               /* The authorization callback routine */
1311f1549f8Sdrh   int disableAuth;           /* Disable the authorizer if it exists */
13255c45f2eSdanielk1977   char *zNull;               /* Text to substitute for an SQL NULL value */
133cabb0819Sdrh   SqlFunc *pFunc;            /* List of SQL functions */
13494eb6a14Sdanielk1977   Tcl_Obj *pUpdateHook;      /* Update hook script (if any) */
13571fd80bfSdanielk1977   Tcl_Obj *pRollbackHook;    /* Rollback hook script (if any) */
1365def0843Sdrh   Tcl_Obj *pWalHook;         /* WAL hook script (if any) */
137404ca075Sdanielk1977   Tcl_Obj *pUnlockNotify;    /* Unlock notify script (if any) */
1380202b29eSdanielk1977   SqlCollate *pCollate;      /* List of SQL collation functions */
1396f8a503dSdanielk1977   int rc;                    /* Return code of most recent sqlite3_exec() */
1407cedc8d4Sdanielk1977   Tcl_Obj *pCollateNeeded;   /* Collation needed script */
141fb7e7651Sdrh   SqlPreparedStmt *stmtList; /* List of prepared statements*/
142fb7e7651Sdrh   SqlPreparedStmt *stmtLast; /* Last statement in the list */
143fb7e7651Sdrh   int maxStmt;               /* The next maximum number of stmtList */
144fb7e7651Sdrh   int nStmt;                 /* Number of statements in stmtList */
145d0441796Sdanielk1977   IncrblobChannel *pIncrblob;/* Linked list of open incrblob channels */
1463c379b01Sdrh   int nStep, nSort, nIndex;  /* Statistics for most recent operation */
147cd38d520Sdanielk1977   int nTransaction;          /* Number of nested [transaction] methods */
148c431fd55Sdan #ifdef SQLITE_TEST
149c431fd55Sdan   int bLegacyPrepare;        /* True to use sqlite3_prepare() */
150c431fd55Sdan #endif
15198808babSdrh };
152297ecf14Sdrh 
153b4e9af9fSdanielk1977 struct IncrblobChannel {
154d0441796Sdanielk1977   sqlite3_blob *pBlob;      /* sqlite3 blob handle */
155dcbb5d3fSdanielk1977   SqliteDb *pDb;            /* Associated database connection */
156b4e9af9fSdanielk1977   int iSeek;                /* Current seek offset */
157d0441796Sdanielk1977   Tcl_Channel channel;      /* Channel identifier */
158d0441796Sdanielk1977   IncrblobChannel *pNext;   /* Linked list of all open incrblob channels */
159d0441796Sdanielk1977   IncrblobChannel *pPrev;   /* Linked list of all open incrblob channels */
160b4e9af9fSdanielk1977 };
161b4e9af9fSdanielk1977 
162ea678832Sdrh /*
163ea678832Sdrh ** Compute a string length that is limited to what can be stored in
164ea678832Sdrh ** lower 30 bits of a 32-bit signed integer.
165ea678832Sdrh */
1664f21c4afSdrh static int strlen30(const char *z){
167ea678832Sdrh   const char *z2 = z;
168ea678832Sdrh   while( *z2 ){ z2++; }
169ea678832Sdrh   return 0x3fffffff & (int)(z2 - z);
170ea678832Sdrh }
171ea678832Sdrh 
172ea678832Sdrh 
17332a0d8bbSdanielk1977 #ifndef SQLITE_OMIT_INCRBLOB
174b4e9af9fSdanielk1977 /*
175d0441796Sdanielk1977 ** Close all incrblob channels opened using database connection pDb.
176d0441796Sdanielk1977 ** This is called when shutting down the database connection.
177d0441796Sdanielk1977 */
178d0441796Sdanielk1977 static void closeIncrblobChannels(SqliteDb *pDb){
179d0441796Sdanielk1977   IncrblobChannel *p;
180d0441796Sdanielk1977   IncrblobChannel *pNext;
181d0441796Sdanielk1977 
182d0441796Sdanielk1977   for(p=pDb->pIncrblob; p; p=pNext){
183d0441796Sdanielk1977     pNext = p->pNext;
184d0441796Sdanielk1977 
185d0441796Sdanielk1977     /* Note: Calling unregister here call Tcl_Close on the incrblob channel,
186d0441796Sdanielk1977     ** which deletes the IncrblobChannel structure at *p. So do not
187d0441796Sdanielk1977     ** call Tcl_Free() here.
188d0441796Sdanielk1977     */
189d0441796Sdanielk1977     Tcl_UnregisterChannel(pDb->interp, p->channel);
190d0441796Sdanielk1977   }
191d0441796Sdanielk1977 }
192d0441796Sdanielk1977 
193d0441796Sdanielk1977 /*
194b4e9af9fSdanielk1977 ** Close an incremental blob channel.
195b4e9af9fSdanielk1977 */
196b4e9af9fSdanielk1977 static int incrblobClose(ClientData instanceData, Tcl_Interp *interp){
197b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
19892d4d7a9Sdanielk1977   int rc = sqlite3_blob_close(p->pBlob);
19992d4d7a9Sdanielk1977   sqlite3 *db = p->pDb->db;
200d0441796Sdanielk1977 
201d0441796Sdanielk1977   /* Remove the channel from the SqliteDb.pIncrblob list. */
202d0441796Sdanielk1977   if( p->pNext ){
203d0441796Sdanielk1977     p->pNext->pPrev = p->pPrev;
204d0441796Sdanielk1977   }
205d0441796Sdanielk1977   if( p->pPrev ){
206d0441796Sdanielk1977     p->pPrev->pNext = p->pNext;
207d0441796Sdanielk1977   }
208d0441796Sdanielk1977   if( p->pDb->pIncrblob==p ){
209d0441796Sdanielk1977     p->pDb->pIncrblob = p->pNext;
210d0441796Sdanielk1977   }
211d0441796Sdanielk1977 
21292d4d7a9Sdanielk1977   /* Free the IncrblobChannel structure */
213b4e9af9fSdanielk1977   Tcl_Free((char *)p);
21492d4d7a9Sdanielk1977 
21592d4d7a9Sdanielk1977   if( rc!=SQLITE_OK ){
21692d4d7a9Sdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_errmsg(db), TCL_VOLATILE);
21792d4d7a9Sdanielk1977     return TCL_ERROR;
21892d4d7a9Sdanielk1977   }
219b4e9af9fSdanielk1977   return TCL_OK;
220b4e9af9fSdanielk1977 }
221b4e9af9fSdanielk1977 
222b4e9af9fSdanielk1977 /*
223b4e9af9fSdanielk1977 ** Read data from an incremental blob channel.
224b4e9af9fSdanielk1977 */
225b4e9af9fSdanielk1977 static int incrblobInput(
226b4e9af9fSdanielk1977   ClientData instanceData,
227b4e9af9fSdanielk1977   char *buf,
228b4e9af9fSdanielk1977   int bufSize,
229b4e9af9fSdanielk1977   int *errorCodePtr
230b4e9af9fSdanielk1977 ){
231b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
232b4e9af9fSdanielk1977   int nRead = bufSize;         /* Number of bytes to read */
233b4e9af9fSdanielk1977   int nBlob;                   /* Total size of the blob */
234b4e9af9fSdanielk1977   int rc;                      /* sqlite error code */
235b4e9af9fSdanielk1977 
236b4e9af9fSdanielk1977   nBlob = sqlite3_blob_bytes(p->pBlob);
237b4e9af9fSdanielk1977   if( (p->iSeek+nRead)>nBlob ){
238b4e9af9fSdanielk1977     nRead = nBlob-p->iSeek;
239b4e9af9fSdanielk1977   }
240b4e9af9fSdanielk1977   if( nRead<=0 ){
241b4e9af9fSdanielk1977     return 0;
242b4e9af9fSdanielk1977   }
243b4e9af9fSdanielk1977 
244b4e9af9fSdanielk1977   rc = sqlite3_blob_read(p->pBlob, (void *)buf, nRead, p->iSeek);
245b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
246b4e9af9fSdanielk1977     *errorCodePtr = rc;
247b4e9af9fSdanielk1977     return -1;
248b4e9af9fSdanielk1977   }
249b4e9af9fSdanielk1977 
250b4e9af9fSdanielk1977   p->iSeek += nRead;
251b4e9af9fSdanielk1977   return nRead;
252b4e9af9fSdanielk1977 }
253b4e9af9fSdanielk1977 
254d0441796Sdanielk1977 /*
255d0441796Sdanielk1977 ** Write data to an incremental blob channel.
256d0441796Sdanielk1977 */
257b4e9af9fSdanielk1977 static int incrblobOutput(
258b4e9af9fSdanielk1977   ClientData instanceData,
259b4e9af9fSdanielk1977   CONST char *buf,
260b4e9af9fSdanielk1977   int toWrite,
261b4e9af9fSdanielk1977   int *errorCodePtr
262b4e9af9fSdanielk1977 ){
263b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
264b4e9af9fSdanielk1977   int nWrite = toWrite;        /* Number of bytes to write */
265b4e9af9fSdanielk1977   int nBlob;                   /* Total size of the blob */
266b4e9af9fSdanielk1977   int rc;                      /* sqlite error code */
267b4e9af9fSdanielk1977 
268b4e9af9fSdanielk1977   nBlob = sqlite3_blob_bytes(p->pBlob);
269b4e9af9fSdanielk1977   if( (p->iSeek+nWrite)>nBlob ){
270b4e9af9fSdanielk1977     *errorCodePtr = EINVAL;
271b4e9af9fSdanielk1977     return -1;
272b4e9af9fSdanielk1977   }
273b4e9af9fSdanielk1977   if( nWrite<=0 ){
274b4e9af9fSdanielk1977     return 0;
275b4e9af9fSdanielk1977   }
276b4e9af9fSdanielk1977 
277b4e9af9fSdanielk1977   rc = sqlite3_blob_write(p->pBlob, (void *)buf, nWrite, p->iSeek);
278b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
279b4e9af9fSdanielk1977     *errorCodePtr = EIO;
280b4e9af9fSdanielk1977     return -1;
281b4e9af9fSdanielk1977   }
282b4e9af9fSdanielk1977 
283b4e9af9fSdanielk1977   p->iSeek += nWrite;
284b4e9af9fSdanielk1977   return nWrite;
285b4e9af9fSdanielk1977 }
286b4e9af9fSdanielk1977 
287b4e9af9fSdanielk1977 /*
288b4e9af9fSdanielk1977 ** Seek an incremental blob channel.
289b4e9af9fSdanielk1977 */
290b4e9af9fSdanielk1977 static int incrblobSeek(
291b4e9af9fSdanielk1977   ClientData instanceData,
292b4e9af9fSdanielk1977   long offset,
293b4e9af9fSdanielk1977   int seekMode,
294b4e9af9fSdanielk1977   int *errorCodePtr
295b4e9af9fSdanielk1977 ){
296b4e9af9fSdanielk1977   IncrblobChannel *p = (IncrblobChannel *)instanceData;
297b4e9af9fSdanielk1977 
298b4e9af9fSdanielk1977   switch( seekMode ){
299b4e9af9fSdanielk1977     case SEEK_SET:
300b4e9af9fSdanielk1977       p->iSeek = offset;
301b4e9af9fSdanielk1977       break;
302b4e9af9fSdanielk1977     case SEEK_CUR:
303b4e9af9fSdanielk1977       p->iSeek += offset;
304b4e9af9fSdanielk1977       break;
305b4e9af9fSdanielk1977     case SEEK_END:
306b4e9af9fSdanielk1977       p->iSeek = sqlite3_blob_bytes(p->pBlob) + offset;
307b4e9af9fSdanielk1977       break;
308b4e9af9fSdanielk1977 
309b4e9af9fSdanielk1977     default: assert(!"Bad seekMode");
310b4e9af9fSdanielk1977   }
311b4e9af9fSdanielk1977 
312b4e9af9fSdanielk1977   return p->iSeek;
313b4e9af9fSdanielk1977 }
314b4e9af9fSdanielk1977 
315b4e9af9fSdanielk1977 
316b4e9af9fSdanielk1977 static void incrblobWatch(ClientData instanceData, int mode){
317b4e9af9fSdanielk1977   /* NO-OP */
318b4e9af9fSdanielk1977 }
319b4e9af9fSdanielk1977 static int incrblobHandle(ClientData instanceData, int dir, ClientData *hPtr){
320b4e9af9fSdanielk1977   return TCL_ERROR;
321b4e9af9fSdanielk1977 }
322b4e9af9fSdanielk1977 
323b4e9af9fSdanielk1977 static Tcl_ChannelType IncrblobChannelType = {
324b4e9af9fSdanielk1977   "incrblob",                        /* typeName                             */
325b4e9af9fSdanielk1977   TCL_CHANNEL_VERSION_2,             /* version                              */
326b4e9af9fSdanielk1977   incrblobClose,                     /* closeProc                            */
327b4e9af9fSdanielk1977   incrblobInput,                     /* inputProc                            */
328b4e9af9fSdanielk1977   incrblobOutput,                    /* outputProc                           */
329b4e9af9fSdanielk1977   incrblobSeek,                      /* seekProc                             */
330b4e9af9fSdanielk1977   0,                                 /* setOptionProc                        */
331b4e9af9fSdanielk1977   0,                                 /* getOptionProc                        */
332b4e9af9fSdanielk1977   incrblobWatch,                     /* watchProc (this is a no-op)          */
333b4e9af9fSdanielk1977   incrblobHandle,                    /* getHandleProc (always returns error) */
334b4e9af9fSdanielk1977   0,                                 /* close2Proc                           */
335b4e9af9fSdanielk1977   0,                                 /* blockModeProc                        */
336b4e9af9fSdanielk1977   0,                                 /* flushProc                            */
337b4e9af9fSdanielk1977   0,                                 /* handlerProc                          */
338b4e9af9fSdanielk1977   0,                                 /* wideSeekProc                         */
339b4e9af9fSdanielk1977 };
340b4e9af9fSdanielk1977 
341b4e9af9fSdanielk1977 /*
342b4e9af9fSdanielk1977 ** Create a new incrblob channel.
343b4e9af9fSdanielk1977 */
344b4e9af9fSdanielk1977 static int createIncrblobChannel(
345b4e9af9fSdanielk1977   Tcl_Interp *interp,
346b4e9af9fSdanielk1977   SqliteDb *pDb,
347b4e9af9fSdanielk1977   const char *zDb,
348b4e9af9fSdanielk1977   const char *zTable,
349b4e9af9fSdanielk1977   const char *zColumn,
3508cbadb02Sdanielk1977   sqlite_int64 iRow,
3518cbadb02Sdanielk1977   int isReadonly
352b4e9af9fSdanielk1977 ){
353b4e9af9fSdanielk1977   IncrblobChannel *p;
3548cbadb02Sdanielk1977   sqlite3 *db = pDb->db;
355b4e9af9fSdanielk1977   sqlite3_blob *pBlob;
356b4e9af9fSdanielk1977   int rc;
3578cbadb02Sdanielk1977   int flags = TCL_READABLE|(isReadonly ? 0 : TCL_WRITABLE);
358b4e9af9fSdanielk1977 
359b4e9af9fSdanielk1977   /* This variable is used to name the channels: "incrblob_[incr count]" */
360b4e9af9fSdanielk1977   static int count = 0;
361b4e9af9fSdanielk1977   char zChannel[64];
362b4e9af9fSdanielk1977 
3638cbadb02Sdanielk1977   rc = sqlite3_blob_open(db, zDb, zTable, zColumn, iRow, !isReadonly, &pBlob);
364b4e9af9fSdanielk1977   if( rc!=SQLITE_OK ){
365b4e9af9fSdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
366b4e9af9fSdanielk1977     return TCL_ERROR;
367b4e9af9fSdanielk1977   }
368b4e9af9fSdanielk1977 
369b4e9af9fSdanielk1977   p = (IncrblobChannel *)Tcl_Alloc(sizeof(IncrblobChannel));
370b4e9af9fSdanielk1977   p->iSeek = 0;
371b4e9af9fSdanielk1977   p->pBlob = pBlob;
372b4e9af9fSdanielk1977 
3735bb3eb9bSdrh   sqlite3_snprintf(sizeof(zChannel), zChannel, "incrblob_%d", ++count);
374d0441796Sdanielk1977   p->channel = Tcl_CreateChannel(&IncrblobChannelType, zChannel, p, flags);
375d0441796Sdanielk1977   Tcl_RegisterChannel(interp, p->channel);
376b4e9af9fSdanielk1977 
377d0441796Sdanielk1977   /* Link the new channel into the SqliteDb.pIncrblob list. */
378d0441796Sdanielk1977   p->pNext = pDb->pIncrblob;
379d0441796Sdanielk1977   p->pPrev = 0;
380d0441796Sdanielk1977   if( p->pNext ){
381d0441796Sdanielk1977     p->pNext->pPrev = p;
382d0441796Sdanielk1977   }
383d0441796Sdanielk1977   pDb->pIncrblob = p;
384d0441796Sdanielk1977   p->pDb = pDb;
385d0441796Sdanielk1977 
386d0441796Sdanielk1977   Tcl_SetResult(interp, (char *)Tcl_GetChannelName(p->channel), TCL_VOLATILE);
387b4e9af9fSdanielk1977   return TCL_OK;
388b4e9af9fSdanielk1977 }
38932a0d8bbSdanielk1977 #else  /* else clause for "#ifndef SQLITE_OMIT_INCRBLOB" */
39032a0d8bbSdanielk1977   #define closeIncrblobChannels(pDb)
39132a0d8bbSdanielk1977 #endif
392b4e9af9fSdanielk1977 
3936d31316cSdrh /*
394d1e4733dSdrh ** Look at the script prefix in pCmd.  We will be executing this script
395d1e4733dSdrh ** after first appending one or more arguments.  This routine analyzes
396d1e4733dSdrh ** the script to see if it is safe to use Tcl_EvalObjv() on the script
397d1e4733dSdrh ** rather than the more general Tcl_EvalEx().  Tcl_EvalObjv() is much
398d1e4733dSdrh ** faster.
399d1e4733dSdrh **
400d1e4733dSdrh ** Scripts that are safe to use with Tcl_EvalObjv() consists of a
401d1e4733dSdrh ** command name followed by zero or more arguments with no [...] or $
402d1e4733dSdrh ** or {...} or ; to be seen anywhere.  Most callback scripts consist
403d1e4733dSdrh ** of just a single procedure name and they meet this requirement.
404d1e4733dSdrh */
405d1e4733dSdrh static int safeToUseEvalObjv(Tcl_Interp *interp, Tcl_Obj *pCmd){
406d1e4733dSdrh   /* We could try to do something with Tcl_Parse().  But we will instead
407d1e4733dSdrh   ** just do a search for forbidden characters.  If any of the forbidden
408d1e4733dSdrh   ** characters appear in pCmd, we will report the string as unsafe.
409d1e4733dSdrh   */
410d1e4733dSdrh   const char *z;
411d1e4733dSdrh   int n;
412d1e4733dSdrh   z = Tcl_GetStringFromObj(pCmd, &n);
413d1e4733dSdrh   while( n-- > 0 ){
414d1e4733dSdrh     int c = *(z++);
415d1e4733dSdrh     if( c=='$' || c=='[' || c==';' ) return 0;
416d1e4733dSdrh   }
417d1e4733dSdrh   return 1;
418d1e4733dSdrh }
419d1e4733dSdrh 
420d1e4733dSdrh /*
421d1e4733dSdrh ** Find an SqlFunc structure with the given name.  Or create a new
422d1e4733dSdrh ** one if an existing one cannot be found.  Return a pointer to the
423d1e4733dSdrh ** structure.
424d1e4733dSdrh */
425d1e4733dSdrh static SqlFunc *findSqlFunc(SqliteDb *pDb, const char *zName){
426d1e4733dSdrh   SqlFunc *p, *pNew;
4270425f189Sdrh   int nName = strlen30(zName);
4280425f189Sdrh   pNew = (SqlFunc*)Tcl_Alloc( sizeof(*pNew) + nName + 1 );
429d1e4733dSdrh   pNew->zName = (char*)&pNew[1];
4300425f189Sdrh   memcpy(pNew->zName, zName, nName+1);
431d1e4733dSdrh   for(p=pDb->pFunc; p; p=p->pNext){
4320425f189Sdrh     if( sqlite3_stricmp(p->zName, pNew->zName)==0 ){
433d1e4733dSdrh       Tcl_Free((char*)pNew);
434d1e4733dSdrh       return p;
435d1e4733dSdrh     }
436d1e4733dSdrh   }
437d1e4733dSdrh   pNew->interp = pDb->interp;
438c45e6716Sdrh   pNew->pDb = pDb;
439d1e4733dSdrh   pNew->pScript = 0;
440d1e4733dSdrh   pNew->pNext = pDb->pFunc;
441d1e4733dSdrh   pDb->pFunc = pNew;
442d1e4733dSdrh   return pNew;
443d1e4733dSdrh }
444d1e4733dSdrh 
445d1e4733dSdrh /*
446c431fd55Sdan ** Free a single SqlPreparedStmt object.
447c431fd55Sdan */
448c431fd55Sdan static void dbFreeStmt(SqlPreparedStmt *pStmt){
449c431fd55Sdan #ifdef SQLITE_TEST
450c431fd55Sdan   if( sqlite3_sql(pStmt->pStmt)==0 ){
451c431fd55Sdan     Tcl_Free((char *)pStmt->zSql);
452c431fd55Sdan   }
453c431fd55Sdan #endif
454c431fd55Sdan   sqlite3_finalize(pStmt->pStmt);
455c431fd55Sdan   Tcl_Free((char *)pStmt);
456c431fd55Sdan }
457c431fd55Sdan 
458c431fd55Sdan /*
459fb7e7651Sdrh ** Finalize and free a list of prepared statements
460fb7e7651Sdrh */
461fb7e7651Sdrh static void flushStmtCache(SqliteDb *pDb){
462fb7e7651Sdrh   SqlPreparedStmt *pPreStmt;
463c431fd55Sdan   SqlPreparedStmt *pNext;
464fb7e7651Sdrh 
465c431fd55Sdan   for(pPreStmt = pDb->stmtList; pPreStmt; pPreStmt=pNext){
466c431fd55Sdan     pNext = pPreStmt->pNext;
467c431fd55Sdan     dbFreeStmt(pPreStmt);
468fb7e7651Sdrh   }
469fb7e7651Sdrh   pDb->nStmt = 0;
470fb7e7651Sdrh   pDb->stmtLast = 0;
471c431fd55Sdan   pDb->stmtList = 0;
472fb7e7651Sdrh }
473fb7e7651Sdrh 
474fb7e7651Sdrh /*
475895d7472Sdrh ** TCL calls this procedure when an sqlite3 database command is
476895d7472Sdrh ** deleted.
47775897234Sdrh */
47875897234Sdrh static void DbDeleteCmd(void *db){
479bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)db;
480fb7e7651Sdrh   flushStmtCache(pDb);
481d0441796Sdanielk1977   closeIncrblobChannels(pDb);
4826f8a503dSdanielk1977   sqlite3_close(pDb->db);
483cabb0819Sdrh   while( pDb->pFunc ){
484cabb0819Sdrh     SqlFunc *pFunc = pDb->pFunc;
485cabb0819Sdrh     pDb->pFunc = pFunc->pNext;
486c45e6716Sdrh     assert( pFunc->pDb==pDb );
487d1e4733dSdrh     Tcl_DecrRefCount(pFunc->pScript);
488cabb0819Sdrh     Tcl_Free((char*)pFunc);
489cabb0819Sdrh   }
4900202b29eSdanielk1977   while( pDb->pCollate ){
4910202b29eSdanielk1977     SqlCollate *pCollate = pDb->pCollate;
4920202b29eSdanielk1977     pDb->pCollate = pCollate->pNext;
4930202b29eSdanielk1977     Tcl_Free((char*)pCollate);
4940202b29eSdanielk1977   }
495bec3f402Sdrh   if( pDb->zBusy ){
496bec3f402Sdrh     Tcl_Free(pDb->zBusy);
497bec3f402Sdrh   }
498b5a20d3cSdrh   if( pDb->zTrace ){
499b5a20d3cSdrh     Tcl_Free(pDb->zTrace);
5000d1a643aSdrh   }
50119e2d37fSdrh   if( pDb->zProfile ){
50219e2d37fSdrh     Tcl_Free(pDb->zProfile);
50319e2d37fSdrh   }
504e22a334bSdrh   if( pDb->zAuth ){
505e22a334bSdrh     Tcl_Free(pDb->zAuth);
506e22a334bSdrh   }
50755c45f2eSdanielk1977   if( pDb->zNull ){
50855c45f2eSdanielk1977     Tcl_Free(pDb->zNull);
50955c45f2eSdanielk1977   }
51094eb6a14Sdanielk1977   if( pDb->pUpdateHook ){
51194eb6a14Sdanielk1977     Tcl_DecrRefCount(pDb->pUpdateHook);
51294eb6a14Sdanielk1977   }
51371fd80bfSdanielk1977   if( pDb->pRollbackHook ){
51471fd80bfSdanielk1977     Tcl_DecrRefCount(pDb->pRollbackHook);
51571fd80bfSdanielk1977   }
5165def0843Sdrh   if( pDb->pWalHook ){
5175def0843Sdrh     Tcl_DecrRefCount(pDb->pWalHook);
5188d22a174Sdan   }
51994eb6a14Sdanielk1977   if( pDb->pCollateNeeded ){
52094eb6a14Sdanielk1977     Tcl_DecrRefCount(pDb->pCollateNeeded);
52194eb6a14Sdanielk1977   }
522bec3f402Sdrh   Tcl_Free((char*)pDb);
523bec3f402Sdrh }
524bec3f402Sdrh 
525bec3f402Sdrh /*
526bec3f402Sdrh ** This routine is called when a database file is locked while trying
527bec3f402Sdrh ** to execute SQL.
528bec3f402Sdrh */
5292a764eb0Sdanielk1977 static int DbBusyHandler(void *cd, int nTries){
530bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)cd;
531bec3f402Sdrh   int rc;
532bec3f402Sdrh   char zVal[30];
533bec3f402Sdrh 
5345bb3eb9bSdrh   sqlite3_snprintf(sizeof(zVal), zVal, "%d", nTries);
535d1e4733dSdrh   rc = Tcl_VarEval(pDb->interp, pDb->zBusy, " ", zVal, (char*)0);
536bec3f402Sdrh   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
537bec3f402Sdrh     return 0;
538bec3f402Sdrh   }
539bec3f402Sdrh   return 1;
54075897234Sdrh }
54175897234Sdrh 
54226e4a8b1Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK
54375897234Sdrh /*
544348bb5d6Sdanielk1977 ** This routine is invoked as the 'progress callback' for the database.
545348bb5d6Sdanielk1977 */
546348bb5d6Sdanielk1977 static int DbProgressHandler(void *cd){
547348bb5d6Sdanielk1977   SqliteDb *pDb = (SqliteDb*)cd;
548348bb5d6Sdanielk1977   int rc;
549348bb5d6Sdanielk1977 
550348bb5d6Sdanielk1977   assert( pDb->zProgress );
551348bb5d6Sdanielk1977   rc = Tcl_Eval(pDb->interp, pDb->zProgress);
552348bb5d6Sdanielk1977   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
553348bb5d6Sdanielk1977     return 1;
554348bb5d6Sdanielk1977   }
555348bb5d6Sdanielk1977   return 0;
556348bb5d6Sdanielk1977 }
55726e4a8b1Sdrh #endif
558348bb5d6Sdanielk1977 
559d1167393Sdrh #ifndef SQLITE_OMIT_TRACE
560348bb5d6Sdanielk1977 /*
561b5a20d3cSdrh ** This routine is called by the SQLite trace handler whenever a new
562b5a20d3cSdrh ** block of SQL is executed.  The TCL script in pDb->zTrace is executed.
5630d1a643aSdrh */
564b5a20d3cSdrh static void DbTraceHandler(void *cd, const char *zSql){
5650d1a643aSdrh   SqliteDb *pDb = (SqliteDb*)cd;
566b5a20d3cSdrh   Tcl_DString str;
5670d1a643aSdrh 
568b5a20d3cSdrh   Tcl_DStringInit(&str);
569b5a20d3cSdrh   Tcl_DStringAppend(&str, pDb->zTrace, -1);
570b5a20d3cSdrh   Tcl_DStringAppendElement(&str, zSql);
571b5a20d3cSdrh   Tcl_Eval(pDb->interp, Tcl_DStringValue(&str));
572b5a20d3cSdrh   Tcl_DStringFree(&str);
573b5a20d3cSdrh   Tcl_ResetResult(pDb->interp);
5740d1a643aSdrh }
575d1167393Sdrh #endif
5760d1a643aSdrh 
577d1167393Sdrh #ifndef SQLITE_OMIT_TRACE
5780d1a643aSdrh /*
57919e2d37fSdrh ** This routine is called by the SQLite profile handler after a statement
58019e2d37fSdrh ** SQL has executed.  The TCL script in pDb->zProfile is evaluated.
58119e2d37fSdrh */
58219e2d37fSdrh static void DbProfileHandler(void *cd, const char *zSql, sqlite_uint64 tm){
58319e2d37fSdrh   SqliteDb *pDb = (SqliteDb*)cd;
58419e2d37fSdrh   Tcl_DString str;
58519e2d37fSdrh   char zTm[100];
58619e2d37fSdrh 
58719e2d37fSdrh   sqlite3_snprintf(sizeof(zTm)-1, zTm, "%lld", tm);
58819e2d37fSdrh   Tcl_DStringInit(&str);
58919e2d37fSdrh   Tcl_DStringAppend(&str, pDb->zProfile, -1);
59019e2d37fSdrh   Tcl_DStringAppendElement(&str, zSql);
59119e2d37fSdrh   Tcl_DStringAppendElement(&str, zTm);
59219e2d37fSdrh   Tcl_Eval(pDb->interp, Tcl_DStringValue(&str));
59319e2d37fSdrh   Tcl_DStringFree(&str);
59419e2d37fSdrh   Tcl_ResetResult(pDb->interp);
59519e2d37fSdrh }
596d1167393Sdrh #endif
59719e2d37fSdrh 
59819e2d37fSdrh /*
599aa940eacSdrh ** This routine is called when a transaction is committed.  The
600aa940eacSdrh ** TCL script in pDb->zCommit is executed.  If it returns non-zero or
601aa940eacSdrh ** if it throws an exception, the transaction is rolled back instead
602aa940eacSdrh ** of being committed.
603aa940eacSdrh */
604aa940eacSdrh static int DbCommitHandler(void *cd){
605aa940eacSdrh   SqliteDb *pDb = (SqliteDb*)cd;
606aa940eacSdrh   int rc;
607aa940eacSdrh 
608aa940eacSdrh   rc = Tcl_Eval(pDb->interp, pDb->zCommit);
609aa940eacSdrh   if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){
610aa940eacSdrh     return 1;
611aa940eacSdrh   }
612aa940eacSdrh   return 0;
613aa940eacSdrh }
614aa940eacSdrh 
61571fd80bfSdanielk1977 static void DbRollbackHandler(void *clientData){
61671fd80bfSdanielk1977   SqliteDb *pDb = (SqliteDb*)clientData;
61771fd80bfSdanielk1977   assert(pDb->pRollbackHook);
61871fd80bfSdanielk1977   if( TCL_OK!=Tcl_EvalObjEx(pDb->interp, pDb->pRollbackHook, 0) ){
61971fd80bfSdanielk1977     Tcl_BackgroundError(pDb->interp);
62071fd80bfSdanielk1977   }
62171fd80bfSdanielk1977 }
62271fd80bfSdanielk1977 
6235def0843Sdrh /*
6245def0843Sdrh ** This procedure handles wal_hook callbacks.
6255def0843Sdrh */
6265def0843Sdrh static int DbWalHandler(
6278d22a174Sdan   void *clientData,
6288d22a174Sdan   sqlite3 *db,
6298d22a174Sdan   const char *zDb,
6308d22a174Sdan   int nEntry
6318d22a174Sdan ){
6325def0843Sdrh   int ret = SQLITE_OK;
6338d22a174Sdan   Tcl_Obj *p;
6348d22a174Sdan   SqliteDb *pDb = (SqliteDb*)clientData;
6358d22a174Sdan   Tcl_Interp *interp = pDb->interp;
6365def0843Sdrh   assert(pDb->pWalHook);
6378d22a174Sdan 
6386e45e0c8Sdan   assert( db==pDb->db );
6395def0843Sdrh   p = Tcl_DuplicateObj(pDb->pWalHook);
6408d22a174Sdan   Tcl_IncrRefCount(p);
6418d22a174Sdan   Tcl_ListObjAppendElement(interp, p, Tcl_NewStringObj(zDb, -1));
6428d22a174Sdan   Tcl_ListObjAppendElement(interp, p, Tcl_NewIntObj(nEntry));
6438d22a174Sdan   if( TCL_OK!=Tcl_EvalObjEx(interp, p, 0)
6448d22a174Sdan    || TCL_OK!=Tcl_GetIntFromObj(interp, Tcl_GetObjResult(interp), &ret)
6458d22a174Sdan   ){
6468d22a174Sdan     Tcl_BackgroundError(interp);
6478d22a174Sdan   }
6488d22a174Sdan   Tcl_DecrRefCount(p);
6498d22a174Sdan 
6508d22a174Sdan   return ret;
6518d22a174Sdan }
6528d22a174Sdan 
653bcf4f484Sdrh #if defined(SQLITE_TEST) && defined(SQLITE_ENABLE_UNLOCK_NOTIFY)
654404ca075Sdanielk1977 static void setTestUnlockNotifyVars(Tcl_Interp *interp, int iArg, int nArg){
655404ca075Sdanielk1977   char zBuf[64];
656404ca075Sdanielk1977   sprintf(zBuf, "%d", iArg);
657404ca075Sdanielk1977   Tcl_SetVar(interp, "sqlite_unlock_notify_arg", zBuf, TCL_GLOBAL_ONLY);
658404ca075Sdanielk1977   sprintf(zBuf, "%d", nArg);
659404ca075Sdanielk1977   Tcl_SetVar(interp, "sqlite_unlock_notify_argcount", zBuf, TCL_GLOBAL_ONLY);
660404ca075Sdanielk1977 }
661404ca075Sdanielk1977 #else
662404ca075Sdanielk1977 # define setTestUnlockNotifyVars(x,y,z)
663404ca075Sdanielk1977 #endif
664404ca075Sdanielk1977 
66569910da9Sdrh #ifdef SQLITE_ENABLE_UNLOCK_NOTIFY
666404ca075Sdanielk1977 static void DbUnlockNotify(void **apArg, int nArg){
667404ca075Sdanielk1977   int i;
668404ca075Sdanielk1977   for(i=0; i<nArg; i++){
669404ca075Sdanielk1977     const int flags = (TCL_EVAL_GLOBAL|TCL_EVAL_DIRECT);
670404ca075Sdanielk1977     SqliteDb *pDb = (SqliteDb *)apArg[i];
671404ca075Sdanielk1977     setTestUnlockNotifyVars(pDb->interp, i, nArg);
672404ca075Sdanielk1977     assert( pDb->pUnlockNotify);
673404ca075Sdanielk1977     Tcl_EvalObjEx(pDb->interp, pDb->pUnlockNotify, flags);
674404ca075Sdanielk1977     Tcl_DecrRefCount(pDb->pUnlockNotify);
675404ca075Sdanielk1977     pDb->pUnlockNotify = 0;
676404ca075Sdanielk1977   }
677404ca075Sdanielk1977 }
67869910da9Sdrh #endif
679404ca075Sdanielk1977 
68094eb6a14Sdanielk1977 static void DbUpdateHandler(
68194eb6a14Sdanielk1977   void *p,
68294eb6a14Sdanielk1977   int op,
68394eb6a14Sdanielk1977   const char *zDb,
68494eb6a14Sdanielk1977   const char *zTbl,
68594eb6a14Sdanielk1977   sqlite_int64 rowid
68694eb6a14Sdanielk1977 ){
68794eb6a14Sdanielk1977   SqliteDb *pDb = (SqliteDb *)p;
68894eb6a14Sdanielk1977   Tcl_Obj *pCmd;
68994eb6a14Sdanielk1977 
69094eb6a14Sdanielk1977   assert( pDb->pUpdateHook );
69194eb6a14Sdanielk1977   assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE );
69294eb6a14Sdanielk1977 
69394eb6a14Sdanielk1977   pCmd = Tcl_DuplicateObj(pDb->pUpdateHook);
69494eb6a14Sdanielk1977   Tcl_IncrRefCount(pCmd);
69594eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(
69694eb6a14Sdanielk1977     ( (op==SQLITE_INSERT)?"INSERT":(op==SQLITE_UPDATE)?"UPDATE":"DELETE"), -1));
69794eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zDb, -1));
69894eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zTbl, -1));
69994eb6a14Sdanielk1977   Tcl_ListObjAppendElement(0, pCmd, Tcl_NewWideIntObj(rowid));
70094eb6a14Sdanielk1977   Tcl_EvalObjEx(pDb->interp, pCmd, TCL_EVAL_DIRECT);
701efdde169Sdrh   Tcl_DecrRefCount(pCmd);
70294eb6a14Sdanielk1977 }
70394eb6a14Sdanielk1977 
7047cedc8d4Sdanielk1977 static void tclCollateNeeded(
7057cedc8d4Sdanielk1977   void *pCtx,
7069bb575fdSdrh   sqlite3 *db,
7077cedc8d4Sdanielk1977   int enc,
7087cedc8d4Sdanielk1977   const char *zName
7097cedc8d4Sdanielk1977 ){
7107cedc8d4Sdanielk1977   SqliteDb *pDb = (SqliteDb *)pCtx;
7117cedc8d4Sdanielk1977   Tcl_Obj *pScript = Tcl_DuplicateObj(pDb->pCollateNeeded);
7127cedc8d4Sdanielk1977   Tcl_IncrRefCount(pScript);
7137cedc8d4Sdanielk1977   Tcl_ListObjAppendElement(0, pScript, Tcl_NewStringObj(zName, -1));
7147cedc8d4Sdanielk1977   Tcl_EvalObjEx(pDb->interp, pScript, 0);
7157cedc8d4Sdanielk1977   Tcl_DecrRefCount(pScript);
7167cedc8d4Sdanielk1977 }
7177cedc8d4Sdanielk1977 
718aa940eacSdrh /*
7190202b29eSdanielk1977 ** This routine is called to evaluate an SQL collation function implemented
7200202b29eSdanielk1977 ** using TCL script.
7210202b29eSdanielk1977 */
7220202b29eSdanielk1977 static int tclSqlCollate(
7230202b29eSdanielk1977   void *pCtx,
7240202b29eSdanielk1977   int nA,
7250202b29eSdanielk1977   const void *zA,
7260202b29eSdanielk1977   int nB,
7270202b29eSdanielk1977   const void *zB
7280202b29eSdanielk1977 ){
7290202b29eSdanielk1977   SqlCollate *p = (SqlCollate *)pCtx;
7300202b29eSdanielk1977   Tcl_Obj *pCmd;
7310202b29eSdanielk1977 
7320202b29eSdanielk1977   pCmd = Tcl_NewStringObj(p->zScript, -1);
7330202b29eSdanielk1977   Tcl_IncrRefCount(pCmd);
7340202b29eSdanielk1977   Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zA, nA));
7350202b29eSdanielk1977   Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zB, nB));
736d1e4733dSdrh   Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT);
7370202b29eSdanielk1977   Tcl_DecrRefCount(pCmd);
7380202b29eSdanielk1977   return (atoi(Tcl_GetStringResult(p->interp)));
7390202b29eSdanielk1977 }
7400202b29eSdanielk1977 
7410202b29eSdanielk1977 /*
742cabb0819Sdrh ** This routine is called to evaluate an SQL function implemented
743cabb0819Sdrh ** using TCL script.
744cabb0819Sdrh */
7450ae8b831Sdanielk1977 static void tclSqlFunc(sqlite3_context *context, int argc, sqlite3_value**argv){
7466f8a503dSdanielk1977   SqlFunc *p = sqlite3_user_data(context);
747d1e4733dSdrh   Tcl_Obj *pCmd;
748cabb0819Sdrh   int i;
749cabb0819Sdrh   int rc;
750cabb0819Sdrh 
751d1e4733dSdrh   if( argc==0 ){
752d1e4733dSdrh     /* If there are no arguments to the function, call Tcl_EvalObjEx on the
753d1e4733dSdrh     ** script object directly.  This allows the TCL compiler to generate
754d1e4733dSdrh     ** bytecode for the command on the first invocation and thus make
755d1e4733dSdrh     ** subsequent invocations much faster. */
756d1e4733dSdrh     pCmd = p->pScript;
757d1e4733dSdrh     Tcl_IncrRefCount(pCmd);
758d1e4733dSdrh     rc = Tcl_EvalObjEx(p->interp, pCmd, 0);
759d1e4733dSdrh     Tcl_DecrRefCount(pCmd);
76051ad0ecdSdanielk1977   }else{
761d1e4733dSdrh     /* If there are arguments to the function, make a shallow copy of the
762d1e4733dSdrh     ** script object, lappend the arguments, then evaluate the copy.
763d1e4733dSdrh     **
76460ec914cSpeter.d.reid     ** By "shallow" copy, we mean only the outer list Tcl_Obj is duplicated.
765d1e4733dSdrh     ** The new Tcl_Obj contains pointers to the original list elements.
766d1e4733dSdrh     ** That way, when Tcl_EvalObjv() is run and shimmers the first element
767d1e4733dSdrh     ** of the list to tclCmdNameType, that alternate representation will
768d1e4733dSdrh     ** be preserved and reused on the next invocation.
769d1e4733dSdrh     */
770d1e4733dSdrh     Tcl_Obj **aArg;
771d1e4733dSdrh     int nArg;
772d1e4733dSdrh     if( Tcl_ListObjGetElements(p->interp, p->pScript, &nArg, &aArg) ){
773d1e4733dSdrh       sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
774d1e4733dSdrh       return;
775d1e4733dSdrh     }
776d1e4733dSdrh     pCmd = Tcl_NewListObj(nArg, aArg);
777d1e4733dSdrh     Tcl_IncrRefCount(pCmd);
778d1e4733dSdrh     for(i=0; i<argc; i++){
779d1e4733dSdrh       sqlite3_value *pIn = argv[i];
780d1e4733dSdrh       Tcl_Obj *pVal;
781d1e4733dSdrh 
782d1e4733dSdrh       /* Set pVal to contain the i'th column of this row. */
783d1e4733dSdrh       switch( sqlite3_value_type(pIn) ){
784d1e4733dSdrh         case SQLITE_BLOB: {
785d1e4733dSdrh           int bytes = sqlite3_value_bytes(pIn);
786d1e4733dSdrh           pVal = Tcl_NewByteArrayObj(sqlite3_value_blob(pIn), bytes);
787d1e4733dSdrh           break;
788d1e4733dSdrh         }
789d1e4733dSdrh         case SQLITE_INTEGER: {
790d1e4733dSdrh           sqlite_int64 v = sqlite3_value_int64(pIn);
791d1e4733dSdrh           if( v>=-2147483647 && v<=2147483647 ){
7927fd33929Sdrh             pVal = Tcl_NewIntObj((int)v);
793d1e4733dSdrh           }else{
794d1e4733dSdrh             pVal = Tcl_NewWideIntObj(v);
795d1e4733dSdrh           }
796d1e4733dSdrh           break;
797d1e4733dSdrh         }
798d1e4733dSdrh         case SQLITE_FLOAT: {
799d1e4733dSdrh           double r = sqlite3_value_double(pIn);
800d1e4733dSdrh           pVal = Tcl_NewDoubleObj(r);
801d1e4733dSdrh           break;
802d1e4733dSdrh         }
803d1e4733dSdrh         case SQLITE_NULL: {
804c45e6716Sdrh           pVal = Tcl_NewStringObj(p->pDb->zNull, -1);
805d1e4733dSdrh           break;
806d1e4733dSdrh         }
807d1e4733dSdrh         default: {
808d1e4733dSdrh           int bytes = sqlite3_value_bytes(pIn);
80900fd957bSdanielk1977           pVal = Tcl_NewStringObj((char *)sqlite3_value_text(pIn), bytes);
810d1e4733dSdrh           break;
81151ad0ecdSdanielk1977         }
812cabb0819Sdrh       }
813d1e4733dSdrh       rc = Tcl_ListObjAppendElement(p->interp, pCmd, pVal);
814d1e4733dSdrh       if( rc ){
815d1e4733dSdrh         Tcl_DecrRefCount(pCmd);
816d1e4733dSdrh         sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
817d1e4733dSdrh         return;
818d1e4733dSdrh       }
819d1e4733dSdrh     }
820d1e4733dSdrh     if( !p->useEvalObjv ){
821d1e4733dSdrh       /* Tcl_EvalObjEx() will automatically call Tcl_EvalObjv() if pCmd
822d1e4733dSdrh       ** is a list without a string representation.  To prevent this from
823d1e4733dSdrh       ** happening, make sure pCmd has a valid string representation */
824d1e4733dSdrh       Tcl_GetString(pCmd);
825d1e4733dSdrh     }
826d1e4733dSdrh     rc = Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT);
827d1e4733dSdrh     Tcl_DecrRefCount(pCmd);
828d1e4733dSdrh   }
829562e8d3cSdanielk1977 
830c7f269d5Sdrh   if( rc && rc!=TCL_RETURN ){
8317e18c259Sdanielk1977     sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1);
832cabb0819Sdrh   }else{
833c7f269d5Sdrh     Tcl_Obj *pVar = Tcl_GetObjResult(p->interp);
834c7f269d5Sdrh     int n;
835c7f269d5Sdrh     u8 *data;
8364a4c11aaSdan     const char *zType = (pVar->typePtr ? pVar->typePtr->name : "");
837c7f269d5Sdrh     char c = zType[0];
838df0bddaeSdrh     if( c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0 ){
839d1e4733dSdrh       /* Only return a BLOB type if the Tcl variable is a bytearray and
840df0bddaeSdrh       ** has no string representation. */
841c7f269d5Sdrh       data = Tcl_GetByteArrayFromObj(pVar, &n);
842c7f269d5Sdrh       sqlite3_result_blob(context, data, n, SQLITE_TRANSIENT);
843985e0c63Sdrh     }else if( c=='b' && strcmp(zType,"boolean")==0 ){
844c7f269d5Sdrh       Tcl_GetIntFromObj(0, pVar, &n);
845c7f269d5Sdrh       sqlite3_result_int(context, n);
846c7f269d5Sdrh     }else if( c=='d' && strcmp(zType,"double")==0 ){
847c7f269d5Sdrh       double r;
848c7f269d5Sdrh       Tcl_GetDoubleFromObj(0, pVar, &r);
849c7f269d5Sdrh       sqlite3_result_double(context, r);
850985e0c63Sdrh     }else if( (c=='w' && strcmp(zType,"wideInt")==0) ||
851985e0c63Sdrh           (c=='i' && strcmp(zType,"int")==0) ){
852df0bddaeSdrh       Tcl_WideInt v;
853df0bddaeSdrh       Tcl_GetWideIntFromObj(0, pVar, &v);
854df0bddaeSdrh       sqlite3_result_int64(context, v);
855c7f269d5Sdrh     }else{
85600fd957bSdanielk1977       data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n);
85700fd957bSdanielk1977       sqlite3_result_text(context, (char *)data, n, SQLITE_TRANSIENT);
858c7f269d5Sdrh     }
859cabb0819Sdrh   }
860cabb0819Sdrh }
861895d7472Sdrh 
862e22a334bSdrh #ifndef SQLITE_OMIT_AUTHORIZATION
863e22a334bSdrh /*
864e22a334bSdrh ** This is the authentication function.  It appends the authentication
865e22a334bSdrh ** type code and the two arguments to zCmd[] then invokes the result
866e22a334bSdrh ** on the interpreter.  The reply is examined to determine if the
867e22a334bSdrh ** authentication fails or succeeds.
868e22a334bSdrh */
869e22a334bSdrh static int auth_callback(
870e22a334bSdrh   void *pArg,
871e22a334bSdrh   int code,
872e22a334bSdrh   const char *zArg1,
873e22a334bSdrh   const char *zArg2,
874e22a334bSdrh   const char *zArg3,
875e22a334bSdrh   const char *zArg4
87632c6a48bSdrh #ifdef SQLITE_USER_AUTHENTICATION
87732c6a48bSdrh   ,const char *zArg5
87832c6a48bSdrh #endif
879e22a334bSdrh ){
8806ef5e12eSmistachkin   const char *zCode;
881e22a334bSdrh   Tcl_DString str;
882e22a334bSdrh   int rc;
883e22a334bSdrh   const char *zReply;
884e22a334bSdrh   SqliteDb *pDb = (SqliteDb*)pArg;
8851f1549f8Sdrh   if( pDb->disableAuth ) return SQLITE_OK;
886e22a334bSdrh 
887e22a334bSdrh   switch( code ){
888e22a334bSdrh     case SQLITE_COPY              : zCode="SQLITE_COPY"; break;
889e22a334bSdrh     case SQLITE_CREATE_INDEX      : zCode="SQLITE_CREATE_INDEX"; break;
890e22a334bSdrh     case SQLITE_CREATE_TABLE      : zCode="SQLITE_CREATE_TABLE"; break;
891e22a334bSdrh     case SQLITE_CREATE_TEMP_INDEX : zCode="SQLITE_CREATE_TEMP_INDEX"; break;
892e22a334bSdrh     case SQLITE_CREATE_TEMP_TABLE : zCode="SQLITE_CREATE_TEMP_TABLE"; break;
893e22a334bSdrh     case SQLITE_CREATE_TEMP_TRIGGER: zCode="SQLITE_CREATE_TEMP_TRIGGER"; break;
894e22a334bSdrh     case SQLITE_CREATE_TEMP_VIEW  : zCode="SQLITE_CREATE_TEMP_VIEW"; break;
895e22a334bSdrh     case SQLITE_CREATE_TRIGGER    : zCode="SQLITE_CREATE_TRIGGER"; break;
896e22a334bSdrh     case SQLITE_CREATE_VIEW       : zCode="SQLITE_CREATE_VIEW"; break;
897e22a334bSdrh     case SQLITE_DELETE            : zCode="SQLITE_DELETE"; break;
898e22a334bSdrh     case SQLITE_DROP_INDEX        : zCode="SQLITE_DROP_INDEX"; break;
899e22a334bSdrh     case SQLITE_DROP_TABLE        : zCode="SQLITE_DROP_TABLE"; break;
900e22a334bSdrh     case SQLITE_DROP_TEMP_INDEX   : zCode="SQLITE_DROP_TEMP_INDEX"; break;
901e22a334bSdrh     case SQLITE_DROP_TEMP_TABLE   : zCode="SQLITE_DROP_TEMP_TABLE"; break;
902e22a334bSdrh     case SQLITE_DROP_TEMP_TRIGGER : zCode="SQLITE_DROP_TEMP_TRIGGER"; break;
903e22a334bSdrh     case SQLITE_DROP_TEMP_VIEW    : zCode="SQLITE_DROP_TEMP_VIEW"; break;
904e22a334bSdrh     case SQLITE_DROP_TRIGGER      : zCode="SQLITE_DROP_TRIGGER"; break;
905e22a334bSdrh     case SQLITE_DROP_VIEW         : zCode="SQLITE_DROP_VIEW"; break;
906e22a334bSdrh     case SQLITE_INSERT            : zCode="SQLITE_INSERT"; break;
907e22a334bSdrh     case SQLITE_PRAGMA            : zCode="SQLITE_PRAGMA"; break;
908e22a334bSdrh     case SQLITE_READ              : zCode="SQLITE_READ"; break;
909e22a334bSdrh     case SQLITE_SELECT            : zCode="SQLITE_SELECT"; break;
910e22a334bSdrh     case SQLITE_TRANSACTION       : zCode="SQLITE_TRANSACTION"; break;
911e22a334bSdrh     case SQLITE_UPDATE            : zCode="SQLITE_UPDATE"; break;
91281e293b4Sdrh     case SQLITE_ATTACH            : zCode="SQLITE_ATTACH"; break;
91381e293b4Sdrh     case SQLITE_DETACH            : zCode="SQLITE_DETACH"; break;
9141c8c23ccSdanielk1977     case SQLITE_ALTER_TABLE       : zCode="SQLITE_ALTER_TABLE"; break;
9151d54df88Sdanielk1977     case SQLITE_REINDEX           : zCode="SQLITE_REINDEX"; break;
916e6e04969Sdrh     case SQLITE_ANALYZE           : zCode="SQLITE_ANALYZE"; break;
917f1a381e7Sdanielk1977     case SQLITE_CREATE_VTABLE     : zCode="SQLITE_CREATE_VTABLE"; break;
918f1a381e7Sdanielk1977     case SQLITE_DROP_VTABLE       : zCode="SQLITE_DROP_VTABLE"; break;
9195169bbc6Sdrh     case SQLITE_FUNCTION          : zCode="SQLITE_FUNCTION"; break;
920ab9b703fSdanielk1977     case SQLITE_SAVEPOINT         : zCode="SQLITE_SAVEPOINT"; break;
92165a2aaa6Sdrh     case SQLITE_RECURSIVE         : zCode="SQLITE_RECURSIVE"; break;
922e22a334bSdrh     default                       : zCode="????"; break;
923e22a334bSdrh   }
924e22a334bSdrh   Tcl_DStringInit(&str);
925e22a334bSdrh   Tcl_DStringAppend(&str, pDb->zAuth, -1);
926e22a334bSdrh   Tcl_DStringAppendElement(&str, zCode);
927e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg1 ? zArg1 : "");
928e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg2 ? zArg2 : "");
929e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg3 ? zArg3 : "");
930e22a334bSdrh   Tcl_DStringAppendElement(&str, zArg4 ? zArg4 : "");
93132c6a48bSdrh #ifdef SQLITE_USER_AUTHENTICATION
93232c6a48bSdrh   Tcl_DStringAppendElement(&str, zArg5 ? zArg5 : "");
93332c6a48bSdrh #endif
934e22a334bSdrh   rc = Tcl_GlobalEval(pDb->interp, Tcl_DStringValue(&str));
935e22a334bSdrh   Tcl_DStringFree(&str);
936b07028f7Sdrh   zReply = rc==TCL_OK ? Tcl_GetStringResult(pDb->interp) : "SQLITE_DENY";
937e22a334bSdrh   if( strcmp(zReply,"SQLITE_OK")==0 ){
938e22a334bSdrh     rc = SQLITE_OK;
939e22a334bSdrh   }else if( strcmp(zReply,"SQLITE_DENY")==0 ){
940e22a334bSdrh     rc = SQLITE_DENY;
941e22a334bSdrh   }else if( strcmp(zReply,"SQLITE_IGNORE")==0 ){
942e22a334bSdrh     rc = SQLITE_IGNORE;
943e22a334bSdrh   }else{
944e22a334bSdrh     rc = 999;
945e22a334bSdrh   }
946e22a334bSdrh   return rc;
947e22a334bSdrh }
948e22a334bSdrh #endif /* SQLITE_OMIT_AUTHORIZATION */
949cabb0819Sdrh 
950cabb0819Sdrh /*
9511067fe11Stpoindex ** This routine reads a line of text from FILE in, stores
9521067fe11Stpoindex ** the text in memory obtained from malloc() and returns a pointer
9531067fe11Stpoindex ** to the text.  NULL is returned at end of file, or if malloc()
9541067fe11Stpoindex ** fails.
9551067fe11Stpoindex **
9561067fe11Stpoindex ** The interface is like "readline" but no command-line editing
9571067fe11Stpoindex ** is done.
9581067fe11Stpoindex **
9591067fe11Stpoindex ** copied from shell.c from '.import' command
9601067fe11Stpoindex */
9611067fe11Stpoindex static char *local_getline(char *zPrompt, FILE *in){
9621067fe11Stpoindex   char *zLine;
9631067fe11Stpoindex   int nLine;
9641067fe11Stpoindex   int n;
9651067fe11Stpoindex 
9661067fe11Stpoindex   nLine = 100;
9671067fe11Stpoindex   zLine = malloc( nLine );
9681067fe11Stpoindex   if( zLine==0 ) return 0;
9691067fe11Stpoindex   n = 0;
970b07028f7Sdrh   while( 1 ){
9711067fe11Stpoindex     if( n+100>nLine ){
9721067fe11Stpoindex       nLine = nLine*2 + 100;
9731067fe11Stpoindex       zLine = realloc(zLine, nLine);
9741067fe11Stpoindex       if( zLine==0 ) return 0;
9751067fe11Stpoindex     }
9761067fe11Stpoindex     if( fgets(&zLine[n], nLine - n, in)==0 ){
9771067fe11Stpoindex       if( n==0 ){
9781067fe11Stpoindex         free(zLine);
9791067fe11Stpoindex         return 0;
9801067fe11Stpoindex       }
9811067fe11Stpoindex       zLine[n] = 0;
9821067fe11Stpoindex       break;
9831067fe11Stpoindex     }
9841067fe11Stpoindex     while( zLine[n] ){ n++; }
9851067fe11Stpoindex     if( n>0 && zLine[n-1]=='\n' ){
9861067fe11Stpoindex       n--;
9871067fe11Stpoindex       zLine[n] = 0;
988b07028f7Sdrh       break;
9891067fe11Stpoindex     }
9901067fe11Stpoindex   }
9911067fe11Stpoindex   zLine = realloc( zLine, n+1 );
9921067fe11Stpoindex   return zLine;
9931067fe11Stpoindex }
9941067fe11Stpoindex 
9958e556520Sdanielk1977 
9968e556520Sdanielk1977 /*
9974a4c11aaSdan ** This function is part of the implementation of the command:
9988e556520Sdanielk1977 **
9994a4c11aaSdan **   $db transaction [-deferred|-immediate|-exclusive] SCRIPT
10008e556520Sdanielk1977 **
10014a4c11aaSdan ** It is invoked after evaluating the script SCRIPT to commit or rollback
10024a4c11aaSdan ** the transaction or savepoint opened by the [transaction] command.
10034a4c11aaSdan */
10044a4c11aaSdan static int DbTransPostCmd(
10054a4c11aaSdan   ClientData data[],                   /* data[0] is the Sqlite3Db* for $db */
10064a4c11aaSdan   Tcl_Interp *interp,                  /* Tcl interpreter */
10074a4c11aaSdan   int result                           /* Result of evaluating SCRIPT */
10084a4c11aaSdan ){
10096ef5e12eSmistachkin   static const char *const azEnd[] = {
10104a4c11aaSdan     "RELEASE _tcl_transaction",        /* rc==TCL_ERROR, nTransaction!=0 */
10114a4c11aaSdan     "COMMIT",                          /* rc!=TCL_ERROR, nTransaction==0 */
10124a4c11aaSdan     "ROLLBACK TO _tcl_transaction ; RELEASE _tcl_transaction",
10134a4c11aaSdan     "ROLLBACK"                         /* rc==TCL_ERROR, nTransaction==0 */
10144a4c11aaSdan   };
10154a4c11aaSdan   SqliteDb *pDb = (SqliteDb*)data[0];
10164a4c11aaSdan   int rc = result;
10174a4c11aaSdan   const char *zEnd;
10184a4c11aaSdan 
10194a4c11aaSdan   pDb->nTransaction--;
10204a4c11aaSdan   zEnd = azEnd[(rc==TCL_ERROR)*2 + (pDb->nTransaction==0)];
10214a4c11aaSdan 
10224a4c11aaSdan   pDb->disableAuth++;
10234a4c11aaSdan   if( sqlite3_exec(pDb->db, zEnd, 0, 0, 0) ){
10244a4c11aaSdan       /* This is a tricky scenario to handle. The most likely cause of an
10254a4c11aaSdan       ** error is that the exec() above was an attempt to commit the
10264a4c11aaSdan       ** top-level transaction that returned SQLITE_BUSY. Or, less likely,
102748864df9Smistachkin       ** that an IO-error has occurred. In either case, throw a Tcl exception
10284a4c11aaSdan       ** and try to rollback the transaction.
10294a4c11aaSdan       **
10304a4c11aaSdan       ** But it could also be that the user executed one or more BEGIN,
10314a4c11aaSdan       ** COMMIT, SAVEPOINT, RELEASE or ROLLBACK commands that are confusing
10324a4c11aaSdan       ** this method's logic. Not clear how this would be best handled.
10334a4c11aaSdan       */
10344a4c11aaSdan     if( rc!=TCL_ERROR ){
1035a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
10364a4c11aaSdan       rc = TCL_ERROR;
10374a4c11aaSdan     }
10384a4c11aaSdan     sqlite3_exec(pDb->db, "ROLLBACK", 0, 0, 0);
10394a4c11aaSdan   }
10404a4c11aaSdan   pDb->disableAuth--;
10414a4c11aaSdan 
10424a4c11aaSdan   return rc;
10434a4c11aaSdan }
10444a4c11aaSdan 
10454a4c11aaSdan /*
1046c431fd55Sdan ** Unless SQLITE_TEST is defined, this function is a simple wrapper around
1047c431fd55Sdan ** sqlite3_prepare_v2(). If SQLITE_TEST is defined, then it uses either
1048c431fd55Sdan ** sqlite3_prepare_v2() or legacy interface sqlite3_prepare(), depending
1049c431fd55Sdan ** on whether or not the [db_use_legacy_prepare] command has been used to
1050c431fd55Sdan ** configure the connection.
1051c431fd55Sdan */
1052c431fd55Sdan static int dbPrepare(
1053c431fd55Sdan   SqliteDb *pDb,                  /* Database object */
1054c431fd55Sdan   const char *zSql,               /* SQL to compile */
1055c431fd55Sdan   sqlite3_stmt **ppStmt,          /* OUT: Prepared statement */
1056c431fd55Sdan   const char **pzOut              /* OUT: Pointer to next SQL statement */
1057c431fd55Sdan ){
1058c431fd55Sdan #ifdef SQLITE_TEST
1059c431fd55Sdan   if( pDb->bLegacyPrepare ){
1060c431fd55Sdan     return sqlite3_prepare(pDb->db, zSql, -1, ppStmt, pzOut);
1061c431fd55Sdan   }
1062c431fd55Sdan #endif
1063c431fd55Sdan   return sqlite3_prepare_v2(pDb->db, zSql, -1, ppStmt, pzOut);
1064c431fd55Sdan }
1065c431fd55Sdan 
1066c431fd55Sdan /*
10674a4c11aaSdan ** Search the cache for a prepared-statement object that implements the
10684a4c11aaSdan ** first SQL statement in the buffer pointed to by parameter zIn. If
10694a4c11aaSdan ** no such prepared-statement can be found, allocate and prepare a new
10704a4c11aaSdan ** one. In either case, bind the current values of the relevant Tcl
10714a4c11aaSdan ** variables to any $var, :var or @var variables in the statement. Before
10724a4c11aaSdan ** returning, set *ppPreStmt to point to the prepared-statement object.
10734a4c11aaSdan **
10744a4c11aaSdan ** Output parameter *pzOut is set to point to the next SQL statement in
10754a4c11aaSdan ** buffer zIn, or to the '\0' byte at the end of zIn if there is no
10764a4c11aaSdan ** next statement.
10774a4c11aaSdan **
10784a4c11aaSdan ** If successful, TCL_OK is returned. Otherwise, TCL_ERROR is returned
10794a4c11aaSdan ** and an error message loaded into interpreter pDb->interp.
10804a4c11aaSdan */
10814a4c11aaSdan static int dbPrepareAndBind(
10824a4c11aaSdan   SqliteDb *pDb,                  /* Database object */
10834a4c11aaSdan   char const *zIn,                /* SQL to compile */
10844a4c11aaSdan   char const **pzOut,             /* OUT: Pointer to next SQL statement */
10854a4c11aaSdan   SqlPreparedStmt **ppPreStmt     /* OUT: Object used to cache statement */
10864a4c11aaSdan ){
10874a4c11aaSdan   const char *zSql = zIn;         /* Pointer to first SQL statement in zIn */
10884a4c11aaSdan   sqlite3_stmt *pStmt;            /* Prepared statement object */
10894a4c11aaSdan   SqlPreparedStmt *pPreStmt;      /* Pointer to cached statement */
10904a4c11aaSdan   int nSql;                       /* Length of zSql in bytes */
10914a4c11aaSdan   int nVar;                       /* Number of variables in statement */
10924a4c11aaSdan   int iParm = 0;                  /* Next free entry in apParm */
10930425f189Sdrh   char c;
10944a4c11aaSdan   int i;
10954a4c11aaSdan   Tcl_Interp *interp = pDb->interp;
10964a4c11aaSdan 
10974a4c11aaSdan   *ppPreStmt = 0;
10984a4c11aaSdan 
10994a4c11aaSdan   /* Trim spaces from the start of zSql and calculate the remaining length. */
11000425f189Sdrh   while( (c = zSql[0])==' ' || c=='\t' || c=='\r' || c=='\n' ){ zSql++; }
11014a4c11aaSdan   nSql = strlen30(zSql);
11024a4c11aaSdan 
11034a4c11aaSdan   for(pPreStmt = pDb->stmtList; pPreStmt; pPreStmt=pPreStmt->pNext){
11044a4c11aaSdan     int n = pPreStmt->nSql;
11054a4c11aaSdan     if( nSql>=n
11064a4c11aaSdan         && memcmp(pPreStmt->zSql, zSql, n)==0
11074a4c11aaSdan         && (zSql[n]==0 || zSql[n-1]==';')
11084a4c11aaSdan     ){
11094a4c11aaSdan       pStmt = pPreStmt->pStmt;
11104a4c11aaSdan       *pzOut = &zSql[pPreStmt->nSql];
11114a4c11aaSdan 
11124a4c11aaSdan       /* When a prepared statement is found, unlink it from the
11134a4c11aaSdan       ** cache list.  It will later be added back to the beginning
11144a4c11aaSdan       ** of the cache list in order to implement LRU replacement.
11154a4c11aaSdan       */
11164a4c11aaSdan       if( pPreStmt->pPrev ){
11174a4c11aaSdan         pPreStmt->pPrev->pNext = pPreStmt->pNext;
11184a4c11aaSdan       }else{
11194a4c11aaSdan         pDb->stmtList = pPreStmt->pNext;
11204a4c11aaSdan       }
11214a4c11aaSdan       if( pPreStmt->pNext ){
11224a4c11aaSdan         pPreStmt->pNext->pPrev = pPreStmt->pPrev;
11234a4c11aaSdan       }else{
11244a4c11aaSdan         pDb->stmtLast = pPreStmt->pPrev;
11254a4c11aaSdan       }
11264a4c11aaSdan       pDb->nStmt--;
11274a4c11aaSdan       nVar = sqlite3_bind_parameter_count(pStmt);
11284a4c11aaSdan       break;
11294a4c11aaSdan     }
11304a4c11aaSdan   }
11314a4c11aaSdan 
11324a4c11aaSdan   /* If no prepared statement was found. Compile the SQL text. Also allocate
11334a4c11aaSdan   ** a new SqlPreparedStmt structure.  */
11344a4c11aaSdan   if( pPreStmt==0 ){
11354a4c11aaSdan     int nByte;
11364a4c11aaSdan 
1137c431fd55Sdan     if( SQLITE_OK!=dbPrepare(pDb, zSql, &pStmt, pzOut) ){
1138c45e6716Sdrh       Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
11394a4c11aaSdan       return TCL_ERROR;
11404a4c11aaSdan     }
11414a4c11aaSdan     if( pStmt==0 ){
11424a4c11aaSdan       if( SQLITE_OK!=sqlite3_errcode(pDb->db) ){
11434a4c11aaSdan         /* A compile-time error in the statement. */
1144c45e6716Sdrh         Tcl_SetObjResult(interp, Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
11454a4c11aaSdan         return TCL_ERROR;
11464a4c11aaSdan       }else{
11474a4c11aaSdan         /* The statement was a no-op.  Continue to the next statement
11484a4c11aaSdan         ** in the SQL string.
11494a4c11aaSdan         */
11504a4c11aaSdan         return TCL_OK;
11514a4c11aaSdan       }
11524a4c11aaSdan     }
11534a4c11aaSdan 
11544a4c11aaSdan     assert( pPreStmt==0 );
11554a4c11aaSdan     nVar = sqlite3_bind_parameter_count(pStmt);
11564a4c11aaSdan     nByte = sizeof(SqlPreparedStmt) + nVar*sizeof(Tcl_Obj *);
11574a4c11aaSdan     pPreStmt = (SqlPreparedStmt*)Tcl_Alloc(nByte);
11584a4c11aaSdan     memset(pPreStmt, 0, nByte);
11594a4c11aaSdan 
11604a4c11aaSdan     pPreStmt->pStmt = pStmt;
11617ed243b7Sdrh     pPreStmt->nSql = (int)(*pzOut - zSql);
11624a4c11aaSdan     pPreStmt->zSql = sqlite3_sql(pStmt);
11634a4c11aaSdan     pPreStmt->apParm = (Tcl_Obj **)&pPreStmt[1];
1164c431fd55Sdan #ifdef SQLITE_TEST
1165c431fd55Sdan     if( pPreStmt->zSql==0 ){
1166c431fd55Sdan       char *zCopy = Tcl_Alloc(pPreStmt->nSql + 1);
1167c431fd55Sdan       memcpy(zCopy, zSql, pPreStmt->nSql);
1168c431fd55Sdan       zCopy[pPreStmt->nSql] = '\0';
1169c431fd55Sdan       pPreStmt->zSql = zCopy;
1170c431fd55Sdan     }
1171c431fd55Sdan #endif
11724a4c11aaSdan   }
11734a4c11aaSdan   assert( pPreStmt );
11744a4c11aaSdan   assert( strlen30(pPreStmt->zSql)==pPreStmt->nSql );
11754a4c11aaSdan   assert( 0==memcmp(pPreStmt->zSql, zSql, pPreStmt->nSql) );
11764a4c11aaSdan 
11774a4c11aaSdan   /* Bind values to parameters that begin with $ or : */
11784a4c11aaSdan   for(i=1; i<=nVar; i++){
11794a4c11aaSdan     const char *zVar = sqlite3_bind_parameter_name(pStmt, i);
11804a4c11aaSdan     if( zVar!=0 && (zVar[0]=='$' || zVar[0]==':' || zVar[0]=='@') ){
11814a4c11aaSdan       Tcl_Obj *pVar = Tcl_GetVar2Ex(interp, &zVar[1], 0, 0);
11824a4c11aaSdan       if( pVar ){
11834a4c11aaSdan         int n;
11844a4c11aaSdan         u8 *data;
11854a4c11aaSdan         const char *zType = (pVar->typePtr ? pVar->typePtr->name : "");
11864a4c11aaSdan         char c = zType[0];
11874a4c11aaSdan         if( zVar[0]=='@' ||
11884a4c11aaSdan            (c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0) ){
11894a4c11aaSdan           /* Load a BLOB type if the Tcl variable is a bytearray and
11904a4c11aaSdan           ** it has no string representation or the host
11914a4c11aaSdan           ** parameter name begins with "@". */
11924a4c11aaSdan           data = Tcl_GetByteArrayFromObj(pVar, &n);
11934a4c11aaSdan           sqlite3_bind_blob(pStmt, i, data, n, SQLITE_STATIC);
11944a4c11aaSdan           Tcl_IncrRefCount(pVar);
11954a4c11aaSdan           pPreStmt->apParm[iParm++] = pVar;
11964a4c11aaSdan         }else if( c=='b' && strcmp(zType,"boolean")==0 ){
11974a4c11aaSdan           Tcl_GetIntFromObj(interp, pVar, &n);
11984a4c11aaSdan           sqlite3_bind_int(pStmt, i, n);
11994a4c11aaSdan         }else if( c=='d' && strcmp(zType,"double")==0 ){
12004a4c11aaSdan           double r;
12014a4c11aaSdan           Tcl_GetDoubleFromObj(interp, pVar, &r);
12024a4c11aaSdan           sqlite3_bind_double(pStmt, i, r);
12034a4c11aaSdan         }else if( (c=='w' && strcmp(zType,"wideInt")==0) ||
12044a4c11aaSdan               (c=='i' && strcmp(zType,"int")==0) ){
12054a4c11aaSdan           Tcl_WideInt v;
12064a4c11aaSdan           Tcl_GetWideIntFromObj(interp, pVar, &v);
12074a4c11aaSdan           sqlite3_bind_int64(pStmt, i, v);
12084a4c11aaSdan         }else{
12094a4c11aaSdan           data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n);
12104a4c11aaSdan           sqlite3_bind_text(pStmt, i, (char *)data, n, SQLITE_STATIC);
12114a4c11aaSdan           Tcl_IncrRefCount(pVar);
12124a4c11aaSdan           pPreStmt->apParm[iParm++] = pVar;
12134a4c11aaSdan         }
12144a4c11aaSdan       }else{
12154a4c11aaSdan         sqlite3_bind_null(pStmt, i);
12164a4c11aaSdan       }
12174a4c11aaSdan     }
12184a4c11aaSdan   }
12194a4c11aaSdan   pPreStmt->nParm = iParm;
12204a4c11aaSdan   *ppPreStmt = pPreStmt;
1221937d0deaSdan 
12224a4c11aaSdan   return TCL_OK;
12234a4c11aaSdan }
12244a4c11aaSdan 
12254a4c11aaSdan /*
12264a4c11aaSdan ** Release a statement reference obtained by calling dbPrepareAndBind().
12274a4c11aaSdan ** There should be exactly one call to this function for each call to
12284a4c11aaSdan ** dbPrepareAndBind().
12294a4c11aaSdan **
12304a4c11aaSdan ** If the discard parameter is non-zero, then the statement is deleted
12314a4c11aaSdan ** immediately. Otherwise it is added to the LRU list and may be returned
12324a4c11aaSdan ** by a subsequent call to dbPrepareAndBind().
12334a4c11aaSdan */
12344a4c11aaSdan static void dbReleaseStmt(
12354a4c11aaSdan   SqliteDb *pDb,                  /* Database handle */
12364a4c11aaSdan   SqlPreparedStmt *pPreStmt,      /* Prepared statement handle to release */
12374a4c11aaSdan   int discard                     /* True to delete (not cache) the pPreStmt */
12384a4c11aaSdan ){
12394a4c11aaSdan   int i;
12404a4c11aaSdan 
12414a4c11aaSdan   /* Free the bound string and blob parameters */
12424a4c11aaSdan   for(i=0; i<pPreStmt->nParm; i++){
12434a4c11aaSdan     Tcl_DecrRefCount(pPreStmt->apParm[i]);
12444a4c11aaSdan   }
12454a4c11aaSdan   pPreStmt->nParm = 0;
12464a4c11aaSdan 
12474a4c11aaSdan   if( pDb->maxStmt<=0 || discard ){
12484a4c11aaSdan     /* If the cache is turned off, deallocated the statement */
1249c431fd55Sdan     dbFreeStmt(pPreStmt);
12504a4c11aaSdan   }else{
12514a4c11aaSdan     /* Add the prepared statement to the beginning of the cache list. */
12524a4c11aaSdan     pPreStmt->pNext = pDb->stmtList;
12534a4c11aaSdan     pPreStmt->pPrev = 0;
12544a4c11aaSdan     if( pDb->stmtList ){
12554a4c11aaSdan      pDb->stmtList->pPrev = pPreStmt;
12564a4c11aaSdan     }
12574a4c11aaSdan     pDb->stmtList = pPreStmt;
12584a4c11aaSdan     if( pDb->stmtLast==0 ){
12594a4c11aaSdan       assert( pDb->nStmt==0 );
12604a4c11aaSdan       pDb->stmtLast = pPreStmt;
12614a4c11aaSdan     }else{
12624a4c11aaSdan       assert( pDb->nStmt>0 );
12634a4c11aaSdan     }
12644a4c11aaSdan     pDb->nStmt++;
12654a4c11aaSdan 
12664a4c11aaSdan     /* If we have too many statement in cache, remove the surplus from
12674a4c11aaSdan     ** the end of the cache list.  */
12684a4c11aaSdan     while( pDb->nStmt>pDb->maxStmt ){
1269c431fd55Sdan       SqlPreparedStmt *pLast = pDb->stmtLast;
1270c431fd55Sdan       pDb->stmtLast = pLast->pPrev;
12714a4c11aaSdan       pDb->stmtLast->pNext = 0;
12724a4c11aaSdan       pDb->nStmt--;
1273c431fd55Sdan       dbFreeStmt(pLast);
12744a4c11aaSdan     }
12754a4c11aaSdan   }
12764a4c11aaSdan }
12774a4c11aaSdan 
12784a4c11aaSdan /*
12794a4c11aaSdan ** Structure used with dbEvalXXX() functions:
12804a4c11aaSdan **
12814a4c11aaSdan **   dbEvalInit()
12824a4c11aaSdan **   dbEvalStep()
12834a4c11aaSdan **   dbEvalFinalize()
12844a4c11aaSdan **   dbEvalRowInfo()
12854a4c11aaSdan **   dbEvalColumnValue()
12864a4c11aaSdan */
12874a4c11aaSdan typedef struct DbEvalContext DbEvalContext;
12884a4c11aaSdan struct DbEvalContext {
12894a4c11aaSdan   SqliteDb *pDb;                  /* Database handle */
12904a4c11aaSdan   Tcl_Obj *pSql;                  /* Object holding string zSql */
12914a4c11aaSdan   const char *zSql;               /* Remaining SQL to execute */
12924a4c11aaSdan   SqlPreparedStmt *pPreStmt;      /* Current statement */
12934a4c11aaSdan   int nCol;                       /* Number of columns returned by pStmt */
12944a4c11aaSdan   Tcl_Obj *pArray;                /* Name of array variable */
12954a4c11aaSdan   Tcl_Obj **apColName;            /* Array of column names */
12964a4c11aaSdan };
12974a4c11aaSdan 
12984a4c11aaSdan /*
12994a4c11aaSdan ** Release any cache of column names currently held as part of
13004a4c11aaSdan ** the DbEvalContext structure passed as the first argument.
13014a4c11aaSdan */
13024a4c11aaSdan static void dbReleaseColumnNames(DbEvalContext *p){
13034a4c11aaSdan   if( p->apColName ){
13044a4c11aaSdan     int i;
13054a4c11aaSdan     for(i=0; i<p->nCol; i++){
13064a4c11aaSdan       Tcl_DecrRefCount(p->apColName[i]);
13074a4c11aaSdan     }
13084a4c11aaSdan     Tcl_Free((char *)p->apColName);
13094a4c11aaSdan     p->apColName = 0;
13104a4c11aaSdan   }
13114a4c11aaSdan   p->nCol = 0;
13124a4c11aaSdan }
13134a4c11aaSdan 
13144a4c11aaSdan /*
13154a4c11aaSdan ** Initialize a DbEvalContext structure.
13168e556520Sdanielk1977 **
13178e556520Sdanielk1977 ** If pArray is not NULL, then it contains the name of a Tcl array
13188e556520Sdanielk1977 ** variable. The "*" member of this array is set to a list containing
13194a4c11aaSdan ** the names of the columns returned by the statement as part of each
13204a4c11aaSdan ** call to dbEvalStep(), in order from left to right. e.g. if the names
13214a4c11aaSdan ** of the returned columns are a, b and c, it does the equivalent of the
13224a4c11aaSdan ** tcl command:
13238e556520Sdanielk1977 **
13248e556520Sdanielk1977 **     set ${pArray}(*) {a b c}
13258e556520Sdanielk1977 */
13264a4c11aaSdan static void dbEvalInit(
13274a4c11aaSdan   DbEvalContext *p,               /* Pointer to structure to initialize */
13284a4c11aaSdan   SqliteDb *pDb,                  /* Database handle */
13294a4c11aaSdan   Tcl_Obj *pSql,                  /* Object containing SQL script */
13304a4c11aaSdan   Tcl_Obj *pArray                 /* Name of Tcl array to set (*) element of */
13318e556520Sdanielk1977 ){
13324a4c11aaSdan   memset(p, 0, sizeof(DbEvalContext));
13334a4c11aaSdan   p->pDb = pDb;
13344a4c11aaSdan   p->zSql = Tcl_GetString(pSql);
13354a4c11aaSdan   p->pSql = pSql;
13364a4c11aaSdan   Tcl_IncrRefCount(pSql);
13374a4c11aaSdan   if( pArray ){
13384a4c11aaSdan     p->pArray = pArray;
13394a4c11aaSdan     Tcl_IncrRefCount(pArray);
13404a4c11aaSdan   }
13414a4c11aaSdan }
13428e556520Sdanielk1977 
13434a4c11aaSdan /*
13444a4c11aaSdan ** Obtain information about the row that the DbEvalContext passed as the
13454a4c11aaSdan ** first argument currently points to.
13464a4c11aaSdan */
13474a4c11aaSdan static void dbEvalRowInfo(
13484a4c11aaSdan   DbEvalContext *p,               /* Evaluation context */
13494a4c11aaSdan   int *pnCol,                     /* OUT: Number of column names */
13504a4c11aaSdan   Tcl_Obj ***papColName           /* OUT: Array of column names */
13514a4c11aaSdan ){
13528e556520Sdanielk1977   /* Compute column names */
13534a4c11aaSdan   if( 0==p->apColName ){
13544a4c11aaSdan     sqlite3_stmt *pStmt = p->pPreStmt->pStmt;
13554a4c11aaSdan     int i;                        /* Iterator variable */
13564a4c11aaSdan     int nCol;                     /* Number of columns returned by pStmt */
13574a4c11aaSdan     Tcl_Obj **apColName = 0;      /* Array of column names */
13584a4c11aaSdan 
13594a4c11aaSdan     p->nCol = nCol = sqlite3_column_count(pStmt);
13604a4c11aaSdan     if( nCol>0 && (papColName || p->pArray) ){
13614a4c11aaSdan       apColName = (Tcl_Obj**)Tcl_Alloc( sizeof(Tcl_Obj*)*nCol );
13628e556520Sdanielk1977       for(i=0; i<nCol; i++){
1363c45e6716Sdrh         apColName[i] = Tcl_NewStringObj(sqlite3_column_name(pStmt,i), -1);
13648e556520Sdanielk1977         Tcl_IncrRefCount(apColName[i]);
13658e556520Sdanielk1977       }
13664a4c11aaSdan       p->apColName = apColName;
13674a4c11aaSdan     }
13688e556520Sdanielk1977 
13698e556520Sdanielk1977     /* If results are being stored in an array variable, then create
13708e556520Sdanielk1977     ** the array(*) entry for that array
13718e556520Sdanielk1977     */
13724a4c11aaSdan     if( p->pArray ){
13734a4c11aaSdan       Tcl_Interp *interp = p->pDb->interp;
13748e556520Sdanielk1977       Tcl_Obj *pColList = Tcl_NewObj();
13758e556520Sdanielk1977       Tcl_Obj *pStar = Tcl_NewStringObj("*", -1);
13764a4c11aaSdan 
13778e556520Sdanielk1977       for(i=0; i<nCol; i++){
13788e556520Sdanielk1977         Tcl_ListObjAppendElement(interp, pColList, apColName[i]);
13798e556520Sdanielk1977       }
13808e556520Sdanielk1977       Tcl_IncrRefCount(pStar);
13814a4c11aaSdan       Tcl_ObjSetVar2(interp, p->pArray, pStar, pColList, 0);
13828e556520Sdanielk1977       Tcl_DecrRefCount(pStar);
13838e556520Sdanielk1977     }
13848e556520Sdanielk1977   }
13858e556520Sdanielk1977 
13864a4c11aaSdan   if( papColName ){
13874a4c11aaSdan     *papColName = p->apColName;
13884a4c11aaSdan   }
13894a4c11aaSdan   if( pnCol ){
13904a4c11aaSdan     *pnCol = p->nCol;
13914a4c11aaSdan   }
13924a4c11aaSdan }
13934a4c11aaSdan 
13944a4c11aaSdan /*
13954a4c11aaSdan ** Return one of TCL_OK, TCL_BREAK or TCL_ERROR. If TCL_ERROR is
13964a4c11aaSdan ** returned, then an error message is stored in the interpreter before
13974a4c11aaSdan ** returning.
13984a4c11aaSdan **
13994a4c11aaSdan ** A return value of TCL_OK means there is a row of data available. The
14004a4c11aaSdan ** data may be accessed using dbEvalRowInfo() and dbEvalColumnValue(). This
14014a4c11aaSdan ** is analogous to a return of SQLITE_ROW from sqlite3_step(). If TCL_BREAK
14024a4c11aaSdan ** is returned, then the SQL script has finished executing and there are
14034a4c11aaSdan ** no further rows available. This is similar to SQLITE_DONE.
14044a4c11aaSdan */
14054a4c11aaSdan static int dbEvalStep(DbEvalContext *p){
1406c431fd55Sdan   const char *zPrevSql = 0;       /* Previous value of p->zSql */
1407c431fd55Sdan 
14084a4c11aaSdan   while( p->zSql[0] || p->pPreStmt ){
14094a4c11aaSdan     int rc;
14104a4c11aaSdan     if( p->pPreStmt==0 ){
1411c431fd55Sdan       zPrevSql = (p->zSql==zPrevSql ? 0 : p->zSql);
14124a4c11aaSdan       rc = dbPrepareAndBind(p->pDb, p->zSql, &p->zSql, &p->pPreStmt);
14134a4c11aaSdan       if( rc!=TCL_OK ) return rc;
14144a4c11aaSdan     }else{
14154a4c11aaSdan       int rcs;
14164a4c11aaSdan       SqliteDb *pDb = p->pDb;
14174a4c11aaSdan       SqlPreparedStmt *pPreStmt = p->pPreStmt;
14184a4c11aaSdan       sqlite3_stmt *pStmt = pPreStmt->pStmt;
14194a4c11aaSdan 
14204a4c11aaSdan       rcs = sqlite3_step(pStmt);
14214a4c11aaSdan       if( rcs==SQLITE_ROW ){
14224a4c11aaSdan         return TCL_OK;
14234a4c11aaSdan       }
14244a4c11aaSdan       if( p->pArray ){
14254a4c11aaSdan         dbEvalRowInfo(p, 0, 0);
14264a4c11aaSdan       }
14274a4c11aaSdan       rcs = sqlite3_reset(pStmt);
14284a4c11aaSdan 
14294a4c11aaSdan       pDb->nStep = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_FULLSCAN_STEP,1);
14304a4c11aaSdan       pDb->nSort = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_SORT,1);
14313c379b01Sdrh       pDb->nIndex = sqlite3_stmt_status(pStmt,SQLITE_STMTSTATUS_AUTOINDEX,1);
14324a4c11aaSdan       dbReleaseColumnNames(p);
14334a4c11aaSdan       p->pPreStmt = 0;
14344a4c11aaSdan 
14354a4c11aaSdan       if( rcs!=SQLITE_OK ){
14364a4c11aaSdan         /* If a run-time error occurs, report the error and stop reading
14374a4c11aaSdan         ** the SQL.  */
14384a4c11aaSdan         dbReleaseStmt(pDb, pPreStmt, 1);
1439c431fd55Sdan #if SQLITE_TEST
1440c431fd55Sdan         if( p->pDb->bLegacyPrepare && rcs==SQLITE_SCHEMA && zPrevSql ){
1441c431fd55Sdan           /* If the runtime error was an SQLITE_SCHEMA, and the database
1442c431fd55Sdan           ** handle is configured to use the legacy sqlite3_prepare()
1443c431fd55Sdan           ** interface, retry prepare()/step() on the same SQL statement.
1444c431fd55Sdan           ** This only happens once. If there is a second SQLITE_SCHEMA
1445c431fd55Sdan           ** error, the error will be returned to the caller. */
1446c431fd55Sdan           p->zSql = zPrevSql;
1447c431fd55Sdan           continue;
1448c431fd55Sdan         }
1449c431fd55Sdan #endif
1450c45e6716Sdrh         Tcl_SetObjResult(pDb->interp,
1451c45e6716Sdrh                          Tcl_NewStringObj(sqlite3_errmsg(pDb->db), -1));
14524a4c11aaSdan         return TCL_ERROR;
14534a4c11aaSdan       }else{
14544a4c11aaSdan         dbReleaseStmt(pDb, pPreStmt, 0);
14554a4c11aaSdan       }
14564a4c11aaSdan     }
14574a4c11aaSdan   }
14584a4c11aaSdan 
14594a4c11aaSdan   /* Finished */
14604a4c11aaSdan   return TCL_BREAK;
14614a4c11aaSdan }
14624a4c11aaSdan 
14634a4c11aaSdan /*
14644a4c11aaSdan ** Free all resources currently held by the DbEvalContext structure passed
14654a4c11aaSdan ** as the first argument. There should be exactly one call to this function
14664a4c11aaSdan ** for each call to dbEvalInit().
14674a4c11aaSdan */
14684a4c11aaSdan static void dbEvalFinalize(DbEvalContext *p){
14694a4c11aaSdan   if( p->pPreStmt ){
14704a4c11aaSdan     sqlite3_reset(p->pPreStmt->pStmt);
14714a4c11aaSdan     dbReleaseStmt(p->pDb, p->pPreStmt, 0);
14724a4c11aaSdan     p->pPreStmt = 0;
14734a4c11aaSdan   }
14744a4c11aaSdan   if( p->pArray ){
14754a4c11aaSdan     Tcl_DecrRefCount(p->pArray);
14764a4c11aaSdan     p->pArray = 0;
14774a4c11aaSdan   }
14784a4c11aaSdan   Tcl_DecrRefCount(p->pSql);
14794a4c11aaSdan   dbReleaseColumnNames(p);
14804a4c11aaSdan }
14814a4c11aaSdan 
14824a4c11aaSdan /*
14834a4c11aaSdan ** Return a pointer to a Tcl_Obj structure with ref-count 0 that contains
14844a4c11aaSdan ** the value for the iCol'th column of the row currently pointed to by
14854a4c11aaSdan ** the DbEvalContext structure passed as the first argument.
14864a4c11aaSdan */
14874a4c11aaSdan static Tcl_Obj *dbEvalColumnValue(DbEvalContext *p, int iCol){
14884a4c11aaSdan   sqlite3_stmt *pStmt = p->pPreStmt->pStmt;
14894a4c11aaSdan   switch( sqlite3_column_type(pStmt, iCol) ){
14904a4c11aaSdan     case SQLITE_BLOB: {
14914a4c11aaSdan       int bytes = sqlite3_column_bytes(pStmt, iCol);
14924a4c11aaSdan       const char *zBlob = sqlite3_column_blob(pStmt, iCol);
14934a4c11aaSdan       if( !zBlob ) bytes = 0;
14944a4c11aaSdan       return Tcl_NewByteArrayObj((u8*)zBlob, bytes);
14954a4c11aaSdan     }
14964a4c11aaSdan     case SQLITE_INTEGER: {
14974a4c11aaSdan       sqlite_int64 v = sqlite3_column_int64(pStmt, iCol);
14984a4c11aaSdan       if( v>=-2147483647 && v<=2147483647 ){
14997fd33929Sdrh         return Tcl_NewIntObj((int)v);
15004a4c11aaSdan       }else{
15014a4c11aaSdan         return Tcl_NewWideIntObj(v);
15024a4c11aaSdan       }
15034a4c11aaSdan     }
15044a4c11aaSdan     case SQLITE_FLOAT: {
15054a4c11aaSdan       return Tcl_NewDoubleObj(sqlite3_column_double(pStmt, iCol));
15064a4c11aaSdan     }
15074a4c11aaSdan     case SQLITE_NULL: {
1508c45e6716Sdrh       return Tcl_NewStringObj(p->pDb->zNull, -1);
15094a4c11aaSdan     }
15104a4c11aaSdan   }
15114a4c11aaSdan 
1512325eff58Sdrh   return Tcl_NewStringObj((char*)sqlite3_column_text(pStmt, iCol), -1);
15134a4c11aaSdan }
15144a4c11aaSdan 
15154a4c11aaSdan /*
15164a4c11aaSdan ** If using Tcl version 8.6 or greater, use the NR functions to avoid
15174a4c11aaSdan ** recursive evalution of scripts by the [db eval] and [db trans]
15184a4c11aaSdan ** commands. Even if the headers used while compiling the extension
15194a4c11aaSdan ** are 8.6 or newer, the code still tests the Tcl version at runtime.
15204a4c11aaSdan ** This allows stubs-enabled builds to be used with older Tcl libraries.
15214a4c11aaSdan */
15224a4c11aaSdan #if TCL_MAJOR_VERSION>8 || (TCL_MAJOR_VERSION==8 && TCL_MINOR_VERSION>=6)
1523a2c8a95bSdrh # define SQLITE_TCL_NRE 1
15244a4c11aaSdan static int DbUseNre(void){
15254a4c11aaSdan   int major, minor;
15264a4c11aaSdan   Tcl_GetVersion(&major, &minor, 0, 0);
15274a4c11aaSdan   return( (major==8 && minor>=6) || major>8 );
15284a4c11aaSdan }
15294a4c11aaSdan #else
15304a4c11aaSdan /*
15314a4c11aaSdan ** Compiling using headers earlier than 8.6. In this case NR cannot be
15324a4c11aaSdan ** used, so DbUseNre() to always return zero. Add #defines for the other
15334a4c11aaSdan ** Tcl_NRxxx() functions to prevent them from causing compilation errors,
15344a4c11aaSdan ** even though the only invocations of them are within conditional blocks
15354a4c11aaSdan ** of the form:
15364a4c11aaSdan **
15374a4c11aaSdan **   if( DbUseNre() ) { ... }
15384a4c11aaSdan */
1539a2c8a95bSdrh # define SQLITE_TCL_NRE 0
15404a4c11aaSdan # define DbUseNre() 0
1541a47941feSdrh # define Tcl_NRAddCallback(a,b,c,d,e,f) (void)0
15424a4c11aaSdan # define Tcl_NREvalObj(a,b,c) 0
1543a47941feSdrh # define Tcl_NRCreateCommand(a,b,c,d,e,f) (void)0
15444a4c11aaSdan #endif
15454a4c11aaSdan 
15464a4c11aaSdan /*
15474a4c11aaSdan ** This function is part of the implementation of the command:
15484a4c11aaSdan **
15494a4c11aaSdan **   $db eval SQL ?ARRAYNAME? SCRIPT
15504a4c11aaSdan */
15514a4c11aaSdan static int DbEvalNextCmd(
15524a4c11aaSdan   ClientData data[],                   /* data[0] is the (DbEvalContext*) */
15534a4c11aaSdan   Tcl_Interp *interp,                  /* Tcl interpreter */
15544a4c11aaSdan   int result                           /* Result so far */
15554a4c11aaSdan ){
15564a4c11aaSdan   int rc = result;                     /* Return code */
15574a4c11aaSdan 
15584a4c11aaSdan   /* The first element of the data[] array is a pointer to a DbEvalContext
15594a4c11aaSdan   ** structure allocated using Tcl_Alloc(). The second element of data[]
15604a4c11aaSdan   ** is a pointer to a Tcl_Obj containing the script to run for each row
15614a4c11aaSdan   ** returned by the queries encapsulated in data[0]. */
15624a4c11aaSdan   DbEvalContext *p = (DbEvalContext *)data[0];
15634a4c11aaSdan   Tcl_Obj *pScript = (Tcl_Obj *)data[1];
15644a4c11aaSdan   Tcl_Obj *pArray = p->pArray;
15654a4c11aaSdan 
15664a4c11aaSdan   while( (rc==TCL_OK || rc==TCL_CONTINUE) && TCL_OK==(rc = dbEvalStep(p)) ){
15674a4c11aaSdan     int i;
15684a4c11aaSdan     int nCol;
15694a4c11aaSdan     Tcl_Obj **apColName;
15704a4c11aaSdan     dbEvalRowInfo(p, &nCol, &apColName);
15714a4c11aaSdan     for(i=0; i<nCol; i++){
15724a4c11aaSdan       Tcl_Obj *pVal = dbEvalColumnValue(p, i);
15734a4c11aaSdan       if( pArray==0 ){
15744a4c11aaSdan         Tcl_ObjSetVar2(interp, apColName[i], 0, pVal, 0);
15754a4c11aaSdan       }else{
15764a4c11aaSdan         Tcl_ObjSetVar2(interp, pArray, apColName[i], pVal, 0);
15774a4c11aaSdan       }
15784a4c11aaSdan     }
15794a4c11aaSdan 
15804a4c11aaSdan     /* The required interpreter variables are now populated with the data
15814a4c11aaSdan     ** from the current row. If using NRE, schedule callbacks to evaluate
15824a4c11aaSdan     ** script pScript, then to invoke this function again to fetch the next
15834a4c11aaSdan     ** row (or clean up if there is no next row or the script throws an
15844a4c11aaSdan     ** exception). After scheduling the callbacks, return control to the
15854a4c11aaSdan     ** caller.
15864a4c11aaSdan     **
15874a4c11aaSdan     ** If not using NRE, evaluate pScript directly and continue with the
15884a4c11aaSdan     ** next iteration of this while(...) loop.  */
15894a4c11aaSdan     if( DbUseNre() ){
15904a4c11aaSdan       Tcl_NRAddCallback(interp, DbEvalNextCmd, (void*)p, (void*)pScript, 0, 0);
15914a4c11aaSdan       return Tcl_NREvalObj(interp, pScript, 0);
15924a4c11aaSdan     }else{
15934a4c11aaSdan       rc = Tcl_EvalObjEx(interp, pScript, 0);
15944a4c11aaSdan     }
15954a4c11aaSdan   }
15964a4c11aaSdan 
15974a4c11aaSdan   Tcl_DecrRefCount(pScript);
15984a4c11aaSdan   dbEvalFinalize(p);
15994a4c11aaSdan   Tcl_Free((char *)p);
16004a4c11aaSdan 
16014a4c11aaSdan   if( rc==TCL_OK || rc==TCL_BREAK ){
16024a4c11aaSdan     Tcl_ResetResult(interp);
16034a4c11aaSdan     rc = TCL_OK;
16044a4c11aaSdan   }
16054a4c11aaSdan   return rc;
16068e556520Sdanielk1977 }
16078e556520Sdanielk1977 
16081067fe11Stpoindex /*
160975897234Sdrh ** The "sqlite" command below creates a new Tcl command for each
161075897234Sdrh ** connection it opens to an SQLite database.  This routine is invoked
161175897234Sdrh ** whenever one of those connection-specific commands is executed
161275897234Sdrh ** in Tcl.  For example, if you run Tcl code like this:
161375897234Sdrh **
16149bb575fdSdrh **       sqlite3 db1  "my_database"
161575897234Sdrh **       db1 close
161675897234Sdrh **
161775897234Sdrh ** The first command opens a connection to the "my_database" database
161875897234Sdrh ** and calls that connection "db1".  The second command causes this
161975897234Sdrh ** subroutine to be invoked.
162075897234Sdrh */
16216d31316cSdrh static int DbObjCmd(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){
1622bec3f402Sdrh   SqliteDb *pDb = (SqliteDb*)cd;
16236d31316cSdrh   int choice;
162422fbcb8dSdrh   int rc = TCL_OK;
16250de8c112Sdrh   static const char *DB_strs[] = {
1626dc2c4915Sdrh     "authorizer",         "backup",            "busy",
1627dc2c4915Sdrh     "cache",              "changes",           "close",
1628dc2c4915Sdrh     "collate",            "collation_needed",  "commit_hook",
1629dc2c4915Sdrh     "complete",           "copy",              "enable_load_extension",
1630dc2c4915Sdrh     "errorcode",          "eval",              "exists",
1631dc2c4915Sdrh     "function",           "incrblob",          "interrupt",
1632833bf968Sdrh     "last_insert_rowid",  "nullvalue",         "onecolumn",
1633833bf968Sdrh     "profile",            "progress",          "rekey",
1634833bf968Sdrh     "restore",            "rollback_hook",     "status",
1635833bf968Sdrh     "timeout",            "total_changes",     "trace",
1636833bf968Sdrh     "transaction",        "unlock_notify",     "update_hook",
1637833bf968Sdrh     "version",            "wal_hook",          0
16386d31316cSdrh   };
1639411995dcSdrh   enum DB_enum {
1640dc2c4915Sdrh     DB_AUTHORIZER,        DB_BACKUP,           DB_BUSY,
1641dc2c4915Sdrh     DB_CACHE,             DB_CHANGES,          DB_CLOSE,
1642dc2c4915Sdrh     DB_COLLATE,           DB_COLLATION_NEEDED, DB_COMMIT_HOOK,
1643dc2c4915Sdrh     DB_COMPLETE,          DB_COPY,             DB_ENABLE_LOAD_EXTENSION,
1644dc2c4915Sdrh     DB_ERRORCODE,         DB_EVAL,             DB_EXISTS,
1645dc2c4915Sdrh     DB_FUNCTION,          DB_INCRBLOB,         DB_INTERRUPT,
1646833bf968Sdrh     DB_LAST_INSERT_ROWID, DB_NULLVALUE,        DB_ONECOLUMN,
1647833bf968Sdrh     DB_PROFILE,           DB_PROGRESS,         DB_REKEY,
1648833bf968Sdrh     DB_RESTORE,           DB_ROLLBACK_HOOK,    DB_STATUS,
1649833bf968Sdrh     DB_TIMEOUT,           DB_TOTAL_CHANGES,    DB_TRACE,
1650833bf968Sdrh     DB_TRANSACTION,       DB_UNLOCK_NOTIFY,    DB_UPDATE_HOOK,
1651833bf968Sdrh     DB_VERSION,           DB_WAL_HOOK
16526d31316cSdrh   };
16531067fe11Stpoindex   /* don't leave trailing commas on DB_enum, it confuses the AIX xlc compiler */
16546d31316cSdrh 
16556d31316cSdrh   if( objc<2 ){
16566d31316cSdrh     Tcl_WrongNumArgs(interp, 1, objv, "SUBCOMMAND ...");
165775897234Sdrh     return TCL_ERROR;
165875897234Sdrh   }
1659411995dcSdrh   if( Tcl_GetIndexFromObj(interp, objv[1], DB_strs, "option", 0, &choice) ){
16606d31316cSdrh     return TCL_ERROR;
16616d31316cSdrh   }
16626d31316cSdrh 
1663411995dcSdrh   switch( (enum DB_enum)choice ){
166475897234Sdrh 
1665e22a334bSdrh   /*    $db authorizer ?CALLBACK?
1666e22a334bSdrh   **
1667e22a334bSdrh   ** Invoke the given callback to authorize each SQL operation as it is
1668e22a334bSdrh   ** compiled.  5 arguments are appended to the callback before it is
1669e22a334bSdrh   ** invoked:
1670e22a334bSdrh   **
1671e22a334bSdrh   **   (1) The authorization type (ex: SQLITE_CREATE_TABLE, SQLITE_INSERT, ...)
1672e22a334bSdrh   **   (2) First descriptive name (depends on authorization type)
1673e22a334bSdrh   **   (3) Second descriptive name
1674e22a334bSdrh   **   (4) Name of the database (ex: "main", "temp")
1675e22a334bSdrh   **   (5) Name of trigger that is doing the access
1676e22a334bSdrh   **
1677e22a334bSdrh   ** The callback should return on of the following strings: SQLITE_OK,
1678e22a334bSdrh   ** SQLITE_IGNORE, or SQLITE_DENY.  Any other return value is an error.
1679e22a334bSdrh   **
1680e22a334bSdrh   ** If this method is invoked with no arguments, the current authorization
1681e22a334bSdrh   ** callback string is returned.
1682e22a334bSdrh   */
1683e22a334bSdrh   case DB_AUTHORIZER: {
16841211de37Sdrh #ifdef SQLITE_OMIT_AUTHORIZATION
1685a198f2b5Sdrh     Tcl_AppendResult(interp, "authorization not available in this build",
1686a198f2b5Sdrh                      (char*)0);
16871211de37Sdrh     return TCL_ERROR;
16881211de37Sdrh #else
1689e22a334bSdrh     if( objc>3 ){
1690e22a334bSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
16910f14e2ebSdrh       return TCL_ERROR;
1692e22a334bSdrh     }else if( objc==2 ){
1693b5a20d3cSdrh       if( pDb->zAuth ){
1694a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zAuth, (char*)0);
1695e22a334bSdrh       }
1696e22a334bSdrh     }else{
1697e22a334bSdrh       char *zAuth;
1698e22a334bSdrh       int len;
1699e22a334bSdrh       if( pDb->zAuth ){
1700e22a334bSdrh         Tcl_Free(pDb->zAuth);
1701e22a334bSdrh       }
1702e22a334bSdrh       zAuth = Tcl_GetStringFromObj(objv[2], &len);
1703e22a334bSdrh       if( zAuth && len>0 ){
1704e22a334bSdrh         pDb->zAuth = Tcl_Alloc( len + 1 );
17055bb3eb9bSdrh         memcpy(pDb->zAuth, zAuth, len+1);
1706e22a334bSdrh       }else{
1707e22a334bSdrh         pDb->zAuth = 0;
1708e22a334bSdrh       }
1709e22a334bSdrh       if( pDb->zAuth ){
171032c6a48bSdrh         typedef int (*sqlite3_auth_cb)(
171132c6a48bSdrh            void*,int,const char*,const char*,
171232c6a48bSdrh            const char*,const char*);
1713e22a334bSdrh         pDb->interp = interp;
171432c6a48bSdrh         sqlite3_set_authorizer(pDb->db,(sqlite3_auth_cb)auth_callback,pDb);
1715e22a334bSdrh       }else{
17166f8a503dSdanielk1977         sqlite3_set_authorizer(pDb->db, 0, 0);
1717e22a334bSdrh       }
1718e22a334bSdrh     }
17191211de37Sdrh #endif
1720e22a334bSdrh     break;
1721e22a334bSdrh   }
1722e22a334bSdrh 
1723dc2c4915Sdrh   /*    $db backup ?DATABASE? FILENAME
1724dc2c4915Sdrh   **
1725dc2c4915Sdrh   ** Open or create a database file named FILENAME.  Transfer the
1726dc2c4915Sdrh   ** content of local database DATABASE (default: "main") into the
1727dc2c4915Sdrh   ** FILENAME database.
1728dc2c4915Sdrh   */
1729dc2c4915Sdrh   case DB_BACKUP: {
1730dc2c4915Sdrh     const char *zDestFile;
1731dc2c4915Sdrh     const char *zSrcDb;
1732dc2c4915Sdrh     sqlite3 *pDest;
1733dc2c4915Sdrh     sqlite3_backup *pBackup;
1734dc2c4915Sdrh 
1735dc2c4915Sdrh     if( objc==3 ){
1736dc2c4915Sdrh       zSrcDb = "main";
1737dc2c4915Sdrh       zDestFile = Tcl_GetString(objv[2]);
1738dc2c4915Sdrh     }else if( objc==4 ){
1739dc2c4915Sdrh       zSrcDb = Tcl_GetString(objv[2]);
1740dc2c4915Sdrh       zDestFile = Tcl_GetString(objv[3]);
1741dc2c4915Sdrh     }else{
1742dc2c4915Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "?DATABASE? FILENAME");
1743dc2c4915Sdrh       return TCL_ERROR;
1744dc2c4915Sdrh     }
1745dc2c4915Sdrh     rc = sqlite3_open(zDestFile, &pDest);
1746dc2c4915Sdrh     if( rc!=SQLITE_OK ){
1747dc2c4915Sdrh       Tcl_AppendResult(interp, "cannot open target database: ",
1748dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1749dc2c4915Sdrh       sqlite3_close(pDest);
1750dc2c4915Sdrh       return TCL_ERROR;
1751dc2c4915Sdrh     }
1752dc2c4915Sdrh     pBackup = sqlite3_backup_init(pDest, "main", pDb->db, zSrcDb);
1753dc2c4915Sdrh     if( pBackup==0 ){
1754dc2c4915Sdrh       Tcl_AppendResult(interp, "backup failed: ",
1755dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1756dc2c4915Sdrh       sqlite3_close(pDest);
1757dc2c4915Sdrh       return TCL_ERROR;
1758dc2c4915Sdrh     }
1759dc2c4915Sdrh     while(  (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK ){}
1760dc2c4915Sdrh     sqlite3_backup_finish(pBackup);
1761dc2c4915Sdrh     if( rc==SQLITE_DONE ){
1762dc2c4915Sdrh       rc = TCL_OK;
1763dc2c4915Sdrh     }else{
1764dc2c4915Sdrh       Tcl_AppendResult(interp, "backup failed: ",
1765dc2c4915Sdrh            sqlite3_errmsg(pDest), (char*)0);
1766dc2c4915Sdrh       rc = TCL_ERROR;
1767dc2c4915Sdrh     }
1768dc2c4915Sdrh     sqlite3_close(pDest);
1769dc2c4915Sdrh     break;
1770dc2c4915Sdrh   }
1771dc2c4915Sdrh 
1772bec3f402Sdrh   /*    $db busy ?CALLBACK?
1773bec3f402Sdrh   **
1774bec3f402Sdrh   ** Invoke the given callback if an SQL statement attempts to open
1775bec3f402Sdrh   ** a locked database file.
1776bec3f402Sdrh   */
17776d31316cSdrh   case DB_BUSY: {
17786d31316cSdrh     if( objc>3 ){
17796d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "CALLBACK");
1780bec3f402Sdrh       return TCL_ERROR;
17816d31316cSdrh     }else if( objc==2 ){
1782bec3f402Sdrh       if( pDb->zBusy ){
1783a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zBusy, (char*)0);
1784bec3f402Sdrh       }
1785bec3f402Sdrh     }else{
17866d31316cSdrh       char *zBusy;
17876d31316cSdrh       int len;
1788bec3f402Sdrh       if( pDb->zBusy ){
1789bec3f402Sdrh         Tcl_Free(pDb->zBusy);
17906d31316cSdrh       }
17916d31316cSdrh       zBusy = Tcl_GetStringFromObj(objv[2], &len);
17926d31316cSdrh       if( zBusy && len>0 ){
17936d31316cSdrh         pDb->zBusy = Tcl_Alloc( len + 1 );
17945bb3eb9bSdrh         memcpy(pDb->zBusy, zBusy, len+1);
17956d31316cSdrh       }else{
1796bec3f402Sdrh         pDb->zBusy = 0;
1797bec3f402Sdrh       }
1798bec3f402Sdrh       if( pDb->zBusy ){
1799bec3f402Sdrh         pDb->interp = interp;
18006f8a503dSdanielk1977         sqlite3_busy_handler(pDb->db, DbBusyHandler, pDb);
18016d31316cSdrh       }else{
18026f8a503dSdanielk1977         sqlite3_busy_handler(pDb->db, 0, 0);
1803bec3f402Sdrh       }
1804bec3f402Sdrh     }
18056d31316cSdrh     break;
18066d31316cSdrh   }
1807bec3f402Sdrh 
1808fb7e7651Sdrh   /*     $db cache flush
1809fb7e7651Sdrh   **     $db cache size n
1810fb7e7651Sdrh   **
1811fb7e7651Sdrh   ** Flush the prepared statement cache, or set the maximum number of
1812fb7e7651Sdrh   ** cached statements.
1813fb7e7651Sdrh   */
1814fb7e7651Sdrh   case DB_CACHE: {
1815fb7e7651Sdrh     char *subCmd;
1816fb7e7651Sdrh     int n;
1817fb7e7651Sdrh 
1818fb7e7651Sdrh     if( objc<=2 ){
1819fb7e7651Sdrh       Tcl_WrongNumArgs(interp, 1, objv, "cache option ?arg?");
1820fb7e7651Sdrh       return TCL_ERROR;
1821fb7e7651Sdrh     }
1822fb7e7651Sdrh     subCmd = Tcl_GetStringFromObj( objv[2], 0 );
1823fb7e7651Sdrh     if( *subCmd=='f' && strcmp(subCmd,"flush")==0 ){
1824fb7e7651Sdrh       if( objc!=3 ){
1825fb7e7651Sdrh         Tcl_WrongNumArgs(interp, 2, objv, "flush");
1826fb7e7651Sdrh         return TCL_ERROR;
1827fb7e7651Sdrh       }else{
1828fb7e7651Sdrh         flushStmtCache( pDb );
1829fb7e7651Sdrh       }
1830fb7e7651Sdrh     }else if( *subCmd=='s' && strcmp(subCmd,"size")==0 ){
1831fb7e7651Sdrh       if( objc!=4 ){
1832fb7e7651Sdrh         Tcl_WrongNumArgs(interp, 2, objv, "size n");
1833fb7e7651Sdrh         return TCL_ERROR;
1834fb7e7651Sdrh       }else{
1835fb7e7651Sdrh         if( TCL_ERROR==Tcl_GetIntFromObj(interp, objv[3], &n) ){
1836fb7e7651Sdrh           Tcl_AppendResult( interp, "cannot convert \"",
1837a198f2b5Sdrh                Tcl_GetStringFromObj(objv[3],0), "\" to integer", (char*)0);
1838fb7e7651Sdrh           return TCL_ERROR;
1839fb7e7651Sdrh         }else{
1840fb7e7651Sdrh           if( n<0 ){
1841fb7e7651Sdrh             flushStmtCache( pDb );
1842fb7e7651Sdrh             n = 0;
1843fb7e7651Sdrh           }else if( n>MAX_PREPARED_STMTS ){
1844fb7e7651Sdrh             n = MAX_PREPARED_STMTS;
1845fb7e7651Sdrh           }
1846fb7e7651Sdrh           pDb->maxStmt = n;
1847fb7e7651Sdrh         }
1848fb7e7651Sdrh       }
1849fb7e7651Sdrh     }else{
1850fb7e7651Sdrh       Tcl_AppendResult( interp, "bad option \"",
1851a198f2b5Sdrh           Tcl_GetStringFromObj(objv[2],0), "\": must be flush or size",
1852a198f2b5Sdrh           (char*)0);
1853fb7e7651Sdrh       return TCL_ERROR;
1854fb7e7651Sdrh     }
1855fb7e7651Sdrh     break;
1856fb7e7651Sdrh   }
1857fb7e7651Sdrh 
1858b28af71aSdanielk1977   /*     $db changes
1859c8d30ac1Sdrh   **
1860c8d30ac1Sdrh   ** Return the number of rows that were modified, inserted, or deleted by
1861b28af71aSdanielk1977   ** the most recent INSERT, UPDATE or DELETE statement, not including
1862b28af71aSdanielk1977   ** any changes made by trigger programs.
1863c8d30ac1Sdrh   */
1864c8d30ac1Sdrh   case DB_CHANGES: {
1865c8d30ac1Sdrh     Tcl_Obj *pResult;
1866c8d30ac1Sdrh     if( objc!=2 ){
1867c8d30ac1Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
1868c8d30ac1Sdrh       return TCL_ERROR;
1869c8d30ac1Sdrh     }
1870c8d30ac1Sdrh     pResult = Tcl_GetObjResult(interp);
1871b28af71aSdanielk1977     Tcl_SetIntObj(pResult, sqlite3_changes(pDb->db));
1872f146a776Srdc     break;
1873f146a776Srdc   }
1874f146a776Srdc 
187575897234Sdrh   /*    $db close
187675897234Sdrh   **
187775897234Sdrh   ** Shutdown the database
187875897234Sdrh   */
18796d31316cSdrh   case DB_CLOSE: {
18806d31316cSdrh     Tcl_DeleteCommand(interp, Tcl_GetStringFromObj(objv[0], 0));
18816d31316cSdrh     break;
18826d31316cSdrh   }
188375897234Sdrh 
18840f14e2ebSdrh   /*
18850f14e2ebSdrh   **     $db collate NAME SCRIPT
18860f14e2ebSdrh   **
18870f14e2ebSdrh   ** Create a new SQL collation function called NAME.  Whenever
18880f14e2ebSdrh   ** that function is called, invoke SCRIPT to evaluate the function.
18890f14e2ebSdrh   */
18900f14e2ebSdrh   case DB_COLLATE: {
18910f14e2ebSdrh     SqlCollate *pCollate;
18920f14e2ebSdrh     char *zName;
18930f14e2ebSdrh     char *zScript;
18940f14e2ebSdrh     int nScript;
18950f14e2ebSdrh     if( objc!=4 ){
18960f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "NAME SCRIPT");
18970f14e2ebSdrh       return TCL_ERROR;
18980f14e2ebSdrh     }
18990f14e2ebSdrh     zName = Tcl_GetStringFromObj(objv[2], 0);
19000f14e2ebSdrh     zScript = Tcl_GetStringFromObj(objv[3], &nScript);
19010f14e2ebSdrh     pCollate = (SqlCollate*)Tcl_Alloc( sizeof(*pCollate) + nScript + 1 );
19020f14e2ebSdrh     if( pCollate==0 ) return TCL_ERROR;
19030f14e2ebSdrh     pCollate->interp = interp;
19040f14e2ebSdrh     pCollate->pNext = pDb->pCollate;
19050f14e2ebSdrh     pCollate->zScript = (char*)&pCollate[1];
19060f14e2ebSdrh     pDb->pCollate = pCollate;
19075bb3eb9bSdrh     memcpy(pCollate->zScript, zScript, nScript+1);
19080f14e2ebSdrh     if( sqlite3_create_collation(pDb->db, zName, SQLITE_UTF8,
19090f14e2ebSdrh         pCollate, tclSqlCollate) ){
19109636c4e1Sdanielk1977       Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
19110f14e2ebSdrh       return TCL_ERROR;
19120f14e2ebSdrh     }
19130f14e2ebSdrh     break;
19140f14e2ebSdrh   }
19150f14e2ebSdrh 
19160f14e2ebSdrh   /*
19170f14e2ebSdrh   **     $db collation_needed SCRIPT
19180f14e2ebSdrh   **
19190f14e2ebSdrh   ** Create a new SQL collation function called NAME.  Whenever
19200f14e2ebSdrh   ** that function is called, invoke SCRIPT to evaluate the function.
19210f14e2ebSdrh   */
19220f14e2ebSdrh   case DB_COLLATION_NEEDED: {
19230f14e2ebSdrh     if( objc!=3 ){
19240f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "SCRIPT");
19250f14e2ebSdrh       return TCL_ERROR;
19260f14e2ebSdrh     }
19270f14e2ebSdrh     if( pDb->pCollateNeeded ){
19280f14e2ebSdrh       Tcl_DecrRefCount(pDb->pCollateNeeded);
19290f14e2ebSdrh     }
19300f14e2ebSdrh     pDb->pCollateNeeded = Tcl_DuplicateObj(objv[2]);
19310f14e2ebSdrh     Tcl_IncrRefCount(pDb->pCollateNeeded);
19320f14e2ebSdrh     sqlite3_collation_needed(pDb->db, pDb, tclCollateNeeded);
19330f14e2ebSdrh     break;
19340f14e2ebSdrh   }
19350f14e2ebSdrh 
193619e2d37fSdrh   /*    $db commit_hook ?CALLBACK?
193719e2d37fSdrh   **
193819e2d37fSdrh   ** Invoke the given callback just before committing every SQL transaction.
193919e2d37fSdrh   ** If the callback throws an exception or returns non-zero, then the
194019e2d37fSdrh   ** transaction is aborted.  If CALLBACK is an empty string, the callback
194119e2d37fSdrh   ** is disabled.
194219e2d37fSdrh   */
194319e2d37fSdrh   case DB_COMMIT_HOOK: {
194419e2d37fSdrh     if( objc>3 ){
194519e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
194619e2d37fSdrh       return TCL_ERROR;
194719e2d37fSdrh     }else if( objc==2 ){
194819e2d37fSdrh       if( pDb->zCommit ){
1949a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zCommit, (char*)0);
195019e2d37fSdrh       }
195119e2d37fSdrh     }else{
19526ef5e12eSmistachkin       const char *zCommit;
195319e2d37fSdrh       int len;
195419e2d37fSdrh       if( pDb->zCommit ){
195519e2d37fSdrh         Tcl_Free(pDb->zCommit);
195619e2d37fSdrh       }
195719e2d37fSdrh       zCommit = Tcl_GetStringFromObj(objv[2], &len);
195819e2d37fSdrh       if( zCommit && len>0 ){
195919e2d37fSdrh         pDb->zCommit = Tcl_Alloc( len + 1 );
19605bb3eb9bSdrh         memcpy(pDb->zCommit, zCommit, len+1);
196119e2d37fSdrh       }else{
196219e2d37fSdrh         pDb->zCommit = 0;
196319e2d37fSdrh       }
196419e2d37fSdrh       if( pDb->zCommit ){
196519e2d37fSdrh         pDb->interp = interp;
196619e2d37fSdrh         sqlite3_commit_hook(pDb->db, DbCommitHandler, pDb);
196719e2d37fSdrh       }else{
196819e2d37fSdrh         sqlite3_commit_hook(pDb->db, 0, 0);
196919e2d37fSdrh       }
197019e2d37fSdrh     }
197119e2d37fSdrh     break;
197219e2d37fSdrh   }
197319e2d37fSdrh 
197475897234Sdrh   /*    $db complete SQL
197575897234Sdrh   **
197675897234Sdrh   ** Return TRUE if SQL is a complete SQL statement.  Return FALSE if
197775897234Sdrh   ** additional lines of input are needed.  This is similar to the
197875897234Sdrh   ** built-in "info complete" command of Tcl.
197975897234Sdrh   */
19806d31316cSdrh   case DB_COMPLETE: {
1981ccae6026Sdrh #ifndef SQLITE_OMIT_COMPLETE
19826d31316cSdrh     Tcl_Obj *pResult;
19836d31316cSdrh     int isComplete;
19846d31316cSdrh     if( objc!=3 ){
19856d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "SQL");
198675897234Sdrh       return TCL_ERROR;
198775897234Sdrh     }
19886f8a503dSdanielk1977     isComplete = sqlite3_complete( Tcl_GetStringFromObj(objv[2], 0) );
19896d31316cSdrh     pResult = Tcl_GetObjResult(interp);
19906d31316cSdrh     Tcl_SetBooleanObj(pResult, isComplete);
1991ccae6026Sdrh #endif
19926d31316cSdrh     break;
19936d31316cSdrh   }
199475897234Sdrh 
199519e2d37fSdrh   /*    $db copy conflict-algorithm table filename ?SEPARATOR? ?NULLINDICATOR?
199619e2d37fSdrh   **
199719e2d37fSdrh   ** Copy data into table from filename, optionally using SEPARATOR
199819e2d37fSdrh   ** as column separators.  If a column contains a null string, or the
199919e2d37fSdrh   ** value of NULLINDICATOR, a NULL is inserted for the column.
200019e2d37fSdrh   ** conflict-algorithm is one of the sqlite conflict algorithms:
200119e2d37fSdrh   **    rollback, abort, fail, ignore, replace
200219e2d37fSdrh   ** On success, return the number of lines processed, not necessarily same
200319e2d37fSdrh   ** as 'db changes' due to conflict-algorithm selected.
200419e2d37fSdrh   **
200519e2d37fSdrh   ** This code is basically an implementation/enhancement of
200619e2d37fSdrh   ** the sqlite3 shell.c ".import" command.
200719e2d37fSdrh   **
200819e2d37fSdrh   ** This command usage is equivalent to the sqlite2.x COPY statement,
200919e2d37fSdrh   ** which imports file data into a table using the PostgreSQL COPY file format:
201019e2d37fSdrh   **   $db copy $conflit_algo $table_name $filename \t \\N
201119e2d37fSdrh   */
201219e2d37fSdrh   case DB_COPY: {
201319e2d37fSdrh     char *zTable;               /* Insert data into this table */
201419e2d37fSdrh     char *zFile;                /* The file from which to extract data */
201519e2d37fSdrh     char *zConflict;            /* The conflict algorithm to use */
201619e2d37fSdrh     sqlite3_stmt *pStmt;        /* A statement */
201719e2d37fSdrh     int nCol;                   /* Number of columns in the table */
201819e2d37fSdrh     int nByte;                  /* Number of bytes in an SQL string */
201919e2d37fSdrh     int i, j;                   /* Loop counters */
202019e2d37fSdrh     int nSep;                   /* Number of bytes in zSep[] */
202119e2d37fSdrh     int nNull;                  /* Number of bytes in zNull[] */
202219e2d37fSdrh     char *zSql;                 /* An SQL statement */
202319e2d37fSdrh     char *zLine;                /* A single line of input from the file */
202419e2d37fSdrh     char **azCol;               /* zLine[] broken up into columns */
20256ef5e12eSmistachkin     const char *zCommit;        /* How to commit changes */
202619e2d37fSdrh     FILE *in;                   /* The input file */
202719e2d37fSdrh     int lineno = 0;             /* Line number of input file */
202819e2d37fSdrh     char zLineNum[80];          /* Line number print buffer */
202919e2d37fSdrh     Tcl_Obj *pResult;           /* interp result */
203019e2d37fSdrh 
20316ef5e12eSmistachkin     const char *zSep;
20326ef5e12eSmistachkin     const char *zNull;
203319e2d37fSdrh     if( objc<5 || objc>7 ){
203419e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv,
203519e2d37fSdrh          "CONFLICT-ALGORITHM TABLE FILENAME ?SEPARATOR? ?NULLINDICATOR?");
203619e2d37fSdrh       return TCL_ERROR;
203719e2d37fSdrh     }
203819e2d37fSdrh     if( objc>=6 ){
203919e2d37fSdrh       zSep = Tcl_GetStringFromObj(objv[5], 0);
204019e2d37fSdrh     }else{
204119e2d37fSdrh       zSep = "\t";
204219e2d37fSdrh     }
204319e2d37fSdrh     if( objc>=7 ){
204419e2d37fSdrh       zNull = Tcl_GetStringFromObj(objv[6], 0);
204519e2d37fSdrh     }else{
204619e2d37fSdrh       zNull = "";
204719e2d37fSdrh     }
204819e2d37fSdrh     zConflict = Tcl_GetStringFromObj(objv[2], 0);
204919e2d37fSdrh     zTable = Tcl_GetStringFromObj(objv[3], 0);
205019e2d37fSdrh     zFile = Tcl_GetStringFromObj(objv[4], 0);
20514f21c4afSdrh     nSep = strlen30(zSep);
20524f21c4afSdrh     nNull = strlen30(zNull);
205319e2d37fSdrh     if( nSep==0 ){
2054a198f2b5Sdrh       Tcl_AppendResult(interp,"Error: non-null separator required for copy",
2055a198f2b5Sdrh                        (char*)0);
205619e2d37fSdrh       return TCL_ERROR;
205719e2d37fSdrh     }
20583e59c012Sdrh     if(strcmp(zConflict, "rollback") != 0 &&
20593e59c012Sdrh        strcmp(zConflict, "abort"   ) != 0 &&
20603e59c012Sdrh        strcmp(zConflict, "fail"    ) != 0 &&
20613e59c012Sdrh        strcmp(zConflict, "ignore"  ) != 0 &&
20623e59c012Sdrh        strcmp(zConflict, "replace" ) != 0 ) {
206319e2d37fSdrh       Tcl_AppendResult(interp, "Error: \"", zConflict,
206419e2d37fSdrh             "\", conflict-algorithm must be one of: rollback, "
2065a198f2b5Sdrh             "abort, fail, ignore, or replace", (char*)0);
206619e2d37fSdrh       return TCL_ERROR;
206719e2d37fSdrh     }
206819e2d37fSdrh     zSql = sqlite3_mprintf("SELECT * FROM '%q'", zTable);
206919e2d37fSdrh     if( zSql==0 ){
2070a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: no such table: ", zTable, (char*)0);
207119e2d37fSdrh       return TCL_ERROR;
207219e2d37fSdrh     }
20734f21c4afSdrh     nByte = strlen30(zSql);
20743e701a18Sdrh     rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0);
207519e2d37fSdrh     sqlite3_free(zSql);
207619e2d37fSdrh     if( rc ){
2077a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), (char*)0);
207819e2d37fSdrh       nCol = 0;
207919e2d37fSdrh     }else{
208019e2d37fSdrh       nCol = sqlite3_column_count(pStmt);
208119e2d37fSdrh     }
208219e2d37fSdrh     sqlite3_finalize(pStmt);
208319e2d37fSdrh     if( nCol==0 ) {
208419e2d37fSdrh       return TCL_ERROR;
208519e2d37fSdrh     }
208619e2d37fSdrh     zSql = malloc( nByte + 50 + nCol*2 );
208719e2d37fSdrh     if( zSql==0 ) {
2088a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: can't malloc()", (char*)0);
208919e2d37fSdrh       return TCL_ERROR;
209019e2d37fSdrh     }
209119e2d37fSdrh     sqlite3_snprintf(nByte+50, zSql, "INSERT OR %q INTO '%q' VALUES(?",
209219e2d37fSdrh          zConflict, zTable);
20934f21c4afSdrh     j = strlen30(zSql);
209419e2d37fSdrh     for(i=1; i<nCol; i++){
209519e2d37fSdrh       zSql[j++] = ',';
209619e2d37fSdrh       zSql[j++] = '?';
209719e2d37fSdrh     }
209819e2d37fSdrh     zSql[j++] = ')';
209919e2d37fSdrh     zSql[j] = 0;
21003e701a18Sdrh     rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0);
210119e2d37fSdrh     free(zSql);
210219e2d37fSdrh     if( rc ){
2103a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), (char*)0);
210419e2d37fSdrh       sqlite3_finalize(pStmt);
210519e2d37fSdrh       return TCL_ERROR;
210619e2d37fSdrh     }
210719e2d37fSdrh     in = fopen(zFile, "rb");
210819e2d37fSdrh     if( in==0 ){
210919e2d37fSdrh       Tcl_AppendResult(interp, "Error: cannot open file: ", zFile, NULL);
211019e2d37fSdrh       sqlite3_finalize(pStmt);
211119e2d37fSdrh       return TCL_ERROR;
211219e2d37fSdrh     }
211319e2d37fSdrh     azCol = malloc( sizeof(azCol[0])*(nCol+1) );
211419e2d37fSdrh     if( azCol==0 ) {
2115a198f2b5Sdrh       Tcl_AppendResult(interp, "Error: can't malloc()", (char*)0);
211643617e9aSdrh       fclose(in);
211719e2d37fSdrh       return TCL_ERROR;
211819e2d37fSdrh     }
21193752785fSdrh     (void)sqlite3_exec(pDb->db, "BEGIN", 0, 0, 0);
212019e2d37fSdrh     zCommit = "COMMIT";
212119e2d37fSdrh     while( (zLine = local_getline(0, in))!=0 ){
212219e2d37fSdrh       char *z;
212319e2d37fSdrh       lineno++;
212419e2d37fSdrh       azCol[0] = zLine;
212519e2d37fSdrh       for(i=0, z=zLine; *z; z++){
212619e2d37fSdrh         if( *z==zSep[0] && strncmp(z, zSep, nSep)==0 ){
212719e2d37fSdrh           *z = 0;
212819e2d37fSdrh           i++;
212919e2d37fSdrh           if( i<nCol ){
213019e2d37fSdrh             azCol[i] = &z[nSep];
213119e2d37fSdrh             z += nSep-1;
213219e2d37fSdrh           }
213319e2d37fSdrh         }
213419e2d37fSdrh       }
213519e2d37fSdrh       if( i+1!=nCol ){
213619e2d37fSdrh         char *zErr;
21374f21c4afSdrh         int nErr = strlen30(zFile) + 200;
21385bb3eb9bSdrh         zErr = malloc(nErr);
2139c1f4494eSdrh         if( zErr ){
21405bb3eb9bSdrh           sqlite3_snprintf(nErr, zErr,
2141955de52cSdanielk1977              "Error: %s line %d: expected %d columns of data but found %d",
214219e2d37fSdrh              zFile, lineno, nCol, i+1);
2143a198f2b5Sdrh           Tcl_AppendResult(interp, zErr, (char*)0);
214419e2d37fSdrh           free(zErr);
2145c1f4494eSdrh         }
214619e2d37fSdrh         zCommit = "ROLLBACK";
214719e2d37fSdrh         break;
214819e2d37fSdrh       }
214919e2d37fSdrh       for(i=0; i<nCol; i++){
215019e2d37fSdrh         /* check for null data, if so, bind as null */
2151ea678832Sdrh         if( (nNull>0 && strcmp(azCol[i], zNull)==0)
21524f21c4afSdrh           || strlen30(azCol[i])==0
2153ea678832Sdrh         ){
215419e2d37fSdrh           sqlite3_bind_null(pStmt, i+1);
215519e2d37fSdrh         }else{
215619e2d37fSdrh           sqlite3_bind_text(pStmt, i+1, azCol[i], -1, SQLITE_STATIC);
215719e2d37fSdrh         }
215819e2d37fSdrh       }
215919e2d37fSdrh       sqlite3_step(pStmt);
216019e2d37fSdrh       rc = sqlite3_reset(pStmt);
216119e2d37fSdrh       free(zLine);
216219e2d37fSdrh       if( rc!=SQLITE_OK ){
2163a198f2b5Sdrh         Tcl_AppendResult(interp,"Error: ", sqlite3_errmsg(pDb->db), (char*)0);
216419e2d37fSdrh         zCommit = "ROLLBACK";
216519e2d37fSdrh         break;
216619e2d37fSdrh       }
216719e2d37fSdrh     }
216819e2d37fSdrh     free(azCol);
216919e2d37fSdrh     fclose(in);
217019e2d37fSdrh     sqlite3_finalize(pStmt);
21713752785fSdrh     (void)sqlite3_exec(pDb->db, zCommit, 0, 0, 0);
217219e2d37fSdrh 
217319e2d37fSdrh     if( zCommit[0] == 'C' ){
217419e2d37fSdrh       /* success, set result as number of lines processed */
217519e2d37fSdrh       pResult = Tcl_GetObjResult(interp);
217619e2d37fSdrh       Tcl_SetIntObj(pResult, lineno);
217719e2d37fSdrh       rc = TCL_OK;
217819e2d37fSdrh     }else{
217919e2d37fSdrh       /* failure, append lineno where failed */
21805bb3eb9bSdrh       sqlite3_snprintf(sizeof(zLineNum), zLineNum,"%d",lineno);
2181a198f2b5Sdrh       Tcl_AppendResult(interp,", failed while processing line: ",zLineNum,
2182a198f2b5Sdrh                        (char*)0);
218319e2d37fSdrh       rc = TCL_ERROR;
218419e2d37fSdrh     }
218519e2d37fSdrh     break;
218619e2d37fSdrh   }
218719e2d37fSdrh 
218875897234Sdrh   /*
21894144905bSdrh   **    $db enable_load_extension BOOLEAN
21904144905bSdrh   **
21914144905bSdrh   ** Turn the extension loading feature on or off.  It if off by
21924144905bSdrh   ** default.
21934144905bSdrh   */
21944144905bSdrh   case DB_ENABLE_LOAD_EXTENSION: {
2195f533acc0Sdrh #ifndef SQLITE_OMIT_LOAD_EXTENSION
21964144905bSdrh     int onoff;
21974144905bSdrh     if( objc!=3 ){
21984144905bSdrh       Tcl_WrongNumArgs(interp, 2, objv, "BOOLEAN");
21994144905bSdrh       return TCL_ERROR;
22004144905bSdrh     }
22014144905bSdrh     if( Tcl_GetBooleanFromObj(interp, objv[2], &onoff) ){
22024144905bSdrh       return TCL_ERROR;
22034144905bSdrh     }
22044144905bSdrh     sqlite3_enable_load_extension(pDb->db, onoff);
22054144905bSdrh     break;
2206f533acc0Sdrh #else
2207f533acc0Sdrh     Tcl_AppendResult(interp, "extension loading is turned off at compile-time",
2208a198f2b5Sdrh                      (char*)0);
2209f533acc0Sdrh     return TCL_ERROR;
2210f533acc0Sdrh #endif
22114144905bSdrh   }
22124144905bSdrh 
22134144905bSdrh   /*
2214dcd997eaSdrh   **    $db errorcode
2215dcd997eaSdrh   **
2216dcd997eaSdrh   ** Return the numeric error code that was returned by the most recent
22176f8a503dSdanielk1977   ** call to sqlite3_exec().
2218dcd997eaSdrh   */
2219dcd997eaSdrh   case DB_ERRORCODE: {
2220f3ce83f5Sdanielk1977     Tcl_SetObjResult(interp, Tcl_NewIntObj(sqlite3_errcode(pDb->db)));
2221dcd997eaSdrh     break;
2222dcd997eaSdrh   }
2223dcd997eaSdrh 
2224dcd997eaSdrh   /*
22254a4c11aaSdan   **    $db exists $sql
22261807ce37Sdrh   **    $db onecolumn $sql
222775897234Sdrh   **
22284a4c11aaSdan   ** The onecolumn method is the equivalent of:
22294a4c11aaSdan   **     lindex [$db eval $sql] 0
22304a4c11aaSdan   */
22314a4c11aaSdan   case DB_EXISTS:
22324a4c11aaSdan   case DB_ONECOLUMN: {
22334a4c11aaSdan     DbEvalContext sEval;
22344a4c11aaSdan     if( objc!=3 ){
22354a4c11aaSdan       Tcl_WrongNumArgs(interp, 2, objv, "SQL");
22364a4c11aaSdan       return TCL_ERROR;
22374a4c11aaSdan     }
22384a4c11aaSdan 
22394a4c11aaSdan     dbEvalInit(&sEval, pDb, objv[2], 0);
22404a4c11aaSdan     rc = dbEvalStep(&sEval);
22414a4c11aaSdan     if( choice==DB_ONECOLUMN ){
22424a4c11aaSdan       if( rc==TCL_OK ){
22434a4c11aaSdan         Tcl_SetObjResult(interp, dbEvalColumnValue(&sEval, 0));
2244d5f12cd5Sdan       }else if( rc==TCL_BREAK ){
2245d5f12cd5Sdan         Tcl_ResetResult(interp);
22464a4c11aaSdan       }
22474a4c11aaSdan     }else if( rc==TCL_BREAK || rc==TCL_OK ){
22484a4c11aaSdan       Tcl_SetObjResult(interp, Tcl_NewBooleanObj(rc==TCL_OK));
22494a4c11aaSdan     }
22504a4c11aaSdan     dbEvalFinalize(&sEval);
22514a4c11aaSdan 
22524a4c11aaSdan     if( rc==TCL_BREAK ){
22534a4c11aaSdan       rc = TCL_OK;
22544a4c11aaSdan     }
22554a4c11aaSdan     break;
22564a4c11aaSdan   }
22574a4c11aaSdan 
22584a4c11aaSdan   /*
22594a4c11aaSdan   **    $db eval $sql ?array? ?{  ...code... }?
22604a4c11aaSdan   **
226175897234Sdrh   ** The SQL statement in $sql is evaluated.  For each row, the values are
2262bec3f402Sdrh   ** placed in elements of the array named "array" and ...code... is executed.
226375897234Sdrh   ** If "array" and "code" are omitted, then no callback is every invoked.
226475897234Sdrh   ** If "array" is an empty string, then the values are placed in variables
226575897234Sdrh   ** that have the same name as the fields extracted by the query.
226675897234Sdrh   */
22674a4c11aaSdan   case DB_EVAL: {
226892febd92Sdrh     if( objc<3 || objc>5 ){
2269895d7472Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "SQL ?ARRAY-NAME? ?SCRIPT?");
227030ccda10Sdanielk1977       return TCL_ERROR;
227130ccda10Sdanielk1977     }
22724a4c11aaSdan 
227392febd92Sdrh     if( objc==3 ){
22744a4c11aaSdan       DbEvalContext sEval;
22754a4c11aaSdan       Tcl_Obj *pRet = Tcl_NewObj();
22764a4c11aaSdan       Tcl_IncrRefCount(pRet);
22774a4c11aaSdan       dbEvalInit(&sEval, pDb, objv[2], 0);
22784a4c11aaSdan       while( TCL_OK==(rc = dbEvalStep(&sEval)) ){
22794a4c11aaSdan         int i;
22804a4c11aaSdan         int nCol;
22814a4c11aaSdan         dbEvalRowInfo(&sEval, &nCol, 0);
228292febd92Sdrh         for(i=0; i<nCol; i++){
22834a4c11aaSdan           Tcl_ListObjAppendElement(interp, pRet, dbEvalColumnValue(&sEval, i));
228492febd92Sdrh         }
228530ccda10Sdanielk1977       }
22864a4c11aaSdan       dbEvalFinalize(&sEval);
228790b6bb19Sdrh       if( rc==TCL_BREAK ){
22884a4c11aaSdan         Tcl_SetObjResult(interp, pRet);
228990b6bb19Sdrh         rc = TCL_OK;
229090b6bb19Sdrh       }
2291ef2cb63eSdanielk1977       Tcl_DecrRefCount(pRet);
22924a4c11aaSdan     }else{
22934a4c11aaSdan       ClientData cd[2];
22944a4c11aaSdan       DbEvalContext *p;
22954a4c11aaSdan       Tcl_Obj *pArray = 0;
22964a4c11aaSdan       Tcl_Obj *pScript;
22974a4c11aaSdan 
22984a4c11aaSdan       if( objc==5 && *(char *)Tcl_GetString(objv[3]) ){
22994a4c11aaSdan         pArray = objv[3];
23004a4c11aaSdan       }
23014a4c11aaSdan       pScript = objv[objc-1];
23024a4c11aaSdan       Tcl_IncrRefCount(pScript);
23034a4c11aaSdan 
23044a4c11aaSdan       p = (DbEvalContext *)Tcl_Alloc(sizeof(DbEvalContext));
23054a4c11aaSdan       dbEvalInit(p, pDb, objv[2], pArray);
23064a4c11aaSdan 
23074a4c11aaSdan       cd[0] = (void *)p;
23084a4c11aaSdan       cd[1] = (void *)pScript;
23094a4c11aaSdan       rc = DbEvalNextCmd(cd, interp, TCL_OK);
23101807ce37Sdrh     }
231130ccda10Sdanielk1977     break;
231230ccda10Sdanielk1977   }
2313bec3f402Sdrh 
2314bec3f402Sdrh   /*
2315e3602be8Sdrh   **     $db function NAME [-argcount N] SCRIPT
2316cabb0819Sdrh   **
2317cabb0819Sdrh   ** Create a new SQL function called NAME.  Whenever that function is
2318cabb0819Sdrh   ** called, invoke SCRIPT to evaluate the function.
2319cabb0819Sdrh   */
2320cabb0819Sdrh   case DB_FUNCTION: {
2321cabb0819Sdrh     SqlFunc *pFunc;
2322d1e4733dSdrh     Tcl_Obj *pScript;
2323cabb0819Sdrh     char *zName;
2324e3602be8Sdrh     int nArg = -1;
2325e3602be8Sdrh     if( objc==6 ){
2326e3602be8Sdrh       const char *z = Tcl_GetString(objv[3]);
23274f21c4afSdrh       int n = strlen30(z);
2328e3602be8Sdrh       if( n>2 && strncmp(z, "-argcount",n)==0 ){
2329e3602be8Sdrh         if( Tcl_GetIntFromObj(interp, objv[4], &nArg) ) return TCL_ERROR;
2330e3602be8Sdrh         if( nArg<0 ){
2331e3602be8Sdrh           Tcl_AppendResult(interp, "number of arguments must be non-negative",
2332e3602be8Sdrh                            (char*)0);
2333cabb0819Sdrh           return TCL_ERROR;
2334cabb0819Sdrh         }
2335e3602be8Sdrh       }
2336e3602be8Sdrh       pScript = objv[5];
2337e3602be8Sdrh     }else if( objc!=4 ){
2338e3602be8Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "NAME [-argcount N] SCRIPT");
2339e3602be8Sdrh       return TCL_ERROR;
2340e3602be8Sdrh     }else{
2341d1e4733dSdrh       pScript = objv[3];
2342e3602be8Sdrh     }
2343e3602be8Sdrh     zName = Tcl_GetStringFromObj(objv[2], 0);
2344d1e4733dSdrh     pFunc = findSqlFunc(pDb, zName);
2345cabb0819Sdrh     if( pFunc==0 ) return TCL_ERROR;
2346d1e4733dSdrh     if( pFunc->pScript ){
2347d1e4733dSdrh       Tcl_DecrRefCount(pFunc->pScript);
2348d1e4733dSdrh     }
2349d1e4733dSdrh     pFunc->pScript = pScript;
2350d1e4733dSdrh     Tcl_IncrRefCount(pScript);
2351d1e4733dSdrh     pFunc->useEvalObjv = safeToUseEvalObjv(interp, pScript);
2352e3602be8Sdrh     rc = sqlite3_create_function(pDb->db, zName, nArg, SQLITE_UTF8,
2353d8123366Sdanielk1977         pFunc, tclSqlFunc, 0, 0);
2354fb7e7651Sdrh     if( rc!=SQLITE_OK ){
2355fb7e7651Sdrh       rc = TCL_ERROR;
23569636c4e1Sdanielk1977       Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE);
2357fb7e7651Sdrh     }
2358cabb0819Sdrh     break;
2359cabb0819Sdrh   }
2360cabb0819Sdrh 
2361cabb0819Sdrh   /*
23628cbadb02Sdanielk1977   **     $db incrblob ?-readonly? ?DB? TABLE COLUMN ROWID
2363b4e9af9fSdanielk1977   */
2364b4e9af9fSdanielk1977   case DB_INCRBLOB: {
236532a0d8bbSdanielk1977 #ifdef SQLITE_OMIT_INCRBLOB
2366a198f2b5Sdrh     Tcl_AppendResult(interp, "incrblob not available in this build", (char*)0);
236732a0d8bbSdanielk1977     return TCL_ERROR;
236832a0d8bbSdanielk1977 #else
23698cbadb02Sdanielk1977     int isReadonly = 0;
2370b4e9af9fSdanielk1977     const char *zDb = "main";
2371b4e9af9fSdanielk1977     const char *zTable;
2372b4e9af9fSdanielk1977     const char *zColumn;
2373b3f787f4Sdrh     Tcl_WideInt iRow;
2374b4e9af9fSdanielk1977 
23758cbadb02Sdanielk1977     /* Check for the -readonly option */
23768cbadb02Sdanielk1977     if( objc>3 && strcmp(Tcl_GetString(objv[2]), "-readonly")==0 ){
23778cbadb02Sdanielk1977       isReadonly = 1;
23788cbadb02Sdanielk1977     }
23798cbadb02Sdanielk1977 
23808cbadb02Sdanielk1977     if( objc!=(5+isReadonly) && objc!=(6+isReadonly) ){
23818cbadb02Sdanielk1977       Tcl_WrongNumArgs(interp, 2, objv, "?-readonly? ?DB? TABLE COLUMN ROWID");
2382b4e9af9fSdanielk1977       return TCL_ERROR;
2383b4e9af9fSdanielk1977     }
2384b4e9af9fSdanielk1977 
23858cbadb02Sdanielk1977     if( objc==(6+isReadonly) ){
2386b4e9af9fSdanielk1977       zDb = Tcl_GetString(objv[2]);
2387b4e9af9fSdanielk1977     }
2388b4e9af9fSdanielk1977     zTable = Tcl_GetString(objv[objc-3]);
2389b4e9af9fSdanielk1977     zColumn = Tcl_GetString(objv[objc-2]);
2390b4e9af9fSdanielk1977     rc = Tcl_GetWideIntFromObj(interp, objv[objc-1], &iRow);
2391b4e9af9fSdanielk1977 
2392b4e9af9fSdanielk1977     if( rc==TCL_OK ){
23938cbadb02Sdanielk1977       rc = createIncrblobChannel(
2394edf5b165Sdan           interp, pDb, zDb, zTable, zColumn, (sqlite3_int64)iRow, isReadonly
23958cbadb02Sdanielk1977       );
2396b4e9af9fSdanielk1977     }
239732a0d8bbSdanielk1977 #endif
2398b4e9af9fSdanielk1977     break;
2399b4e9af9fSdanielk1977   }
2400b4e9af9fSdanielk1977 
2401b4e9af9fSdanielk1977   /*
2402f11bded5Sdrh   **     $db interrupt
2403f11bded5Sdrh   **
2404f11bded5Sdrh   ** Interrupt the execution of the inner-most SQL interpreter.  This
2405f11bded5Sdrh   ** causes the SQL statement to return an error of SQLITE_INTERRUPT.
2406f11bded5Sdrh   */
2407f11bded5Sdrh   case DB_INTERRUPT: {
2408f11bded5Sdrh     sqlite3_interrupt(pDb->db);
2409f11bded5Sdrh     break;
2410f11bded5Sdrh   }
2411f11bded5Sdrh 
2412f11bded5Sdrh   /*
241319e2d37fSdrh   **     $db nullvalue ?STRING?
241419e2d37fSdrh   **
241519e2d37fSdrh   ** Change text used when a NULL comes back from the database. If ?STRING?
241619e2d37fSdrh   ** is not present, then the current string used for NULL is returned.
241719e2d37fSdrh   ** If STRING is present, then STRING is returned.
241819e2d37fSdrh   **
241919e2d37fSdrh   */
242019e2d37fSdrh   case DB_NULLVALUE: {
242119e2d37fSdrh     if( objc!=2 && objc!=3 ){
242219e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "NULLVALUE");
242319e2d37fSdrh       return TCL_ERROR;
242419e2d37fSdrh     }
242519e2d37fSdrh     if( objc==3 ){
242619e2d37fSdrh       int len;
242719e2d37fSdrh       char *zNull = Tcl_GetStringFromObj(objv[2], &len);
242819e2d37fSdrh       if( pDb->zNull ){
242919e2d37fSdrh         Tcl_Free(pDb->zNull);
243019e2d37fSdrh       }
243119e2d37fSdrh       if( zNull && len>0 ){
243219e2d37fSdrh         pDb->zNull = Tcl_Alloc( len + 1 );
24337fd33929Sdrh         memcpy(pDb->zNull, zNull, len);
243419e2d37fSdrh         pDb->zNull[len] = '\0';
243519e2d37fSdrh       }else{
243619e2d37fSdrh         pDb->zNull = 0;
243719e2d37fSdrh       }
243819e2d37fSdrh     }
2439c45e6716Sdrh     Tcl_SetObjResult(interp, Tcl_NewStringObj(pDb->zNull, -1));
244019e2d37fSdrh     break;
244119e2d37fSdrh   }
244219e2d37fSdrh 
244319e2d37fSdrh   /*
2444af9ff33aSdrh   **     $db last_insert_rowid
2445af9ff33aSdrh   **
2446af9ff33aSdrh   ** Return an integer which is the ROWID for the most recent insert.
2447af9ff33aSdrh   */
2448af9ff33aSdrh   case DB_LAST_INSERT_ROWID: {
2449af9ff33aSdrh     Tcl_Obj *pResult;
2450f7e678d6Sdrh     Tcl_WideInt rowid;
2451af9ff33aSdrh     if( objc!=2 ){
2452af9ff33aSdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
2453af9ff33aSdrh       return TCL_ERROR;
2454af9ff33aSdrh     }
24556f8a503dSdanielk1977     rowid = sqlite3_last_insert_rowid(pDb->db);
2456af9ff33aSdrh     pResult = Tcl_GetObjResult(interp);
2457f7e678d6Sdrh     Tcl_SetWideIntObj(pResult, rowid);
2458af9ff33aSdrh     break;
2459af9ff33aSdrh   }
2460af9ff33aSdrh 
2461af9ff33aSdrh   /*
24624a4c11aaSdan   ** The DB_ONECOLUMN method is implemented together with DB_EXISTS.
24635d9d7576Sdrh   */
24641807ce37Sdrh 
24651807ce37Sdrh   /*    $db progress ?N CALLBACK?
24661807ce37Sdrh   **
24671807ce37Sdrh   ** Invoke the given callback every N virtual machine opcodes while executing
24681807ce37Sdrh   ** queries.
24691807ce37Sdrh   */
24701807ce37Sdrh   case DB_PROGRESS: {
24711807ce37Sdrh     if( objc==2 ){
24721807ce37Sdrh       if( pDb->zProgress ){
2473a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zProgress, (char*)0);
24745d9d7576Sdrh       }
24751807ce37Sdrh     }else if( objc==4 ){
24761807ce37Sdrh       char *zProgress;
24771807ce37Sdrh       int len;
24781807ce37Sdrh       int N;
24791807ce37Sdrh       if( TCL_OK!=Tcl_GetIntFromObj(interp, objv[2], &N) ){
24801807ce37Sdrh         return TCL_ERROR;
24811807ce37Sdrh       };
24821807ce37Sdrh       if( pDb->zProgress ){
24831807ce37Sdrh         Tcl_Free(pDb->zProgress);
24841807ce37Sdrh       }
24851807ce37Sdrh       zProgress = Tcl_GetStringFromObj(objv[3], &len);
24861807ce37Sdrh       if( zProgress && len>0 ){
24871807ce37Sdrh         pDb->zProgress = Tcl_Alloc( len + 1 );
24885bb3eb9bSdrh         memcpy(pDb->zProgress, zProgress, len+1);
24891807ce37Sdrh       }else{
24901807ce37Sdrh         pDb->zProgress = 0;
24911807ce37Sdrh       }
24921807ce37Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK
24931807ce37Sdrh       if( pDb->zProgress ){
24941807ce37Sdrh         pDb->interp = interp;
24951807ce37Sdrh         sqlite3_progress_handler(pDb->db, N, DbProgressHandler, pDb);
24961807ce37Sdrh       }else{
24971807ce37Sdrh         sqlite3_progress_handler(pDb->db, 0, 0, 0);
24981807ce37Sdrh       }
24991807ce37Sdrh #endif
25001807ce37Sdrh     }else{
25011807ce37Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "N CALLBACK");
25021807ce37Sdrh       return TCL_ERROR;
25035d9d7576Sdrh     }
25045d9d7576Sdrh     break;
25055d9d7576Sdrh   }
25065d9d7576Sdrh 
250719e2d37fSdrh   /*    $db profile ?CALLBACK?
250819e2d37fSdrh   **
250919e2d37fSdrh   ** Make arrangements to invoke the CALLBACK routine after each SQL statement
251019e2d37fSdrh   ** that has run.  The text of the SQL and the amount of elapse time are
251119e2d37fSdrh   ** appended to CALLBACK before the script is run.
251219e2d37fSdrh   */
251319e2d37fSdrh   case DB_PROFILE: {
251419e2d37fSdrh     if( objc>3 ){
251519e2d37fSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
251619e2d37fSdrh       return TCL_ERROR;
251719e2d37fSdrh     }else if( objc==2 ){
251819e2d37fSdrh       if( pDb->zProfile ){
2519a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zProfile, (char*)0);
252019e2d37fSdrh       }
252119e2d37fSdrh     }else{
252219e2d37fSdrh       char *zProfile;
252319e2d37fSdrh       int len;
252419e2d37fSdrh       if( pDb->zProfile ){
252519e2d37fSdrh         Tcl_Free(pDb->zProfile);
252619e2d37fSdrh       }
252719e2d37fSdrh       zProfile = Tcl_GetStringFromObj(objv[2], &len);
252819e2d37fSdrh       if( zProfile && len>0 ){
252919e2d37fSdrh         pDb->zProfile = Tcl_Alloc( len + 1 );
25305bb3eb9bSdrh         memcpy(pDb->zProfile, zProfile, len+1);
253119e2d37fSdrh       }else{
253219e2d37fSdrh         pDb->zProfile = 0;
253319e2d37fSdrh       }
2534bb201344Sshaneh #if !defined(SQLITE_OMIT_TRACE) && !defined(SQLITE_OMIT_FLOATING_POINT)
253519e2d37fSdrh       if( pDb->zProfile ){
253619e2d37fSdrh         pDb->interp = interp;
253719e2d37fSdrh         sqlite3_profile(pDb->db, DbProfileHandler, pDb);
253819e2d37fSdrh       }else{
253919e2d37fSdrh         sqlite3_profile(pDb->db, 0, 0);
254019e2d37fSdrh       }
254119e2d37fSdrh #endif
254219e2d37fSdrh     }
254319e2d37fSdrh     break;
254419e2d37fSdrh   }
254519e2d37fSdrh 
25465d9d7576Sdrh   /*
254722fbcb8dSdrh   **     $db rekey KEY
254822fbcb8dSdrh   **
254922fbcb8dSdrh   ** Change the encryption key on the currently open database.
255022fbcb8dSdrh   */
255122fbcb8dSdrh   case DB_REKEY: {
2552b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
255322fbcb8dSdrh     int nKey;
255422fbcb8dSdrh     void *pKey;
2555b07028f7Sdrh #endif
255622fbcb8dSdrh     if( objc!=3 ){
255722fbcb8dSdrh       Tcl_WrongNumArgs(interp, 2, objv, "KEY");
255822fbcb8dSdrh       return TCL_ERROR;
255922fbcb8dSdrh     }
25609eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
2561b07028f7Sdrh     pKey = Tcl_GetByteArrayFromObj(objv[2], &nKey);
25622011d5f5Sdrh     rc = sqlite3_rekey(pDb->db, pKey, nKey);
256322fbcb8dSdrh     if( rc ){
2564a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errstr(rc), (char*)0);
256522fbcb8dSdrh       rc = TCL_ERROR;
256622fbcb8dSdrh     }
256722fbcb8dSdrh #endif
256822fbcb8dSdrh     break;
256922fbcb8dSdrh   }
257022fbcb8dSdrh 
2571dc2c4915Sdrh   /*    $db restore ?DATABASE? FILENAME
2572dc2c4915Sdrh   **
2573dc2c4915Sdrh   ** Open a database file named FILENAME.  Transfer the content
2574dc2c4915Sdrh   ** of FILENAME into the local database DATABASE (default: "main").
2575dc2c4915Sdrh   */
2576dc2c4915Sdrh   case DB_RESTORE: {
2577dc2c4915Sdrh     const char *zSrcFile;
2578dc2c4915Sdrh     const char *zDestDb;
2579dc2c4915Sdrh     sqlite3 *pSrc;
2580dc2c4915Sdrh     sqlite3_backup *pBackup;
2581dc2c4915Sdrh     int nTimeout = 0;
2582dc2c4915Sdrh 
2583dc2c4915Sdrh     if( objc==3 ){
2584dc2c4915Sdrh       zDestDb = "main";
2585dc2c4915Sdrh       zSrcFile = Tcl_GetString(objv[2]);
2586dc2c4915Sdrh     }else if( objc==4 ){
2587dc2c4915Sdrh       zDestDb = Tcl_GetString(objv[2]);
2588dc2c4915Sdrh       zSrcFile = Tcl_GetString(objv[3]);
2589dc2c4915Sdrh     }else{
2590dc2c4915Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "?DATABASE? FILENAME");
2591dc2c4915Sdrh       return TCL_ERROR;
2592dc2c4915Sdrh     }
2593dc2c4915Sdrh     rc = sqlite3_open_v2(zSrcFile, &pSrc, SQLITE_OPEN_READONLY, 0);
2594dc2c4915Sdrh     if( rc!=SQLITE_OK ){
2595dc2c4915Sdrh       Tcl_AppendResult(interp, "cannot open source database: ",
2596dc2c4915Sdrh            sqlite3_errmsg(pSrc), (char*)0);
2597dc2c4915Sdrh       sqlite3_close(pSrc);
2598dc2c4915Sdrh       return TCL_ERROR;
2599dc2c4915Sdrh     }
2600dc2c4915Sdrh     pBackup = sqlite3_backup_init(pDb->db, zDestDb, pSrc, "main");
2601dc2c4915Sdrh     if( pBackup==0 ){
2602dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: ",
2603dc2c4915Sdrh            sqlite3_errmsg(pDb->db), (char*)0);
2604dc2c4915Sdrh       sqlite3_close(pSrc);
2605dc2c4915Sdrh       return TCL_ERROR;
2606dc2c4915Sdrh     }
2607dc2c4915Sdrh     while( (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK
2608dc2c4915Sdrh               || rc==SQLITE_BUSY ){
2609dc2c4915Sdrh       if( rc==SQLITE_BUSY ){
2610dc2c4915Sdrh         if( nTimeout++ >= 3 ) break;
2611dc2c4915Sdrh         sqlite3_sleep(100);
2612dc2c4915Sdrh       }
2613dc2c4915Sdrh     }
2614dc2c4915Sdrh     sqlite3_backup_finish(pBackup);
2615dc2c4915Sdrh     if( rc==SQLITE_DONE ){
2616dc2c4915Sdrh       rc = TCL_OK;
2617dc2c4915Sdrh     }else if( rc==SQLITE_BUSY || rc==SQLITE_LOCKED ){
2618dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: source database busy",
2619dc2c4915Sdrh                        (char*)0);
2620dc2c4915Sdrh       rc = TCL_ERROR;
2621dc2c4915Sdrh     }else{
2622dc2c4915Sdrh       Tcl_AppendResult(interp, "restore failed: ",
2623dc2c4915Sdrh            sqlite3_errmsg(pDb->db), (char*)0);
2624dc2c4915Sdrh       rc = TCL_ERROR;
2625dc2c4915Sdrh     }
2626dc2c4915Sdrh     sqlite3_close(pSrc);
2627dc2c4915Sdrh     break;
2628dc2c4915Sdrh   }
2629dc2c4915Sdrh 
263022fbcb8dSdrh   /*
26313c379b01Sdrh   **     $db status (step|sort|autoindex)
2632d1d38488Sdrh   **
2633d1d38488Sdrh   ** Display SQLITE_STMTSTATUS_FULLSCAN_STEP or
2634d1d38488Sdrh   ** SQLITE_STMTSTATUS_SORT for the most recent eval.
2635d1d38488Sdrh   */
2636d1d38488Sdrh   case DB_STATUS: {
2637d1d38488Sdrh     int v;
2638d1d38488Sdrh     const char *zOp;
2639d1d38488Sdrh     if( objc!=3 ){
26401c320a43Sdrh       Tcl_WrongNumArgs(interp, 2, objv, "(step|sort|autoindex)");
2641d1d38488Sdrh       return TCL_ERROR;
2642d1d38488Sdrh     }
2643d1d38488Sdrh     zOp = Tcl_GetString(objv[2]);
2644d1d38488Sdrh     if( strcmp(zOp, "step")==0 ){
2645d1d38488Sdrh       v = pDb->nStep;
2646d1d38488Sdrh     }else if( strcmp(zOp, "sort")==0 ){
2647d1d38488Sdrh       v = pDb->nSort;
26483c379b01Sdrh     }else if( strcmp(zOp, "autoindex")==0 ){
26493c379b01Sdrh       v = pDb->nIndex;
2650d1d38488Sdrh     }else{
26513c379b01Sdrh       Tcl_AppendResult(interp,
26523c379b01Sdrh             "bad argument: should be autoindex, step, or sort",
2653d1d38488Sdrh             (char*)0);
2654d1d38488Sdrh       return TCL_ERROR;
2655d1d38488Sdrh     }
2656d1d38488Sdrh     Tcl_SetObjResult(interp, Tcl_NewIntObj(v));
2657d1d38488Sdrh     break;
2658d1d38488Sdrh   }
2659d1d38488Sdrh 
2660d1d38488Sdrh   /*
2661bec3f402Sdrh   **     $db timeout MILLESECONDS
2662bec3f402Sdrh   **
2663bec3f402Sdrh   ** Delay for the number of milliseconds specified when a file is locked.
2664bec3f402Sdrh   */
26656d31316cSdrh   case DB_TIMEOUT: {
2666bec3f402Sdrh     int ms;
26676d31316cSdrh     if( objc!=3 ){
26686d31316cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "MILLISECONDS");
2669bec3f402Sdrh       return TCL_ERROR;
267075897234Sdrh     }
26716d31316cSdrh     if( Tcl_GetIntFromObj(interp, objv[2], &ms) ) return TCL_ERROR;
26726f8a503dSdanielk1977     sqlite3_busy_timeout(pDb->db, ms);
26736d31316cSdrh     break;
267475897234Sdrh   }
2675b5a20d3cSdrh 
26760f14e2ebSdrh   /*
26770f14e2ebSdrh   **     $db total_changes
26780f14e2ebSdrh   **
26790f14e2ebSdrh   ** Return the number of rows that were modified, inserted, or deleted
26800f14e2ebSdrh   ** since the database handle was created.
26810f14e2ebSdrh   */
26820f14e2ebSdrh   case DB_TOTAL_CHANGES: {
26830f14e2ebSdrh     Tcl_Obj *pResult;
26840f14e2ebSdrh     if( objc!=2 ){
26850f14e2ebSdrh       Tcl_WrongNumArgs(interp, 2, objv, "");
26860f14e2ebSdrh       return TCL_ERROR;
26870f14e2ebSdrh     }
26880f14e2ebSdrh     pResult = Tcl_GetObjResult(interp);
26890f14e2ebSdrh     Tcl_SetIntObj(pResult, sqlite3_total_changes(pDb->db));
26900f14e2ebSdrh     break;
26910f14e2ebSdrh   }
26920f14e2ebSdrh 
2693b5a20d3cSdrh   /*    $db trace ?CALLBACK?
2694b5a20d3cSdrh   **
2695b5a20d3cSdrh   ** Make arrangements to invoke the CALLBACK routine for each SQL statement
2696b5a20d3cSdrh   ** that is executed.  The text of the SQL is appended to CALLBACK before
2697b5a20d3cSdrh   ** it is executed.
2698b5a20d3cSdrh   */
2699b5a20d3cSdrh   case DB_TRACE: {
2700b5a20d3cSdrh     if( objc>3 ){
2701b5a20d3cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?");
2702b97759edSdrh       return TCL_ERROR;
2703b5a20d3cSdrh     }else if( objc==2 ){
2704b5a20d3cSdrh       if( pDb->zTrace ){
2705a198f2b5Sdrh         Tcl_AppendResult(interp, pDb->zTrace, (char*)0);
2706b5a20d3cSdrh       }
2707b5a20d3cSdrh     }else{
2708b5a20d3cSdrh       char *zTrace;
2709b5a20d3cSdrh       int len;
2710b5a20d3cSdrh       if( pDb->zTrace ){
2711b5a20d3cSdrh         Tcl_Free(pDb->zTrace);
2712b5a20d3cSdrh       }
2713b5a20d3cSdrh       zTrace = Tcl_GetStringFromObj(objv[2], &len);
2714b5a20d3cSdrh       if( zTrace && len>0 ){
2715b5a20d3cSdrh         pDb->zTrace = Tcl_Alloc( len + 1 );
27165bb3eb9bSdrh         memcpy(pDb->zTrace, zTrace, len+1);
2717b5a20d3cSdrh       }else{
2718b5a20d3cSdrh         pDb->zTrace = 0;
2719b5a20d3cSdrh       }
2720bb201344Sshaneh #if !defined(SQLITE_OMIT_TRACE) && !defined(SQLITE_OMIT_FLOATING_POINT)
2721b5a20d3cSdrh       if( pDb->zTrace ){
2722b5a20d3cSdrh         pDb->interp = interp;
27236f8a503dSdanielk1977         sqlite3_trace(pDb->db, DbTraceHandler, pDb);
2724b5a20d3cSdrh       }else{
27256f8a503dSdanielk1977         sqlite3_trace(pDb->db, 0, 0);
2726b5a20d3cSdrh       }
272719e2d37fSdrh #endif
2728b5a20d3cSdrh     }
2729b5a20d3cSdrh     break;
2730b5a20d3cSdrh   }
2731b5a20d3cSdrh 
27323d21423cSdrh   /*    $db transaction [-deferred|-immediate|-exclusive] SCRIPT
27333d21423cSdrh   **
27343d21423cSdrh   ** Start a new transaction (if we are not already in the midst of a
27353d21423cSdrh   ** transaction) and execute the TCL script SCRIPT.  After SCRIPT
27363d21423cSdrh   ** completes, either commit the transaction or roll it back if SCRIPT
27373d21423cSdrh   ** throws an exception.  Or if no new transation was started, do nothing.
27383d21423cSdrh   ** pass the exception on up the stack.
27393d21423cSdrh   **
27403d21423cSdrh   ** This command was inspired by Dave Thomas's talk on Ruby at the
27413d21423cSdrh   ** 2005 O'Reilly Open Source Convention (OSCON).
27423d21423cSdrh   */
27433d21423cSdrh   case DB_TRANSACTION: {
27443d21423cSdrh     Tcl_Obj *pScript;
2745cd38d520Sdanielk1977     const char *zBegin = "SAVEPOINT _tcl_transaction";
27463d21423cSdrh     if( objc!=3 && objc!=4 ){
27473d21423cSdrh       Tcl_WrongNumArgs(interp, 2, objv, "[TYPE] SCRIPT");
27483d21423cSdrh       return TCL_ERROR;
27493d21423cSdrh     }
2750cd38d520Sdanielk1977 
27514a4c11aaSdan     if( pDb->nTransaction==0 && objc==4 ){
27523d21423cSdrh       static const char *TTYPE_strs[] = {
2753ce604012Sdrh         "deferred",   "exclusive",  "immediate", 0
27543d21423cSdrh       };
27553d21423cSdrh       enum TTYPE_enum {
27563d21423cSdrh         TTYPE_DEFERRED, TTYPE_EXCLUSIVE, TTYPE_IMMEDIATE
27573d21423cSdrh       };
27583d21423cSdrh       int ttype;
2759b5555e7eSdrh       if( Tcl_GetIndexFromObj(interp, objv[2], TTYPE_strs, "transaction type",
27603d21423cSdrh                               0, &ttype) ){
27613d21423cSdrh         return TCL_ERROR;
27623d21423cSdrh       }
27633d21423cSdrh       switch( (enum TTYPE_enum)ttype ){
27643d21423cSdrh         case TTYPE_DEFERRED:    /* no-op */;                 break;
27653d21423cSdrh         case TTYPE_EXCLUSIVE:   zBegin = "BEGIN EXCLUSIVE";  break;
27663d21423cSdrh         case TTYPE_IMMEDIATE:   zBegin = "BEGIN IMMEDIATE";  break;
27673d21423cSdrh       }
27683d21423cSdrh     }
2769cd38d520Sdanielk1977     pScript = objv[objc-1];
2770cd38d520Sdanielk1977 
27714a4c11aaSdan     /* Run the SQLite BEGIN command to open a transaction or savepoint. */
27721f1549f8Sdrh     pDb->disableAuth++;
2773cd38d520Sdanielk1977     rc = sqlite3_exec(pDb->db, zBegin, 0, 0, 0);
27741f1549f8Sdrh     pDb->disableAuth--;
2775cd38d520Sdanielk1977     if( rc!=SQLITE_OK ){
2776a198f2b5Sdrh       Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
2777cd38d520Sdanielk1977       return TCL_ERROR;
27783d21423cSdrh     }
2779cd38d520Sdanielk1977     pDb->nTransaction++;
2780cd38d520Sdanielk1977 
27814a4c11aaSdan     /* If using NRE, schedule a callback to invoke the script pScript, then
27824a4c11aaSdan     ** a second callback to commit (or rollback) the transaction or savepoint
27834a4c11aaSdan     ** opened above. If not using NRE, evaluate the script directly, then
27844a4c11aaSdan     ** call function DbTransPostCmd() to commit (or rollback) the transaction
27854a4c11aaSdan     ** or savepoint.  */
27864a4c11aaSdan     if( DbUseNre() ){
27874a4c11aaSdan       Tcl_NRAddCallback(interp, DbTransPostCmd, cd, 0, 0, 0);
2788a47941feSdrh       (void)Tcl_NREvalObj(interp, pScript, 0);
27893d21423cSdrh     }else{
27904a4c11aaSdan       rc = DbTransPostCmd(&cd, interp, Tcl_EvalObjEx(interp, pScript, 0));
27913d21423cSdrh     }
27923d21423cSdrh     break;
27933d21423cSdrh   }
27943d21423cSdrh 
279594eb6a14Sdanielk1977   /*
2796404ca075Sdanielk1977   **    $db unlock_notify ?script?
2797404ca075Sdanielk1977   */
2798404ca075Sdanielk1977   case DB_UNLOCK_NOTIFY: {
2799404ca075Sdanielk1977 #ifndef SQLITE_ENABLE_UNLOCK_NOTIFY
2800a198f2b5Sdrh     Tcl_AppendResult(interp, "unlock_notify not available in this build",
2801a198f2b5Sdrh                      (char*)0);
2802404ca075Sdanielk1977     rc = TCL_ERROR;
2803404ca075Sdanielk1977 #else
2804404ca075Sdanielk1977     if( objc!=2 && objc!=3 ){
2805404ca075Sdanielk1977       Tcl_WrongNumArgs(interp, 2, objv, "?SCRIPT?");
2806404ca075Sdanielk1977       rc = TCL_ERROR;
2807404ca075Sdanielk1977     }else{
2808404ca075Sdanielk1977       void (*xNotify)(void **, int) = 0;
2809404ca075Sdanielk1977       void *pNotifyArg = 0;
2810404ca075Sdanielk1977 
2811404ca075Sdanielk1977       if( pDb->pUnlockNotify ){
2812404ca075Sdanielk1977         Tcl_DecrRefCount(pDb->pUnlockNotify);
2813404ca075Sdanielk1977         pDb->pUnlockNotify = 0;
2814404ca075Sdanielk1977       }
2815404ca075Sdanielk1977 
2816404ca075Sdanielk1977       if( objc==3 ){
2817404ca075Sdanielk1977         xNotify = DbUnlockNotify;
2818404ca075Sdanielk1977         pNotifyArg = (void *)pDb;
2819404ca075Sdanielk1977         pDb->pUnlockNotify = objv[2];
2820404ca075Sdanielk1977         Tcl_IncrRefCount(pDb->pUnlockNotify);
2821404ca075Sdanielk1977       }
2822404ca075Sdanielk1977 
2823404ca075Sdanielk1977       if( sqlite3_unlock_notify(pDb->db, xNotify, pNotifyArg) ){
2824a198f2b5Sdrh         Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), (char*)0);
2825404ca075Sdanielk1977         rc = TCL_ERROR;
2826404ca075Sdanielk1977       }
2827404ca075Sdanielk1977     }
2828404ca075Sdanielk1977 #endif
2829404ca075Sdanielk1977     break;
2830404ca075Sdanielk1977   }
2831404ca075Sdanielk1977 
2832404ca075Sdanielk1977   /*
2833833bf968Sdrh   **    $db wal_hook ?script?
283494eb6a14Sdanielk1977   **    $db update_hook ?script?
283571fd80bfSdanielk1977   **    $db rollback_hook ?script?
283694eb6a14Sdanielk1977   */
2837833bf968Sdrh   case DB_WAL_HOOK:
283871fd80bfSdanielk1977   case DB_UPDATE_HOOK:
283971fd80bfSdanielk1977   case DB_ROLLBACK_HOOK: {
284071fd80bfSdanielk1977 
284171fd80bfSdanielk1977     /* set ppHook to point at pUpdateHook or pRollbackHook, depending on
284271fd80bfSdanielk1977     ** whether [$db update_hook] or [$db rollback_hook] was invoked.
284371fd80bfSdanielk1977     */
284471fd80bfSdanielk1977     Tcl_Obj **ppHook;
284571fd80bfSdanielk1977     if( choice==DB_UPDATE_HOOK ){
284671fd80bfSdanielk1977       ppHook = &pDb->pUpdateHook;
2847833bf968Sdrh     }else if( choice==DB_WAL_HOOK ){
28485def0843Sdrh       ppHook = &pDb->pWalHook;
284971fd80bfSdanielk1977     }else{
285071fd80bfSdanielk1977       ppHook = &pDb->pRollbackHook;
285171fd80bfSdanielk1977     }
285271fd80bfSdanielk1977 
285394eb6a14Sdanielk1977     if( objc!=2 && objc!=3 ){
285494eb6a14Sdanielk1977        Tcl_WrongNumArgs(interp, 2, objv, "?SCRIPT?");
285594eb6a14Sdanielk1977        return TCL_ERROR;
285694eb6a14Sdanielk1977     }
285771fd80bfSdanielk1977     if( *ppHook ){
285871fd80bfSdanielk1977       Tcl_SetObjResult(interp, *ppHook);
285994eb6a14Sdanielk1977       if( objc==3 ){
286071fd80bfSdanielk1977         Tcl_DecrRefCount(*ppHook);
286171fd80bfSdanielk1977         *ppHook = 0;
286294eb6a14Sdanielk1977       }
286394eb6a14Sdanielk1977     }
286494eb6a14Sdanielk1977     if( objc==3 ){
286571fd80bfSdanielk1977       assert( !(*ppHook) );
286694eb6a14Sdanielk1977       if( Tcl_GetCharLength(objv[2])>0 ){
286771fd80bfSdanielk1977         *ppHook = objv[2];
286871fd80bfSdanielk1977         Tcl_IncrRefCount(*ppHook);
286994eb6a14Sdanielk1977       }
287094eb6a14Sdanielk1977     }
287171fd80bfSdanielk1977 
287271fd80bfSdanielk1977     sqlite3_update_hook(pDb->db, (pDb->pUpdateHook?DbUpdateHandler:0), pDb);
287371fd80bfSdanielk1977     sqlite3_rollback_hook(pDb->db,(pDb->pRollbackHook?DbRollbackHandler:0),pDb);
28745def0843Sdrh     sqlite3_wal_hook(pDb->db,(pDb->pWalHook?DbWalHandler:0),pDb);
287571fd80bfSdanielk1977 
287694eb6a14Sdanielk1977     break;
287794eb6a14Sdanielk1977   }
287894eb6a14Sdanielk1977 
28794397de57Sdanielk1977   /*    $db version
28804397de57Sdanielk1977   **
28814397de57Sdanielk1977   ** Return the version string for this database.
28824397de57Sdanielk1977   */
28834397de57Sdanielk1977   case DB_VERSION: {
28844397de57Sdanielk1977     Tcl_SetResult(interp, (char *)sqlite3_libversion(), TCL_STATIC);
28854397de57Sdanielk1977     break;
28864397de57Sdanielk1977   }
28874397de57Sdanielk1977 
28881067fe11Stpoindex 
28896d31316cSdrh   } /* End of the SWITCH statement */
289022fbcb8dSdrh   return rc;
289175897234Sdrh }
289275897234Sdrh 
2893a2c8a95bSdrh #if SQLITE_TCL_NRE
2894a2c8a95bSdrh /*
2895a2c8a95bSdrh ** Adaptor that provides an objCmd interface to the NRE-enabled
2896a2c8a95bSdrh ** interface implementation.
2897a2c8a95bSdrh */
2898a2c8a95bSdrh static int DbObjCmdAdaptor(
2899a2c8a95bSdrh   void *cd,
2900a2c8a95bSdrh   Tcl_Interp *interp,
2901a2c8a95bSdrh   int objc,
2902a2c8a95bSdrh   Tcl_Obj *const*objv
2903a2c8a95bSdrh ){
2904a2c8a95bSdrh   return Tcl_NRCallObjProc(interp, DbObjCmd, cd, objc, objv);
2905a2c8a95bSdrh }
2906a2c8a95bSdrh #endif /* SQLITE_TCL_NRE */
2907a2c8a95bSdrh 
290875897234Sdrh /*
29093570ad93Sdrh **   sqlite3 DBNAME FILENAME ?-vfs VFSNAME? ?-key KEY? ?-readonly BOOLEAN?
29109a6284c1Sdanielk1977 **                           ?-create BOOLEAN? ?-nomutex BOOLEAN?
291175897234Sdrh **
291275897234Sdrh ** This is the main Tcl command.  When the "sqlite" Tcl command is
291375897234Sdrh ** invoked, this routine runs to process that command.
291475897234Sdrh **
291575897234Sdrh ** The first argument, DBNAME, is an arbitrary name for a new
291675897234Sdrh ** database connection.  This command creates a new command named
291775897234Sdrh ** DBNAME that is used to control that connection.  The database
291875897234Sdrh ** connection is deleted when the DBNAME command is deleted.
291975897234Sdrh **
29203570ad93Sdrh ** The second argument is the name of the database file.
2921fbc3eab8Sdrh **
292275897234Sdrh */
292322fbcb8dSdrh static int DbMain(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){
2924bec3f402Sdrh   SqliteDb *p;
292522fbcb8dSdrh   const char *zArg;
292675897234Sdrh   char *zErrMsg;
29273570ad93Sdrh   int i;
292822fbcb8dSdrh   const char *zFile;
29293570ad93Sdrh   const char *zVfs = 0;
2930d9da78a2Sdrh   int flags;
2931882e8e4dSdrh   Tcl_DString translatedFilename;
2932b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
2933b07028f7Sdrh   void *pKey = 0;
2934b07028f7Sdrh   int nKey = 0;
2935b07028f7Sdrh #endif
2936540ebf82Smistachkin   int rc;
2937d9da78a2Sdrh 
2938d9da78a2Sdrh   /* In normal use, each TCL interpreter runs in a single thread.  So
2939d9da78a2Sdrh   ** by default, we can turn of mutexing on SQLite database connections.
2940d9da78a2Sdrh   ** However, for testing purposes it is useful to have mutexes turned
2941d9da78a2Sdrh   ** on.  So, by default, mutexes default off.  But if compiled with
2942d9da78a2Sdrh   ** SQLITE_TCL_DEFAULT_FULLMUTEX then mutexes default on.
2943d9da78a2Sdrh   */
2944d9da78a2Sdrh #ifdef SQLITE_TCL_DEFAULT_FULLMUTEX
2945d9da78a2Sdrh   flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_FULLMUTEX;
2946d9da78a2Sdrh #else
2947d9da78a2Sdrh   flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_NOMUTEX;
2948d9da78a2Sdrh #endif
2949d9da78a2Sdrh 
295022fbcb8dSdrh   if( objc==2 ){
295122fbcb8dSdrh     zArg = Tcl_GetStringFromObj(objv[1], 0);
295222fbcb8dSdrh     if( strcmp(zArg,"-version")==0 ){
2953a198f2b5Sdrh       Tcl_AppendResult(interp,sqlite3_libversion(), (char*)0);
2954647cb0e1Sdrh       return TCL_OK;
2955647cb0e1Sdrh     }
29569eb9e26bSdrh     if( strcmp(zArg,"-has-codec")==0 ){
29579eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
2958a198f2b5Sdrh       Tcl_AppendResult(interp,"1",(char*)0);
295922fbcb8dSdrh #else
2960a198f2b5Sdrh       Tcl_AppendResult(interp,"0",(char*)0);
296122fbcb8dSdrh #endif
296222fbcb8dSdrh       return TCL_OK;
296322fbcb8dSdrh     }
2964fbc3eab8Sdrh   }
29653570ad93Sdrh   for(i=3; i+1<objc; i+=2){
29663570ad93Sdrh     zArg = Tcl_GetString(objv[i]);
296722fbcb8dSdrh     if( strcmp(zArg,"-key")==0 ){
2968b07028f7Sdrh #ifdef SQLITE_HAS_CODEC
29693570ad93Sdrh       pKey = Tcl_GetByteArrayFromObj(objv[i+1], &nKey);
2970b07028f7Sdrh #endif
29713570ad93Sdrh     }else if( strcmp(zArg, "-vfs")==0 ){
29723c3dd7b9Sdan       zVfs = Tcl_GetString(objv[i+1]);
29733570ad93Sdrh     }else if( strcmp(zArg, "-readonly")==0 ){
29743570ad93Sdrh       int b;
29753570ad93Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
29763570ad93Sdrh       if( b ){
297733f4e02aSdrh         flags &= ~(SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE);
29783570ad93Sdrh         flags |= SQLITE_OPEN_READONLY;
29793570ad93Sdrh       }else{
29803570ad93Sdrh         flags &= ~SQLITE_OPEN_READONLY;
29813570ad93Sdrh         flags |= SQLITE_OPEN_READWRITE;
29823570ad93Sdrh       }
29833570ad93Sdrh     }else if( strcmp(zArg, "-create")==0 ){
29843570ad93Sdrh       int b;
29853570ad93Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
298633f4e02aSdrh       if( b && (flags & SQLITE_OPEN_READONLY)==0 ){
29873570ad93Sdrh         flags |= SQLITE_OPEN_CREATE;
29883570ad93Sdrh       }else{
29893570ad93Sdrh         flags &= ~SQLITE_OPEN_CREATE;
29903570ad93Sdrh       }
29919a6284c1Sdanielk1977     }else if( strcmp(zArg, "-nomutex")==0 ){
29929a6284c1Sdanielk1977       int b;
29939a6284c1Sdanielk1977       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
29949a6284c1Sdanielk1977       if( b ){
29959a6284c1Sdanielk1977         flags |= SQLITE_OPEN_NOMUTEX;
2996039963adSdrh         flags &= ~SQLITE_OPEN_FULLMUTEX;
29979a6284c1Sdanielk1977       }else{
29989a6284c1Sdanielk1977         flags &= ~SQLITE_OPEN_NOMUTEX;
29999a6284c1Sdanielk1977       }
3000039963adSdrh     }else if( strcmp(zArg, "-fullmutex")==0 ){
3001039963adSdrh       int b;
3002039963adSdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
3003039963adSdrh       if( b ){
3004039963adSdrh         flags |= SQLITE_OPEN_FULLMUTEX;
3005039963adSdrh         flags &= ~SQLITE_OPEN_NOMUTEX;
3006039963adSdrh       }else{
3007039963adSdrh         flags &= ~SQLITE_OPEN_FULLMUTEX;
3008039963adSdrh       }
3009f12b3f60Sdrh     }else if( strcmp(zArg, "-uri")==0 ){
3010f12b3f60Sdrh       int b;
3011f12b3f60Sdrh       if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR;
3012f12b3f60Sdrh       if( b ){
3013f12b3f60Sdrh         flags |= SQLITE_OPEN_URI;
3014f12b3f60Sdrh       }else{
3015f12b3f60Sdrh         flags &= ~SQLITE_OPEN_URI;
3016f12b3f60Sdrh       }
30173570ad93Sdrh     }else{
30183570ad93Sdrh       Tcl_AppendResult(interp, "unknown option: ", zArg, (char*)0);
30193570ad93Sdrh       return TCL_ERROR;
302022fbcb8dSdrh     }
302122fbcb8dSdrh   }
30223570ad93Sdrh   if( objc<3 || (objc&1)!=1 ){
302322fbcb8dSdrh     Tcl_WrongNumArgs(interp, 1, objv,
30243570ad93Sdrh       "HANDLE FILENAME ?-vfs VFSNAME? ?-readonly BOOLEAN? ?-create BOOLEAN?"
302568bd4aa2Sdrh       " ?-nomutex BOOLEAN? ?-fullmutex BOOLEAN? ?-uri BOOLEAN?"
30269eb9e26bSdrh #ifdef SQLITE_HAS_CODEC
30273570ad93Sdrh       " ?-key CODECKEY?"
302822fbcb8dSdrh #endif
302922fbcb8dSdrh     );
303075897234Sdrh     return TCL_ERROR;
303175897234Sdrh   }
303275897234Sdrh   zErrMsg = 0;
30334cdc9e84Sdrh   p = (SqliteDb*)Tcl_Alloc( sizeof(*p) );
303475897234Sdrh   if( p==0 ){
30356ef5e12eSmistachkin     Tcl_SetResult(interp, (char *)"malloc failed", TCL_STATIC);
3036bec3f402Sdrh     return TCL_ERROR;
3037bec3f402Sdrh   }
3038bec3f402Sdrh   memset(p, 0, sizeof(*p));
303922fbcb8dSdrh   zFile = Tcl_GetStringFromObj(objv[2], 0);
3040882e8e4dSdrh   zFile = Tcl_TranslateFileName(interp, zFile, &translatedFilename);
3041540ebf82Smistachkin   rc = sqlite3_open_v2(zFile, &p->db, flags, zVfs);
3042882e8e4dSdrh   Tcl_DStringFree(&translatedFilename);
3043540ebf82Smistachkin   if( p->db ){
304480290863Sdanielk1977     if( SQLITE_OK!=sqlite3_errcode(p->db) ){
30459404d50eSdrh       zErrMsg = sqlite3_mprintf("%s", sqlite3_errmsg(p->db));
304680290863Sdanielk1977       sqlite3_close(p->db);
304780290863Sdanielk1977       p->db = 0;
304880290863Sdanielk1977     }
3049540ebf82Smistachkin   }else{
30505dac8432Smistachkin     zErrMsg = sqlite3_mprintf("%s", sqlite3_errstr(rc));
3051540ebf82Smistachkin   }
30522011d5f5Sdrh #ifdef SQLITE_HAS_CODEC
3053f3a65f7eSdrh   if( p->db ){
30542011d5f5Sdrh     sqlite3_key(p->db, pKey, nKey);
3055f3a65f7eSdrh   }
3056eb8ed70dSdrh #endif
3057bec3f402Sdrh   if( p->db==0 ){
305875897234Sdrh     Tcl_SetResult(interp, zErrMsg, TCL_VOLATILE);
3059bec3f402Sdrh     Tcl_Free((char*)p);
30609404d50eSdrh     sqlite3_free(zErrMsg);
306175897234Sdrh     return TCL_ERROR;
306275897234Sdrh   }
3063fb7e7651Sdrh   p->maxStmt = NUM_PREPARED_STMTS;
30645169bbc6Sdrh   p->interp = interp;
306522fbcb8dSdrh   zArg = Tcl_GetStringFromObj(objv[1], 0);
30664a4c11aaSdan   if( DbUseNre() ){
3067a2c8a95bSdrh     Tcl_NRCreateCommand(interp, zArg, DbObjCmdAdaptor, DbObjCmd,
3068a2c8a95bSdrh                         (char*)p, DbDeleteCmd);
30694a4c11aaSdan   }else{
307022fbcb8dSdrh     Tcl_CreateObjCommand(interp, zArg, DbObjCmd, (char*)p, DbDeleteCmd);
30714a4c11aaSdan   }
307275897234Sdrh   return TCL_OK;
307375897234Sdrh }
307475897234Sdrh 
307575897234Sdrh /*
307690ca9753Sdrh ** Provide a dummy Tcl_InitStubs if we are using this as a static
307790ca9753Sdrh ** library.
307890ca9753Sdrh */
307990ca9753Sdrh #ifndef USE_TCL_STUBS
308090ca9753Sdrh # undef  Tcl_InitStubs
30810e85ccfcSdrh # define Tcl_InitStubs(a,b,c) TCL_VERSION
308290ca9753Sdrh #endif
308390ca9753Sdrh 
308490ca9753Sdrh /*
308529bc4615Sdrh ** Make sure we have a PACKAGE_VERSION macro defined.  This will be
308629bc4615Sdrh ** defined automatically by the TEA makefile.  But other makefiles
308729bc4615Sdrh ** do not define it.
308829bc4615Sdrh */
308929bc4615Sdrh #ifndef PACKAGE_VERSION
309029bc4615Sdrh # define PACKAGE_VERSION SQLITE_VERSION
309129bc4615Sdrh #endif
309229bc4615Sdrh 
309329bc4615Sdrh /*
309475897234Sdrh ** Initialize this module.
309575897234Sdrh **
309675897234Sdrh ** This Tcl module contains only a single new Tcl command named "sqlite".
309775897234Sdrh ** (Hence there is no namespace.  There is no point in using a namespace
309875897234Sdrh ** if the extension only supplies one new name!)  The "sqlite" command is
309975897234Sdrh ** used to open a new SQLite database.  See the DbMain() routine above
310075897234Sdrh ** for additional information.
3101b652f432Sdrh **
3102b652f432Sdrh ** The EXTERN macros are required by TCL in order to work on windows.
310375897234Sdrh */
3104b652f432Sdrh EXTERN int Sqlite3_Init(Tcl_Interp *interp){
31050e85ccfcSdrh   int rc = Tcl_InitStubs(interp, "8.4", 0)==0 ? TCL_ERROR : TCL_OK;
31066dc8cbe0Sdrh   if( rc==TCL_OK ){
3107ef4ac8f9Sdrh     Tcl_CreateObjCommand(interp, "sqlite3", (Tcl_ObjCmdProc*)DbMain, 0, 0);
31081cca0d22Sdrh #ifndef SQLITE_3_SUFFIX_ONLY
31091cca0d22Sdrh     /* The "sqlite" alias is undocumented.  It is here only to support
31101cca0d22Sdrh     ** legacy scripts.  All new scripts should use only the "sqlite3"
31116dc8cbe0Sdrh     ** command. */
311249766d6cSdrh     Tcl_CreateObjCommand(interp, "sqlite", (Tcl_ObjCmdProc*)DbMain, 0, 0);
31134c0f1649Sdrh #endif
31146dc8cbe0Sdrh     rc = Tcl_PkgProvide(interp, "sqlite3", PACKAGE_VERSION);
31156dc8cbe0Sdrh   }
31166dc8cbe0Sdrh   return rc;
311790ca9753Sdrh }
3118b652f432Sdrh EXTERN int Tclsqlite3_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3119b652f432Sdrh EXTERN int Sqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3120b652f432Sdrh EXTERN int Tclsqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3121e2c3a659Sdrh 
3122d878cab5Sdrh /* Because it accesses the file-system and uses persistent state, SQLite
3123d878cab5Sdrh ** is not considered appropriate for safe interpreters.  Hence, we deliberately
3124d878cab5Sdrh ** omit the _SafeInit() interfaces.
3125d878cab5Sdrh */
312649766d6cSdrh 
312749766d6cSdrh #ifndef SQLITE_3_SUFFIX_ONLY
3128a3e63c4aSdan int Sqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3129a3e63c4aSdan int Tclsqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); }
3130a3e63c4aSdan int Sqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
3131a3e63c4aSdan int Tclsqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; }
313249766d6cSdrh #endif
313375897234Sdrh 
31343e27c026Sdrh #ifdef TCLSH
31353e27c026Sdrh /*****************************************************************************
313657a0227fSdrh ** All of the code that follows is used to build standalone TCL interpreters
313757a0227fSdrh ** that are statically linked with SQLite.  Enable these by compiling
313857a0227fSdrh ** with -DTCLSH=n where n can be 1 or 2.  An n of 1 generates a standard
313957a0227fSdrh ** tclsh but with SQLite built in.  An n of 2 generates the SQLite space
314057a0227fSdrh ** analysis program.
314175897234Sdrh */
3142348784efSdrh 
314357a0227fSdrh #if defined(SQLITE_TEST) || defined(SQLITE_TCLMD5)
314457a0227fSdrh /*
314557a0227fSdrh  * This code implements the MD5 message-digest algorithm.
314657a0227fSdrh  * The algorithm is due to Ron Rivest.  This code was
314757a0227fSdrh  * written by Colin Plumb in 1993, no copyright is claimed.
314857a0227fSdrh  * This code is in the public domain; do with it what you wish.
314957a0227fSdrh  *
315057a0227fSdrh  * Equivalent code is available from RSA Data Security, Inc.
315157a0227fSdrh  * This code has been tested against that, and is equivalent,
315257a0227fSdrh  * except that you don't need to include two pages of legalese
315357a0227fSdrh  * with every copy.
315457a0227fSdrh  *
315557a0227fSdrh  * To compute the message digest of a chunk of bytes, declare an
315657a0227fSdrh  * MD5Context structure, pass it to MD5Init, call MD5Update as
315757a0227fSdrh  * needed on buffers full of bytes, and then call MD5Final, which
315857a0227fSdrh  * will fill a supplied 16-byte array with the digest.
315957a0227fSdrh  */
316057a0227fSdrh 
316157a0227fSdrh /*
316257a0227fSdrh  * If compiled on a machine that doesn't have a 32-bit integer,
316357a0227fSdrh  * you just set "uint32" to the appropriate datatype for an
316457a0227fSdrh  * unsigned 32-bit integer.  For example:
316557a0227fSdrh  *
316657a0227fSdrh  *       cc -Duint32='unsigned long' md5.c
316757a0227fSdrh  *
316857a0227fSdrh  */
316957a0227fSdrh #ifndef uint32
317057a0227fSdrh #  define uint32 unsigned int
317157a0227fSdrh #endif
317257a0227fSdrh 
317357a0227fSdrh struct MD5Context {
317457a0227fSdrh   int isInit;
317557a0227fSdrh   uint32 buf[4];
317657a0227fSdrh   uint32 bits[2];
317757a0227fSdrh   unsigned char in[64];
317857a0227fSdrh };
317957a0227fSdrh typedef struct MD5Context MD5Context;
318057a0227fSdrh 
318157a0227fSdrh /*
318257a0227fSdrh  * Note: this code is harmless on little-endian machines.
318357a0227fSdrh  */
318457a0227fSdrh static void byteReverse (unsigned char *buf, unsigned longs){
318557a0227fSdrh         uint32 t;
318657a0227fSdrh         do {
318757a0227fSdrh                 t = (uint32)((unsigned)buf[3]<<8 | buf[2]) << 16 |
318857a0227fSdrh                             ((unsigned)buf[1]<<8 | buf[0]);
318957a0227fSdrh                 *(uint32 *)buf = t;
319057a0227fSdrh                 buf += 4;
319157a0227fSdrh         } while (--longs);
319257a0227fSdrh }
319357a0227fSdrh /* The four core functions - F1 is optimized somewhat */
319457a0227fSdrh 
319557a0227fSdrh /* #define F1(x, y, z) (x & y | ~x & z) */
319657a0227fSdrh #define F1(x, y, z) (z ^ (x & (y ^ z)))
319757a0227fSdrh #define F2(x, y, z) F1(z, x, y)
319857a0227fSdrh #define F3(x, y, z) (x ^ y ^ z)
319957a0227fSdrh #define F4(x, y, z) (y ^ (x | ~z))
320057a0227fSdrh 
320157a0227fSdrh /* This is the central step in the MD5 algorithm. */
320257a0227fSdrh #define MD5STEP(f, w, x, y, z, data, s) \
320357a0227fSdrh         ( w += f(x, y, z) + data,  w = w<<s | w>>(32-s),  w += x )
320457a0227fSdrh 
320557a0227fSdrh /*
320657a0227fSdrh  * The core of the MD5 algorithm, this alters an existing MD5 hash to
320757a0227fSdrh  * reflect the addition of 16 longwords of new data.  MD5Update blocks
320857a0227fSdrh  * the data and converts bytes into longwords for this routine.
320957a0227fSdrh  */
321057a0227fSdrh static void MD5Transform(uint32 buf[4], const uint32 in[16]){
321157a0227fSdrh         register uint32 a, b, c, d;
321257a0227fSdrh 
321357a0227fSdrh         a = buf[0];
321457a0227fSdrh         b = buf[1];
321557a0227fSdrh         c = buf[2];
321657a0227fSdrh         d = buf[3];
321757a0227fSdrh 
321857a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 0]+0xd76aa478,  7);
321957a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 1]+0xe8c7b756, 12);
322057a0227fSdrh         MD5STEP(F1, c, d, a, b, in[ 2]+0x242070db, 17);
322157a0227fSdrh         MD5STEP(F1, b, c, d, a, in[ 3]+0xc1bdceee, 22);
322257a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 4]+0xf57c0faf,  7);
322357a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 5]+0x4787c62a, 12);
322457a0227fSdrh         MD5STEP(F1, c, d, a, b, in[ 6]+0xa8304613, 17);
322557a0227fSdrh         MD5STEP(F1, b, c, d, a, in[ 7]+0xfd469501, 22);
322657a0227fSdrh         MD5STEP(F1, a, b, c, d, in[ 8]+0x698098d8,  7);
322757a0227fSdrh         MD5STEP(F1, d, a, b, c, in[ 9]+0x8b44f7af, 12);
322857a0227fSdrh         MD5STEP(F1, c, d, a, b, in[10]+0xffff5bb1, 17);
322957a0227fSdrh         MD5STEP(F1, b, c, d, a, in[11]+0x895cd7be, 22);
323057a0227fSdrh         MD5STEP(F1, a, b, c, d, in[12]+0x6b901122,  7);
323157a0227fSdrh         MD5STEP(F1, d, a, b, c, in[13]+0xfd987193, 12);
323257a0227fSdrh         MD5STEP(F1, c, d, a, b, in[14]+0xa679438e, 17);
323357a0227fSdrh         MD5STEP(F1, b, c, d, a, in[15]+0x49b40821, 22);
323457a0227fSdrh 
323557a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 1]+0xf61e2562,  5);
323657a0227fSdrh         MD5STEP(F2, d, a, b, c, in[ 6]+0xc040b340,  9);
323757a0227fSdrh         MD5STEP(F2, c, d, a, b, in[11]+0x265e5a51, 14);
323857a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 0]+0xe9b6c7aa, 20);
323957a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 5]+0xd62f105d,  5);
324057a0227fSdrh         MD5STEP(F2, d, a, b, c, in[10]+0x02441453,  9);
324157a0227fSdrh         MD5STEP(F2, c, d, a, b, in[15]+0xd8a1e681, 14);
324257a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 4]+0xe7d3fbc8, 20);
324357a0227fSdrh         MD5STEP(F2, a, b, c, d, in[ 9]+0x21e1cde6,  5);
324457a0227fSdrh         MD5STEP(F2, d, a, b, c, in[14]+0xc33707d6,  9);
324557a0227fSdrh         MD5STEP(F2, c, d, a, b, in[ 3]+0xf4d50d87, 14);
324657a0227fSdrh         MD5STEP(F2, b, c, d, a, in[ 8]+0x455a14ed, 20);
324757a0227fSdrh         MD5STEP(F2, a, b, c, d, in[13]+0xa9e3e905,  5);
324857a0227fSdrh         MD5STEP(F2, d, a, b, c, in[ 2]+0xfcefa3f8,  9);
324957a0227fSdrh         MD5STEP(F2, c, d, a, b, in[ 7]+0x676f02d9, 14);
325057a0227fSdrh         MD5STEP(F2, b, c, d, a, in[12]+0x8d2a4c8a, 20);
325157a0227fSdrh 
325257a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 5]+0xfffa3942,  4);
325357a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 8]+0x8771f681, 11);
325457a0227fSdrh         MD5STEP(F3, c, d, a, b, in[11]+0x6d9d6122, 16);
325557a0227fSdrh         MD5STEP(F3, b, c, d, a, in[14]+0xfde5380c, 23);
325657a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 1]+0xa4beea44,  4);
325757a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 4]+0x4bdecfa9, 11);
325857a0227fSdrh         MD5STEP(F3, c, d, a, b, in[ 7]+0xf6bb4b60, 16);
325957a0227fSdrh         MD5STEP(F3, b, c, d, a, in[10]+0xbebfbc70, 23);
326057a0227fSdrh         MD5STEP(F3, a, b, c, d, in[13]+0x289b7ec6,  4);
326157a0227fSdrh         MD5STEP(F3, d, a, b, c, in[ 0]+0xeaa127fa, 11);
326257a0227fSdrh         MD5STEP(F3, c, d, a, b, in[ 3]+0xd4ef3085, 16);
326357a0227fSdrh         MD5STEP(F3, b, c, d, a, in[ 6]+0x04881d05, 23);
326457a0227fSdrh         MD5STEP(F3, a, b, c, d, in[ 9]+0xd9d4d039,  4);
326557a0227fSdrh         MD5STEP(F3, d, a, b, c, in[12]+0xe6db99e5, 11);
326657a0227fSdrh         MD5STEP(F3, c, d, a, b, in[15]+0x1fa27cf8, 16);
326757a0227fSdrh         MD5STEP(F3, b, c, d, a, in[ 2]+0xc4ac5665, 23);
326857a0227fSdrh 
326957a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 0]+0xf4292244,  6);
327057a0227fSdrh         MD5STEP(F4, d, a, b, c, in[ 7]+0x432aff97, 10);
327157a0227fSdrh         MD5STEP(F4, c, d, a, b, in[14]+0xab9423a7, 15);
327257a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 5]+0xfc93a039, 21);
327357a0227fSdrh         MD5STEP(F4, a, b, c, d, in[12]+0x655b59c3,  6);
327457a0227fSdrh         MD5STEP(F4, d, a, b, c, in[ 3]+0x8f0ccc92, 10);
327557a0227fSdrh         MD5STEP(F4, c, d, a, b, in[10]+0xffeff47d, 15);
327657a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 1]+0x85845dd1, 21);
327757a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 8]+0x6fa87e4f,  6);
327857a0227fSdrh         MD5STEP(F4, d, a, b, c, in[15]+0xfe2ce6e0, 10);
327957a0227fSdrh         MD5STEP(F4, c, d, a, b, in[ 6]+0xa3014314, 15);
328057a0227fSdrh         MD5STEP(F4, b, c, d, a, in[13]+0x4e0811a1, 21);
328157a0227fSdrh         MD5STEP(F4, a, b, c, d, in[ 4]+0xf7537e82,  6);
328257a0227fSdrh         MD5STEP(F4, d, a, b, c, in[11]+0xbd3af235, 10);
328357a0227fSdrh         MD5STEP(F4, c, d, a, b, in[ 2]+0x2ad7d2bb, 15);
328457a0227fSdrh         MD5STEP(F4, b, c, d, a, in[ 9]+0xeb86d391, 21);
328557a0227fSdrh 
328657a0227fSdrh         buf[0] += a;
328757a0227fSdrh         buf[1] += b;
328857a0227fSdrh         buf[2] += c;
328957a0227fSdrh         buf[3] += d;
329057a0227fSdrh }
329157a0227fSdrh 
329257a0227fSdrh /*
329357a0227fSdrh  * Start MD5 accumulation.  Set bit count to 0 and buffer to mysterious
329457a0227fSdrh  * initialization constants.
329557a0227fSdrh  */
329657a0227fSdrh static void MD5Init(MD5Context *ctx){
329757a0227fSdrh         ctx->isInit = 1;
329857a0227fSdrh         ctx->buf[0] = 0x67452301;
329957a0227fSdrh         ctx->buf[1] = 0xefcdab89;
330057a0227fSdrh         ctx->buf[2] = 0x98badcfe;
330157a0227fSdrh         ctx->buf[3] = 0x10325476;
330257a0227fSdrh         ctx->bits[0] = 0;
330357a0227fSdrh         ctx->bits[1] = 0;
330457a0227fSdrh }
330557a0227fSdrh 
330657a0227fSdrh /*
330757a0227fSdrh  * Update context to reflect the concatenation of another buffer full
330857a0227fSdrh  * of bytes.
330957a0227fSdrh  */
331057a0227fSdrh static
331157a0227fSdrh void MD5Update(MD5Context *ctx, const unsigned char *buf, unsigned int len){
331257a0227fSdrh         uint32 t;
331357a0227fSdrh 
331457a0227fSdrh         /* Update bitcount */
331557a0227fSdrh 
331657a0227fSdrh         t = ctx->bits[0];
331757a0227fSdrh         if ((ctx->bits[0] = t + ((uint32)len << 3)) < t)
331857a0227fSdrh                 ctx->bits[1]++; /* Carry from low to high */
331957a0227fSdrh         ctx->bits[1] += len >> 29;
332057a0227fSdrh 
332157a0227fSdrh         t = (t >> 3) & 0x3f;    /* Bytes already in shsInfo->data */
332257a0227fSdrh 
332357a0227fSdrh         /* Handle any leading odd-sized chunks */
332457a0227fSdrh 
332557a0227fSdrh         if ( t ) {
332657a0227fSdrh                 unsigned char *p = (unsigned char *)ctx->in + t;
332757a0227fSdrh 
332857a0227fSdrh                 t = 64-t;
332957a0227fSdrh                 if (len < t) {
333057a0227fSdrh                         memcpy(p, buf, len);
333157a0227fSdrh                         return;
333257a0227fSdrh                 }
333357a0227fSdrh                 memcpy(p, buf, t);
333457a0227fSdrh                 byteReverse(ctx->in, 16);
333557a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
333657a0227fSdrh                 buf += t;
333757a0227fSdrh                 len -= t;
333857a0227fSdrh         }
333957a0227fSdrh 
334057a0227fSdrh         /* Process data in 64-byte chunks */
334157a0227fSdrh 
334257a0227fSdrh         while (len >= 64) {
334357a0227fSdrh                 memcpy(ctx->in, buf, 64);
334457a0227fSdrh                 byteReverse(ctx->in, 16);
334557a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
334657a0227fSdrh                 buf += 64;
334757a0227fSdrh                 len -= 64;
334857a0227fSdrh         }
334957a0227fSdrh 
335057a0227fSdrh         /* Handle any remaining bytes of data. */
335157a0227fSdrh 
335257a0227fSdrh         memcpy(ctx->in, buf, len);
335357a0227fSdrh }
335457a0227fSdrh 
335557a0227fSdrh /*
335657a0227fSdrh  * Final wrapup - pad to 64-byte boundary with the bit pattern
335757a0227fSdrh  * 1 0* (64-bit count of bits processed, MSB-first)
335857a0227fSdrh  */
335957a0227fSdrh static void MD5Final(unsigned char digest[16], MD5Context *ctx){
336057a0227fSdrh         unsigned count;
336157a0227fSdrh         unsigned char *p;
336257a0227fSdrh 
336357a0227fSdrh         /* Compute number of bytes mod 64 */
336457a0227fSdrh         count = (ctx->bits[0] >> 3) & 0x3F;
336557a0227fSdrh 
336657a0227fSdrh         /* Set the first char of padding to 0x80.  This is safe since there is
336757a0227fSdrh            always at least one byte free */
336857a0227fSdrh         p = ctx->in + count;
336957a0227fSdrh         *p++ = 0x80;
337057a0227fSdrh 
337157a0227fSdrh         /* Bytes of padding needed to make 64 bytes */
337257a0227fSdrh         count = 64 - 1 - count;
337357a0227fSdrh 
337457a0227fSdrh         /* Pad out to 56 mod 64 */
337557a0227fSdrh         if (count < 8) {
337657a0227fSdrh                 /* Two lots of padding:  Pad the first block to 64 bytes */
337757a0227fSdrh                 memset(p, 0, count);
337857a0227fSdrh                 byteReverse(ctx->in, 16);
337957a0227fSdrh                 MD5Transform(ctx->buf, (uint32 *)ctx->in);
338057a0227fSdrh 
338157a0227fSdrh                 /* Now fill the next block with 56 bytes */
338257a0227fSdrh                 memset(ctx->in, 0, 56);
338357a0227fSdrh         } else {
338457a0227fSdrh                 /* Pad block to 56 bytes */
338557a0227fSdrh                 memset(p, 0, count-8);
338657a0227fSdrh         }
338757a0227fSdrh         byteReverse(ctx->in, 14);
338857a0227fSdrh 
338957a0227fSdrh         /* Append length in bits and transform */
3390a47941feSdrh         memcpy(ctx->in + 14*4, ctx->bits, 8);
339157a0227fSdrh 
339257a0227fSdrh         MD5Transform(ctx->buf, (uint32 *)ctx->in);
339357a0227fSdrh         byteReverse((unsigned char *)ctx->buf, 4);
339457a0227fSdrh         memcpy(digest, ctx->buf, 16);
339557a0227fSdrh }
339657a0227fSdrh 
339757a0227fSdrh /*
339857a0227fSdrh ** Convert a 128-bit MD5 digest into a 32-digit base-16 number.
339957a0227fSdrh */
340057a0227fSdrh static void MD5DigestToBase16(unsigned char *digest, char *zBuf){
340157a0227fSdrh   static char const zEncode[] = "0123456789abcdef";
340257a0227fSdrh   int i, j;
340357a0227fSdrh 
340457a0227fSdrh   for(j=i=0; i<16; i++){
340557a0227fSdrh     int a = digest[i];
340657a0227fSdrh     zBuf[j++] = zEncode[(a>>4)&0xf];
340757a0227fSdrh     zBuf[j++] = zEncode[a & 0xf];
340857a0227fSdrh   }
340957a0227fSdrh   zBuf[j] = 0;
341057a0227fSdrh }
341157a0227fSdrh 
341257a0227fSdrh 
341357a0227fSdrh /*
341457a0227fSdrh ** Convert a 128-bit MD5 digest into sequency of eight 5-digit integers
341557a0227fSdrh ** each representing 16 bits of the digest and separated from each
341657a0227fSdrh ** other by a "-" character.
341757a0227fSdrh */
341857a0227fSdrh static void MD5DigestToBase10x8(unsigned char digest[16], char zDigest[50]){
341957a0227fSdrh   int i, j;
342057a0227fSdrh   unsigned int x;
342157a0227fSdrh   for(i=j=0; i<16; i+=2){
342257a0227fSdrh     x = digest[i]*256 + digest[i+1];
342357a0227fSdrh     if( i>0 ) zDigest[j++] = '-';
342457a0227fSdrh     sprintf(&zDigest[j], "%05u", x);
342557a0227fSdrh     j += 5;
342657a0227fSdrh   }
342757a0227fSdrh   zDigest[j] = 0;
342857a0227fSdrh }
342957a0227fSdrh 
343057a0227fSdrh /*
343157a0227fSdrh ** A TCL command for md5.  The argument is the text to be hashed.  The
343257a0227fSdrh ** Result is the hash in base64.
343357a0227fSdrh */
343457a0227fSdrh static int md5_cmd(void*cd, Tcl_Interp *interp, int argc, const char **argv){
343557a0227fSdrh   MD5Context ctx;
343657a0227fSdrh   unsigned char digest[16];
343757a0227fSdrh   char zBuf[50];
343857a0227fSdrh   void (*converter)(unsigned char*, char*);
343957a0227fSdrh 
344057a0227fSdrh   if( argc!=2 ){
344157a0227fSdrh     Tcl_AppendResult(interp,"wrong # args: should be \"", argv[0],
3442a198f2b5Sdrh         " TEXT\"", (char*)0);
344357a0227fSdrh     return TCL_ERROR;
344457a0227fSdrh   }
344557a0227fSdrh   MD5Init(&ctx);
344657a0227fSdrh   MD5Update(&ctx, (unsigned char*)argv[1], (unsigned)strlen(argv[1]));
344757a0227fSdrh   MD5Final(digest, &ctx);
344857a0227fSdrh   converter = (void(*)(unsigned char*,char*))cd;
344957a0227fSdrh   converter(digest, zBuf);
345057a0227fSdrh   Tcl_AppendResult(interp, zBuf, (char*)0);
345157a0227fSdrh   return TCL_OK;
345257a0227fSdrh }
345357a0227fSdrh 
345457a0227fSdrh /*
345557a0227fSdrh ** A TCL command to take the md5 hash of a file.  The argument is the
345657a0227fSdrh ** name of the file.
345757a0227fSdrh */
345857a0227fSdrh static int md5file_cmd(void*cd, Tcl_Interp*interp, int argc, const char **argv){
345957a0227fSdrh   FILE *in;
346057a0227fSdrh   MD5Context ctx;
346157a0227fSdrh   void (*converter)(unsigned char*, char*);
346257a0227fSdrh   unsigned char digest[16];
346357a0227fSdrh   char zBuf[10240];
346457a0227fSdrh 
346557a0227fSdrh   if( argc!=2 ){
346657a0227fSdrh     Tcl_AppendResult(interp,"wrong # args: should be \"", argv[0],
3467a198f2b5Sdrh         " FILENAME\"", (char*)0);
346857a0227fSdrh     return TCL_ERROR;
346957a0227fSdrh   }
347057a0227fSdrh   in = fopen(argv[1],"rb");
347157a0227fSdrh   if( in==0 ){
347257a0227fSdrh     Tcl_AppendResult(interp,"unable to open file \"", argv[1],
3473a198f2b5Sdrh          "\" for reading", (char*)0);
347457a0227fSdrh     return TCL_ERROR;
347557a0227fSdrh   }
347657a0227fSdrh   MD5Init(&ctx);
347757a0227fSdrh   for(;;){
347857a0227fSdrh     int n;
347983cc1392Sdrh     n = (int)fread(zBuf, 1, sizeof(zBuf), in);
348057a0227fSdrh     if( n<=0 ) break;
348157a0227fSdrh     MD5Update(&ctx, (unsigned char*)zBuf, (unsigned)n);
348257a0227fSdrh   }
348357a0227fSdrh   fclose(in);
348457a0227fSdrh   MD5Final(digest, &ctx);
348557a0227fSdrh   converter = (void(*)(unsigned char*,char*))cd;
348657a0227fSdrh   converter(digest, zBuf);
348757a0227fSdrh   Tcl_AppendResult(interp, zBuf, (char*)0);
348857a0227fSdrh   return TCL_OK;
348957a0227fSdrh }
349057a0227fSdrh 
349157a0227fSdrh /*
349257a0227fSdrh ** Register the four new TCL commands for generating MD5 checksums
349357a0227fSdrh ** with the TCL interpreter.
349457a0227fSdrh */
349557a0227fSdrh int Md5_Init(Tcl_Interp *interp){
349657a0227fSdrh   Tcl_CreateCommand(interp, "md5", (Tcl_CmdProc*)md5_cmd,
349757a0227fSdrh                     MD5DigestToBase16, 0);
349857a0227fSdrh   Tcl_CreateCommand(interp, "md5-10x8", (Tcl_CmdProc*)md5_cmd,
349957a0227fSdrh                     MD5DigestToBase10x8, 0);
350057a0227fSdrh   Tcl_CreateCommand(interp, "md5file", (Tcl_CmdProc*)md5file_cmd,
350157a0227fSdrh                     MD5DigestToBase16, 0);
350257a0227fSdrh   Tcl_CreateCommand(interp, "md5file-10x8", (Tcl_CmdProc*)md5file_cmd,
350357a0227fSdrh                     MD5DigestToBase10x8, 0);
350457a0227fSdrh   return TCL_OK;
350557a0227fSdrh }
350657a0227fSdrh #endif /* defined(SQLITE_TEST) || defined(SQLITE_TCLMD5) */
350757a0227fSdrh 
350857a0227fSdrh #if defined(SQLITE_TEST)
350957a0227fSdrh /*
351057a0227fSdrh ** During testing, the special md5sum() aggregate function is available.
351157a0227fSdrh ** inside SQLite.  The following routines implement that function.
351257a0227fSdrh */
351357a0227fSdrh static void md5step(sqlite3_context *context, int argc, sqlite3_value **argv){
351457a0227fSdrh   MD5Context *p;
351557a0227fSdrh   int i;
351657a0227fSdrh   if( argc<1 ) return;
351757a0227fSdrh   p = sqlite3_aggregate_context(context, sizeof(*p));
351857a0227fSdrh   if( p==0 ) return;
351957a0227fSdrh   if( !p->isInit ){
352057a0227fSdrh     MD5Init(p);
352157a0227fSdrh   }
352257a0227fSdrh   for(i=0; i<argc; i++){
352357a0227fSdrh     const char *zData = (char*)sqlite3_value_text(argv[i]);
352457a0227fSdrh     if( zData ){
352583cc1392Sdrh       MD5Update(p, (unsigned char*)zData, (int)strlen(zData));
352657a0227fSdrh     }
352757a0227fSdrh   }
352857a0227fSdrh }
352957a0227fSdrh static void md5finalize(sqlite3_context *context){
353057a0227fSdrh   MD5Context *p;
353157a0227fSdrh   unsigned char digest[16];
353257a0227fSdrh   char zBuf[33];
353357a0227fSdrh   p = sqlite3_aggregate_context(context, sizeof(*p));
353457a0227fSdrh   MD5Final(digest,p);
353557a0227fSdrh   MD5DigestToBase16(digest, zBuf);
353657a0227fSdrh   sqlite3_result_text(context, zBuf, -1, SQLITE_TRANSIENT);
353757a0227fSdrh }
353857a0227fSdrh int Md5_Register(sqlite3 *db){
353957a0227fSdrh   int rc = sqlite3_create_function(db, "md5sum", -1, SQLITE_UTF8, 0, 0,
354057a0227fSdrh                                  md5step, md5finalize);
354157a0227fSdrh   sqlite3_overload_function(db, "md5sum", -1);  /* To exercise this API */
354257a0227fSdrh   return rc;
354357a0227fSdrh }
354457a0227fSdrh #endif /* defined(SQLITE_TEST) */
354557a0227fSdrh 
354657a0227fSdrh 
3547348784efSdrh /*
35483e27c026Sdrh ** If the macro TCLSH is one, then put in code this for the
35493e27c026Sdrh ** "main" routine that will initialize Tcl and take input from
35503570ad93Sdrh ** standard input, or if a file is named on the command line
35513570ad93Sdrh ** the TCL interpreter reads and evaluates that file.
3552348784efSdrh */
35533e27c026Sdrh #if TCLSH==1
35540ae479dfSdan static const char *tclsh_main_loop(void){
35550ae479dfSdan   static const char zMainloop[] =
3556348784efSdrh     "set line {}\n"
3557348784efSdrh     "while {![eof stdin]} {\n"
3558348784efSdrh       "if {$line!=\"\"} {\n"
3559348784efSdrh         "puts -nonewline \"> \"\n"
3560348784efSdrh       "} else {\n"
3561348784efSdrh         "puts -nonewline \"% \"\n"
3562348784efSdrh       "}\n"
3563348784efSdrh       "flush stdout\n"
3564348784efSdrh       "append line [gets stdin]\n"
3565348784efSdrh       "if {[info complete $line]} {\n"
3566348784efSdrh         "if {[catch {uplevel #0 $line} result]} {\n"
3567348784efSdrh           "puts stderr \"Error: $result\"\n"
3568348784efSdrh         "} elseif {$result!=\"\"} {\n"
3569348784efSdrh           "puts $result\n"
3570348784efSdrh         "}\n"
3571348784efSdrh         "set line {}\n"
3572348784efSdrh       "} else {\n"
3573348784efSdrh         "append line \\n\n"
3574348784efSdrh       "}\n"
3575348784efSdrh     "}\n"
3576348784efSdrh   ;
35770ae479dfSdan   return zMainloop;
35780ae479dfSdan }
35793e27c026Sdrh #endif
35803a0f13ffSdrh #if TCLSH==2
35810ae479dfSdan static const char *tclsh_main_loop(void);
35823a0f13ffSdrh #endif
35833e27c026Sdrh 
3584c1a60c51Sdan #ifdef SQLITE_TEST
3585c1a60c51Sdan static void init_all(Tcl_Interp *);
3586c1a60c51Sdan static int init_all_cmd(
3587c1a60c51Sdan   ClientData cd,
3588c1a60c51Sdan   Tcl_Interp *interp,
3589c1a60c51Sdan   int objc,
3590c1a60c51Sdan   Tcl_Obj *CONST objv[]
3591c1a60c51Sdan ){
35920a549071Sdanielk1977 
3593c1a60c51Sdan   Tcl_Interp *slave;
3594c1a60c51Sdan   if( objc!=2 ){
3595c1a60c51Sdan     Tcl_WrongNumArgs(interp, 1, objv, "SLAVE");
3596c1a60c51Sdan     return TCL_ERROR;
3597c1a60c51Sdan   }
35980a549071Sdanielk1977 
3599c1a60c51Sdan   slave = Tcl_GetSlave(interp, Tcl_GetString(objv[1]));
3600c1a60c51Sdan   if( !slave ){
3601c1a60c51Sdan     return TCL_ERROR;
3602c1a60c51Sdan   }
3603c1a60c51Sdan 
3604c1a60c51Sdan   init_all(slave);
3605c1a60c51Sdan   return TCL_OK;
3606c1a60c51Sdan }
3607c431fd55Sdan 
3608c431fd55Sdan /*
3609c431fd55Sdan ** Tclcmd: db_use_legacy_prepare DB BOOLEAN
3610c431fd55Sdan **
3611c431fd55Sdan **   The first argument to this command must be a database command created by
3612c431fd55Sdan **   [sqlite3]. If the second argument is true, then the handle is configured
3613c431fd55Sdan **   to use the sqlite3_prepare_v2() function to prepare statements. If it
3614c431fd55Sdan **   is false, sqlite3_prepare().
3615c431fd55Sdan */
3616c431fd55Sdan static int db_use_legacy_prepare_cmd(
3617c431fd55Sdan   ClientData cd,
3618c431fd55Sdan   Tcl_Interp *interp,
3619c431fd55Sdan   int objc,
3620c431fd55Sdan   Tcl_Obj *CONST objv[]
3621c431fd55Sdan ){
3622c431fd55Sdan   Tcl_CmdInfo cmdInfo;
3623c431fd55Sdan   SqliteDb *pDb;
3624c431fd55Sdan   int bPrepare;
3625c431fd55Sdan 
3626c431fd55Sdan   if( objc!=3 ){
3627c431fd55Sdan     Tcl_WrongNumArgs(interp, 1, objv, "DB BOOLEAN");
3628c431fd55Sdan     return TCL_ERROR;
3629c431fd55Sdan   }
3630c431fd55Sdan 
3631c431fd55Sdan   if( !Tcl_GetCommandInfo(interp, Tcl_GetString(objv[1]), &cmdInfo) ){
3632c431fd55Sdan     Tcl_AppendResult(interp, "no such db: ", Tcl_GetString(objv[1]), (char*)0);
3633c431fd55Sdan     return TCL_ERROR;
3634c431fd55Sdan   }
3635c431fd55Sdan   pDb = (SqliteDb*)cmdInfo.objClientData;
3636c431fd55Sdan   if( Tcl_GetBooleanFromObj(interp, objv[2], &bPrepare) ){
3637c431fd55Sdan     return TCL_ERROR;
3638c431fd55Sdan   }
3639c431fd55Sdan 
3640c431fd55Sdan   pDb->bLegacyPrepare = bPrepare;
3641c431fd55Sdan 
3642c431fd55Sdan   Tcl_ResetResult(interp);
3643c431fd55Sdan   return TCL_OK;
3644c431fd55Sdan }
364504489b6dSdan 
364604489b6dSdan /*
364704489b6dSdan ** Tclcmd: db_last_stmt_ptr DB
364804489b6dSdan **
364904489b6dSdan **   If the statement cache associated with database DB is not empty,
365004489b6dSdan **   return the text representation of the most recently used statement
365104489b6dSdan **   handle.
365204489b6dSdan */
365304489b6dSdan static int db_last_stmt_ptr(
365404489b6dSdan   ClientData cd,
365504489b6dSdan   Tcl_Interp *interp,
365604489b6dSdan   int objc,
365704489b6dSdan   Tcl_Obj *CONST objv[]
365804489b6dSdan ){
365904489b6dSdan   extern int sqlite3TestMakePointerStr(Tcl_Interp*, char*, void*);
366004489b6dSdan   Tcl_CmdInfo cmdInfo;
366104489b6dSdan   SqliteDb *pDb;
366204489b6dSdan   sqlite3_stmt *pStmt = 0;
366304489b6dSdan   char zBuf[100];
366404489b6dSdan 
366504489b6dSdan   if( objc!=2 ){
366604489b6dSdan     Tcl_WrongNumArgs(interp, 1, objv, "DB");
366704489b6dSdan     return TCL_ERROR;
366804489b6dSdan   }
366904489b6dSdan 
367004489b6dSdan   if( !Tcl_GetCommandInfo(interp, Tcl_GetString(objv[1]), &cmdInfo) ){
367104489b6dSdan     Tcl_AppendResult(interp, "no such db: ", Tcl_GetString(objv[1]), (char*)0);
367204489b6dSdan     return TCL_ERROR;
367304489b6dSdan   }
367404489b6dSdan   pDb = (SqliteDb*)cmdInfo.objClientData;
367504489b6dSdan 
367604489b6dSdan   if( pDb->stmtList ) pStmt = pDb->stmtList->pStmt;
367704489b6dSdan   if( sqlite3TestMakePointerStr(interp, zBuf, pStmt) ){
367804489b6dSdan     return TCL_ERROR;
367904489b6dSdan   }
368004489b6dSdan   Tcl_SetResult(interp, zBuf, TCL_VOLATILE);
368104489b6dSdan 
368204489b6dSdan   return TCL_OK;
368304489b6dSdan }
3684c1a60c51Sdan #endif
3685c1a60c51Sdan 
3686c1a60c51Sdan /*
3687c1a60c51Sdan ** Configure the interpreter passed as the first argument to have access
3688c1a60c51Sdan ** to the commands and linked variables that make up:
3689c1a60c51Sdan **
3690c1a60c51Sdan **   * the [sqlite3] extension itself,
3691c1a60c51Sdan **
3692c1a60c51Sdan **   * If SQLITE_TCLMD5 or SQLITE_TEST is defined, the Md5 commands, and
3693c1a60c51Sdan **
3694c1a60c51Sdan **   * If SQLITE_TEST is set, the various test interfaces used by the Tcl
3695c1a60c51Sdan **     test suite.
3696c1a60c51Sdan */
3697c1a60c51Sdan static void init_all(Tcl_Interp *interp){
369838f8271fSdrh   Sqlite3_Init(interp);
3699c1a60c51Sdan 
370057a0227fSdrh #if defined(SQLITE_TEST) || defined(SQLITE_TCLMD5)
370157a0227fSdrh   Md5_Init(interp);
370257a0227fSdrh #endif
3703c1a60c51Sdan 
37040ae479dfSdan   /* Install the [register_dbstat_vtab] command to access the implementation
37050ae479dfSdan   ** of virtual table dbstat (source file test_stat.c). This command is
37060ae479dfSdan   ** required for testfixture and sqlite3_analyzer, but not by the production
37070ae479dfSdan   ** Tcl extension.  */
37080ae479dfSdan #if defined(SQLITE_TEST) || TCLSH==2
37090ae479dfSdan   {
37100ae479dfSdan     extern int SqlitetestStat_Init(Tcl_Interp*);
37110ae479dfSdan     SqlitetestStat_Init(interp);
37120ae479dfSdan   }
37130ae479dfSdan #endif
37140ae479dfSdan 
3715d9b0257aSdrh #ifdef SQLITE_TEST
3716d1bf3512Sdrh   {
37172f999a67Sdrh     extern int Sqliteconfig_Init(Tcl_Interp*);
3718d1bf3512Sdrh     extern int Sqlitetest1_Init(Tcl_Interp*);
37195c4d9703Sdrh     extern int Sqlitetest2_Init(Tcl_Interp*);
37205c4d9703Sdrh     extern int Sqlitetest3_Init(Tcl_Interp*);
3721a6064dcfSdrh     extern int Sqlitetest4_Init(Tcl_Interp*);
3722998b56c3Sdanielk1977     extern int Sqlitetest5_Init(Tcl_Interp*);
37239c06c953Sdrh     extern int Sqlitetest6_Init(Tcl_Interp*);
372429c636bcSdrh     extern int Sqlitetest7_Init(Tcl_Interp*);
3725b9bb7c18Sdrh     extern int Sqlitetest8_Init(Tcl_Interp*);
3726a713f2c3Sdanielk1977     extern int Sqlitetest9_Init(Tcl_Interp*);
37272366940dSdrh     extern int Sqlitetestasync_Init(Tcl_Interp*);
37281409be69Sdrh     extern int Sqlitetest_autoext_Init(Tcl_Interp*);
3729b391b944Sdan     extern int Sqlitetest_blob_Init(Tcl_Interp*);
37300a7a9155Sdan     extern int Sqlitetest_demovfs_Init(Tcl_Interp *);
3731984bfaa4Sdrh     extern int Sqlitetest_func_Init(Tcl_Interp*);
373215926590Sdrh     extern int Sqlitetest_hexio_Init(Tcl_Interp*);
3733e1ab2193Sdan     extern int Sqlitetest_init_Init(Tcl_Interp*);
37342f999a67Sdrh     extern int Sqlitetest_malloc_Init(Tcl_Interp*);
37351a9ed0b2Sdanielk1977     extern int Sqlitetest_mutex_Init(Tcl_Interp*);
37362f999a67Sdrh     extern int Sqlitetestschema_Init(Tcl_Interp*);
37372f999a67Sdrh     extern int Sqlitetestsse_Init(Tcl_Interp*);
37382f999a67Sdrh     extern int Sqlitetesttclvar_Init(Tcl_Interp*);
37399f5ff371Sdan     extern int Sqlitetestfs_Init(Tcl_Interp*);
374044918fa0Sdanielk1977     extern int SqlitetestThread_Init(Tcl_Interp*);
3741a15db353Sdanielk1977     extern int SqlitetestOnefile_Init();
37425d1f5aa6Sdanielk1977     extern int SqlitetestOsinst_Init(Tcl_Interp*);
37430410302eSdanielk1977     extern int Sqlitetestbackup_Init(Tcl_Interp*);
3744522efc62Sdrh     extern int Sqlitetestintarray_Init(Tcl_Interp*);
3745c7991bdfSdan     extern int Sqlitetestvfs_Init(Tcl_Interp *);
37469508daa9Sdan     extern int Sqlitetestrtree_Init(Tcl_Interp*);
37478cf35eb4Sdan     extern int Sqlitequota_Init(Tcl_Interp*);
37488a922f75Sshaneh     extern int Sqlitemultiplex_Init(Tcl_Interp*);
3749e336b001Sdan     extern int SqliteSuperlock_Init(Tcl_Interp*);
3750213ca0a8Sdan     extern int SqlitetestSyscall_Init(Tcl_Interp*);
37512e66f0b9Sdrh 
37526764a700Sdan #if defined(SQLITE_ENABLE_FTS3) || defined(SQLITE_ENABLE_FTS4)
375399ebad90Sdan     extern int Sqlitetestfts3_Init(Tcl_Interp *interp);
375499ebad90Sdan #endif
375599ebad90Sdan 
3756b29010cdSdan #ifdef SQLITE_ENABLE_ZIPVFS
3757b29010cdSdan     extern int Zipvfs_Init(Tcl_Interp*);
3758b29010cdSdan     Zipvfs_Init(interp);
3759b29010cdSdan #endif
3760b29010cdSdan 
37612f999a67Sdrh     Sqliteconfig_Init(interp);
37626490bebdSdanielk1977     Sqlitetest1_Init(interp);
37635c4d9703Sdrh     Sqlitetest2_Init(interp);
3764de647130Sdrh     Sqlitetest3_Init(interp);
3765fc57d7bfSdanielk1977     Sqlitetest4_Init(interp);
3766998b56c3Sdanielk1977     Sqlitetest5_Init(interp);
37679c06c953Sdrh     Sqlitetest6_Init(interp);
376829c636bcSdrh     Sqlitetest7_Init(interp);
3769b9bb7c18Sdrh     Sqlitetest8_Init(interp);
3770a713f2c3Sdanielk1977     Sqlitetest9_Init(interp);
37712366940dSdrh     Sqlitetestasync_Init(interp);
37721409be69Sdrh     Sqlitetest_autoext_Init(interp);
3773b391b944Sdan     Sqlitetest_blob_Init(interp);
37740a7a9155Sdan     Sqlitetest_demovfs_Init(interp);
3775984bfaa4Sdrh     Sqlitetest_func_Init(interp);
377615926590Sdrh     Sqlitetest_hexio_Init(interp);
3777e1ab2193Sdan     Sqlitetest_init_Init(interp);
37782f999a67Sdrh     Sqlitetest_malloc_Init(interp);
37791a9ed0b2Sdanielk1977     Sqlitetest_mutex_Init(interp);
37802f999a67Sdrh     Sqlitetestschema_Init(interp);
37812f999a67Sdrh     Sqlitetesttclvar_Init(interp);
37829f5ff371Sdan     Sqlitetestfs_Init(interp);
378344918fa0Sdanielk1977     SqlitetestThread_Init(interp);
3784a15db353Sdanielk1977     SqlitetestOnefile_Init(interp);
37855d1f5aa6Sdanielk1977     SqlitetestOsinst_Init(interp);
37860410302eSdanielk1977     Sqlitetestbackup_Init(interp);
3787522efc62Sdrh     Sqlitetestintarray_Init(interp);
3788c7991bdfSdan     Sqlitetestvfs_Init(interp);
37899508daa9Sdan     Sqlitetestrtree_Init(interp);
37908cf35eb4Sdan     Sqlitequota_Init(interp);
37918a922f75Sshaneh     Sqlitemultiplex_Init(interp);
3792e336b001Sdan     SqliteSuperlock_Init(interp);
3793213ca0a8Sdan     SqlitetestSyscall_Init(interp);
3794a15db353Sdanielk1977 
37956764a700Sdan #if defined(SQLITE_ENABLE_FTS3) || defined(SQLITE_ENABLE_FTS4)
379699ebad90Sdan     Sqlitetestfts3_Init(interp);
379799ebad90Sdan #endif
379899ebad90Sdan 
3799c431fd55Sdan     Tcl_CreateObjCommand(
3800c431fd55Sdan         interp, "load_testfixture_extensions", init_all_cmd, 0, 0
3801c431fd55Sdan     );
3802c431fd55Sdan     Tcl_CreateObjCommand(
3803c431fd55Sdan         interp, "db_use_legacy_prepare", db_use_legacy_prepare_cmd, 0, 0
3804c431fd55Sdan     );
380504489b6dSdan     Tcl_CreateObjCommand(
380604489b6dSdan         interp, "db_last_stmt_ptr", db_last_stmt_ptr, 0, 0
380704489b6dSdan     );
3808c1a60c51Sdan 
380989dec819Sdrh #ifdef SQLITE_SSE
38102e66f0b9Sdrh     Sqlitetestsse_Init(interp);
38112e66f0b9Sdrh #endif
3812d1bf3512Sdrh   }
3813d1bf3512Sdrh #endif
3814c1a60c51Sdan }
3815c1a60c51Sdan 
3816*db6bafaeSdrh /* Needed for the setrlimit() system call on unix */
3817*db6bafaeSdrh #if defined(unix)
3818*db6bafaeSdrh #include <sys/resource.h>
3819*db6bafaeSdrh #endif
3820*db6bafaeSdrh 
3821c1a60c51Sdan #define TCLSH_MAIN main   /* Needed to fake out mktclapp */
3822c1a60c51Sdan int TCLSH_MAIN(int argc, char **argv){
3823c1a60c51Sdan   Tcl_Interp *interp;
3824c1a60c51Sdan 
38251f28e070Smistachkin #if !defined(_WIN32_WCE)
38261f28e070Smistachkin   if( getenv("BREAK") ){
38271f28e070Smistachkin     fprintf(stderr,
38281f28e070Smistachkin         "attach debugger to process %d and press any key to continue.\n",
38291f28e070Smistachkin         GETPID());
38301f28e070Smistachkin     fgetc(stdin);
38311f28e070Smistachkin   }
38321f28e070Smistachkin #endif
38331f28e070Smistachkin 
3834*db6bafaeSdrh   /* Since the primary use case for this binary is testing of SQLite,
3835*db6bafaeSdrh   ** be sure to generate core files if we crash */
3836*db6bafaeSdrh #if defined(SQLITE_TEST) && defined(unix)
3837*db6bafaeSdrh   { struct rlimit x;
3838*db6bafaeSdrh     getrlimit(RLIMIT_CORE, &x);
3839*db6bafaeSdrh     x.rlim_cur = x.rlim_max;
3840*db6bafaeSdrh     setrlimit(RLIMIT_CORE, &x);
3841*db6bafaeSdrh   }
3842*db6bafaeSdrh #endif /* SQLITE_TEST && unix */
3843*db6bafaeSdrh 
3844*db6bafaeSdrh 
3845c1a60c51Sdan   /* Call sqlite3_shutdown() once before doing anything else. This is to
3846c1a60c51Sdan   ** test that sqlite3_shutdown() can be safely called by a process before
3847c1a60c51Sdan   ** sqlite3_initialize() is. */
3848c1a60c51Sdan   sqlite3_shutdown();
3849c1a60c51Sdan 
38500ae479dfSdan   Tcl_FindExecutable(argv[0]);
38512953ba9eSmistachkin   Tcl_SetSystemEncoding(NULL, "utf-8");
38520ae479dfSdan   interp = Tcl_CreateInterp();
38530ae479dfSdan 
38543a0f13ffSdrh #if TCLSH==2
38553a0f13ffSdrh   sqlite3_config(SQLITE_CONFIG_SINGLETHREAD);
38563a0f13ffSdrh #endif
3857c1a60c51Sdan 
3858c1a60c51Sdan   init_all(interp);
3859c7285978Sdrh   if( argc>=2 ){
3860348784efSdrh     int i;
3861ad42c3a3Sshess     char zArgc[32];
3862ad42c3a3Sshess     sqlite3_snprintf(sizeof(zArgc), zArgc, "%d", argc-(3-TCLSH));
3863ad42c3a3Sshess     Tcl_SetVar(interp,"argc", zArgc, TCL_GLOBAL_ONLY);
3864348784efSdrh     Tcl_SetVar(interp,"argv0",argv[1],TCL_GLOBAL_ONLY);
3865348784efSdrh     Tcl_SetVar(interp,"argv", "", TCL_GLOBAL_ONLY);
386661212b69Sdrh     for(i=3-TCLSH; i<argc; i++){
3867348784efSdrh       Tcl_SetVar(interp, "argv", argv[i],
3868348784efSdrh           TCL_GLOBAL_ONLY | TCL_LIST_ELEMENT | TCL_APPEND_VALUE);
3869348784efSdrh     }
38703a0f13ffSdrh     if( TCLSH==1 && Tcl_EvalFile(interp, argv[1])!=TCL_OK ){
38710de8c112Sdrh       const char *zInfo = Tcl_GetVar(interp, "errorInfo", TCL_GLOBAL_ONLY);
3872a81c64a2Sdrh       if( zInfo==0 ) zInfo = Tcl_GetStringResult(interp);
3873c61053b7Sdrh       fprintf(stderr,"%s: %s\n", *argv, zInfo);
3874348784efSdrh       return 1;
3875348784efSdrh     }
38763e27c026Sdrh   }
38773a0f13ffSdrh   if( TCLSH==2 || argc<=1 ){
38780ae479dfSdan     Tcl_GlobalEval(interp, tclsh_main_loop());
3879348784efSdrh   }
3880348784efSdrh   return 0;
3881348784efSdrh }
3882348784efSdrh #endif /* TCLSH */
3883