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