blob: 1280e9055926df32aee39e36fe5d4315f6220db9 [file] [log] [blame]
drhd0e4a6c2005-02-15 20:47:57 +00001/*
2** 2005 February 15
3**
4** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
6**
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.
10**
11*************************************************************************
12** This file contains C code routines that used to generate VDBE code
13** that implements the ALTER TABLE command.
drhd0e4a6c2005-02-15 20:47:57 +000014*/
15#include "sqliteInt.h"
16
drh1f01ec12005-02-15 21:36:18 +000017/*
18** The code in this file only exists if we are not omitting the
19** ALTER TABLE logic from the build.
20*/
drhd0e4a6c2005-02-15 20:47:57 +000021#ifndef SQLITE_OMIT_ALTERTABLE
drh1f01ec12005-02-15 21:36:18 +000022
drh1f01ec12005-02-15 21:36:18 +000023/*
danbe535002011-04-01 15:15:58 +000024** Parameter zName is the name of a table that is about to be altered
25** (either with ALTER TABLE ... RENAME TO or ALTER TABLE ... ADD COLUMN).
26** If the table is a system table, this function leaves an error message
27** in pParse->zErr (system tables may not be altered) and returns non-zero.
28**
29** Or, if zName is not a system table, zero is returned.
30*/
31static int isSystemTable(Parse *pParse, const char *zName){
drh59a386e2017-06-28 01:12:53 +000032 if( 0==sqlite3StrNICmp(zName, "sqlite_", 7) ){
danbe535002011-04-01 15:15:58 +000033 sqlite3ErrorMsg(pParse, "table %s may not be altered", zName);
34 return 1;
35 }
36 return 0;
37}
38
dan09236502018-09-01 16:05:50 +000039/*
40** Generate code to verify that the schemas of database zDb and, if
41** bTemp is not true, database "temp", can still be parsed. This is
42** called at the end of the generation of an ALTER TABLE ... RENAME ...
43** statement to ensure that the operation has not rendered any schema
44** objects unusable.
45*/
drh16b870d2018-09-12 15:51:56 +000046static void renameTestSchema(Parse *pParse, const char *zDb, int bTemp){
dan9d324822018-08-30 20:03:44 +000047 sqlite3NestedParse(pParse,
48 "SELECT 1 "
49 "FROM \"%w\".%s "
50 "WHERE name NOT LIKE 'sqlite_%%'"
51 " AND sql NOT LIKE 'create virtual%%'"
dan1d85c6b2018-09-06 16:01:37 +000052 " AND sqlite_rename_test(%Q, sql, type, name, %d)=NULL ",
dan9d324822018-08-30 20:03:44 +000053 zDb, MASTER_NAME,
54 zDb, bTemp
55 );
56
57 if( bTemp==0 ){
58 sqlite3NestedParse(pParse,
59 "SELECT 1 "
60 "FROM temp.%s "
61 "WHERE name NOT LIKE 'sqlite_%%'"
62 " AND sql NOT LIKE 'create virtual%%'"
dan1d85c6b2018-09-06 16:01:37 +000063 " AND sqlite_rename_test(%Q, sql, type, name, 1)=NULL ",
dan9d324822018-08-30 20:03:44 +000064 MASTER_NAME, zDb
65 );
66 }
67}
68
danbe535002011-04-01 15:15:58 +000069/*
dan09236502018-09-01 16:05:50 +000070** Generate code to reload the schema for database iDb. And, if iDb!=1, for
71** the temp database as well.
72*/
drh16b870d2018-09-12 15:51:56 +000073static void renameReloadSchema(Parse *pParse, int iDb){
dan09236502018-09-01 16:05:50 +000074 Vdbe *v = pParse->pVdbe;
75 if( v ){
76 sqlite3ChangeCookie(pParse, iDb);
77 sqlite3VdbeAddParseSchemaOp(pParse->pVdbe, iDb, 0);
78 if( iDb!=1 ) sqlite3VdbeAddParseSchemaOp(pParse->pVdbe, 1, 0);
79 }
80}
81
82/*
drhd0e4a6c2005-02-15 20:47:57 +000083** Generate code to implement the "ALTER TABLE xxx RENAME TO yyy"
84** command.
85*/
86void sqlite3AlterRenameTable(
87 Parse *pParse, /* Parser context. */
88 SrcList *pSrc, /* The table to rename. */
89 Token *pName /* The new table name. */
90){
91 int iDb; /* Database that contains the table */
92 char *zDb; /* Name of database iDb */
93 Table *pTab; /* Table being renamed */
94 char *zName = 0; /* NULL-terminated version of pName */
drhd0e4a6c2005-02-15 20:47:57 +000095 sqlite3 *db = pParse->db; /* Database connection */
drh4e5dd852007-05-15 03:56:49 +000096 int nTabName; /* Number of UTF-8 characters in zTabName */
97 const char *zTabName; /* Original name of the table */
drhd0e4a6c2005-02-15 20:47:57 +000098 Vdbe *v;
danielk1977595a5232009-07-24 17:58:53 +000099 VTable *pVTab = 0; /* Non-zero if this is a v-tab with an xRename() */
drh8257aa82017-07-26 19:59:13 +0000100 u32 savedDbFlags; /* Saved value of db->mDbFlags */
drh545f5872010-04-24 14:02:59 +0000101
drh8257aa82017-07-26 19:59:13 +0000102 savedDbFlags = db->mDbFlags;
drh56d56f72009-04-16 16:30:17 +0000103 if( NEVER(db->mallocFailed) ) goto exit_rename_table;
drhd0e4a6c2005-02-15 20:47:57 +0000104 assert( pSrc->nSrc==1 );
drh1fee73e2007-08-29 04:00:57 +0000105 assert( sqlite3BtreeHoldsAllMutexes(pParse->db) );
drhd0e4a6c2005-02-15 20:47:57 +0000106
dan41fb5cd2012-10-04 19:33:00 +0000107 pTab = sqlite3LocateTableItem(pParse, 0, &pSrc->a[0]);
drhd0e4a6c2005-02-15 20:47:57 +0000108 if( !pTab ) goto exit_rename_table;
danielk1977da184232006-01-05 11:34:32 +0000109 iDb = sqlite3SchemaToIndex(pParse->db, pTab->pSchema);
drh69c33822016-08-18 14:33:11 +0000110 zDb = db->aDb[iDb].zDbSName;
drh8257aa82017-07-26 19:59:13 +0000111 db->mDbFlags |= DBFLAG_PreferBuiltin;
drhd0e4a6c2005-02-15 20:47:57 +0000112
113 /* Get a NULL terminated version of the new table name. */
drh17435752007-08-16 04:30:38 +0000114 zName = sqlite3NameFromToken(db, pName);
drhd0e4a6c2005-02-15 20:47:57 +0000115 if( !zName ) goto exit_rename_table;
116
117 /* Check that a table or index named 'zName' does not already exist
118 ** in database iDb. If so, this is an error.
119 */
120 if( sqlite3FindTable(db, zName, zDb) || sqlite3FindIndex(db, zName, zDb) ){
121 sqlite3ErrorMsg(pParse,
122 "there is already another table or index with this name: %s", zName);
123 goto exit_rename_table;
124 }
125
126 /* Make sure it is not a system table being altered, or a reserved name
127 ** that the table is being renamed to.
128 */
danbe535002011-04-01 15:15:58 +0000129 if( SQLITE_OK!=isSystemTable(pParse, pTab->zName) ){
drhd0e4a6c2005-02-15 20:47:57 +0000130 goto exit_rename_table;
131 }
danbe535002011-04-01 15:15:58 +0000132 if( SQLITE_OK!=sqlite3CheckObjectName(pParse, zName) ){ goto
133 exit_rename_table;
drhd0e4a6c2005-02-15 20:47:57 +0000134 }
135
danielk197761116ae2007-12-13 08:15:30 +0000136#ifndef SQLITE_OMIT_VIEW
137 if( pTab->pSelect ){
138 sqlite3ErrorMsg(pParse, "view %s may not be altered", pTab->zName);
139 goto exit_rename_table;
140 }
141#endif
142
drhd0e4a6c2005-02-15 20:47:57 +0000143#ifndef SQLITE_OMIT_AUTHORIZATION
144 /* Invoke the authorization callback. */
145 if( sqlite3AuthCheck(pParse, SQLITE_ALTER_TABLE, zDb, pTab->zName, 0) ){
146 goto exit_rename_table;
147 }
148#endif
149
danielk1977182c4ba2007-06-27 15:53:34 +0000150#ifndef SQLITE_OMIT_VIRTUALTABLE
danielk19775c558862007-06-27 17:09:24 +0000151 if( sqlite3ViewGetColumnNames(pParse, pTab) ){
152 goto exit_rename_table;
153 }
danielk1977595a5232009-07-24 17:58:53 +0000154 if( IsVirtual(pTab) ){
155 pVTab = sqlite3GetVTable(db, pTab);
156 if( pVTab->pVtab->pModule->xRename==0 ){
157 pVTab = 0;
158 }
danielk1977182c4ba2007-06-27 15:53:34 +0000159 }
160#endif
161
drhb22f7c82014-02-06 23:56:27 +0000162 /* Begin a transaction for database iDb.
drhd0e4a6c2005-02-15 20:47:57 +0000163 ** Then modify the schema cookie (since the ALTER TABLE modifies the
danielk1977182c4ba2007-06-27 15:53:34 +0000164 ** schema). Open a statement transaction if the table is a virtual
165 ** table.
drhd0e4a6c2005-02-15 20:47:57 +0000166 */
167 v = sqlite3GetVdbe(pParse);
168 if( v==0 ){
169 goto exit_rename_table;
170 }
drhd0e4a6c2005-02-15 20:47:57 +0000171
drh4e5dd852007-05-15 03:56:49 +0000172 /* figure out how many UTF-8 characters are in zName */
173 zTabName = pTab->zName;
drh9a087a92007-05-15 14:34:32 +0000174 nTabName = sqlite3Utf8CharLen(zTabName, -1);
drh4e5dd852007-05-15 03:56:49 +0000175
danc9461ec2018-08-29 21:00:16 +0000176 /* Rewrite all CREATE TABLE, INDEX, TRIGGER or VIEW statements in
177 ** the schema to use the new table name. */
178 sqlite3NestedParse(pParse,
179 "UPDATE \"%w\".%s SET "
dan65372fa2018-09-03 20:05:15 +0000180 "sql = sqlite_rename_table(%Q, type, name, sql, %Q, %Q, %d) "
danc9461ec2018-08-29 21:00:16 +0000181 "WHERE (type!='index' OR tbl_name=%Q COLLATE nocase)"
182 "AND name NOT LIKE 'sqlite_%%'"
dan0ccda962018-08-30 16:26:48 +0000183 , zDb, MASTER_NAME, zDb, zTabName, zName, (iDb==1), zTabName
danc9461ec2018-08-29 21:00:16 +0000184 );
dan432cc5b2009-09-26 17:51:48 +0000185
danc9461ec2018-08-29 21:00:16 +0000186 /* Update the tbl_name and name columns of the sqlite_master table
187 ** as required. */
drhd0e4a6c2005-02-15 20:47:57 +0000188 sqlite3NestedParse(pParse,
189 "UPDATE %Q.%s SET "
drhd0e4a6c2005-02-15 20:47:57 +0000190 "tbl_name = %Q, "
191 "name = CASE "
192 "WHEN type='table' THEN %Q "
193 "WHEN name LIKE 'sqlite_autoindex%%' AND type='index' THEN "
drha21a9292007-10-20 20:58:57 +0000194 "'sqlite_autoindex_' || %Q || substr(name,%d+18) "
drhd0e4a6c2005-02-15 20:47:57 +0000195 "ELSE name END "
drh01522682012-02-01 01:13:10 +0000196 "WHERE tbl_name=%Q COLLATE nocase AND "
drhd0e4a6c2005-02-15 20:47:57 +0000197 "(type='table' OR type='index' OR type='trigger');",
danc9461ec2018-08-29 21:00:16 +0000198 zDb, MASTER_NAME,
199 zName, zName, zName,
200 nTabName, zTabName
drhd0e4a6c2005-02-15 20:47:57 +0000201 );
202
203#ifndef SQLITE_OMIT_AUTOINCREMENT
204 /* If the sqlite_sequence table exists in this database, then update
205 ** it with the new table name.
206 */
207 if( sqlite3FindTable(db, "sqlite_sequence", zDb) ){
208 sqlite3NestedParse(pParse,
drh8e5b5f82008-02-09 14:30:29 +0000209 "UPDATE \"%w\".sqlite_sequence set name = %Q WHERE name = %Q",
drhd0e4a6c2005-02-15 20:47:57 +0000210 zDb, zName, pTab->zName);
211 }
212#endif
213
danc9461ec2018-08-29 21:00:16 +0000214 /* If the table being renamed is not itself part of the temp database,
215 ** edit view and trigger definitions within the temp database
216 ** as required. */
217 if( iDb!=1 ){
danielk197719a8e7e2005-03-17 05:03:38 +0000218 sqlite3NestedParse(pParse,
219 "UPDATE sqlite_temp_master SET "
dan65372fa2018-09-03 20:05:15 +0000220 "sql = sqlite_rename_table(%Q, type, name, sql, %Q, %Q, 1), "
danc9461ec2018-08-29 21:00:16 +0000221 "tbl_name = "
dan1d85c6b2018-09-06 16:01:37 +0000222 "CASE WHEN tbl_name=%Q COLLATE nocase AND "
223 " sqlite_rename_test(%Q, sql, type, name, 1) "
224 "THEN %Q ELSE tbl_name END "
danc9461ec2018-08-29 21:00:16 +0000225 "WHERE type IN ('view', 'trigger')"
dan1d85c6b2018-09-06 16:01:37 +0000226 , zDb, zTabName, zName, zTabName, zDb, zName);
drhd0e4a6c2005-02-15 20:47:57 +0000227 }
drhd0e4a6c2005-02-15 20:47:57 +0000228
dan34566c42018-09-20 17:21:21 +0000229 /* If this is a virtual table, invoke the xRename() function if
230 ** one is defined. The xRename() callback will modify the names
231 ** of any resources used by the v-table implementation (including other
232 ** SQLite tables) that are identified by the name of the virtual table.
233 */
234#ifndef SQLITE_OMIT_VIRTUALTABLE
235 if( pVTab ){
236 int i = ++pParse->nMem;
237 sqlite3VdbeLoadString(v, i, zName);
238 sqlite3VdbeAddOp4(v, OP_VRename, i, 0, 0,(const char*)pVTab, P4_VTAB);
239 sqlite3MayAbort(pParse);
240 }
241#endif
242
dan09236502018-09-01 16:05:50 +0000243 renameReloadSchema(pParse, iDb);
dan9d324822018-08-30 20:03:44 +0000244 renameTestSchema(pParse, zDb, iDb==1);
245
drhd0e4a6c2005-02-15 20:47:57 +0000246exit_rename_table:
drh633e6d52008-07-28 19:34:53 +0000247 sqlite3SrcListDelete(db, pSrc);
248 sqlite3DbFree(db, zName);
drh8257aa82017-07-26 19:59:13 +0000249 db->mDbFlags = savedDbFlags;
drhd0e4a6c2005-02-15 20:47:57 +0000250}
danielk197719a8e7e2005-03-17 05:03:38 +0000251
drhd3001712009-05-12 17:46:53 +0000252/*
danielk197719a8e7e2005-03-17 05:03:38 +0000253** This function is called after an "ALTER TABLE ... ADD" statement
254** has been parsed. Argument pColDef contains the text of the new
255** column definition.
256**
257** The Table structure pParse->pNewTable was extended to include
258** the new column during parsing.
259*/
260void sqlite3AlterFinishAddColumn(Parse *pParse, Token *pColDef){
261 Table *pNew; /* Copy of pParse->pNewTable */
262 Table *pTab; /* Table being altered */
263 int iDb; /* Database number */
264 const char *zDb; /* Database name */
265 const char *zTab; /* Table name */
266 char *zCol; /* Null-terminated column definition */
267 Column *pCol; /* The new column */
268 Expr *pDflt; /* Default value for the new column */
drh17435752007-08-16 04:30:38 +0000269 sqlite3 *db; /* The database connection; */
dan09236502018-09-01 16:05:50 +0000270 Vdbe *v; /* The prepared statement under construction */
drh86396212016-07-14 19:13:11 +0000271 int r1; /* Temporary registers */
danielk197719a8e7e2005-03-17 05:03:38 +0000272
danielk1977f150c9d2008-10-30 17:21:12 +0000273 db = pParse->db;
274 if( pParse->nErr || db->mallocFailed ) return;
danielk197719a8e7e2005-03-17 05:03:38 +0000275 pNew = pParse->pNewTable;
276 assert( pNew );
277
drh1fee73e2007-08-29 04:00:57 +0000278 assert( sqlite3BtreeHoldsAllMutexes(db) );
drh17435752007-08-16 04:30:38 +0000279 iDb = sqlite3SchemaToIndex(db, pNew->pSchema);
drh69c33822016-08-18 14:33:11 +0000280 zDb = db->aDb[iDb].zDbSName;
drh03881232009-02-13 03:43:31 +0000281 zTab = &pNew->zName[16]; /* Skip the "sqlite_altertab_" prefix on the name */
danielk197719a8e7e2005-03-17 05:03:38 +0000282 pCol = &pNew->aCol[pNew->nCol-1];
283 pDflt = pCol->pDflt;
drh17435752007-08-16 04:30:38 +0000284 pTab = sqlite3FindTable(db, zTab, zDb);
danielk197719a8e7e2005-03-17 05:03:38 +0000285 assert( pTab );
286
drh81f2ccd2006-01-31 14:28:44 +0000287#ifndef SQLITE_OMIT_AUTHORIZATION
288 /* Invoke the authorization callback. */
289 if( sqlite3AuthCheck(pParse, SQLITE_ALTER_TABLE, zDb, pTab->zName, 0) ){
290 return;
291 }
292#endif
293
danielk197719a8e7e2005-03-17 05:03:38 +0000294 /* If the default value for the new column was specified with a
295 ** literal NULL, then set pDflt to 0. This simplifies checking
296 ** for an SQL NULL default below.
297 */
drh94fa9c42016-02-27 21:16:04 +0000298 assert( pDflt==0 || pDflt->op==TK_SPAN );
299 if( pDflt && pDflt->pLeft->op==TK_NULL ){
danielk197719a8e7e2005-03-17 05:03:38 +0000300 pDflt = 0;
301 }
302
303 /* Check that the new column is not specified as PRIMARY KEY or UNIQUE.
304 ** If there is a NOT NULL constraint, then the default value for the
305 ** column must not be NULL.
306 */
drha371ace2012-09-13 14:22:47 +0000307 if( pCol->colFlags & COLFLAG_PRIMKEY ){
danielk197719a8e7e2005-03-17 05:03:38 +0000308 sqlite3ErrorMsg(pParse, "Cannot add a PRIMARY KEY column");
309 return;
310 }
311 if( pNew->pIndex ){
312 sqlite3ErrorMsg(pParse, "Cannot add a UNIQUE column");
313 return;
314 }
dan53c3fa82009-09-25 11:26:54 +0000315 if( (db->flags&SQLITE_ForeignKeys) && pNew->pFKey && pDflt ){
316 sqlite3ErrorMsg(pParse,
317 "Cannot add a REFERENCES column with non-NULL default value");
318 return;
319 }
danielk197719a8e7e2005-03-17 05:03:38 +0000320 if( pCol->notNull && !pDflt ){
321 sqlite3ErrorMsg(pParse,
322 "Cannot add a NOT NULL column with default value NULL");
323 return;
324 }
325
326 /* Ensure the default expression is something that sqlite3ValueFromExpr()
327 ** can handle (i.e. not CURRENT_TIME etc.)
328 */
329 if( pDflt ){
dan7a419232013-08-06 20:01:43 +0000330 sqlite3_value *pVal = 0;
drh96f4ad22015-03-12 21:02:36 +0000331 int rc;
drh05883a32015-06-02 15:32:08 +0000332 rc = sqlite3ValueFromExpr(db, pDflt, SQLITE_UTF8, SQLITE_AFF_BLOB, &pVal);
drh96f4ad22015-03-12 21:02:36 +0000333 assert( rc==SQLITE_OK || rc==SQLITE_NOMEM );
334 if( rc!=SQLITE_OK ){
pdrbb3da062016-02-06 14:14:43 +0000335 assert( db->mallocFailed == 1 );
danielk197719a8e7e2005-03-17 05:03:38 +0000336 return;
337 }
338 if( !pVal ){
339 sqlite3ErrorMsg(pParse, "Cannot add a column with non-constant default");
340 return;
341 }
342 sqlite3ValueFree(pVal);
343 }
344
345 /* Modify the CREATE TABLE statement. */
drh17435752007-08-16 04:30:38 +0000346 zCol = sqlite3DbStrNDup(db, (char*)pColDef->z, pColDef->n);
danielk197719a8e7e2005-03-17 05:03:38 +0000347 if( zCol ){
348 char *zEnd = &zCol[pColDef->n-1];
drh8257aa82017-07-26 19:59:13 +0000349 u32 savedDbFlags = db->mDbFlags;
drh56d56f72009-04-16 16:30:17 +0000350 while( zEnd>zCol && (*zEnd==';' || sqlite3Isspace(*zEnd)) ){
danielk197719a8e7e2005-03-17 05:03:38 +0000351 *zEnd-- = '\0';
352 }
drh8257aa82017-07-26 19:59:13 +0000353 db->mDbFlags |= DBFLAG_PreferBuiltin;
danielk197719a8e7e2005-03-17 05:03:38 +0000354 sqlite3NestedParse(pParse,
drh8e5b5f82008-02-09 14:30:29 +0000355 "UPDATE \"%w\".%s SET "
drha21a9292007-10-20 20:58:57 +0000356 "sql = substr(sql,1,%d) || ', ' || %Q || substr(sql,%d) "
danielk197719a8e7e2005-03-17 05:03:38 +0000357 "WHERE type = 'table' AND name = %Q",
drhe0a04a32016-12-16 01:00:21 +0000358 zDb, MASTER_NAME, pNew->addColOffset, zCol, pNew->addColOffset+1,
danielk197719a8e7e2005-03-17 05:03:38 +0000359 zTab
360 );
drh633e6d52008-07-28 19:34:53 +0000361 sqlite3DbFree(db, zCol);
drh8257aa82017-07-26 19:59:13 +0000362 db->mDbFlags = savedDbFlags;
danielk197719a8e7e2005-03-17 05:03:38 +0000363 }
364
drh86396212016-07-14 19:13:11 +0000365 /* Make sure the schema version is at least 3. But do not upgrade
366 ** from less than 3 to 4, as that will corrupt any preexisting DESC
367 ** index.
danielk197719a8e7e2005-03-17 05:03:38 +0000368 */
dan09236502018-09-01 16:05:50 +0000369 v = sqlite3GetVdbe(pParse);
370 if( v ){
371 r1 = sqlite3GetTempReg(pParse);
372 sqlite3VdbeAddOp3(v, OP_ReadCookie, iDb, r1, BTREE_FILE_FORMAT);
373 sqlite3VdbeUsesBtree(v, iDb);
374 sqlite3VdbeAddOp2(v, OP_AddImm, r1, -2);
375 sqlite3VdbeAddOp2(v, OP_IfPos, r1, sqlite3VdbeCurrentAddr(v)+2);
376 VdbeCoverage(v);
377 sqlite3VdbeAddOp3(v, OP_SetCookie, iDb, BTREE_FILE_FORMAT, 3);
378 sqlite3ReleaseTempReg(pParse, r1);
379 }
danielk197719a8e7e2005-03-17 05:03:38 +0000380
dan09236502018-09-01 16:05:50 +0000381 /* Reload the table definition */
382 renameReloadSchema(pParse, iDb);
danielk197719a8e7e2005-03-17 05:03:38 +0000383}
384
drhfdd6e852005-12-16 01:06:16 +0000385/*
danielk197719a8e7e2005-03-17 05:03:38 +0000386** This function is called by the parser after the table-name in
387** an "ALTER TABLE <table-name> ADD" statement is parsed. Argument
388** pSrc is the full-name of the table being altered.
389**
390** This routine makes a (partial) copy of the Table structure
391** for the table being altered and sets Parse.pNewTable to point
392** to it. Routines called by the parser as the column definition
393** is parsed (i.e. sqlite3AddColumn()) add the new Column data to
394** the copy. The copy of the Table structure is deleted by tokenize.c
395** after parsing is finished.
396**
397** Routine sqlite3AlterFinishAddColumn() will be called to complete
398** coding the "ALTER TABLE ... ADD" statement.
399*/
400void sqlite3AlterBeginAddColumn(Parse *pParse, SrcList *pSrc){
401 Table *pNew;
402 Table *pTab;
danielk197719a8e7e2005-03-17 05:03:38 +0000403 int iDb;
404 int i;
405 int nAlloc;
drh17435752007-08-16 04:30:38 +0000406 sqlite3 *db = pParse->db;
danielk197719a8e7e2005-03-17 05:03:38 +0000407
408 /* Look up the table being altered. */
drh0bbaa1b2005-08-19 19:14:12 +0000409 assert( pParse->pNewTable==0 );
drh1fee73e2007-08-29 04:00:57 +0000410 assert( sqlite3BtreeHoldsAllMutexes(db) );
drh17435752007-08-16 04:30:38 +0000411 if( db->mallocFailed ) goto exit_begin_add_column;
dan41fb5cd2012-10-04 19:33:00 +0000412 pTab = sqlite3LocateTableItem(pParse, 0, &pSrc->a[0]);
danielk197719a8e7e2005-03-17 05:03:38 +0000413 if( !pTab ) goto exit_begin_add_column;
414
danielk19775ee9d692006-06-21 12:36:25 +0000415#ifndef SQLITE_OMIT_VIRTUALTABLE
416 if( IsVirtual(pTab) ){
417 sqlite3ErrorMsg(pParse, "virtual tables may not be altered");
418 goto exit_begin_add_column;
419 }
420#endif
421
danielk197719a8e7e2005-03-17 05:03:38 +0000422 /* Make sure this is not an attempt to ALTER a view. */
423 if( pTab->pSelect ){
424 sqlite3ErrorMsg(pParse, "Cannot add a column to a view");
425 goto exit_begin_add_column;
426 }
danbe535002011-04-01 15:15:58 +0000427 if( SQLITE_OK!=isSystemTable(pParse, pTab->zName) ){
428 goto exit_begin_add_column;
429 }
danielk197719a8e7e2005-03-17 05:03:38 +0000430
431 assert( pTab->addColOffset>0 );
drh17435752007-08-16 04:30:38 +0000432 iDb = sqlite3SchemaToIndex(db, pTab->pSchema);
danielk197719a8e7e2005-03-17 05:03:38 +0000433
434 /* Put a copy of the Table struct in Parse.pNewTable for the
drh03881232009-02-13 03:43:31 +0000435 ** sqlite3AddColumn() function and friends to modify. But modify
436 ** the name by adding an "sqlite_altertab_" prefix. By adding this
437 ** prefix, we insure that the name will not collide with an existing
438 ** table because user table are not allowed to have the "sqlite_"
439 ** prefix on their name.
danielk197719a8e7e2005-03-17 05:03:38 +0000440 */
drh17435752007-08-16 04:30:38 +0000441 pNew = (Table*)sqlite3DbMallocZero(db, sizeof(Table));
danielk197719a8e7e2005-03-17 05:03:38 +0000442 if( !pNew ) goto exit_begin_add_column;
443 pParse->pNewTable = pNew;
drh79df7782016-12-14 14:07:35 +0000444 pNew->nTabRef = 1;
danielk197719a8e7e2005-03-17 05:03:38 +0000445 pNew->nCol = pTab->nCol;
danielk1977b3a2cce2005-03-27 01:56:30 +0000446 assert( pNew->nCol>0 );
447 nAlloc = (((pNew->nCol-1)/8)*8)+8;
448 assert( nAlloc>=pNew->nCol && nAlloc%8==0 && nAlloc-pNew->nCol<8 );
danielk197726783a52007-08-29 14:06:22 +0000449 pNew->aCol = (Column*)sqlite3DbMallocZero(db, sizeof(Column)*nAlloc);
drh03881232009-02-13 03:43:31 +0000450 pNew->zName = sqlite3MPrintf(db, "sqlite_altertab_%s", pTab->zName);
danielk197719a8e7e2005-03-17 05:03:38 +0000451 if( !pNew->aCol || !pNew->zName ){
drh4df86af2016-02-04 11:48:00 +0000452 assert( db->mallocFailed );
danielk197719a8e7e2005-03-17 05:03:38 +0000453 goto exit_begin_add_column;
454 }
455 memcpy(pNew->aCol, pTab->aCol, sizeof(Column)*pNew->nCol);
456 for(i=0; i<pNew->nCol; i++){
457 Column *pCol = &pNew->aCol[i];
drh17435752007-08-16 04:30:38 +0000458 pCol->zName = sqlite3DbStrDup(db, pCol->zName);
drhff22e182006-02-09 02:56:02 +0000459 pCol->zColl = 0;
danielk197719a8e7e2005-03-17 05:03:38 +0000460 pCol->pDflt = 0;
461 }
drh17435752007-08-16 04:30:38 +0000462 pNew->pSchema = db->aDb[iDb].pSchema;
danielk197719a8e7e2005-03-17 05:03:38 +0000463 pNew->addColOffset = pTab->addColOffset;
drh79df7782016-12-14 14:07:35 +0000464 pNew->nTabRef = 1;
danielk197719a8e7e2005-03-17 05:03:38 +0000465
danielk197719a8e7e2005-03-17 05:03:38 +0000466exit_begin_add_column:
drh633e6d52008-07-28 19:34:53 +0000467 sqlite3SrcListDelete(db, pSrc);
danielk197719a8e7e2005-03-17 05:03:38 +0000468 return;
469}
dancf8f2892018-08-09 20:47:01 +0000470
drh4a2c7472018-08-13 15:09:48 +0000471/*
dan9d705572018-08-20 16:16:05 +0000472** Parameter pTab is the subject of an ALTER TABLE ... RENAME COLUMN
473** command. This function checks if the table is a view or virtual
474** table (columns of views or virtual tables may not be renamed). If so,
475** it loads an error message into pParse and returns non-zero.
476**
477** Or, if pTab is not a view or virtual table, zero is returned.
478*/
479#if !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_VIRTUALTABLE)
480static int isRealTable(Parse *pParse, Table *pTab){
481 const char *zType = 0;
482#ifndef SQLITE_OMIT_VIEW
483 if( pTab->pSelect ){
484 zType = "view";
dan1041a6a2018-09-06 17:47:09 +0000485 }
dan9d705572018-08-20 16:16:05 +0000486#endif
487#ifndef SQLITE_OMIT_VIRTUALTABLE
488 if( IsVirtual(pTab) ){
489 zType = "virtual table";
490 }
491#endif
492 if( zType ){
493 sqlite3ErrorMsg(
drh79a5ee92018-08-23 19:32:04 +0000494 pParse, "cannot rename columns of %s \"%s\"", zType, pTab->zName
dan9d705572018-08-20 16:16:05 +0000495 );
496 return 1;
497 }
498 return 0;
499}
500#else /* !defined(SQLITE_OMIT_VIEW) || !defined(SQLITE_OMIT_VIRTUALTABLE) */
501# define isRealTable(x,y) (0)
502#endif
503
504/*
drh4a2c7472018-08-13 15:09:48 +0000505** Handles the following parser reduction:
506**
507** cmd ::= ALTER TABLE pSrc RENAME COLUMN pOld TO pNew
508*/
dancf8f2892018-08-09 20:47:01 +0000509void sqlite3AlterRenameColumn(
drh4a2c7472018-08-13 15:09:48 +0000510 Parse *pParse, /* Parsing context */
511 SrcList *pSrc, /* Table being altered. pSrc->nSrc==1 */
512 Token *pOld, /* Name of column being changed */
513 Token *pNew /* New column name */
dancf8f2892018-08-09 20:47:01 +0000514){
drh4a2c7472018-08-13 15:09:48 +0000515 sqlite3 *db = pParse->db; /* Database connection */
dancf8f2892018-08-09 20:47:01 +0000516 Table *pTab; /* Table being updated */
517 int iCol; /* Index of column being renamed */
drh4a2c7472018-08-13 15:09:48 +0000518 char *zOld = 0; /* Old column name */
519 char *zNew = 0; /* New column name */
520 const char *zDb; /* Name of schema containing the table */
521 int iSchema; /* Index of the schema */
522 int bQuote; /* True to quote the new name */
dancf8f2892018-08-09 20:47:01 +0000523
drh4a2c7472018-08-13 15:09:48 +0000524 /* Locate the table to be altered */
dancf8f2892018-08-09 20:47:01 +0000525 pTab = sqlite3LocateTableItem(pParse, 0, &pSrc->a[0]);
526 if( !pTab ) goto exit_rename_column;
drh4a2c7472018-08-13 15:09:48 +0000527
528 /* Cannot alter a system table */
dan872165f2018-08-11 17:34:38 +0000529 if( SQLITE_OK!=isSystemTable(pParse, pTab->zName) ) goto exit_rename_column;
dan9d705572018-08-20 16:16:05 +0000530 if( SQLITE_OK!=isRealTable(pParse, pTab) ) goto exit_rename_column;
drh4a2c7472018-08-13 15:09:48 +0000531
532 /* Which schema holds the table to be altered */
dancf8f2892018-08-09 20:47:01 +0000533 iSchema = sqlite3SchemaToIndex(db, pTab->pSchema);
534 assert( iSchema>=0 );
535 zDb = db->aDb[iSchema].zDbSName;
536
drh0d019b92018-08-25 16:14:46 +0000537#ifndef SQLITE_OMIT_AUTHORIZATION
538 /* Invoke the authorization callback. */
539 if( sqlite3AuthCheck(pParse, SQLITE_ALTER_TABLE, zDb, pTab->zName, 0) ){
540 goto exit_rename_column;
541 }
542#endif
543
drh4a2c7472018-08-13 15:09:48 +0000544 /* Make sure the old name really is a column name in the table to be
545 ** altered. Set iCol to be the index of the column being renamed */
dancf8f2892018-08-09 20:47:01 +0000546 zOld = sqlite3NameFromToken(db, pOld);
547 if( !zOld ) goto exit_rename_column;
548 for(iCol=0; iCol<pTab->nCol; iCol++){
549 if( 0==sqlite3StrICmp(pTab->aCol[iCol].zName, zOld) ) break;
550 }
551 if( iCol==pTab->nCol ){
552 sqlite3ErrorMsg(pParse, "no such column: \"%s\"", zOld);
553 goto exit_rename_column;
554 }
555
drh4a2c7472018-08-13 15:09:48 +0000556 /* Do the rename operation using a recursive UPDATE statement that
557 ** uses the sqlite_rename_column() SQL function to compute the new
558 ** CREATE statement text for the sqlite_master table.
559 */
dancf8f2892018-08-09 20:47:01 +0000560 zNew = sqlite3NameFromToken(db, pNew);
561 if( !zNew ) goto exit_rename_column;
dan404c3ba2018-08-11 20:38:33 +0000562 assert( pNew->n>0 );
563 bQuote = sqlite3Isquote(pNew->z[0]);
dancf8f2892018-08-09 20:47:01 +0000564 sqlite3NestedParse(pParse,
565 "UPDATE \"%w\".%s SET "
danb87a9a82018-09-01 20:23:28 +0000566 "sql = sqlite_rename_column(sql, type, name, %Q, %Q, %d, %Q, %d, %d) "
dan499b8252018-08-17 18:08:28 +0000567 "WHERE name NOT LIKE 'sqlite_%%' AND (type != 'index' OR tbl_name = %Q)"
568 " AND sql NOT LIKE 'create virtual%%'",
dan987db762018-08-14 20:18:50 +0000569 zDb, MASTER_NAME,
danb87a9a82018-09-01 20:23:28 +0000570 zDb, pTab->zName, iCol, zNew, bQuote, iSchema==1,
dan987db762018-08-14 20:18:50 +0000571 pTab->zName
dancf8f2892018-08-09 20:47:01 +0000572 );
573
dan9d324822018-08-30 20:03:44 +0000574 sqlite3NestedParse(pParse,
575 "UPDATE temp.%s SET "
danb87a9a82018-09-01 20:23:28 +0000576 "sql = sqlite_rename_column(sql, type, name, %Q, %Q, %d, %Q, %d, 1) "
dan9d324822018-08-30 20:03:44 +0000577 "WHERE type IN ('trigger', 'view')",
578 MASTER_NAME,
579 zDb, pTab->zName, iCol, zNew, bQuote
580 );
581
dane325ffe2018-08-11 13:40:20 +0000582 /* Drop and reload the database schema. */
dan09236502018-09-01 16:05:50 +0000583 renameReloadSchema(pParse, iSchema);
dan9d324822018-08-30 20:03:44 +0000584 renameTestSchema(pParse, zDb, iSchema==1);
dan0d5fa6b2018-08-24 17:55:49 +0000585
dancf8f2892018-08-09 20:47:01 +0000586 exit_rename_column:
587 sqlite3SrcListDelete(db, pSrc);
588 sqlite3DbFree(db, zOld);
589 sqlite3DbFree(db, zNew);
590 return;
591}
592
drh4a2c7472018-08-13 15:09:48 +0000593/*
594** Each RenameToken object maps an element of the parse tree into
595** the token that generated that element. The parse tree element
596** might be one of:
597**
598** * A pointer to an Expr that represents an ID
599** * The name of a table column in Column.zName
600**
601** A list of RenameToken objects can be constructed during parsing.
dan07e95232018-08-21 16:32:53 +0000602** Each new object is created by sqlite3RenameTokenMap().
603** As the parse tree is transformed, the sqlite3RenameTokenRemap()
drh4a2c7472018-08-13 15:09:48 +0000604** routine is used to keep the mapping current.
605**
606** After the parse finishes, renameTokenFind() routine can be used
607** to look up the actual token value that created some element in
608** the parse tree.
609*/
dancf8f2892018-08-09 20:47:01 +0000610struct RenameToken {
drh4a2c7472018-08-13 15:09:48 +0000611 void *p; /* Parse tree element created by token t */
612 Token t; /* The token that created parse tree element p */
613 RenameToken *pNext; /* Next is a list of all RenameToken objects */
dancf8f2892018-08-09 20:47:01 +0000614};
615
drh4a2c7472018-08-13 15:09:48 +0000616/*
617** The context of an ALTER TABLE RENAME COLUMN operation that gets passed
618** down into the Walker.
619*/
dan5496d6a2018-08-13 17:14:26 +0000620typedef struct RenameCtx RenameCtx;
dancf8f2892018-08-09 20:47:01 +0000621struct RenameCtx {
622 RenameToken *pList; /* List of tokens to overwrite */
623 int nList; /* Number of tokens in pList */
624 int iCol; /* Index of column being renamed */
dan987db762018-08-14 20:18:50 +0000625 Table *pTab; /* Table being ALTERed */
dan5496d6a2018-08-13 17:14:26 +0000626 const char *zOld; /* Old column name */
dancf8f2892018-08-09 20:47:01 +0000627};
628
dan8900a482018-09-05 14:36:05 +0000629#ifdef SQLITE_DEBUG
630/*
631** This function is only for debugging. It performs two tasks:
632**
633** 1. Checks that pointer pPtr does not already appear in the
634** rename-token list.
635**
636** 2. Dereferences each pointer in the rename-token list.
637**
638** The second is most effective when debugging under valgrind or
639** address-sanitizer or similar. If any of these pointers no longer
640** point to valid objects, an exception is raised by the memory-checking
641** tool.
642**
643** The point of this is to prevent comparisons of invalid pointer values.
644** Even though this always seems to work, it is undefined according to the
645** C standard. Example of undefined comparison:
646**
647** sqlite3_free(x);
648** if( x==y ) ...
649**
650** Technically, as x no longer points into a valid object or to the byte
651** following a valid object, it may not be used in comparison operations.
652*/
drh16b870d2018-09-12 15:51:56 +0000653static void renameTokenCheckAll(Parse *pParse, void *pPtr){
dan8900a482018-09-05 14:36:05 +0000654 if( pParse->nErr==0 && pParse->db->mallocFailed==0 ){
655 RenameToken *p;
656 u8 i = 0;
657 for(p=pParse->pRename; p; p=p->pNext){
658 if( p->p ){
659 assert( p->p!=pPtr );
660 i += *(u8*)(p->p);
661 }
danc9461ec2018-08-29 21:00:16 +0000662 }
663 }
664}
dan8900a482018-09-05 14:36:05 +0000665#else
666# define renameTokenCheckAll(x,y)
667#endif
danc9461ec2018-08-29 21:00:16 +0000668
drh4a2c7472018-08-13 15:09:48 +0000669/*
drh49b269e2018-11-26 15:00:25 +0000670** Remember that the parser tree element pPtr was created using
671** the token pToken.
dan07e95232018-08-21 16:32:53 +0000672**
drh49b269e2018-11-26 15:00:25 +0000673** In other words, construct a new RenameToken object and add it
674** to the list of RenameToken objects currently being built up
675** in pParse->pRename.
676**
677** The pPtr argument is returned so that this routine can be used
678** with tail recursion in tokenExpr() routine, for a small performance
679** improvement.
drh4a2c7472018-08-13 15:09:48 +0000680*/
dan07e95232018-08-21 16:32:53 +0000681void *sqlite3RenameTokenMap(Parse *pParse, void *pPtr, Token *pToken){
dancf8f2892018-08-09 20:47:01 +0000682 RenameToken *pNew;
danc9461ec2018-08-29 21:00:16 +0000683 assert( pPtr || pParse->db->mallocFailed );
dan8900a482018-09-05 14:36:05 +0000684 renameTokenCheckAll(pParse, pPtr);
dancf8f2892018-08-09 20:47:01 +0000685 pNew = sqlite3DbMallocZero(pParse->db, sizeof(RenameToken));
686 if( pNew ){
687 pNew->p = pPtr;
688 pNew->t = *pToken;
689 pNew->pNext = pParse->pRename;
690 pParse->pRename = pNew;
691 }
danc9461ec2018-08-29 21:00:16 +0000692
dand145e5f2018-08-21 08:29:48 +0000693 return pPtr;
dancf8f2892018-08-09 20:47:01 +0000694}
695
drh4a2c7472018-08-13 15:09:48 +0000696/*
dan07e95232018-08-21 16:32:53 +0000697** It is assumed that there is already a RenameToken object associated
698** with parse tree element pFrom. This function remaps the associated token
699** to parse tree element pTo.
drh4a2c7472018-08-13 15:09:48 +0000700*/
dan07e95232018-08-21 16:32:53 +0000701void sqlite3RenameTokenRemap(Parse *pParse, void *pTo, void *pFrom){
dancf8f2892018-08-09 20:47:01 +0000702 RenameToken *p;
dan8900a482018-09-05 14:36:05 +0000703 renameTokenCheckAll(pParse, pTo);
danc9461ec2018-08-29 21:00:16 +0000704 for(p=pParse->pRename; p; p=p->pNext){
dancf8f2892018-08-09 20:47:01 +0000705 if( p->p==pFrom ){
706 p->p = pTo;
707 break;
708 }
709 }
dancf8f2892018-08-09 20:47:01 +0000710}
711
drh4a2c7472018-08-13 15:09:48 +0000712/*
dan8900a482018-09-05 14:36:05 +0000713** Walker callback used by sqlite3RenameExprUnmap().
714*/
715static int renameUnmapExprCb(Walker *pWalker, Expr *pExpr){
716 Parse *pParse = pWalker->pParse;
717 sqlite3RenameTokenRemap(pParse, 0, (void*)pExpr);
718 return WRC_Continue;
719}
720
721/*
722** Remove all nodes that are part of expression pExpr from the rename list.
723*/
724void sqlite3RenameExprUnmap(Parse *pParse, Expr *pExpr){
725 Walker sWalker;
726 memset(&sWalker, 0, sizeof(Walker));
727 sWalker.pParse = pParse;
728 sWalker.xExprCallback = renameUnmapExprCb;
729 sqlite3WalkExpr(&sWalker, pExpr);
730}
731
732/*
dane8ab40d2018-09-12 08:51:48 +0000733** Remove all nodes that are part of expression-list pEList from the
734** rename list.
735*/
736void sqlite3RenameExprlistUnmap(Parse *pParse, ExprList *pEList){
737 if( pEList ){
738 int i;
739 Walker sWalker;
740 memset(&sWalker, 0, sizeof(Walker));
741 sWalker.pParse = pParse;
742 sWalker.xExprCallback = renameUnmapExprCb;
743 sqlite3WalkExprList(&sWalker, pEList);
744 for(i=0; i<pEList->nExpr; i++){
745 sqlite3RenameTokenRemap(pParse, 0, (void*)pEList->a[i].zName);
746 }
747 }
748}
749
750/*
drh4a2c7472018-08-13 15:09:48 +0000751** Free the list of RenameToken objects given in the second argument
752*/
dancf8f2892018-08-09 20:47:01 +0000753static void renameTokenFree(sqlite3 *db, RenameToken *pToken){
754 RenameToken *pNext;
755 RenameToken *p;
756 for(p=pToken; p; p=pNext){
757 pNext = p->pNext;
758 sqlite3DbFree(db, p);
759 }
760}
761
dan987db762018-08-14 20:18:50 +0000762/*
763** Search the Parse object passed as the first argument for a RenameToken
764** object associated with parse tree element pPtr. If found, remove it
765** from the Parse object and add it to the list maintained by the
766** RenameCtx object passed as the second argument.
767*/
768static void renameTokenFind(Parse *pParse, struct RenameCtx *pCtx, void *pPtr){
dancf8f2892018-08-09 20:47:01 +0000769 RenameToken **pp;
dan1b0c5de2018-08-24 16:04:26 +0000770 assert( pPtr!=0 );
dancf8f2892018-08-09 20:47:01 +0000771 for(pp=&pParse->pRename; (*pp); pp=&(*pp)->pNext){
772 if( (*pp)->p==pPtr ){
773 RenameToken *pToken = *pp;
774 *pp = pToken->pNext;
dan5496d6a2018-08-13 17:14:26 +0000775 pToken->pNext = pCtx->pList;
776 pCtx->pList = pToken;
777 pCtx->nList++;
778 break;
dancf8f2892018-08-09 20:47:01 +0000779 }
780 }
dancf8f2892018-08-09 20:47:01 +0000781}
782
dan24fedb92018-08-18 17:35:38 +0000783/*
784** This is a Walker select callback. It does nothing. It is only required
785** because without a dummy callback, sqlite3WalkExpr() and similar do not
786** descend into sub-select statements.
787*/
dan987db762018-08-14 20:18:50 +0000788static int renameColumnSelectCb(Walker *pWalker, Select *p){
drh38d99642018-08-18 18:27:18 +0000789 UNUSED_PARAMETER(pWalker);
790 UNUSED_PARAMETER(p);
dan987db762018-08-14 20:18:50 +0000791 return WRC_Continue;
792}
793
dan987db762018-08-14 20:18:50 +0000794/*
795** This is a Walker expression callback.
796**
797** For every TK_COLUMN node in the expression tree, search to see
798** if the column being references is the column being renamed by an
799** ALTER TABLE statement. If it is, then attach its associated
800** RenameToken object to the list of RenameToken objects being
801** constructed in RenameCtx object at pWalker->u.pRename.
802*/
dancf8f2892018-08-09 20:47:01 +0000803static int renameColumnExprCb(Walker *pWalker, Expr *pExpr){
dan5496d6a2018-08-13 17:14:26 +0000804 RenameCtx *p = pWalker->u.pRename;
dan0cbb0b12018-08-16 19:49:16 +0000805 if( pExpr->op==TK_TRIGGER
806 && pExpr->iColumn==p->iCol
807 && pWalker->pParse->pTriggerTab==p->pTab
808 ){
dan5be60c52018-08-15 20:28:39 +0000809 renameTokenFind(pWalker->pParse, p, (void*)pExpr);
dan0cbb0b12018-08-16 19:49:16 +0000810 }else if( pExpr->op==TK_COLUMN
811 && pExpr->iColumn==p->iCol
drheda079c2018-09-20 19:02:15 +0000812 && p->pTab==pExpr->y.pTab
dan987db762018-08-14 20:18:50 +0000813 ){
dan5496d6a2018-08-13 17:14:26 +0000814 renameTokenFind(pWalker->pParse, p, (void*)pExpr);
dancf8f2892018-08-09 20:47:01 +0000815 }
816 return WRC_Continue;
817}
818
dan987db762018-08-14 20:18:50 +0000819/*
820** The RenameCtx contains a list of tokens that reference a column that
dan24fedb92018-08-18 17:35:38 +0000821** is being renamed by an ALTER TABLE statement. Return the "last"
dan987db762018-08-14 20:18:50 +0000822** RenameToken in the RenameCtx and remove that RenameToken from the
dan24fedb92018-08-18 17:35:38 +0000823** RenameContext. "Last" means the last RenameToken encountered when
824** the input SQL is parsed from left to right. Repeated calls to this routine
dan987db762018-08-14 20:18:50 +0000825** return all column name tokens in the order that they are encountered
826** in the SQL statement.
827*/
dan5496d6a2018-08-13 17:14:26 +0000828static RenameToken *renameColumnTokenNext(RenameCtx *pCtx){
dancf8f2892018-08-09 20:47:01 +0000829 RenameToken *pBest = pCtx->pList;
830 RenameToken *pToken;
831 RenameToken **pp;
832
833 for(pToken=pBest->pNext; pToken; pToken=pToken->pNext){
834 if( pToken->t.z>pBest->t.z ) pBest = pToken;
835 }
836 for(pp=&pCtx->pList; *pp!=pBest; pp=&(*pp)->pNext);
837 *pp = pBest->pNext;
838
839 return pBest;
840}
841
dan6fe7f232018-08-10 19:19:33 +0000842/*
dan24fedb92018-08-18 17:35:38 +0000843** An error occured while parsing or otherwise processing a database
844** object (either pParse->pNewTable, pNewIndex or pNewTrigger) as part of an
845** ALTER TABLE RENAME COLUMN program. The error message emitted by the
846** sub-routine is currently stored in pParse->zErrMsg. This function
847** adds context to the error message and then stores it in pCtx.
848*/
danb0137382018-08-20 20:01:01 +0000849static void renameColumnParseError(
850 sqlite3_context *pCtx,
dan0d5fa6b2018-08-24 17:55:49 +0000851 int bPost,
danb0137382018-08-20 20:01:01 +0000852 sqlite3_value *pType,
853 sqlite3_value *pObject,
854 Parse *pParse
855){
drh79a5ee92018-08-23 19:32:04 +0000856 const char *zT = (const char*)sqlite3_value_text(pType);
857 const char *zN = (const char*)sqlite3_value_text(pObject);
dan24fedb92018-08-18 17:35:38 +0000858 char *zErr;
danb0137382018-08-20 20:01:01 +0000859
dan0d5fa6b2018-08-24 17:55:49 +0000860 zErr = sqlite3_mprintf("error in %s %s%s: %s",
861 zT, zN, (bPost ? " after rename" : ""),
862 pParse->zErrMsg
863 );
dan24fedb92018-08-18 17:35:38 +0000864 sqlite3_result_error(pCtx, zErr, -1);
865 sqlite3_free(zErr);
866}
867
868/*
dan06249392018-08-21 15:06:59 +0000869** For each name in the the expression-list pEList (i.e. each
870** pEList->a[i].zName) that matches the string in zOld, extract the
871** corresponding rename-token from Parse object pParse and add it
872** to the RenameCtx pCtx.
873*/
874static void renameColumnElistNames(
875 Parse *pParse,
876 RenameCtx *pCtx,
877 ExprList *pEList,
878 const char *zOld
879){
880 if( pEList ){
881 int i;
882 for(i=0; i<pEList->nExpr; i++){
883 char *zName = pEList->a[i].zName;
884 if( 0==sqlite3_stricmp(zName, zOld) ){
885 renameTokenFind(pParse, pCtx, (void*)zName);
886 }
887 }
888 }
889}
890
891/*
892** For each name in the the id-list pIdList (i.e. each pIdList->a[i].zName)
893** that matches the string in zOld, extract the corresponding rename-token
894** from Parse object pParse and add it to the RenameCtx pCtx.
895*/
896static void renameColumnIdlistNames(
897 Parse *pParse,
898 RenameCtx *pCtx,
899 IdList *pIdList,
900 const char *zOld
901){
902 if( pIdList ){
903 int i;
904 for(i=0; i<pIdList->nId; i++){
905 char *zName = pIdList->a[i].zName;
906 if( 0==sqlite3_stricmp(zName, zOld) ){
907 renameTokenFind(pParse, pCtx, (void*)zName);
908 }
909 }
910 }
911}
912
dandd1a9c82018-09-05 08:28:30 +0000913/*
914** Parse the SQL statement zSql using Parse object (*p). The Parse object
915** is initialized by this function before it is used.
916*/
danc9461ec2018-08-29 21:00:16 +0000917static int renameParseSql(
dandd1a9c82018-09-05 08:28:30 +0000918 Parse *p, /* Memory to use for Parse object */
919 const char *zDb, /* Name of schema SQL belongs to */
920 int bTable, /* 1 -> RENAME TABLE, 0 -> RENAME COLUMN */
921 sqlite3 *db, /* Database handle */
922 const char *zSql, /* SQL to parse */
923 int bTemp /* True if SQL is from temp schema */
danc9461ec2018-08-29 21:00:16 +0000924){
925 int rc;
926 char *zErr = 0;
927
928 db->init.iDb = bTemp ? 1 : sqlite3FindDbName(db, zDb);
929
930 /* Parse the SQL statement passed as the first argument. If no error
931 ** occurs and the parse does not result in a new table, index or
932 ** trigger object, the database must be corrupt. */
933 memset(p, 0, sizeof(Parse));
934 p->eParseMode = (bTable ? PARSE_MODE_RENAME_TABLE : PARSE_MODE_RENAME_COLUMN);
935 p->db = db;
936 p->nQueryLoop = 1;
937 rc = sqlite3RunParser(p, zSql, &zErr);
938 assert( p->zErrMsg==0 );
939 assert( rc!=SQLITE_OK || zErr==0 );
940 assert( (0!=p->pNewTable) + (0!=p->pNewIndex) + (0!=p->pNewTrigger)<2 );
941 p->zErrMsg = zErr;
942 if( db->mallocFailed ) rc = SQLITE_NOMEM;
943 if( rc==SQLITE_OK
944 && p->pNewTable==0 && p->pNewIndex==0 && p->pNewTrigger==0
945 ){
946 rc = SQLITE_CORRUPT_BKPT;
947 }
948
949#ifdef SQLITE_DEBUG
950 /* Ensure that all mappings in the Parse.pRename list really do map to
951 ** a part of the input string. */
952 if( rc==SQLITE_OK ){
953 int nSql = sqlite3Strlen30(zSql);
954 RenameToken *pToken;
955 for(pToken=p->pRename; pToken; pToken=pToken->pNext){
956 assert( pToken->t.z>=zSql && &pToken->t.z[pToken->t.n]<=&zSql[nSql] );
957 }
958 }
959#endif
960
961 db->init.iDb = 0;
962 return rc;
963}
964
dandd1a9c82018-09-05 08:28:30 +0000965/*
966** This function edits SQL statement zSql, replacing each token identified
967** by the linked list pRename with the text of zNew. If argument bQuote is
968** true, then zNew is always quoted first. If no error occurs, the result
969** is loaded into context object pCtx as the result.
970**
971** Or, if an error occurs (i.e. an OOM condition), an error is left in
972** pCtx and an SQLite error code returned.
973*/
danc9461ec2018-08-29 21:00:16 +0000974static int renameEditSql(
975 sqlite3_context *pCtx, /* Return result here */
976 RenameCtx *pRename, /* Rename context */
977 const char *zSql, /* SQL statement to edit */
978 const char *zNew, /* New token text */
979 int bQuote /* True to always quote token */
980){
981 int nNew = sqlite3Strlen30(zNew);
982 int nSql = sqlite3Strlen30(zSql);
983 sqlite3 *db = sqlite3_context_db_handle(pCtx);
984 int rc = SQLITE_OK;
985 char *zQuot;
986 char *zOut;
987 int nQuot;
988
989 /* Set zQuot to point to a buffer containing a quoted copy of the
990 ** identifier zNew. If the corresponding identifier in the original
991 ** ALTER TABLE statement was quoted (bQuote==1), then set zNew to
992 ** point to zQuot so that all substitutions are made using the
993 ** quoted version of the new column name. */
drhc753c212018-09-01 16:55:36 +0000994 zQuot = sqlite3MPrintf(db, "\"%w\"", zNew);
danc9461ec2018-08-29 21:00:16 +0000995 if( zQuot==0 ){
996 return SQLITE_NOMEM;
997 }else{
998 nQuot = sqlite3Strlen30(zQuot);
999 }
1000 if( bQuote ){
1001 zNew = zQuot;
1002 nNew = nQuot;
1003 }
1004
1005 /* At this point pRename->pList contains a list of RenameToken objects
1006 ** corresponding to all tokens in the input SQL that must be replaced
1007 ** with the new column name. All that remains is to construct and
1008 ** return the edited SQL string. */
1009 assert( nQuot>=nNew );
1010 zOut = sqlite3DbMallocZero(db, nSql + pRename->nList*nQuot + 1);
1011 if( zOut ){
1012 int nOut = nSql;
1013 memcpy(zOut, zSql, nSql);
1014 while( pRename->pList ){
1015 int iOff; /* Offset of token to replace in zOut */
1016 RenameToken *pBest = renameColumnTokenNext(pRename);
1017
1018 u32 nReplace;
1019 const char *zReplace;
1020 if( sqlite3IsIdChar(*pBest->t.z) ){
1021 nReplace = nNew;
1022 zReplace = zNew;
1023 }else{
1024 nReplace = nQuot;
1025 zReplace = zQuot;
1026 }
1027
1028 iOff = pBest->t.z - zSql;
1029 if( pBest->t.n!=nReplace ){
1030 memmove(&zOut[iOff + nReplace], &zOut[iOff + pBest->t.n],
1031 nOut - (iOff + pBest->t.n)
1032 );
1033 nOut += nReplace - pBest->t.n;
1034 zOut[nOut] = '\0';
1035 }
1036 memcpy(&zOut[iOff], zReplace, nReplace);
1037 sqlite3DbFree(db, pBest);
1038 }
1039
1040 sqlite3_result_text(pCtx, zOut, -1, SQLITE_TRANSIENT);
1041 sqlite3DbFree(db, zOut);
1042 }else{
1043 rc = SQLITE_NOMEM;
1044 }
1045
1046 sqlite3_free(zQuot);
1047 return rc;
1048}
1049
dandd1a9c82018-09-05 08:28:30 +00001050/*
1051** Resolve all symbols in the trigger at pParse->pNewTrigger, assuming
1052** it was read from the schema of database zDb. Return SQLITE_OK if
1053** successful. Otherwise, return an SQLite error code and leave an error
1054** message in the Parse object.
1055*/
1056static int renameResolveTrigger(Parse *pParse, const char *zDb){
danc9461ec2018-08-29 21:00:16 +00001057 sqlite3 *db = pParse->db;
dand5e6fef2018-09-07 15:50:31 +00001058 Trigger *pNew = pParse->pNewTrigger;
danc9461ec2018-08-29 21:00:16 +00001059 TriggerStep *pStep;
1060 NameContext sNC;
1061 int rc = SQLITE_OK;
1062
1063 memset(&sNC, 0, sizeof(sNC));
1064 sNC.pParse = pParse;
dand5e6fef2018-09-07 15:50:31 +00001065 assert( pNew->pTabSchema );
1066 pParse->pTriggerTab = sqlite3FindTable(db, pNew->table,
1067 db->aDb[sqlite3SchemaToIndex(db, pNew->pTabSchema)].zDbSName
1068 );
1069 pParse->eTriggerOp = pNew->op;
drhf470c372018-10-03 18:05:36 +00001070 /* ALWAYS() because if the table of the trigger does not exist, the
1071 ** error would have been hit before this point */
1072 if( ALWAYS(pParse->pTriggerTab) ){
dan5351e882018-10-01 07:04:12 +00001073 rc = sqlite3ViewGetColumnNames(pParse, pParse->pTriggerTab);
1074 }
danc9461ec2018-08-29 21:00:16 +00001075
1076 /* Resolve symbols in WHEN clause */
dan5351e882018-10-01 07:04:12 +00001077 if( rc==SQLITE_OK && pNew->pWhen ){
dand5e6fef2018-09-07 15:50:31 +00001078 rc = sqlite3ResolveExprNames(&sNC, pNew->pWhen);
danc9461ec2018-08-29 21:00:16 +00001079 }
1080
dand5e6fef2018-09-07 15:50:31 +00001081 for(pStep=pNew->step_list; rc==SQLITE_OK && pStep; pStep=pStep->pNext){
danc9461ec2018-08-29 21:00:16 +00001082 if( pStep->pSelect ){
1083 sqlite3SelectPrep(pParse, pStep->pSelect, &sNC);
1084 if( pParse->nErr ) rc = pParse->rc;
1085 }
dand5e6fef2018-09-07 15:50:31 +00001086 if( rc==SQLITE_OK && pStep->zTarget ){
danc9461ec2018-08-29 21:00:16 +00001087 Table *pTarget = sqlite3LocateTable(pParse, 0, pStep->zTarget, zDb);
1088 if( pTarget==0 ){
1089 rc = SQLITE_ERROR;
dande79e092018-09-17 13:38:45 +00001090 }else if( SQLITE_OK==(rc = sqlite3ViewGetColumnNames(pParse, pTarget)) ){
danc9461ec2018-08-29 21:00:16 +00001091 SrcList sSrc;
1092 memset(&sSrc, 0, sizeof(sSrc));
1093 sSrc.nSrc = 1;
1094 sSrc.a[0].zName = pStep->zTarget;
1095 sSrc.a[0].pTab = pTarget;
1096 sNC.pSrcList = &sSrc;
1097 if( pStep->pWhere ){
1098 rc = sqlite3ResolveExprNames(&sNC, pStep->pWhere);
1099 }
1100 if( rc==SQLITE_OK ){
1101 rc = sqlite3ResolveExprListNames(&sNC, pStep->pExprList);
1102 }
1103 assert( !pStep->pUpsert || (!pStep->pWhere && !pStep->pExprList) );
1104 if( pStep->pUpsert ){
1105 Upsert *pUpsert = pStep->pUpsert;
1106 assert( rc==SQLITE_OK );
1107 pUpsert->pUpsertSrc = &sSrc;
1108 sNC.uNC.pUpsert = pUpsert;
1109 sNC.ncFlags = NC_UUpsert;
1110 rc = sqlite3ResolveExprListNames(&sNC, pUpsert->pUpsertTarget);
1111 if( rc==SQLITE_OK ){
1112 ExprList *pUpsertSet = pUpsert->pUpsertSet;
1113 rc = sqlite3ResolveExprListNames(&sNC, pUpsertSet);
1114 }
1115 if( rc==SQLITE_OK ){
1116 rc = sqlite3ResolveExprNames(&sNC, pUpsert->pUpsertWhere);
1117 }
1118 if( rc==SQLITE_OK ){
1119 rc = sqlite3ResolveExprNames(&sNC, pUpsert->pUpsertTargetWhere);
1120 }
1121 sNC.ncFlags = 0;
1122 }
1123 }
1124 }
1125 }
1126 return rc;
1127}
1128
dandd1a9c82018-09-05 08:28:30 +00001129/*
1130** Invoke sqlite3WalkExpr() or sqlite3WalkSelect() on all Select or Expr
1131** objects that are part of the trigger passed as the second argument.
1132*/
danc9461ec2018-08-29 21:00:16 +00001133static void renameWalkTrigger(Walker *pWalker, Trigger *pTrigger){
1134 TriggerStep *pStep;
1135
1136 /* Find tokens to edit in WHEN clause */
1137 sqlite3WalkExpr(pWalker, pTrigger->pWhen);
1138
1139 /* Find tokens to edit in trigger steps */
1140 for(pStep=pTrigger->step_list; pStep; pStep=pStep->pNext){
1141 sqlite3WalkSelect(pWalker, pStep->pSelect);
1142 sqlite3WalkExpr(pWalker, pStep->pWhere);
1143 sqlite3WalkExprList(pWalker, pStep->pExprList);
1144 if( pStep->pUpsert ){
1145 Upsert *pUpsert = pStep->pUpsert;
1146 sqlite3WalkExprList(pWalker, pUpsert->pUpsertTarget);
1147 sqlite3WalkExprList(pWalker, pUpsert->pUpsertSet);
1148 sqlite3WalkExpr(pWalker, pUpsert->pUpsertWhere);
1149 sqlite3WalkExpr(pWalker, pUpsert->pUpsertTargetWhere);
1150 }
1151 }
1152}
1153
dandd1a9c82018-09-05 08:28:30 +00001154/*
1155** Free the contents of Parse object (*pParse). Do not free the memory
1156** occupied by the Parse object itself.
1157*/
dan141e1192018-08-31 18:23:53 +00001158static void renameParseCleanup(Parse *pParse){
1159 sqlite3 *db = pParse->db;
1160 if( pParse->pVdbe ){
1161 sqlite3VdbeFinalize(pParse->pVdbe);
1162 }
1163 sqlite3DeleteTable(db, pParse->pNewTable);
1164 if( pParse->pNewIndex ) sqlite3FreeIndex(db, pParse->pNewIndex);
1165 sqlite3DeleteTrigger(db, pParse->pNewTrigger);
1166 sqlite3DbFree(db, pParse->zErrMsg);
1167 renameTokenFree(db, pParse->pRename);
1168 sqlite3ParserReset(pParse);
1169}
1170
dan06249392018-08-21 15:06:59 +00001171/*
dan987db762018-08-14 20:18:50 +00001172** SQL function:
1173**
1174** sqlite_rename_column(zSql, iCol, bQuote, zNew, zTable, zOld)
1175**
1176** 0. zSql: SQL statement to rewrite
danb0137382018-08-20 20:01:01 +00001177** 1. type: Type of object ("table", "view" etc.)
1178** 2. object: Name of object
1179** 3. Database: Database name (e.g. "main")
1180** 4. Table: Table name
1181** 5. iCol: Index of column to rename
1182** 6. zNew: New column name
dan9d324822018-08-30 20:03:44 +00001183** 7. bQuote: Non-zero if the new column name should be quoted.
danb87a9a82018-09-01 20:23:28 +00001184** 8. bTemp: True if zSql comes from temp schema
dan987db762018-08-14 20:18:50 +00001185**
1186** Do a column rename operation on the CREATE statement given in zSql.
1187** The iCol-th column (left-most is 0) of table zTable is renamed from zCol
1188** into zNew. The name should be quoted if bQuote is true.
1189**
1190** This function is used internally by the ALTER TABLE RENAME COLUMN command.
drheea8eb62018-11-26 18:09:15 +00001191** It is only accessible to SQL created using sqlite3NestedParse(). It is
1192** not reachable from ordinary SQL passed into sqlite3_prepare().
dan6fe7f232018-08-10 19:19:33 +00001193*/
dancf8f2892018-08-09 20:47:01 +00001194static void renameColumnFunc(
1195 sqlite3_context *context,
1196 int NotUsed,
1197 sqlite3_value **argv
1198){
1199 sqlite3 *db = sqlite3_context_db_handle(context);
dan5496d6a2018-08-13 17:14:26 +00001200 RenameCtx sCtx;
drhad866a12018-08-10 19:33:09 +00001201 const char *zSql = (const char*)sqlite3_value_text(argv[0]);
danb0137382018-08-20 20:01:01 +00001202 const char *zDb = (const char*)sqlite3_value_text(argv[3]);
1203 const char *zTable = (const char*)sqlite3_value_text(argv[4]);
1204 int iCol = sqlite3_value_int(argv[5]);
1205 const char *zNew = (const char*)sqlite3_value_text(argv[6]);
danb0137382018-08-20 20:01:01 +00001206 int bQuote = sqlite3_value_int(argv[7]);
danb87a9a82018-09-01 20:23:28 +00001207 int bTemp = sqlite3_value_int(argv[8]);
dan987db762018-08-14 20:18:50 +00001208 const char *zOld;
dancf8f2892018-08-09 20:47:01 +00001209 int rc;
dancf8f2892018-08-09 20:47:01 +00001210 Parse sParse;
1211 Walker sWalker;
dancf8f2892018-08-09 20:47:01 +00001212 Index *pIdx;
dancf8f2892018-08-09 20:47:01 +00001213 int i;
dan987db762018-08-14 20:18:50 +00001214 Table *pTab;
dan141e1192018-08-31 18:23:53 +00001215#ifndef SQLITE_OMIT_AUTHORIZATION
1216 sqlite3_xauth xAuth = db->xAuth;
1217#endif
dancf8f2892018-08-09 20:47:01 +00001218
drh38d99642018-08-18 18:27:18 +00001219 UNUSED_PARAMETER(NotUsed);
dan987db762018-08-14 20:18:50 +00001220 if( zSql==0 ) return;
dan987db762018-08-14 20:18:50 +00001221 if( zTable==0 ) return;
danb0137382018-08-20 20:01:01 +00001222 if( zNew==0 ) return;
dan987db762018-08-14 20:18:50 +00001223 if( iCol<0 ) return;
drhda76adc2018-08-25 02:04:05 +00001224 sqlite3BtreeEnterAll(db);
dan987db762018-08-14 20:18:50 +00001225 pTab = sqlite3FindTable(db, zTable, zDb);
drhda76adc2018-08-25 02:04:05 +00001226 if( pTab==0 || iCol>=pTab->nCol ){
1227 sqlite3BtreeLeaveAll(db);
1228 return;
1229 }
dan987db762018-08-14 20:18:50 +00001230 zOld = pTab->aCol[iCol].zName;
dancf8f2892018-08-09 20:47:01 +00001231 memset(&sCtx, 0, sizeof(sCtx));
dan987db762018-08-14 20:18:50 +00001232 sCtx.iCol = ((iCol==pTab->iPKey) ? -1 : iCol);
dancf8f2892018-08-09 20:47:01 +00001233
dan141e1192018-08-31 18:23:53 +00001234#ifndef SQLITE_OMIT_AUTHORIZATION
1235 db->xAuth = 0;
1236#endif
danc9461ec2018-08-29 21:00:16 +00001237 rc = renameParseSql(&sParse, zDb, 0, db, zSql, bTemp);
dan24fedb92018-08-18 17:35:38 +00001238
dancf8f2892018-08-09 20:47:01 +00001239 /* Find tokens that need to be replaced. */
1240 memset(&sWalker, 0, sizeof(Walker));
1241 sWalker.pParse = &sParse;
1242 sWalker.xExprCallback = renameColumnExprCb;
dan987db762018-08-14 20:18:50 +00001243 sWalker.xSelectCallback = renameColumnSelectCb;
dancf8f2892018-08-09 20:47:01 +00001244 sWalker.u.pRename = &sCtx;
1245
dan0cbb0b12018-08-16 19:49:16 +00001246 sCtx.pTab = pTab;
dan987db762018-08-14 20:18:50 +00001247 if( rc!=SQLITE_OK ) goto renameColumnFunc_done;
dancf8f2892018-08-09 20:47:01 +00001248 if( sParse.pNewTable ){
dan987db762018-08-14 20:18:50 +00001249 Select *pSelect = sParse.pNewTable->pSelect;
1250 if( pSelect ){
dan987db762018-08-14 20:18:50 +00001251 sParse.rc = SQLITE_OK;
1252 sqlite3SelectPrep(&sParse, sParse.pNewTable->pSelect, 0);
1253 rc = (db->mallocFailed ? SQLITE_NOMEM : sParse.rc);
1254 if( rc==SQLITE_OK ){
1255 sqlite3WalkSelect(&sWalker, pSelect);
dana8762ae2018-08-11 17:49:23 +00001256 }
dan987db762018-08-14 20:18:50 +00001257 if( rc!=SQLITE_OK ) goto renameColumnFunc_done;
1258 }else{
1259 /* A regular table */
1260 int bFKOnly = sqlite3_stricmp(zTable, sParse.pNewTable->zName);
1261 FKey *pFKey;
1262 assert( sParse.pNewTable->pSelect==0 );
dan0cbb0b12018-08-16 19:49:16 +00001263 sCtx.pTab = sParse.pNewTable;
dan987db762018-08-14 20:18:50 +00001264 if( bFKOnly==0 ){
1265 renameTokenFind(
1266 &sParse, &sCtx, (void*)sParse.pNewTable->aCol[iCol].zName
1267 );
1268 if( sCtx.iCol<0 ){
1269 renameTokenFind(&sParse, &sCtx, (void*)&sParse.pNewTable->iPKey);
dancf8f2892018-08-09 20:47:01 +00001270 }
dan987db762018-08-14 20:18:50 +00001271 sqlite3WalkExprList(&sWalker, sParse.pNewTable->pCheck);
1272 for(pIdx=sParse.pNewTable->pIndex; pIdx; pIdx=pIdx->pNext){
1273 sqlite3WalkExprList(&sWalker, pIdx->aColExpr);
1274 }
1275 }
1276
1277 for(pFKey=sParse.pNewTable->pFKey; pFKey; pFKey=pFKey->pNextFrom){
1278 for(i=0; i<pFKey->nCol; i++){
dan356afab2018-08-14 21:05:35 +00001279 if( bFKOnly==0 && pFKey->aCol[i].iFrom==iCol ){
dan987db762018-08-14 20:18:50 +00001280 renameTokenFind(&sParse, &sCtx, (void*)&pFKey->aCol[i]);
1281 }
1282 if( 0==sqlite3_stricmp(pFKey->zTo, zTable)
1283 && 0==sqlite3_stricmp(pFKey->aCol[i].zCol, zOld)
1284 ){
1285 renameTokenFind(&sParse, &sCtx, (void*)pFKey->aCol[i].zCol);
1286 }
dan6fe7f232018-08-10 19:19:33 +00001287 }
dancf8f2892018-08-09 20:47:01 +00001288 }
1289 }
dan5496d6a2018-08-13 17:14:26 +00001290 }else if( sParse.pNewIndex ){
dancf8f2892018-08-09 20:47:01 +00001291 sqlite3WalkExprList(&sWalker, sParse.pNewIndex->aColExpr);
1292 sqlite3WalkExpr(&sWalker, sParse.pNewIndex->pPartIdxWhere);
dan5496d6a2018-08-13 17:14:26 +00001293 }else{
dan5be60c52018-08-15 20:28:39 +00001294 /* A trigger */
1295 TriggerStep *pStep;
dan0ccda962018-08-30 16:26:48 +00001296 rc = renameResolveTrigger(&sParse, (bTemp ? 0 : zDb));
danc9461ec2018-08-29 21:00:16 +00001297 if( rc!=SQLITE_OK ) goto renameColumnFunc_done;
dan5be60c52018-08-15 20:28:39 +00001298
danc9461ec2018-08-29 21:00:16 +00001299 for(pStep=sParse.pNewTrigger->step_list; pStep; pStep=pStep->pNext){
1300 if( pStep->zTarget ){
dan06249392018-08-21 15:06:59 +00001301 Table *pTarget = sqlite3LocateTable(&sParse, 0, pStep->zTarget, zDb);
danc9461ec2018-08-29 21:00:16 +00001302 if( pTarget==pTab ){
dan0cbb0b12018-08-16 19:49:16 +00001303 if( pStep->pUpsert ){
danc9461ec2018-08-29 21:00:16 +00001304 ExprList *pUpsertSet = pStep->pUpsert->pUpsertSet;
1305 renameColumnElistNames(&sParse, &sCtx, pUpsertSet, zOld);
dan0cbb0b12018-08-16 19:49:16 +00001306 }
danc9461ec2018-08-29 21:00:16 +00001307 renameColumnIdlistNames(&sParse, &sCtx, pStep->pIdList, zOld);
1308 renameColumnElistNames(&sParse, &sCtx, pStep->pExprList, zOld);
dan5be60c52018-08-15 20:28:39 +00001309 }
1310 }
1311 }
1312
dan5be60c52018-08-15 20:28:39 +00001313
1314 /* Find tokens to edit in UPDATE OF clause */
dan06249392018-08-21 15:06:59 +00001315 if( sParse.pTriggerTab==pTab ){
1316 renameColumnIdlistNames(&sParse, &sCtx,sParse.pNewTrigger->pColumns,zOld);
dan5496d6a2018-08-13 17:14:26 +00001317 }
dan5be60c52018-08-15 20:28:39 +00001318
danc9461ec2018-08-29 21:00:16 +00001319 /* Find tokens to edit in various expressions and selects */
1320 renameWalkTrigger(&sWalker, sParse.pNewTrigger);
dancf8f2892018-08-09 20:47:01 +00001321 }
1322
dan987db762018-08-14 20:18:50 +00001323 assert( rc==SQLITE_OK );
danc9461ec2018-08-29 21:00:16 +00001324 rc = renameEditSql(context, &sCtx, zSql, zNew, bQuote);
dancf8f2892018-08-09 20:47:01 +00001325
drh5fc22cd2018-08-13 13:43:11 +00001326renameColumnFunc_done:
dan987db762018-08-14 20:18:50 +00001327 if( rc!=SQLITE_OK ){
dan24fedb92018-08-18 17:35:38 +00001328 if( sParse.zErrMsg ){
dan9d324822018-08-30 20:03:44 +00001329 renameColumnParseError(context, 0, argv[1], argv[2], &sParse);
dan987db762018-08-14 20:18:50 +00001330 }else{
1331 sqlite3_result_error_code(context, rc);
1332 }
1333 }
1334
dan141e1192018-08-31 18:23:53 +00001335 renameParseCleanup(&sParse);
drh4a2c7472018-08-13 15:09:48 +00001336 renameTokenFree(db, sCtx.pList);
dan141e1192018-08-31 18:23:53 +00001337#ifndef SQLITE_OMIT_AUTHORIZATION
1338 db->xAuth = xAuth;
1339#endif
drhda76adc2018-08-25 02:04:05 +00001340 sqlite3BtreeLeaveAll(db);
dancf8f2892018-08-09 20:47:01 +00001341}
1342
dandd1a9c82018-09-05 08:28:30 +00001343/*
1344** Walker expression callback used by "RENAME TABLE".
1345*/
danc9461ec2018-08-29 21:00:16 +00001346static int renameTableExprCb(Walker *pWalker, Expr *pExpr){
1347 RenameCtx *p = pWalker->u.pRename;
drheda079c2018-09-20 19:02:15 +00001348 if( pExpr->op==TK_COLUMN && p->pTab==pExpr->y.pTab ){
1349 renameTokenFind(pWalker->pParse, p, (void*)&pExpr->y.pTab);
danc9461ec2018-08-29 21:00:16 +00001350 }
1351 return WRC_Continue;
1352}
1353
1354/*
dandd1a9c82018-09-05 08:28:30 +00001355** Walker select callback used by "RENAME TABLE".
danc9461ec2018-08-29 21:00:16 +00001356*/
1357static int renameTableSelectCb(Walker *pWalker, Select *pSelect){
1358 int i;
1359 RenameCtx *p = pWalker->u.pRename;
1360 SrcList *pSrc = pSelect->pSrc;
1361 for(i=0; i<pSrc->nSrc; i++){
1362 struct SrcList_item *pItem = &pSrc->a[i];
1363 if( pItem->pTab==p->pTab ){
1364 renameTokenFind(pWalker->pParse, p, pItem->zName);
1365 }
1366 }
1367
1368 return WRC_Continue;
1369}
1370
1371
1372/*
1373** This C function implements an SQL user function that is used by SQL code
1374** generated by the ALTER TABLE ... RENAME command to modify the definition
1375** of any foreign key constraints that use the table being renamed as the
1376** parent table. It is passed three arguments:
1377**
dan141e1192018-08-31 18:23:53 +00001378** 0: The database containing the table being renamed.
dan65372fa2018-09-03 20:05:15 +00001379** 1. type: Type of object ("table", "view" etc.)
1380** 2. object: Name of object
1381** 3: The complete text of the schema statement being modified,
1382** 4: The old name of the table being renamed, and
1383** 5: The new name of the table being renamed.
1384** 6: True if the schema statement comes from the temp db.
danc9461ec2018-08-29 21:00:16 +00001385**
dan141e1192018-08-31 18:23:53 +00001386** It returns the new schema statement. For example:
danc9461ec2018-08-29 21:00:16 +00001387**
dan141e1192018-08-31 18:23:53 +00001388** sqlite_rename_table('main', 'CREATE TABLE t1(a REFERENCES t2)','t2','t3',0)
danc9461ec2018-08-29 21:00:16 +00001389** -> 'CREATE TABLE t1(a REFERENCES t3)'
1390*/
1391static void renameTableFunc(
1392 sqlite3_context *context,
1393 int NotUsed,
1394 sqlite3_value **argv
1395){
1396 sqlite3 *db = sqlite3_context_db_handle(context);
drh5b1da302018-09-01 20:02:07 +00001397 const char *zDb = (const char*)sqlite3_value_text(argv[0]);
dan65372fa2018-09-03 20:05:15 +00001398 const char *zInput = (const char*)sqlite3_value_text(argv[3]);
1399 const char *zOld = (const char*)sqlite3_value_text(argv[4]);
1400 const char *zNew = (const char*)sqlite3_value_text(argv[5]);
1401 int bTemp = sqlite3_value_int(argv[6]);
drh5b1da302018-09-01 20:02:07 +00001402 UNUSED_PARAMETER(NotUsed);
danc9461ec2018-08-29 21:00:16 +00001403
dan141e1192018-08-31 18:23:53 +00001404 if( zInput && zOld && zNew ){
dan141e1192018-08-31 18:23:53 +00001405 Parse sParse;
1406 int rc;
1407 int bQuote = 1;
1408 RenameCtx sCtx;
1409 Walker sWalker;
danc9461ec2018-08-29 21:00:16 +00001410
dan141e1192018-08-31 18:23:53 +00001411#ifndef SQLITE_OMIT_AUTHORIZATION
1412 sqlite3_xauth xAuth = db->xAuth;
1413 db->xAuth = 0;
danc9461ec2018-08-29 21:00:16 +00001414#endif
1415
dan141e1192018-08-31 18:23:53 +00001416 sqlite3BtreeEnterAll(db);
1417
1418 memset(&sCtx, 0, sizeof(RenameCtx));
1419 sCtx.pTab = sqlite3FindTable(db, zOld, zDb);
1420 memset(&sWalker, 0, sizeof(Walker));
1421 sWalker.pParse = &sParse;
1422 sWalker.xExprCallback = renameTableExprCb;
1423 sWalker.xSelectCallback = renameTableSelectCb;
1424 sWalker.u.pRename = &sCtx;
1425
1426 rc = renameParseSql(&sParse, zDb, 1, db, zInput, bTemp);
1427
1428 if( rc==SQLITE_OK ){
dan674b8942018-09-20 08:28:01 +00001429 int isLegacy = (db->flags & SQLITE_LegacyAlter);
dan141e1192018-08-31 18:23:53 +00001430 if( sParse.pNewTable ){
1431 Table *pTab = sParse.pNewTable;
1432
1433 if( pTab->pSelect ){
dan674b8942018-09-20 08:28:01 +00001434 if( isLegacy==0 ){
1435 NameContext sNC;
1436 memset(&sNC, 0, sizeof(sNC));
1437 sNC.pParse = &sParse;
dan141e1192018-08-31 18:23:53 +00001438
dan674b8942018-09-20 08:28:01 +00001439 sqlite3SelectPrep(&sParse, pTab->pSelect, &sNC);
1440 if( sParse.nErr ) rc = sParse.rc;
1441 sqlite3WalkSelect(&sWalker, pTab->pSelect);
1442 }
dan141e1192018-08-31 18:23:53 +00001443 }else{
1444 /* Modify any FK definitions to point to the new table. */
1445#ifndef SQLITE_OMIT_FOREIGN_KEY
danb4307012018-11-09 20:04:05 +00001446 if( isLegacy==0 || (db->flags & SQLITE_ForeignKeys) ){
dan202a0272018-09-07 11:51:21 +00001447 FKey *pFKey;
1448 for(pFKey=pTab->pFKey; pFKey; pFKey=pFKey->pNextFrom){
1449 if( sqlite3_stricmp(pFKey->zTo, zOld)==0 ){
1450 renameTokenFind(&sParse, &sCtx, (void*)pFKey->zTo);
1451 }
dan141e1192018-08-31 18:23:53 +00001452 }
1453 }
1454#endif
1455
1456 /* If this is the table being altered, fix any table refs in CHECK
1457 ** expressions. Also update the name that appears right after the
1458 ** "CREATE [VIRTUAL] TABLE" bit. */
1459 if( sqlite3_stricmp(zOld, pTab->zName)==0 ){
1460 sCtx.pTab = pTab;
dan674b8942018-09-20 08:28:01 +00001461 if( isLegacy==0 ){
1462 sqlite3WalkExprList(&sWalker, pTab->pCheck);
1463 }
dan141e1192018-08-31 18:23:53 +00001464 renameTokenFind(&sParse, &sCtx, pTab->zName);
1465 }
danc9461ec2018-08-29 21:00:16 +00001466 }
1467 }
danc9461ec2018-08-29 21:00:16 +00001468
dan141e1192018-08-31 18:23:53 +00001469 else if( sParse.pNewIndex ){
1470 renameTokenFind(&sParse, &sCtx, sParse.pNewIndex->zName);
dan674b8942018-09-20 08:28:01 +00001471 if( isLegacy==0 ){
1472 sqlite3WalkExpr(&sWalker, sParse.pNewIndex->pPartIdxWhere);
1473 }
dan141e1192018-08-31 18:23:53 +00001474 }
danc9461ec2018-08-29 21:00:16 +00001475
1476#ifndef SQLITE_OMIT_TRIGGER
danb87a9a82018-09-01 20:23:28 +00001477 else{
dan141e1192018-08-31 18:23:53 +00001478 Trigger *pTrigger = sParse.pNewTrigger;
1479 TriggerStep *pStep;
1480 if( 0==sqlite3_stricmp(sParse.pNewTrigger->table, zOld)
1481 && sCtx.pTab->pSchema==pTrigger->pTabSchema
1482 ){
1483 renameTokenFind(&sParse, &sCtx, sParse.pNewTrigger->table);
1484 }
danc9461ec2018-08-29 21:00:16 +00001485
dan674b8942018-09-20 08:28:01 +00001486 if( isLegacy==0 ){
1487 rc = renameResolveTrigger(&sParse, bTemp ? 0 : zDb);
1488 if( rc==SQLITE_OK ){
1489 renameWalkTrigger(&sWalker, pTrigger);
1490 for(pStep=pTrigger->step_list; pStep; pStep=pStep->pNext){
1491 if( pStep->zTarget && 0==sqlite3_stricmp(pStep->zTarget, zOld) ){
1492 renameTokenFind(&sParse, &sCtx, pStep->zTarget);
1493 }
dan141e1192018-08-31 18:23:53 +00001494 }
dan0ccda962018-08-30 16:26:48 +00001495 }
danc9461ec2018-08-29 21:00:16 +00001496 }
1497 }
dan141e1192018-08-31 18:23:53 +00001498#endif
danc9461ec2018-08-29 21:00:16 +00001499 }
dan141e1192018-08-31 18:23:53 +00001500
1501 if( rc==SQLITE_OK ){
1502 rc = renameEditSql(context, &sCtx, zInput, zNew, bQuote);
1503 }
1504 if( rc!=SQLITE_OK ){
dan65372fa2018-09-03 20:05:15 +00001505 if( sParse.zErrMsg ){
1506 renameColumnParseError(context, 0, argv[1], argv[2], &sParse);
1507 }else{
1508 sqlite3_result_error_code(context, rc);
1509 }
dan141e1192018-08-31 18:23:53 +00001510 }
1511
1512 renameParseCleanup(&sParse);
1513 renameTokenFree(db, sCtx.pList);
1514 sqlite3BtreeLeaveAll(db);
1515#ifndef SQLITE_OMIT_AUTHORIZATION
1516 db->xAuth = xAuth;
danc9461ec2018-08-29 21:00:16 +00001517#endif
1518 }
1519
danc9461ec2018-08-29 21:00:16 +00001520 return;
1521}
1522
dandd1a9c82018-09-05 08:28:30 +00001523/*
1524** An SQL user function that checks that there are no parse or symbol
1525** resolution problems in a CREATE TRIGGER|TABLE|VIEW|INDEX statement.
1526** After an ALTER TABLE .. RENAME operation is performed and the schema
1527** reloaded, this function is called on each SQL statement in the schema
dan1d85c6b2018-09-06 16:01:37 +00001528** to ensure that it is still usable.
dandd1a9c82018-09-05 08:28:30 +00001529**
1530** 0: Database name ("main", "temp" etc.).
1531** 1: SQL statement.
1532** 2: Object type ("view", "table", "trigger" or "index").
1533** 3: Object name.
1534** 4: True if object is from temp schema.
dan1d85c6b2018-09-06 16:01:37 +00001535**
1536** Unless it finds an error, this function normally returns NULL. However, it
1537** returns integer value 1 if:
1538**
1539** * the SQL argument creates a trigger, and
1540** * the table that the trigger is attached to is in database zDb.
dandd1a9c82018-09-05 08:28:30 +00001541*/
dan9d324822018-08-30 20:03:44 +00001542static void renameTableTest(
1543 sqlite3_context *context,
1544 int NotUsed,
1545 sqlite3_value **argv
1546){
1547 sqlite3 *db = sqlite3_context_db_handle(context);
drh5b1da302018-09-01 20:02:07 +00001548 char const *zDb = (const char*)sqlite3_value_text(argv[0]);
1549 char const *zInput = (const char*)sqlite3_value_text(argv[1]);
dan9d324822018-08-30 20:03:44 +00001550 int bTemp = sqlite3_value_int(argv[4]);
dan674b8942018-09-20 08:28:01 +00001551 int isLegacy = (db->flags & SQLITE_LegacyAlter);
dan9d324822018-08-30 20:03:44 +00001552
dan141e1192018-08-31 18:23:53 +00001553#ifndef SQLITE_OMIT_AUTHORIZATION
1554 sqlite3_xauth xAuth = db->xAuth;
1555 db->xAuth = 0;
1556#endif
1557
drh5b1da302018-09-01 20:02:07 +00001558 UNUSED_PARAMETER(NotUsed);
dan09236502018-09-01 16:05:50 +00001559 if( zDb && zInput ){
1560 int rc;
1561 Parse sParse;
1562 rc = renameParseSql(&sParse, zDb, 1, db, zInput, bTemp);
1563 if( rc==SQLITE_OK ){
dan674b8942018-09-20 08:28:01 +00001564 if( isLegacy==0 && sParse.pNewTable && sParse.pNewTable->pSelect ){
dan09236502018-09-01 16:05:50 +00001565 NameContext sNC;
1566 memset(&sNC, 0, sizeof(sNC));
1567 sNC.pParse = &sParse;
1568 sqlite3SelectPrep(&sParse, sParse.pNewTable->pSelect, &sNC);
1569 if( sParse.nErr ) rc = sParse.rc;
1570 }
1571
1572 else if( sParse.pNewTrigger ){
dan674b8942018-09-20 08:28:01 +00001573 if( isLegacy==0 ){
1574 rc = renameResolveTrigger(&sParse, bTemp ? 0 : zDb);
1575 }
drh3b700452018-09-07 19:12:08 +00001576 if( rc==SQLITE_OK ){
dan1d85c6b2018-09-06 16:01:37 +00001577 int i1 = sqlite3SchemaToIndex(db, sParse.pNewTrigger->pTabSchema);
1578 int i2 = sqlite3FindDbName(db, zDb);
1579 if( i1==i2 ) sqlite3_result_int(context, 1);
1580 }
dan09236502018-09-01 16:05:50 +00001581 }
dan9d324822018-08-30 20:03:44 +00001582 }
1583
dan09236502018-09-01 16:05:50 +00001584 if( rc!=SQLITE_OK ){
1585 renameColumnParseError(context, 1, argv[2], argv[3], &sParse);
dan9d324822018-08-30 20:03:44 +00001586 }
dan09236502018-09-01 16:05:50 +00001587 renameParseCleanup(&sParse);
dan9d324822018-08-30 20:03:44 +00001588 }
1589
dan141e1192018-08-31 18:23:53 +00001590#ifndef SQLITE_OMIT_AUTHORIZATION
1591 db->xAuth = xAuth;
1592#endif
dan9d324822018-08-30 20:03:44 +00001593}
1594
dancf8f2892018-08-09 20:47:01 +00001595/*
1596** Register built-in functions used to help implement ALTER TABLE
1597*/
1598void sqlite3AlterFunctions(void){
1599 static FuncDef aAlterTableFuncs[] = {
drheea8eb62018-11-26 18:09:15 +00001600 INTERNAL_FUNCTION(sqlite_rename_column, 9, renameColumnFunc),
1601 INTERNAL_FUNCTION(sqlite_rename_table, 7, renameTableFunc),
1602 INTERNAL_FUNCTION(sqlite_rename_test, 5, renameTableTest),
dancf8f2892018-08-09 20:47:01 +00001603 };
1604 sqlite3InsertBuiltinFuncs(aAlterTableFuncs, ArraySize(aAlterTableFuncs));
1605}
drhd0e4a6c2005-02-15 20:47:57 +00001606#endif /* SQLITE_ALTER_TABLE */