blob: 3348470fe6d9f079a328d6198dce6098b56fe915 [file] [log] [blame]
drhcce7d172000-05-31 15:34:51 +00001/*
drhb19a2bc2001-09-16 00:13:26 +00002** 2001 September 15
drhcce7d172000-05-31 15:34:51 +00003**
drhb19a2bc2001-09-16 00:13:26 +00004** The author disclaims copyright to this source code. In place of
5** a legal notice, here is a blessing:
drhcce7d172000-05-31 15:34:51 +00006**
drhb19a2bc2001-09-16 00:13:26 +00007** 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.
drhcce7d172000-05-31 15:34:51 +000010**
11*************************************************************************
12** This file contains C code routines that are called by the parser
13** to handle UPDATE statements.
14**
drh17435752007-08-16 04:30:38 +000015** $Id: update.c,v 1.139 2007/08/16 04:30:40 drh Exp $
drhcce7d172000-05-31 15:34:51 +000016*/
17#include "sqliteInt.h"
18
drhedb193b2006-06-27 13:20:21 +000019#ifndef SQLITE_OMIT_VIRTUALTABLE
drh9c419382006-06-16 21:13:21 +000020/* Forward declaration */
21static void updateVirtualTable(
22 Parse *pParse, /* The parsing context */
23 SrcList *pSrc, /* The virtual table to be modified */
24 Table *pTab, /* The virtual table */
25 ExprList *pChanges, /* The columns to change in the UPDATE statement */
26 Expr *pRowidExpr, /* Expression used to recompute the rowid */
27 int *aXRef, /* Mapping from columns of pTab to entries in pChanges */
28 Expr *pWhere /* WHERE clause of the UPDATE statement */
29);
drhedb193b2006-06-27 13:20:21 +000030#endif /* SQLITE_OMIT_VIRTUALTABLE */
drh9c419382006-06-16 21:13:21 +000031
drhcce7d172000-05-31 15:34:51 +000032/*
drh8a512562005-11-14 22:29:05 +000033** The most recently coded instruction was an OP_Column to retrieve the
34** i-th column of table pTab. This routine sets the P3 parameter of the
danielk1977aee18ef2005-03-09 12:26:50 +000035** OP_Column to the default value, if any.
36**
37** The default value of a column is specified by a DEFAULT clause in the
38** column definition. This was either supplied by the user when the table
39** was created, or added later to the table definition by an ALTER TABLE
40** command. If the latter, then the row-records in the table btree on disk
41** may not contain a value for the column and the default value, taken
42** from the P3 parameter of the OP_Column instruction, is returned instead.
43** If the former, then all row-records are guaranteed to include a value
44** for the column and the P3 value is not required.
45**
46** Column definitions created by an ALTER TABLE command may only have
47** literal default values specified: a number, null or a string. (If a more
48** complicated default expression value was provided, it is evaluated
49** when the ALTER TABLE is executed and one of the literal values written
50** into the sqlite_master table.)
51**
52** Therefore, the P3 parameter is only required if the default value for
53** the column is a literal number, string or null. The sqlite3ValueFromExpr()
54** function is capable of transforming these types of expressions into
55** sqlite3_value objects.
56*/
57void sqlite3ColumnDefault(Vdbe *v, Table *pTab, int i){
58 if( pTab && !pTab->pSelect ){
59 sqlite3_value *pValue;
danielk197714db2662006-01-09 16:12:04 +000060 u8 enc = ENC(sqlite3VdbeDb(v));
danielk1977aee18ef2005-03-09 12:26:50 +000061 Column *pCol = &pTab->aCol[i];
danielk1977c9cf6e32007-06-25 16:29:33 +000062 assert( i<pTab->nCol );
danielk1977aee18ef2005-03-09 12:26:50 +000063 sqlite3ValueFromExpr(pCol->pDflt, enc, pCol->affinity, &pValue);
drh29dda4a2005-07-21 18:23:20 +000064 if( pValue ){
65 sqlite3VdbeChangeP3(v, -1, (const char *)pValue, P3_MEM);
66 }else{
67 VdbeComment((v, "# %s.%s", pTab->zName, pCol->zName));
68 }
danielk1977aee18ef2005-03-09 12:26:50 +000069 }
70}
71
72/*
drhcce7d172000-05-31 15:34:51 +000073** Process an UPDATE statement.
drhb2fe7d82003-04-20 17:29:23 +000074**
75** UPDATE OR IGNORE table_wxyz SET a=b, c=d WHERE e<5 AND f NOT NULL;
76** \_______/ \________/ \______/ \________________/
77* onError pTabList pChanges pWhere
drhcce7d172000-05-31 15:34:51 +000078*/
danielk19774adee202004-05-08 08:23:19 +000079void sqlite3Update(
drhcce7d172000-05-31 15:34:51 +000080 Parse *pParse, /* The parser context */
drh113088e2003-03-20 01:16:58 +000081 SrcList *pTabList, /* The table in which we should change things */
drhcce7d172000-05-31 15:34:51 +000082 ExprList *pChanges, /* Things to be changed */
drh9cfcf5d2002-01-29 18:41:24 +000083 Expr *pWhere, /* The WHERE clause. May be null */
84 int onError /* How to handle constraint errors */
drhcce7d172000-05-31 15:34:51 +000085){
86 int i, j; /* Loop counters */
87 Table *pTab; /* The table to be updated */
danielk1977742f9472004-06-16 12:02:43 +000088 int addr = 0; /* VDBE instruction address of the start of the loop */
drhcce7d172000-05-31 15:34:51 +000089 WhereInfo *pWInfo; /* Information about the WHERE clause */
90 Vdbe *v; /* The virtual database engine */
91 Index *pIdx; /* For looping over indices */
92 int nIdx; /* Number of indices that need updating */
drh0ca3e242002-01-29 23:07:02 +000093 int nIdxTotal; /* Total number of indices */
drh6a3ea0e2003-05-02 14:32:12 +000094 int iCur; /* VDBE Cursor number of pTab */
drh9bb575f2004-09-06 17:24:11 +000095 sqlite3 *db; /* The database structure */
drhcce7d172000-05-31 15:34:51 +000096 Index **apIdx = 0; /* An array of indices that need updating too */
drhb2fe7d82003-04-20 17:29:23 +000097 char *aIdxUsed = 0; /* aIdxUsed[i]==1 if the i-th index is used */
drhcce7d172000-05-31 15:34:51 +000098 int *aXRef = 0; /* aXRef[i] is the index in pChanges->a[] of the
drh967e8b72000-06-21 13:59:10 +000099 ** an expression for the i-th column of the table.
100 ** aXRef[i]==-1 if the i-th column is not changed. */
drhf0863fe2005-06-12 21:35:51 +0000101 int chngRowid; /* True if the record number is being changed */
102 Expr *pRowidExpr = 0; /* Expression defining the new record number */
danielk1977742f9472004-06-16 12:02:43 +0000103 int openAll = 0; /* True if all indices need to be opened */
drh85e20962003-04-25 17:52:11 +0000104 AuthContext sContext; /* The authorization context */
danielk1977b3bce662005-01-29 08:32:43 +0000105 NameContext sNC; /* The name-context to resolve expressions in */
danielk1977da184232006-01-05 11:34:32 +0000106 int iDb; /* Database containing the table being updated */
drh53a67772007-02-07 01:06:52 +0000107 int memCnt = 0; /* Memory cell used for counting rows changed */
drhcce7d172000-05-31 15:34:51 +0000108
drh798da522004-11-04 04:42:28 +0000109#ifndef SQLITE_OMIT_TRIGGER
110 int isView; /* Trying to update a view */
drhdca76842004-12-07 14:06:13 +0000111 int triggers_exist = 0; /* True if any row triggers exist */
drh798da522004-11-04 04:42:28 +0000112#endif
danielk1977c3f9bad2002-05-15 08:30:12 +0000113
114 int newIdx = -1; /* index of trigger "new" temp table */
115 int oldIdx = -1; /* index of trigger "old" temp table */
116
drh85e20962003-04-25 17:52:11 +0000117 sContext.pParse = 0;
drh17435752007-08-16 04:30:38 +0000118 db = pParse->db;
119 if( pParse->nErr || db->mallocFailed ){
drh6f7adc82006-01-11 21:41:20 +0000120 goto update_cleanup;
121 }
drh113088e2003-03-20 01:16:58 +0000122 assert( pTabList->nSrc==1 );
drhdaffd0e2001-04-11 14:28:42 +0000123
drhb2fe7d82003-04-20 17:29:23 +0000124 /* Locate the table which we want to update.
drhcce7d172000-05-31 15:34:51 +0000125 */
danielk19774adee202004-05-08 08:23:19 +0000126 pTab = sqlite3SrcListLookup(pParse, pTabList);
drha69d9162003-04-17 22:57:53 +0000127 if( pTab==0 ) goto update_cleanup;
danielk1977da184232006-01-05 11:34:32 +0000128 iDb = sqlite3SchemaToIndex(pParse->db, pTab->pSchema);
drhb7f91642004-10-31 02:22:47 +0000129
130 /* Figure out if we have any triggers and if the table being
131 ** updated is a view
132 */
133#ifndef SQLITE_OMIT_TRIGGER
drhdca76842004-12-07 14:06:13 +0000134 triggers_exist = sqlite3TriggersExist(pParse, pTab, TK_UPDATE, pChanges);
drh5cf590c2003-04-24 01:45:04 +0000135 isView = pTab->pSelect!=0;
drhb7f91642004-10-31 02:22:47 +0000136#else
drhdca76842004-12-07 14:06:13 +0000137# define triggers_exist 0
drhb7f91642004-10-31 02:22:47 +0000138# define isView 0
139#endif
140#ifdef SQLITE_OMIT_VIEW
141# undef isView
142# define isView 0
143#endif
144
drhdca76842004-12-07 14:06:13 +0000145 if( sqlite3IsReadOnly(pParse, pTab, triggers_exist) ){
drh5cf590c2003-04-24 01:45:04 +0000146 goto update_cleanup;
drha69d9162003-04-17 22:57:53 +0000147 }
danielk1977b3d24bf2006-06-19 03:05:10 +0000148 if( sqlite3ViewGetColumnNames(pParse, pTab) ){
149 goto update_cleanup;
drh5cf590c2003-04-24 01:45:04 +0000150 }
drh17435752007-08-16 04:30:38 +0000151 aXRef = sqlite3DbMallocRaw(db, sizeof(int) * pTab->nCol );
drhcce7d172000-05-31 15:34:51 +0000152 if( aXRef==0 ) goto update_cleanup;
153 for(i=0; i<pTab->nCol; i++) aXRef[i] = -1;
154
drhb2fe7d82003-04-20 17:29:23 +0000155 /* If there are FOR EACH ROW triggers, allocate cursors for the
156 ** special OLD and NEW tables
157 */
drhdca76842004-12-07 14:06:13 +0000158 if( triggers_exist ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000159 newIdx = pParse->nTab++;
160 oldIdx = pParse->nTab++;
161 }
162
drh53e3fc72002-07-16 17:22:50 +0000163 /* Allocate a cursors for the main database table and for all indices.
164 ** The index cursors might not be used, but if they are used they
165 ** need to occur right after the database cursor. So go ahead and
166 ** allocate enough space, just in case.
167 */
drh6a3ea0e2003-05-02 14:32:12 +0000168 pTabList->a[0].iCursor = iCur = pParse->nTab++;
drh53e3fc72002-07-16 17:22:50 +0000169 for(pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext){
170 pParse->nTab++;
171 }
172
danielk1977b3bce662005-01-29 08:32:43 +0000173 /* Initialize the name-context */
174 memset(&sNC, 0, sizeof(sNC));
175 sNC.pParse = pParse;
176 sNC.pSrcList = pTabList;
177
drh85e20962003-04-25 17:52:11 +0000178 /* Resolve the column names in all the expressions of the
179 ** of the UPDATE statement. Also find the column index
drhed6c8672003-01-12 18:02:16 +0000180 ** for each column to be updated in the pChanges array. For each
181 ** column to be updated, make sure we have authorization to change
182 ** that column.
drhcce7d172000-05-31 15:34:51 +0000183 */
drhf0863fe2005-06-12 21:35:51 +0000184 chngRowid = 0;
drhcce7d172000-05-31 15:34:51 +0000185 for(i=0; i<pChanges->nExpr; i++){
danielk1977b3bce662005-01-29 08:32:43 +0000186 if( sqlite3ExprResolveNames(&sNC, pChanges->a[i].pExpr) ){
drhcce7d172000-05-31 15:34:51 +0000187 goto update_cleanup;
188 }
189 for(j=0; j<pTab->nCol; j++){
danielk19774adee202004-05-08 08:23:19 +0000190 if( sqlite3StrICmp(pTab->aCol[j].zName, pChanges->a[i].zName)==0 ){
drh9647ff82002-01-14 02:56:24 +0000191 if( j==pTab->iPKey ){
drhf0863fe2005-06-12 21:35:51 +0000192 chngRowid = 1;
193 pRowidExpr = pChanges->a[i].pExpr;
drh4a324312001-12-21 14:30:42 +0000194 }
drhcce7d172000-05-31 15:34:51 +0000195 aXRef[j] = i;
196 break;
197 }
198 }
199 if( j>=pTab->nCol ){
danielk19774adee202004-05-08 08:23:19 +0000200 if( sqlite3IsRowid(pChanges->a[i].zName) ){
drhf0863fe2005-06-12 21:35:51 +0000201 chngRowid = 1;
202 pRowidExpr = pChanges->a[i].pExpr;
drha0217ba2003-06-01 01:10:33 +0000203 }else{
danielk19774adee202004-05-08 08:23:19 +0000204 sqlite3ErrorMsg(pParse, "no such column: %s", pChanges->a[i].zName);
drha0217ba2003-06-01 01:10:33 +0000205 goto update_cleanup;
206 }
drhcce7d172000-05-31 15:34:51 +0000207 }
drhed6c8672003-01-12 18:02:16 +0000208#ifndef SQLITE_OMIT_AUTHORIZATION
drhe5f9c642003-01-13 23:27:31 +0000209 {
210 int rc;
danielk19774adee202004-05-08 08:23:19 +0000211 rc = sqlite3AuthCheck(pParse, SQLITE_UPDATE, pTab->zName,
danielk1977da184232006-01-05 11:34:32 +0000212 pTab->aCol[j].zName, db->aDb[iDb].zName);
drhe5f9c642003-01-13 23:27:31 +0000213 if( rc==SQLITE_DENY ){
214 goto update_cleanup;
215 }else if( rc==SQLITE_IGNORE ){
216 aXRef[j] = -1;
217 }
drhed6c8672003-01-12 18:02:16 +0000218 }
219#endif
drhcce7d172000-05-31 15:34:51 +0000220 }
221
drh5a2c2c22001-11-21 02:21:11 +0000222 /* Allocate memory for the array apIdx[] and fill it with pointers to every
drhcce7d172000-05-31 15:34:51 +0000223 ** index that needs to be updated. Indices only need updating if their
drhc8392582001-12-31 02:48:51 +0000224 ** key includes one of the columns named in pChanges or if the record
225 ** number of the original table entry is changing.
drhcce7d172000-05-31 15:34:51 +0000226 */
drh0ca3e242002-01-29 23:07:02 +0000227 for(nIdx=nIdxTotal=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, nIdxTotal++){
drhf0863fe2005-06-12 21:35:51 +0000228 if( chngRowid ){
drh4a324312001-12-21 14:30:42 +0000229 i = 0;
230 }else {
231 for(i=0; i<pIdx->nColumn; i++){
232 if( aXRef[pIdx->aiColumn[i]]>=0 ) break;
233 }
drhcce7d172000-05-31 15:34:51 +0000234 }
drh967e8b72000-06-21 13:59:10 +0000235 if( i<pIdx->nColumn ) nIdx++;
drhcce7d172000-05-31 15:34:51 +0000236 }
drh0ca3e242002-01-29 23:07:02 +0000237 if( nIdxTotal>0 ){
drh17435752007-08-16 04:30:38 +0000238 apIdx = sqlite3DbMallocRaw(db, sizeof(Index*) * nIdx + nIdxTotal );
drhb0729502001-03-14 12:35:57 +0000239 if( apIdx==0 ) goto update_cleanup;
drh0ca3e242002-01-29 23:07:02 +0000240 aIdxUsed = (char*)&apIdx[nIdx];
drhb0729502001-03-14 12:35:57 +0000241 }
drh0ca3e242002-01-29 23:07:02 +0000242 for(nIdx=j=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, j++){
drhf0863fe2005-06-12 21:35:51 +0000243 if( chngRowid ){
drh4a324312001-12-21 14:30:42 +0000244 i = 0;
245 }else{
246 for(i=0; i<pIdx->nColumn; i++){
247 if( aXRef[pIdx->aiColumn[i]]>=0 ) break;
248 }
drhcce7d172000-05-31 15:34:51 +0000249 }
drh0ca3e242002-01-29 23:07:02 +0000250 if( i<pIdx->nColumn ){
251 apIdx[nIdx++] = pIdx;
252 aIdxUsed[j] = 1;
253 }else{
254 aIdxUsed[j] = 0;
255 }
drhcce7d172000-05-31 15:34:51 +0000256 }
257
258 /* Begin generating code.
259 */
danielk19774adee202004-05-08 08:23:19 +0000260 v = sqlite3GetVdbe(pParse);
drhcce7d172000-05-31 15:34:51 +0000261 if( v==0 ) goto update_cleanup;
drh4794f732004-11-05 17:17:50 +0000262 if( pParse->nested==0 ) sqlite3VdbeCountChanges(v);
danielk1977da184232006-01-05 11:34:32 +0000263 sqlite3BeginWriteOperation(pParse, 1, iDb);
drhcce7d172000-05-31 15:34:51 +0000264
drh9c419382006-06-16 21:13:21 +0000265#ifndef SQLITE_OMIT_VIRTUALTABLE
266 /* Virtual tables must be handled separately */
267 if( IsVirtual(pTab) ){
268 updateVirtualTable(pParse, pTabList, pTab, pChanges, pRowidExpr, aXRef,
269 pWhere);
270 pWhere = 0;
271 pTabList = 0;
272 goto update_cleanup;
273 }
274#endif
275
276 /* Resolve the column names in all the expressions in the
277 ** WHERE clause.
278 */
279 if( sqlite3ExprResolveNames(&sNC, pWhere) ){
280 goto update_cleanup;
281 }
282
danielk19774273dea2006-06-17 06:31:18 +0000283 /* Start the view context
284 */
285 if( isView ){
286 sqlite3AuthContextPush(pParse, &sContext, pTab->zName);
287 }
288
drh9d2985c2005-09-08 01:58:42 +0000289 /* If we are trying to update a view, realize that view into
290 ** a ephemeral table.
drh5cf590c2003-04-24 01:45:04 +0000291 */
292 if( isView ){
drh85e20962003-04-25 17:52:11 +0000293 Select *pView;
drh17435752007-08-16 04:30:38 +0000294 pView = sqlite3SelectDup(db, pTab->pSelect);
drhb9bb7c12006-06-11 23:41:55 +0000295 sqlite3Select(pParse, pView, SRT_EphemTab, iCur, 0, 0, 0, 0);
danielk19774adee202004-05-08 08:23:19 +0000296 sqlite3SelectDelete(pView);
drh5cf590c2003-04-24 01:45:04 +0000297 }
298
drhcce7d172000-05-31 15:34:51 +0000299 /* Begin the database scan
300 */
drhf8db1bc2005-04-22 02:38:37 +0000301 pWInfo = sqlite3WhereBegin(pParse, pTabList, pWhere, 0);
drhcce7d172000-05-31 15:34:51 +0000302 if( pWInfo==0 ) goto update_cleanup;
303
drh4cbdda92006-06-14 19:00:20 +0000304 /* Remember the rowid of every item to be updated.
drhcce7d172000-05-31 15:34:51 +0000305 */
drh4cbdda92006-06-14 19:00:20 +0000306 sqlite3VdbeAddOp(v, IsVirtual(pTab) ? OP_VRowid : OP_Rowid, iCur, 0);
drha01f79d2005-07-08 13:07:59 +0000307 sqlite3VdbeAddOp(v, OP_FifoWrite, 0, 0);
drhcce7d172000-05-31 15:34:51 +0000308
309 /* End the database scan loop.
310 */
danielk19774adee202004-05-08 08:23:19 +0000311 sqlite3WhereEnd(pWInfo);
drhcce7d172000-05-31 15:34:51 +0000312
drh1bee3d72001-10-15 00:44:35 +0000313 /* Initialize the count of updated rows
314 */
danielk1977c3f9bad2002-05-15 08:30:12 +0000315 if( db->flags & SQLITE_CountRows && !pParse->trigStack ){
drh53a67772007-02-07 01:06:52 +0000316 memCnt = pParse->nMem++;
317 sqlite3VdbeAddOp(v, OP_MemInt, 0, memCnt);
drh1bee3d72001-10-15 00:44:35 +0000318 }
319
drhdca76842004-12-07 14:06:13 +0000320 if( triggers_exist ){
drh70ce3f02003-04-15 19:22:22 +0000321 /* Create pseudo-tables for NEW and OLD
322 */
danielk19774adee202004-05-08 08:23:19 +0000323 sqlite3VdbeAddOp(v, OP_OpenPseudo, oldIdx, 0);
danielk197784ac9d02004-05-18 09:58:06 +0000324 sqlite3VdbeAddOp(v, OP_SetNumColumns, oldIdx, pTab->nCol);
danielk19774adee202004-05-08 08:23:19 +0000325 sqlite3VdbeAddOp(v, OP_OpenPseudo, newIdx, 0);
danielk197784ac9d02004-05-18 09:58:06 +0000326 sqlite3VdbeAddOp(v, OP_SetNumColumns, newIdx, pTab->nCol);
danielk1977c3f9bad2002-05-15 08:30:12 +0000327
drh70ce3f02003-04-15 19:22:22 +0000328 /* The top of the update loop for when there are triggers.
329 */
drha01f79d2005-07-08 13:07:59 +0000330 addr = sqlite3VdbeAddOp(v, OP_FifoRead, 0, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000331
drh5cf590c2003-04-24 01:45:04 +0000332 if( !isView ){
kweld5362732005-04-08 16:08:36 +0000333 sqlite3VdbeAddOp(v, OP_Dup, 0, 0);
334 sqlite3VdbeAddOp(v, OP_Dup, 0, 0);
335 /* Open a cursor and make it point to the record that is
336 ** being updated.
337 */
danielk1977c00da102006-01-07 13:21:04 +0000338 sqlite3OpenTable(pParse, iCur, iDb, pTab, OP_OpenRead);
drh5cf590c2003-04-24 01:45:04 +0000339 }
drh7cf6e4d2004-05-19 14:56:55 +0000340 sqlite3VdbeAddOp(v, OP_MoveGe, iCur, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000341
drh70ce3f02003-04-15 19:22:22 +0000342 /* Generate the OLD table
343 */
drhf0863fe2005-06-12 21:35:51 +0000344 sqlite3VdbeAddOp(v, OP_Rowid, iCur, 0);
danielk19774adee202004-05-08 08:23:19 +0000345 sqlite3VdbeAddOp(v, OP_RowData, iCur, 0);
drhf0863fe2005-06-12 21:35:51 +0000346 sqlite3VdbeAddOp(v, OP_Insert, oldIdx, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000347
drh70ce3f02003-04-15 19:22:22 +0000348 /* Generate the NEW table
349 */
drhf0863fe2005-06-12 21:35:51 +0000350 if( chngRowid ){
351 sqlite3ExprCodeAndCache(pParse, pRowidExpr);
drh70ce3f02003-04-15 19:22:22 +0000352 }else{
drhf0863fe2005-06-12 21:35:51 +0000353 sqlite3VdbeAddOp(v, OP_Rowid, iCur, 0);
drh70ce3f02003-04-15 19:22:22 +0000354 }
drh25303782004-12-07 15:41:48 +0000355 for(i=0; i<pTab->nCol; i++){
drh70ce3f02003-04-15 19:22:22 +0000356 if( i==pTab->iPKey ){
drhf0863fe2005-06-12 21:35:51 +0000357 sqlite3VdbeAddOp(v, OP_Null, 0, 0);
drh70ce3f02003-04-15 19:22:22 +0000358 continue;
359 }
360 j = aXRef[i];
361 if( j<0 ){
danielk19774adee202004-05-08 08:23:19 +0000362 sqlite3VdbeAddOp(v, OP_Column, iCur, i);
danielk1977aee18ef2005-03-09 12:26:50 +0000363 sqlite3ColumnDefault(v, pTab, i);
danielk1977c3f9bad2002-05-15 08:30:12 +0000364 }else{
drh25303782004-12-07 15:41:48 +0000365 sqlite3ExprCodeAndCache(pParse, pChanges->a[j].pExpr);
danielk1977c3f9bad2002-05-15 08:30:12 +0000366 }
367 }
danielk19774adee202004-05-08 08:23:19 +0000368 sqlite3VdbeAddOp(v, OP_MakeRecord, pTab->nCol, 0);
danielk1977a37cdde2004-05-16 11:15:36 +0000369 if( !isView ){
370 sqlite3TableAffinityStr(v, pTab);
371 }
372 if( pParse->nErr ) goto update_cleanup;
drhf0863fe2005-06-12 21:35:51 +0000373 sqlite3VdbeAddOp(v, OP_Insert, newIdx, 0);
drh5cf590c2003-04-24 01:45:04 +0000374 if( !isView ){
danielk19774adee202004-05-08 08:23:19 +0000375 sqlite3VdbeAddOp(v, OP_Close, iCur, 0);
drh5cf590c2003-04-24 01:45:04 +0000376 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000377
drh5cf590c2003-04-24 01:45:04 +0000378 /* Fire the BEFORE and INSTEAD OF triggers
drh70ce3f02003-04-15 19:22:22 +0000379 */
drhdca76842004-12-07 14:06:13 +0000380 if( sqlite3CodeRowTrigger(pParse, TK_UPDATE, pChanges, TRIGGER_BEFORE, pTab,
danielk19776f349032002-06-11 02:25:40 +0000381 newIdx, oldIdx, onError, addr) ){
danielk1977f29ce552002-05-19 23:43:12 +0000382 goto update_cleanup;
383 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000384 }
385
drh4cbdda92006-06-14 19:00:20 +0000386 if( !isView && !IsVirtual(pTab) ){
drh5cf590c2003-04-24 01:45:04 +0000387 /*
388 ** Open every index that needs updating. Note that if any
389 ** index could potentially invoke a REPLACE conflict resolution
390 ** action, then we need to open all indices because we might need
391 ** to be deleting some records.
392 */
danielk1977c00da102006-01-07 13:21:04 +0000393 sqlite3OpenTable(pParse, iCur, iDb, pTab, OP_OpenWrite);
drh5cf590c2003-04-24 01:45:04 +0000394 if( onError==OE_Replace ){
395 openAll = 1;
396 }else{
397 openAll = 0;
398 for(pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext){
399 if( pIdx->onError==OE_Replace ){
400 openAll = 1;
401 break;
402 }
drh0ca3e242002-01-29 23:07:02 +0000403 }
404 }
drh5cf590c2003-04-24 01:45:04 +0000405 for(i=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, i++){
406 if( openAll || aIdxUsed[i] ){
danielk1977b3bf5562006-01-10 17:58:23 +0000407 KeyInfo *pKey = sqlite3IndexKeyinfo(pParse, pIdx);
danielk1977da184232006-01-05 11:34:32 +0000408 sqlite3VdbeAddOp(v, OP_Integer, iDb, 0);
drhd3d39e92004-05-20 22:16:29 +0000409 sqlite3VdbeOp3(v, OP_OpenWrite, iCur+i+1, pIdx->tnum,
danielk1977b3bf5562006-01-10 17:58:23 +0000410 (char*)pKey, P3_KEYINFO_HANDOFF);
drh6a3ea0e2003-05-02 14:32:12 +0000411 assert( pParse->nTab>iCur+i+1 );
drh5cf590c2003-04-24 01:45:04 +0000412 }
drh0ca3e242002-01-29 23:07:02 +0000413 }
drhcce7d172000-05-31 15:34:51 +0000414
drh5cf590c2003-04-24 01:45:04 +0000415 /* Loop over every record that needs updating. We have to load
416 ** the old data for each record to be updated because some columns
417 ** might not change and we will need to copy the old value.
drh4cbdda92006-06-14 19:00:20 +0000418 ** Also, the old data is needed to delete the old index entries.
drh5cf590c2003-04-24 01:45:04 +0000419 ** So make the cursor point at the old record.
420 */
drhdca76842004-12-07 14:06:13 +0000421 if( !triggers_exist ){
drha01f79d2005-07-08 13:07:59 +0000422 addr = sqlite3VdbeAddOp(v, OP_FifoRead, 0, 0);
danielk19774adee202004-05-08 08:23:19 +0000423 sqlite3VdbeAddOp(v, OP_Dup, 0, 0);
drh4a324312001-12-21 14:30:42 +0000424 }
danielk19774adee202004-05-08 08:23:19 +0000425 sqlite3VdbeAddOp(v, OP_NotExists, iCur, addr);
drh5cf590c2003-04-24 01:45:04 +0000426
427 /* If the record number will change, push the record number as it
428 ** will be after the update. (The old record number is currently
429 ** on top of the stack.)
430 */
drhf0863fe2005-06-12 21:35:51 +0000431 if( chngRowid ){
432 sqlite3ExprCode(pParse, pRowidExpr);
danielk19774adee202004-05-08 08:23:19 +0000433 sqlite3VdbeAddOp(v, OP_MustBeInt, 0, 0);
drhcce7d172000-05-31 15:34:51 +0000434 }
drh5cf590c2003-04-24 01:45:04 +0000435
436 /* Compute new data for this record.
437 */
438 for(i=0; i<pTab->nCol; i++){
439 if( i==pTab->iPKey ){
drhf0863fe2005-06-12 21:35:51 +0000440 sqlite3VdbeAddOp(v, OP_Null, 0, 0);
drh5cf590c2003-04-24 01:45:04 +0000441 continue;
442 }
443 j = aXRef[i];
444 if( j<0 ){
danielk19774adee202004-05-08 08:23:19 +0000445 sqlite3VdbeAddOp(v, OP_Column, iCur, i);
danielk1977aee18ef2005-03-09 12:26:50 +0000446 sqlite3ColumnDefault(v, pTab, i);
drh5cf590c2003-04-24 01:45:04 +0000447 }else{
danielk19774adee202004-05-08 08:23:19 +0000448 sqlite3ExprCode(pParse, pChanges->a[j].pExpr);
drh5cf590c2003-04-24 01:45:04 +0000449 }
450 }
451
452 /* Do constraint checks
453 */
drhf0863fe2005-06-12 21:35:51 +0000454 sqlite3GenerateConstraintChecks(pParse, pTab, iCur, aIdxUsed, chngRowid, 1,
drh5cf590c2003-04-24 01:45:04 +0000455 onError, addr);
456
457 /* Delete the old indices for the current record.
458 */
drh74161702006-02-24 02:53:49 +0000459 sqlite3GenerateRowIndexDelete(v, pTab, iCur, aIdxUsed);
drh5cf590c2003-04-24 01:45:04 +0000460
461 /* If changing the record number, delete the old record.
462 */
drhf0863fe2005-06-12 21:35:51 +0000463 if( chngRowid ){
danielk19774adee202004-05-08 08:23:19 +0000464 sqlite3VdbeAddOp(v, OP_Delete, iCur, 0);
drh5cf590c2003-04-24 01:45:04 +0000465 }
466
467 /* Create the new index entries and the new record.
468 */
drhe4d90812007-03-29 05:51:49 +0000469 sqlite3CompleteInsertion(pParse, pTab, iCur, aIdxUsed, chngRowid, 1, -1, 0);
drhcce7d172000-05-31 15:34:51 +0000470 }
471
drh0ca3e242002-01-29 23:07:02 +0000472 /* Increment the row counter
drh1bee3d72001-10-15 00:44:35 +0000473 */
danielk1977c3f9bad2002-05-15 08:30:12 +0000474 if( db->flags & SQLITE_CountRows && !pParse->trigStack){
drh53a67772007-02-07 01:06:52 +0000475 sqlite3VdbeAddOp(v, OP_MemIncr, 1, memCnt);
drh1bee3d72001-10-15 00:44:35 +0000476 }
477
drh5cf590c2003-04-24 01:45:04 +0000478 /* If there are triggers, close all the cursors after each iteration
479 ** through the loop. The fire the after triggers.
480 */
drhdca76842004-12-07 14:06:13 +0000481 if( triggers_exist ){
drh5cf590c2003-04-24 01:45:04 +0000482 if( !isView ){
483 for(i=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, i++){
484 if( openAll || aIdxUsed[i] )
danielk19774adee202004-05-08 08:23:19 +0000485 sqlite3VdbeAddOp(v, OP_Close, iCur+i+1, 0);
drh5cf590c2003-04-24 01:45:04 +0000486 }
danielk19774adee202004-05-08 08:23:19 +0000487 sqlite3VdbeAddOp(v, OP_Close, iCur, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000488 }
drhdca76842004-12-07 14:06:13 +0000489 if( sqlite3CodeRowTrigger(pParse, TK_UPDATE, pChanges, TRIGGER_AFTER, pTab,
danielk19776f349032002-06-11 02:25:40 +0000490 newIdx, oldIdx, onError, addr) ){
danielk1977f29ce552002-05-19 23:43:12 +0000491 goto update_cleanup;
492 }
danielk1977c3f9bad2002-05-15 08:30:12 +0000493 }
494
drhcce7d172000-05-31 15:34:51 +0000495 /* Repeat the above with the next record to be updated, until
496 ** all record selected by the WHERE clause have been updated.
497 */
danielk19774adee202004-05-08 08:23:19 +0000498 sqlite3VdbeAddOp(v, OP_Goto, 0, addr);
drhd654be82005-09-20 17:42:23 +0000499 sqlite3VdbeJumpHere(v, addr);
danielk1977c3f9bad2002-05-15 08:30:12 +0000500
501 /* Close all tables if there were no FOR EACH ROW triggers */
drh9c419382006-06-16 21:13:21 +0000502 if( !triggers_exist ){
danielk1977c3f9bad2002-05-15 08:30:12 +0000503 for(i=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, i++){
504 if( openAll || aIdxUsed[i] ){
danielk19774adee202004-05-08 08:23:19 +0000505 sqlite3VdbeAddOp(v, OP_Close, iCur+i+1, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000506 }
507 }
danielk19774adee202004-05-08 08:23:19 +0000508 sqlite3VdbeAddOp(v, OP_Close, iCur, 0);
danielk1977f29ce552002-05-19 23:43:12 +0000509 }else{
danielk19774adee202004-05-08 08:23:19 +0000510 sqlite3VdbeAddOp(v, OP_Close, newIdx, 0);
511 sqlite3VdbeAddOp(v, OP_Close, oldIdx, 0);
danielk1977c3f9bad2002-05-15 08:30:12 +0000512 }
513
drh1bee3d72001-10-15 00:44:35 +0000514 /*
danielk1977e7de6f22004-11-05 06:02:06 +0000515 ** Return the number of rows that were changed. If this routine is
516 ** generating code because of a call to sqlite3NestedParse(), do not
517 ** invoke the callback function.
drh1bee3d72001-10-15 00:44:35 +0000518 */
danielk1977e7de6f22004-11-05 06:02:06 +0000519 if( db->flags & SQLITE_CountRows && !pParse->trigStack && pParse->nested==0 ){
drh53a67772007-02-07 01:06:52 +0000520 sqlite3VdbeAddOp(v, OP_MemLoad, memCnt, 0);
danielk19774adee202004-05-08 08:23:19 +0000521 sqlite3VdbeAddOp(v, OP_Callback, 1, 0);
danielk197722322fd2004-05-25 23:35:17 +0000522 sqlite3VdbeSetNumCols(v, 1);
danielk1977955de522006-02-10 02:27:42 +0000523 sqlite3VdbeSetColName(v, 0, COLNAME_NAME, "rows updated", P3_STATIC);
drh1bee3d72001-10-15 00:44:35 +0000524 }
525
drhcce7d172000-05-31 15:34:51 +0000526update_cleanup:
danielk19774adee202004-05-08 08:23:19 +0000527 sqlite3AuthContextPop(&sContext);
drh17435752007-08-16 04:30:38 +0000528 sqlite3_free(apIdx);
529 sqlite3_free(aXRef);
danielk19774adee202004-05-08 08:23:19 +0000530 sqlite3SrcListDelete(pTabList);
531 sqlite3ExprListDelete(pChanges);
532 sqlite3ExprDelete(pWhere);
drhcce7d172000-05-31 15:34:51 +0000533 return;
534}
drh9c419382006-06-16 21:13:21 +0000535
536#ifndef SQLITE_OMIT_VIRTUALTABLE
537/*
538** Generate code for an UPDATE of a virtual table.
539**
540** The strategy is that we create an ephemerial table that contains
541** for each row to be changed:
542**
543** (A) The original rowid of that row.
544** (B) The revised rowid for the row. (note1)
545** (C) The content of every column in the row.
546**
547** Then we loop over this ephemeral table and for each row in
548** the ephermeral table call VUpdate.
549**
550** When finished, drop the ephemeral table.
551**
552** (note1) Actually, if we know in advance that (A) is always the same
553** as (B) we only store (A), then duplicate (A) when pulling
554** it out of the ephemeral table before calling VUpdate.
555*/
556static void updateVirtualTable(
557 Parse *pParse, /* The parsing context */
558 SrcList *pSrc, /* The virtual table to be modified */
559 Table *pTab, /* The virtual table */
560 ExprList *pChanges, /* The columns to change in the UPDATE statement */
561 Expr *pRowid, /* Expression used to recompute the rowid */
562 int *aXRef, /* Mapping from columns of pTab to entries in pChanges */
563 Expr *pWhere /* WHERE clause of the UPDATE statement */
564){
565 Vdbe *v = pParse->pVdbe; /* Virtual machine under construction */
566 ExprList *pEList = 0; /* The result set of the SELECT statement */
567 Select *pSelect = 0; /* The SELECT statement */
568 Expr *pExpr; /* Temporary expression */
569 int ephemTab; /* Table holding the result of the SELECT */
570 int i; /* Loop counter */
571 int addr; /* Address of top of loop */
drh17435752007-08-16 04:30:38 +0000572 sqlite3 *db = pParse->db; /* Database connection */
drh9c419382006-06-16 21:13:21 +0000573
574 /* Construct the SELECT statement that will find the new values for
575 ** all updated rows.
576 */
drh17435752007-08-16 04:30:38 +0000577 pEList = sqlite3ExprListAppend(pParse, 0,
578 sqlite3CreateIdExpr(pParse, "_rowid_"), 0);
drh9c419382006-06-16 21:13:21 +0000579 if( pRowid ){
drh17435752007-08-16 04:30:38 +0000580 pEList = sqlite3ExprListAppend(pParse, pEList,
581 sqlite3ExprDup(db, pRowid), 0);
drh9c419382006-06-16 21:13:21 +0000582 }
danielk197765fd59f2006-06-24 11:51:33 +0000583 assert( pTab->iPKey<0 );
drh9c419382006-06-16 21:13:21 +0000584 for(i=0; i<pTab->nCol; i++){
danielk197765fd59f2006-06-24 11:51:33 +0000585 if( aXRef[i]>=0 ){
drh17435752007-08-16 04:30:38 +0000586 pExpr = sqlite3ExprDup(db, pChanges->a[aXRef[i]].pExpr);
drh9c419382006-06-16 21:13:21 +0000587 }else{
drh17435752007-08-16 04:30:38 +0000588 pExpr = sqlite3CreateIdExpr(pParse, pTab->aCol[i].zName);
drh9c419382006-06-16 21:13:21 +0000589 }
drh17435752007-08-16 04:30:38 +0000590 pEList = sqlite3ExprListAppend(pParse, pEList, pExpr, 0);
drh9c419382006-06-16 21:13:21 +0000591 }
drh17435752007-08-16 04:30:38 +0000592 pSelect = sqlite3SelectNew(pParse, pEList, pSrc, pWhere, 0, 0, 0, 0, 0, 0);
drh9c419382006-06-16 21:13:21 +0000593
594 /* Create the ephemeral table into which the update results will
595 ** be stored.
596 */
597 assert( v );
598 ephemTab = pParse->nTab++;
599 sqlite3VdbeAddOp(v, OP_OpenEphemeral, ephemTab, pTab->nCol+1+(pRowid!=0));
600
601 /* fill the ephemeral table
602 */
603 sqlite3Select(pParse, pSelect, SRT_Table, ephemTab, 0, 0, 0, 0);
604
605 /*
606 ** Generate code to scan the ephemeral table and call VDelete and
607 ** VInsert
608 */
danielk197707fd0592007-02-21 17:04:04 +0000609 sqlite3VdbeAddOp(v, OP_Rewind, ephemTab, 0);
drh9c419382006-06-16 21:13:21 +0000610 addr = sqlite3VdbeCurrentAddr(v);
611 sqlite3VdbeAddOp(v, OP_Column, ephemTab, 0);
612 if( pRowid ){
613 sqlite3VdbeAddOp(v, OP_Column, ephemTab, 1);
614 }else{
danielk19772867fef2006-06-17 03:27:21 +0000615 sqlite3VdbeAddOp(v, OP_Dup, 0, 0);
drh9c419382006-06-16 21:13:21 +0000616 }
617 for(i=0; i<pTab->nCol; i++){
618 sqlite3VdbeAddOp(v, OP_Column, ephemTab, i+1+(pRowid!=0));
619 }
danielk1977c69cdfd2006-06-17 09:39:55 +0000620 pParse->pVirtualLock = pTab;
drh9c419382006-06-16 21:13:21 +0000621 sqlite3VdbeOp3(v, OP_VUpdate, 0, pTab->nCol+2,
622 (const char*)pTab->pVtab, P3_VTAB);
623 sqlite3VdbeAddOp(v, OP_Next, ephemTab, addr);
danielk197707fd0592007-02-21 17:04:04 +0000624 sqlite3VdbeJumpHere(v, addr-1);
drh9c419382006-06-16 21:13:21 +0000625 sqlite3VdbeAddOp(v, OP_Close, ephemTab, 0);
626
627 /* Cleanup */
628 sqlite3SelectDelete(pSelect);
629}
630#endif /* SQLITE_OMIT_VIRTUALTABLE */