drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 1 | /* |
drh | b19a2bc | 2001-09-16 00:13:26 +0000 | [diff] [blame] | 2 | ** 2001 September 15 |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 3 | ** |
drh | b19a2bc | 2001-09-16 00:13:26 +0000 | [diff] [blame] | 4 | ** The author disclaims copyright to this source code. In place of |
| 5 | ** a legal notice, here is a blessing: |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 6 | ** |
drh | b19a2bc | 2001-09-16 00:13:26 +0000 | [diff] [blame] | 7 | ** May you do good and not evil. |
| 8 | ** May you find forgiveness for yourself and forgive others. |
| 9 | ** May you share freely, never taking more than you give. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 10 | ** |
| 11 | ************************************************************************* |
| 12 | ** Internal interface definitions for SQLite. |
| 13 | ** |
drh | 1d1f305 | 2002-05-21 13:18:25 +0000 | [diff] [blame^] | 14 | ** @(#) $Id: sqliteInt.h,v 1.112 2002/05/21 13:18:26 drh Exp $ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 15 | */ |
| 16 | #include "sqlite.h" |
drh | beae319 | 2001-09-22 18:12:08 +0000 | [diff] [blame] | 17 | #include "hash.h" |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 18 | #include "vdbe.h" |
| 19 | #include "parse.h" |
drh | be0072d | 2001-09-13 14:46:09 +0000 | [diff] [blame] | 20 | #include "btree.h" |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 21 | #include <stdio.h> |
| 22 | #include <stdlib.h> |
| 23 | #include <string.h> |
| 24 | #include <assert.h> |
| 25 | |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 26 | /* |
drh | a1b351a | 2001-09-14 16:42:12 +0000 | [diff] [blame] | 27 | ** The maximum number of in-memory pages to use for the main database |
| 28 | ** table and for temporary tables. |
| 29 | */ |
drh | 603240c | 2002-03-05 01:11:12 +0000 | [diff] [blame] | 30 | #define MAX_PAGES 2000 |
| 31 | #define TEMP_PAGES 500 |
drh | a1b351a | 2001-09-14 16:42:12 +0000 | [diff] [blame] | 32 | |
| 33 | /* |
drh | 5a2c2c2 | 2001-11-21 02:21:11 +0000 | [diff] [blame] | 34 | ** Integers of known sizes. These typedefs might change for architectures |
| 35 | ** where the sizes very. Preprocessor macros are available so that the |
| 36 | ** types can be conveniently redefined at compile-type. Like this: |
| 37 | ** |
| 38 | ** cc '-DUINTPTR_TYPE=long long int' ... |
drh | 41a2b48 | 2001-01-20 19:52:49 +0000 | [diff] [blame] | 39 | */ |
drh | 5a2c2c2 | 2001-11-21 02:21:11 +0000 | [diff] [blame] | 40 | #ifndef UINT32_TYPE |
| 41 | # define UINT32_TYPE unsigned int |
| 42 | #endif |
| 43 | #ifndef UINT16_TYPE |
| 44 | # define UINT16_TYPE unsigned short int |
| 45 | #endif |
| 46 | #ifndef UINT8_TYPE |
| 47 | # define UINT8_TYPE unsigned char |
| 48 | #endif |
| 49 | #ifndef INTPTR_TYPE |
| 50 | # define INTPTR_TYPE int |
| 51 | #endif |
| 52 | typedef UINT32_TYPE u32; /* 4-byte unsigned integer */ |
| 53 | typedef UINT16_TYPE u16; /* 2-byte unsigned integer */ |
| 54 | typedef UINT8_TYPE u8; /* 1-byte unsigned integer */ |
| 55 | typedef INTPTR_TYPE ptr; /* Big enough to hold a pointer */ |
| 56 | typedef unsigned INTPTR_TYPE uptr; /* Big enough to hold a pointer */ |
| 57 | |
| 58 | /* |
| 59 | ** This macro casts a pointer to an integer. Useful for doing |
| 60 | ** pointer arithmetic. |
| 61 | */ |
| 62 | #define Addr(X) ((uptr)X) |
drh | 41a2b48 | 2001-01-20 19:52:49 +0000 | [diff] [blame] | 63 | |
| 64 | /* |
drh | 872ff86 | 2001-09-15 14:43:39 +0000 | [diff] [blame] | 65 | ** The maximum number of bytes of data that can be put into a single |
drh | 80ff32f | 2001-11-04 18:32:46 +0000 | [diff] [blame] | 66 | ** row of a single table. The upper bound on this limit is 16777215 |
| 67 | ** bytes (or 16MB-1). We have arbitrarily set the limit to just 1MB |
| 68 | ** here because the overflow page chain is inefficient for really big |
| 69 | ** records and we want to discourage people from thinking that |
| 70 | ** multi-megabyte records are OK. If your needs are different, you can |
| 71 | ** change this define and recompile to increase or decrease the record |
| 72 | ** size. |
drh | 872ff86 | 2001-09-15 14:43:39 +0000 | [diff] [blame] | 73 | */ |
drh | 80ff32f | 2001-11-04 18:32:46 +0000 | [diff] [blame] | 74 | #define MAX_BYTES_PER_ROW 1048576 |
drh | 872ff86 | 2001-09-15 14:43:39 +0000 | [diff] [blame] | 75 | |
| 76 | /* |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 77 | ** If memory allocation problems are found, recompile with |
| 78 | ** |
| 79 | ** -DMEMORY_DEBUG=1 |
| 80 | ** |
| 81 | ** to enable some sanity checking on malloc() and free(). To |
| 82 | ** check for memory leaks, recompile with |
| 83 | ** |
| 84 | ** -DMEMORY_DEBUG=2 |
| 85 | ** |
| 86 | ** and a line of text will be written to standard error for |
| 87 | ** each malloc() and free(). This output can be analyzed |
| 88 | ** by an AWK script to determine if there are any leaks. |
| 89 | */ |
drh | dcc581c | 2000-05-30 13:44:19 +0000 | [diff] [blame] | 90 | #ifdef MEMORY_DEBUG |
| 91 | # define sqliteMalloc(X) sqliteMalloc_(X,__FILE__,__LINE__) |
| 92 | # define sqliteFree(X) sqliteFree_(X,__FILE__,__LINE__) |
| 93 | # define sqliteRealloc(X,Y) sqliteRealloc_(X,Y,__FILE__,__LINE__) |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 94 | # define sqliteStrDup(X) sqliteStrDup_(X,__FILE__,__LINE__) |
| 95 | # define sqliteStrNDup(X,Y) sqliteStrNDup_(X,Y,__FILE__,__LINE__) |
drh | c3c2fc9 | 2000-05-31 22:58:39 +0000 | [diff] [blame] | 96 | void sqliteStrRealloc(char**); |
| 97 | #else |
| 98 | # define sqliteStrRealloc(X) |
drh | dcc581c | 2000-05-30 13:44:19 +0000 | [diff] [blame] | 99 | #endif |
| 100 | |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 101 | /* |
drh | daffd0e | 2001-04-11 14:28:42 +0000 | [diff] [blame] | 102 | ** This variable gets set if malloc() ever fails. After it gets set, |
| 103 | ** the SQLite library shuts down permanently. |
| 104 | */ |
| 105 | extern int sqlite_malloc_failed; |
| 106 | |
| 107 | /* |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 108 | ** The following global variables are used for testing and debugging |
drh | 8c82b35 | 2000-12-10 18:23:50 +0000 | [diff] [blame] | 109 | ** only. They only work if MEMORY_DEBUG is defined. |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 110 | */ |
| 111 | #ifdef MEMORY_DEBUG |
drh | 8c82b35 | 2000-12-10 18:23:50 +0000 | [diff] [blame] | 112 | extern int sqlite_nMalloc; /* Number of sqliteMalloc() calls */ |
| 113 | extern int sqlite_nFree; /* Number of sqliteFree() calls */ |
| 114 | extern int sqlite_iMallocFail; /* Fail sqliteMalloc() after this many calls */ |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 115 | #endif |
| 116 | |
| 117 | /* |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 118 | ** Name of the master database table. The master database table |
| 119 | ** is a special table that holds the names and attributes of all |
| 120 | ** user tables and indices. |
| 121 | */ |
| 122 | #define MASTER_NAME "sqlite_master" |
| 123 | |
| 124 | /* |
| 125 | ** A convenience macro that returns the number of elements in |
| 126 | ** an array. |
| 127 | */ |
| 128 | #define ArraySize(X) (sizeof(X)/sizeof(X[0])) |
| 129 | |
| 130 | /* |
| 131 | ** Forward references to structures |
| 132 | */ |
drh | 7020f65 | 2000-06-03 18:06:52 +0000 | [diff] [blame] | 133 | typedef struct Column Column; |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 134 | typedef struct Table Table; |
| 135 | typedef struct Index Index; |
| 136 | typedef struct Instruction Instruction; |
| 137 | typedef struct Expr Expr; |
| 138 | typedef struct ExprList ExprList; |
| 139 | typedef struct Parse Parse; |
| 140 | typedef struct Token Token; |
| 141 | typedef struct IdList IdList; |
| 142 | typedef struct WhereInfo WhereInfo; |
drh | 6b56344 | 2001-11-07 16:48:26 +0000 | [diff] [blame] | 143 | typedef struct WhereLevel WhereLevel; |
drh | 9bb61fe | 2000-06-05 16:01:39 +0000 | [diff] [blame] | 144 | typedef struct Select Select; |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 145 | typedef struct AggExpr AggExpr; |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 146 | typedef struct FuncDef FuncDef; |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 147 | typedef struct Trigger Trigger; |
| 148 | typedef struct TriggerStep TriggerStep; |
| 149 | typedef struct TriggerStack TriggerStack; |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 150 | |
| 151 | /* |
| 152 | ** Each database is an instance of the following structure |
| 153 | */ |
| 154 | struct sqlite { |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 155 | Btree *pBe; /* The B*Tree backend */ |
drh | f57b339 | 2001-10-08 13:22:32 +0000 | [diff] [blame] | 156 | Btree *pBeTemp; /* Backend for session temporary tables */ |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 157 | int flags; /* Miscellanous flags. See below */ |
| 158 | int file_format; /* What file format version is this database? */ |
drh | 50e5dad | 2001-09-15 00:57:28 +0000 | [diff] [blame] | 159 | int schema_cookie; /* Magic number that changes with the schema */ |
| 160 | int next_cookie; /* Value of schema_cookie after commit */ |
drh | cd61c28 | 2002-03-06 22:01:34 +0000 | [diff] [blame] | 161 | int cache_size; /* Number of pages to use in the cache */ |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 162 | int nTable; /* Number of tables in the database */ |
| 163 | void *pBusyArg; /* 1st Argument to the busy callback */ |
drh | 353f57e | 2000-08-02 12:26:28 +0000 | [diff] [blame] | 164 | int (*xBusyCallback)(void *,const char*,int); /* The busy callback */ |
drh | beae319 | 2001-09-22 18:12:08 +0000 | [diff] [blame] | 165 | Hash tblHash; /* All tables indexed by name */ |
| 166 | Hash idxHash; /* All (named) indices indexed by name */ |
drh | 74e24cd | 2002-01-09 03:19:59 +0000 | [diff] [blame] | 167 | Hash tblDrop; /* Uncommitted DROP TABLEs */ |
| 168 | Hash idxDrop; /* Uncommitted DROP INDEXs */ |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 169 | Hash aFunc; /* All functions that can be in SQL exprs */ |
drh | af9ff33 | 2002-01-16 21:00:27 +0000 | [diff] [blame] | 170 | int lastRowid; /* ROWID of most recent insert */ |
drh | 5cf8e8c | 2002-02-19 22:42:05 +0000 | [diff] [blame] | 171 | int priorNewRowid; /* Last randomly generated ROWID */ |
drh | 1c92853 | 2002-01-31 15:54:21 +0000 | [diff] [blame] | 172 | int onError; /* Default conflict algorithm */ |
drh | 247be43 | 2002-05-10 05:44:55 +0000 | [diff] [blame] | 173 | int magic; /* Magic number for detect library misuse */ |
drh | c8d30ac | 2002-04-12 10:08:59 +0000 | [diff] [blame] | 174 | int nChange; /* Number of rows changed */ |
| 175 | int recursionDepth; /* Number of nested calls to sqlite_exec() */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 176 | |
| 177 | Hash trigHash; /* All triggers indexed by name */ |
| 178 | Hash trigDrop; /* Uncommited dropped triggers */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 179 | }; |
| 180 | |
| 181 | /* |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 182 | ** Possible values for the sqlite.flags. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 183 | */ |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 184 | #define SQLITE_VdbeTrace 0x00000001 /* True to trace VDBE execution */ |
| 185 | #define SQLITE_Initialized 0x00000002 /* True after initialization */ |
| 186 | #define SQLITE_Interrupt 0x00000004 /* Cancel current operation */ |
| 187 | #define SQLITE_InTrans 0x00000008 /* True if in a transaction */ |
| 188 | #define SQLITE_InternChanges 0x00000010 /* Uncommitted Hash table changes */ |
drh | 382c024 | 2001-10-06 16:33:02 +0000 | [diff] [blame] | 189 | #define SQLITE_FullColNames 0x00000020 /* Show full column names on SELECT */ |
drh | 1bee3d7 | 2001-10-15 00:44:35 +0000 | [diff] [blame] | 190 | #define SQLITE_CountRows 0x00000040 /* Count rows changed by INSERT, */ |
| 191 | /* DELETE, or UPDATE and return */ |
| 192 | /* the count using a callback. */ |
drh | 6a53534 | 2001-10-19 16:44:56 +0000 | [diff] [blame] | 193 | #define SQLITE_NullCallback 0x00000080 /* Invoke the callback once if the */ |
| 194 | /* result set is empty */ |
drh | c3a64ba | 2001-11-22 00:01:27 +0000 | [diff] [blame] | 195 | #define SQLITE_ResultDetails 0x00000100 /* Details added to result set */ |
drh | 417be79 | 2002-03-03 18:59:40 +0000 | [diff] [blame] | 196 | #define SQLITE_UnresetViews 0x00000200 /* True if one or more views have */ |
| 197 | /* defined column names */ |
drh | 58b9576 | 2000-06-02 01:17:37 +0000 | [diff] [blame] | 198 | |
| 199 | /* |
drh | 247be43 | 2002-05-10 05:44:55 +0000 | [diff] [blame] | 200 | ** Possible values for the sqlite.magic field. |
| 201 | ** The numbers are obtained at random and have no special meaning, other |
| 202 | ** than being distinct from one another. |
| 203 | */ |
| 204 | #define SQLITE_MAGIC_OPEN 0xa029a697 /* Database is open */ |
| 205 | #define SQLITE_MAGIC_CLOSED 0x9f3c2d33 /* Database is closed */ |
| 206 | #define SQLITE_MAGIC_BUSY 0xf03b7906 /* Database currently in use */ |
| 207 | #define SQLITE_MAGIC_ERROR 0xb5357930 /* An SQLITE_MISUSE error occurred */ |
| 208 | |
| 209 | /* |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 210 | ** Each SQL function is defined by an instance of the following |
| 211 | ** structure. A pointer to this structure is stored in the sqlite.aFunc |
drh | 8e0a2f9 | 2002-02-23 23:45:45 +0000 | [diff] [blame] | 212 | ** hash table. When multiple functions have the same name, the hash table |
| 213 | ** points to a linked list of these structures. |
drh | 2803757 | 2000-08-02 13:47:41 +0000 | [diff] [blame] | 214 | */ |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 215 | struct FuncDef { |
drh | 1350b03 | 2002-02-27 19:00:20 +0000 | [diff] [blame] | 216 | void (*xFunc)(sqlite_func*,int,const char**); /* Regular function */ |
drh | 56c0e92 | 2002-03-12 23:10:04 +0000 | [diff] [blame] | 217 | void (*xStep)(sqlite_func*,int,const char**); /* Aggregate function step */ |
drh | 1350b03 | 2002-02-27 19:00:20 +0000 | [diff] [blame] | 218 | void (*xFinalize)(sqlite_func*); /* Aggregate function finializer */ |
| 219 | int nArg; /* Number of arguments */ |
| 220 | void *pUserData; /* User data parameter */ |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 221 | FuncDef *pNext; /* Next function with same name */ |
drh | 8e0a2f9 | 2002-02-23 23:45:45 +0000 | [diff] [blame] | 222 | }; |
drh | 2803757 | 2000-08-02 13:47:41 +0000 | [diff] [blame] | 223 | |
| 224 | /* |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 225 | ** information about each column of an SQL table is held in an instance |
drh | 7020f65 | 2000-06-03 18:06:52 +0000 | [diff] [blame] | 226 | ** of this structure. |
| 227 | */ |
| 228 | struct Column { |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 229 | char *zName; /* Name of this column */ |
| 230 | char *zDflt; /* Default value of this column */ |
drh | 382c024 | 2001-10-06 16:33:02 +0000 | [diff] [blame] | 231 | char *zType; /* Data type for this column */ |
drh | 4a32431 | 2001-12-21 14:30:42 +0000 | [diff] [blame] | 232 | u8 notNull; /* True if there is a NOT NULL constraint */ |
| 233 | u8 isPrimKey; /* True if this column is an INTEGER PRIMARY KEY */ |
drh | 7020f65 | 2000-06-03 18:06:52 +0000 | [diff] [blame] | 234 | }; |
| 235 | |
| 236 | /* |
drh | 22f70c3 | 2002-02-18 01:17:00 +0000 | [diff] [blame] | 237 | ** Each SQL table is represented in memory by an instance of the |
| 238 | ** following structure. |
| 239 | ** |
| 240 | ** Expr.zName is the name of the table. The case of the original |
| 241 | ** CREATE TABLE statement is stored, but case is not significant for |
| 242 | ** comparisons. |
| 243 | ** |
| 244 | ** Expr.nCol is the number of columns in this table. Expr.aCol is a |
| 245 | ** pointer to an array of Column structures, one for each column. |
| 246 | ** |
| 247 | ** If the table has an INTEGER PRIMARY KEY, then Expr.iPKey is the index of |
| 248 | ** the column that is that key. Otherwise Expr.iPKey is negative. Note |
| 249 | ** that the datatype of the PRIMARY KEY must be INTEGER for this field to |
| 250 | ** be set. An INTEGER PRIMARY KEY is used as the rowid for each row of |
| 251 | ** the table. If a table has no INTEGER PRIMARY KEY, then a random rowid |
| 252 | ** is generated for each row of the table. Expr.hasPrimKey is true if |
| 253 | ** the table has any PRIMARY KEY, INTEGER or otherwise. |
| 254 | ** |
| 255 | ** Expr.tnum is the page number for the root BTree page of the table in the |
| 256 | ** database file. If Expr.isTemp is true, then this page occurs in the |
| 257 | ** auxiliary database file, not the main database file. If Expr.isTransient |
| 258 | ** is true, then the table is stored in a file that is automatically deleted |
| 259 | ** when the VDBE cursor to the table is closed. In this case Expr.tnum |
| 260 | ** refers VDBE cursor number that holds the table open, not to the root |
| 261 | ** page number. Transient tables are used to hold the results of a |
| 262 | ** sub-query that appears instead of a real table name in the FROM clause |
| 263 | ** of a SELECT statement. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 264 | */ |
| 265 | struct Table { |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 266 | char *zName; /* Name of the table */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 267 | int nCol; /* Number of columns in this table */ |
| 268 | Column *aCol; /* Information about each column */ |
drh | c839258 | 2001-12-31 02:48:51 +0000 | [diff] [blame] | 269 | int iPKey; /* If not less then 0, use aCol[iPKey] as the primary key */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 270 | Index *pIndex; /* List of SQL indexes on this table. */ |
drh | 22f70c3 | 2002-02-18 01:17:00 +0000 | [diff] [blame] | 271 | int tnum; /* Root BTree node for this table (see note above) */ |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 272 | Select *pSelect; /* NULL for tables. Points to definition if a view. */ |
drh | 717e640 | 2001-09-27 03:22:32 +0000 | [diff] [blame] | 273 | u8 readOnly; /* True if this table should not be written by the user */ |
| 274 | u8 isCommit; /* True if creation of this table has been committed */ |
drh | f57b339 | 2001-10-08 13:22:32 +0000 | [diff] [blame] | 275 | u8 isTemp; /* True if stored in db->pBeTemp instead of db->pBe */ |
drh | 22f70c3 | 2002-02-18 01:17:00 +0000 | [diff] [blame] | 276 | u8 isTransient; /* True if automatically deleted when VDBE finishes */ |
drh | 4a32431 | 2001-12-21 14:30:42 +0000 | [diff] [blame] | 277 | u8 hasPrimKey; /* True if there exists a primary key */ |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 278 | u8 keyConf; /* What to do in case of uniqueness conflict on iPKey */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 279 | |
| 280 | Trigger *pTrigger; /* List of SQL triggers on this table */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 281 | }; |
| 282 | |
| 283 | /* |
drh | 22f70c3 | 2002-02-18 01:17:00 +0000 | [diff] [blame] | 284 | ** SQLite supports 5 different ways to resolve a contraint |
| 285 | ** error. ROLLBACK processing means that a constraint violation |
drh | 1c92853 | 2002-01-31 15:54:21 +0000 | [diff] [blame] | 286 | ** causes the operation in proces to fail and for the current transaction |
| 287 | ** to be rolled back. ABORT processing means the operation in process |
| 288 | ** fails and any prior changes from that one operation are backed out, |
| 289 | ** but the transaction is not rolled back. FAIL processing means that |
| 290 | ** the operation in progress stops and returns an error code. But prior |
| 291 | ** changes due to the same operation are not backed out and no rollback |
| 292 | ** occurs. IGNORE means that the particular row that caused the constraint |
| 293 | ** error is not inserted or updated. Processing continues and no error |
| 294 | ** is returned. REPLACE means that preexisting database rows that caused |
| 295 | ** a UNIQUE constraint violation are removed so that the new insert or |
| 296 | ** update can proceed. Processing continues and no error is reported. |
| 297 | ** |
| 298 | ** The following there symbolic values are used to record which type |
| 299 | ** of action to take. |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 300 | */ |
drh | 1c92853 | 2002-01-31 15:54:21 +0000 | [diff] [blame] | 301 | #define OE_None 0 /* There is no constraint to check */ |
| 302 | #define OE_Rollback 1 /* Fail the operation and rollback the transaction */ |
| 303 | #define OE_Abort 2 /* Back out changes but do no rollback transaction */ |
| 304 | #define OE_Fail 3 /* Stop the operation but leave all prior changes */ |
| 305 | #define OE_Ignore 4 /* Ignore the error. Do not do the INSERT or UPDATE */ |
| 306 | #define OE_Replace 5 /* Delete existing record, then do INSERT or UPDATE */ |
| 307 | #define OE_Default 9 /* Do whatever the default action is */ |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 308 | |
| 309 | /* |
drh | 66b89c8 | 2000-11-28 20:47:17 +0000 | [diff] [blame] | 310 | ** Each SQL index is represented in memory by an |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 311 | ** instance of the following structure. |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 312 | ** |
| 313 | ** The columns of the table that are to be indexed are described |
| 314 | ** by the aiColumn[] field of this structure. For example, suppose |
| 315 | ** we have the following table and index: |
| 316 | ** |
| 317 | ** CREATE TABLE Ex1(c1 int, c2 int, c3 text); |
| 318 | ** CREATE INDEX Ex2 ON Ex1(c3,c1); |
| 319 | ** |
| 320 | ** In the Table structure describing Ex1, nCol==3 because there are |
| 321 | ** three columns in the table. In the Index structure describing |
| 322 | ** Ex2, nColumn==2 since 2 of the 3 columns of Ex1 are indexed. |
| 323 | ** The value of aiColumn is {2, 0}. aiColumn[0]==2 because the |
| 324 | ** first column to be indexed (c3) has an index of 2 in Ex1.aCol[]. |
| 325 | ** The second column to be indexed (c1) has an index of 0 in |
| 326 | ** Ex1.aCol[], hence Ex2.aiColumn[1]==0. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 327 | */ |
| 328 | struct Index { |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 329 | char *zName; /* Name of this index */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 330 | int nColumn; /* Number of columns in the table used by this index */ |
| 331 | int *aiColumn; /* Which columns are used by this index. 1st is 0 */ |
| 332 | Table *pTable; /* The SQL table being indexed */ |
drh | be0072d | 2001-09-13 14:46:09 +0000 | [diff] [blame] | 333 | int tnum; /* Page containing root of this index in database file */ |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 334 | u8 isUnique; /* OE_Abort, OE_Ignore, OE_Replace, or OE_None */ |
drh | 717e640 | 2001-09-27 03:22:32 +0000 | [diff] [blame] | 335 | u8 isCommit; /* True if creation of this index has been committed */ |
drh | 74e24cd | 2002-01-09 03:19:59 +0000 | [diff] [blame] | 336 | u8 isDropped; /* True if a DROP INDEX has executed on this index */ |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 337 | u8 onError; /* OE_Abort, OE_Ignore, OE_Replace, or OE_None */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 338 | Index *pNext; /* The next index associated with the same table */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 339 | }; |
| 340 | |
| 341 | /* |
| 342 | ** Each token coming out of the lexer is an instance of |
| 343 | ** this structure. |
| 344 | */ |
| 345 | struct Token { |
drh | 80ff32f | 2001-11-04 18:32:46 +0000 | [diff] [blame] | 346 | const char *z; /* Text of the token. Not NULL-terminated! */ |
| 347 | int n; /* Number of characters in this token */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 348 | }; |
| 349 | |
| 350 | /* |
| 351 | ** Each node of an expression in the parse tree is an instance |
drh | 22f70c3 | 2002-02-18 01:17:00 +0000 | [diff] [blame] | 352 | ** of this structure. |
| 353 | ** |
| 354 | ** Expr.op is the opcode. The integer parser token codes are reused |
| 355 | ** as opcodes here. For example, the parser defines TK_GE to be an integer |
| 356 | ** code representing the ">=" operator. This same integer code is reused |
| 357 | ** to represent the greater-than-or-equal-to operator in the expression |
| 358 | ** tree. |
| 359 | ** |
| 360 | ** Expr.pRight and Expr.pLeft are subexpressions. Expr.pList is a list |
| 361 | ** of argument if the expression is a function. |
| 362 | ** |
| 363 | ** Expr.token is the operator token for this node. Expr.span is the complete |
| 364 | ** subexpression represented by this node and all its decendents. These |
| 365 | ** fields are used for error reporting and for reconstructing the text of |
| 366 | ** an expression to use as the column name in a SELECT statement. |
| 367 | ** |
| 368 | ** An expression of the form ID or ID.ID refers to a column in a table. |
| 369 | ** For such expressions, Expr.op is set to TK_COLUMN and Expr.iTable is |
| 370 | ** the integer cursor number of a VDBE cursor pointing to that table and |
| 371 | ** Expr.iColumn is the column number for the specific column. If the |
| 372 | ** expression is used as a result in an aggregate SELECT, then the |
| 373 | ** value is also stored in the Expr.iAgg column in the aggregate so that |
| 374 | ** it can be accessed after all aggregates are computed. |
| 375 | ** |
| 376 | ** If the expression is a function, the Expr.iTable is an integer code |
| 377 | ** representing which function. |
| 378 | ** |
| 379 | ** The Expr.pSelect field points to a SELECT statement. The SELECT might |
| 380 | ** be the right operand of an IN operator. Or, if a scalar SELECT appears |
| 381 | ** in an expression the opcode is TK_SELECT and Expr.pSelect is the only |
| 382 | ** operand. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 383 | */ |
| 384 | struct Expr { |
| 385 | int op; /* Operation performed by this node */ |
| 386 | Expr *pLeft, *pRight; /* Left and right subnodes */ |
| 387 | ExprList *pList; /* A list of expressions used as a function argument */ |
| 388 | Token token; /* An operand token */ |
drh | e1b6a5b | 2000-07-29 13:06:59 +0000 | [diff] [blame] | 389 | Token span; /* Complete text of the expression */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 390 | int iTable, iColumn; /* When op==TK_COLUMN, then this expr node means the |
| 391 | ** iColumn-th field of the iTable-th table. When |
| 392 | ** op==TK_FUNCTION, iColumn holds the function id */ |
| 393 | int iAgg; /* When op==TK_COLUMN and pParse->useAgg==TRUE, pull |
| 394 | ** result from the iAgg-th element of the aggregator */ |
drh | 19a775c | 2000-06-05 18:54:46 +0000 | [diff] [blame] | 395 | Select *pSelect; /* When the expression is a sub-select */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 396 | }; |
| 397 | |
| 398 | /* |
| 399 | ** A list of expressions. Each expression may optionally have a |
| 400 | ** name. An expr/name combination can be used in several ways, such |
| 401 | ** as the list of "expr AS ID" fields following a "SELECT" or in the |
| 402 | ** list of "ID = expr" items in an UPDATE. A list of expressions can |
| 403 | ** also be used as the argument to a function, in which case the azName |
| 404 | ** field is not used. |
| 405 | */ |
| 406 | struct ExprList { |
| 407 | int nExpr; /* Number of expressions on the list */ |
drh | 6d4abfb | 2001-10-22 02:58:08 +0000 | [diff] [blame] | 408 | struct ExprList_item { |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 409 | Expr *pExpr; /* The list of expressions */ |
| 410 | char *zName; /* Token associated with this expression */ |
drh | d8bc708 | 2000-06-07 23:51:50 +0000 | [diff] [blame] | 411 | char sortOrder; /* 1 for DESC or 0 for ASC */ |
| 412 | char isAgg; /* True if this is an aggregate like count(*) */ |
| 413 | char done; /* A flag to indicate when processing is finished */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 414 | } *a; /* One entry for each expression */ |
| 415 | }; |
| 416 | |
| 417 | /* |
| 418 | ** A list of identifiers. |
| 419 | */ |
| 420 | struct IdList { |
| 421 | int nId; /* Number of identifiers on the list */ |
drh | 6d4abfb | 2001-10-22 02:58:08 +0000 | [diff] [blame] | 422 | struct IdList_item { |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 423 | char *zName; /* Text of the identifier. */ |
| 424 | char *zAlias; /* The "B" part of a "A AS B" phrase. zName is the "A" */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 425 | int idx; /* Index in some Table.aCol[] of a column named zName */ |
drh | daffd0e | 2001-04-11 14:28:42 +0000 | [diff] [blame] | 426 | Table *pTab; /* An SQL table corresponding to zName */ |
| 427 | Select *pSelect; /* A SELECT statement used in place of a table name */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 428 | } *a; /* One entry for each identifier on the list */ |
| 429 | }; |
| 430 | |
| 431 | /* |
drh | 6b56344 | 2001-11-07 16:48:26 +0000 | [diff] [blame] | 432 | ** For each nested loop in a WHERE clause implementation, the WhereInfo |
| 433 | ** structure contains a single instance of this structure. This structure |
| 434 | ** is intended to be private the the where.c module and should not be |
| 435 | ** access or modified by other modules. |
| 436 | */ |
| 437 | struct WhereLevel { |
| 438 | int iMem; /* Memory cell used by this level */ |
| 439 | Index *pIdx; /* Index used */ |
| 440 | int iCur; /* Cursor number used for this index */ |
drh | 487ab3c | 2001-11-08 00:45:21 +0000 | [diff] [blame] | 441 | int score; /* How well this indexed scored */ |
drh | 6b56344 | 2001-11-07 16:48:26 +0000 | [diff] [blame] | 442 | int brk; /* Jump here to break out of the loop */ |
| 443 | int cont; /* Jump here to continue with the next loop cycle */ |
| 444 | int op, p1, p2; /* Opcode used to terminate the loop */ |
| 445 | }; |
| 446 | |
| 447 | /* |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 448 | ** The WHERE clause processing routine has two halves. The |
| 449 | ** first part does the start of the WHERE loop and the second |
| 450 | ** half does the tail of the WHERE loop. An instance of |
| 451 | ** this structure is returned by the first half and passed |
| 452 | ** into the second half to give some continuity. |
| 453 | */ |
| 454 | struct WhereInfo { |
| 455 | Parse *pParse; |
drh | 19a775c | 2000-06-05 18:54:46 +0000 | [diff] [blame] | 456 | IdList *pTabList; /* List of tables in the join */ |
| 457 | int iContinue; /* Jump here to continue with next record */ |
| 458 | int iBreak; /* Jump here to break out of the loop */ |
| 459 | int base; /* Index of first Open opcode */ |
drh | 6b56344 | 2001-11-07 16:48:26 +0000 | [diff] [blame] | 460 | int nLevel; /* Number of nested loop */ |
drh | 832508b | 2002-03-02 17:04:07 +0000 | [diff] [blame] | 461 | int savedNTab; /* Value of pParse->nTab before WhereBegin() */ |
| 462 | int peakNTab; /* Value of pParse->nTab after WhereBegin() */ |
drh | 6b56344 | 2001-11-07 16:48:26 +0000 | [diff] [blame] | 463 | WhereLevel a[1]; /* Information about each nest loop in the WHERE */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 464 | }; |
| 465 | |
| 466 | /* |
drh | 9bb61fe | 2000-06-05 16:01:39 +0000 | [diff] [blame] | 467 | ** An instance of the following structure contains all information |
| 468 | ** needed to generate code for a single SELECT statement. |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 469 | ** |
| 470 | ** The zSelect field is used when the Select structure must be persistent. |
| 471 | ** Normally, the expression tree points to tokens in the original input |
| 472 | ** string that encodes the select. But if the Select structure must live |
| 473 | ** longer than its input string (for example when it is used to describe |
| 474 | ** a VIEW) we have to make a copy of the input string so that the nodes |
| 475 | ** of the expression tree will have something to point to. zSelect is used |
| 476 | ** to hold that copy. |
drh | 9bb61fe | 2000-06-05 16:01:39 +0000 | [diff] [blame] | 477 | */ |
| 478 | struct Select { |
| 479 | int isDistinct; /* True if the DISTINCT keyword is present */ |
| 480 | ExprList *pEList; /* The fields of the result */ |
| 481 | IdList *pSrc; /* The FROM clause */ |
| 482 | Expr *pWhere; /* The WHERE clause */ |
| 483 | ExprList *pGroupBy; /* The GROUP BY clause */ |
| 484 | Expr *pHaving; /* The HAVING clause */ |
| 485 | ExprList *pOrderBy; /* The ORDER BY clause */ |
drh | 82c3d63 | 2000-06-06 21:56:07 +0000 | [diff] [blame] | 486 | int op; /* One of: TK_UNION TK_ALL TK_INTERSECT TK_EXCEPT */ |
drh | 967e8b7 | 2000-06-21 13:59:10 +0000 | [diff] [blame] | 487 | Select *pPrior; /* Prior select in a compound select statement */ |
drh | 9bbca4c | 2001-11-06 04:00:18 +0000 | [diff] [blame] | 488 | int nLimit, nOffset; /* LIMIT and OFFSET values. -1 means not used */ |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 489 | char *zSelect; /* Complete text of the SELECT command */ |
drh | 832508b | 2002-03-02 17:04:07 +0000 | [diff] [blame] | 490 | int base; /* Index of VDBE cursor for left-most FROM table */ |
drh | 9bb61fe | 2000-06-05 16:01:39 +0000 | [diff] [blame] | 491 | }; |
| 492 | |
| 493 | /* |
drh | fef5208 | 2000-06-06 01:50:43 +0000 | [diff] [blame] | 494 | ** The results of a select can be distributed in several ways. |
| 495 | */ |
| 496 | #define SRT_Callback 1 /* Invoke a callback with each row of result */ |
| 497 | #define SRT_Mem 2 /* Store result in a memory cell */ |
drh | 82c3d63 | 2000-06-06 21:56:07 +0000 | [diff] [blame] | 498 | #define SRT_Set 3 /* Store result as unique keys in a table */ |
| 499 | #define SRT_Union 5 /* Store result as keys in a table */ |
| 500 | #define SRT_Except 6 /* Remove result from a UNION table */ |
drh | 5974a30 | 2000-06-07 14:42:26 +0000 | [diff] [blame] | 501 | #define SRT_Table 7 /* Store result as data with a unique key */ |
drh | 2d0794e | 2002-03-03 03:03:52 +0000 | [diff] [blame] | 502 | #define SRT_TempTable 8 /* Store result in a trasient table */ |
drh | fef5208 | 2000-06-06 01:50:43 +0000 | [diff] [blame] | 503 | |
| 504 | /* |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 505 | ** When a SELECT uses aggregate functions (like "count(*)" or "avg(f1)") |
| 506 | ** we have to do some additional analysis of expressions. An instance |
| 507 | ** of the following structure holds information about a single subexpression |
| 508 | ** somewhere in the SELECT statement. An array of these structures holds |
| 509 | ** all the information we need to generate code for aggregate |
| 510 | ** expressions. |
| 511 | ** |
| 512 | ** Note that when analyzing a SELECT containing aggregates, both |
| 513 | ** non-aggregate field variables and aggregate functions are stored |
| 514 | ** in the AggExpr array of the Parser structure. |
| 515 | ** |
| 516 | ** The pExpr field points to an expression that is part of either the |
| 517 | ** field list, the GROUP BY clause, the HAVING clause or the ORDER BY |
| 518 | ** clause. The expression will be freed when those clauses are cleaned |
| 519 | ** up. Do not try to delete the expression attached to AggExpr.pExpr. |
| 520 | ** |
| 521 | ** If AggExpr.pExpr==0, that means the expression is "count(*)". |
| 522 | */ |
| 523 | struct AggExpr { |
| 524 | int isAgg; /* if TRUE contains an aggregate function */ |
| 525 | Expr *pExpr; /* The expression */ |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 526 | FuncDef *pFunc; /* Information about the aggregate function */ |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 527 | }; |
| 528 | |
| 529 | /* |
drh | f57b339 | 2001-10-08 13:22:32 +0000 | [diff] [blame] | 530 | ** An SQL parser context. A copy of this structure is passed through |
| 531 | ** the parser and down into all the parser action routine in order to |
| 532 | ** carry around information that is global to the entire parse. |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 533 | */ |
| 534 | struct Parse { |
| 535 | sqlite *db; /* The main database structure */ |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 536 | Btree *pBe; /* The database backend */ |
drh | 4c50439 | 2000-10-16 22:06:40 +0000 | [diff] [blame] | 537 | int rc; /* Return code from execution */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 538 | sqlite_callback xCallback; /* The callback function */ |
| 539 | void *pArg; /* First argument to the callback function */ |
| 540 | char *zErrMsg; /* An error message */ |
| 541 | Token sErrToken; /* The token at which the error occurred */ |
| 542 | Token sFirstToken; /* The first token parsed */ |
| 543 | Token sLastToken; /* The last token parsed */ |
| 544 | Table *pNewTable; /* A table being constructed by CREATE TABLE */ |
| 545 | Vdbe *pVdbe; /* An engine for executing database bytecode */ |
drh | d8bc708 | 2000-06-07 23:51:50 +0000 | [diff] [blame] | 546 | int colNamesSet; /* TRUE after OP_ColumnCount has been issued to pVdbe */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 547 | int explain; /* True if the EXPLAIN flag is found on the query */ |
| 548 | int initFlag; /* True if reparsing CREATE TABLEs */ |
drh | f57b339 | 2001-10-08 13:22:32 +0000 | [diff] [blame] | 549 | int nameClash; /* A permanent table name clashes with temp table name */ |
drh | d78eeee | 2001-09-13 16:18:53 +0000 | [diff] [blame] | 550 | int newTnum; /* Table number to use when reparsing CREATE TABLEs */ |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 551 | int nErr; /* Number of errors seen */ |
drh | 832508b | 2002-03-02 17:04:07 +0000 | [diff] [blame] | 552 | int nTab; /* Number of previously allocated VDBE cursors */ |
drh | 19a775c | 2000-06-05 18:54:46 +0000 | [diff] [blame] | 553 | int nMem; /* Number of memory cells used so far */ |
drh | fef5208 | 2000-06-06 01:50:43 +0000 | [diff] [blame] | 554 | int nSet; /* Number of sets used so far */ |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 555 | int nAgg; /* Number of aggregate expressions */ |
| 556 | AggExpr *aAgg; /* An array of aggregate expressions */ |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 557 | int useAgg; /* If true, extract field values from the aggregator |
| 558 | ** while generating expressions. Normally false */ |
drh | 50e5dad | 2001-09-15 00:57:28 +0000 | [diff] [blame] | 559 | int schemaVerified; /* True if an OP_VerifySchema has been coded someplace |
| 560 | ** other than after an OP_Transaction */ |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 561 | TriggerStack *trigStack; |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 562 | }; |
| 563 | |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 564 | /* |
| 565 | * Each trigger present in the database schema is stored as an instance of |
| 566 | * struct Trigger. |
| 567 | * |
| 568 | * Pointers to instances of struct Trigger are stored in two ways. |
| 569 | * 1. In the "trigHash" hash table (part of the sqlite* that represents the |
| 570 | * database). This allows Trigger structures to be retrieved by name. |
| 571 | * 2. All triggers associated with a single table form a linked list, using the |
| 572 | * pNext member of struct Trigger. A pointer to the first element of the linked |
| 573 | * list is stored as the "pTrigger" member of the associated struct Table. |
| 574 | * |
| 575 | * The "strings" member of struct Trigger contains a pointer to the memory |
| 576 | * referenced by the various Token structures referenced indirectly by the |
| 577 | * "pWhen", "pColumns" and "step_list" members. (ie. the memory allocated for |
| 578 | * use in conjunction with the sqliteExprMoveStrings() etc. interface). |
| 579 | * |
| 580 | * The "step_list" member points to the first element of a linked list containing |
| 581 | * the SQL statements specified as the trigger program. |
| 582 | * |
| 583 | * When a trigger is initially created, the "isCommit" member is set to FALSE. |
| 584 | * When a transaction is rolled back, any Trigger structures with "isCommit" set |
| 585 | * to FALSE are deleted by the logic in sqliteRollbackInternalChanges(). When |
| 586 | * a transaction is commited, the "isCommit" member is set to TRUE for any |
| 587 | * Trigger structures for which it is FALSE. |
| 588 | * |
| 589 | * When a trigger is dropped, using the sqliteDropTrigger() interfaced, it is |
| 590 | * removed from the trigHash hash table and added to the trigDrop hash table. If |
| 591 | * the transaction is rolled back, the trigger is re-added into the trigHash |
| 592 | * hash table (and hence the database schema). If the transaction is commited, |
| 593 | * then the Trigger structure is deleted permanently. |
| 594 | */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 595 | struct Trigger { |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 596 | char *name; /* The name of the trigger */ |
| 597 | char *table; /* The table or view to which the trigger applies */ |
| 598 | int op; /* One of TK_DELETE, TK_UPDATE, TK_INSERT */ |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 599 | int tr_tm; /* One of TK_BEFORE, TK_AFTER */ |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 600 | Expr *pWhen; /* The WHEN clause of the expresion (may be NULL) */ |
| 601 | IdList *pColumns; /* If this is an UPDATE OF <column-list> trigger, |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 602 | the <column-list> is stored here */ |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 603 | int foreach; /* One of TK_ROW or TK_STATEMENT */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 604 | |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 605 | TriggerStep *step_list; /* Link list of trigger program steps */ |
| 606 | char *strings; /* pointer to allocation of Token strings */ |
| 607 | Trigger *pNext; /* Next trigger associated with the table */ |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 608 | int isCommit; /* Set to TRUE once the trigger has been committed */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 609 | }; |
| 610 | |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 611 | /* |
| 612 | * An instance of struct TriggerStep is used to store a single SQL statement |
| 613 | * that is a part of a trigger-program. |
| 614 | * |
| 615 | * Instances of struct TriggerStep are stored in a singly linked list (linked |
| 616 | * using the "pNext" member) referenced by the "step_list" member of the |
| 617 | * associated struct Trigger instance. The first element of the linked list is |
| 618 | * the first step of the trigger-program. |
| 619 | * |
| 620 | * The "op" member indicates whether this is a "DELETE", "INSERT", "UPDATE" or |
| 621 | * "SELECT" statement. The meanings of the other members is determined by the |
| 622 | * value of "op" as follows: |
| 623 | * |
| 624 | * (op == TK_INSERT) |
| 625 | * orconf -> stores the ON CONFLICT algorithm |
| 626 | * pSelect -> If this is an INSERT INTO ... SELECT ... statement, then |
| 627 | * this stores a pointer to the SELECT statement. Otherwise NULL. |
| 628 | * target -> A token holding the name of the table to insert into. |
| 629 | * pExprList -> If this is an INSERT INTO ... VALUES ... statement, then |
| 630 | * this stores values to be inserted. Otherwise NULL. |
| 631 | * pIdList -> If this is an INSERT INTO ... (<column-names>) VALUES ... |
| 632 | * statement, then this stores the column-names to be inserted into. |
| 633 | * |
| 634 | * (op == TK_DELETE) |
| 635 | * target -> A token holding the name of the table to delete from. |
| 636 | * pWhere -> The WHERE clause of the DELETE statement if one is specified. |
| 637 | * Otherwise NULL. |
| 638 | * |
| 639 | * (op == TK_UPDATE) |
| 640 | * target -> A token holding the name of the table to update rows of. |
| 641 | * pWhere -> The WHERE clause of the UPDATE statement if one is specified. |
| 642 | * Otherwise NULL. |
| 643 | * pExprList -> A list of the columns to update and the expressions to update |
| 644 | * them to. See sqliteUpdate() documentation of "pChanges" argument. |
| 645 | * |
| 646 | */ |
| 647 | struct TriggerStep { |
| 648 | int op; /* One of TK_DELETE, TK_UPDATE, TK_INSERT, TK_SELECT */ |
| 649 | int orconf; /* OE_Rollback etc. */ |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 650 | |
danielk1977 | d99bc93 | 2002-05-16 00:13:12 +0000 | [diff] [blame] | 651 | Select *pSelect; /* Valid for SELECT and sometimes |
| 652 | INSERT steps (when pExprList == 0) */ |
| 653 | Token target; /* Valid for DELETE, UPDATE, INSERT steps */ |
| 654 | Expr *pWhere; /* Valid for DELETE, UPDATE steps */ |
| 655 | ExprList *pExprList; /* Valid for UPDATE statements and sometimes |
| 656 | INSERT steps (when pSelect == 0) */ |
| 657 | IdList *pIdList; /* Valid for INSERT statements only */ |
| 658 | |
| 659 | TriggerStep * pNext; /* Next in the link-list */ |
| 660 | }; |
| 661 | |
| 662 | /* |
| 663 | * An instance of struct TriggerStack stores information required during code |
| 664 | * generation of a single trigger program. While the trigger program is being |
| 665 | * coded, its associated TriggerStack instance is pointed to by the |
| 666 | * "pTriggerStack" member of the Parse structure. |
| 667 | * |
| 668 | * The pTab member points to the table that triggers are being coded on. The |
| 669 | * newIdx member contains the index of the vdbe cursor that points at the temp |
| 670 | * table that stores the new.* references. If new.* references are not valid |
| 671 | * for the trigger being coded (for example an ON DELETE trigger), then newIdx |
| 672 | * is set to -1. The oldIdx member is analogous to newIdx, for old.* references. |
| 673 | * |
| 674 | * The ON CONFLICT policy to be used for the trigger program steps is stored |
| 675 | * as the orconf member. If this is OE_Default, then the ON CONFLICT clause |
| 676 | * specified for individual triggers steps is used. |
| 677 | * |
| 678 | * struct TriggerStack has a "pNext" member, to allow linked lists to be |
| 679 | * constructed. When coding nested triggers (triggers fired by other triggers) |
| 680 | * each nested trigger stores its parent trigger's TriggerStack as the "pNext" |
| 681 | * pointer. Once the nested trigger has been coded, the pNext value is restored |
| 682 | * to the pTriggerStack member of the Parse stucture and coding of the parent |
| 683 | * trigger continues. |
| 684 | * |
| 685 | * Before a nested trigger is coded, the linked list pointed to by the |
| 686 | * pTriggerStack is scanned to ensure that the trigger is not about to be coded |
| 687 | * recursively. If this condition is detected, the nested trigger is not coded. |
| 688 | */ |
| 689 | struct TriggerStack { |
| 690 | Table *pTab; /* Table that triggers are currently being coded on */ |
| 691 | int newIdx; /* Index of vdbe cursor to "new" temp table */ |
| 692 | int oldIdx; /* Index of vdbe cursor to "old" temp table */ |
| 693 | int orconf; /* Current orconf policy */ |
| 694 | Trigger *pTrigger; |
| 695 | |
| 696 | TriggerStack *pNext; |
| 697 | }; |
| 698 | |
| 699 | /* |
| 700 | * This global flag is set for performance testing of triggers. When it is set |
| 701 | * SQLite will perform the overhead of building new and old trigger references |
| 702 | * even when no triggers exist |
| 703 | */ |
| 704 | extern int always_code_trigger_setup; |
danielk1977 | c3f9bad | 2002-05-15 08:30:12 +0000 | [diff] [blame] | 705 | |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 706 | /* |
| 707 | ** Internal function prototypes |
| 708 | */ |
| 709 | int sqliteStrICmp(const char *, const char *); |
| 710 | int sqliteStrNICmp(const char *, const char *, int); |
| 711 | int sqliteHashNoCase(const char *, int); |
| 712 | int sqliteCompare(const char *, const char *); |
| 713 | int sqliteSortCompare(const char *, const char *); |
drh | 9bbca4c | 2001-11-06 04:00:18 +0000 | [diff] [blame] | 714 | void sqliteRealToSortable(double r, char *); |
drh | dcc581c | 2000-05-30 13:44:19 +0000 | [diff] [blame] | 715 | #ifdef MEMORY_DEBUG |
| 716 | void *sqliteMalloc_(int,char*,int); |
| 717 | void sqliteFree_(void*,char*,int); |
| 718 | void *sqliteRealloc_(void*,int,char*,int); |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 719 | char *sqliteStrDup_(const char*,char*,int); |
| 720 | char *sqliteStrNDup_(const char*, int,char*,int); |
drh | dcc581c | 2000-05-30 13:44:19 +0000 | [diff] [blame] | 721 | #else |
| 722 | void *sqliteMalloc(int); |
| 723 | void sqliteFree(void*); |
| 724 | void *sqliteRealloc(void*,int); |
drh | 6e142f5 | 2000-06-08 13:36:40 +0000 | [diff] [blame] | 725 | char *sqliteStrDup(const char*); |
| 726 | char *sqliteStrNDup(const char*, int); |
drh | dcc581c | 2000-05-30 13:44:19 +0000 | [diff] [blame] | 727 | #endif |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 728 | void sqliteSetString(char **, const char *, ...); |
| 729 | void sqliteSetNString(char **, ...); |
drh | 982cef7 | 2000-05-30 16:27:03 +0000 | [diff] [blame] | 730 | void sqliteDequote(char*); |
drh | 17f7193 | 2002-02-21 12:01:27 +0000 | [diff] [blame] | 731 | int sqliteKeywordCode(const char*, int); |
drh | 80ff32f | 2001-11-04 18:32:46 +0000 | [diff] [blame] | 732 | int sqliteRunParser(Parse*, const char*, char **); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 733 | void sqliteExec(Parse*); |
| 734 | Expr *sqliteExpr(int, Expr*, Expr*, Token*); |
drh | e1b6a5b | 2000-07-29 13:06:59 +0000 | [diff] [blame] | 735 | void sqliteExprSpan(Expr*,Token*,Token*); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 736 | Expr *sqliteExprFunction(ExprList*, Token*); |
| 737 | void sqliteExprDelete(Expr*); |
| 738 | ExprList *sqliteExprListAppend(ExprList*,Expr*,Token*); |
| 739 | void sqliteExprListDelete(ExprList*); |
drh | f57b14a | 2001-09-14 18:54:08 +0000 | [diff] [blame] | 740 | void sqlitePragma(Parse*,Token*,Token*,int); |
drh | 5e00f6c | 2001-09-13 13:46:56 +0000 | [diff] [blame] | 741 | void sqliteCommitInternalChanges(sqlite*); |
| 742 | void sqliteRollbackInternalChanges(sqlite*); |
drh | 969fa7c | 2002-02-18 18:30:32 +0000 | [diff] [blame] | 743 | Table *sqliteResultSetOfSelect(Parse*,char*,Select*); |
drh | f57b339 | 2001-10-08 13:22:32 +0000 | [diff] [blame] | 744 | void sqliteStartTable(Parse*,Token*,Token*,int); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 745 | void sqliteAddColumn(Parse*,Token*); |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 746 | void sqliteAddNotNull(Parse*, int); |
| 747 | void sqliteAddPrimaryKey(Parse*, IdList*, int); |
drh | 382c024 | 2001-10-06 16:33:02 +0000 | [diff] [blame] | 748 | void sqliteAddColumnType(Parse*,Token*,Token*); |
drh | 7020f65 | 2000-06-03 18:06:52 +0000 | [diff] [blame] | 749 | void sqliteAddDefaultValue(Parse*,Token*,int); |
drh | 969fa7c | 2002-02-18 18:30:32 +0000 | [diff] [blame] | 750 | void sqliteEndTable(Parse*,Token*,Select*); |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 751 | void sqliteCreateView(Parse*,Token*,Token*,Select*); |
drh | 417be79 | 2002-03-03 18:59:40 +0000 | [diff] [blame] | 752 | int sqliteViewGetColumnNames(Parse*,Table*); |
| 753 | void sqliteViewResetAll(sqlite*); |
drh | 4ff6dfa | 2002-03-03 23:06:00 +0000 | [diff] [blame] | 754 | void sqliteDropTable(Parse*, Token*, int); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 755 | void sqliteDeleteTable(sqlite*, Table*); |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 756 | void sqliteInsert(Parse*, Token*, ExprList*, Select*, IdList*, int); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 757 | IdList *sqliteIdListAppend(IdList*, Token*); |
| 758 | void sqliteIdListAddAlias(IdList*, Token*); |
| 759 | void sqliteIdListDelete(IdList*); |
drh | 717e640 | 2001-09-27 03:22:32 +0000 | [diff] [blame] | 760 | void sqliteCreateIndex(Parse*, Token*, Token*, IdList*, int, Token*, Token*); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 761 | void sqliteDropIndex(Parse*, Token*); |
drh | 1b2e032 | 2002-03-03 02:49:51 +0000 | [diff] [blame] | 762 | int sqliteSelect(Parse*, Select*, int, int, Select*, int, int*); |
drh | 9bbca4c | 2001-11-06 04:00:18 +0000 | [diff] [blame] | 763 | Select *sqliteSelectNew(ExprList*,IdList*,Expr*,ExprList*,Expr*,ExprList*, |
| 764 | int,int,int); |
drh | 9bb61fe | 2000-06-05 16:01:39 +0000 | [diff] [blame] | 765 | void sqliteSelectDelete(Select*); |
drh | ff78bd2 | 2002-02-27 01:47:11 +0000 | [diff] [blame] | 766 | void sqliteSelectUnbind(Select*); |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 767 | Table *sqliteTableNameToTable(Parse*, const char*); |
| 768 | IdList *sqliteTableTokenToIdList(Parse*, Token*); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 769 | void sqliteDeleteFrom(Parse*, Token*, Expr*); |
drh | 9cfcf5d | 2002-01-29 18:41:24 +0000 | [diff] [blame] | 770 | void sqliteUpdate(Parse*, Token*, ExprList*, Expr*, int); |
drh | 832508b | 2002-03-02 17:04:07 +0000 | [diff] [blame] | 771 | WhereInfo *sqliteWhereBegin(Parse*, int, IdList*, Expr*, int); |
drh | 7589723 | 2000-05-29 14:26:00 +0000 | [diff] [blame] | 772 | void sqliteWhereEnd(WhereInfo*); |
| 773 | void sqliteExprCode(Parse*, Expr*); |
| 774 | void sqliteExprIfTrue(Parse*, Expr*, int); |
| 775 | void sqliteExprIfFalse(Parse*, Expr*, int); |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 776 | Table *sqliteFindTable(sqlite*,const char*); |
| 777 | Index *sqliteFindIndex(sqlite*,const char*); |
drh | 6d4abfb | 2001-10-22 02:58:08 +0000 | [diff] [blame] | 778 | void sqliteUnlinkAndDeleteIndex(sqlite*,Index*); |
drh | b419a92 | 2002-01-30 16:17:23 +0000 | [diff] [blame] | 779 | void sqliteCopy(Parse*, Token*, Token*, Token*, int); |
drh | dce2cbe | 2000-05-31 02:27:49 +0000 | [diff] [blame] | 780 | void sqliteVacuum(Parse*, Token*); |
drh | e17a7e3 | 2001-04-04 21:10:18 +0000 | [diff] [blame] | 781 | int sqliteGlobCompare(const unsigned char*,const unsigned char*); |
drh | dce2cbe | 2000-05-31 02:27:49 +0000 | [diff] [blame] | 782 | int sqliteLikeCompare(const unsigned char*,const unsigned char*); |
drh | cce7d17 | 2000-05-31 15:34:51 +0000 | [diff] [blame] | 783 | char *sqliteTableNameFromToken(Token*); |
| 784 | int sqliteExprCheck(Parse*, Expr*, int, int*); |
drh | d8bc708 | 2000-06-07 23:51:50 +0000 | [diff] [blame] | 785 | int sqliteExprCompare(Expr*, Expr*); |
drh | cce7d17 | 2000-05-31 15:34:51 +0000 | [diff] [blame] | 786 | int sqliteFuncId(Token*); |
drh | 832508b | 2002-03-02 17:04:07 +0000 | [diff] [blame] | 787 | int sqliteExprResolveIds(Parse*, int, IdList*, ExprList*, Expr*); |
drh | 2282792 | 2000-06-06 17:27:05 +0000 | [diff] [blame] | 788 | int sqliteExprAnalyzeAggregates(Parse*, Expr*); |
drh | d8bc708 | 2000-06-07 23:51:50 +0000 | [diff] [blame] | 789 | Vdbe *sqliteGetVdbe(Parse*); |
drh | b8ca307 | 2001-12-05 00:21:20 +0000 | [diff] [blame] | 790 | int sqliteRandomByte(void); |
| 791 | int sqliteRandomInteger(void); |
drh | 1c92853 | 2002-01-31 15:54:21 +0000 | [diff] [blame] | 792 | void sqliteBeginTransaction(Parse*, int); |
drh | c4a3c77 | 2001-04-04 11:48:57 +0000 | [diff] [blame] | 793 | void sqliteCommitTransaction(Parse*); |
| 794 | void sqliteRollbackTransaction(Parse*); |
drh | d1bf351 | 2001-04-07 15:24:33 +0000 | [diff] [blame] | 795 | char *sqlite_mprintf(const char *, ...); |
drh | 9208643 | 2002-01-22 14:11:29 +0000 | [diff] [blame] | 796 | int sqliteExprIsConstant(Expr*); |
drh | c8d30ac | 2002-04-12 10:08:59 +0000 | [diff] [blame] | 797 | void sqliteGenerateRowDelete(Vdbe*, Table*, int, int); |
drh | 0ca3e24 | 2002-01-29 23:07:02 +0000 | [diff] [blame] | 798 | void sqliteGenerateRowIndexDelete(Vdbe*, Table*, int, char*); |
| 799 | void sqliteGenerateConstraintChecks(Parse*,Table*,int,char*,int,int,int,int); |
drh | b419a92 | 2002-01-30 16:17:23 +0000 | [diff] [blame] | 800 | void sqliteCompleteInsertion(Parse*, Table*, int, char*, int, int); |
drh | c977f7f | 2002-05-21 11:38:11 +0000 | [diff] [blame] | 801 | void sqliteBeginWriteOperation(Parse*, int); |
drh | 1c92853 | 2002-01-31 15:54:21 +0000 | [diff] [blame] | 802 | void sqliteEndWriteOperation(Parse*); |
drh | a76b5df | 2002-02-23 02:32:10 +0000 | [diff] [blame] | 803 | void sqliteExprMoveStrings(Expr*, int); |
| 804 | void sqliteExprListMoveStrings(ExprList*, int); |
| 805 | void sqliteSelectMoveStrings(Select*, int); |
drh | ff78bd2 | 2002-02-27 01:47:11 +0000 | [diff] [blame] | 806 | Expr *sqliteExprDup(Expr*); |
| 807 | ExprList *sqliteExprListDup(ExprList*); |
| 808 | IdList *sqliteIdListDup(IdList*); |
| 809 | Select *sqliteSelectDup(Select*); |
drh | 0bce835 | 2002-02-28 00:41:10 +0000 | [diff] [blame] | 810 | FuncDef *sqliteFindFunction(sqlite*,const char*,int,int,int); |
drh | dc04c58 | 2002-02-24 01:55:15 +0000 | [diff] [blame] | 811 | void sqliteRegisterBuildinFunctions(sqlite*); |
drh | 247be43 | 2002-05-10 05:44:55 +0000 | [diff] [blame] | 812 | int sqliteSafetyOn(sqlite*); |
| 813 | int sqliteSafetyOff(sqlite*); |
drh | c22bd47 | 2002-05-10 13:14:07 +0000 | [diff] [blame] | 814 | int sqliteSafetyCheck(sqlite*); |
drh | dc37945 | 2002-05-15 12:45:43 +0000 | [diff] [blame] | 815 | void sqliteChangeCookie(sqlite *); |
| 816 | void sqliteCreateTrigger(Parse*, Token*, int, int, IdList*, Token*, |
| 817 | int, Expr*, TriggerStep*, char const*,int); |
| 818 | void sqliteDropTrigger(Parse*, Token*, int); |
| 819 | int sqliteTriggersExist(Parse* , Trigger* , int , int , int, ExprList*); |
| 820 | int sqliteCodeRowTrigger(Parse*, int, ExprList*, int, Table *, int, int, int); |
| 821 | void sqliteViewTriggers(Parse*, Table*, Expr*, int, ExprList*); |
| 822 | TriggerStep *sqliteTriggerSelectStep(Select*); |
| 823 | TriggerStep *sqliteTriggerInsertStep(Token*, IdList*, ExprList*, Select*, int); |
| 824 | TriggerStep *sqliteTriggerUpdateStep(Token*, ExprList*, Expr*, int); |
| 825 | TriggerStep *sqliteTriggerDeleteStep(Token*, Expr*); |
drh | 1d1f305 | 2002-05-21 13:18:25 +0000 | [diff] [blame^] | 826 | void sqliteDeleteTrigger(Trigger*); |