Index: third_party/sqlite/src/src/shell.c |
diff --git a/third_party/sqlite/src/src/shell.c b/third_party/sqlite/src/src/shell.c |
index 84d07440ecad89ccc3a97f3b40606fa89a6681f0..13685c2c184b84c8a068964cf2d2264a0a3c778c 100644 |
--- a/third_party/sqlite/src/src/shell.c |
+++ b/third_party/sqlite/src/src/shell.c |
@@ -11,8 +11,6 @@ |
************************************************************************* |
** This file contains code to implement the "sqlite" command line |
** utility for accessing SQLite databases. |
-** |
-** $Id: shell.c,v 1.210 2009/05/31 17:16:10 drh Exp $ |
*/ |
#if defined(_WIN32) || defined(WIN32) |
/* This needs to come before any includes for MSVC compiler */ |
@@ -40,10 +38,14 @@ |
# include <unistd.h> |
#endif |
+#ifdef HAVE_EDITLINE |
+# include <editline/editline.h> |
+#endif |
#if defined(HAVE_READLINE) && HAVE_READLINE==1 |
# include <readline/readline.h> |
# include <readline/history.h> |
-#else |
+#endif |
+#if !defined(HAVE_EDITLINE) && (!defined(HAVE_READLINE) || HAVE_READLINE!=1) |
# define readline(p) local_getline(p,stdin) |
# define add_history(X) |
# define read_history(X) |
@@ -69,6 +71,9 @@ extern int isatty(); |
#define isatty(x) 1 |
#endif |
+/* True if the timer is enabled */ |
+static int enableTimer = 0; |
+ |
#if !defined(_WIN32) && !defined(WIN32) && !defined(__OS2__) && !defined(__RTP__) && !defined(_WRS_KERNEL) |
#include <sys/time.h> |
#include <sys/resource.h> |
@@ -76,9 +81,6 @@ extern int isatty(); |
/* Saved resource information for the beginning of an operation */ |
static struct rusage sBegin; |
-/* True if the timer is enabled */ |
-static int enableTimer = 0; |
- |
/* |
** Begin timing an operation |
*/ |
@@ -106,881 +108,93 @@ static void endTimer(void){ |
timeDiff(&sBegin.ru_stime, &sEnd.ru_stime)); |
} |
} |
+ |
#define BEGIN_TIMER beginTimer() |
#define END_TIMER endTimer() |
#define HAS_TIMER 1 |
-#else |
-#define BEGIN_TIMER |
-#define END_TIMER |
-#define HAS_TIMER 0 |
-#endif |
- |
-/* |
-** Used to prevent warnings about unused parameters |
-*/ |
-#define UNUSED_PARAMETER(x) (void)(x) |
- |
- |
-/************************************************************************** |
-*************************************************************************** |
-** Begin genfkey logic. |
-*/ |
-#if !defined(SQLITE_OMIT_VIRTUALTABLE) && !defined SQLITE_OMIT_SUBQUERY |
- |
-#define GENFKEY_ERROR 1 |
-#define GENFKEY_DROPTRIGGER 2 |
-#define GENFKEY_CREATETRIGGER 3 |
-static int genfkey_create_triggers(sqlite3 *, const char *, void *, |
- int (*)(void *, int, const char *) |
-); |
- |
-struct GenfkeyCb { |
- void *pCtx; |
- int eType; |
- int (*xData)(void *, int, const char *); |
-}; |
-typedef struct GenfkeyCb GenfkeyCb; |
- |
-/* The code in this file defines a sqlite3 virtual-table module that |
-** provides a read-only view of the current database schema. There is one |
-** row in the schema table for each column in the database schema. |
-*/ |
-#define SCHEMA \ |
-"CREATE TABLE x(" \ |
- "database," /* Name of database (i.e. main, temp etc.) */ \ |
- "tablename," /* Name of table */ \ |
- "cid," /* Column number (from left-to-right, 0 upward) */ \ |
- "name," /* Column name */ \ |
- "type," /* Specified type (i.e. VARCHAR(32)) */ \ |
- "not_null," /* Boolean. True if NOT NULL was specified */ \ |
- "dflt_value," /* Default value for this column */ \ |
- "pk" /* True if this column is part of the primary key */ \ |
-")" |
- |
-#define SCHEMA2 \ |
-"CREATE TABLE x(" \ |
- "database," /* Name of database (i.e. main, temp etc.) */ \ |
- "from_tbl," /* Name of table */ \ |
- "fkid," \ |
- "seq," \ |
- "to_tbl," \ |
- "from_col," \ |
- "to_col," \ |
- "on_update," \ |
- "on_delete," \ |
- "match" \ |
-")" |
- |
-#define SCHEMA3 \ |
-"CREATE TABLE x(" \ |
- "database," /* Name of database (i.e. main, temp etc.) */ \ |
- "tablename," /* Name of table */ \ |
- "seq," \ |
- "name," \ |
- "isunique" \ |
-")" |
- |
-#define SCHEMA4 \ |
-"CREATE TABLE x(" \ |
- "database," /* Name of database (i.e. main, temp etc.) */ \ |
- "indexname," /* Name of table */ \ |
- "seqno," \ |
- "cid," \ |
- "name" \ |
-")" |
- |
-#define SCHEMA5 \ |
-"CREATE TABLE x(" \ |
- "database," /* Name of database (i.e. main, temp etc.) */ \ |
- "triggername," /* Name of trigger */ \ |
- "dummy" /* Unused */ \ |
-")" |
- |
-typedef struct SchemaTable SchemaTable; |
-struct SchemaTable { |
- const char *zName; |
- const char *zObject; |
- const char *zPragma; |
- const char *zSchema; |
-} aSchemaTable[] = { |
- { "table_info", "table", "PRAGMA %Q.table_info(%Q)", SCHEMA }, |
- { "foreign_key_list", "table", "PRAGMA %Q.foreign_key_list(%Q)", SCHEMA2 }, |
- { "index_list", "table", "PRAGMA %Q.index_list(%Q)", SCHEMA3 }, |
- { "index_info", "index", "PRAGMA %Q.index_info(%Q)", SCHEMA4 }, |
- { "trigger_list", "trigger", "SELECT 1", SCHEMA5 }, |
- { 0, 0, 0, 0 } |
-}; |
- |
-typedef struct schema_vtab schema_vtab; |
-typedef struct schema_cursor schema_cursor; |
- |
-/* A schema table object */ |
-struct schema_vtab { |
- sqlite3_vtab base; |
- sqlite3 *db; |
- SchemaTable *pType; |
-}; |
- |
-/* A schema table cursor object */ |
-struct schema_cursor { |
- sqlite3_vtab_cursor base; |
- sqlite3_stmt *pDbList; |
- sqlite3_stmt *pTableList; |
- sqlite3_stmt *pColumnList; |
- int rowid; |
-}; |
- |
-/* |
-** Table destructor for the schema module. |
-*/ |
-static int schemaDestroy(sqlite3_vtab *pVtab){ |
- sqlite3_free(pVtab); |
- return 0; |
-} |
- |
-/* |
-** Table constructor for the schema module. |
-*/ |
-static int schemaCreate( |
- sqlite3 *db, |
- void *pAux, |
- int argc, const char *const*argv, |
- sqlite3_vtab **ppVtab, |
- char **pzErr |
-){ |
- int rc = SQLITE_NOMEM; |
- schema_vtab *pVtab; |
- SchemaTable *pType = &aSchemaTable[0]; |
- |
- UNUSED_PARAMETER(pzErr); |
- if( argc>3 ){ |
- int i; |
- pType = 0; |
- for(i=0; aSchemaTable[i].zName; i++){ |
- if( 0==strcmp(argv[3], aSchemaTable[i].zName) ){ |
- pType = &aSchemaTable[i]; |
- } |
- } |
- if( !pType ){ |
- return SQLITE_ERROR; |
- } |
- } |
- |
- pVtab = sqlite3_malloc(sizeof(schema_vtab)); |
- if( pVtab ){ |
- memset(pVtab, 0, sizeof(schema_vtab)); |
- pVtab->db = (sqlite3 *)pAux; |
- pVtab->pType = pType; |
- rc = sqlite3_declare_vtab(db, pType->zSchema); |
- } |
- *ppVtab = (sqlite3_vtab *)pVtab; |
- return rc; |
-} |
- |
-/* |
-** Open a new cursor on the schema table. |
-*/ |
-static int schemaOpen(sqlite3_vtab *pVTab, sqlite3_vtab_cursor **ppCursor){ |
- int rc = SQLITE_NOMEM; |
- schema_cursor *pCur; |
- UNUSED_PARAMETER(pVTab); |
- pCur = sqlite3_malloc(sizeof(schema_cursor)); |
- if( pCur ){ |
- memset(pCur, 0, sizeof(schema_cursor)); |
- *ppCursor = (sqlite3_vtab_cursor *)pCur; |
- rc = SQLITE_OK; |
- } |
- return rc; |
-} |
- |
-/* |
-** Close a schema table cursor. |
-*/ |
-static int schemaClose(sqlite3_vtab_cursor *cur){ |
- schema_cursor *pCur = (schema_cursor *)cur; |
- sqlite3_finalize(pCur->pDbList); |
- sqlite3_finalize(pCur->pTableList); |
- sqlite3_finalize(pCur->pColumnList); |
- sqlite3_free(pCur); |
- return SQLITE_OK; |
-} |
- |
-static void columnToResult(sqlite3_context *ctx, sqlite3_stmt *pStmt, int iCol){ |
- switch( sqlite3_column_type(pStmt, iCol) ){ |
- case SQLITE_NULL: |
- sqlite3_result_null(ctx); |
- break; |
- case SQLITE_INTEGER: |
- sqlite3_result_int64(ctx, sqlite3_column_int64(pStmt, iCol)); |
- break; |
- case SQLITE_FLOAT: |
- sqlite3_result_double(ctx, sqlite3_column_double(pStmt, iCol)); |
- break; |
- case SQLITE_TEXT: { |
- const char *z = (const char *)sqlite3_column_text(pStmt, iCol); |
- sqlite3_result_text(ctx, z, -1, SQLITE_TRANSIENT); |
- break; |
- } |
- } |
-} |
- |
-/* |
-** Retrieve a column of data. |
-*/ |
-static int schemaColumn(sqlite3_vtab_cursor *cur, sqlite3_context *ctx, int i){ |
- schema_cursor *pCur = (schema_cursor *)cur; |
- switch( i ){ |
- case 0: |
- columnToResult(ctx, pCur->pDbList, 1); |
- break; |
- case 1: |
- columnToResult(ctx, pCur->pTableList, 0); |
- break; |
- default: |
- columnToResult(ctx, pCur->pColumnList, i-2); |
- break; |
- } |
- return SQLITE_OK; |
-} |
-/* |
-** Retrieve the current rowid. |
-*/ |
-static int schemaRowid(sqlite3_vtab_cursor *cur, sqlite_int64 *pRowid){ |
- schema_cursor *pCur = (schema_cursor *)cur; |
- *pRowid = pCur->rowid; |
- return SQLITE_OK; |
-} |
+#elif (defined(_WIN32) || defined(WIN32)) |
-static int finalize(sqlite3_stmt **ppStmt){ |
- int rc = sqlite3_finalize(*ppStmt); |
- *ppStmt = 0; |
- return rc; |
-} |
+#include <windows.h> |
-static int schemaEof(sqlite3_vtab_cursor *cur){ |
- schema_cursor *pCur = (schema_cursor *)cur; |
- return (pCur->pDbList ? 0 : 1); |
-} |
+/* Saved resource information for the beginning of an operation */ |
+static HANDLE hProcess; |
+static FILETIME ftKernelBegin; |
+static FILETIME ftUserBegin; |
+typedef BOOL (WINAPI *GETPROCTIMES)(HANDLE, LPFILETIME, LPFILETIME, LPFILETIME, LPFILETIME); |
+static GETPROCTIMES getProcessTimesAddr = NULL; |
/* |
-** Advance the cursor to the next row. |
-*/ |
-static int schemaNext(sqlite3_vtab_cursor *cur){ |
- int rc = SQLITE_OK; |
- schema_cursor *pCur = (schema_cursor *)cur; |
- schema_vtab *pVtab = (schema_vtab *)(cur->pVtab); |
- char *zSql = 0; |
- |
- while( !pCur->pColumnList || SQLITE_ROW!=sqlite3_step(pCur->pColumnList) ){ |
- if( SQLITE_OK!=(rc = finalize(&pCur->pColumnList)) ) goto next_exit; |
- |
- while( !pCur->pTableList || SQLITE_ROW!=sqlite3_step(pCur->pTableList) ){ |
- if( SQLITE_OK!=(rc = finalize(&pCur->pTableList)) ) goto next_exit; |
- |
- assert(pCur->pDbList); |
- while( SQLITE_ROW!=sqlite3_step(pCur->pDbList) ){ |
- rc = finalize(&pCur->pDbList); |
- goto next_exit; |
- } |
- |
- /* Set zSql to the SQL to pull the list of tables from the |
- ** sqlite_master (or sqlite_temp_master) table of the database |
- ** identfied by the row pointed to by the SQL statement pCur->pDbList |
- ** (iterating through a "PRAGMA database_list;" statement). |
- */ |
- if( sqlite3_column_int(pCur->pDbList, 0)==1 ){ |
- zSql = sqlite3_mprintf( |
- "SELECT name FROM sqlite_temp_master WHERE type=%Q", |
- pVtab->pType->zObject |
- ); |
- }else{ |
- sqlite3_stmt *pDbList = pCur->pDbList; |
- zSql = sqlite3_mprintf( |
- "SELECT name FROM %Q.sqlite_master WHERE type=%Q", |
- sqlite3_column_text(pDbList, 1), pVtab->pType->zObject |
- ); |
- } |
- if( !zSql ){ |
- rc = SQLITE_NOMEM; |
- goto next_exit; |
- } |
- |
- rc = sqlite3_prepare(pVtab->db, zSql, -1, &pCur->pTableList, 0); |
- sqlite3_free(zSql); |
- if( rc!=SQLITE_OK ) goto next_exit; |
- } |
- |
- /* Set zSql to the SQL to the table_info pragma for the table currently |
- ** identified by the rows pointed to by statements pCur->pDbList and |
- ** pCur->pTableList. |
+** Check to see if we have timer support. Return 1 if necessary |
+** support found (or found previously). |
+*/ |
+static int hasTimer(void){ |
+ if( getProcessTimesAddr ){ |
+ return 1; |
+ } else { |
+ /* GetProcessTimes() isn't supported in WIN95 and some other Windows versions. |
+ ** See if the version we are running on has it, and if it does, save off |
+ ** a pointer to it and the current process handle. |
*/ |
- zSql = sqlite3_mprintf(pVtab->pType->zPragma, |
- sqlite3_column_text(pCur->pDbList, 1), |
- sqlite3_column_text(pCur->pTableList, 0) |
- ); |
- |
- if( !zSql ){ |
- rc = SQLITE_NOMEM; |
- goto next_exit; |
+ hProcess = GetCurrentProcess(); |
+ if( hProcess ){ |
+ HINSTANCE hinstLib = LoadLibrary(TEXT("Kernel32.dll")); |
+ if( NULL != hinstLib ){ |
+ getProcessTimesAddr = (GETPROCTIMES) GetProcAddress(hinstLib, "GetProcessTimes"); |
+ if( NULL != getProcessTimesAddr ){ |
+ return 1; |
+ } |
+ FreeLibrary(hinstLib); |
+ } |
} |
- rc = sqlite3_prepare(pVtab->db, zSql, -1, &pCur->pColumnList, 0); |
- sqlite3_free(zSql); |
- if( rc!=SQLITE_OK ) goto next_exit; |
} |
- pCur->rowid++; |
- |
-next_exit: |
- /* TODO: Handle rc */ |
- return rc; |
-} |
- |
-/* |
-** Reset a schema table cursor. |
-*/ |
-static int schemaFilter( |
- sqlite3_vtab_cursor *pVtabCursor, |
- int idxNum, const char *idxStr, |
- int argc, sqlite3_value **argv |
-){ |
- int rc; |
- schema_vtab *pVtab = (schema_vtab *)(pVtabCursor->pVtab); |
- schema_cursor *pCur = (schema_cursor *)pVtabCursor; |
- UNUSED_PARAMETER(idxNum); |
- UNUSED_PARAMETER(idxStr); |
- UNUSED_PARAMETER(argc); |
- UNUSED_PARAMETER(argv); |
- pCur->rowid = 0; |
- finalize(&pCur->pTableList); |
- finalize(&pCur->pColumnList); |
- finalize(&pCur->pDbList); |
- rc = sqlite3_prepare(pVtab->db,"SELECT 0, 'main'", -1, &pCur->pDbList, 0); |
- return (rc==SQLITE_OK ? schemaNext(pVtabCursor) : rc); |
-} |
- |
-/* |
-** Analyse the WHERE condition. |
-*/ |
-static int schemaBestIndex(sqlite3_vtab *tab, sqlite3_index_info *pIdxInfo){ |
- UNUSED_PARAMETER(tab); |
- UNUSED_PARAMETER(pIdxInfo); |
- return SQLITE_OK; |
-} |
- |
-/* |
-** A virtual table module that merely echos method calls into TCL |
-** variables. |
-*/ |
-static sqlite3_module schemaModule = { |
- 0, /* iVersion */ |
- schemaCreate, |
- schemaCreate, |
- schemaBestIndex, |
- schemaDestroy, |
- schemaDestroy, |
- schemaOpen, /* xOpen - open a cursor */ |
- schemaClose, /* xClose - close a cursor */ |
- schemaFilter, /* xFilter - configure scan constraints */ |
- schemaNext, /* xNext - advance a cursor */ |
- schemaEof, /* xEof */ |
- schemaColumn, /* xColumn - read data */ |
- schemaRowid, /* xRowid - read data */ |
- 0, /* xUpdate */ |
- 0, /* xBegin */ |
- 0, /* xSync */ |
- 0, /* xCommit */ |
- 0, /* xRollback */ |
- 0, /* xFindMethod */ |
- 0, /* xRename */ |
-}; |
- |
-/* |
-** Extension load function. |
-*/ |
-static int installSchemaModule(sqlite3 *db, sqlite3 *sdb){ |
- sqlite3_create_module(db, "schema", &schemaModule, (void *)sdb); |
return 0; |
} |
/* |
-** sj(zValue, zJoin) |
-** |
-** The following block contains the implementation of an aggregate |
-** function that returns a string. Each time the function is stepped, |
-** it appends data to an internal buffer. When the aggregate is finalized, |
-** the contents of the buffer are returned. |
-** |
-** The first time the aggregate is stepped the buffer is set to a copy |
-** of the first argument. The second time and subsequent times it is |
-** stepped a copy of the second argument is appended to the buffer, then |
-** a copy of the first. |
-** |
-** Example: |
-** |
-** INSERT INTO t1(a) VALUES('1'); |
-** INSERT INTO t1(a) VALUES('2'); |
-** INSERT INTO t1(a) VALUES('3'); |
-** SELECT sj(a, ', ') FROM t1; |
-** |
-** => "1, 2, 3" |
-** |
+** Begin timing an operation |
*/ |
-struct StrBuffer { |
- char *zBuf; |
-}; |
-typedef struct StrBuffer StrBuffer; |
-static void joinFinalize(sqlite3_context *context){ |
- StrBuffer *p; |
- p = (StrBuffer *)sqlite3_aggregate_context(context, sizeof(StrBuffer)); |
- sqlite3_result_text(context, p->zBuf, -1, SQLITE_TRANSIENT); |
- sqlite3_free(p->zBuf); |
-} |
-static void joinStep( |
- sqlite3_context *context, |
- int argc, |
- sqlite3_value **argv |
-){ |
- StrBuffer *p; |
- UNUSED_PARAMETER(argc); |
- p = (StrBuffer *)sqlite3_aggregate_context(context, sizeof(StrBuffer)); |
- if( p->zBuf==0 ){ |
- p->zBuf = sqlite3_mprintf("%s", sqlite3_value_text(argv[0])); |
- }else{ |
- char *zTmp = p->zBuf; |
- p->zBuf = sqlite3_mprintf("%s%s%s", |
- zTmp, sqlite3_value_text(argv[1]), sqlite3_value_text(argv[0]) |
- ); |
- sqlite3_free(zTmp); |
+static void beginTimer(void){ |
+ if( enableTimer && getProcessTimesAddr ){ |
+ FILETIME ftCreation, ftExit; |
+ getProcessTimesAddr(hProcess, &ftCreation, &ftExit, &ftKernelBegin, &ftUserBegin); |
} |
} |
-/* |
-** dq(zString) |
-** |
-** This scalar function accepts a single argument and interprets it as |
-** a text value. The return value is the argument enclosed in double |
-** quotes. If any double quote characters are present in the argument, |
-** these are escaped. |
-** |
-** dq('the raven "Nevermore."') == '"the raven ""Nevermore."""' |
-*/ |
-static void doublequote( |
- sqlite3_context *context, |
- int argc, |
- sqlite3_value **argv |
-){ |
- int ii; |
- char *zOut; |
- char *zCsr; |
- const char *zIn = (const char *)sqlite3_value_text(argv[0]); |
- int nIn = sqlite3_value_bytes(argv[0]); |
- |
- UNUSED_PARAMETER(argc); |
- zOut = sqlite3_malloc(nIn*2+3); |
- zCsr = zOut; |
- *zCsr++ = '"'; |
- for(ii=0; ii<nIn; ii++){ |
- *zCsr++ = zIn[ii]; |
- if( zIn[ii]=='"' ){ |
- *zCsr++ = '"'; |
- } |
- } |
- *zCsr++ = '"'; |
- *zCsr++ = '\0'; |
- |
- sqlite3_result_text(context, zOut, -1, SQLITE_TRANSIENT); |
- sqlite3_free(zOut); |
+/* Return the difference of two FILETIME structs in seconds */ |
+static double timeDiff(FILETIME *pStart, FILETIME *pEnd){ |
+ sqlite_int64 i64Start = *((sqlite_int64 *) pStart); |
+ sqlite_int64 i64End = *((sqlite_int64 *) pEnd); |
+ return (double) ((i64End - i64Start) / 10000000.0); |
} |
/* |
-** multireplace(zString, zSearch1, zReplace1, ...) |
+** Print the timing results. |
*/ |
-static void multireplace( |
- sqlite3_context *context, |
- int argc, |
- sqlite3_value **argv |
-){ |
- int i = 0; |
- char *zOut = 0; |
- int nOut = 0; |
- int nMalloc = 0; |
- const char *zIn = (const char *)sqlite3_value_text(argv[0]); |
- int nIn = sqlite3_value_bytes(argv[0]); |
- |
- while( i<nIn ){ |
- const char *zCopy = &zIn[i]; |
- int nCopy = 1; |
- int nReplace = 1; |
- int j; |
- for(j=1; j<(argc-1); j+=2){ |
- const char *z = (const char *)sqlite3_value_text(argv[j]); |
- int n = sqlite3_value_bytes(argv[j]); |
- if( n<=(nIn-i) && 0==strncmp(z, zCopy, n) ){ |
- zCopy = (const char *)sqlite3_value_text(argv[j+1]); |
- nCopy = sqlite3_value_bytes(argv[j+1]); |
- nReplace = n; |
- break; |
- } |
- } |
- if( (nOut+nCopy)>nMalloc ){ |
- char *zNew; |
- nMalloc = 16 + (nOut+nCopy)*2; |
- zNew = (char*)sqlite3_realloc(zOut, nMalloc); |
- if( zNew==0 ){ |
- sqlite3_result_error_nomem(context); |
- return; |
- }else{ |
- zOut = zNew; |
- } |
- } |
- assert( nMalloc>=(nOut+nCopy) ); |
- memcpy(&zOut[nOut], zCopy, nCopy); |
- i += nReplace; |
- nOut += nCopy; |
+static void endTimer(void){ |
+ if( enableTimer && getProcessTimesAddr){ |
+ FILETIME ftCreation, ftExit, ftKernelEnd, ftUserEnd; |
+ getProcessTimesAddr(hProcess, &ftCreation, &ftExit, &ftKernelEnd, &ftUserEnd); |
+ printf("CPU Time: user %f sys %f\n", |
+ timeDiff(&ftUserBegin, &ftUserEnd), |
+ timeDiff(&ftKernelBegin, &ftKernelEnd)); |
} |
- |
- sqlite3_result_text(context, zOut, nOut, SQLITE_TRANSIENT); |
- sqlite3_free(zOut); |
} |
-/* |
-** A callback for sqlite3_exec() invokes the callback specified by the |
-** GenfkeyCb structure pointed to by the void* passed as the first argument. |
-*/ |
-static int invokeCallback(void *p, int nArg, char **azArg, char **azCol){ |
- GenfkeyCb *pCb = (GenfkeyCb *)p; |
- UNUSED_PARAMETER(nArg); |
- UNUSED_PARAMETER(azCol); |
- return pCb->xData(pCb->pCtx, pCb->eType, azArg[0]); |
-} |
+#define BEGIN_TIMER beginTimer() |
+#define END_TIMER endTimer() |
+#define HAS_TIMER hasTimer() |
-int detectSchemaProblem( |
- sqlite3 *db, /* Database connection */ |
- const char *zMessage, /* English language error message */ |
- const char *zSql, /* SQL statement to run */ |
- GenfkeyCb *pCb |
-){ |
- sqlite3_stmt *pStmt; |
- int rc; |
- rc = sqlite3_prepare(db, zSql, -1, &pStmt, 0); |
- if( rc!=SQLITE_OK ){ |
- return rc; |
- } |
- while( SQLITE_ROW==sqlite3_step(pStmt) ){ |
- char *zDel; |
- int iFk = sqlite3_column_int(pStmt, 0); |
- const char *zTab = (const char *)sqlite3_column_text(pStmt, 1); |
- zDel = sqlite3_mprintf("Error in table %s: %s", zTab, zMessage); |
- rc = pCb->xData(pCb->pCtx, pCb->eType, zDel); |
- sqlite3_free(zDel); |
- if( rc!=SQLITE_OK ) return rc; |
- zDel = sqlite3_mprintf( |
- "DELETE FROM temp.fkey WHERE from_tbl = %Q AND fkid = %d" |
- , zTab, iFk |
- ); |
- sqlite3_exec(db, zDel, 0, 0, 0); |
- sqlite3_free(zDel); |
- } |
- sqlite3_finalize(pStmt); |
- return SQLITE_OK; |
-} |
+#else |
+#define BEGIN_TIMER |
+#define END_TIMER |
+#define HAS_TIMER 0 |
+#endif |
/* |
-** Create and populate temporary table "fkey". |
+** Used to prevent warnings about unused parameters |
*/ |
-static int populateTempTable(sqlite3 *db, GenfkeyCb *pCallback){ |
- int rc; |
- |
- rc = sqlite3_exec(db, |
- "CREATE VIRTUAL TABLE temp.v_fkey USING schema(foreign_key_list);" |
- "CREATE VIRTUAL TABLE temp.v_col USING schema(table_info);" |
- "CREATE VIRTUAL TABLE temp.v_idxlist USING schema(index_list);" |
- "CREATE VIRTUAL TABLE temp.v_idxinfo USING schema(index_info);" |
- "CREATE VIRTUAL TABLE temp.v_triggers USING schema(trigger_list);" |
- "CREATE TABLE temp.fkey AS " |
- "SELECT from_tbl, to_tbl, fkid, from_col, to_col, on_update, on_delete " |
- "FROM temp.v_fkey WHERE database = 'main';" |
- , 0, 0, 0 |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- rc = detectSchemaProblem(db, "foreign key columns do not exist", |
- "SELECT fkid, from_tbl " |
- "FROM temp.fkey " |
- "WHERE to_col IS NOT NULL AND NOT EXISTS (SELECT 1 " |
- "FROM temp.v_col WHERE tablename=to_tbl AND name==to_col" |
- ")", pCallback |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* At this point the temp.fkey table is mostly populated. If any foreign |
- ** keys were specified so that they implicitly refer to they primary |
- ** key of the parent table, the "to_col" values of the temp.fkey rows |
- ** are still set to NULL. |
- ** |
- ** This is easily fixed for single column primary keys, but not for |
- ** composites. With a composite primary key, there is no way to reliably |
- ** query sqlite for the order in which the columns that make up the |
- ** composite key were declared i.e. there is no way to tell if the |
- ** schema actually contains "PRIMARY KEY(a, b)" or "PRIMARY KEY(b, a)". |
- ** Therefore, this case is not handled. The following function call |
- ** detects instances of this case. |
- */ |
- rc = detectSchemaProblem(db, "implicit mapping to composite primary key", |
- "SELECT fkid, from_tbl " |
- "FROM temp.fkey " |
- "WHERE to_col IS NULL " |
- "GROUP BY fkid, from_tbl HAVING count(*) > 1", pCallback |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* Detect attempts to implicitly map to the primary key of a table |
- ** that has no primary key column. |
- */ |
- rc = detectSchemaProblem(db, "implicit mapping to non-existant primary key", |
- "SELECT fkid, from_tbl " |
- "FROM temp.fkey " |
- "WHERE to_col IS NULL AND NOT EXISTS " |
- "(SELECT 1 FROM temp.v_col WHERE pk AND tablename = temp.fkey.to_tbl)" |
- , pCallback |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* Fix all the implicit primary key mappings in the temp.fkey table. */ |
- rc = sqlite3_exec(db, |
- "UPDATE temp.fkey SET to_col = " |
- "(SELECT name FROM temp.v_col WHERE pk AND tablename=temp.fkey.to_tbl)" |
- " WHERE to_col IS NULL;" |
- , 0, 0, 0 |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- /* Now check that all all parent keys are either primary keys or |
- ** subject to a unique constraint. |
- */ |
- rc = sqlite3_exec(db, |
- "CREATE TABLE temp.idx2 AS SELECT " |
- "il.tablename AS tablename," |
- "ii.indexname AS indexname," |
- "ii.name AS col " |
- "FROM temp.v_idxlist AS il, temp.v_idxinfo AS ii " |
- "WHERE il.isunique AND il.database='main' AND ii.indexname = il.name;" |
- "INSERT INTO temp.idx2 " |
- "SELECT tablename, 'pk', name FROM temp.v_col WHERE pk;" |
- |
- "CREATE TABLE temp.idx AS SELECT " |
- "tablename, indexname, sj(dq(col),',') AS cols " |
- "FROM (SELECT * FROM temp.idx2 ORDER BY col) " |
- "GROUP BY tablename, indexname;" |
- |
- "CREATE TABLE temp.fkey2 AS SELECT " |
- "fkid, from_tbl, to_tbl, sj(dq(to_col),',') AS cols " |
- "FROM (SELECT * FROM temp.fkey ORDER BY to_col) " |
- "GROUP BY fkid, from_tbl;" |
- |
- "CREATE TABLE temp.triggers AS SELECT " |
- "triggername FROM temp.v_triggers WHERE database='main' AND " |
- "triggername LIKE 'genfkey%';" |
- , 0, 0, 0 |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- rc = detectSchemaProblem(db, "foreign key is not unique", |
- "SELECT fkid, from_tbl " |
- "FROM temp.fkey2 " |
- "WHERE NOT EXISTS (SELECT 1 " |
- "FROM temp.idx WHERE tablename=to_tbl AND fkey2.cols==idx.cols" |
- ")", pCallback |
- ); |
- if( rc!=SQLITE_OK ) return rc; |
- |
- return rc; |
-} |
- |
-#define GENFKEY_ERROR 1 |
-#define GENFKEY_DROPTRIGGER 2 |
-#define GENFKEY_CREATETRIGGER 3 |
-static int genfkey_create_triggers( |
- sqlite3 *sdb, /* Connection to read schema from */ |
- const char *zDb, /* Name of db to read ("main", "temp") */ |
- void *pCtx, /* Context pointer to pass to xData */ |
- int (*xData)(void *, int, const char *) |
-){ |
- const char *zSql = |
- "SELECT multireplace('" |
- |
- "-- Triggers for foreign key mapping:\n" |
- "--\n" |
- "-- /from_readable/ REFERENCES /to_readable/\n" |
- "-- on delete /on_delete/\n" |
- "-- on update /on_update/\n" |
- "--\n" |
- |
- /* The "BEFORE INSERT ON <referencing>" trigger. This trigger's job is to |
- ** throw an exception if the user tries to insert a row into the |
- ** referencing table for which there is no corresponding row in |
- ** the referenced table. |
- */ |
- "CREATE TRIGGER /name/_insert_referencing BEFORE INSERT ON /tbl/ WHEN \n" |
- " /key_notnull/ AND NOT EXISTS (SELECT 1 FROM /ref/ WHERE /cond1/)\n" |
- "BEGIN\n" |
- " SELECT RAISE(ABORT, ''constraint failed'');\n" |
- "END;\n" |
- |
- /* The "BEFORE UPDATE ON <referencing>" trigger. This trigger's job |
- ** is to throw an exception if the user tries to update a row in the |
- ** referencing table causing it to correspond to no row in the |
- ** referenced table. |
- */ |
- "CREATE TRIGGER /name/_update_referencing BEFORE\n" |
- " UPDATE OF /rkey_list/ ON /tbl/ WHEN \n" |
- " /key_notnull/ AND \n" |
- " NOT EXISTS (SELECT 1 FROM /ref/ WHERE /cond1/)\n" |
- "BEGIN\n" |
- " SELECT RAISE(ABORT, ''constraint failed'');\n" |
- "END;\n" |
- |
- |
- /* The "BEFORE DELETE ON <referenced>" trigger. This trigger's job |
- ** is to detect when a row is deleted from the referenced table to |
- ** which rows in the referencing table correspond. The action taken |
- ** depends on the value of the 'ON DELETE' clause. |
- */ |
- "CREATE TRIGGER /name/_delete_referenced BEFORE DELETE ON /ref/ WHEN\n" |
- " EXISTS (SELECT 1 FROM /tbl/ WHERE /cond2/)\n" |
- "BEGIN\n" |
- " /delete_action/\n" |
- "END;\n" |
- |
- /* The "BEFORE DELETE ON <referenced>" trigger. This trigger's job |
- ** is to detect when the key columns of a row in the referenced table |
- ** to which one or more rows in the referencing table correspond are |
- ** updated. The action taken depends on the value of the 'ON UPDATE' |
- ** clause. |
- */ |
- "CREATE TRIGGER /name/_update_referenced AFTER\n" |
- " UPDATE OF /fkey_list/ ON /ref/ WHEN \n" |
- " EXISTS (SELECT 1 FROM /tbl/ WHERE /cond2/)\n" |
- "BEGIN\n" |
- " /update_action/\n" |
- "END;\n" |
- "'" |
- |
- /* These are used in the SQL comment written above each set of triggers */ |
- ", '/from_readable/', from_tbl || '(' || sj(from_col, ', ') || ')'" |
- ", '/to_readable/', to_tbl || '(' || sj(to_col, ', ') || ')'" |
- ", '/on_delete/', on_delete" |
- ", '/on_update/', on_update" |
- |
- ", '/name/', 'genfkey' || min(rowid)" |
- ", '/tbl/', dq(from_tbl)" |
- ", '/ref/', dq(to_tbl)" |
- ", '/key_notnull/', sj('new.' || dq(from_col) || ' IS NOT NULL', ' AND ')" |
- |
- ", '/fkey_list/', sj(to_col, ', ')" |
- ", '/rkey_list/', sj(from_col, ', ')" |
- |
- ", '/cond1/', sj(multireplace('new./from/ == /to/'" |
- ", '/from/', dq(from_col)" |
- ", '/to/', dq(to_col)" |
- "), ' AND ')" |
- ", '/cond2/', sj(multireplace('old./to/ == /from/'" |
- ", '/from/', dq(from_col)" |
- ", '/to/', dq(to_col)" |
- "), ' AND ')" |
- |
- ", '/update_action/', CASE on_update " |
- "WHEN 'SET NULL' THEN " |
- "multireplace('UPDATE /tbl/ SET /setlist/ WHERE /where/;' " |
- ", '/setlist/', sj(from_col||' = NULL',', ')" |
- ", '/tbl/', dq(from_tbl)" |
- ", '/where/', sj(from_col||' = old.'||dq(to_col),' AND ')" |
- ")" |
- "WHEN 'CASCADE' THEN " |
- "multireplace('UPDATE /tbl/ SET /setlist/ WHERE /where/;' " |
- ", '/setlist/', sj(dq(from_col)||' = new.'||dq(to_col),', ')" |
- ", '/tbl/', dq(from_tbl)" |
- ", '/where/', sj(dq(from_col)||' = old.'||dq(to_col),' AND ')" |
- ")" |
- "ELSE " |
- " 'SELECT RAISE(ABORT, ''constraint failed'');'" |
- "END " |
- |
- ", '/delete_action/', CASE on_delete " |
- "WHEN 'SET NULL' THEN " |
- "multireplace('UPDATE /tbl/ SET /setlist/ WHERE /where/;' " |
- ", '/setlist/', sj(from_col||' = NULL',', ')" |
- ", '/tbl/', dq(from_tbl)" |
- ", '/where/', sj(from_col||' = old.'||dq(to_col),' AND ')" |
- ")" |
- "WHEN 'CASCADE' THEN " |
- "multireplace('DELETE FROM /tbl/ WHERE /where/;' " |
- ", '/tbl/', dq(from_tbl)" |
- ", '/where/', sj(dq(from_col)||' = old.'||dq(to_col),' AND ')" |
- ")" |
- "ELSE " |
- " 'SELECT RAISE(ABORT, ''constraint failed'');'" |
- "END " |
- |
- ") FROM temp.fkey " |
- "GROUP BY from_tbl, fkid" |
- ; |
- |
- int rc; |
- const int enc = SQLITE_UTF8; |
- sqlite3 *db = 0; |
- |
- GenfkeyCb cb; |
- cb.xData = xData; |
- cb.pCtx = pCtx; |
- |
- UNUSED_PARAMETER(zDb); |
- |
- /* Open the working database handle. */ |
- rc = sqlite3_open(":memory:", &db); |
- if( rc!=SQLITE_OK ) goto genfkey_exit; |
- |
- /* Create the special scalar and aggregate functions used by this program. */ |
- sqlite3_create_function(db, "dq", 1, enc, 0, doublequote, 0, 0); |
- sqlite3_create_function(db, "multireplace", -1, enc, db, multireplace, 0, 0); |
- sqlite3_create_function(db, "sj", 2, enc, 0, 0, joinStep, joinFinalize); |
- |
- /* Install the "schema" virtual table module */ |
- installSchemaModule(db, sdb); |
- |
- /* Create and populate a temp table with the information required to |
- ** build the foreign key triggers. See function populateTempTable() |
- ** for details. |
- */ |
- cb.eType = GENFKEY_ERROR; |
- rc = populateTempTable(db, &cb); |
- if( rc!=SQLITE_OK ) goto genfkey_exit; |
- |
- /* Unless the --no-drop option was specified, generate DROP TRIGGER |
- ** statements to drop any triggers in the database generated by a |
- ** previous run of this program. |
- */ |
- cb.eType = GENFKEY_DROPTRIGGER; |
- rc = sqlite3_exec(db, |
- "SELECT 'DROP TRIGGER main.' || dq(triggername) || ';' FROM triggers" |
- ,invokeCallback, (void *)&cb, 0 |
- ); |
- if( rc!=SQLITE_OK ) goto genfkey_exit; |
- |
- /* Run the main query to create the trigger definitions. */ |
- cb.eType = GENFKEY_CREATETRIGGER; |
- rc = sqlite3_exec(db, zSql, invokeCallback, (void *)&cb, 0); |
- if( rc!=SQLITE_OK ) goto genfkey_exit; |
- |
-genfkey_exit: |
- sqlite3_close(db); |
- return rc; |
-} |
- |
- |
-#endif |
-/* End genfkey logic. */ |
-/*************************************************************************/ |
-/*************************************************************************/ |
+#define UNUSED_PARAMETER(x) (void)(x) |
/* |
** If the following flag is set, then command execution stops |
@@ -1137,6 +351,7 @@ static char *local_getline(char *zPrompt, FILE *in){ |
while( zLine[n] ){ n++; } |
if( n>0 && zLine[n-1]=='\n' ){ |
n--; |
+ if( n>0 && zLine[n-1]=='\r' ) n--; |
zLine[n] = 0; |
eol = 1; |
} |
@@ -1182,8 +397,9 @@ struct previous_mode_data { |
** state and mode information. |
*/ |
struct callback_data { |
- sqlite3 *db; /* The database */ |
+ sqlite3 *db; /* The database */ |
int echoOn; /* True to echo input commands */ |
+ int statsOn; /* True to display memory stats before each finalize */ |
int cnt; /* Number of records displayed so far */ |
FILE *out; /* Write results here */ |
int mode; /* An output mode setting */ |
@@ -1200,6 +416,9 @@ struct callback_data { |
** .explain ON */ |
char outfile[FILENAME_MAX]; /* Filename for *out */ |
const char *zDbFilename; /* name of the database file */ |
+ const char *zVfs; /* Name of VFS to use */ |
+ sqlite3_stmt *pStmt; /* Current statement if any. */ |
+ FILE *pLog; /* Write log output here */ |
}; |
/* |
@@ -1243,6 +462,27 @@ static int strlen30(const char *z){ |
} |
/* |
+** A callback for the sqlite3_log() interface. |
+*/ |
+static void shellLog(void *pArg, int iErrCode, const char *zMsg){ |
+ struct callback_data *p = (struct callback_data*)pArg; |
+ if( p->pLog==0 ) return; |
+ fprintf(p->pLog, "(%d) %s\n", iErrCode, zMsg); |
+ fflush(p->pLog); |
+} |
+ |
+/* |
+** Output the given string as a hex-encoded blob (eg. X'1234' ) |
+*/ |
+static void output_hex_blob(FILE *out, const void *pBlob, int nBlob){ |
+ int i; |
+ char *zBlob = (char *)pBlob; |
+ fprintf(out,"X'"); |
+ for(i=0; i<nBlob; i++){ fprintf(out,"%02x",zBlob[i]); } |
+ fprintf(out,"'"); |
+} |
+ |
+/* |
** Output the given string as a quoted string using SQL quoting conventions. |
*/ |
static void output_quoted_string(FILE *out, const char *z){ |
@@ -1307,7 +547,13 @@ static void output_c_string(FILE *out, const char *z){ |
static void output_html_string(FILE *out, const char *z){ |
int i; |
while( *z ){ |
- for(i=0; z[i] && z[i]!='<' && z[i]!='&'; i++){} |
+ for(i=0; z[i] |
+ && z[i]!='<' |
+ && z[i]!='&' |
+ && z[i]!='>' |
+ && z[i]!='\"' |
+ && z[i]!='\''; |
+ i++){} |
if( i>0 ){ |
fprintf(out,"%.*s",i,z); |
} |
@@ -1315,6 +561,12 @@ static void output_html_string(FILE *out, const char *z){ |
fprintf(out,"<"); |
}else if( z[i]=='&' ){ |
fprintf(out,"&"); |
+ }else if( z[i]=='>' ){ |
+ fprintf(out,">"); |
+ }else if( z[i]=='\"' ){ |
+ fprintf(out,"""); |
+ }else if( z[i]=='\'' ){ |
+ fprintf(out,"'"); |
}else{ |
break; |
} |
@@ -1394,12 +646,13 @@ static void interrupt_handler(int NotUsed){ |
#endif |
/* |
-** This is the callback routine that the SQLite library |
+** This is the callback routine that the shell |
** invokes for each row of a query result. |
*/ |
-static int callback(void *pArg, int nArg, char **azArg, char **azCol){ |
+static int shell_callback(void *pArg, int nArg, char **azArg, char **azCol, int *aiType){ |
int i; |
struct callback_data *p = (struct callback_data*)pArg; |
+ |
switch( p->mode ){ |
case MODE_Line: { |
int w = 5; |
@@ -1495,7 +748,9 @@ static int callback(void *pArg, int nArg, char **azArg, char **azCol){ |
if( p->cnt++==0 && p->showHeader ){ |
fprintf(p->out,"<TR>"); |
for(i=0; i<nArg; i++){ |
- fprintf(p->out,"<TH>%s</TH>",azCol[i]); |
+ fprintf(p->out,"<TH>"); |
+ output_html_string(p->out, azCol[i]); |
+ fprintf(p->out,"</TH>\n"); |
} |
fprintf(p->out,"</TR>\n"); |
} |
@@ -1540,12 +795,23 @@ static int callback(void *pArg, int nArg, char **azArg, char **azCol){ |
break; |
} |
case MODE_Insert: { |
+ p->cnt++; |
if( azArg==0 ) break; |
fprintf(p->out,"INSERT INTO %s VALUES(",p->zDestTable); |
for(i=0; i<nArg; i++){ |
char *zSep = i>0 ? ",": ""; |
- if( azArg[i]==0 ){ |
+ if( (azArg[i]==0) || (aiType && aiType[i]==SQLITE_NULL) ){ |
fprintf(p->out,"%sNULL",zSep); |
+ }else if( aiType && aiType[i]==SQLITE_TEXT ){ |
+ if( zSep[0] ) fprintf(p->out,"%s",zSep); |
+ output_quoted_string(p->out, azArg[i]); |
+ }else if( aiType && (aiType[i]==SQLITE_INTEGER || aiType[i]==SQLITE_FLOAT) ){ |
+ fprintf(p->out,"%s%s",zSep, azArg[i]); |
+ }else if( aiType && aiType[i]==SQLITE_BLOB && p->pStmt ){ |
+ const void *pBlob = sqlite3_column_blob(p->pStmt, i); |
+ int nBlob = sqlite3_column_bytes(p->pStmt, i); |
+ if( zSep[0] ) fprintf(p->out,"%s",zSep); |
+ output_hex_blob(p->out, pBlob, nBlob); |
}else if( isNumber(azArg[i], 0) ){ |
fprintf(p->out,"%s%s",zSep, azArg[i]); |
}else{ |
@@ -1561,6 +827,15 @@ static int callback(void *pArg, int nArg, char **azArg, char **azCol){ |
} |
/* |
+** This is the callback routine that the SQLite library |
+** invokes for each row of a query result. |
+*/ |
+static int callback(void *pArg, int nArg, char **azArg, char **azCol){ |
+ /* since we don't have type info, call the shell_callback with a NULL value */ |
+ return shell_callback(pArg, nArg, azArg, azCol, NULL); |
+} |
+ |
+/* |
** Set the destination table field of the callback_data structure to |
** the name of the table given. Escape any quote characters in the |
** table name. |
@@ -1585,7 +860,7 @@ static void set_table_name(struct callback_data *p, const char *zName){ |
if( needQuote ) n += 2; |
z = p->zDestTable = malloc( n+1 ); |
if( z==0 ){ |
- fprintf(stderr,"Out of memory!\n"); |
+ fprintf(stderr,"Error: out of memory\n"); |
exit(1); |
} |
n = 0; |
@@ -1675,6 +950,236 @@ static int run_table_dump_query( |
return sqlite3_finalize(pSelect); |
} |
+/* |
+** Allocate space and save off current error string. |
+*/ |
+static char *save_err_msg( |
+ sqlite3 *db /* Database to query */ |
+){ |
+ int nErrMsg = 1+strlen30(sqlite3_errmsg(db)); |
+ char *zErrMsg = sqlite3_malloc(nErrMsg); |
+ if( zErrMsg ){ |
+ memcpy(zErrMsg, sqlite3_errmsg(db), nErrMsg); |
+ } |
+ return zErrMsg; |
+} |
+ |
+/* |
+** Display memory stats. |
+*/ |
+static int display_stats( |
+ sqlite3 *db, /* Database to query */ |
+ struct callback_data *pArg, /* Pointer to struct callback_data */ |
+ int bReset /* True to reset the stats */ |
+){ |
+ int iCur; |
+ int iHiwtr; |
+ |
+ if( pArg && pArg->out ){ |
+ |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_MEMORY_USED, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Memory Used: %d (max %d) bytes\n", iCur, iHiwtr); |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_MALLOC_COUNT, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Number of Outstanding Allocations: %d (max %d)\n", iCur, iHiwtr); |
+/* |
+** Not currently used by the CLI. |
+** iHiwtr = iCur = -1; |
+** sqlite3_status(SQLITE_STATUS_PAGECACHE_USED, &iCur, &iHiwtr, bReset); |
+** fprintf(pArg->out, "Number of Pcache Pages Used: %d (max %d) pages\n", iCur, iHiwtr); |
+*/ |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_PAGECACHE_OVERFLOW, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Number of Pcache Overflow Bytes: %d (max %d) bytes\n", iCur, iHiwtr); |
+/* |
+** Not currently used by the CLI. |
+** iHiwtr = iCur = -1; |
+** sqlite3_status(SQLITE_STATUS_SCRATCH_USED, &iCur, &iHiwtr, bReset); |
+** fprintf(pArg->out, "Number of Scratch Allocations Used: %d (max %d)\n", iCur, iHiwtr); |
+*/ |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_SCRATCH_OVERFLOW, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Number of Scratch Overflow Bytes: %d (max %d) bytes\n", iCur, iHiwtr); |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_MALLOC_SIZE, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Largest Allocation: %d bytes\n", iHiwtr); |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_PAGECACHE_SIZE, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Largest Pcache Allocation: %d bytes\n", iHiwtr); |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_SCRATCH_SIZE, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Largest Scratch Allocation: %d bytes\n", iHiwtr); |
+#ifdef YYTRACKMAXSTACKDEPTH |
+ iHiwtr = iCur = -1; |
+ sqlite3_status(SQLITE_STATUS_PARSER_STACK, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Deepest Parser Stack: %d (max %d)\n", iCur, iHiwtr); |
+#endif |
+ } |
+ |
+ if( pArg && pArg->out && db ){ |
+ iHiwtr = iCur = -1; |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_LOOKASIDE_USED, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Lookaside Slots Used: %d (max %d)\n", iCur, iHiwtr); |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_LOOKASIDE_HIT, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Successful lookaside attempts: %d\n", iHiwtr); |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_LOOKASIDE_MISS_SIZE, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Lookaside failures due to size: %d\n", iHiwtr); |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_LOOKASIDE_MISS_FULL, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Lookaside failures due to OOM: %d\n", iHiwtr); |
+ iHiwtr = iCur = -1; |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_CACHE_USED, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Pager Heap Usage: %d bytes\n", iCur); |
+ iHiwtr = iCur = -1; |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_SCHEMA_USED, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Schema Heap Usage: %d bytes\n", iCur); |
+ iHiwtr = iCur = -1; |
+ sqlite3_db_status(db, SQLITE_DBSTATUS_STMT_USED, &iCur, &iHiwtr, bReset); |
+ fprintf(pArg->out, "Statement Heap/Lookaside Usage: %d bytes\n", iCur); |
+ } |
+ |
+ if( pArg && pArg->out && db && pArg->pStmt ){ |
+ iCur = sqlite3_stmt_status(pArg->pStmt, SQLITE_STMTSTATUS_FULLSCAN_STEP, bReset); |
+ fprintf(pArg->out, "Fullscan Steps: %d\n", iCur); |
+ iCur = sqlite3_stmt_status(pArg->pStmt, SQLITE_STMTSTATUS_SORT, bReset); |
+ fprintf(pArg->out, "Sort Operations: %d\n", iCur); |
+ iCur = sqlite3_stmt_status(pArg->pStmt, SQLITE_STMTSTATUS_AUTOINDEX, bReset); |
+ fprintf(pArg->out, "Autoindex Inserts: %d\n", iCur); |
+ } |
+ |
+ return 0; |
+} |
+ |
+/* |
+** Execute a statement or set of statements. Print |
+** any result rows/columns depending on the current mode |
+** set via the supplied callback. |
+** |
+** This is very similar to SQLite's built-in sqlite3_exec() |
+** function except it takes a slightly different callback |
+** and callback data argument. |
+*/ |
+static int shell_exec( |
+ sqlite3 *db, /* An open database */ |
+ const char *zSql, /* SQL to be evaluated */ |
+ int (*xCallback)(void*,int,char**,char**,int*), /* Callback function */ |
+ /* (not the same as sqlite3_exec) */ |
+ struct callback_data *pArg, /* Pointer to struct callback_data */ |
+ char **pzErrMsg /* Error msg written here */ |
+){ |
+ sqlite3_stmt *pStmt = NULL; /* Statement to execute. */ |
+ int rc = SQLITE_OK; /* Return Code */ |
+ const char *zLeftover; /* Tail of unprocessed SQL */ |
+ |
+ if( pzErrMsg ){ |
+ *pzErrMsg = NULL; |
+ } |
+ |
+ while( zSql[0] && (SQLITE_OK == rc) ){ |
+ rc = sqlite3_prepare_v2(db, zSql, -1, &pStmt, &zLeftover); |
+ if( SQLITE_OK != rc ){ |
+ if( pzErrMsg ){ |
+ *pzErrMsg = save_err_msg(db); |
+ } |
+ }else{ |
+ if( !pStmt ){ |
+ /* this happens for a comment or white-space */ |
+ zSql = zLeftover; |
+ while( isspace(zSql[0]) ) zSql++; |
+ continue; |
+ } |
+ |
+ /* save off the prepared statment handle and reset row count */ |
+ if( pArg ){ |
+ pArg->pStmt = pStmt; |
+ pArg->cnt = 0; |
+ } |
+ |
+ /* echo the sql statement if echo on */ |
+ if( pArg && pArg->echoOn ){ |
+ const char *zStmtSql = sqlite3_sql(pStmt); |
+ fprintf(pArg->out, "%s\n", zStmtSql ? zStmtSql : zSql); |
+ } |
+ |
+ /* perform the first step. this will tell us if we |
+ ** have a result set or not and how wide it is. |
+ */ |
+ rc = sqlite3_step(pStmt); |
+ /* if we have a result set... */ |
+ if( SQLITE_ROW == rc ){ |
+ /* if we have a callback... */ |
+ if( xCallback ){ |
+ /* allocate space for col name ptr, value ptr, and type */ |
+ int nCol = sqlite3_column_count(pStmt); |
+ void *pData = sqlite3_malloc(3*nCol*sizeof(const char*) + 1); |
+ if( !pData ){ |
+ rc = SQLITE_NOMEM; |
+ }else{ |
+ char **azCols = (char **)pData; /* Names of result columns */ |
+ char **azVals = &azCols[nCol]; /* Results */ |
+ int *aiTypes = (int *)&azVals[nCol]; /* Result types */ |
+ int i; |
+ assert(sizeof(int) <= sizeof(char *)); |
+ /* save off ptrs to column names */ |
+ for(i=0; i<nCol; i++){ |
+ azCols[i] = (char *)sqlite3_column_name(pStmt, i); |
+ } |
+ do{ |
+ /* extract the data and data types */ |
+ for(i=0; i<nCol; i++){ |
+ azVals[i] = (char *)sqlite3_column_text(pStmt, i); |
+ aiTypes[i] = sqlite3_column_type(pStmt, i); |
+ if( !azVals[i] && (aiTypes[i]!=SQLITE_NULL) ){ |
+ rc = SQLITE_NOMEM; |
+ break; /* from for */ |
+ } |
+ } /* end for */ |
+ |
+ /* if data and types extracted successfully... */ |
+ if( SQLITE_ROW == rc ){ |
+ /* call the supplied callback with the result row data */ |
+ if( xCallback(pArg, nCol, azVals, azCols, aiTypes) ){ |
+ rc = SQLITE_ABORT; |
+ }else{ |
+ rc = sqlite3_step(pStmt); |
+ } |
+ } |
+ } while( SQLITE_ROW == rc ); |
+ sqlite3_free(pData); |
+ } |
+ }else{ |
+ do{ |
+ rc = sqlite3_step(pStmt); |
+ } while( rc == SQLITE_ROW ); |
+ } |
+ } |
+ |
+ /* print usage stats if stats on */ |
+ if( pArg && pArg->statsOn ){ |
+ display_stats(db, pArg, 0); |
+ } |
+ |
+ /* Finalize the statement just executed. If this fails, save a |
+ ** copy of the error message. Otherwise, set zSql to point to the |
+ ** next statement to execute. */ |
+ rc = sqlite3_finalize(pStmt); |
+ if( rc==SQLITE_OK ){ |
+ zSql = zLeftover; |
+ while( isspace(zSql[0]) ) zSql++; |
+ }else if( pzErrMsg ){ |
+ *pzErrMsg = save_err_msg(db); |
+ } |
+ |
+ /* clear saved stmt handle */ |
+ if( pArg ){ |
+ pArg->pStmt = NULL; |
+ } |
+ } |
+ } /* end while */ |
+ |
+ return rc; |
+} |
+ |
/* |
** This is a different callback routine used for dumping the database. |
@@ -1800,62 +1305,6 @@ static int run_schema_dump_query( |
return rc; |
} |
-#if !defined(SQLITE_OMIT_VIRTUALTABLE) && !defined(SQLITE_OMIT_SUBQUERY) |
-struct GenfkeyCmd { |
- sqlite3 *db; /* Database handle */ |
- struct callback_data *pCb; /* Callback data */ |
- int isIgnoreErrors; /* True for --ignore-errors */ |
- int isExec; /* True for --exec */ |
- int isNoDrop; /* True for --no-drop */ |
- int nErr; /* Number of errors seen so far */ |
-}; |
-typedef struct GenfkeyCmd GenfkeyCmd; |
- |
-static int genfkeyParseArgs(GenfkeyCmd *p, char **azArg, int nArg){ |
- int ii; |
- memset(p, 0, sizeof(GenfkeyCmd)); |
- |
- for(ii=0; ii<nArg; ii++){ |
- int n = strlen30(azArg[ii]); |
- |
- if( n>2 && n<10 && 0==strncmp(azArg[ii], "--no-drop", n) ){ |
- p->isNoDrop = 1; |
- }else if( n>2 && n<16 && 0==strncmp(azArg[ii], "--ignore-errors", n) ){ |
- p->isIgnoreErrors = 1; |
- }else if( n>2 && n<7 && 0==strncmp(azArg[ii], "--exec", n) ){ |
- p->isExec = 1; |
- }else{ |
- fprintf(stderr, "unknown option: %s\n", azArg[ii]); |
- return -1; |
- } |
- } |
- |
- return SQLITE_OK; |
-} |
- |
-static int genfkeyCmdCb(void *pCtx, int eType, const char *z){ |
- GenfkeyCmd *p = (GenfkeyCmd *)pCtx; |
- if( eType==GENFKEY_ERROR && !p->isIgnoreErrors ){ |
- p->nErr++; |
- fprintf(stderr, "%s\n", z); |
- } |
- |
- if( p->nErr==0 && ( |
- (eType==GENFKEY_CREATETRIGGER) |
- || (eType==GENFKEY_DROPTRIGGER && !p->isNoDrop) |
- )){ |
- if( p->isExec ){ |
- sqlite3_exec(p->db, z, 0, 0, 0); |
- }else{ |
- char *zCol = "sql"; |
- callback((void *)p->pCb, 1, (char **)&z, (char **)&zCol); |
- } |
- } |
- |
- return SQLITE_OK; |
-} |
-#endif |
- |
/* |
** Text of a help message |
*/ |
@@ -1864,27 +1313,25 @@ static char zHelp[] = |
".bail ON|OFF Stop after hitting an error. Default OFF\n" |
".databases List names and files of attached databases\n" |
".dump ?TABLE? ... Dump the database in an SQL text format\n" |
+ " If TABLE specified, only dump tables matching\n" |
+ " LIKE pattern TABLE.\n" |
".echo ON|OFF Turn command echo on or off\n" |
".exit Exit this program\n" |
- ".explain ON|OFF Turn output mode suitable for EXPLAIN on or off.\n" |
-#if !defined(SQLITE_OMIT_VIRTUALTABLE) && !defined(SQLITE_OMIT_SUBQUERY) |
- ".genfkey ?OPTIONS? Options are:\n" |
- " --no-drop: Do not drop old fkey triggers.\n" |
- " --ignore-errors: Ignore tables with fkey errors\n" |
- " --exec: Execute generated SQL immediately\n" |
- " See file tool/genfkey.README in the source \n" |
- " distribution for further information.\n" |
-#endif |
+ ".explain ?ON|OFF? Turn output mode suitable for EXPLAIN on or off.\n" |
+ " With no args, it turns EXPLAIN on.\n" |
".header(s) ON|OFF Turn display of headers on or off\n" |
".help Show this message\n" |
".import FILE TABLE Import data from FILE into TABLE\n" |
- ".indices TABLE Show names of all indices on TABLE\n" |
+ ".indices ?TABLE? Show names of all indices\n" |
+ " If TABLE specified, only show indices for tables\n" |
+ " matching LIKE pattern TABLE.\n" |
#ifdef SQLITE_ENABLE_IOTRACE |
".iotrace FILE Enable I/O diagnostic logging to FILE\n" |
#endif |
#ifndef SQLITE_OMIT_LOAD_EXTENSION |
".load FILE ?ENTRY? Load an extension library\n" |
#endif |
+ ".log FILE|off Turn logging on or off. FILE can be stderr/stdout\n" |
".mode MODE ?TABLE? Set output mode where MODE is one of:\n" |
" csv Comma-separated values\n" |
" column Left-aligned columns. (See .width)\n" |
@@ -1902,14 +1349,20 @@ static char zHelp[] = |
".read FILENAME Execute SQL in FILENAME\n" |
".restore ?DB? FILE Restore content of DB (default \"main\") from FILE\n" |
".schema ?TABLE? Show the CREATE statements\n" |
+ " If TABLE specified, only show tables matching\n" |
+ " LIKE pattern TABLE.\n" |
".separator STRING Change separator used by output mode and .import\n" |
".show Show the current values for various settings\n" |
- ".tables ?PATTERN? List names of tables matching a LIKE pattern\n" |
+ ".stats ON|OFF Turn stats on or off\n" |
+ ".tables ?TABLE? List names of tables\n" |
+ " If TABLE specified, only list tables matching\n" |
+ " LIKE pattern TABLE.\n" |
".timeout MS Try opening locked tables for MS milliseconds\n" |
-#if HAS_TIMER |
+ ".width NUM1 NUM2 ... Set column widths for \"column\" mode\n" |
+; |
+ |
+static char zTimerHelp[] = |
".timer ON|OFF Turn the CPU timer measurement on or off\n" |
-#endif |
- ".width NUM NUM ... Set column widths for \"column\" mode\n" |
; |
/* Forward reference */ |
@@ -1928,7 +1381,7 @@ static void open_db(struct callback_data *p){ |
shellstaticFunc, 0, 0); |
} |
if( db==0 || SQLITE_OK!=sqlite3_errcode(db) ){ |
- fprintf(stderr,"Unable to open database \"%s\": %s\n", |
+ fprintf(stderr,"Error: unable to open database \"%s\": %s\n", |
p->zDbFilename, sqlite3_errmsg(db)); |
exit(1); |
} |
@@ -2029,15 +1482,14 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
/* Process the input line. |
*/ |
- if( nArg==0 ) return rc; |
+ if( nArg==0 ) return 0; /* no tokens, no error */ |
n = strlen30(azArg[0]); |
c = azArg[0][0]; |
- if( c=='b' && n>=3 && strncmp(azArg[0], "backup", n)==0 && nArg>1 ){ |
+ if( c=='b' && n>=3 && strncmp(azArg[0], "backup", n)==0 && nArg>1 && nArg<4){ |
const char *zDestFile; |
const char *zDb; |
sqlite3 *pDest; |
sqlite3_backup *pBackup; |
- int rc; |
if( nArg==2 ){ |
zDestFile = azArg[1]; |
zDb = "main"; |
@@ -2047,7 +1499,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
rc = sqlite3_open(zDestFile, &pDest); |
if( rc!=SQLITE_OK ){ |
- fprintf(stderr, "Error: cannot open %s\n", zDestFile); |
+ fprintf(stderr, "Error: cannot open \"%s\"\n", zDestFile); |
sqlite3_close(pDest); |
return 1; |
} |
@@ -2061,18 +1513,19 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
while( (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK ){} |
sqlite3_backup_finish(pBackup); |
if( rc==SQLITE_DONE ){ |
- rc = SQLITE_OK; |
+ rc = 0; |
}else{ |
fprintf(stderr, "Error: %s\n", sqlite3_errmsg(pDest)); |
+ rc = 1; |
} |
sqlite3_close(pDest); |
}else |
- if( c=='b' && n>=3 && strncmp(azArg[0], "bail", n)==0 && nArg>1 ){ |
+ if( c=='b' && n>=3 && strncmp(azArg[0], "bail", n)==0 && nArg>1 && nArg<3 ){ |
bail_on_error = booleanValue(azArg[1]); |
}else |
- if( c=='d' && n>1 && strncmp(azArg[0], "databases", n)==0 ){ |
+ if( c=='d' && n>1 && strncmp(azArg[0], "databases", n)==0 && nArg==1 ){ |
struct callback_data data; |
char *zErrMsg = 0; |
open_db(p); |
@@ -2087,12 +1540,17 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
if( zErrMsg ){ |
fprintf(stderr,"Error: %s\n", zErrMsg); |
sqlite3_free(zErrMsg); |
+ rc = 1; |
} |
}else |
- if( c=='d' && strncmp(azArg[0], "dump", n)==0 ){ |
+ if( c=='d' && strncmp(azArg[0], "dump", n)==0 && nArg<3 ){ |
char *zErrMsg = 0; |
open_db(p); |
+ /* When playing back a "dump", the content might appear in an order |
+ ** which causes immediate foreign key constraints to be violated. |
+ ** So disable foreign-key constraint enforcement to prevent problems. */ |
+ fprintf(p->out, "PRAGMA foreign_keys=OFF;\n"); |
fprintf(p->out, "BEGIN TRANSACTION;\n"); |
p->writableSchema = 0; |
sqlite3_exec(p->db, "PRAGMA writable_schema=ON", 0, 0, 0); |
@@ -2139,15 +1597,15 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
}else |
- if( c=='e' && strncmp(azArg[0], "echo", n)==0 && nArg>1 ){ |
+ if( c=='e' && strncmp(azArg[0], "echo", n)==0 && nArg>1 && nArg<3 ){ |
p->echoOn = booleanValue(azArg[1]); |
}else |
- if( c=='e' && strncmp(azArg[0], "exit", n)==0 ){ |
+ if( c=='e' && strncmp(azArg[0], "exit", n)==0 && nArg==1 ){ |
rc = 2; |
}else |
- if( c=='e' && strncmp(azArg[0], "explain", n)==0 ){ |
+ if( c=='e' && strncmp(azArg[0], "explain", n)==0 && nArg<3 ){ |
int val = nArg>=2 ? booleanValue(azArg[1]) : 1; |
if(val == 1) { |
if(!p->explainPrev.valid) { |
@@ -2182,31 +1640,22 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
}else |
-#if !defined(SQLITE_OMIT_VIRTUALTABLE) && !defined(SQLITE_OMIT_SUBQUERY) |
- if( c=='g' && strncmp(azArg[0], "genfkey", n)==0 ){ |
- GenfkeyCmd cmd; |
- if( 0==genfkeyParseArgs(&cmd, &azArg[1], nArg-1) ){ |
- cmd.db = p->db; |
- cmd.pCb = p; |
- genfkey_create_triggers(p->db, "main", (void *)&cmd, genfkeyCmdCb); |
- } |
- }else |
-#endif |
- |
if( c=='h' && (strncmp(azArg[0], "header", n)==0 || |
- strncmp(azArg[0], "headers", n)==0 )&& nArg>1 ){ |
+ strncmp(azArg[0], "headers", n)==0) && nArg>1 && nArg<3 ){ |
p->showHeader = booleanValue(azArg[1]); |
}else |
if( c=='h' && strncmp(azArg[0], "help", n)==0 ){ |
fprintf(stderr,"%s",zHelp); |
+ if( HAS_TIMER ){ |
+ fprintf(stderr,"%s",zTimerHelp); |
+ } |
}else |
- if( c=='i' && strncmp(azArg[0], "import", n)==0 && nArg>=3 ){ |
+ if( c=='i' && strncmp(azArg[0], "import", n)==0 && nArg==3 ){ |
char *zTable = azArg[2]; /* Insert data into this table */ |
char *zFile = azArg[1]; /* The file from which to extract data */ |
- sqlite3_stmt *pStmt; /* A statement */ |
- int rc; /* Result code */ |
+ sqlite3_stmt *pStmt = NULL; /* A statement */ |
int nCol; /* Number of columns in the table */ |
int nByte; /* Number of bytes in an SQL string */ |
int i, j; /* Loop counters */ |
@@ -2221,25 +1670,31 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
open_db(p); |
nSep = strlen30(p->separator); |
if( nSep==0 ){ |
- fprintf(stderr, "non-null separator required for import\n"); |
- return 0; |
+ fprintf(stderr, "Error: non-null separator required for import\n"); |
+ return 1; |
} |
zSql = sqlite3_mprintf("SELECT * FROM '%q'", zTable); |
- if( zSql==0 ) return 0; |
+ if( zSql==0 ){ |
+ fprintf(stderr, "Error: out of memory\n"); |
+ return 1; |
+ } |
nByte = strlen30(zSql); |
rc = sqlite3_prepare(p->db, zSql, -1, &pStmt, 0); |
sqlite3_free(zSql); |
if( rc ){ |
+ if (pStmt) sqlite3_finalize(pStmt); |
fprintf(stderr,"Error: %s\n", sqlite3_errmsg(db)); |
- nCol = 0; |
- rc = 1; |
- }else{ |
- nCol = sqlite3_column_count(pStmt); |
+ return 1; |
} |
+ nCol = sqlite3_column_count(pStmt); |
sqlite3_finalize(pStmt); |
- if( nCol==0 ) return 0; |
+ pStmt = 0; |
+ if( nCol==0 ) return 0; /* no columns, no error */ |
zSql = malloc( nByte + 20 + nCol*2 ); |
- if( zSql==0 ) return 0; |
+ if( zSql==0 ){ |
+ fprintf(stderr, "Error: out of memory\n"); |
+ return 1; |
+ } |
sqlite3_snprintf(nByte+20, zSql, "INSERT INTO '%q' VALUES(?", zTable); |
j = strlen30(zSql); |
for(i=1; i<nCol; i++){ |
@@ -2252,19 +1707,21 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
free(zSql); |
if( rc ){ |
fprintf(stderr, "Error: %s\n", sqlite3_errmsg(db)); |
- sqlite3_finalize(pStmt); |
+ if (pStmt) sqlite3_finalize(pStmt); |
return 1; |
} |
in = fopen(zFile, "rb"); |
if( in==0 ){ |
- fprintf(stderr, "cannot open file: %s\n", zFile); |
+ fprintf(stderr, "Error: cannot open \"%s\"\n", zFile); |
sqlite3_finalize(pStmt); |
- return 0; |
+ return 1; |
} |
azCol = malloc( sizeof(azCol[0])*(nCol+1) ); |
if( azCol==0 ){ |
+ fprintf(stderr, "Error: out of memory\n"); |
fclose(in); |
- return 0; |
+ sqlite3_finalize(pStmt); |
+ return 1; |
} |
sqlite3_exec(p->db, "BEGIN", 0, 0, 0); |
zCommit = "COMMIT"; |
@@ -2282,14 +1739,16 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
z += nSep-1; |
} |
} |
- } |
+ } /* end for */ |
*z = 0; |
if( i+1!=nCol ){ |
- fprintf(stderr,"%s line %d: expected %d columns of data but found %d\n", |
- zFile, lineno, nCol, i+1); |
+ fprintf(stderr, |
+ "Error: %s line %d: expected %d columns of data but found %d\n", |
+ zFile, lineno, nCol, i+1); |
zCommit = "ROLLBACK"; |
free(zLine); |
- break; |
+ rc = 1; |
+ break; /* from while */ |
} |
for(i=0; i<nCol; i++){ |
sqlite3_bind_text(pStmt, i+1, azCol[i], -1, SQLITE_STATIC); |
@@ -2301,36 +1760,52 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
fprintf(stderr,"Error: %s\n", sqlite3_errmsg(db)); |
zCommit = "ROLLBACK"; |
rc = 1; |
- break; |
+ break; /* from while */ |
} |
- } |
+ } /* end while */ |
free(azCol); |
fclose(in); |
sqlite3_finalize(pStmt); |
sqlite3_exec(p->db, zCommit, 0, 0, 0); |
}else |
- if( c=='i' && strncmp(azArg[0], "indices", n)==0 && nArg>1 ){ |
+ if( c=='i' && strncmp(azArg[0], "indices", n)==0 && nArg<3 ){ |
struct callback_data data; |
char *zErrMsg = 0; |
open_db(p); |
memcpy(&data, p, sizeof(data)); |
data.showHeader = 0; |
data.mode = MODE_List; |
- zShellStatic = azArg[1]; |
- sqlite3_exec(p->db, |
- "SELECT name FROM sqlite_master " |
- "WHERE type='index' AND tbl_name LIKE shellstatic() " |
- "UNION ALL " |
- "SELECT name FROM sqlite_temp_master " |
- "WHERE type='index' AND tbl_name LIKE shellstatic() " |
- "ORDER BY 1", |
- callback, &data, &zErrMsg |
- ); |
- zShellStatic = 0; |
+ if( nArg==1 ){ |
+ rc = sqlite3_exec(p->db, |
+ "SELECT name FROM sqlite_master " |
+ "WHERE type='index' AND name NOT LIKE 'sqlite_%' " |
+ "UNION ALL " |
+ "SELECT name FROM sqlite_temp_master " |
+ "WHERE type='index' " |
+ "ORDER BY 1", |
+ callback, &data, &zErrMsg |
+ ); |
+ }else{ |
+ zShellStatic = azArg[1]; |
+ rc = sqlite3_exec(p->db, |
+ "SELECT name FROM sqlite_master " |
+ "WHERE type='index' AND tbl_name LIKE shellstatic() " |
+ "UNION ALL " |
+ "SELECT name FROM sqlite_temp_master " |
+ "WHERE type='index' AND tbl_name LIKE shellstatic() " |
+ "ORDER BY 1", |
+ callback, &data, &zErrMsg |
+ ); |
+ zShellStatic = 0; |
+ } |
if( zErrMsg ){ |
fprintf(stderr,"Error: %s\n", zErrMsg); |
sqlite3_free(zErrMsg); |
+ rc = 1; |
+ }else if( rc != SQLITE_OK ){ |
+ fprintf(stderr,"Error: querying sqlite_master and sqlite_temp_master\n"); |
+ rc = 1; |
} |
}else |
@@ -2347,8 +1822,9 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
}else{ |
iotrace = fopen(azArg[1], "w"); |
if( iotrace==0 ){ |
- fprintf(stderr, "cannot open \"%s\"\n", azArg[1]); |
+ fprintf(stderr, "Error: cannot open \"%s\"\n", azArg[1]); |
sqlite3IoTrace = 0; |
+ rc = 1; |
}else{ |
sqlite3IoTrace = iotracePrintf; |
} |
@@ -2360,51 +1836,79 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
if( c=='l' && strncmp(azArg[0], "load", n)==0 && nArg>=2 ){ |
const char *zFile, *zProc; |
char *zErrMsg = 0; |
- int rc; |
zFile = azArg[1]; |
zProc = nArg>=3 ? azArg[2] : 0; |
open_db(p); |
rc = sqlite3_load_extension(p->db, zFile, zProc, &zErrMsg); |
if( rc!=SQLITE_OK ){ |
- fprintf(stderr, "%s\n", zErrMsg); |
+ fprintf(stderr, "Error: %s\n", zErrMsg); |
sqlite3_free(zErrMsg); |
rc = 1; |
} |
}else |
#endif |
- if( c=='m' && strncmp(azArg[0], "mode", n)==0 && nArg>=2 ){ |
+ if( c=='l' && strncmp(azArg[0], "log", n)==0 && nArg>=2 ){ |
+ const char *zFile = azArg[1]; |
+ if( p->pLog && p->pLog!=stdout && p->pLog!=stderr ){ |
+ fclose(p->pLog); |
+ p->pLog = 0; |
+ } |
+ if( strcmp(zFile,"stdout")==0 ){ |
+ p->pLog = stdout; |
+ }else if( strcmp(zFile, "stderr")==0 ){ |
+ p->pLog = stderr; |
+ }else if( strcmp(zFile, "off")==0 ){ |
+ p->pLog = 0; |
+ }else{ |
+ p->pLog = fopen(zFile, "w"); |
+ if( p->pLog==0 ){ |
+ fprintf(stderr, "Error: cannot open \"%s\"\n", zFile); |
+ } |
+ } |
+ }else |
+ |
+ if( c=='m' && strncmp(azArg[0], "mode", n)==0 && nArg==2 ){ |
int n2 = strlen30(azArg[1]); |
- if( strncmp(azArg[1],"line",n2)==0 |
+ if( (n2==4 && strncmp(azArg[1],"line",n2)==0) |
|| |
- strncmp(azArg[1],"lines",n2)==0 ){ |
+ (n2==5 && strncmp(azArg[1],"lines",n2)==0) ){ |
p->mode = MODE_Line; |
- }else if( strncmp(azArg[1],"column",n2)==0 |
+ }else if( (n2==6 && strncmp(azArg[1],"column",n2)==0) |
|| |
- strncmp(azArg[1],"columns",n2)==0 ){ |
+ (n2==7 && strncmp(azArg[1],"columns",n2)==0) ){ |
p->mode = MODE_Column; |
- }else if( strncmp(azArg[1],"list",n2)==0 ){ |
+ }else if( n2==4 && strncmp(azArg[1],"list",n2)==0 ){ |
p->mode = MODE_List; |
- }else if( strncmp(azArg[1],"html",n2)==0 ){ |
+ }else if( n2==4 && strncmp(azArg[1],"html",n2)==0 ){ |
p->mode = MODE_Html; |
- }else if( strncmp(azArg[1],"tcl",n2)==0 ){ |
+ }else if( n2==3 && strncmp(azArg[1],"tcl",n2)==0 ){ |
p->mode = MODE_Tcl; |
- }else if( strncmp(azArg[1],"csv",n2)==0 ){ |
+ }else if( n2==3 && strncmp(azArg[1],"csv",n2)==0 ){ |
p->mode = MODE_Csv; |
sqlite3_snprintf(sizeof(p->separator), p->separator, ","); |
- }else if( strncmp(azArg[1],"tabs",n2)==0 ){ |
+ }else if( n2==4 && strncmp(azArg[1],"tabs",n2)==0 ){ |
p->mode = MODE_List; |
sqlite3_snprintf(sizeof(p->separator), p->separator, "\t"); |
- }else if( strncmp(azArg[1],"insert",n2)==0 ){ |
+ }else if( n2==6 && strncmp(azArg[1],"insert",n2)==0 ){ |
p->mode = MODE_Insert; |
- if( nArg>=3 ){ |
- set_table_name(p, azArg[2]); |
- }else{ |
- set_table_name(p, "table"); |
- } |
+ set_table_name(p, "table"); |
}else { |
- fprintf(stderr,"mode should be one of: " |
+ fprintf(stderr,"Error: mode should be one of: " |
"column csv html insert line list tabs tcl\n"); |
+ rc = 1; |
+ } |
+ }else |
+ |
+ if( c=='m' && strncmp(azArg[0], "mode", n)==0 && nArg==3 ){ |
+ int n2 = strlen30(azArg[1]); |
+ if( n2==6 && strncmp(azArg[1],"insert",n2)==0 ){ |
+ p->mode = MODE_Insert; |
+ set_table_name(p, azArg[2]); |
+ }else { |
+ fprintf(stderr, "Error: invalid arguments: " |
+ " \"%s\". Enter \".help\" for help\n", azArg[2]); |
+ rc = 1; |
} |
}else |
@@ -2423,8 +1927,9 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
}else{ |
p->out = fopen(azArg[1], "wb"); |
if( p->out==0 ){ |
- fprintf(stderr,"can't write to \"%s\"\n", azArg[1]); |
+ fprintf(stderr,"Error: cannot write to \"%s\"\n", azArg[1]); |
p->out = stdout; |
+ rc = 1; |
} else { |
sqlite3_snprintf(sizeof(p->outfile), p->outfile, "%s", azArg[1]); |
} |
@@ -2440,26 +1945,26 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
}else |
- if( c=='q' && strncmp(azArg[0], "quit", n)==0 ){ |
+ if( c=='q' && strncmp(azArg[0], "quit", n)==0 && nArg==1 ){ |
rc = 2; |
}else |
if( c=='r' && n>=3 && strncmp(azArg[0], "read", n)==0 && nArg==2 ){ |
FILE *alt = fopen(azArg[1], "rb"); |
if( alt==0 ){ |
- fprintf(stderr,"can't open \"%s\"\n", azArg[1]); |
+ fprintf(stderr,"Error: cannot open \"%s\"\n", azArg[1]); |
+ rc = 1; |
}else{ |
- process_input(p, alt); |
+ rc = process_input(p, alt); |
fclose(alt); |
} |
}else |
- if( c=='r' && n>=3 && strncmp(azArg[0], "restore", n)==0 && nArg>1 ){ |
+ if( c=='r' && n>=3 && strncmp(azArg[0], "restore", n)==0 && nArg>1 && nArg<4){ |
const char *zSrcFile; |
const char *zDb; |
sqlite3 *pSrc; |
sqlite3_backup *pBackup; |
- int rc; |
int nTimeout = 0; |
if( nArg==2 ){ |
@@ -2471,7 +1976,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
rc = sqlite3_open(zSrcFile, &pSrc); |
if( rc!=SQLITE_OK ){ |
- fprintf(stderr, "Error: cannot open %s\n", zSrcFile); |
+ fprintf(stderr, "Error: cannot open \"%s\"\n", zSrcFile); |
sqlite3_close(pSrc); |
return 1; |
} |
@@ -2491,16 +1996,18 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
sqlite3_backup_finish(pBackup); |
if( rc==SQLITE_DONE ){ |
- rc = SQLITE_OK; |
+ rc = 0; |
}else if( rc==SQLITE_BUSY || rc==SQLITE_LOCKED ){ |
- fprintf(stderr, "source database is busy\n"); |
+ fprintf(stderr, "Error: source database is busy\n"); |
+ rc = 1; |
}else{ |
fprintf(stderr, "Error: %s\n", sqlite3_errmsg(p->db)); |
+ rc = 1; |
} |
sqlite3_close(pSrc); |
}else |
- if( c=='s' && strncmp(azArg[0], "schema", n)==0 ){ |
+ if( c=='s' && strncmp(azArg[0], "schema", n)==0 && nArg<3 ){ |
struct callback_data data; |
char *zErrMsg = 0; |
open_db(p); |
@@ -2523,6 +2030,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
new_colv[0] = "sql"; |
new_colv[1] = 0; |
callback(&data, 1, new_argv, new_colv); |
+ rc = SQLITE_OK; |
}else if( strcmp(azArg[1],"sqlite_temp_master")==0 ){ |
char *new_argv[2], *new_colv[2]; |
new_argv[0] = "CREATE TEMP TABLE sqlite_temp_master (\n" |
@@ -2536,9 +2044,10 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
new_colv[0] = "sql"; |
new_colv[1] = 0; |
callback(&data, 1, new_argv, new_colv); |
+ rc = SQLITE_OK; |
}else{ |
zShellStatic = azArg[1]; |
- sqlite3_exec(p->db, |
+ rc = sqlite3_exec(p->db, |
"SELECT sql FROM " |
" (SELECT sql sql, type type, tbl_name tbl_name, name name" |
" FROM sqlite_master UNION ALL" |
@@ -2549,7 +2058,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
zShellStatic = 0; |
} |
}else{ |
- sqlite3_exec(p->db, |
+ rc = sqlite3_exec(p->db, |
"SELECT sql FROM " |
" (SELECT sql sql, type type, tbl_name tbl_name, name name" |
" FROM sqlite_master UNION ALL" |
@@ -2562,6 +2071,12 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
if( zErrMsg ){ |
fprintf(stderr,"Error: %s\n", zErrMsg); |
sqlite3_free(zErrMsg); |
+ rc = 1; |
+ }else if( rc != SQLITE_OK ){ |
+ fprintf(stderr,"Error: querying schema information\n"); |
+ rc = 1; |
+ }else{ |
+ rc = 0; |
} |
}else |
@@ -2570,7 +2085,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
"%.*s", (int)sizeof(p->separator)-1, azArg[1]); |
}else |
- if( c=='s' && strncmp(azArg[0], "show", n)==0){ |
+ if( c=='s' && strncmp(azArg[0], "show", n)==0 && nArg==1 ){ |
int i; |
fprintf(p->out,"%9.9s: %s\n","echo", p->echoOn ? "on" : "off"); |
fprintf(p->out,"%9.9s: %s\n","explain", p->explainPrev.valid ? "on" :"off"); |
@@ -2584,6 +2099,7 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
fprintf(p->out,"%9.9s: ", "separator"); |
output_c_string(p->out, p->separator); |
fprintf(p->out, "\n"); |
+ fprintf(p->out,"%9.9s: %s\n","stats", p->statsOn ? "on" : "off"); |
fprintf(p->out,"%9.9s: ","width"); |
for (i=0;i<(int)ArraySize(p->colWidth) && p->colWidth[i] != 0;i++) { |
fprintf(p->out,"%d ",p->colWidth[i]); |
@@ -2591,15 +2107,19 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
fprintf(p->out,"\n"); |
}else |
- if( c=='t' && n>1 && strncmp(azArg[0], "tables", n)==0 ){ |
+ if( c=='s' && strncmp(azArg[0], "stats", n)==0 && nArg>1 && nArg<3 ){ |
+ p->statsOn = booleanValue(azArg[1]); |
+ }else |
+ |
+ if( c=='t' && n>1 && strncmp(azArg[0], "tables", n)==0 && nArg<3 ){ |
char **azResult; |
- int nRow, rc; |
+ int nRow; |
char *zErrMsg; |
open_db(p); |
if( nArg==1 ){ |
rc = sqlite3_get_table(p->db, |
"SELECT name FROM sqlite_master " |
- "WHERE type IN ('table','view') AND name NOT LIKE 'sqlite_%'" |
+ "WHERE type IN ('table','view') AND name NOT LIKE 'sqlite_%' " |
"UNION ALL " |
"SELECT name FROM sqlite_temp_master " |
"WHERE type IN ('table','view') " |
@@ -2610,10 +2130,10 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
zShellStatic = azArg[1]; |
rc = sqlite3_get_table(p->db, |
"SELECT name FROM sqlite_master " |
- "WHERE type IN ('table','view') AND name LIKE '%'||shellstatic()||'%' " |
+ "WHERE type IN ('table','view') AND name LIKE shellstatic() " |
"UNION ALL " |
"SELECT name FROM sqlite_temp_master " |
- "WHERE type IN ('table','view') AND name LIKE '%'||shellstatic()||'%' " |
+ "WHERE type IN ('table','view') AND name LIKE shellstatic() " |
"ORDER BY 1", |
&azResult, &nRow, 0, &zErrMsg |
); |
@@ -2622,8 +2142,11 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
if( zErrMsg ){ |
fprintf(stderr,"Error: %s\n", zErrMsg); |
sqlite3_free(zErrMsg); |
- } |
- if( rc==SQLITE_OK ){ |
+ rc = 1; |
+ }else if( rc != SQLITE_OK ){ |
+ fprintf(stderr,"Error: querying sqlite_master and sqlite_temp_master\n"); |
+ rc = 1; |
+ }else{ |
int len, maxlen = 0; |
int i, j; |
int nPrintCol, nPrintRow; |
@@ -2642,24 +2165,144 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
printf("\n"); |
} |
- }else{ |
- rc = 1; |
} |
sqlite3_free_table(azResult); |
}else |
- if( c=='t' && n>4 && strncmp(azArg[0], "timeout", n)==0 && nArg>=2 ){ |
+ if( c=='t' && n>=8 && strncmp(azArg[0], "testctrl", n)==0 && nArg>=2 ){ |
+ static const struct { |
+ const char *zCtrlName; /* Name of a test-control option */ |
+ int ctrlCode; /* Integer code for that option */ |
+ } aCtrl[] = { |
+ { "prng_save", SQLITE_TESTCTRL_PRNG_SAVE }, |
+ { "prng_restore", SQLITE_TESTCTRL_PRNG_RESTORE }, |
+ { "prng_reset", SQLITE_TESTCTRL_PRNG_RESET }, |
+ { "bitvec_test", SQLITE_TESTCTRL_BITVEC_TEST }, |
+ { "fault_install", SQLITE_TESTCTRL_FAULT_INSTALL }, |
+ { "benign_malloc_hooks", SQLITE_TESTCTRL_BENIGN_MALLOC_HOOKS }, |
+ { "pending_byte", SQLITE_TESTCTRL_PENDING_BYTE }, |
+ { "assert", SQLITE_TESTCTRL_ASSERT }, |
+ { "always", SQLITE_TESTCTRL_ALWAYS }, |
+ { "reserve", SQLITE_TESTCTRL_RESERVE }, |
+ { "optimizations", SQLITE_TESTCTRL_OPTIMIZATIONS }, |
+ { "iskeyword", SQLITE_TESTCTRL_ISKEYWORD }, |
+ { "pghdrsz", SQLITE_TESTCTRL_PGHDRSZ }, |
+ { "scratchmalloc", SQLITE_TESTCTRL_SCRATCHMALLOC }, |
+ }; |
+ int testctrl = -1; |
+ int rc = 0; |
+ int i, n; |
+ open_db(p); |
+ |
+ /* convert testctrl text option to value. allow any unique prefix |
+ ** of the option name, or a numerical value. */ |
+ n = strlen30(azArg[1]); |
+ for(i=0; i<(int)(sizeof(aCtrl)/sizeof(aCtrl[0])); i++){ |
+ if( strncmp(azArg[1], aCtrl[i].zCtrlName, n)==0 ){ |
+ if( testctrl<0 ){ |
+ testctrl = aCtrl[i].ctrlCode; |
+ }else{ |
+ fprintf(stderr, "ambiguous option name: \"%s\"\n", azArg[i]); |
+ testctrl = -1; |
+ break; |
+ } |
+ } |
+ } |
+ if( testctrl<0 ) testctrl = atoi(azArg[1]); |
+ if( (testctrl<SQLITE_TESTCTRL_FIRST) || (testctrl>SQLITE_TESTCTRL_LAST) ){ |
+ fprintf(stderr,"Error: invalid testctrl option: %s\n", azArg[1]); |
+ }else{ |
+ switch(testctrl){ |
+ |
+ /* sqlite3_test_control(int, db, int) */ |
+ case SQLITE_TESTCTRL_OPTIMIZATIONS: |
+ case SQLITE_TESTCTRL_RESERVE: |
+ if( nArg==3 ){ |
+ int opt = (int)strtol(azArg[2], 0, 0); |
+ rc = sqlite3_test_control(testctrl, p->db, opt); |
+ printf("%d (0x%08x)\n", rc, rc); |
+ } else { |
+ fprintf(stderr,"Error: testctrl %s takes a single int option\n", |
+ azArg[1]); |
+ } |
+ break; |
+ |
+ /* sqlite3_test_control(int) */ |
+ case SQLITE_TESTCTRL_PRNG_SAVE: |
+ case SQLITE_TESTCTRL_PRNG_RESTORE: |
+ case SQLITE_TESTCTRL_PRNG_RESET: |
+ case SQLITE_TESTCTRL_PGHDRSZ: |
+ if( nArg==2 ){ |
+ rc = sqlite3_test_control(testctrl); |
+ printf("%d (0x%08x)\n", rc, rc); |
+ } else { |
+ fprintf(stderr,"Error: testctrl %s takes no options\n", azArg[1]); |
+ } |
+ break; |
+ |
+ /* sqlite3_test_control(int, uint) */ |
+ case SQLITE_TESTCTRL_PENDING_BYTE: |
+ if( nArg==3 ){ |
+ unsigned int opt = (unsigned int)atoi(azArg[2]); |
+ rc = sqlite3_test_control(testctrl, opt); |
+ printf("%d (0x%08x)\n", rc, rc); |
+ } else { |
+ fprintf(stderr,"Error: testctrl %s takes a single unsigned" |
+ " int option\n", azArg[1]); |
+ } |
+ break; |
+ |
+ /* sqlite3_test_control(int, int) */ |
+ case SQLITE_TESTCTRL_ASSERT: |
+ case SQLITE_TESTCTRL_ALWAYS: |
+ if( nArg==3 ){ |
+ int opt = atoi(azArg[2]); |
+ rc = sqlite3_test_control(testctrl, opt); |
+ printf("%d (0x%08x)\n", rc, rc); |
+ } else { |
+ fprintf(stderr,"Error: testctrl %s takes a single int option\n", |
+ azArg[1]); |
+ } |
+ break; |
+ |
+ /* sqlite3_test_control(int, char *) */ |
+#ifdef SQLITE_N_KEYWORD |
+ case SQLITE_TESTCTRL_ISKEYWORD: |
+ if( nArg==3 ){ |
+ const char *opt = azArg[2]; |
+ rc = sqlite3_test_control(testctrl, opt); |
+ printf("%d (0x%08x)\n", rc, rc); |
+ } else { |
+ fprintf(stderr,"Error: testctrl %s takes a single char * option\n", |
+ azArg[1]); |
+ } |
+ break; |
+#endif |
+ |
+ case SQLITE_TESTCTRL_BITVEC_TEST: |
+ case SQLITE_TESTCTRL_FAULT_INSTALL: |
+ case SQLITE_TESTCTRL_BENIGN_MALLOC_HOOKS: |
+ case SQLITE_TESTCTRL_SCRATCHMALLOC: |
+ default: |
+ fprintf(stderr,"Error: CLI support for testctrl %s not implemented\n", |
+ azArg[1]); |
+ break; |
+ } |
+ } |
+ }else |
+ |
+ if( c=='t' && n>4 && strncmp(azArg[0], "timeout", n)==0 && nArg==2 ){ |
open_db(p); |
sqlite3_busy_timeout(p->db, atoi(azArg[1])); |
}else |
- |
-#if HAS_TIMER |
- if( c=='t' && n>=5 && strncmp(azArg[0], "timer", n)==0 && nArg>1 ){ |
+ |
+ if( HAS_TIMER && c=='t' && n>=5 && strncmp(azArg[0], "timer", n)==0 |
+ && nArg==2 |
+ ){ |
enableTimer = booleanValue(azArg[1]); |
}else |
-#endif |
- |
- if( c=='w' && strncmp(azArg[0], "width", n)==0 ){ |
+ |
+ if( c=='w' && strncmp(azArg[0], "width", n)==0 && nArg>1 ){ |
int j; |
assert( nArg<=ArraySize(azArg) ); |
for(j=1; j<nArg && j<ArraySize(p->colWidth); j++){ |
@@ -2667,10 +2310,10 @@ static int do_meta_command(char *zLine, struct callback_data *p){ |
} |
}else |
- |
{ |
- fprintf(stderr, "unknown command or invalid arguments: " |
+ fprintf(stderr, "Error: unknown command or invalid arguments: " |
" \"%s\". Enter \".help\" for help\n", azArg[0]); |
+ rc = 1; |
} |
return rc; |
@@ -2773,11 +2416,11 @@ static int process_input(struct callback_data *p, FILE *in){ |
seenInterrupt = 0; |
} |
lineno++; |
- if( p->echoOn ) printf("%s\n", zLine); |
if( (zSql==0 || zSql[0]==0) && _all_whitespace(zLine) ) continue; |
if( zLine && zLine[0]=='.' && nSql==0 ){ |
+ if( p->echoOn ) printf("%s\n", zLine); |
rc = do_meta_command(zLine, p); |
- if( rc==2 ){ |
+ if( rc==2 ){ /* exit requested */ |
break; |
}else if( rc ){ |
errCnt++; |
@@ -2795,7 +2438,7 @@ static int process_input(struct callback_data *p, FILE *in){ |
nSql = strlen30(zLine); |
zSql = malloc( nSql+3 ); |
if( zSql==0 ){ |
- fprintf(stderr, "out of memory\n"); |
+ fprintf(stderr, "Error: out of memory\n"); |
exit(1); |
} |
memcpy(zSql, zLine, nSql+1); |
@@ -2805,7 +2448,7 @@ static int process_input(struct callback_data *p, FILE *in){ |
int len = strlen30(zLine); |
zSql = realloc( zSql, nSql + len + 4 ); |
if( zSql==0 ){ |
- fprintf(stderr,"%s: out of memory!\n", Argv0); |
+ fprintf(stderr,"Error: out of memory\n"); |
exit(1); |
} |
zSql[nSql++] = '\n'; |
@@ -2817,22 +2460,22 @@ static int process_input(struct callback_data *p, FILE *in){ |
p->cnt = 0; |
open_db(p); |
BEGIN_TIMER; |
- rc = sqlite3_exec(p->db, zSql, callback, p, &zErrMsg); |
+ rc = shell_exec(p->db, zSql, shell_callback, p, &zErrMsg); |
END_TIMER; |
if( rc || zErrMsg ){ |
char zPrefix[100]; |
if( in!=0 || !stdin_is_interactive ){ |
sqlite3_snprintf(sizeof(zPrefix), zPrefix, |
- "SQL error near line %d:", startline); |
+ "Error: near line %d:", startline); |
}else{ |
- sqlite3_snprintf(sizeof(zPrefix), zPrefix, "SQL error:"); |
+ sqlite3_snprintf(sizeof(zPrefix), zPrefix, "Error:"); |
} |
if( zErrMsg!=0 ){ |
- printf("%s %s\n", zPrefix, zErrMsg); |
+ fprintf(stderr, "%s %s\n", zPrefix, zErrMsg); |
sqlite3_free(zErrMsg); |
zErrMsg = 0; |
}else{ |
- printf("%s %s\n", zPrefix, sqlite3_errmsg(p->db)); |
+ fprintf(stderr, "%s %s\n", zPrefix, sqlite3_errmsg(p->db)); |
} |
errCnt++; |
} |
@@ -2842,7 +2485,9 @@ static int process_input(struct callback_data *p, FILE *in){ |
} |
} |
if( zSql ){ |
- if( !_all_whitespace(zSql) ) fprintf(stderr, "Incomplete SQL: %s\n", zSql); |
+ if( !_all_whitespace(zSql) ){ |
+ fprintf(stderr, "Error: incomplete SQL: %s\n", zSql); |
+ } |
free(zSql); |
} |
free(zLine); |
@@ -2914,8 +2559,10 @@ static char *find_home_dir(void){ |
/* |
** Read input from the file given by sqliterc_override. Or if that |
** parameter is NULL, take input from ~/.sqliterc |
+** |
+** Returns the number of errors. |
*/ |
-static void process_sqliterc( |
+static int process_sqliterc( |
struct callback_data *p, /* Configuration data */ |
const char *sqliterc_override /* Name of config file. NULL to use default */ |
){ |
@@ -2924,20 +2571,21 @@ static void process_sqliterc( |
char *zBuf = 0; |
FILE *in = NULL; |
int nBuf; |
+ int rc = 0; |
if (sqliterc == NULL) { |
home_dir = find_home_dir(); |
if( home_dir==0 ){ |
#if !defined(__RTP__) && !defined(_WRS_KERNEL) |
- fprintf(stderr,"%s: cannot locate your home directory!\n", Argv0); |
+ fprintf(stderr,"%s: Error: cannot locate your home directory\n", Argv0); |
#endif |
- return; |
+ return 1; |
} |
nBuf = strlen30(home_dir) + 16; |
zBuf = malloc( nBuf ); |
if( zBuf==0 ){ |
- fprintf(stderr,"%s: out of memory!\n", Argv0); |
- exit(1); |
+ fprintf(stderr,"%s: Error: out of memory\n",Argv0); |
+ return 1; |
} |
sqlite3_snprintf(nBuf, zBuf,"%s/.sqliterc",home_dir); |
free(home_dir); |
@@ -2946,19 +2594,20 @@ static void process_sqliterc( |
in = fopen(sqliterc,"rb"); |
if( in ){ |
if( stdin_is_interactive ){ |
- printf("-- Loading resources from %s\n",sqliterc); |
+ fprintf(stderr,"-- Loading resources from %s\n",sqliterc); |
} |
- process_input(p,in); |
+ rc = process_input(p,in); |
fclose(in); |
} |
free(zBuf); |
- return; |
+ return rc; |
} |
/* |
** Show available command line options |
*/ |
static const char zOptions[] = |
+ " -help show this message\n" |
" -init filename read/process named file\n" |
" -echo print commands before execution\n" |
" -[no]header turn headers on or off\n" |
@@ -2971,8 +2620,13 @@ static const char zOptions[] = |
" -line set output mode to 'line'\n" |
" -list set output mode to 'list'\n" |
" -separator 'x' set output field separator (|)\n" |
+ " -stats print memory stats before each finalize\n" |
" -nullvalue 'text' set text string for NULL values\n" |
" -version show SQLite version\n" |
+ " -vfs NAME use NAME as the default VFS\n" |
+#ifdef SQLITE_ENABLE_VFSTRACE |
+ " -vfstrace enable tracing of all VFS calls\n" |
+#endif |
; |
static void usage(int showDetail){ |
fprintf(stderr, |
@@ -2995,8 +2649,10 @@ static void main_init(struct callback_data *data) { |
data->mode = MODE_List; |
memcpy(data->separator,"|", 2); |
data->showHeader = 0; |
+ sqlite3_config(SQLITE_CONFIG_LOG, shellLog, data); |
sqlite3_snprintf(sizeof(mainPrompt), mainPrompt,"sqlite> "); |
sqlite3_snprintf(sizeof(continuePrompt), continuePrompt," ...> "); |
+ sqlite3_config(SQLITE_CONFIG_SINGLETHREAD); |
} |
int main(int argc, char **argv){ |
@@ -3028,6 +2684,7 @@ int main(int argc, char **argv){ |
/* Do an initial pass through the command-line argument to locate |
** the name of the database file, the name of the initialization file, |
+ ** the size of the alternative malloc heap, |
** and the first command to execute. |
*/ |
for(i=1; i<argc-1; i++){ |
@@ -3040,6 +2697,47 @@ int main(int argc, char **argv){ |
}else if( strcmp(argv[i],"-init")==0 ){ |
i++; |
zInitFile = argv[i]; |
+ /* Need to check for batch mode here to so we can avoid printing |
+ ** informational messages (like from process_sqliterc) before |
+ ** we do the actual processing of arguments later in a second pass. |
+ */ |
+ }else if( strcmp(argv[i],"-batch")==0 ){ |
+ stdin_is_interactive = 0; |
+ }else if( strcmp(argv[i],"-heap")==0 ){ |
+ int j, c; |
+ const char *zSize; |
+ sqlite3_int64 szHeap; |
+ |
+ zSize = argv[++i]; |
+ szHeap = atoi(zSize); |
+ for(j=0; (c = zSize[j])!=0; j++){ |
+ if( c=='M' ){ szHeap *= 1000000; break; } |
+ if( c=='K' ){ szHeap *= 1000; break; } |
+ if( c=='G' ){ szHeap *= 1000000000; break; } |
+ } |
+ if( szHeap>0x7fff0000 ) szHeap = 0x7fff0000; |
+#if defined(SQLITE_ENABLE_MEMSYS3) || defined(SQLITE_ENABLE_MEMSYS5) |
+ sqlite3_config(SQLITE_CONFIG_HEAP, malloc((int)szHeap), (int)szHeap, 64); |
+#endif |
+#ifdef SQLITE_ENABLE_VFSTRACE |
+ }else if( strcmp(argv[i],"-vfstrace")==0 ){ |
+ extern int vfstrace_register( |
+ const char *zTraceName, |
+ const char *zOldVfsName, |
+ int (*xOut)(const char*,void*), |
+ void *pOutArg, |
+ int makeDefault |
+ ); |
+ vfstrace_register("trace",0,(int(*)(const char*,void*))fputs,stderr,1); |
+#endif |
+ }else if( strcmp(argv[i],"-vfs")==0 ){ |
+ sqlite3_vfs *pVfs = sqlite3_vfs_find(argv[++i]); |
+ if( pVfs ){ |
+ sqlite3_vfs_register(pVfs, 1); |
+ }else{ |
+ fprintf(stderr, "no such VFS: \"%s\"\n", argv[i]); |
+ exit(1); |
+ } |
} |
} |
if( i<argc ){ |
@@ -3058,12 +2756,17 @@ int main(int argc, char **argv){ |
if( i<argc ){ |
zFirstCmd = argv[i++]; |
} |
+ if( i<argc ){ |
+ fprintf(stderr,"%s: Error: too many options: \"%s\"\n", Argv0, argv[i]); |
+ fprintf(stderr,"Use -help for a list of options.\n"); |
+ return 1; |
+ } |
data.out = stdout; |
#ifdef SQLITE_OMIT_MEMORYDB |
if( data.zDbFilename==0 ){ |
- fprintf(stderr,"%s: no database filename specified\n", argv[0]); |
- exit(1); |
+ fprintf(stderr,"%s: Error: no database filename specified\n", Argv0); |
+ return 1; |
} |
#endif |
@@ -3080,7 +2783,10 @@ int main(int argc, char **argv){ |
** is given on the command line, look for a file named ~/.sqliterc and |
** try to process it. |
*/ |
- process_sqliterc(&data,zInitFile); |
+ rc = process_sqliterc(&data,zInitFile); |
+ if( rc>0 ){ |
+ return rc; |
+ } |
/* Make a second pass through the command-line argument and set |
** options. This second pass is delayed until after the initialization |
@@ -3105,10 +2811,20 @@ int main(int argc, char **argv){ |
memcpy(data.separator,",",2); |
}else if( strcmp(z,"-separator")==0 ){ |
i++; |
+ if(i>=argc){ |
+ fprintf(stderr,"%s: Error: missing argument for option: %s\n", Argv0, z); |
+ fprintf(stderr,"Use -help for a list of options.\n"); |
+ return 1; |
+ } |
sqlite3_snprintf(sizeof(data.separator), data.separator, |
"%.*s",(int)sizeof(data.separator)-1,argv[i]); |
}else if( strcmp(z,"-nullvalue")==0 ){ |
i++; |
+ if(i>=argc){ |
+ fprintf(stderr,"%s: Error: missing argument for option: %s\n", Argv0, z); |
+ fprintf(stderr,"Use -help for a list of options.\n"); |
+ return 1; |
+ } |
sqlite3_snprintf(sizeof(data.nullvalue), data.nullvalue, |
"%.*s",(int)sizeof(data.nullvalue)-1,argv[i]); |
}else if( strcmp(z,"-header")==0 ){ |
@@ -3117,6 +2833,8 @@ int main(int argc, char **argv){ |
data.showHeader = 0; |
}else if( strcmp(z,"-echo")==0 ){ |
data.echoOn = 1; |
+ }else if( strcmp(z,"-stats")==0 ){ |
+ data.statsOn = 1; |
}else if( strcmp(z,"-bail")==0 ){ |
bail_on_error = 1; |
}else if( strcmp(z,"-version")==0 ){ |
@@ -3126,10 +2844,16 @@ int main(int argc, char **argv){ |
stdin_is_interactive = 1; |
}else if( strcmp(z,"-batch")==0 ){ |
stdin_is_interactive = 0; |
+ }else if( strcmp(z,"-heap")==0 ){ |
+ i++; |
+ }else if( strcmp(z,"-vfs")==0 ){ |
+ i++; |
+ }else if( strcmp(z,"-vfstrace")==0 ){ |
+ i++; |
}else if( strcmp(z,"-help")==0 || strcmp(z, "--help")==0 ){ |
usage(1); |
}else{ |
- fprintf(stderr,"%s: unknown option: %s\n", Argv0, z); |
+ fprintf(stderr,"%s: Error: unknown option: %s\n", Argv0, z); |
fprintf(stderr,"Use -help for a list of options.\n"); |
return 1; |
} |
@@ -3139,15 +2863,16 @@ int main(int argc, char **argv){ |
/* Run just the command that follows the database name |
*/ |
if( zFirstCmd[0]=='.' ){ |
- do_meta_command(zFirstCmd, &data); |
- exit(0); |
+ rc = do_meta_command(zFirstCmd, &data); |
}else{ |
- int rc; |
open_db(&data); |
- rc = sqlite3_exec(data.db, zFirstCmd, callback, &data, &zErrMsg); |
- if( rc!=0 && zErrMsg!=0 ){ |
- fprintf(stderr,"SQL error: %s\n", zErrMsg); |
- exit(1); |
+ rc = shell_exec(data.db, zFirstCmd, shell_callback, &data, &zErrMsg); |
+ if( zErrMsg!=0 ){ |
+ fprintf(stderr,"Error: %s\n", zErrMsg); |
+ return rc!=0 ? rc : 1; |
+ }else if( rc!=0 ){ |
+ fprintf(stderr,"Error: unable to process SQL \"%s\"\n", zFirstCmd); |
+ return rc; |
} |
} |
}else{ |
@@ -3185,10 +2910,8 @@ int main(int argc, char **argv){ |
} |
} |
set_table_name(&data, 0); |
- if( db ){ |
- if( sqlite3_close(db)!=SQLITE_OK ){ |
- fprintf(stderr,"error closing database: %s\n", sqlite3_errmsg(db)); |
- } |
+ if( data.db ){ |
+ sqlite3_close(data.db); |
} |
return rc; |
} |