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. 1475897234Sdrh ** 15*cd38d520Sdanielk1977 ** $Id: tclsqlite.c,v 1.233 2009/01/02 17:33:46 danielk1977 Exp $ 1675897234Sdrh */ 17bd08af48Sdrh #include "tcl.h" 18b4e9af9fSdanielk1977 #include <errno.h> 196d31316cSdrh 20bd08af48Sdrh /* 21bd08af48Sdrh ** Some additional include files are needed if this file is not 22bd08af48Sdrh ** appended to the amalgamation. 23bd08af48Sdrh */ 24bd08af48Sdrh #ifndef SQLITE_AMALGAMATION 2506b2718aSdrh # include "sqliteInt.h" 2675897234Sdrh # include <stdlib.h> 2775897234Sdrh # include <string.h> 28ce927065Sdrh # include <assert.h> 29d1e4733dSdrh # include <ctype.h> 30bd08af48Sdrh #endif 3175897234Sdrh 32ad6e1370Sdrh /* 33ad6e1370Sdrh * Windows needs to know which symbols to export. Unix does not. 34ad6e1370Sdrh * BUILD_sqlite should be undefined for Unix. 35ad6e1370Sdrh */ 36ad6e1370Sdrh #ifdef BUILD_sqlite 37ad6e1370Sdrh #undef TCL_STORAGE_CLASS 38ad6e1370Sdrh #define TCL_STORAGE_CLASS DLLEXPORT 39ad6e1370Sdrh #endif /* BUILD_sqlite */ 4029bc4615Sdrh 41a21c6b6fSdanielk1977 #define NUM_PREPARED_STMTS 10 42fb7e7651Sdrh #define MAX_PREPARED_STMTS 100 43fb7e7651Sdrh 4475897234Sdrh /* 4598808babSdrh ** If TCL uses UTF-8 and SQLite is configured to use iso8859, then we 4698808babSdrh ** have to do a translation when going between the two. Set the 4798808babSdrh ** UTF_TRANSLATION_NEEDED macro to indicate that we need to do 4898808babSdrh ** this translation. 4998808babSdrh */ 5098808babSdrh #if defined(TCL_UTF_MAX) && !defined(SQLITE_UTF8) 5198808babSdrh # define UTF_TRANSLATION_NEEDED 1 5298808babSdrh #endif 5398808babSdrh 5498808babSdrh /* 55cabb0819Sdrh ** New SQL functions can be created as TCL scripts. Each such function 56cabb0819Sdrh ** is described by an instance of the following structure. 57cabb0819Sdrh */ 58cabb0819Sdrh typedef struct SqlFunc SqlFunc; 59cabb0819Sdrh struct SqlFunc { 60cabb0819Sdrh Tcl_Interp *interp; /* The TCL interpret to execute the function */ 61d1e4733dSdrh Tcl_Obj *pScript; /* The Tcl_Obj representation of the script */ 62d1e4733dSdrh int useEvalObjv; /* True if it is safe to use Tcl_EvalObjv */ 63d1e4733dSdrh char *zName; /* Name of this function */ 64cabb0819Sdrh SqlFunc *pNext; /* Next function on the list of them all */ 65cabb0819Sdrh }; 66cabb0819Sdrh 67cabb0819Sdrh /* 680202b29eSdanielk1977 ** New collation sequences function can be created as TCL scripts. Each such 690202b29eSdanielk1977 ** function is described by an instance of the following structure. 700202b29eSdanielk1977 */ 710202b29eSdanielk1977 typedef struct SqlCollate SqlCollate; 720202b29eSdanielk1977 struct SqlCollate { 730202b29eSdanielk1977 Tcl_Interp *interp; /* The TCL interpret to execute the function */ 740202b29eSdanielk1977 char *zScript; /* The script to be run */ 750202b29eSdanielk1977 SqlCollate *pNext; /* Next function on the list of them all */ 760202b29eSdanielk1977 }; 770202b29eSdanielk1977 780202b29eSdanielk1977 /* 79fb7e7651Sdrh ** Prepared statements are cached for faster execution. Each prepared 80fb7e7651Sdrh ** statement is described by an instance of the following structure. 81fb7e7651Sdrh */ 82fb7e7651Sdrh typedef struct SqlPreparedStmt SqlPreparedStmt; 83fb7e7651Sdrh struct SqlPreparedStmt { 84fb7e7651Sdrh SqlPreparedStmt *pNext; /* Next in linked list */ 85fb7e7651Sdrh SqlPreparedStmt *pPrev; /* Previous on the list */ 86fb7e7651Sdrh sqlite3_stmt *pStmt; /* The prepared statement */ 87fb7e7651Sdrh int nSql; /* chars in zSql[] */ 88d0e2a854Sdanielk1977 const char *zSql; /* Text of the SQL statement */ 89fb7e7651Sdrh }; 90fb7e7651Sdrh 91d0441796Sdanielk1977 typedef struct IncrblobChannel IncrblobChannel; 92d0441796Sdanielk1977 93fb7e7651Sdrh /* 94bec3f402Sdrh ** There is one instance of this structure for each SQLite database 95bec3f402Sdrh ** that has been opened by the SQLite TCL interface. 96bec3f402Sdrh */ 97bec3f402Sdrh typedef struct SqliteDb SqliteDb; 98bec3f402Sdrh struct SqliteDb { 99dddca286Sdrh sqlite3 *db; /* The "real" database structure. MUST BE FIRST */ 100bec3f402Sdrh Tcl_Interp *interp; /* The interpreter used for this database */ 1016d31316cSdrh char *zBusy; /* The busy callback routine */ 102aa940eacSdrh char *zCommit; /* The commit hook callback routine */ 103b5a20d3cSdrh char *zTrace; /* The trace callback routine */ 10419e2d37fSdrh char *zProfile; /* The profile callback routine */ 105348bb5d6Sdanielk1977 char *zProgress; /* The progress callback routine */ 106e22a334bSdrh char *zAuth; /* The authorization callback routine */ 1071f1549f8Sdrh int disableAuth; /* Disable the authorizer if it exists */ 10855c45f2eSdanielk1977 char *zNull; /* Text to substitute for an SQL NULL value */ 109cabb0819Sdrh SqlFunc *pFunc; /* List of SQL functions */ 11094eb6a14Sdanielk1977 Tcl_Obj *pUpdateHook; /* Update hook script (if any) */ 11171fd80bfSdanielk1977 Tcl_Obj *pRollbackHook; /* Rollback hook script (if any) */ 1120202b29eSdanielk1977 SqlCollate *pCollate; /* List of SQL collation functions */ 1136f8a503dSdanielk1977 int rc; /* Return code of most recent sqlite3_exec() */ 1147cedc8d4Sdanielk1977 Tcl_Obj *pCollateNeeded; /* Collation needed script */ 115fb7e7651Sdrh SqlPreparedStmt *stmtList; /* List of prepared statements*/ 116fb7e7651Sdrh SqlPreparedStmt *stmtLast; /* Last statement in the list */ 117fb7e7651Sdrh int maxStmt; /* The next maximum number of stmtList */ 118fb7e7651Sdrh int nStmt; /* Number of statements in stmtList */ 119d0441796Sdanielk1977 IncrblobChannel *pIncrblob;/* Linked list of open incrblob channels */ 120d1d38488Sdrh int nStep, nSort; /* Statistics for most recent operation */ 121*cd38d520Sdanielk1977 int nTransaction; /* Number of nested [transaction] methods */ 12298808babSdrh }; 123297ecf14Sdrh 124b4e9af9fSdanielk1977 struct IncrblobChannel { 125d0441796Sdanielk1977 sqlite3_blob *pBlob; /* sqlite3 blob handle */ 126dcbb5d3fSdanielk1977 SqliteDb *pDb; /* Associated database connection */ 127b4e9af9fSdanielk1977 int iSeek; /* Current seek offset */ 128d0441796Sdanielk1977 Tcl_Channel channel; /* Channel identifier */ 129d0441796Sdanielk1977 IncrblobChannel *pNext; /* Linked list of all open incrblob channels */ 130d0441796Sdanielk1977 IncrblobChannel *pPrev; /* Linked list of all open incrblob channels */ 131b4e9af9fSdanielk1977 }; 132b4e9af9fSdanielk1977 133ea678832Sdrh /* 134ea678832Sdrh ** Compute a string length that is limited to what can be stored in 135ea678832Sdrh ** lower 30 bits of a 32-bit signed integer. 136ea678832Sdrh */ 1374f21c4afSdrh static int strlen30(const char *z){ 138ea678832Sdrh const char *z2 = z; 139ea678832Sdrh while( *z2 ){ z2++; } 140ea678832Sdrh return 0x3fffffff & (int)(z2 - z); 141ea678832Sdrh } 142ea678832Sdrh 143ea678832Sdrh 14432a0d8bbSdanielk1977 #ifndef SQLITE_OMIT_INCRBLOB 145b4e9af9fSdanielk1977 /* 146d0441796Sdanielk1977 ** Close all incrblob channels opened using database connection pDb. 147d0441796Sdanielk1977 ** This is called when shutting down the database connection. 148d0441796Sdanielk1977 */ 149d0441796Sdanielk1977 static void closeIncrblobChannels(SqliteDb *pDb){ 150d0441796Sdanielk1977 IncrblobChannel *p; 151d0441796Sdanielk1977 IncrblobChannel *pNext; 152d0441796Sdanielk1977 153d0441796Sdanielk1977 for(p=pDb->pIncrblob; p; p=pNext){ 154d0441796Sdanielk1977 pNext = p->pNext; 155d0441796Sdanielk1977 156d0441796Sdanielk1977 /* Note: Calling unregister here call Tcl_Close on the incrblob channel, 157d0441796Sdanielk1977 ** which deletes the IncrblobChannel structure at *p. So do not 158d0441796Sdanielk1977 ** call Tcl_Free() here. 159d0441796Sdanielk1977 */ 160d0441796Sdanielk1977 Tcl_UnregisterChannel(pDb->interp, p->channel); 161d0441796Sdanielk1977 } 162d0441796Sdanielk1977 } 163d0441796Sdanielk1977 164d0441796Sdanielk1977 /* 165b4e9af9fSdanielk1977 ** Close an incremental blob channel. 166b4e9af9fSdanielk1977 */ 167b4e9af9fSdanielk1977 static int incrblobClose(ClientData instanceData, Tcl_Interp *interp){ 168b4e9af9fSdanielk1977 IncrblobChannel *p = (IncrblobChannel *)instanceData; 16992d4d7a9Sdanielk1977 int rc = sqlite3_blob_close(p->pBlob); 17092d4d7a9Sdanielk1977 sqlite3 *db = p->pDb->db; 171d0441796Sdanielk1977 172d0441796Sdanielk1977 /* Remove the channel from the SqliteDb.pIncrblob list. */ 173d0441796Sdanielk1977 if( p->pNext ){ 174d0441796Sdanielk1977 p->pNext->pPrev = p->pPrev; 175d0441796Sdanielk1977 } 176d0441796Sdanielk1977 if( p->pPrev ){ 177d0441796Sdanielk1977 p->pPrev->pNext = p->pNext; 178d0441796Sdanielk1977 } 179d0441796Sdanielk1977 if( p->pDb->pIncrblob==p ){ 180d0441796Sdanielk1977 p->pDb->pIncrblob = p->pNext; 181d0441796Sdanielk1977 } 182d0441796Sdanielk1977 18392d4d7a9Sdanielk1977 /* Free the IncrblobChannel structure */ 184b4e9af9fSdanielk1977 Tcl_Free((char *)p); 18592d4d7a9Sdanielk1977 18692d4d7a9Sdanielk1977 if( rc!=SQLITE_OK ){ 18792d4d7a9Sdanielk1977 Tcl_SetResult(interp, (char *)sqlite3_errmsg(db), TCL_VOLATILE); 18892d4d7a9Sdanielk1977 return TCL_ERROR; 18992d4d7a9Sdanielk1977 } 190b4e9af9fSdanielk1977 return TCL_OK; 191b4e9af9fSdanielk1977 } 192b4e9af9fSdanielk1977 193b4e9af9fSdanielk1977 /* 194b4e9af9fSdanielk1977 ** Read data from an incremental blob channel. 195b4e9af9fSdanielk1977 */ 196b4e9af9fSdanielk1977 static int incrblobInput( 197b4e9af9fSdanielk1977 ClientData instanceData, 198b4e9af9fSdanielk1977 char *buf, 199b4e9af9fSdanielk1977 int bufSize, 200b4e9af9fSdanielk1977 int *errorCodePtr 201b4e9af9fSdanielk1977 ){ 202b4e9af9fSdanielk1977 IncrblobChannel *p = (IncrblobChannel *)instanceData; 203b4e9af9fSdanielk1977 int nRead = bufSize; /* Number of bytes to read */ 204b4e9af9fSdanielk1977 int nBlob; /* Total size of the blob */ 205b4e9af9fSdanielk1977 int rc; /* sqlite error code */ 206b4e9af9fSdanielk1977 207b4e9af9fSdanielk1977 nBlob = sqlite3_blob_bytes(p->pBlob); 208b4e9af9fSdanielk1977 if( (p->iSeek+nRead)>nBlob ){ 209b4e9af9fSdanielk1977 nRead = nBlob-p->iSeek; 210b4e9af9fSdanielk1977 } 211b4e9af9fSdanielk1977 if( nRead<=0 ){ 212b4e9af9fSdanielk1977 return 0; 213b4e9af9fSdanielk1977 } 214b4e9af9fSdanielk1977 215b4e9af9fSdanielk1977 rc = sqlite3_blob_read(p->pBlob, (void *)buf, nRead, p->iSeek); 216b4e9af9fSdanielk1977 if( rc!=SQLITE_OK ){ 217b4e9af9fSdanielk1977 *errorCodePtr = rc; 218b4e9af9fSdanielk1977 return -1; 219b4e9af9fSdanielk1977 } 220b4e9af9fSdanielk1977 221b4e9af9fSdanielk1977 p->iSeek += nRead; 222b4e9af9fSdanielk1977 return nRead; 223b4e9af9fSdanielk1977 } 224b4e9af9fSdanielk1977 225d0441796Sdanielk1977 /* 226d0441796Sdanielk1977 ** Write data to an incremental blob channel. 227d0441796Sdanielk1977 */ 228b4e9af9fSdanielk1977 static int incrblobOutput( 229b4e9af9fSdanielk1977 ClientData instanceData, 230b4e9af9fSdanielk1977 CONST char *buf, 231b4e9af9fSdanielk1977 int toWrite, 232b4e9af9fSdanielk1977 int *errorCodePtr 233b4e9af9fSdanielk1977 ){ 234b4e9af9fSdanielk1977 IncrblobChannel *p = (IncrblobChannel *)instanceData; 235b4e9af9fSdanielk1977 int nWrite = toWrite; /* Number of bytes to write */ 236b4e9af9fSdanielk1977 int nBlob; /* Total size of the blob */ 237b4e9af9fSdanielk1977 int rc; /* sqlite error code */ 238b4e9af9fSdanielk1977 239b4e9af9fSdanielk1977 nBlob = sqlite3_blob_bytes(p->pBlob); 240b4e9af9fSdanielk1977 if( (p->iSeek+nWrite)>nBlob ){ 241b4e9af9fSdanielk1977 *errorCodePtr = EINVAL; 242b4e9af9fSdanielk1977 return -1; 243b4e9af9fSdanielk1977 } 244b4e9af9fSdanielk1977 if( nWrite<=0 ){ 245b4e9af9fSdanielk1977 return 0; 246b4e9af9fSdanielk1977 } 247b4e9af9fSdanielk1977 248b4e9af9fSdanielk1977 rc = sqlite3_blob_write(p->pBlob, (void *)buf, nWrite, p->iSeek); 249b4e9af9fSdanielk1977 if( rc!=SQLITE_OK ){ 250b4e9af9fSdanielk1977 *errorCodePtr = EIO; 251b4e9af9fSdanielk1977 return -1; 252b4e9af9fSdanielk1977 } 253b4e9af9fSdanielk1977 254b4e9af9fSdanielk1977 p->iSeek += nWrite; 255b4e9af9fSdanielk1977 return nWrite; 256b4e9af9fSdanielk1977 } 257b4e9af9fSdanielk1977 258b4e9af9fSdanielk1977 /* 259b4e9af9fSdanielk1977 ** Seek an incremental blob channel. 260b4e9af9fSdanielk1977 */ 261b4e9af9fSdanielk1977 static int incrblobSeek( 262b4e9af9fSdanielk1977 ClientData instanceData, 263b4e9af9fSdanielk1977 long offset, 264b4e9af9fSdanielk1977 int seekMode, 265b4e9af9fSdanielk1977 int *errorCodePtr 266b4e9af9fSdanielk1977 ){ 267b4e9af9fSdanielk1977 IncrblobChannel *p = (IncrblobChannel *)instanceData; 268b4e9af9fSdanielk1977 269b4e9af9fSdanielk1977 switch( seekMode ){ 270b4e9af9fSdanielk1977 case SEEK_SET: 271b4e9af9fSdanielk1977 p->iSeek = offset; 272b4e9af9fSdanielk1977 break; 273b4e9af9fSdanielk1977 case SEEK_CUR: 274b4e9af9fSdanielk1977 p->iSeek += offset; 275b4e9af9fSdanielk1977 break; 276b4e9af9fSdanielk1977 case SEEK_END: 277b4e9af9fSdanielk1977 p->iSeek = sqlite3_blob_bytes(p->pBlob) + offset; 278b4e9af9fSdanielk1977 break; 279b4e9af9fSdanielk1977 280b4e9af9fSdanielk1977 default: assert(!"Bad seekMode"); 281b4e9af9fSdanielk1977 } 282b4e9af9fSdanielk1977 283b4e9af9fSdanielk1977 return p->iSeek; 284b4e9af9fSdanielk1977 } 285b4e9af9fSdanielk1977 286b4e9af9fSdanielk1977 287b4e9af9fSdanielk1977 static void incrblobWatch(ClientData instanceData, int mode){ 288b4e9af9fSdanielk1977 /* NO-OP */ 289b4e9af9fSdanielk1977 } 290b4e9af9fSdanielk1977 static int incrblobHandle(ClientData instanceData, int dir, ClientData *hPtr){ 291b4e9af9fSdanielk1977 return TCL_ERROR; 292b4e9af9fSdanielk1977 } 293b4e9af9fSdanielk1977 294b4e9af9fSdanielk1977 static Tcl_ChannelType IncrblobChannelType = { 295b4e9af9fSdanielk1977 "incrblob", /* typeName */ 296b4e9af9fSdanielk1977 TCL_CHANNEL_VERSION_2, /* version */ 297b4e9af9fSdanielk1977 incrblobClose, /* closeProc */ 298b4e9af9fSdanielk1977 incrblobInput, /* inputProc */ 299b4e9af9fSdanielk1977 incrblobOutput, /* outputProc */ 300b4e9af9fSdanielk1977 incrblobSeek, /* seekProc */ 301b4e9af9fSdanielk1977 0, /* setOptionProc */ 302b4e9af9fSdanielk1977 0, /* getOptionProc */ 303b4e9af9fSdanielk1977 incrblobWatch, /* watchProc (this is a no-op) */ 304b4e9af9fSdanielk1977 incrblobHandle, /* getHandleProc (always returns error) */ 305b4e9af9fSdanielk1977 0, /* close2Proc */ 306b4e9af9fSdanielk1977 0, /* blockModeProc */ 307b4e9af9fSdanielk1977 0, /* flushProc */ 308b4e9af9fSdanielk1977 0, /* handlerProc */ 309b4e9af9fSdanielk1977 0, /* wideSeekProc */ 310b4e9af9fSdanielk1977 }; 311b4e9af9fSdanielk1977 312b4e9af9fSdanielk1977 /* 313b4e9af9fSdanielk1977 ** Create a new incrblob channel. 314b4e9af9fSdanielk1977 */ 315b4e9af9fSdanielk1977 static int createIncrblobChannel( 316b4e9af9fSdanielk1977 Tcl_Interp *interp, 317b4e9af9fSdanielk1977 SqliteDb *pDb, 318b4e9af9fSdanielk1977 const char *zDb, 319b4e9af9fSdanielk1977 const char *zTable, 320b4e9af9fSdanielk1977 const char *zColumn, 3218cbadb02Sdanielk1977 sqlite_int64 iRow, 3228cbadb02Sdanielk1977 int isReadonly 323b4e9af9fSdanielk1977 ){ 324b4e9af9fSdanielk1977 IncrblobChannel *p; 3258cbadb02Sdanielk1977 sqlite3 *db = pDb->db; 326b4e9af9fSdanielk1977 sqlite3_blob *pBlob; 327b4e9af9fSdanielk1977 int rc; 3288cbadb02Sdanielk1977 int flags = TCL_READABLE|(isReadonly ? 0 : TCL_WRITABLE); 329b4e9af9fSdanielk1977 330b4e9af9fSdanielk1977 /* This variable is used to name the channels: "incrblob_[incr count]" */ 331b4e9af9fSdanielk1977 static int count = 0; 332b4e9af9fSdanielk1977 char zChannel[64]; 333b4e9af9fSdanielk1977 3348cbadb02Sdanielk1977 rc = sqlite3_blob_open(db, zDb, zTable, zColumn, iRow, !isReadonly, &pBlob); 335b4e9af9fSdanielk1977 if( rc!=SQLITE_OK ){ 336b4e9af9fSdanielk1977 Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE); 337b4e9af9fSdanielk1977 return TCL_ERROR; 338b4e9af9fSdanielk1977 } 339b4e9af9fSdanielk1977 340b4e9af9fSdanielk1977 p = (IncrblobChannel *)Tcl_Alloc(sizeof(IncrblobChannel)); 341b4e9af9fSdanielk1977 p->iSeek = 0; 342b4e9af9fSdanielk1977 p->pBlob = pBlob; 343b4e9af9fSdanielk1977 3445bb3eb9bSdrh sqlite3_snprintf(sizeof(zChannel), zChannel, "incrblob_%d", ++count); 345d0441796Sdanielk1977 p->channel = Tcl_CreateChannel(&IncrblobChannelType, zChannel, p, flags); 346d0441796Sdanielk1977 Tcl_RegisterChannel(interp, p->channel); 347b4e9af9fSdanielk1977 348d0441796Sdanielk1977 /* Link the new channel into the SqliteDb.pIncrblob list. */ 349d0441796Sdanielk1977 p->pNext = pDb->pIncrblob; 350d0441796Sdanielk1977 p->pPrev = 0; 351d0441796Sdanielk1977 if( p->pNext ){ 352d0441796Sdanielk1977 p->pNext->pPrev = p; 353d0441796Sdanielk1977 } 354d0441796Sdanielk1977 pDb->pIncrblob = p; 355d0441796Sdanielk1977 p->pDb = pDb; 356d0441796Sdanielk1977 357d0441796Sdanielk1977 Tcl_SetResult(interp, (char *)Tcl_GetChannelName(p->channel), TCL_VOLATILE); 358b4e9af9fSdanielk1977 return TCL_OK; 359b4e9af9fSdanielk1977 } 36032a0d8bbSdanielk1977 #else /* else clause for "#ifndef SQLITE_OMIT_INCRBLOB" */ 36132a0d8bbSdanielk1977 #define closeIncrblobChannels(pDb) 36232a0d8bbSdanielk1977 #endif 363b4e9af9fSdanielk1977 3646d31316cSdrh /* 365d1e4733dSdrh ** Look at the script prefix in pCmd. We will be executing this script 366d1e4733dSdrh ** after first appending one or more arguments. This routine analyzes 367d1e4733dSdrh ** the script to see if it is safe to use Tcl_EvalObjv() on the script 368d1e4733dSdrh ** rather than the more general Tcl_EvalEx(). Tcl_EvalObjv() is much 369d1e4733dSdrh ** faster. 370d1e4733dSdrh ** 371d1e4733dSdrh ** Scripts that are safe to use with Tcl_EvalObjv() consists of a 372d1e4733dSdrh ** command name followed by zero or more arguments with no [...] or $ 373d1e4733dSdrh ** or {...} or ; to be seen anywhere. Most callback scripts consist 374d1e4733dSdrh ** of just a single procedure name and they meet this requirement. 375d1e4733dSdrh */ 376d1e4733dSdrh static int safeToUseEvalObjv(Tcl_Interp *interp, Tcl_Obj *pCmd){ 377d1e4733dSdrh /* We could try to do something with Tcl_Parse(). But we will instead 378d1e4733dSdrh ** just do a search for forbidden characters. If any of the forbidden 379d1e4733dSdrh ** characters appear in pCmd, we will report the string as unsafe. 380d1e4733dSdrh */ 381d1e4733dSdrh const char *z; 382d1e4733dSdrh int n; 383d1e4733dSdrh z = Tcl_GetStringFromObj(pCmd, &n); 384d1e4733dSdrh while( n-- > 0 ){ 385d1e4733dSdrh int c = *(z++); 386d1e4733dSdrh if( c=='$' || c=='[' || c==';' ) return 0; 387d1e4733dSdrh } 388d1e4733dSdrh return 1; 389d1e4733dSdrh } 390d1e4733dSdrh 391d1e4733dSdrh /* 392d1e4733dSdrh ** Find an SqlFunc structure with the given name. Or create a new 393d1e4733dSdrh ** one if an existing one cannot be found. Return a pointer to the 394d1e4733dSdrh ** structure. 395d1e4733dSdrh */ 396d1e4733dSdrh static SqlFunc *findSqlFunc(SqliteDb *pDb, const char *zName){ 397d1e4733dSdrh SqlFunc *p, *pNew; 398d1e4733dSdrh int i; 3994f21c4afSdrh pNew = (SqlFunc*)Tcl_Alloc( sizeof(*pNew) + strlen30(zName) + 1 ); 400d1e4733dSdrh pNew->zName = (char*)&pNew[1]; 401d1e4733dSdrh for(i=0; zName[i]; i++){ pNew->zName[i] = tolower(zName[i]); } 402d1e4733dSdrh pNew->zName[i] = 0; 403d1e4733dSdrh for(p=pDb->pFunc; p; p=p->pNext){ 404d1e4733dSdrh if( strcmp(p->zName, pNew->zName)==0 ){ 405d1e4733dSdrh Tcl_Free((char*)pNew); 406d1e4733dSdrh return p; 407d1e4733dSdrh } 408d1e4733dSdrh } 409d1e4733dSdrh pNew->interp = pDb->interp; 410d1e4733dSdrh pNew->pScript = 0; 411d1e4733dSdrh pNew->pNext = pDb->pFunc; 412d1e4733dSdrh pDb->pFunc = pNew; 413d1e4733dSdrh return pNew; 414d1e4733dSdrh } 415d1e4733dSdrh 416d1e4733dSdrh /* 417fb7e7651Sdrh ** Finalize and free a list of prepared statements 418fb7e7651Sdrh */ 419fb7e7651Sdrh static void flushStmtCache( SqliteDb *pDb ){ 420fb7e7651Sdrh SqlPreparedStmt *pPreStmt; 421fb7e7651Sdrh 422fb7e7651Sdrh while( pDb->stmtList ){ 423fb7e7651Sdrh sqlite3_finalize( pDb->stmtList->pStmt ); 424fb7e7651Sdrh pPreStmt = pDb->stmtList; 425fb7e7651Sdrh pDb->stmtList = pDb->stmtList->pNext; 426fb7e7651Sdrh Tcl_Free( (char*)pPreStmt ); 427fb7e7651Sdrh } 428fb7e7651Sdrh pDb->nStmt = 0; 429fb7e7651Sdrh pDb->stmtLast = 0; 430fb7e7651Sdrh } 431fb7e7651Sdrh 432fb7e7651Sdrh /* 433895d7472Sdrh ** TCL calls this procedure when an sqlite3 database command is 434895d7472Sdrh ** deleted. 43575897234Sdrh */ 43675897234Sdrh static void DbDeleteCmd(void *db){ 437bec3f402Sdrh SqliteDb *pDb = (SqliteDb*)db; 438fb7e7651Sdrh flushStmtCache(pDb); 439d0441796Sdanielk1977 closeIncrblobChannels(pDb); 4406f8a503dSdanielk1977 sqlite3_close(pDb->db); 441cabb0819Sdrh while( pDb->pFunc ){ 442cabb0819Sdrh SqlFunc *pFunc = pDb->pFunc; 443cabb0819Sdrh pDb->pFunc = pFunc->pNext; 444d1e4733dSdrh Tcl_DecrRefCount(pFunc->pScript); 445cabb0819Sdrh Tcl_Free((char*)pFunc); 446cabb0819Sdrh } 4470202b29eSdanielk1977 while( pDb->pCollate ){ 4480202b29eSdanielk1977 SqlCollate *pCollate = pDb->pCollate; 4490202b29eSdanielk1977 pDb->pCollate = pCollate->pNext; 4500202b29eSdanielk1977 Tcl_Free((char*)pCollate); 4510202b29eSdanielk1977 } 452bec3f402Sdrh if( pDb->zBusy ){ 453bec3f402Sdrh Tcl_Free(pDb->zBusy); 454bec3f402Sdrh } 455b5a20d3cSdrh if( pDb->zTrace ){ 456b5a20d3cSdrh Tcl_Free(pDb->zTrace); 4570d1a643aSdrh } 45819e2d37fSdrh if( pDb->zProfile ){ 45919e2d37fSdrh Tcl_Free(pDb->zProfile); 46019e2d37fSdrh } 461e22a334bSdrh if( pDb->zAuth ){ 462e22a334bSdrh Tcl_Free(pDb->zAuth); 463e22a334bSdrh } 46455c45f2eSdanielk1977 if( pDb->zNull ){ 46555c45f2eSdanielk1977 Tcl_Free(pDb->zNull); 46655c45f2eSdanielk1977 } 46794eb6a14Sdanielk1977 if( pDb->pUpdateHook ){ 46894eb6a14Sdanielk1977 Tcl_DecrRefCount(pDb->pUpdateHook); 46994eb6a14Sdanielk1977 } 47071fd80bfSdanielk1977 if( pDb->pRollbackHook ){ 47171fd80bfSdanielk1977 Tcl_DecrRefCount(pDb->pRollbackHook); 47271fd80bfSdanielk1977 } 47394eb6a14Sdanielk1977 if( pDb->pCollateNeeded ){ 47494eb6a14Sdanielk1977 Tcl_DecrRefCount(pDb->pCollateNeeded); 47594eb6a14Sdanielk1977 } 476bec3f402Sdrh Tcl_Free((char*)pDb); 477bec3f402Sdrh } 478bec3f402Sdrh 479bec3f402Sdrh /* 480bec3f402Sdrh ** This routine is called when a database file is locked while trying 481bec3f402Sdrh ** to execute SQL. 482bec3f402Sdrh */ 4832a764eb0Sdanielk1977 static int DbBusyHandler(void *cd, int nTries){ 484bec3f402Sdrh SqliteDb *pDb = (SqliteDb*)cd; 485bec3f402Sdrh int rc; 486bec3f402Sdrh char zVal[30]; 487bec3f402Sdrh 4885bb3eb9bSdrh sqlite3_snprintf(sizeof(zVal), zVal, "%d", nTries); 489d1e4733dSdrh rc = Tcl_VarEval(pDb->interp, pDb->zBusy, " ", zVal, (char*)0); 490bec3f402Sdrh if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){ 491bec3f402Sdrh return 0; 492bec3f402Sdrh } 493bec3f402Sdrh return 1; 49475897234Sdrh } 49575897234Sdrh 49626e4a8b1Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK 49775897234Sdrh /* 498348bb5d6Sdanielk1977 ** This routine is invoked as the 'progress callback' for the database. 499348bb5d6Sdanielk1977 */ 500348bb5d6Sdanielk1977 static int DbProgressHandler(void *cd){ 501348bb5d6Sdanielk1977 SqliteDb *pDb = (SqliteDb*)cd; 502348bb5d6Sdanielk1977 int rc; 503348bb5d6Sdanielk1977 504348bb5d6Sdanielk1977 assert( pDb->zProgress ); 505348bb5d6Sdanielk1977 rc = Tcl_Eval(pDb->interp, pDb->zProgress); 506348bb5d6Sdanielk1977 if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){ 507348bb5d6Sdanielk1977 return 1; 508348bb5d6Sdanielk1977 } 509348bb5d6Sdanielk1977 return 0; 510348bb5d6Sdanielk1977 } 51126e4a8b1Sdrh #endif 512348bb5d6Sdanielk1977 513d1167393Sdrh #ifndef SQLITE_OMIT_TRACE 514348bb5d6Sdanielk1977 /* 515b5a20d3cSdrh ** This routine is called by the SQLite trace handler whenever a new 516b5a20d3cSdrh ** block of SQL is executed. The TCL script in pDb->zTrace is executed. 5170d1a643aSdrh */ 518b5a20d3cSdrh static void DbTraceHandler(void *cd, const char *zSql){ 5190d1a643aSdrh SqliteDb *pDb = (SqliteDb*)cd; 520b5a20d3cSdrh Tcl_DString str; 5210d1a643aSdrh 522b5a20d3cSdrh Tcl_DStringInit(&str); 523b5a20d3cSdrh Tcl_DStringAppend(&str, pDb->zTrace, -1); 524b5a20d3cSdrh Tcl_DStringAppendElement(&str, zSql); 525b5a20d3cSdrh Tcl_Eval(pDb->interp, Tcl_DStringValue(&str)); 526b5a20d3cSdrh Tcl_DStringFree(&str); 527b5a20d3cSdrh Tcl_ResetResult(pDb->interp); 5280d1a643aSdrh } 529d1167393Sdrh #endif 5300d1a643aSdrh 531d1167393Sdrh #ifndef SQLITE_OMIT_TRACE 5320d1a643aSdrh /* 53319e2d37fSdrh ** This routine is called by the SQLite profile handler after a statement 53419e2d37fSdrh ** SQL has executed. The TCL script in pDb->zProfile is evaluated. 53519e2d37fSdrh */ 53619e2d37fSdrh static void DbProfileHandler(void *cd, const char *zSql, sqlite_uint64 tm){ 53719e2d37fSdrh SqliteDb *pDb = (SqliteDb*)cd; 53819e2d37fSdrh Tcl_DString str; 53919e2d37fSdrh char zTm[100]; 54019e2d37fSdrh 54119e2d37fSdrh sqlite3_snprintf(sizeof(zTm)-1, zTm, "%lld", tm); 54219e2d37fSdrh Tcl_DStringInit(&str); 54319e2d37fSdrh Tcl_DStringAppend(&str, pDb->zProfile, -1); 54419e2d37fSdrh Tcl_DStringAppendElement(&str, zSql); 54519e2d37fSdrh Tcl_DStringAppendElement(&str, zTm); 54619e2d37fSdrh Tcl_Eval(pDb->interp, Tcl_DStringValue(&str)); 54719e2d37fSdrh Tcl_DStringFree(&str); 54819e2d37fSdrh Tcl_ResetResult(pDb->interp); 54919e2d37fSdrh } 550d1167393Sdrh #endif 55119e2d37fSdrh 55219e2d37fSdrh /* 553aa940eacSdrh ** This routine is called when a transaction is committed. The 554aa940eacSdrh ** TCL script in pDb->zCommit is executed. If it returns non-zero or 555aa940eacSdrh ** if it throws an exception, the transaction is rolled back instead 556aa940eacSdrh ** of being committed. 557aa940eacSdrh */ 558aa940eacSdrh static int DbCommitHandler(void *cd){ 559aa940eacSdrh SqliteDb *pDb = (SqliteDb*)cd; 560aa940eacSdrh int rc; 561aa940eacSdrh 562aa940eacSdrh rc = Tcl_Eval(pDb->interp, pDb->zCommit); 563aa940eacSdrh if( rc!=TCL_OK || atoi(Tcl_GetStringResult(pDb->interp)) ){ 564aa940eacSdrh return 1; 565aa940eacSdrh } 566aa940eacSdrh return 0; 567aa940eacSdrh } 568aa940eacSdrh 56971fd80bfSdanielk1977 static void DbRollbackHandler(void *clientData){ 57071fd80bfSdanielk1977 SqliteDb *pDb = (SqliteDb*)clientData; 57171fd80bfSdanielk1977 assert(pDb->pRollbackHook); 57271fd80bfSdanielk1977 if( TCL_OK!=Tcl_EvalObjEx(pDb->interp, pDb->pRollbackHook, 0) ){ 57371fd80bfSdanielk1977 Tcl_BackgroundError(pDb->interp); 57471fd80bfSdanielk1977 } 57571fd80bfSdanielk1977 } 57671fd80bfSdanielk1977 57794eb6a14Sdanielk1977 static void DbUpdateHandler( 57894eb6a14Sdanielk1977 void *p, 57994eb6a14Sdanielk1977 int op, 58094eb6a14Sdanielk1977 const char *zDb, 58194eb6a14Sdanielk1977 const char *zTbl, 58294eb6a14Sdanielk1977 sqlite_int64 rowid 58394eb6a14Sdanielk1977 ){ 58494eb6a14Sdanielk1977 SqliteDb *pDb = (SqliteDb *)p; 58594eb6a14Sdanielk1977 Tcl_Obj *pCmd; 58694eb6a14Sdanielk1977 58794eb6a14Sdanielk1977 assert( pDb->pUpdateHook ); 58894eb6a14Sdanielk1977 assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE ); 58994eb6a14Sdanielk1977 59094eb6a14Sdanielk1977 pCmd = Tcl_DuplicateObj(pDb->pUpdateHook); 59194eb6a14Sdanielk1977 Tcl_IncrRefCount(pCmd); 59294eb6a14Sdanielk1977 Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj( 59394eb6a14Sdanielk1977 ( (op==SQLITE_INSERT)?"INSERT":(op==SQLITE_UPDATE)?"UPDATE":"DELETE"), -1)); 59494eb6a14Sdanielk1977 Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zDb, -1)); 59594eb6a14Sdanielk1977 Tcl_ListObjAppendElement(0, pCmd, Tcl_NewStringObj(zTbl, -1)); 59694eb6a14Sdanielk1977 Tcl_ListObjAppendElement(0, pCmd, Tcl_NewWideIntObj(rowid)); 59794eb6a14Sdanielk1977 Tcl_EvalObjEx(pDb->interp, pCmd, TCL_EVAL_DIRECT); 59894eb6a14Sdanielk1977 } 59994eb6a14Sdanielk1977 6007cedc8d4Sdanielk1977 static void tclCollateNeeded( 6017cedc8d4Sdanielk1977 void *pCtx, 6029bb575fdSdrh sqlite3 *db, 6037cedc8d4Sdanielk1977 int enc, 6047cedc8d4Sdanielk1977 const char *zName 6057cedc8d4Sdanielk1977 ){ 6067cedc8d4Sdanielk1977 SqliteDb *pDb = (SqliteDb *)pCtx; 6077cedc8d4Sdanielk1977 Tcl_Obj *pScript = Tcl_DuplicateObj(pDb->pCollateNeeded); 6087cedc8d4Sdanielk1977 Tcl_IncrRefCount(pScript); 6097cedc8d4Sdanielk1977 Tcl_ListObjAppendElement(0, pScript, Tcl_NewStringObj(zName, -1)); 6107cedc8d4Sdanielk1977 Tcl_EvalObjEx(pDb->interp, pScript, 0); 6117cedc8d4Sdanielk1977 Tcl_DecrRefCount(pScript); 6127cedc8d4Sdanielk1977 } 6137cedc8d4Sdanielk1977 614aa940eacSdrh /* 6150202b29eSdanielk1977 ** This routine is called to evaluate an SQL collation function implemented 6160202b29eSdanielk1977 ** using TCL script. 6170202b29eSdanielk1977 */ 6180202b29eSdanielk1977 static int tclSqlCollate( 6190202b29eSdanielk1977 void *pCtx, 6200202b29eSdanielk1977 int nA, 6210202b29eSdanielk1977 const void *zA, 6220202b29eSdanielk1977 int nB, 6230202b29eSdanielk1977 const void *zB 6240202b29eSdanielk1977 ){ 6250202b29eSdanielk1977 SqlCollate *p = (SqlCollate *)pCtx; 6260202b29eSdanielk1977 Tcl_Obj *pCmd; 6270202b29eSdanielk1977 6280202b29eSdanielk1977 pCmd = Tcl_NewStringObj(p->zScript, -1); 6290202b29eSdanielk1977 Tcl_IncrRefCount(pCmd); 6300202b29eSdanielk1977 Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zA, nA)); 6310202b29eSdanielk1977 Tcl_ListObjAppendElement(p->interp, pCmd, Tcl_NewStringObj(zB, nB)); 632d1e4733dSdrh Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT); 6330202b29eSdanielk1977 Tcl_DecrRefCount(pCmd); 6340202b29eSdanielk1977 return (atoi(Tcl_GetStringResult(p->interp))); 6350202b29eSdanielk1977 } 6360202b29eSdanielk1977 6370202b29eSdanielk1977 /* 638cabb0819Sdrh ** This routine is called to evaluate an SQL function implemented 639cabb0819Sdrh ** using TCL script. 640cabb0819Sdrh */ 6410ae8b831Sdanielk1977 static void tclSqlFunc(sqlite3_context *context, int argc, sqlite3_value**argv){ 6426f8a503dSdanielk1977 SqlFunc *p = sqlite3_user_data(context); 643d1e4733dSdrh Tcl_Obj *pCmd; 644cabb0819Sdrh int i; 645cabb0819Sdrh int rc; 646cabb0819Sdrh 647d1e4733dSdrh if( argc==0 ){ 648d1e4733dSdrh /* If there are no arguments to the function, call Tcl_EvalObjEx on the 649d1e4733dSdrh ** script object directly. This allows the TCL compiler to generate 650d1e4733dSdrh ** bytecode for the command on the first invocation and thus make 651d1e4733dSdrh ** subsequent invocations much faster. */ 652d1e4733dSdrh pCmd = p->pScript; 653d1e4733dSdrh Tcl_IncrRefCount(pCmd); 654d1e4733dSdrh rc = Tcl_EvalObjEx(p->interp, pCmd, 0); 655d1e4733dSdrh Tcl_DecrRefCount(pCmd); 65651ad0ecdSdanielk1977 }else{ 657d1e4733dSdrh /* If there are arguments to the function, make a shallow copy of the 658d1e4733dSdrh ** script object, lappend the arguments, then evaluate the copy. 659d1e4733dSdrh ** 660d1e4733dSdrh ** By "shallow" copy, we mean a only the outer list Tcl_Obj is duplicated. 661d1e4733dSdrh ** The new Tcl_Obj contains pointers to the original list elements. 662d1e4733dSdrh ** That way, when Tcl_EvalObjv() is run and shimmers the first element 663d1e4733dSdrh ** of the list to tclCmdNameType, that alternate representation will 664d1e4733dSdrh ** be preserved and reused on the next invocation. 665d1e4733dSdrh */ 666d1e4733dSdrh Tcl_Obj **aArg; 667d1e4733dSdrh int nArg; 668d1e4733dSdrh if( Tcl_ListObjGetElements(p->interp, p->pScript, &nArg, &aArg) ){ 669d1e4733dSdrh sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1); 670d1e4733dSdrh return; 671d1e4733dSdrh } 672d1e4733dSdrh pCmd = Tcl_NewListObj(nArg, aArg); 673d1e4733dSdrh Tcl_IncrRefCount(pCmd); 674d1e4733dSdrh for(i=0; i<argc; i++){ 675d1e4733dSdrh sqlite3_value *pIn = argv[i]; 676d1e4733dSdrh Tcl_Obj *pVal; 677d1e4733dSdrh 678d1e4733dSdrh /* Set pVal to contain the i'th column of this row. */ 679d1e4733dSdrh switch( sqlite3_value_type(pIn) ){ 680d1e4733dSdrh case SQLITE_BLOB: { 681d1e4733dSdrh int bytes = sqlite3_value_bytes(pIn); 682d1e4733dSdrh pVal = Tcl_NewByteArrayObj(sqlite3_value_blob(pIn), bytes); 683d1e4733dSdrh break; 684d1e4733dSdrh } 685d1e4733dSdrh case SQLITE_INTEGER: { 686d1e4733dSdrh sqlite_int64 v = sqlite3_value_int64(pIn); 687d1e4733dSdrh if( v>=-2147483647 && v<=2147483647 ){ 688d1e4733dSdrh pVal = Tcl_NewIntObj(v); 689d1e4733dSdrh }else{ 690d1e4733dSdrh pVal = Tcl_NewWideIntObj(v); 691d1e4733dSdrh } 692d1e4733dSdrh break; 693d1e4733dSdrh } 694d1e4733dSdrh case SQLITE_FLOAT: { 695d1e4733dSdrh double r = sqlite3_value_double(pIn); 696d1e4733dSdrh pVal = Tcl_NewDoubleObj(r); 697d1e4733dSdrh break; 698d1e4733dSdrh } 699d1e4733dSdrh case SQLITE_NULL: { 700d1e4733dSdrh pVal = Tcl_NewStringObj("", 0); 701d1e4733dSdrh break; 702d1e4733dSdrh } 703d1e4733dSdrh default: { 704d1e4733dSdrh int bytes = sqlite3_value_bytes(pIn); 70500fd957bSdanielk1977 pVal = Tcl_NewStringObj((char *)sqlite3_value_text(pIn), bytes); 706d1e4733dSdrh break; 70751ad0ecdSdanielk1977 } 708cabb0819Sdrh } 709d1e4733dSdrh rc = Tcl_ListObjAppendElement(p->interp, pCmd, pVal); 710d1e4733dSdrh if( rc ){ 711d1e4733dSdrh Tcl_DecrRefCount(pCmd); 712d1e4733dSdrh sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1); 713d1e4733dSdrh return; 714d1e4733dSdrh } 715d1e4733dSdrh } 716d1e4733dSdrh if( !p->useEvalObjv ){ 717d1e4733dSdrh /* Tcl_EvalObjEx() will automatically call Tcl_EvalObjv() if pCmd 718d1e4733dSdrh ** is a list without a string representation. To prevent this from 719d1e4733dSdrh ** happening, make sure pCmd has a valid string representation */ 720d1e4733dSdrh Tcl_GetString(pCmd); 721d1e4733dSdrh } 722d1e4733dSdrh rc = Tcl_EvalObjEx(p->interp, pCmd, TCL_EVAL_DIRECT); 723d1e4733dSdrh Tcl_DecrRefCount(pCmd); 724d1e4733dSdrh } 725562e8d3cSdanielk1977 726c7f269d5Sdrh if( rc && rc!=TCL_RETURN ){ 7277e18c259Sdanielk1977 sqlite3_result_error(context, Tcl_GetStringResult(p->interp), -1); 728cabb0819Sdrh }else{ 729c7f269d5Sdrh Tcl_Obj *pVar = Tcl_GetObjResult(p->interp); 730c7f269d5Sdrh int n; 731c7f269d5Sdrh u8 *data; 732c7f269d5Sdrh char *zType = pVar->typePtr ? pVar->typePtr->name : ""; 733c7f269d5Sdrh char c = zType[0]; 734df0bddaeSdrh if( c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0 ){ 735d1e4733dSdrh /* Only return a BLOB type if the Tcl variable is a bytearray and 736df0bddaeSdrh ** has no string representation. */ 737c7f269d5Sdrh data = Tcl_GetByteArrayFromObj(pVar, &n); 738c7f269d5Sdrh sqlite3_result_blob(context, data, n, SQLITE_TRANSIENT); 739985e0c63Sdrh }else if( c=='b' && strcmp(zType,"boolean")==0 ){ 740c7f269d5Sdrh Tcl_GetIntFromObj(0, pVar, &n); 741c7f269d5Sdrh sqlite3_result_int(context, n); 742c7f269d5Sdrh }else if( c=='d' && strcmp(zType,"double")==0 ){ 743c7f269d5Sdrh double r; 744c7f269d5Sdrh Tcl_GetDoubleFromObj(0, pVar, &r); 745c7f269d5Sdrh sqlite3_result_double(context, r); 746985e0c63Sdrh }else if( (c=='w' && strcmp(zType,"wideInt")==0) || 747985e0c63Sdrh (c=='i' && strcmp(zType,"int")==0) ){ 748df0bddaeSdrh Tcl_WideInt v; 749df0bddaeSdrh Tcl_GetWideIntFromObj(0, pVar, &v); 750df0bddaeSdrh sqlite3_result_int64(context, v); 751c7f269d5Sdrh }else{ 75200fd957bSdanielk1977 data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n); 75300fd957bSdanielk1977 sqlite3_result_text(context, (char *)data, n, SQLITE_TRANSIENT); 754c7f269d5Sdrh } 755cabb0819Sdrh } 756cabb0819Sdrh } 757895d7472Sdrh 758e22a334bSdrh #ifndef SQLITE_OMIT_AUTHORIZATION 759e22a334bSdrh /* 760e22a334bSdrh ** This is the authentication function. It appends the authentication 761e22a334bSdrh ** type code and the two arguments to zCmd[] then invokes the result 762e22a334bSdrh ** on the interpreter. The reply is examined to determine if the 763e22a334bSdrh ** authentication fails or succeeds. 764e22a334bSdrh */ 765e22a334bSdrh static int auth_callback( 766e22a334bSdrh void *pArg, 767e22a334bSdrh int code, 768e22a334bSdrh const char *zArg1, 769e22a334bSdrh const char *zArg2, 770e22a334bSdrh const char *zArg3, 771e22a334bSdrh const char *zArg4 772e22a334bSdrh ){ 773e22a334bSdrh char *zCode; 774e22a334bSdrh Tcl_DString str; 775e22a334bSdrh int rc; 776e22a334bSdrh const char *zReply; 777e22a334bSdrh SqliteDb *pDb = (SqliteDb*)pArg; 7781f1549f8Sdrh if( pDb->disableAuth ) return SQLITE_OK; 779e22a334bSdrh 780e22a334bSdrh switch( code ){ 781e22a334bSdrh case SQLITE_COPY : zCode="SQLITE_COPY"; break; 782e22a334bSdrh case SQLITE_CREATE_INDEX : zCode="SQLITE_CREATE_INDEX"; break; 783e22a334bSdrh case SQLITE_CREATE_TABLE : zCode="SQLITE_CREATE_TABLE"; break; 784e22a334bSdrh case SQLITE_CREATE_TEMP_INDEX : zCode="SQLITE_CREATE_TEMP_INDEX"; break; 785e22a334bSdrh case SQLITE_CREATE_TEMP_TABLE : zCode="SQLITE_CREATE_TEMP_TABLE"; break; 786e22a334bSdrh case SQLITE_CREATE_TEMP_TRIGGER: zCode="SQLITE_CREATE_TEMP_TRIGGER"; break; 787e22a334bSdrh case SQLITE_CREATE_TEMP_VIEW : zCode="SQLITE_CREATE_TEMP_VIEW"; break; 788e22a334bSdrh case SQLITE_CREATE_TRIGGER : zCode="SQLITE_CREATE_TRIGGER"; break; 789e22a334bSdrh case SQLITE_CREATE_VIEW : zCode="SQLITE_CREATE_VIEW"; break; 790e22a334bSdrh case SQLITE_DELETE : zCode="SQLITE_DELETE"; break; 791e22a334bSdrh case SQLITE_DROP_INDEX : zCode="SQLITE_DROP_INDEX"; break; 792e22a334bSdrh case SQLITE_DROP_TABLE : zCode="SQLITE_DROP_TABLE"; break; 793e22a334bSdrh case SQLITE_DROP_TEMP_INDEX : zCode="SQLITE_DROP_TEMP_INDEX"; break; 794e22a334bSdrh case SQLITE_DROP_TEMP_TABLE : zCode="SQLITE_DROP_TEMP_TABLE"; break; 795e22a334bSdrh case SQLITE_DROP_TEMP_TRIGGER : zCode="SQLITE_DROP_TEMP_TRIGGER"; break; 796e22a334bSdrh case SQLITE_DROP_TEMP_VIEW : zCode="SQLITE_DROP_TEMP_VIEW"; break; 797e22a334bSdrh case SQLITE_DROP_TRIGGER : zCode="SQLITE_DROP_TRIGGER"; break; 798e22a334bSdrh case SQLITE_DROP_VIEW : zCode="SQLITE_DROP_VIEW"; break; 799e22a334bSdrh case SQLITE_INSERT : zCode="SQLITE_INSERT"; break; 800e22a334bSdrh case SQLITE_PRAGMA : zCode="SQLITE_PRAGMA"; break; 801e22a334bSdrh case SQLITE_READ : zCode="SQLITE_READ"; break; 802e22a334bSdrh case SQLITE_SELECT : zCode="SQLITE_SELECT"; break; 803e22a334bSdrh case SQLITE_TRANSACTION : zCode="SQLITE_TRANSACTION"; break; 804e22a334bSdrh case SQLITE_UPDATE : zCode="SQLITE_UPDATE"; break; 80581e293b4Sdrh case SQLITE_ATTACH : zCode="SQLITE_ATTACH"; break; 80681e293b4Sdrh case SQLITE_DETACH : zCode="SQLITE_DETACH"; break; 8071c8c23ccSdanielk1977 case SQLITE_ALTER_TABLE : zCode="SQLITE_ALTER_TABLE"; break; 8081d54df88Sdanielk1977 case SQLITE_REINDEX : zCode="SQLITE_REINDEX"; break; 809e6e04969Sdrh case SQLITE_ANALYZE : zCode="SQLITE_ANALYZE"; break; 810f1a381e7Sdanielk1977 case SQLITE_CREATE_VTABLE : zCode="SQLITE_CREATE_VTABLE"; break; 811f1a381e7Sdanielk1977 case SQLITE_DROP_VTABLE : zCode="SQLITE_DROP_VTABLE"; break; 8125169bbc6Sdrh case SQLITE_FUNCTION : zCode="SQLITE_FUNCTION"; break; 813ab9b703fSdanielk1977 case SQLITE_SAVEPOINT : zCode="SQLITE_SAVEPOINT"; break; 814e22a334bSdrh default : zCode="????"; break; 815e22a334bSdrh } 816e22a334bSdrh Tcl_DStringInit(&str); 817e22a334bSdrh Tcl_DStringAppend(&str, pDb->zAuth, -1); 818e22a334bSdrh Tcl_DStringAppendElement(&str, zCode); 819e22a334bSdrh Tcl_DStringAppendElement(&str, zArg1 ? zArg1 : ""); 820e22a334bSdrh Tcl_DStringAppendElement(&str, zArg2 ? zArg2 : ""); 821e22a334bSdrh Tcl_DStringAppendElement(&str, zArg3 ? zArg3 : ""); 822e22a334bSdrh Tcl_DStringAppendElement(&str, zArg4 ? zArg4 : ""); 823e22a334bSdrh rc = Tcl_GlobalEval(pDb->interp, Tcl_DStringValue(&str)); 824e22a334bSdrh Tcl_DStringFree(&str); 825e22a334bSdrh zReply = Tcl_GetStringResult(pDb->interp); 826e22a334bSdrh if( strcmp(zReply,"SQLITE_OK")==0 ){ 827e22a334bSdrh rc = SQLITE_OK; 828e22a334bSdrh }else if( strcmp(zReply,"SQLITE_DENY")==0 ){ 829e22a334bSdrh rc = SQLITE_DENY; 830e22a334bSdrh }else if( strcmp(zReply,"SQLITE_IGNORE")==0 ){ 831e22a334bSdrh rc = SQLITE_IGNORE; 832e22a334bSdrh }else{ 833e22a334bSdrh rc = 999; 834e22a334bSdrh } 835e22a334bSdrh return rc; 836e22a334bSdrh } 837e22a334bSdrh #endif /* SQLITE_OMIT_AUTHORIZATION */ 838cabb0819Sdrh 839cabb0819Sdrh /* 840ef2cb63eSdanielk1977 ** zText is a pointer to text obtained via an sqlite3_result_text() 841ef2cb63eSdanielk1977 ** or similar interface. This routine returns a Tcl string object, 842ef2cb63eSdanielk1977 ** reference count set to 0, containing the text. If a translation 843ef2cb63eSdanielk1977 ** between iso8859 and UTF-8 is required, it is preformed. 844ef2cb63eSdanielk1977 */ 845ef2cb63eSdanielk1977 static Tcl_Obj *dbTextToObj(char const *zText){ 846ef2cb63eSdanielk1977 Tcl_Obj *pVal; 847ef2cb63eSdanielk1977 #ifdef UTF_TRANSLATION_NEEDED 848ef2cb63eSdanielk1977 Tcl_DString dCol; 849ef2cb63eSdanielk1977 Tcl_DStringInit(&dCol); 850ef2cb63eSdanielk1977 Tcl_ExternalToUtfDString(NULL, zText, -1, &dCol); 851ef2cb63eSdanielk1977 pVal = Tcl_NewStringObj(Tcl_DStringValue(&dCol), -1); 852ef2cb63eSdanielk1977 Tcl_DStringFree(&dCol); 853ef2cb63eSdanielk1977 #else 854ef2cb63eSdanielk1977 pVal = Tcl_NewStringObj(zText, -1); 855ef2cb63eSdanielk1977 #endif 856ef2cb63eSdanielk1977 return pVal; 857ef2cb63eSdanielk1977 } 858ef2cb63eSdanielk1977 859ef2cb63eSdanielk1977 /* 8601067fe11Stpoindex ** This routine reads a line of text from FILE in, stores 8611067fe11Stpoindex ** the text in memory obtained from malloc() and returns a pointer 8621067fe11Stpoindex ** to the text. NULL is returned at end of file, or if malloc() 8631067fe11Stpoindex ** fails. 8641067fe11Stpoindex ** 8651067fe11Stpoindex ** The interface is like "readline" but no command-line editing 8661067fe11Stpoindex ** is done. 8671067fe11Stpoindex ** 8681067fe11Stpoindex ** copied from shell.c from '.import' command 8691067fe11Stpoindex */ 8701067fe11Stpoindex static char *local_getline(char *zPrompt, FILE *in){ 8711067fe11Stpoindex char *zLine; 8721067fe11Stpoindex int nLine; 8731067fe11Stpoindex int n; 8741067fe11Stpoindex int eol; 8751067fe11Stpoindex 8761067fe11Stpoindex nLine = 100; 8771067fe11Stpoindex zLine = malloc( nLine ); 8781067fe11Stpoindex if( zLine==0 ) return 0; 8791067fe11Stpoindex n = 0; 8801067fe11Stpoindex eol = 0; 8811067fe11Stpoindex while( !eol ){ 8821067fe11Stpoindex if( n+100>nLine ){ 8831067fe11Stpoindex nLine = nLine*2 + 100; 8841067fe11Stpoindex zLine = realloc(zLine, nLine); 8851067fe11Stpoindex if( zLine==0 ) return 0; 8861067fe11Stpoindex } 8871067fe11Stpoindex if( fgets(&zLine[n], nLine - n, in)==0 ){ 8881067fe11Stpoindex if( n==0 ){ 8891067fe11Stpoindex free(zLine); 8901067fe11Stpoindex return 0; 8911067fe11Stpoindex } 8921067fe11Stpoindex zLine[n] = 0; 8931067fe11Stpoindex eol = 1; 8941067fe11Stpoindex break; 8951067fe11Stpoindex } 8961067fe11Stpoindex while( zLine[n] ){ n++; } 8971067fe11Stpoindex if( n>0 && zLine[n-1]=='\n' ){ 8981067fe11Stpoindex n--; 8991067fe11Stpoindex zLine[n] = 0; 9001067fe11Stpoindex eol = 1; 9011067fe11Stpoindex } 9021067fe11Stpoindex } 9031067fe11Stpoindex zLine = realloc( zLine, n+1 ); 9041067fe11Stpoindex return zLine; 9051067fe11Stpoindex } 9061067fe11Stpoindex 9078e556520Sdanielk1977 9088e556520Sdanielk1977 /* 9098e556520Sdanielk1977 ** Figure out the column names for the data returned by the statement 9108e556520Sdanielk1977 ** passed as the second argument. 9118e556520Sdanielk1977 ** 9128e556520Sdanielk1977 ** If parameter papColName is not NULL, then *papColName is set to point 9138e556520Sdanielk1977 ** at an array allocated using Tcl_Alloc(). It is the callers responsibility 9148e556520Sdanielk1977 ** to free this array using Tcl_Free(), and to decrement the reference 9158e556520Sdanielk1977 ** count of each Tcl_Obj* member of the array. 9168e556520Sdanielk1977 ** 9178e556520Sdanielk1977 ** The return value of this function is the number of columns of data 9188e556520Sdanielk1977 ** returned by pStmt (and hence the size of the *papColName array). 9198e556520Sdanielk1977 ** 9208e556520Sdanielk1977 ** If pArray is not NULL, then it contains the name of a Tcl array 9218e556520Sdanielk1977 ** variable. The "*" member of this array is set to a list containing 9228e556520Sdanielk1977 ** the names of the columns returned by the statement, in order from 9238e556520Sdanielk1977 ** left to right. e.g. if the names of the returned columns are a, b and 9248e556520Sdanielk1977 ** c, it does the equivalent of the tcl command: 9258e556520Sdanielk1977 ** 9268e556520Sdanielk1977 ** set ${pArray}(*) {a b c} 9278e556520Sdanielk1977 */ 9288e556520Sdanielk1977 static int 9298e556520Sdanielk1977 computeColumnNames( 9308e556520Sdanielk1977 Tcl_Interp *interp, 9318e556520Sdanielk1977 sqlite3_stmt *pStmt, /* SQL statement */ 9328e556520Sdanielk1977 Tcl_Obj ***papColName, /* OUT: Array of column names */ 9338e556520Sdanielk1977 Tcl_Obj *pArray /* Name of array variable (may be null) */ 9348e556520Sdanielk1977 ){ 9358e556520Sdanielk1977 int nCol; 9368e556520Sdanielk1977 9378e556520Sdanielk1977 /* Compute column names */ 9388e556520Sdanielk1977 nCol = sqlite3_column_count(pStmt); 9398e556520Sdanielk1977 if( papColName ){ 9408e556520Sdanielk1977 int i; 9418e556520Sdanielk1977 Tcl_Obj **apColName = (Tcl_Obj**)Tcl_Alloc( sizeof(Tcl_Obj*)*nCol ); 9428e556520Sdanielk1977 for(i=0; i<nCol; i++){ 9438e556520Sdanielk1977 apColName[i] = dbTextToObj(sqlite3_column_name(pStmt,i)); 9448e556520Sdanielk1977 Tcl_IncrRefCount(apColName[i]); 9458e556520Sdanielk1977 } 9468e556520Sdanielk1977 9478e556520Sdanielk1977 /* If results are being stored in an array variable, then create 9488e556520Sdanielk1977 ** the array(*) entry for that array 9498e556520Sdanielk1977 */ 9508e556520Sdanielk1977 if( pArray ){ 9518e556520Sdanielk1977 Tcl_Obj *pColList = Tcl_NewObj(); 9528e556520Sdanielk1977 Tcl_Obj *pStar = Tcl_NewStringObj("*", -1); 9538e556520Sdanielk1977 Tcl_IncrRefCount(pColList); 9548e556520Sdanielk1977 for(i=0; i<nCol; i++){ 9558e556520Sdanielk1977 Tcl_ListObjAppendElement(interp, pColList, apColName[i]); 9568e556520Sdanielk1977 } 9578e556520Sdanielk1977 Tcl_IncrRefCount(pStar); 9588e556520Sdanielk1977 Tcl_ObjSetVar2(interp, pArray, pStar, pColList,0); 9598e556520Sdanielk1977 Tcl_DecrRefCount(pColList); 9608e556520Sdanielk1977 Tcl_DecrRefCount(pStar); 9618e556520Sdanielk1977 } 9628e556520Sdanielk1977 *papColName = apColName; 9638e556520Sdanielk1977 } 9648e556520Sdanielk1977 9658e556520Sdanielk1977 return nCol; 9668e556520Sdanielk1977 } 9678e556520Sdanielk1977 9681067fe11Stpoindex /* 96975897234Sdrh ** The "sqlite" command below creates a new Tcl command for each 97075897234Sdrh ** connection it opens to an SQLite database. This routine is invoked 97175897234Sdrh ** whenever one of those connection-specific commands is executed 97275897234Sdrh ** in Tcl. For example, if you run Tcl code like this: 97375897234Sdrh ** 9749bb575fdSdrh ** sqlite3 db1 "my_database" 97575897234Sdrh ** db1 close 97675897234Sdrh ** 97775897234Sdrh ** The first command opens a connection to the "my_database" database 97875897234Sdrh ** and calls that connection "db1". The second command causes this 97975897234Sdrh ** subroutine to be invoked. 98075897234Sdrh */ 9816d31316cSdrh static int DbObjCmd(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){ 982bec3f402Sdrh SqliteDb *pDb = (SqliteDb*)cd; 9836d31316cSdrh int choice; 98422fbcb8dSdrh int rc = TCL_OK; 9850de8c112Sdrh static const char *DB_strs[] = { 986fb7e7651Sdrh "authorizer", "busy", "cache", 987fb7e7651Sdrh "changes", "close", "collate", 988fb7e7651Sdrh "collation_needed", "commit_hook", "complete", 9894144905bSdrh "copy", "enable_load_extension","errorcode", 9904144905bSdrh "eval", "exists", "function", 99159fffd02Sdrh "incrblob", "interrupt", "last_insert_rowid", 99259fffd02Sdrh "nullvalue", "onecolumn", "profile", 99359fffd02Sdrh "progress", "rekey", "rollback_hook", 994d1d38488Sdrh "status", "timeout", "total_changes", 995d1d38488Sdrh "trace", "transaction", "update_hook", 996d1d38488Sdrh "version", 0 9976d31316cSdrh }; 998411995dcSdrh enum DB_enum { 999fb7e7651Sdrh DB_AUTHORIZER, DB_BUSY, DB_CACHE, 1000fb7e7651Sdrh DB_CHANGES, DB_CLOSE, DB_COLLATE, 1001fb7e7651Sdrh DB_COLLATION_NEEDED, DB_COMMIT_HOOK, DB_COMPLETE, 10024144905bSdrh DB_COPY, DB_ENABLE_LOAD_EXTENSION,DB_ERRORCODE, 10034144905bSdrh DB_EVAL, DB_EXISTS, DB_FUNCTION, 100459fffd02Sdrh DB_INCRBLOB, DB_INTERRUPT, DB_LAST_INSERT_ROWID, 100559fffd02Sdrh DB_NULLVALUE, DB_ONECOLUMN, DB_PROFILE, 100659fffd02Sdrh DB_PROGRESS, DB_REKEY, DB_ROLLBACK_HOOK, 1007d1d38488Sdrh DB_STATUS, DB_TIMEOUT, DB_TOTAL_CHANGES, 1008d1d38488Sdrh DB_TRACE, DB_TRANSACTION, DB_UPDATE_HOOK, 1009d1d38488Sdrh DB_VERSION 10106d31316cSdrh }; 10111067fe11Stpoindex /* don't leave trailing commas on DB_enum, it confuses the AIX xlc compiler */ 10126d31316cSdrh 10136d31316cSdrh if( objc<2 ){ 10146d31316cSdrh Tcl_WrongNumArgs(interp, 1, objv, "SUBCOMMAND ..."); 101575897234Sdrh return TCL_ERROR; 101675897234Sdrh } 1017411995dcSdrh if( Tcl_GetIndexFromObj(interp, objv[1], DB_strs, "option", 0, &choice) ){ 10186d31316cSdrh return TCL_ERROR; 10196d31316cSdrh } 10206d31316cSdrh 1021411995dcSdrh switch( (enum DB_enum)choice ){ 102275897234Sdrh 1023e22a334bSdrh /* $db authorizer ?CALLBACK? 1024e22a334bSdrh ** 1025e22a334bSdrh ** Invoke the given callback to authorize each SQL operation as it is 1026e22a334bSdrh ** compiled. 5 arguments are appended to the callback before it is 1027e22a334bSdrh ** invoked: 1028e22a334bSdrh ** 1029e22a334bSdrh ** (1) The authorization type (ex: SQLITE_CREATE_TABLE, SQLITE_INSERT, ...) 1030e22a334bSdrh ** (2) First descriptive name (depends on authorization type) 1031e22a334bSdrh ** (3) Second descriptive name 1032e22a334bSdrh ** (4) Name of the database (ex: "main", "temp") 1033e22a334bSdrh ** (5) Name of trigger that is doing the access 1034e22a334bSdrh ** 1035e22a334bSdrh ** The callback should return on of the following strings: SQLITE_OK, 1036e22a334bSdrh ** SQLITE_IGNORE, or SQLITE_DENY. Any other return value is an error. 1037e22a334bSdrh ** 1038e22a334bSdrh ** If this method is invoked with no arguments, the current authorization 1039e22a334bSdrh ** callback string is returned. 1040e22a334bSdrh */ 1041e22a334bSdrh case DB_AUTHORIZER: { 10421211de37Sdrh #ifdef SQLITE_OMIT_AUTHORIZATION 10431211de37Sdrh Tcl_AppendResult(interp, "authorization not available in this build", 0); 10441211de37Sdrh return TCL_ERROR; 10451211de37Sdrh #else 1046e22a334bSdrh if( objc>3 ){ 1047e22a334bSdrh Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?"); 10480f14e2ebSdrh return TCL_ERROR; 1049e22a334bSdrh }else if( objc==2 ){ 1050b5a20d3cSdrh if( pDb->zAuth ){ 1051e22a334bSdrh Tcl_AppendResult(interp, pDb->zAuth, 0); 1052e22a334bSdrh } 1053e22a334bSdrh }else{ 1054e22a334bSdrh char *zAuth; 1055e22a334bSdrh int len; 1056e22a334bSdrh if( pDb->zAuth ){ 1057e22a334bSdrh Tcl_Free(pDb->zAuth); 1058e22a334bSdrh } 1059e22a334bSdrh zAuth = Tcl_GetStringFromObj(objv[2], &len); 1060e22a334bSdrh if( zAuth && len>0 ){ 1061e22a334bSdrh pDb->zAuth = Tcl_Alloc( len + 1 ); 10625bb3eb9bSdrh memcpy(pDb->zAuth, zAuth, len+1); 1063e22a334bSdrh }else{ 1064e22a334bSdrh pDb->zAuth = 0; 1065e22a334bSdrh } 1066e22a334bSdrh if( pDb->zAuth ){ 1067e22a334bSdrh pDb->interp = interp; 10686f8a503dSdanielk1977 sqlite3_set_authorizer(pDb->db, auth_callback, pDb); 1069e22a334bSdrh }else{ 10706f8a503dSdanielk1977 sqlite3_set_authorizer(pDb->db, 0, 0); 1071e22a334bSdrh } 1072e22a334bSdrh } 10731211de37Sdrh #endif 1074e22a334bSdrh break; 1075e22a334bSdrh } 1076e22a334bSdrh 1077bec3f402Sdrh /* $db busy ?CALLBACK? 1078bec3f402Sdrh ** 1079bec3f402Sdrh ** Invoke the given callback if an SQL statement attempts to open 1080bec3f402Sdrh ** a locked database file. 1081bec3f402Sdrh */ 10826d31316cSdrh case DB_BUSY: { 10836d31316cSdrh if( objc>3 ){ 10846d31316cSdrh Tcl_WrongNumArgs(interp, 2, objv, "CALLBACK"); 1085bec3f402Sdrh return TCL_ERROR; 10866d31316cSdrh }else if( objc==2 ){ 1087bec3f402Sdrh if( pDb->zBusy ){ 1088bec3f402Sdrh Tcl_AppendResult(interp, pDb->zBusy, 0); 1089bec3f402Sdrh } 1090bec3f402Sdrh }else{ 10916d31316cSdrh char *zBusy; 10926d31316cSdrh int len; 1093bec3f402Sdrh if( pDb->zBusy ){ 1094bec3f402Sdrh Tcl_Free(pDb->zBusy); 10956d31316cSdrh } 10966d31316cSdrh zBusy = Tcl_GetStringFromObj(objv[2], &len); 10976d31316cSdrh if( zBusy && len>0 ){ 10986d31316cSdrh pDb->zBusy = Tcl_Alloc( len + 1 ); 10995bb3eb9bSdrh memcpy(pDb->zBusy, zBusy, len+1); 11006d31316cSdrh }else{ 1101bec3f402Sdrh pDb->zBusy = 0; 1102bec3f402Sdrh } 1103bec3f402Sdrh if( pDb->zBusy ){ 1104bec3f402Sdrh pDb->interp = interp; 11056f8a503dSdanielk1977 sqlite3_busy_handler(pDb->db, DbBusyHandler, pDb); 11066d31316cSdrh }else{ 11076f8a503dSdanielk1977 sqlite3_busy_handler(pDb->db, 0, 0); 1108bec3f402Sdrh } 1109bec3f402Sdrh } 11106d31316cSdrh break; 11116d31316cSdrh } 1112bec3f402Sdrh 1113fb7e7651Sdrh /* $db cache flush 1114fb7e7651Sdrh ** $db cache size n 1115fb7e7651Sdrh ** 1116fb7e7651Sdrh ** Flush the prepared statement cache, or set the maximum number of 1117fb7e7651Sdrh ** cached statements. 1118fb7e7651Sdrh */ 1119fb7e7651Sdrh case DB_CACHE: { 1120fb7e7651Sdrh char *subCmd; 1121fb7e7651Sdrh int n; 1122fb7e7651Sdrh 1123fb7e7651Sdrh if( objc<=2 ){ 1124fb7e7651Sdrh Tcl_WrongNumArgs(interp, 1, objv, "cache option ?arg?"); 1125fb7e7651Sdrh return TCL_ERROR; 1126fb7e7651Sdrh } 1127fb7e7651Sdrh subCmd = Tcl_GetStringFromObj( objv[2], 0 ); 1128fb7e7651Sdrh if( *subCmd=='f' && strcmp(subCmd,"flush")==0 ){ 1129fb7e7651Sdrh if( objc!=3 ){ 1130fb7e7651Sdrh Tcl_WrongNumArgs(interp, 2, objv, "flush"); 1131fb7e7651Sdrh return TCL_ERROR; 1132fb7e7651Sdrh }else{ 1133fb7e7651Sdrh flushStmtCache( pDb ); 1134fb7e7651Sdrh } 1135fb7e7651Sdrh }else if( *subCmd=='s' && strcmp(subCmd,"size")==0 ){ 1136fb7e7651Sdrh if( objc!=4 ){ 1137fb7e7651Sdrh Tcl_WrongNumArgs(interp, 2, objv, "size n"); 1138fb7e7651Sdrh return TCL_ERROR; 1139fb7e7651Sdrh }else{ 1140fb7e7651Sdrh if( TCL_ERROR==Tcl_GetIntFromObj(interp, objv[3], &n) ){ 1141fb7e7651Sdrh Tcl_AppendResult( interp, "cannot convert \"", 1142fb7e7651Sdrh Tcl_GetStringFromObj(objv[3],0), "\" to integer", 0); 1143fb7e7651Sdrh return TCL_ERROR; 1144fb7e7651Sdrh }else{ 1145fb7e7651Sdrh if( n<0 ){ 1146fb7e7651Sdrh flushStmtCache( pDb ); 1147fb7e7651Sdrh n = 0; 1148fb7e7651Sdrh }else if( n>MAX_PREPARED_STMTS ){ 1149fb7e7651Sdrh n = MAX_PREPARED_STMTS; 1150fb7e7651Sdrh } 1151fb7e7651Sdrh pDb->maxStmt = n; 1152fb7e7651Sdrh } 1153fb7e7651Sdrh } 1154fb7e7651Sdrh }else{ 1155fb7e7651Sdrh Tcl_AppendResult( interp, "bad option \"", 1156191fadcfSdanielk1977 Tcl_GetStringFromObj(objv[2],0), "\": must be flush or size", 0); 1157fb7e7651Sdrh return TCL_ERROR; 1158fb7e7651Sdrh } 1159fb7e7651Sdrh break; 1160fb7e7651Sdrh } 1161fb7e7651Sdrh 1162b28af71aSdanielk1977 /* $db changes 1163c8d30ac1Sdrh ** 1164c8d30ac1Sdrh ** Return the number of rows that were modified, inserted, or deleted by 1165b28af71aSdanielk1977 ** the most recent INSERT, UPDATE or DELETE statement, not including 1166b28af71aSdanielk1977 ** any changes made by trigger programs. 1167c8d30ac1Sdrh */ 1168c8d30ac1Sdrh case DB_CHANGES: { 1169c8d30ac1Sdrh Tcl_Obj *pResult; 1170c8d30ac1Sdrh if( objc!=2 ){ 1171c8d30ac1Sdrh Tcl_WrongNumArgs(interp, 2, objv, ""); 1172c8d30ac1Sdrh return TCL_ERROR; 1173c8d30ac1Sdrh } 1174c8d30ac1Sdrh pResult = Tcl_GetObjResult(interp); 1175b28af71aSdanielk1977 Tcl_SetIntObj(pResult, sqlite3_changes(pDb->db)); 1176f146a776Srdc break; 1177f146a776Srdc } 1178f146a776Srdc 117975897234Sdrh /* $db close 118075897234Sdrh ** 118175897234Sdrh ** Shutdown the database 118275897234Sdrh */ 11836d31316cSdrh case DB_CLOSE: { 11846d31316cSdrh Tcl_DeleteCommand(interp, Tcl_GetStringFromObj(objv[0], 0)); 11856d31316cSdrh break; 11866d31316cSdrh } 118775897234Sdrh 11880f14e2ebSdrh /* 11890f14e2ebSdrh ** $db collate NAME SCRIPT 11900f14e2ebSdrh ** 11910f14e2ebSdrh ** Create a new SQL collation function called NAME. Whenever 11920f14e2ebSdrh ** that function is called, invoke SCRIPT to evaluate the function. 11930f14e2ebSdrh */ 11940f14e2ebSdrh case DB_COLLATE: { 11950f14e2ebSdrh SqlCollate *pCollate; 11960f14e2ebSdrh char *zName; 11970f14e2ebSdrh char *zScript; 11980f14e2ebSdrh int nScript; 11990f14e2ebSdrh if( objc!=4 ){ 12000f14e2ebSdrh Tcl_WrongNumArgs(interp, 2, objv, "NAME SCRIPT"); 12010f14e2ebSdrh return TCL_ERROR; 12020f14e2ebSdrh } 12030f14e2ebSdrh zName = Tcl_GetStringFromObj(objv[2], 0); 12040f14e2ebSdrh zScript = Tcl_GetStringFromObj(objv[3], &nScript); 12050f14e2ebSdrh pCollate = (SqlCollate*)Tcl_Alloc( sizeof(*pCollate) + nScript + 1 ); 12060f14e2ebSdrh if( pCollate==0 ) return TCL_ERROR; 12070f14e2ebSdrh pCollate->interp = interp; 12080f14e2ebSdrh pCollate->pNext = pDb->pCollate; 12090f14e2ebSdrh pCollate->zScript = (char*)&pCollate[1]; 12100f14e2ebSdrh pDb->pCollate = pCollate; 12115bb3eb9bSdrh memcpy(pCollate->zScript, zScript, nScript+1); 12120f14e2ebSdrh if( sqlite3_create_collation(pDb->db, zName, SQLITE_UTF8, 12130f14e2ebSdrh pCollate, tclSqlCollate) ){ 12149636c4e1Sdanielk1977 Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE); 12150f14e2ebSdrh return TCL_ERROR; 12160f14e2ebSdrh } 12170f14e2ebSdrh break; 12180f14e2ebSdrh } 12190f14e2ebSdrh 12200f14e2ebSdrh /* 12210f14e2ebSdrh ** $db collation_needed SCRIPT 12220f14e2ebSdrh ** 12230f14e2ebSdrh ** Create a new SQL collation function called NAME. Whenever 12240f14e2ebSdrh ** that function is called, invoke SCRIPT to evaluate the function. 12250f14e2ebSdrh */ 12260f14e2ebSdrh case DB_COLLATION_NEEDED: { 12270f14e2ebSdrh if( objc!=3 ){ 12280f14e2ebSdrh Tcl_WrongNumArgs(interp, 2, objv, "SCRIPT"); 12290f14e2ebSdrh return TCL_ERROR; 12300f14e2ebSdrh } 12310f14e2ebSdrh if( pDb->pCollateNeeded ){ 12320f14e2ebSdrh Tcl_DecrRefCount(pDb->pCollateNeeded); 12330f14e2ebSdrh } 12340f14e2ebSdrh pDb->pCollateNeeded = Tcl_DuplicateObj(objv[2]); 12350f14e2ebSdrh Tcl_IncrRefCount(pDb->pCollateNeeded); 12360f14e2ebSdrh sqlite3_collation_needed(pDb->db, pDb, tclCollateNeeded); 12370f14e2ebSdrh break; 12380f14e2ebSdrh } 12390f14e2ebSdrh 124019e2d37fSdrh /* $db commit_hook ?CALLBACK? 124119e2d37fSdrh ** 124219e2d37fSdrh ** Invoke the given callback just before committing every SQL transaction. 124319e2d37fSdrh ** If the callback throws an exception or returns non-zero, then the 124419e2d37fSdrh ** transaction is aborted. If CALLBACK is an empty string, the callback 124519e2d37fSdrh ** is disabled. 124619e2d37fSdrh */ 124719e2d37fSdrh case DB_COMMIT_HOOK: { 124819e2d37fSdrh if( objc>3 ){ 124919e2d37fSdrh Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?"); 125019e2d37fSdrh return TCL_ERROR; 125119e2d37fSdrh }else if( objc==2 ){ 125219e2d37fSdrh if( pDb->zCommit ){ 125319e2d37fSdrh Tcl_AppendResult(interp, pDb->zCommit, 0); 125419e2d37fSdrh } 125519e2d37fSdrh }else{ 125619e2d37fSdrh char *zCommit; 125719e2d37fSdrh int len; 125819e2d37fSdrh if( pDb->zCommit ){ 125919e2d37fSdrh Tcl_Free(pDb->zCommit); 126019e2d37fSdrh } 126119e2d37fSdrh zCommit = Tcl_GetStringFromObj(objv[2], &len); 126219e2d37fSdrh if( zCommit && len>0 ){ 126319e2d37fSdrh pDb->zCommit = Tcl_Alloc( len + 1 ); 12645bb3eb9bSdrh memcpy(pDb->zCommit, zCommit, len+1); 126519e2d37fSdrh }else{ 126619e2d37fSdrh pDb->zCommit = 0; 126719e2d37fSdrh } 126819e2d37fSdrh if( pDb->zCommit ){ 126919e2d37fSdrh pDb->interp = interp; 127019e2d37fSdrh sqlite3_commit_hook(pDb->db, DbCommitHandler, pDb); 127119e2d37fSdrh }else{ 127219e2d37fSdrh sqlite3_commit_hook(pDb->db, 0, 0); 127319e2d37fSdrh } 127419e2d37fSdrh } 127519e2d37fSdrh break; 127619e2d37fSdrh } 127719e2d37fSdrh 127875897234Sdrh /* $db complete SQL 127975897234Sdrh ** 128075897234Sdrh ** Return TRUE if SQL is a complete SQL statement. Return FALSE if 128175897234Sdrh ** additional lines of input are needed. This is similar to the 128275897234Sdrh ** built-in "info complete" command of Tcl. 128375897234Sdrh */ 12846d31316cSdrh case DB_COMPLETE: { 1285ccae6026Sdrh #ifndef SQLITE_OMIT_COMPLETE 12866d31316cSdrh Tcl_Obj *pResult; 12876d31316cSdrh int isComplete; 12886d31316cSdrh if( objc!=3 ){ 12896d31316cSdrh Tcl_WrongNumArgs(interp, 2, objv, "SQL"); 129075897234Sdrh return TCL_ERROR; 129175897234Sdrh } 12926f8a503dSdanielk1977 isComplete = sqlite3_complete( Tcl_GetStringFromObj(objv[2], 0) ); 12936d31316cSdrh pResult = Tcl_GetObjResult(interp); 12946d31316cSdrh Tcl_SetBooleanObj(pResult, isComplete); 1295ccae6026Sdrh #endif 12966d31316cSdrh break; 12976d31316cSdrh } 129875897234Sdrh 129919e2d37fSdrh /* $db copy conflict-algorithm table filename ?SEPARATOR? ?NULLINDICATOR? 130019e2d37fSdrh ** 130119e2d37fSdrh ** Copy data into table from filename, optionally using SEPARATOR 130219e2d37fSdrh ** as column separators. If a column contains a null string, or the 130319e2d37fSdrh ** value of NULLINDICATOR, a NULL is inserted for the column. 130419e2d37fSdrh ** conflict-algorithm is one of the sqlite conflict algorithms: 130519e2d37fSdrh ** rollback, abort, fail, ignore, replace 130619e2d37fSdrh ** On success, return the number of lines processed, not necessarily same 130719e2d37fSdrh ** as 'db changes' due to conflict-algorithm selected. 130819e2d37fSdrh ** 130919e2d37fSdrh ** This code is basically an implementation/enhancement of 131019e2d37fSdrh ** the sqlite3 shell.c ".import" command. 131119e2d37fSdrh ** 131219e2d37fSdrh ** This command usage is equivalent to the sqlite2.x COPY statement, 131319e2d37fSdrh ** which imports file data into a table using the PostgreSQL COPY file format: 131419e2d37fSdrh ** $db copy $conflit_algo $table_name $filename \t \\N 131519e2d37fSdrh */ 131619e2d37fSdrh case DB_COPY: { 131719e2d37fSdrh char *zTable; /* Insert data into this table */ 131819e2d37fSdrh char *zFile; /* The file from which to extract data */ 131919e2d37fSdrh char *zConflict; /* The conflict algorithm to use */ 132019e2d37fSdrh sqlite3_stmt *pStmt; /* A statement */ 132119e2d37fSdrh int nCol; /* Number of columns in the table */ 132219e2d37fSdrh int nByte; /* Number of bytes in an SQL string */ 132319e2d37fSdrh int i, j; /* Loop counters */ 132419e2d37fSdrh int nSep; /* Number of bytes in zSep[] */ 132519e2d37fSdrh int nNull; /* Number of bytes in zNull[] */ 132619e2d37fSdrh char *zSql; /* An SQL statement */ 132719e2d37fSdrh char *zLine; /* A single line of input from the file */ 132819e2d37fSdrh char **azCol; /* zLine[] broken up into columns */ 132919e2d37fSdrh char *zCommit; /* How to commit changes */ 133019e2d37fSdrh FILE *in; /* The input file */ 133119e2d37fSdrh int lineno = 0; /* Line number of input file */ 133219e2d37fSdrh char zLineNum[80]; /* Line number print buffer */ 133319e2d37fSdrh Tcl_Obj *pResult; /* interp result */ 133419e2d37fSdrh 133519e2d37fSdrh char *zSep; 133619e2d37fSdrh char *zNull; 133719e2d37fSdrh if( objc<5 || objc>7 ){ 133819e2d37fSdrh Tcl_WrongNumArgs(interp, 2, objv, 133919e2d37fSdrh "CONFLICT-ALGORITHM TABLE FILENAME ?SEPARATOR? ?NULLINDICATOR?"); 134019e2d37fSdrh return TCL_ERROR; 134119e2d37fSdrh } 134219e2d37fSdrh if( objc>=6 ){ 134319e2d37fSdrh zSep = Tcl_GetStringFromObj(objv[5], 0); 134419e2d37fSdrh }else{ 134519e2d37fSdrh zSep = "\t"; 134619e2d37fSdrh } 134719e2d37fSdrh if( objc>=7 ){ 134819e2d37fSdrh zNull = Tcl_GetStringFromObj(objv[6], 0); 134919e2d37fSdrh }else{ 135019e2d37fSdrh zNull = ""; 135119e2d37fSdrh } 135219e2d37fSdrh zConflict = Tcl_GetStringFromObj(objv[2], 0); 135319e2d37fSdrh zTable = Tcl_GetStringFromObj(objv[3], 0); 135419e2d37fSdrh zFile = Tcl_GetStringFromObj(objv[4], 0); 13554f21c4afSdrh nSep = strlen30(zSep); 13564f21c4afSdrh nNull = strlen30(zNull); 135719e2d37fSdrh if( nSep==0 ){ 135819e2d37fSdrh Tcl_AppendResult(interp,"Error: non-null separator required for copy",0); 135919e2d37fSdrh return TCL_ERROR; 136019e2d37fSdrh } 13613e59c012Sdrh if(strcmp(zConflict, "rollback") != 0 && 13623e59c012Sdrh strcmp(zConflict, "abort" ) != 0 && 13633e59c012Sdrh strcmp(zConflict, "fail" ) != 0 && 13643e59c012Sdrh strcmp(zConflict, "ignore" ) != 0 && 13653e59c012Sdrh strcmp(zConflict, "replace" ) != 0 ) { 136619e2d37fSdrh Tcl_AppendResult(interp, "Error: \"", zConflict, 136719e2d37fSdrh "\", conflict-algorithm must be one of: rollback, " 136819e2d37fSdrh "abort, fail, ignore, or replace", 0); 136919e2d37fSdrh return TCL_ERROR; 137019e2d37fSdrh } 137119e2d37fSdrh zSql = sqlite3_mprintf("SELECT * FROM '%q'", zTable); 137219e2d37fSdrh if( zSql==0 ){ 137319e2d37fSdrh Tcl_AppendResult(interp, "Error: no such table: ", zTable, 0); 137419e2d37fSdrh return TCL_ERROR; 137519e2d37fSdrh } 13764f21c4afSdrh nByte = strlen30(zSql); 13773e701a18Sdrh rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0); 137819e2d37fSdrh sqlite3_free(zSql); 137919e2d37fSdrh if( rc ){ 138019e2d37fSdrh Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), 0); 138119e2d37fSdrh nCol = 0; 138219e2d37fSdrh }else{ 138319e2d37fSdrh nCol = sqlite3_column_count(pStmt); 138419e2d37fSdrh } 138519e2d37fSdrh sqlite3_finalize(pStmt); 138619e2d37fSdrh if( nCol==0 ) { 138719e2d37fSdrh return TCL_ERROR; 138819e2d37fSdrh } 138919e2d37fSdrh zSql = malloc( nByte + 50 + nCol*2 ); 139019e2d37fSdrh if( zSql==0 ) { 139119e2d37fSdrh Tcl_AppendResult(interp, "Error: can't malloc()", 0); 139219e2d37fSdrh return TCL_ERROR; 139319e2d37fSdrh } 139419e2d37fSdrh sqlite3_snprintf(nByte+50, zSql, "INSERT OR %q INTO '%q' VALUES(?", 139519e2d37fSdrh zConflict, zTable); 13964f21c4afSdrh j = strlen30(zSql); 139719e2d37fSdrh for(i=1; i<nCol; i++){ 139819e2d37fSdrh zSql[j++] = ','; 139919e2d37fSdrh zSql[j++] = '?'; 140019e2d37fSdrh } 140119e2d37fSdrh zSql[j++] = ')'; 140219e2d37fSdrh zSql[j] = 0; 14033e701a18Sdrh rc = sqlite3_prepare(pDb->db, zSql, -1, &pStmt, 0); 140419e2d37fSdrh free(zSql); 140519e2d37fSdrh if( rc ){ 140619e2d37fSdrh Tcl_AppendResult(interp, "Error: ", sqlite3_errmsg(pDb->db), 0); 140719e2d37fSdrh sqlite3_finalize(pStmt); 140819e2d37fSdrh return TCL_ERROR; 140919e2d37fSdrh } 141019e2d37fSdrh in = fopen(zFile, "rb"); 141119e2d37fSdrh if( in==0 ){ 141219e2d37fSdrh Tcl_AppendResult(interp, "Error: cannot open file: ", zFile, NULL); 141319e2d37fSdrh sqlite3_finalize(pStmt); 141419e2d37fSdrh return TCL_ERROR; 141519e2d37fSdrh } 141619e2d37fSdrh azCol = malloc( sizeof(azCol[0])*(nCol+1) ); 141719e2d37fSdrh if( azCol==0 ) { 141819e2d37fSdrh Tcl_AppendResult(interp, "Error: can't malloc()", 0); 141943617e9aSdrh fclose(in); 142019e2d37fSdrh return TCL_ERROR; 142119e2d37fSdrh } 14223752785fSdrh (void)sqlite3_exec(pDb->db, "BEGIN", 0, 0, 0); 142319e2d37fSdrh zCommit = "COMMIT"; 142419e2d37fSdrh while( (zLine = local_getline(0, in))!=0 ){ 142519e2d37fSdrh char *z; 142619e2d37fSdrh i = 0; 142719e2d37fSdrh lineno++; 142819e2d37fSdrh azCol[0] = zLine; 142919e2d37fSdrh for(i=0, z=zLine; *z; z++){ 143019e2d37fSdrh if( *z==zSep[0] && strncmp(z, zSep, nSep)==0 ){ 143119e2d37fSdrh *z = 0; 143219e2d37fSdrh i++; 143319e2d37fSdrh if( i<nCol ){ 143419e2d37fSdrh azCol[i] = &z[nSep]; 143519e2d37fSdrh z += nSep-1; 143619e2d37fSdrh } 143719e2d37fSdrh } 143819e2d37fSdrh } 143919e2d37fSdrh if( i+1!=nCol ){ 144019e2d37fSdrh char *zErr; 14414f21c4afSdrh int nErr = strlen30(zFile) + 200; 14425bb3eb9bSdrh zErr = malloc(nErr); 1443c1f4494eSdrh if( zErr ){ 14445bb3eb9bSdrh sqlite3_snprintf(nErr, zErr, 1445955de52cSdanielk1977 "Error: %s line %d: expected %d columns of data but found %d", 144619e2d37fSdrh zFile, lineno, nCol, i+1); 144719e2d37fSdrh Tcl_AppendResult(interp, zErr, 0); 144819e2d37fSdrh free(zErr); 1449c1f4494eSdrh } 145019e2d37fSdrh zCommit = "ROLLBACK"; 145119e2d37fSdrh break; 145219e2d37fSdrh } 145319e2d37fSdrh for(i=0; i<nCol; i++){ 145419e2d37fSdrh /* check for null data, if so, bind as null */ 1455ea678832Sdrh if( (nNull>0 && strcmp(azCol[i], zNull)==0) 14564f21c4afSdrh || strlen30(azCol[i])==0 1457ea678832Sdrh ){ 145819e2d37fSdrh sqlite3_bind_null(pStmt, i+1); 145919e2d37fSdrh }else{ 146019e2d37fSdrh sqlite3_bind_text(pStmt, i+1, azCol[i], -1, SQLITE_STATIC); 146119e2d37fSdrh } 146219e2d37fSdrh } 146319e2d37fSdrh sqlite3_step(pStmt); 146419e2d37fSdrh rc = sqlite3_reset(pStmt); 146519e2d37fSdrh free(zLine); 146619e2d37fSdrh if( rc!=SQLITE_OK ){ 146719e2d37fSdrh Tcl_AppendResult(interp,"Error: ", sqlite3_errmsg(pDb->db), 0); 146819e2d37fSdrh zCommit = "ROLLBACK"; 146919e2d37fSdrh break; 147019e2d37fSdrh } 147119e2d37fSdrh } 147219e2d37fSdrh free(azCol); 147319e2d37fSdrh fclose(in); 147419e2d37fSdrh sqlite3_finalize(pStmt); 14753752785fSdrh (void)sqlite3_exec(pDb->db, zCommit, 0, 0, 0); 147619e2d37fSdrh 147719e2d37fSdrh if( zCommit[0] == 'C' ){ 147819e2d37fSdrh /* success, set result as number of lines processed */ 147919e2d37fSdrh pResult = Tcl_GetObjResult(interp); 148019e2d37fSdrh Tcl_SetIntObj(pResult, lineno); 148119e2d37fSdrh rc = TCL_OK; 148219e2d37fSdrh }else{ 148319e2d37fSdrh /* failure, append lineno where failed */ 14845bb3eb9bSdrh sqlite3_snprintf(sizeof(zLineNum), zLineNum,"%d",lineno); 148519e2d37fSdrh Tcl_AppendResult(interp,", failed while processing line: ",zLineNum,0); 148619e2d37fSdrh rc = TCL_ERROR; 148719e2d37fSdrh } 148819e2d37fSdrh break; 148919e2d37fSdrh } 149019e2d37fSdrh 149175897234Sdrh /* 14924144905bSdrh ** $db enable_load_extension BOOLEAN 14934144905bSdrh ** 14944144905bSdrh ** Turn the extension loading feature on or off. It if off by 14954144905bSdrh ** default. 14964144905bSdrh */ 14974144905bSdrh case DB_ENABLE_LOAD_EXTENSION: { 1498f533acc0Sdrh #ifndef SQLITE_OMIT_LOAD_EXTENSION 14994144905bSdrh int onoff; 15004144905bSdrh if( objc!=3 ){ 15014144905bSdrh Tcl_WrongNumArgs(interp, 2, objv, "BOOLEAN"); 15024144905bSdrh return TCL_ERROR; 15034144905bSdrh } 15044144905bSdrh if( Tcl_GetBooleanFromObj(interp, objv[2], &onoff) ){ 15054144905bSdrh return TCL_ERROR; 15064144905bSdrh } 15074144905bSdrh sqlite3_enable_load_extension(pDb->db, onoff); 15084144905bSdrh break; 1509f533acc0Sdrh #else 1510f533acc0Sdrh Tcl_AppendResult(interp, "extension loading is turned off at compile-time", 1511f533acc0Sdrh 0); 1512f533acc0Sdrh return TCL_ERROR; 1513f533acc0Sdrh #endif 15144144905bSdrh } 15154144905bSdrh 15164144905bSdrh /* 1517dcd997eaSdrh ** $db errorcode 1518dcd997eaSdrh ** 1519dcd997eaSdrh ** Return the numeric error code that was returned by the most recent 15206f8a503dSdanielk1977 ** call to sqlite3_exec(). 1521dcd997eaSdrh */ 1522dcd997eaSdrh case DB_ERRORCODE: { 1523f3ce83f5Sdanielk1977 Tcl_SetObjResult(interp, Tcl_NewIntObj(sqlite3_errcode(pDb->db))); 1524dcd997eaSdrh break; 1525dcd997eaSdrh } 1526dcd997eaSdrh 1527dcd997eaSdrh /* 1528895d7472Sdrh ** $db eval $sql ?array? ?{ ...code... }? 15291807ce37Sdrh ** $db onecolumn $sql 153075897234Sdrh ** 153175897234Sdrh ** The SQL statement in $sql is evaluated. For each row, the values are 1532bec3f402Sdrh ** placed in elements of the array named "array" and ...code... is executed. 153375897234Sdrh ** If "array" and "code" are omitted, then no callback is every invoked. 153475897234Sdrh ** If "array" is an empty string, then the values are placed in variables 153575897234Sdrh ** that have the same name as the fields extracted by the query. 15361807ce37Sdrh ** 15371807ce37Sdrh ** The onecolumn method is the equivalent of: 15381807ce37Sdrh ** lindex [$db eval $sql] 0 153975897234Sdrh */ 15401807ce37Sdrh case DB_ONECOLUMN: 154197f2ebc1Sdrh case DB_EVAL: 154297f2ebc1Sdrh case DB_EXISTS: { 15439d74b4c5Sdrh char const *zSql; /* Next SQL statement to execute */ 15449d74b4c5Sdrh char const *zLeft; /* What is left after first stmt in zSql */ 15459d74b4c5Sdrh sqlite3_stmt *pStmt; /* Compiled SQL statment */ 154692febd92Sdrh Tcl_Obj *pArray; /* Name of array into which results are written */ 154792febd92Sdrh Tcl_Obj *pScript; /* Script to run for each result set */ 15481d895039Sdrh Tcl_Obj **apParm; /* Parameters that need a Tcl_DecrRefCount() */ 15491d895039Sdrh int nParm; /* Number of entries used in apParm[] */ 15501d895039Sdrh Tcl_Obj *aParm[10]; /* Static space for apParm[] in the common case */ 15511807ce37Sdrh Tcl_Obj *pRet; /* Value to be returned */ 1552fb7e7651Sdrh SqlPreparedStmt *pPreStmt; /* Pointer to a prepared statement */ 1553fb7e7651Sdrh int rc2; 1554ef2cb63eSdanielk1977 155597f2ebc1Sdrh if( choice==DB_EVAL ){ 155692febd92Sdrh if( objc<3 || objc>5 ){ 1557895d7472Sdrh Tcl_WrongNumArgs(interp, 2, objv, "SQL ?ARRAY-NAME? ?SCRIPT?"); 155830ccda10Sdanielk1977 return TCL_ERROR; 155930ccda10Sdanielk1977 } 15601807ce37Sdrh pRet = Tcl_NewObj(); 15611807ce37Sdrh Tcl_IncrRefCount(pRet); 156297f2ebc1Sdrh }else{ 156397f2ebc1Sdrh if( objc!=3 ){ 156497f2ebc1Sdrh Tcl_WrongNumArgs(interp, 2, objv, "SQL"); 156597f2ebc1Sdrh return TCL_ERROR; 156697f2ebc1Sdrh } 156797f2ebc1Sdrh if( choice==DB_EXISTS ){ 1568446a9b82Sdrh pRet = Tcl_NewBooleanObj(0); 1569446a9b82Sdrh Tcl_IncrRefCount(pRet); 1570446a9b82Sdrh }else{ 1571446a9b82Sdrh pRet = 0; 157297f2ebc1Sdrh } 15731807ce37Sdrh } 157492febd92Sdrh if( objc==3 ){ 157592febd92Sdrh pArray = pScript = 0; 157692febd92Sdrh }else if( objc==4 ){ 157792febd92Sdrh pArray = 0; 157892febd92Sdrh pScript = objv[3]; 157992febd92Sdrh }else{ 158092febd92Sdrh pArray = objv[3]; 158192febd92Sdrh if( Tcl_GetString(pArray)[0]==0 ) pArray = 0; 158292febd92Sdrh pScript = objv[4]; 158392febd92Sdrh } 158430ccda10Sdanielk1977 15851d895039Sdrh Tcl_IncrRefCount(objv[2]); 158630ccda10Sdanielk1977 zSql = Tcl_GetStringFromObj(objv[2], 0); 158790b6bb19Sdrh while( rc==TCL_OK && zSql[0] ){ 158892febd92Sdrh int i; /* Loop counter */ 1589fb7e7651Sdrh int nVar; /* Number of bind parameters in the pStmt */ 15908e556520Sdanielk1977 int nCol = -1; /* Number of columns in the result set */ 159192febd92Sdrh Tcl_Obj **apColName = 0; /* Array of column names */ 1592fb7e7651Sdrh int len; /* String length of zSql */ 159330ccda10Sdanielk1977 1594fb7e7651Sdrh /* Try to find a SQL statement that has already been compiled and 1595fb7e7651Sdrh ** which matches the next sequence of SQL. 1596fb7e7651Sdrh */ 1597fb7e7651Sdrh pStmt = 0; 15984f21c4afSdrh len = strlen30(zSql); 15998e556520Sdanielk1977 for(pPreStmt = pDb->stmtList; pPreStmt; pPreStmt=pPreStmt->pNext){ 1600fb7e7651Sdrh int n = pPreStmt->nSql; 1601fb7e7651Sdrh if( len>=n 1602fb7e7651Sdrh && memcmp(pPreStmt->zSql, zSql, n)==0 1603fb7e7651Sdrh && (zSql[n]==0 || zSql[n-1]==';') 1604fb7e7651Sdrh ){ 1605fb7e7651Sdrh pStmt = pPreStmt->pStmt; 1606fb7e7651Sdrh zLeft = &zSql[pPreStmt->nSql]; 1607fb7e7651Sdrh 1608fb7e7651Sdrh /* When a prepared statement is found, unlink it from the 1609fb7e7651Sdrh ** cache list. It will later be added back to the beginning 1610fb7e7651Sdrh ** of the cache list in order to implement LRU replacement. 1611fb7e7651Sdrh */ 1612fb7e7651Sdrh if( pPreStmt->pPrev ){ 1613fb7e7651Sdrh pPreStmt->pPrev->pNext = pPreStmt->pNext; 1614fb7e7651Sdrh }else{ 1615fb7e7651Sdrh pDb->stmtList = pPreStmt->pNext; 1616fb7e7651Sdrh } 1617fb7e7651Sdrh if( pPreStmt->pNext ){ 1618fb7e7651Sdrh pPreStmt->pNext->pPrev = pPreStmt->pPrev; 1619fb7e7651Sdrh }else{ 1620fb7e7651Sdrh pDb->stmtLast = pPreStmt->pPrev; 1621fb7e7651Sdrh } 1622fb7e7651Sdrh pDb->nStmt--; 1623fb7e7651Sdrh break; 1624fb7e7651Sdrh } 1625fb7e7651Sdrh } 1626fb7e7651Sdrh 1627fb7e7651Sdrh /* If no prepared statement was found. Compile the SQL text 1628fb7e7651Sdrh */ 1629fb7e7651Sdrh if( pStmt==0 ){ 16308e556520Sdanielk1977 if( SQLITE_OK!=sqlite3_prepare_v2(pDb->db, zSql, -1, &pStmt, &zLeft) ){ 1631ef2cb63eSdanielk1977 Tcl_SetObjResult(interp, dbTextToObj(sqlite3_errmsg(pDb->db))); 163230ccda10Sdanielk1977 rc = TCL_ERROR; 163330ccda10Sdanielk1977 break; 163430ccda10Sdanielk1977 } 163592febd92Sdrh if( pStmt==0 ){ 163692febd92Sdrh if( SQLITE_OK!=sqlite3_errcode(pDb->db) ){ 1637fb7e7651Sdrh /* A compile-time error in the statement 1638fb7e7651Sdrh */ 163992febd92Sdrh Tcl_SetObjResult(interp, dbTextToObj(sqlite3_errmsg(pDb->db))); 164092febd92Sdrh rc = TCL_ERROR; 164192febd92Sdrh break; 164292febd92Sdrh }else{ 1643fb7e7651Sdrh /* The statement was a no-op. Continue to the next statement 1644fb7e7651Sdrh ** in the SQL string. 1645fb7e7651Sdrh */ 164692febd92Sdrh zSql = zLeft; 164792febd92Sdrh continue; 164892febd92Sdrh } 164992febd92Sdrh } 1650fb7e7651Sdrh assert( pPreStmt==0 ); 1651fb7e7651Sdrh } 165230ccda10Sdanielk1977 1653fb7e7651Sdrh /* Bind values to parameters that begin with $ or : 1654fb7e7651Sdrh */ 165592febd92Sdrh nVar = sqlite3_bind_parameter_count(pStmt); 16561d895039Sdrh nParm = 0; 16571d895039Sdrh if( nVar>sizeof(aParm)/sizeof(aParm[0]) ){ 16581d895039Sdrh apParm = (Tcl_Obj**)Tcl_Alloc(nVar*sizeof(apParm[0])); 16591d895039Sdrh }else{ 16601d895039Sdrh apParm = aParm; 16611d895039Sdrh } 166292febd92Sdrh for(i=1; i<=nVar; i++){ 166392febd92Sdrh const char *zVar = sqlite3_bind_parameter_name(pStmt, i); 16644f5e80f9Sdrh if( zVar!=0 && (zVar[0]=='$' || zVar[0]==':' || zVar[0]=='@') ){ 166592febd92Sdrh Tcl_Obj *pVar = Tcl_GetVar2Ex(interp, &zVar[1], 0, 0); 166692febd92Sdrh if( pVar ){ 166792febd92Sdrh int n; 166892febd92Sdrh u8 *data; 166992febd92Sdrh char *zType = pVar->typePtr ? pVar->typePtr->name : ""; 167092febd92Sdrh char c = zType[0]; 16711c747819Sdrh if( zVar[0]=='@' || 16721c747819Sdrh (c=='b' && strcmp(zType,"bytearray")==0 && pVar->bytes==0) ){ 16731c747819Sdrh /* Load a BLOB type if the Tcl variable is a bytearray and 16741c747819Sdrh ** it has no string representation or the host 16754f5e80f9Sdrh ** parameter name begins with "@". */ 167692febd92Sdrh data = Tcl_GetByteArrayFromObj(pVar, &n); 167792febd92Sdrh sqlite3_bind_blob(pStmt, i, data, n, SQLITE_STATIC); 16781d895039Sdrh Tcl_IncrRefCount(pVar); 16791d895039Sdrh apParm[nParm++] = pVar; 1680985e0c63Sdrh }else if( c=='b' && strcmp(zType,"boolean")==0 ){ 168192febd92Sdrh Tcl_GetIntFromObj(interp, pVar, &n); 168292febd92Sdrh sqlite3_bind_int(pStmt, i, n); 168392febd92Sdrh }else if( c=='d' && strcmp(zType,"double")==0 ){ 168492febd92Sdrh double r; 168592febd92Sdrh Tcl_GetDoubleFromObj(interp, pVar, &r); 168692febd92Sdrh sqlite3_bind_double(pStmt, i, r); 1687985e0c63Sdrh }else if( (c=='w' && strcmp(zType,"wideInt")==0) || 1688985e0c63Sdrh (c=='i' && strcmp(zType,"int")==0) ){ 1689df0bddaeSdrh Tcl_WideInt v; 1690df0bddaeSdrh Tcl_GetWideIntFromObj(interp, pVar, &v); 1691df0bddaeSdrh sqlite3_bind_int64(pStmt, i, v); 169292febd92Sdrh }else{ 169300fd957bSdanielk1977 data = (unsigned char *)Tcl_GetStringFromObj(pVar, &n); 1694b08c2a72Sdrh sqlite3_bind_text(pStmt, i, (char *)data, n, SQLITE_STATIC); 16951d895039Sdrh Tcl_IncrRefCount(pVar); 16961d895039Sdrh apParm[nParm++] = pVar; 169792febd92Sdrh } 1698fb7e7651Sdrh }else{ 1699fb7e7651Sdrh sqlite3_bind_null( pStmt, i ); 170092febd92Sdrh } 170192febd92Sdrh } 170292febd92Sdrh } 170392febd92Sdrh 170492febd92Sdrh /* Execute the SQL 170592febd92Sdrh */ 170690b6bb19Sdrh while( rc==TCL_OK && pStmt && SQLITE_ROW==sqlite3_step(pStmt) ){ 17078e556520Sdanielk1977 17088e556520Sdanielk1977 /* Compute column names. This must be done after the first successful 17098e556520Sdanielk1977 ** call to sqlite3_step(), in case the query is recompiled and the 17108e556520Sdanielk1977 ** number or names of the returned columns changes. 17118e556520Sdanielk1977 */ 17128e556520Sdanielk1977 assert(!pArray||pScript); 17138e556520Sdanielk1977 if (nCol < 0) { 17148e556520Sdanielk1977 Tcl_Obj ***ap = (pScript?&apColName:0); 17158e556520Sdanielk1977 nCol = computeColumnNames(interp, pStmt, ap, pArray); 17168e556520Sdanielk1977 } 17178e556520Sdanielk1977 171892febd92Sdrh for(i=0; i<nCol; i++){ 171930ccda10Sdanielk1977 Tcl_Obj *pVal; 172030ccda10Sdanielk1977 172130ccda10Sdanielk1977 /* Set pVal to contain the i'th column of this row. */ 172292febd92Sdrh switch( sqlite3_column_type(pStmt, i) ){ 172392febd92Sdrh case SQLITE_BLOB: { 17243fd0a736Sdanielk1977 int bytes = sqlite3_column_bytes(pStmt, i); 1725eee4c8caSdrh const char *zBlob = sqlite3_column_blob(pStmt, i); 1726a7a8e14bSdanielk1977 if( !zBlob ) bytes = 0; 1727eee4c8caSdrh pVal = Tcl_NewByteArrayObj((u8*)zBlob, bytes); 172892febd92Sdrh break; 172992febd92Sdrh } 173092febd92Sdrh case SQLITE_INTEGER: { 173192febd92Sdrh sqlite_int64 v = sqlite3_column_int64(pStmt, i); 173292febd92Sdrh if( v>=-2147483647 && v<=2147483647 ){ 173392febd92Sdrh pVal = Tcl_NewIntObj(v); 173492febd92Sdrh }else{ 173592febd92Sdrh pVal = Tcl_NewWideIntObj(v); 173692febd92Sdrh } 173792febd92Sdrh break; 173892febd92Sdrh } 173992febd92Sdrh case SQLITE_FLOAT: { 174092febd92Sdrh double r = sqlite3_column_double(pStmt, i); 174192febd92Sdrh pVal = Tcl_NewDoubleObj(r); 174292febd92Sdrh break; 174392febd92Sdrh } 174455c45f2eSdanielk1977 case SQLITE_NULL: { 174555c45f2eSdanielk1977 pVal = dbTextToObj(pDb->zNull); 174655c45f2eSdanielk1977 break; 174755c45f2eSdanielk1977 } 174892febd92Sdrh default: { 174900fd957bSdanielk1977 pVal = dbTextToObj((char *)sqlite3_column_text(pStmt, i)); 175092febd92Sdrh break; 175192febd92Sdrh } 175230ccda10Sdanielk1977 } 175330ccda10Sdanielk1977 175492febd92Sdrh if( pScript ){ 175592febd92Sdrh if( pArray==0 ){ 175692febd92Sdrh Tcl_ObjSetVar2(interp, apColName[i], 0, pVal, 0); 175730ccda10Sdanielk1977 }else{ 175892febd92Sdrh Tcl_ObjSetVar2(interp, pArray, apColName[i], pVal, 0); 175930ccda10Sdanielk1977 } 17601807ce37Sdrh }else if( choice==DB_ONECOLUMN ){ 176197f2ebc1Sdrh assert( pRet==0 ); 17621807ce37Sdrh if( pRet==0 ){ 17631807ce37Sdrh pRet = pVal; 17641807ce37Sdrh Tcl_IncrRefCount(pRet); 17651807ce37Sdrh } 176690b6bb19Sdrh rc = TCL_BREAK; 176797f2ebc1Sdrh i = nCol; 176897f2ebc1Sdrh }else if( choice==DB_EXISTS ){ 1769446a9b82Sdrh Tcl_DecrRefCount(pRet); 1770446a9b82Sdrh pRet = Tcl_NewBooleanObj(1); 1771446a9b82Sdrh Tcl_IncrRefCount(pRet); 177297f2ebc1Sdrh rc = TCL_BREAK; 177397f2ebc1Sdrh i = nCol; 177430ccda10Sdanielk1977 }else{ 177530ccda10Sdanielk1977 Tcl_ListObjAppendElement(interp, pRet, pVal); 177630ccda10Sdanielk1977 } 177730ccda10Sdanielk1977 } 177830ccda10Sdanielk1977 177992febd92Sdrh if( pScript ){ 1780d1d38488Sdrh pDb->nStep = sqlite3_stmt_status(pStmt, 1781d1d38488Sdrh SQLITE_STMTSTATUS_FULLSCAN_STEP, 0); 1782d1d38488Sdrh pDb->nSort = sqlite3_stmt_status(pStmt, 1783d1d38488Sdrh SQLITE_STMTSTATUS_SORT, 0); 178492febd92Sdrh rc = Tcl_EvalObjEx(interp, pScript, 0); 178590b6bb19Sdrh if( rc==TCL_CONTINUE ){ 178690b6bb19Sdrh rc = TCL_OK; 178730ccda10Sdanielk1977 } 178830ccda10Sdanielk1977 } 178990b6bb19Sdrh } 179090b6bb19Sdrh if( rc==TCL_BREAK ){ 179190b6bb19Sdrh rc = TCL_OK; 179290b6bb19Sdrh } 179330ccda10Sdanielk1977 179492febd92Sdrh /* Free the column name objects */ 179592febd92Sdrh if( pScript ){ 17968e556520Sdanielk1977 /* If the query returned no rows, but an array variable was 17978e556520Sdanielk1977 ** specified, call computeColumnNames() now to populate the 17988e556520Sdanielk1977 ** arrayname(*) variable. 17998e556520Sdanielk1977 */ 18008e556520Sdanielk1977 if (pArray && nCol < 0) { 18018e556520Sdanielk1977 Tcl_Obj ***ap = (pScript?&apColName:0); 18028e556520Sdanielk1977 nCol = computeColumnNames(interp, pStmt, ap, pArray); 18038e556520Sdanielk1977 } 180492febd92Sdrh for(i=0; i<nCol; i++){ 180592febd92Sdrh Tcl_DecrRefCount(apColName[i]); 180692febd92Sdrh } 180792febd92Sdrh Tcl_Free((char*)apColName); 180892febd92Sdrh } 180992febd92Sdrh 18101d895039Sdrh /* Free the bound string and blob parameters */ 18111d895039Sdrh for(i=0; i<nParm; i++){ 18121d895039Sdrh Tcl_DecrRefCount(apParm[i]); 18131d895039Sdrh } 18141d895039Sdrh if( apParm!=aParm ){ 18151d895039Sdrh Tcl_Free((char*)apParm); 18161d895039Sdrh } 18171d895039Sdrh 1818fb7e7651Sdrh /* Reset the statement. If the result code is SQLITE_SCHEMA, then 1819fb7e7651Sdrh ** flush the statement cache and try the statement again. 182092febd92Sdrh */ 1821fb7e7651Sdrh rc2 = sqlite3_reset(pStmt); 1822d1d38488Sdrh pDb->nStep = sqlite3_stmt_status(pStmt, 1823d1d38488Sdrh SQLITE_STMTSTATUS_FULLSCAN_STEP, 1); 1824d1d38488Sdrh pDb->nSort = sqlite3_stmt_status(pStmt, 1825d1d38488Sdrh SQLITE_STMTSTATUS_SORT, 1); 18268e556520Sdanielk1977 if( SQLITE_OK!=rc2 ){ 1827fb7e7651Sdrh /* If a run-time error occurs, report the error and stop reading 1828fb7e7651Sdrh ** the SQL 1829fb7e7651Sdrh */ 1830ef2cb63eSdanielk1977 Tcl_SetObjResult(interp, dbTextToObj(sqlite3_errmsg(pDb->db))); 1831fb7e7651Sdrh sqlite3_finalize(pStmt); 183230ccda10Sdanielk1977 rc = TCL_ERROR; 1833fb7e7651Sdrh if( pPreStmt ) Tcl_Free((char*)pPreStmt); 183430ccda10Sdanielk1977 break; 1835fb7e7651Sdrh }else if( pDb->maxStmt<=0 ){ 1836fb7e7651Sdrh /* If the cache is turned off, deallocated the statement */ 1837fb7e7651Sdrh if( pPreStmt ) Tcl_Free((char*)pPreStmt); 1838fb7e7651Sdrh sqlite3_finalize(pStmt); 1839fb7e7651Sdrh }else{ 1840fb7e7651Sdrh /* Everything worked and the cache is operational. 1841fb7e7651Sdrh ** Create a new SqlPreparedStmt structure if we need one. 1842fb7e7651Sdrh ** (If we already have one we can just reuse it.) 1843fb7e7651Sdrh */ 1844fb7e7651Sdrh if( pPreStmt==0 ){ 1845fb7e7651Sdrh len = zLeft - zSql; 1846d0e2a854Sdanielk1977 pPreStmt = (SqlPreparedStmt*)Tcl_Alloc( sizeof(*pPreStmt) ); 1847fb7e7651Sdrh if( pPreStmt==0 ) return TCL_ERROR; 1848fb7e7651Sdrh pPreStmt->pStmt = pStmt; 1849fb7e7651Sdrh pPreStmt->nSql = len; 1850d0e2a854Sdanielk1977 pPreStmt->zSql = sqlite3_sql(pStmt); 18514f21c4afSdrh assert( strlen30(pPreStmt->zSql)==len ); 1852d0e2a854Sdanielk1977 assert( 0==memcmp(pPreStmt->zSql, zSql, len) ); 185330ccda10Sdanielk1977 } 185430ccda10Sdanielk1977 1855fb7e7651Sdrh /* Add the prepared statement to the beginning of the cache list 1856fb7e7651Sdrh */ 1857fb7e7651Sdrh pPreStmt->pNext = pDb->stmtList; 1858fb7e7651Sdrh pPreStmt->pPrev = 0; 1859fb7e7651Sdrh if( pDb->stmtList ){ 1860fb7e7651Sdrh pDb->stmtList->pPrev = pPreStmt; 1861fb7e7651Sdrh } 1862fb7e7651Sdrh pDb->stmtList = pPreStmt; 1863fb7e7651Sdrh if( pDb->stmtLast==0 ){ 1864fb7e7651Sdrh assert( pDb->nStmt==0 ); 1865fb7e7651Sdrh pDb->stmtLast = pPreStmt; 1866fb7e7651Sdrh }else{ 1867fb7e7651Sdrh assert( pDb->nStmt>0 ); 1868fb7e7651Sdrh } 1869fb7e7651Sdrh pDb->nStmt++; 1870fb7e7651Sdrh 1871fb7e7651Sdrh /* If we have too many statement in cache, remove the surplus from the 1872fb7e7651Sdrh ** end of the cache list. 1873fb7e7651Sdrh */ 1874fb7e7651Sdrh while( pDb->nStmt>pDb->maxStmt ){ 1875fb7e7651Sdrh sqlite3_finalize(pDb->stmtLast->pStmt); 1876fb7e7651Sdrh pDb->stmtLast = pDb->stmtLast->pPrev; 1877fb7e7651Sdrh Tcl_Free((char*)pDb->stmtLast->pNext); 1878fb7e7651Sdrh pDb->stmtLast->pNext = 0; 1879fb7e7651Sdrh pDb->nStmt--; 1880fb7e7651Sdrh } 1881fb7e7651Sdrh } 1882fb7e7651Sdrh 1883fb7e7651Sdrh /* Proceed to the next statement */ 188430ccda10Sdanielk1977 zSql = zLeft; 188530ccda10Sdanielk1977 } 18861d895039Sdrh Tcl_DecrRefCount(objv[2]); 188730ccda10Sdanielk1977 18881807ce37Sdrh if( pRet ){ 1889ef2cb63eSdanielk1977 if( rc==TCL_OK ){ 189030ccda10Sdanielk1977 Tcl_SetObjResult(interp, pRet); 189130ccda10Sdanielk1977 } 1892ef2cb63eSdanielk1977 Tcl_DecrRefCount(pRet); 1893050be329Sdrh }else if( rc==TCL_OK ){ 1894050be329Sdrh Tcl_ResetResult(interp); 18951807ce37Sdrh } 189630ccda10Sdanielk1977 break; 189730ccda10Sdanielk1977 } 1898bec3f402Sdrh 1899bec3f402Sdrh /* 1900e3602be8Sdrh ** $db function NAME [-argcount N] SCRIPT 1901cabb0819Sdrh ** 1902cabb0819Sdrh ** Create a new SQL function called NAME. Whenever that function is 1903cabb0819Sdrh ** called, invoke SCRIPT to evaluate the function. 1904cabb0819Sdrh */ 1905cabb0819Sdrh case DB_FUNCTION: { 1906cabb0819Sdrh SqlFunc *pFunc; 1907d1e4733dSdrh Tcl_Obj *pScript; 1908cabb0819Sdrh char *zName; 1909e3602be8Sdrh int nArg = -1; 1910e3602be8Sdrh if( objc==6 ){ 1911e3602be8Sdrh const char *z = Tcl_GetString(objv[3]); 19124f21c4afSdrh int n = strlen30(z); 1913e3602be8Sdrh if( n>2 && strncmp(z, "-argcount",n)==0 ){ 1914e3602be8Sdrh if( Tcl_GetIntFromObj(interp, objv[4], &nArg) ) return TCL_ERROR; 1915e3602be8Sdrh if( nArg<0 ){ 1916e3602be8Sdrh Tcl_AppendResult(interp, "number of arguments must be non-negative", 1917e3602be8Sdrh (char*)0); 1918cabb0819Sdrh return TCL_ERROR; 1919cabb0819Sdrh } 1920e3602be8Sdrh } 1921e3602be8Sdrh pScript = objv[5]; 1922e3602be8Sdrh }else if( objc!=4 ){ 1923e3602be8Sdrh Tcl_WrongNumArgs(interp, 2, objv, "NAME [-argcount N] SCRIPT"); 1924e3602be8Sdrh return TCL_ERROR; 1925e3602be8Sdrh }else{ 1926d1e4733dSdrh pScript = objv[3]; 1927e3602be8Sdrh } 1928e3602be8Sdrh zName = Tcl_GetStringFromObj(objv[2], 0); 1929d1e4733dSdrh pFunc = findSqlFunc(pDb, zName); 1930cabb0819Sdrh if( pFunc==0 ) return TCL_ERROR; 1931d1e4733dSdrh if( pFunc->pScript ){ 1932d1e4733dSdrh Tcl_DecrRefCount(pFunc->pScript); 1933d1e4733dSdrh } 1934d1e4733dSdrh pFunc->pScript = pScript; 1935d1e4733dSdrh Tcl_IncrRefCount(pScript); 1936d1e4733dSdrh pFunc->useEvalObjv = safeToUseEvalObjv(interp, pScript); 1937e3602be8Sdrh rc = sqlite3_create_function(pDb->db, zName, nArg, SQLITE_UTF8, 1938d8123366Sdanielk1977 pFunc, tclSqlFunc, 0, 0); 1939fb7e7651Sdrh if( rc!=SQLITE_OK ){ 1940fb7e7651Sdrh rc = TCL_ERROR; 19419636c4e1Sdanielk1977 Tcl_SetResult(interp, (char *)sqlite3_errmsg(pDb->db), TCL_VOLATILE); 1942fb7e7651Sdrh } 1943cabb0819Sdrh break; 1944cabb0819Sdrh } 1945cabb0819Sdrh 1946cabb0819Sdrh /* 19478cbadb02Sdanielk1977 ** $db incrblob ?-readonly? ?DB? TABLE COLUMN ROWID 1948b4e9af9fSdanielk1977 */ 1949b4e9af9fSdanielk1977 case DB_INCRBLOB: { 195032a0d8bbSdanielk1977 #ifdef SQLITE_OMIT_INCRBLOB 195132a0d8bbSdanielk1977 Tcl_AppendResult(interp, "incrblob not available in this build", 0); 195232a0d8bbSdanielk1977 return TCL_ERROR; 195332a0d8bbSdanielk1977 #else 19548cbadb02Sdanielk1977 int isReadonly = 0; 1955b4e9af9fSdanielk1977 const char *zDb = "main"; 1956b4e9af9fSdanielk1977 const char *zTable; 1957b4e9af9fSdanielk1977 const char *zColumn; 1958b4e9af9fSdanielk1977 sqlite_int64 iRow; 1959b4e9af9fSdanielk1977 19608cbadb02Sdanielk1977 /* Check for the -readonly option */ 19618cbadb02Sdanielk1977 if( objc>3 && strcmp(Tcl_GetString(objv[2]), "-readonly")==0 ){ 19628cbadb02Sdanielk1977 isReadonly = 1; 19638cbadb02Sdanielk1977 } 19648cbadb02Sdanielk1977 19658cbadb02Sdanielk1977 if( objc!=(5+isReadonly) && objc!=(6+isReadonly) ){ 19668cbadb02Sdanielk1977 Tcl_WrongNumArgs(interp, 2, objv, "?-readonly? ?DB? TABLE COLUMN ROWID"); 1967b4e9af9fSdanielk1977 return TCL_ERROR; 1968b4e9af9fSdanielk1977 } 1969b4e9af9fSdanielk1977 19708cbadb02Sdanielk1977 if( objc==(6+isReadonly) ){ 1971b4e9af9fSdanielk1977 zDb = Tcl_GetString(objv[2]); 1972b4e9af9fSdanielk1977 } 1973b4e9af9fSdanielk1977 zTable = Tcl_GetString(objv[objc-3]); 1974b4e9af9fSdanielk1977 zColumn = Tcl_GetString(objv[objc-2]); 1975b4e9af9fSdanielk1977 rc = Tcl_GetWideIntFromObj(interp, objv[objc-1], &iRow); 1976b4e9af9fSdanielk1977 1977b4e9af9fSdanielk1977 if( rc==TCL_OK ){ 19788cbadb02Sdanielk1977 rc = createIncrblobChannel( 19798cbadb02Sdanielk1977 interp, pDb, zDb, zTable, zColumn, iRow, isReadonly 19808cbadb02Sdanielk1977 ); 1981b4e9af9fSdanielk1977 } 198232a0d8bbSdanielk1977 #endif 1983b4e9af9fSdanielk1977 break; 1984b4e9af9fSdanielk1977 } 1985b4e9af9fSdanielk1977 1986b4e9af9fSdanielk1977 /* 1987f11bded5Sdrh ** $db interrupt 1988f11bded5Sdrh ** 1989f11bded5Sdrh ** Interrupt the execution of the inner-most SQL interpreter. This 1990f11bded5Sdrh ** causes the SQL statement to return an error of SQLITE_INTERRUPT. 1991f11bded5Sdrh */ 1992f11bded5Sdrh case DB_INTERRUPT: { 1993f11bded5Sdrh sqlite3_interrupt(pDb->db); 1994f11bded5Sdrh break; 1995f11bded5Sdrh } 1996f11bded5Sdrh 1997f11bded5Sdrh /* 199819e2d37fSdrh ** $db nullvalue ?STRING? 199919e2d37fSdrh ** 200019e2d37fSdrh ** Change text used when a NULL comes back from the database. If ?STRING? 200119e2d37fSdrh ** is not present, then the current string used for NULL is returned. 200219e2d37fSdrh ** If STRING is present, then STRING is returned. 200319e2d37fSdrh ** 200419e2d37fSdrh */ 200519e2d37fSdrh case DB_NULLVALUE: { 200619e2d37fSdrh if( objc!=2 && objc!=3 ){ 200719e2d37fSdrh Tcl_WrongNumArgs(interp, 2, objv, "NULLVALUE"); 200819e2d37fSdrh return TCL_ERROR; 200919e2d37fSdrh } 201019e2d37fSdrh if( objc==3 ){ 201119e2d37fSdrh int len; 201219e2d37fSdrh char *zNull = Tcl_GetStringFromObj(objv[2], &len); 201319e2d37fSdrh if( pDb->zNull ){ 201419e2d37fSdrh Tcl_Free(pDb->zNull); 201519e2d37fSdrh } 201619e2d37fSdrh if( zNull && len>0 ){ 201719e2d37fSdrh pDb->zNull = Tcl_Alloc( len + 1 ); 201819e2d37fSdrh strncpy(pDb->zNull, zNull, len); 201919e2d37fSdrh pDb->zNull[len] = '\0'; 202019e2d37fSdrh }else{ 202119e2d37fSdrh pDb->zNull = 0; 202219e2d37fSdrh } 202319e2d37fSdrh } 202419e2d37fSdrh Tcl_SetObjResult(interp, dbTextToObj(pDb->zNull)); 202519e2d37fSdrh break; 202619e2d37fSdrh } 202719e2d37fSdrh 202819e2d37fSdrh /* 2029af9ff33aSdrh ** $db last_insert_rowid 2030af9ff33aSdrh ** 2031af9ff33aSdrh ** Return an integer which is the ROWID for the most recent insert. 2032af9ff33aSdrh */ 2033af9ff33aSdrh case DB_LAST_INSERT_ROWID: { 2034af9ff33aSdrh Tcl_Obj *pResult; 2035f7e678d6Sdrh Tcl_WideInt rowid; 2036af9ff33aSdrh if( objc!=2 ){ 2037af9ff33aSdrh Tcl_WrongNumArgs(interp, 2, objv, ""); 2038af9ff33aSdrh return TCL_ERROR; 2039af9ff33aSdrh } 20406f8a503dSdanielk1977 rowid = sqlite3_last_insert_rowid(pDb->db); 2041af9ff33aSdrh pResult = Tcl_GetObjResult(interp); 2042f7e678d6Sdrh Tcl_SetWideIntObj(pResult, rowid); 2043af9ff33aSdrh break; 2044af9ff33aSdrh } 2045af9ff33aSdrh 2046af9ff33aSdrh /* 20471807ce37Sdrh ** The DB_ONECOLUMN method is implemented together with DB_EVAL. 20485d9d7576Sdrh */ 20491807ce37Sdrh 20501807ce37Sdrh /* $db progress ?N CALLBACK? 20511807ce37Sdrh ** 20521807ce37Sdrh ** Invoke the given callback every N virtual machine opcodes while executing 20531807ce37Sdrh ** queries. 20541807ce37Sdrh */ 20551807ce37Sdrh case DB_PROGRESS: { 20561807ce37Sdrh if( objc==2 ){ 20571807ce37Sdrh if( pDb->zProgress ){ 20581807ce37Sdrh Tcl_AppendResult(interp, pDb->zProgress, 0); 20595d9d7576Sdrh } 20601807ce37Sdrh }else if( objc==4 ){ 20611807ce37Sdrh char *zProgress; 20621807ce37Sdrh int len; 20631807ce37Sdrh int N; 20641807ce37Sdrh if( TCL_OK!=Tcl_GetIntFromObj(interp, objv[2], &N) ){ 20651807ce37Sdrh return TCL_ERROR; 20661807ce37Sdrh }; 20671807ce37Sdrh if( pDb->zProgress ){ 20681807ce37Sdrh Tcl_Free(pDb->zProgress); 20691807ce37Sdrh } 20701807ce37Sdrh zProgress = Tcl_GetStringFromObj(objv[3], &len); 20711807ce37Sdrh if( zProgress && len>0 ){ 20721807ce37Sdrh pDb->zProgress = Tcl_Alloc( len + 1 ); 20735bb3eb9bSdrh memcpy(pDb->zProgress, zProgress, len+1); 20741807ce37Sdrh }else{ 20751807ce37Sdrh pDb->zProgress = 0; 20761807ce37Sdrh } 20771807ce37Sdrh #ifndef SQLITE_OMIT_PROGRESS_CALLBACK 20781807ce37Sdrh if( pDb->zProgress ){ 20791807ce37Sdrh pDb->interp = interp; 20801807ce37Sdrh sqlite3_progress_handler(pDb->db, N, DbProgressHandler, pDb); 20811807ce37Sdrh }else{ 20821807ce37Sdrh sqlite3_progress_handler(pDb->db, 0, 0, 0); 20831807ce37Sdrh } 20841807ce37Sdrh #endif 20851807ce37Sdrh }else{ 20861807ce37Sdrh Tcl_WrongNumArgs(interp, 2, objv, "N CALLBACK"); 20871807ce37Sdrh return TCL_ERROR; 20885d9d7576Sdrh } 20895d9d7576Sdrh break; 20905d9d7576Sdrh } 20915d9d7576Sdrh 209219e2d37fSdrh /* $db profile ?CALLBACK? 209319e2d37fSdrh ** 209419e2d37fSdrh ** Make arrangements to invoke the CALLBACK routine after each SQL statement 209519e2d37fSdrh ** that has run. The text of the SQL and the amount of elapse time are 209619e2d37fSdrh ** appended to CALLBACK before the script is run. 209719e2d37fSdrh */ 209819e2d37fSdrh case DB_PROFILE: { 209919e2d37fSdrh if( objc>3 ){ 210019e2d37fSdrh Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?"); 210119e2d37fSdrh return TCL_ERROR; 210219e2d37fSdrh }else if( objc==2 ){ 210319e2d37fSdrh if( pDb->zProfile ){ 210419e2d37fSdrh Tcl_AppendResult(interp, pDb->zProfile, 0); 210519e2d37fSdrh } 210619e2d37fSdrh }else{ 210719e2d37fSdrh char *zProfile; 210819e2d37fSdrh int len; 210919e2d37fSdrh if( pDb->zProfile ){ 211019e2d37fSdrh Tcl_Free(pDb->zProfile); 211119e2d37fSdrh } 211219e2d37fSdrh zProfile = Tcl_GetStringFromObj(objv[2], &len); 211319e2d37fSdrh if( zProfile && len>0 ){ 211419e2d37fSdrh pDb->zProfile = Tcl_Alloc( len + 1 ); 21155bb3eb9bSdrh memcpy(pDb->zProfile, zProfile, len+1); 211619e2d37fSdrh }else{ 211719e2d37fSdrh pDb->zProfile = 0; 211819e2d37fSdrh } 211919e2d37fSdrh #ifndef SQLITE_OMIT_TRACE 212019e2d37fSdrh if( pDb->zProfile ){ 212119e2d37fSdrh pDb->interp = interp; 212219e2d37fSdrh sqlite3_profile(pDb->db, DbProfileHandler, pDb); 212319e2d37fSdrh }else{ 212419e2d37fSdrh sqlite3_profile(pDb->db, 0, 0); 212519e2d37fSdrh } 212619e2d37fSdrh #endif 212719e2d37fSdrh } 212819e2d37fSdrh break; 212919e2d37fSdrh } 213019e2d37fSdrh 21315d9d7576Sdrh /* 213222fbcb8dSdrh ** $db rekey KEY 213322fbcb8dSdrh ** 213422fbcb8dSdrh ** Change the encryption key on the currently open database. 213522fbcb8dSdrh */ 213622fbcb8dSdrh case DB_REKEY: { 213722fbcb8dSdrh int nKey; 213822fbcb8dSdrh void *pKey; 213922fbcb8dSdrh if( objc!=3 ){ 214022fbcb8dSdrh Tcl_WrongNumArgs(interp, 2, objv, "KEY"); 214122fbcb8dSdrh return TCL_ERROR; 214222fbcb8dSdrh } 214322fbcb8dSdrh pKey = Tcl_GetByteArrayFromObj(objv[2], &nKey); 21449eb9e26bSdrh #ifdef SQLITE_HAS_CODEC 21452011d5f5Sdrh rc = sqlite3_rekey(pDb->db, pKey, nKey); 214622fbcb8dSdrh if( rc ){ 2147f20b21c8Sdanielk1977 Tcl_AppendResult(interp, sqlite3ErrStr(rc), 0); 214822fbcb8dSdrh rc = TCL_ERROR; 214922fbcb8dSdrh } 215022fbcb8dSdrh #endif 215122fbcb8dSdrh break; 215222fbcb8dSdrh } 215322fbcb8dSdrh 215422fbcb8dSdrh /* 2155d1d38488Sdrh ** $db status (step|sort) 2156d1d38488Sdrh ** 2157d1d38488Sdrh ** Display SQLITE_STMTSTATUS_FULLSCAN_STEP or 2158d1d38488Sdrh ** SQLITE_STMTSTATUS_SORT for the most recent eval. 2159d1d38488Sdrh */ 2160d1d38488Sdrh case DB_STATUS: { 2161d1d38488Sdrh int v; 2162d1d38488Sdrh const char *zOp; 2163d1d38488Sdrh if( objc!=3 ){ 2164d1d38488Sdrh Tcl_WrongNumArgs(interp, 2, objv, "(step|sort)"); 2165d1d38488Sdrh return TCL_ERROR; 2166d1d38488Sdrh } 2167d1d38488Sdrh zOp = Tcl_GetString(objv[2]); 2168d1d38488Sdrh if( strcmp(zOp, "step")==0 ){ 2169d1d38488Sdrh v = pDb->nStep; 2170d1d38488Sdrh }else if( strcmp(zOp, "sort")==0 ){ 2171d1d38488Sdrh v = pDb->nSort; 2172d1d38488Sdrh }else{ 2173d1d38488Sdrh Tcl_AppendResult(interp, "bad argument: should be step or sort", 2174d1d38488Sdrh (char*)0); 2175d1d38488Sdrh return TCL_ERROR; 2176d1d38488Sdrh } 2177d1d38488Sdrh Tcl_SetObjResult(interp, Tcl_NewIntObj(v)); 2178d1d38488Sdrh break; 2179d1d38488Sdrh } 2180d1d38488Sdrh 2181d1d38488Sdrh /* 2182bec3f402Sdrh ** $db timeout MILLESECONDS 2183bec3f402Sdrh ** 2184bec3f402Sdrh ** Delay for the number of milliseconds specified when a file is locked. 2185bec3f402Sdrh */ 21866d31316cSdrh case DB_TIMEOUT: { 2187bec3f402Sdrh int ms; 21886d31316cSdrh if( objc!=3 ){ 21896d31316cSdrh Tcl_WrongNumArgs(interp, 2, objv, "MILLISECONDS"); 2190bec3f402Sdrh return TCL_ERROR; 219175897234Sdrh } 21926d31316cSdrh if( Tcl_GetIntFromObj(interp, objv[2], &ms) ) return TCL_ERROR; 21936f8a503dSdanielk1977 sqlite3_busy_timeout(pDb->db, ms); 21946d31316cSdrh break; 219575897234Sdrh } 2196b5a20d3cSdrh 21970f14e2ebSdrh /* 21980f14e2ebSdrh ** $db total_changes 21990f14e2ebSdrh ** 22000f14e2ebSdrh ** Return the number of rows that were modified, inserted, or deleted 22010f14e2ebSdrh ** since the database handle was created. 22020f14e2ebSdrh */ 22030f14e2ebSdrh case DB_TOTAL_CHANGES: { 22040f14e2ebSdrh Tcl_Obj *pResult; 22050f14e2ebSdrh if( objc!=2 ){ 22060f14e2ebSdrh Tcl_WrongNumArgs(interp, 2, objv, ""); 22070f14e2ebSdrh return TCL_ERROR; 22080f14e2ebSdrh } 22090f14e2ebSdrh pResult = Tcl_GetObjResult(interp); 22100f14e2ebSdrh Tcl_SetIntObj(pResult, sqlite3_total_changes(pDb->db)); 22110f14e2ebSdrh break; 22120f14e2ebSdrh } 22130f14e2ebSdrh 2214b5a20d3cSdrh /* $db trace ?CALLBACK? 2215b5a20d3cSdrh ** 2216b5a20d3cSdrh ** Make arrangements to invoke the CALLBACK routine for each SQL statement 2217b5a20d3cSdrh ** that is executed. The text of the SQL is appended to CALLBACK before 2218b5a20d3cSdrh ** it is executed. 2219b5a20d3cSdrh */ 2220b5a20d3cSdrh case DB_TRACE: { 2221b5a20d3cSdrh if( objc>3 ){ 2222b5a20d3cSdrh Tcl_WrongNumArgs(interp, 2, objv, "?CALLBACK?"); 2223b97759edSdrh return TCL_ERROR; 2224b5a20d3cSdrh }else if( objc==2 ){ 2225b5a20d3cSdrh if( pDb->zTrace ){ 2226b5a20d3cSdrh Tcl_AppendResult(interp, pDb->zTrace, 0); 2227b5a20d3cSdrh } 2228b5a20d3cSdrh }else{ 2229b5a20d3cSdrh char *zTrace; 2230b5a20d3cSdrh int len; 2231b5a20d3cSdrh if( pDb->zTrace ){ 2232b5a20d3cSdrh Tcl_Free(pDb->zTrace); 2233b5a20d3cSdrh } 2234b5a20d3cSdrh zTrace = Tcl_GetStringFromObj(objv[2], &len); 2235b5a20d3cSdrh if( zTrace && len>0 ){ 2236b5a20d3cSdrh pDb->zTrace = Tcl_Alloc( len + 1 ); 22375bb3eb9bSdrh memcpy(pDb->zTrace, zTrace, len+1); 2238b5a20d3cSdrh }else{ 2239b5a20d3cSdrh pDb->zTrace = 0; 2240b5a20d3cSdrh } 224119e2d37fSdrh #ifndef SQLITE_OMIT_TRACE 2242b5a20d3cSdrh if( pDb->zTrace ){ 2243b5a20d3cSdrh pDb->interp = interp; 22446f8a503dSdanielk1977 sqlite3_trace(pDb->db, DbTraceHandler, pDb); 2245b5a20d3cSdrh }else{ 22466f8a503dSdanielk1977 sqlite3_trace(pDb->db, 0, 0); 2247b5a20d3cSdrh } 224819e2d37fSdrh #endif 2249b5a20d3cSdrh } 2250b5a20d3cSdrh break; 2251b5a20d3cSdrh } 2252b5a20d3cSdrh 22533d21423cSdrh /* $db transaction [-deferred|-immediate|-exclusive] SCRIPT 22543d21423cSdrh ** 22553d21423cSdrh ** Start a new transaction (if we are not already in the midst of a 22563d21423cSdrh ** transaction) and execute the TCL script SCRIPT. After SCRIPT 22573d21423cSdrh ** completes, either commit the transaction or roll it back if SCRIPT 22583d21423cSdrh ** throws an exception. Or if no new transation was started, do nothing. 22593d21423cSdrh ** pass the exception on up the stack. 22603d21423cSdrh ** 22613d21423cSdrh ** This command was inspired by Dave Thomas's talk on Ruby at the 22623d21423cSdrh ** 2005 O'Reilly Open Source Convention (OSCON). 22633d21423cSdrh */ 22643d21423cSdrh case DB_TRANSACTION: { 22653d21423cSdrh Tcl_Obj *pScript; 2266*cd38d520Sdanielk1977 const char *zBegin = "SAVEPOINT _tcl_transaction"; 2267*cd38d520Sdanielk1977 const char *zEnd; 22683d21423cSdrh if( objc!=3 && objc!=4 ){ 22693d21423cSdrh Tcl_WrongNumArgs(interp, 2, objv, "[TYPE] SCRIPT"); 22703d21423cSdrh return TCL_ERROR; 22713d21423cSdrh } 2272*cd38d520Sdanielk1977 2273*cd38d520Sdanielk1977 if( pDb->nTransaction ){ 2274*cd38d520Sdanielk1977 zBegin = "SAVEPOINT _tcl_transaction"; 2275*cd38d520Sdanielk1977 }else if( pDb->nTransaction==0 && objc==4 ){ 22763d21423cSdrh static const char *TTYPE_strs[] = { 2277ce604012Sdrh "deferred", "exclusive", "immediate", 0 22783d21423cSdrh }; 22793d21423cSdrh enum TTYPE_enum { 22803d21423cSdrh TTYPE_DEFERRED, TTYPE_EXCLUSIVE, TTYPE_IMMEDIATE 22813d21423cSdrh }; 22823d21423cSdrh int ttype; 2283b5555e7eSdrh if( Tcl_GetIndexFromObj(interp, objv[2], TTYPE_strs, "transaction type", 22843d21423cSdrh 0, &ttype) ){ 22853d21423cSdrh return TCL_ERROR; 22863d21423cSdrh } 22873d21423cSdrh switch( (enum TTYPE_enum)ttype ){ 22883d21423cSdrh case TTYPE_DEFERRED: /* no-op */; break; 22893d21423cSdrh case TTYPE_EXCLUSIVE: zBegin = "BEGIN EXCLUSIVE"; break; 22903d21423cSdrh case TTYPE_IMMEDIATE: zBegin = "BEGIN IMMEDIATE"; break; 22913d21423cSdrh } 22923d21423cSdrh } 2293*cd38d520Sdanielk1977 pScript = objv[objc-1]; 2294*cd38d520Sdanielk1977 22951f1549f8Sdrh pDb->disableAuth++; 2296*cd38d520Sdanielk1977 rc = sqlite3_exec(pDb->db, zBegin, 0, 0, 0); 22971f1549f8Sdrh pDb->disableAuth--; 2298*cd38d520Sdanielk1977 if( rc!=SQLITE_OK ){ 2299*cd38d520Sdanielk1977 Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), 0); 2300*cd38d520Sdanielk1977 return TCL_ERROR; 23013d21423cSdrh } 2302*cd38d520Sdanielk1977 2303*cd38d520Sdanielk1977 pDb->nTransaction++; 23043d21423cSdrh rc = Tcl_EvalObjEx(interp, pScript, 0); 2305*cd38d520Sdanielk1977 pDb->nTransaction--; 2306*cd38d520Sdanielk1977 2307*cd38d520Sdanielk1977 if( rc!=TCL_ERROR ){ 2308*cd38d520Sdanielk1977 if( pDb->nTransaction ){ 2309*cd38d520Sdanielk1977 zEnd = "RELEASE _tcl_transaction"; 23103d21423cSdrh }else{ 23113d21423cSdrh zEnd = "COMMIT"; 23123d21423cSdrh } 2313*cd38d520Sdanielk1977 }else{ 2314*cd38d520Sdanielk1977 if( pDb->nTransaction ){ 2315*cd38d520Sdanielk1977 zEnd = "ROLLBACK TO _tcl_transaction ; RELEASE _tcl_transaction"; 2316*cd38d520Sdanielk1977 }else{ 2317*cd38d520Sdanielk1977 zEnd = "ROLLBACK"; 2318*cd38d520Sdanielk1977 } 2319*cd38d520Sdanielk1977 } 2320*cd38d520Sdanielk1977 23211f1549f8Sdrh pDb->disableAuth++; 2322109b4350Sdrh if( sqlite3_exec(pDb->db, zEnd, 0, 0, 0) ){ 2323*cd38d520Sdanielk1977 /* This is a tricky scenario to handle. The most likely cause of an 2324*cd38d520Sdanielk1977 ** error is that the exec() above was an attempt to commit the 2325*cd38d520Sdanielk1977 ** top-level transaction that returned SQLITE_BUSY. Or, less likely, 2326*cd38d520Sdanielk1977 ** that an IO-error has occured. In either case, throw a Tcl exception 2327*cd38d520Sdanielk1977 ** and try to rollback the transaction. 2328*cd38d520Sdanielk1977 ** 2329*cd38d520Sdanielk1977 ** But it could also be that the user executed one or more BEGIN, 2330*cd38d520Sdanielk1977 ** COMMIT, SAVEPOINT, RELEASE or ROLLBACK commands that are confusing 2331*cd38d520Sdanielk1977 ** this method's logic. Not clear how this would be best handled. 2332*cd38d520Sdanielk1977 */ 2333*cd38d520Sdanielk1977 if( rc!=TCL_ERROR ){ 2334*cd38d520Sdanielk1977 Tcl_AppendResult(interp, sqlite3_errmsg(pDb->db), 0); 2335*cd38d520Sdanielk1977 rc = TCL_ERROR; 2336*cd38d520Sdanielk1977 } 2337109b4350Sdrh sqlite3_exec(pDb->db, "ROLLBACK", 0, 0, 0); 2338109b4350Sdrh } 23391f1549f8Sdrh pDb->disableAuth--; 2340*cd38d520Sdanielk1977 23413d21423cSdrh break; 23423d21423cSdrh } 23433d21423cSdrh 234494eb6a14Sdanielk1977 /* 234594eb6a14Sdanielk1977 ** $db update_hook ?script? 234671fd80bfSdanielk1977 ** $db rollback_hook ?script? 234794eb6a14Sdanielk1977 */ 234871fd80bfSdanielk1977 case DB_UPDATE_HOOK: 234971fd80bfSdanielk1977 case DB_ROLLBACK_HOOK: { 235071fd80bfSdanielk1977 235171fd80bfSdanielk1977 /* set ppHook to point at pUpdateHook or pRollbackHook, depending on 235271fd80bfSdanielk1977 ** whether [$db update_hook] or [$db rollback_hook] was invoked. 235371fd80bfSdanielk1977 */ 235471fd80bfSdanielk1977 Tcl_Obj **ppHook; 235571fd80bfSdanielk1977 if( choice==DB_UPDATE_HOOK ){ 235671fd80bfSdanielk1977 ppHook = &pDb->pUpdateHook; 235771fd80bfSdanielk1977 }else{ 235871fd80bfSdanielk1977 ppHook = &pDb->pRollbackHook; 235971fd80bfSdanielk1977 } 236071fd80bfSdanielk1977 236194eb6a14Sdanielk1977 if( objc!=2 && objc!=3 ){ 236294eb6a14Sdanielk1977 Tcl_WrongNumArgs(interp, 2, objv, "?SCRIPT?"); 236394eb6a14Sdanielk1977 return TCL_ERROR; 236494eb6a14Sdanielk1977 } 236571fd80bfSdanielk1977 if( *ppHook ){ 236671fd80bfSdanielk1977 Tcl_SetObjResult(interp, *ppHook); 236794eb6a14Sdanielk1977 if( objc==3 ){ 236871fd80bfSdanielk1977 Tcl_DecrRefCount(*ppHook); 236971fd80bfSdanielk1977 *ppHook = 0; 237094eb6a14Sdanielk1977 } 237194eb6a14Sdanielk1977 } 237294eb6a14Sdanielk1977 if( objc==3 ){ 237371fd80bfSdanielk1977 assert( !(*ppHook) ); 237494eb6a14Sdanielk1977 if( Tcl_GetCharLength(objv[2])>0 ){ 237571fd80bfSdanielk1977 *ppHook = objv[2]; 237671fd80bfSdanielk1977 Tcl_IncrRefCount(*ppHook); 237794eb6a14Sdanielk1977 } 237894eb6a14Sdanielk1977 } 237971fd80bfSdanielk1977 238071fd80bfSdanielk1977 sqlite3_update_hook(pDb->db, (pDb->pUpdateHook?DbUpdateHandler:0), pDb); 238171fd80bfSdanielk1977 sqlite3_rollback_hook(pDb->db,(pDb->pRollbackHook?DbRollbackHandler:0),pDb); 238271fd80bfSdanielk1977 238394eb6a14Sdanielk1977 break; 238494eb6a14Sdanielk1977 } 238594eb6a14Sdanielk1977 23864397de57Sdanielk1977 /* $db version 23874397de57Sdanielk1977 ** 23884397de57Sdanielk1977 ** Return the version string for this database. 23894397de57Sdanielk1977 */ 23904397de57Sdanielk1977 case DB_VERSION: { 23914397de57Sdanielk1977 Tcl_SetResult(interp, (char *)sqlite3_libversion(), TCL_STATIC); 23924397de57Sdanielk1977 break; 23934397de57Sdanielk1977 } 23944397de57Sdanielk1977 23951067fe11Stpoindex 23966d31316cSdrh } /* End of the SWITCH statement */ 239722fbcb8dSdrh return rc; 239875897234Sdrh } 239975897234Sdrh 240075897234Sdrh /* 24013570ad93Sdrh ** sqlite3 DBNAME FILENAME ?-vfs VFSNAME? ?-key KEY? ?-readonly BOOLEAN? 24029a6284c1Sdanielk1977 ** ?-create BOOLEAN? ?-nomutex BOOLEAN? 240375897234Sdrh ** 240475897234Sdrh ** This is the main Tcl command. When the "sqlite" Tcl command is 240575897234Sdrh ** invoked, this routine runs to process that command. 240675897234Sdrh ** 240775897234Sdrh ** The first argument, DBNAME, is an arbitrary name for a new 240875897234Sdrh ** database connection. This command creates a new command named 240975897234Sdrh ** DBNAME that is used to control that connection. The database 241075897234Sdrh ** connection is deleted when the DBNAME command is deleted. 241175897234Sdrh ** 24123570ad93Sdrh ** The second argument is the name of the database file. 2413fbc3eab8Sdrh ** 241475897234Sdrh */ 241522fbcb8dSdrh static int DbMain(void *cd, Tcl_Interp *interp, int objc,Tcl_Obj *const*objv){ 2416bec3f402Sdrh SqliteDb *p; 241722fbcb8dSdrh void *pKey = 0; 241822fbcb8dSdrh int nKey = 0; 241922fbcb8dSdrh const char *zArg; 242075897234Sdrh char *zErrMsg; 24213570ad93Sdrh int i; 242222fbcb8dSdrh const char *zFile; 24233570ad93Sdrh const char *zVfs = 0; 2424cc91e7f8Sdrh int flags = SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_NOMUTEX; 2425882e8e4dSdrh Tcl_DString translatedFilename; 242622fbcb8dSdrh if( objc==2 ){ 242722fbcb8dSdrh zArg = Tcl_GetStringFromObj(objv[1], 0); 242822fbcb8dSdrh if( strcmp(zArg,"-version")==0 ){ 24296f8a503dSdanielk1977 Tcl_AppendResult(interp,sqlite3_version,0); 2430647cb0e1Sdrh return TCL_OK; 2431647cb0e1Sdrh } 24329eb9e26bSdrh if( strcmp(zArg,"-has-codec")==0 ){ 24339eb9e26bSdrh #ifdef SQLITE_HAS_CODEC 243422fbcb8dSdrh Tcl_AppendResult(interp,"1",0); 243522fbcb8dSdrh #else 243622fbcb8dSdrh Tcl_AppendResult(interp,"0",0); 243722fbcb8dSdrh #endif 243822fbcb8dSdrh return TCL_OK; 243922fbcb8dSdrh } 2440fbc3eab8Sdrh } 24413570ad93Sdrh for(i=3; i+1<objc; i+=2){ 24423570ad93Sdrh zArg = Tcl_GetString(objv[i]); 244322fbcb8dSdrh if( strcmp(zArg,"-key")==0 ){ 24443570ad93Sdrh pKey = Tcl_GetByteArrayFromObj(objv[i+1], &nKey); 24453570ad93Sdrh }else if( strcmp(zArg, "-vfs")==0 ){ 24463570ad93Sdrh i++; 24473570ad93Sdrh zVfs = Tcl_GetString(objv[i]); 24483570ad93Sdrh }else if( strcmp(zArg, "-readonly")==0 ){ 24493570ad93Sdrh int b; 24503570ad93Sdrh if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR; 24513570ad93Sdrh if( b ){ 245233f4e02aSdrh flags &= ~(SQLITE_OPEN_READWRITE|SQLITE_OPEN_CREATE); 24533570ad93Sdrh flags |= SQLITE_OPEN_READONLY; 24543570ad93Sdrh }else{ 24553570ad93Sdrh flags &= ~SQLITE_OPEN_READONLY; 24563570ad93Sdrh flags |= SQLITE_OPEN_READWRITE; 24573570ad93Sdrh } 24583570ad93Sdrh }else if( strcmp(zArg, "-create")==0 ){ 24593570ad93Sdrh int b; 24603570ad93Sdrh if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR; 246133f4e02aSdrh if( b && (flags & SQLITE_OPEN_READONLY)==0 ){ 24623570ad93Sdrh flags |= SQLITE_OPEN_CREATE; 24633570ad93Sdrh }else{ 24643570ad93Sdrh flags &= ~SQLITE_OPEN_CREATE; 24653570ad93Sdrh } 24669a6284c1Sdanielk1977 }else if( strcmp(zArg, "-nomutex")==0 ){ 24679a6284c1Sdanielk1977 int b; 24689a6284c1Sdanielk1977 if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR; 24699a6284c1Sdanielk1977 if( b ){ 24709a6284c1Sdanielk1977 flags |= SQLITE_OPEN_NOMUTEX; 2471039963adSdrh flags &= ~SQLITE_OPEN_FULLMUTEX; 24729a6284c1Sdanielk1977 }else{ 24739a6284c1Sdanielk1977 flags &= ~SQLITE_OPEN_NOMUTEX; 24749a6284c1Sdanielk1977 } 2475039963adSdrh }else if( strcmp(zArg, "-fullmutex")==0 ){ 2476039963adSdrh int b; 2477039963adSdrh if( Tcl_GetBooleanFromObj(interp, objv[i+1], &b) ) return TCL_ERROR; 2478039963adSdrh if( b ){ 2479039963adSdrh flags |= SQLITE_OPEN_FULLMUTEX; 2480039963adSdrh flags &= ~SQLITE_OPEN_NOMUTEX; 2481039963adSdrh }else{ 2482039963adSdrh flags &= ~SQLITE_OPEN_FULLMUTEX; 2483039963adSdrh } 24843570ad93Sdrh }else{ 24853570ad93Sdrh Tcl_AppendResult(interp, "unknown option: ", zArg, (char*)0); 24863570ad93Sdrh return TCL_ERROR; 248722fbcb8dSdrh } 248822fbcb8dSdrh } 24893570ad93Sdrh if( objc<3 || (objc&1)!=1 ){ 249022fbcb8dSdrh Tcl_WrongNumArgs(interp, 1, objv, 24913570ad93Sdrh "HANDLE FILENAME ?-vfs VFSNAME? ?-readonly BOOLEAN? ?-create BOOLEAN?" 2492039963adSdrh " ?-nomutex BOOLEAN? ?-fullmutex BOOLEAN?" 24939eb9e26bSdrh #ifdef SQLITE_HAS_CODEC 24943570ad93Sdrh " ?-key CODECKEY?" 249522fbcb8dSdrh #endif 249622fbcb8dSdrh ); 249775897234Sdrh return TCL_ERROR; 249875897234Sdrh } 249975897234Sdrh zErrMsg = 0; 25004cdc9e84Sdrh p = (SqliteDb*)Tcl_Alloc( sizeof(*p) ); 250175897234Sdrh if( p==0 ){ 2502bec3f402Sdrh Tcl_SetResult(interp, "malloc failed", TCL_STATIC); 2503bec3f402Sdrh return TCL_ERROR; 2504bec3f402Sdrh } 2505bec3f402Sdrh memset(p, 0, sizeof(*p)); 250622fbcb8dSdrh zFile = Tcl_GetStringFromObj(objv[2], 0); 2507882e8e4dSdrh zFile = Tcl_TranslateFileName(interp, zFile, &translatedFilename); 25083570ad93Sdrh sqlite3_open_v2(zFile, &p->db, flags, zVfs); 2509882e8e4dSdrh Tcl_DStringFree(&translatedFilename); 251080290863Sdanielk1977 if( SQLITE_OK!=sqlite3_errcode(p->db) ){ 25119404d50eSdrh zErrMsg = sqlite3_mprintf("%s", sqlite3_errmsg(p->db)); 251280290863Sdanielk1977 sqlite3_close(p->db); 251380290863Sdanielk1977 p->db = 0; 251480290863Sdanielk1977 } 25152011d5f5Sdrh #ifdef SQLITE_HAS_CODEC 2516f3a65f7eSdrh if( p->db ){ 25172011d5f5Sdrh sqlite3_key(p->db, pKey, nKey); 2518f3a65f7eSdrh } 2519eb8ed70dSdrh #endif 2520bec3f402Sdrh if( p->db==0 ){ 252175897234Sdrh Tcl_SetResult(interp, zErrMsg, TCL_VOLATILE); 2522bec3f402Sdrh Tcl_Free((char*)p); 25239404d50eSdrh sqlite3_free(zErrMsg); 252475897234Sdrh return TCL_ERROR; 252575897234Sdrh } 2526fb7e7651Sdrh p->maxStmt = NUM_PREPARED_STMTS; 25275169bbc6Sdrh p->interp = interp; 252822fbcb8dSdrh zArg = Tcl_GetStringFromObj(objv[1], 0); 252922fbcb8dSdrh Tcl_CreateObjCommand(interp, zArg, DbObjCmd, (char*)p, DbDeleteCmd); 253075897234Sdrh return TCL_OK; 253175897234Sdrh } 253275897234Sdrh 253375897234Sdrh /* 253490ca9753Sdrh ** Provide a dummy Tcl_InitStubs if we are using this as a static 253590ca9753Sdrh ** library. 253690ca9753Sdrh */ 253790ca9753Sdrh #ifndef USE_TCL_STUBS 253890ca9753Sdrh # undef Tcl_InitStubs 253990ca9753Sdrh # define Tcl_InitStubs(a,b,c) 254090ca9753Sdrh #endif 254190ca9753Sdrh 254290ca9753Sdrh /* 254329bc4615Sdrh ** Make sure we have a PACKAGE_VERSION macro defined. This will be 254429bc4615Sdrh ** defined automatically by the TEA makefile. But other makefiles 254529bc4615Sdrh ** do not define it. 254629bc4615Sdrh */ 254729bc4615Sdrh #ifndef PACKAGE_VERSION 254829bc4615Sdrh # define PACKAGE_VERSION SQLITE_VERSION 254929bc4615Sdrh #endif 255029bc4615Sdrh 255129bc4615Sdrh /* 255275897234Sdrh ** Initialize this module. 255375897234Sdrh ** 255475897234Sdrh ** This Tcl module contains only a single new Tcl command named "sqlite". 255575897234Sdrh ** (Hence there is no namespace. There is no point in using a namespace 255675897234Sdrh ** if the extension only supplies one new name!) The "sqlite" command is 255775897234Sdrh ** used to open a new SQLite database. See the DbMain() routine above 255875897234Sdrh ** for additional information. 255975897234Sdrh */ 2560ad6e1370Sdrh EXTERN int Sqlite3_Init(Tcl_Interp *interp){ 256192febd92Sdrh Tcl_InitStubs(interp, "8.4", 0); 2562ef4ac8f9Sdrh Tcl_CreateObjCommand(interp, "sqlite3", (Tcl_ObjCmdProc*)DbMain, 0, 0); 256329bc4615Sdrh Tcl_PkgProvide(interp, "sqlite3", PACKAGE_VERSION); 256449766d6cSdrh Tcl_CreateObjCommand(interp, "sqlite", (Tcl_ObjCmdProc*)DbMain, 0, 0); 256529bc4615Sdrh Tcl_PkgProvide(interp, "sqlite", PACKAGE_VERSION); 256690ca9753Sdrh return TCL_OK; 256790ca9753Sdrh } 2568ad6e1370Sdrh EXTERN int Tclsqlite3_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); } 2569ad6e1370Sdrh EXTERN int Sqlite3_SafeInit(Tcl_Interp *interp){ return TCL_OK; } 2570ad6e1370Sdrh EXTERN int Tclsqlite3_SafeInit(Tcl_Interp *interp){ return TCL_OK; } 2571e2c3a659Sdrh EXTERN int Sqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2572e2c3a659Sdrh EXTERN int Tclsqlite3_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2573e2c3a659Sdrh EXTERN int Sqlite3_SafeUnload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2574e2c3a659Sdrh EXTERN int Tclsqlite3_SafeUnload(Tcl_Interp *interp, int flags){ return TCL_OK;} 2575e2c3a659Sdrh 257649766d6cSdrh 257749766d6cSdrh #ifndef SQLITE_3_SUFFIX_ONLY 2578ad6e1370Sdrh EXTERN int Sqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); } 2579ad6e1370Sdrh EXTERN int Tclsqlite_Init(Tcl_Interp *interp){ return Sqlite3_Init(interp); } 2580ad6e1370Sdrh EXTERN int Sqlite_SafeInit(Tcl_Interp *interp){ return TCL_OK; } 2581ad6e1370Sdrh EXTERN int Tclsqlite_SafeInit(Tcl_Interp *interp){ return TCL_OK; } 2582e2c3a659Sdrh EXTERN int Sqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2583e2c3a659Sdrh EXTERN int Tclsqlite_Unload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2584e2c3a659Sdrh EXTERN int Sqlite_SafeUnload(Tcl_Interp *interp, int flags){ return TCL_OK; } 2585e2c3a659Sdrh EXTERN int Tclsqlite_SafeUnload(Tcl_Interp *interp, int flags){ return TCL_OK;} 258649766d6cSdrh #endif 258775897234Sdrh 25883e27c026Sdrh #ifdef TCLSH 25893e27c026Sdrh /***************************************************************************** 25903e27c026Sdrh ** The code that follows is used to build standalone TCL interpreters 25913570ad93Sdrh ** that are statically linked with SQLite. 259275897234Sdrh */ 2593348784efSdrh 2594348784efSdrh /* 25953e27c026Sdrh ** If the macro TCLSH is one, then put in code this for the 25963e27c026Sdrh ** "main" routine that will initialize Tcl and take input from 25973570ad93Sdrh ** standard input, or if a file is named on the command line 25983570ad93Sdrh ** the TCL interpreter reads and evaluates that file. 2599348784efSdrh */ 26003e27c026Sdrh #if TCLSH==1 2601348784efSdrh static char zMainloop[] = 2602348784efSdrh "set line {}\n" 2603348784efSdrh "while {![eof stdin]} {\n" 2604348784efSdrh "if {$line!=\"\"} {\n" 2605348784efSdrh "puts -nonewline \"> \"\n" 2606348784efSdrh "} else {\n" 2607348784efSdrh "puts -nonewline \"% \"\n" 2608348784efSdrh "}\n" 2609348784efSdrh "flush stdout\n" 2610348784efSdrh "append line [gets stdin]\n" 2611348784efSdrh "if {[info complete $line]} {\n" 2612348784efSdrh "if {[catch {uplevel #0 $line} result]} {\n" 2613348784efSdrh "puts stderr \"Error: $result\"\n" 2614348784efSdrh "} elseif {$result!=\"\"} {\n" 2615348784efSdrh "puts $result\n" 2616348784efSdrh "}\n" 2617348784efSdrh "set line {}\n" 2618348784efSdrh "} else {\n" 2619348784efSdrh "append line \\n\n" 2620348784efSdrh "}\n" 2621348784efSdrh "}\n" 2622348784efSdrh ; 26233e27c026Sdrh #endif 26243e27c026Sdrh 26253e27c026Sdrh /* 26263e27c026Sdrh ** If the macro TCLSH is two, then get the main loop code out of 26273e27c026Sdrh ** the separate file "spaceanal_tcl.h". 26283e27c026Sdrh */ 26293e27c026Sdrh #if TCLSH==2 26303e27c026Sdrh static char zMainloop[] = 26313e27c026Sdrh #include "spaceanal_tcl.h" 26323e27c026Sdrh ; 26333e27c026Sdrh #endif 2634348784efSdrh 2635348784efSdrh #define TCLSH_MAIN main /* Needed to fake out mktclapp */ 2636348784efSdrh int TCLSH_MAIN(int argc, char **argv){ 2637348784efSdrh Tcl_Interp *interp; 2638297ecf14Sdrh Tcl_FindExecutable(argv[0]); 2639348784efSdrh interp = Tcl_CreateInterp(); 264038f8271fSdrh Sqlite3_Init(interp); 2641d9b0257aSdrh #ifdef SQLITE_TEST 2642d1bf3512Sdrh { 26432f999a67Sdrh extern int Md5_Init(Tcl_Interp*); 26442f999a67Sdrh extern int Sqliteconfig_Init(Tcl_Interp*); 2645d1bf3512Sdrh extern int Sqlitetest1_Init(Tcl_Interp*); 26465c4d9703Sdrh extern int Sqlitetest2_Init(Tcl_Interp*); 26475c4d9703Sdrh extern int Sqlitetest3_Init(Tcl_Interp*); 2648a6064dcfSdrh extern int Sqlitetest4_Init(Tcl_Interp*); 2649998b56c3Sdanielk1977 extern int Sqlitetest5_Init(Tcl_Interp*); 26509c06c953Sdrh extern int Sqlitetest6_Init(Tcl_Interp*); 265129c636bcSdrh extern int Sqlitetest7_Init(Tcl_Interp*); 2652b9bb7c18Sdrh extern int Sqlitetest8_Init(Tcl_Interp*); 2653a713f2c3Sdanielk1977 extern int Sqlitetest9_Init(Tcl_Interp*); 26542366940dSdrh extern int Sqlitetestasync_Init(Tcl_Interp*); 26551409be69Sdrh extern int Sqlitetest_autoext_Init(Tcl_Interp*); 2656984bfaa4Sdrh extern int Sqlitetest_func_Init(Tcl_Interp*); 265715926590Sdrh extern int Sqlitetest_hexio_Init(Tcl_Interp*); 26582f999a67Sdrh extern int Sqlitetest_malloc_Init(Tcl_Interp*); 26591a9ed0b2Sdanielk1977 extern int Sqlitetest_mutex_Init(Tcl_Interp*); 26602f999a67Sdrh extern int Sqlitetestschema_Init(Tcl_Interp*); 26612f999a67Sdrh extern int Sqlitetestsse_Init(Tcl_Interp*); 26622f999a67Sdrh extern int Sqlitetesttclvar_Init(Tcl_Interp*); 266344918fa0Sdanielk1977 extern int SqlitetestThread_Init(Tcl_Interp*); 2664a15db353Sdanielk1977 extern int SqlitetestOnefile_Init(); 26655d1f5aa6Sdanielk1977 extern int SqlitetestOsinst_Init(Tcl_Interp*); 26662e66f0b9Sdrh 26672f999a67Sdrh Md5_Init(interp); 26682f999a67Sdrh Sqliteconfig_Init(interp); 26696490bebdSdanielk1977 Sqlitetest1_Init(interp); 26705c4d9703Sdrh Sqlitetest2_Init(interp); 2671de647130Sdrh Sqlitetest3_Init(interp); 2672fc57d7bfSdanielk1977 Sqlitetest4_Init(interp); 2673998b56c3Sdanielk1977 Sqlitetest5_Init(interp); 26749c06c953Sdrh Sqlitetest6_Init(interp); 267529c636bcSdrh Sqlitetest7_Init(interp); 2676b9bb7c18Sdrh Sqlitetest8_Init(interp); 2677a713f2c3Sdanielk1977 Sqlitetest9_Init(interp); 26782366940dSdrh Sqlitetestasync_Init(interp); 26791409be69Sdrh Sqlitetest_autoext_Init(interp); 2680984bfaa4Sdrh Sqlitetest_func_Init(interp); 268115926590Sdrh Sqlitetest_hexio_Init(interp); 26822f999a67Sdrh Sqlitetest_malloc_Init(interp); 26831a9ed0b2Sdanielk1977 Sqlitetest_mutex_Init(interp); 26842f999a67Sdrh Sqlitetestschema_Init(interp); 26852f999a67Sdrh Sqlitetesttclvar_Init(interp); 268644918fa0Sdanielk1977 SqlitetestThread_Init(interp); 2687a15db353Sdanielk1977 SqlitetestOnefile_Init(interp); 26885d1f5aa6Sdanielk1977 SqlitetestOsinst_Init(interp); 2689a15db353Sdanielk1977 269089dec819Sdrh #ifdef SQLITE_SSE 26912e66f0b9Sdrh Sqlitetestsse_Init(interp); 26922e66f0b9Sdrh #endif 2693d1bf3512Sdrh } 2694d1bf3512Sdrh #endif 26953e27c026Sdrh if( argc>=2 || TCLSH==2 ){ 2696348784efSdrh int i; 2697ad42c3a3Sshess char zArgc[32]; 2698ad42c3a3Sshess sqlite3_snprintf(sizeof(zArgc), zArgc, "%d", argc-(3-TCLSH)); 2699ad42c3a3Sshess Tcl_SetVar(interp,"argc", zArgc, TCL_GLOBAL_ONLY); 2700348784efSdrh Tcl_SetVar(interp,"argv0",argv[1],TCL_GLOBAL_ONLY); 2701348784efSdrh Tcl_SetVar(interp,"argv", "", TCL_GLOBAL_ONLY); 270261212b69Sdrh for(i=3-TCLSH; i<argc; i++){ 2703348784efSdrh Tcl_SetVar(interp, "argv", argv[i], 2704348784efSdrh TCL_GLOBAL_ONLY | TCL_LIST_ELEMENT | TCL_APPEND_VALUE); 2705348784efSdrh } 27063e27c026Sdrh if( TCLSH==1 && Tcl_EvalFile(interp, argv[1])!=TCL_OK ){ 27070de8c112Sdrh const char *zInfo = Tcl_GetVar(interp, "errorInfo", TCL_GLOBAL_ONLY); 2708c61053b7Sdrh if( zInfo==0 ) zInfo = interp->result; 2709c61053b7Sdrh fprintf(stderr,"%s: %s\n", *argv, zInfo); 2710348784efSdrh return 1; 2711348784efSdrh } 27123e27c026Sdrh } 27133e27c026Sdrh if( argc<=1 || TCLSH==2 ){ 2714348784efSdrh Tcl_GlobalEval(interp, zMainloop); 2715348784efSdrh } 2716348784efSdrh return 0; 2717348784efSdrh } 2718348784efSdrh #endif /* TCLSH */ 2719