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