| OLD | NEW |
| 1 /* | 1 /* |
| 2 ** 2001 September 15 | 2 ** 2001 September 15 |
| 3 ** | 3 ** |
| 4 ** The author disclaims copyright to this source code. In place of | 4 ** The author disclaims copyright to this source code. In place of |
| 5 ** a legal notice, here is a blessing: | 5 ** a legal notice, here is a blessing: |
| 6 ** | 6 ** |
| 7 ** May you do good and not evil. | 7 ** May you do good and not evil. |
| 8 ** May you find forgiveness for yourself and forgive others. | 8 ** May you find forgiveness for yourself and forgive others. |
| 9 ** May you share freely, never taking more than you give. | 9 ** May you share freely, never taking more than you give. |
| 10 ** | 10 ** |
| 11 ************************************************************************* | 11 ************************************************************************* |
| 12 ** This file contains C code routines that are called by the parser | 12 ** This file contains C code routines that are called by the parser |
| 13 ** to handle INSERT statements in SQLite. | 13 ** to handle INSERT statements in SQLite. |
| 14 ** | |
| 15 ** $Id: insert.c,v 1.270 2009/07/24 17:58:53 danielk1977 Exp $ | |
| 16 */ | 14 */ |
| 17 #include "sqliteInt.h" | 15 #include "sqliteInt.h" |
| 18 | 16 |
| 19 /* | 17 /* |
| 20 ** Generate code that will open a table for reading. | 18 ** Generate code that will open a table for reading. |
| 21 */ | 19 */ |
| 22 void sqlite3OpenTable( | 20 void sqlite3OpenTable( |
| 23 Parse *p, /* Generate code into this VDBE */ | 21 Parse *p, /* Generate code into this VDBE */ |
| 24 int iCur, /* The cursor number of the table */ | 22 int iCur, /* The cursor number of the table */ |
| 25 int iDb, /* The database index in sqlite3.aDb[] */ | 23 int iDb, /* The database index in sqlite3.aDb[] */ |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 ** required, it is allocated and populated here. It is then stored as | 60 ** required, it is allocated and populated here. It is then stored as |
| 63 ** a member of the Index structure for subsequent use. | 61 ** a member of the Index structure for subsequent use. |
| 64 ** | 62 ** |
| 65 ** The column affinity string will eventually be deleted by | 63 ** The column affinity string will eventually be deleted by |
| 66 ** sqliteDeleteIndex() when the Index structure itself is cleaned | 64 ** sqliteDeleteIndex() when the Index structure itself is cleaned |
| 67 ** up. | 65 ** up. |
| 68 */ | 66 */ |
| 69 int n; | 67 int n; |
| 70 Table *pTab = pIdx->pTable; | 68 Table *pTab = pIdx->pTable; |
| 71 sqlite3 *db = sqlite3VdbeDb(v); | 69 sqlite3 *db = sqlite3VdbeDb(v); |
| 72 pIdx->zColAff = (char *)sqlite3Malloc(pIdx->nColumn+2); | 70 pIdx->zColAff = (char *)sqlite3DbMallocRaw(0, pIdx->nColumn+2); |
| 73 if( !pIdx->zColAff ){ | 71 if( !pIdx->zColAff ){ |
| 74 db->mallocFailed = 1; | 72 db->mallocFailed = 1; |
| 75 return 0; | 73 return 0; |
| 76 } | 74 } |
| 77 for(n=0; n<pIdx->nColumn; n++){ | 75 for(n=0; n<pIdx->nColumn; n++){ |
| 78 pIdx->zColAff[n] = pTab->aCol[pIdx->aiColumn[n]].affinity; | 76 pIdx->zColAff[n] = pTab->aCol[pIdx->aiColumn[n]].affinity; |
| 79 } | 77 } |
| 80 pIdx->zColAff[n++] = SQLITE_AFF_NONE; | 78 pIdx->zColAff[n++] = SQLITE_AFF_NONE; |
| 81 pIdx->zColAff[n] = 0; | 79 pIdx->zColAff[n] = 0; |
| 82 } | 80 } |
| (...skipping 21 matching lines...) Expand all Loading... |
| 104 ** stored as a member of the Table structure for subsequent use. | 102 ** stored as a member of the Table structure for subsequent use. |
| 105 ** | 103 ** |
| 106 ** The column affinity string will eventually be deleted by | 104 ** The column affinity string will eventually be deleted by |
| 107 ** sqlite3DeleteTable() when the Table structure itself is cleaned up. | 105 ** sqlite3DeleteTable() when the Table structure itself is cleaned up. |
| 108 */ | 106 */ |
| 109 if( !pTab->zColAff ){ | 107 if( !pTab->zColAff ){ |
| 110 char *zColAff; | 108 char *zColAff; |
| 111 int i; | 109 int i; |
| 112 sqlite3 *db = sqlite3VdbeDb(v); | 110 sqlite3 *db = sqlite3VdbeDb(v); |
| 113 | 111 |
| 114 zColAff = (char *)sqlite3Malloc(pTab->nCol+1); | 112 zColAff = (char *)sqlite3DbMallocRaw(0, pTab->nCol+1); |
| 115 if( !zColAff ){ | 113 if( !zColAff ){ |
| 116 db->mallocFailed = 1; | 114 db->mallocFailed = 1; |
| 117 return; | 115 return; |
| 118 } | 116 } |
| 119 | 117 |
| 120 for(i=0; i<pTab->nCol; i++){ | 118 for(i=0; i<pTab->nCol; i++){ |
| 121 zColAff[i] = pTab->aCol[i].affinity; | 119 zColAff[i] = pTab->aCol[i].affinity; |
| 122 } | 120 } |
| 123 zColAff[pTab->nCol] = '\0'; | 121 zColAff[pTab->nCol] = '\0'; |
| 124 | 122 |
| 125 pTab->zColAff = zColAff; | 123 pTab->zColAff = zColAff; |
| 126 } | 124 } |
| 127 | 125 |
| 128 sqlite3VdbeChangeP4(v, -1, pTab->zColAff, 0); | 126 sqlite3VdbeChangeP4(v, -1, pTab->zColAff, P4_TRANSIENT); |
| 129 } | 127 } |
| 130 | 128 |
| 131 /* | 129 /* |
| 132 ** Return non-zero if the table pTab in database iDb or any of its indices | 130 ** Return non-zero if the table pTab in database iDb or any of its indices |
| 133 ** have been opened at any point in the VDBE program beginning at location | 131 ** have been opened at any point in the VDBE program beginning at location |
| 134 ** iStartAddr throught the end of the program. This is used to see if | 132 ** iStartAddr throught the end of the program. This is used to see if |
| 135 ** a statement of the form "INSERT INTO <iDb, pTab> SELECT ..." can | 133 ** a statement of the form "INSERT INTO <iDb, pTab> SELECT ..." can |
| 136 ** run without using temporary table for the results of the SELECT. | 134 ** run without using temporary table for the results of the SELECT. |
| 137 */ | 135 */ |
| 138 static int readsTable(Parse *p, int iStartAddr, int iDb, Table *pTab){ | 136 static int readsTable(Parse *p, int iStartAddr, int iDb, Table *pTab){ |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 232 | 230 |
| 233 /* This routine is never called during trigger-generation. It is | 231 /* This routine is never called during trigger-generation. It is |
| 234 ** only called from the top-level */ | 232 ** only called from the top-level */ |
| 235 assert( pParse->pTriggerTab==0 ); | 233 assert( pParse->pTriggerTab==0 ); |
| 236 assert( pParse==sqlite3ParseToplevel(pParse) ); | 234 assert( pParse==sqlite3ParseToplevel(pParse) ); |
| 237 | 235 |
| 238 assert( v ); /* We failed long ago if this is not so */ | 236 assert( v ); /* We failed long ago if this is not so */ |
| 239 for(p = pParse->pAinc; p; p = p->pNext){ | 237 for(p = pParse->pAinc; p; p = p->pNext){ |
| 240 pDb = &db->aDb[p->iDb]; | 238 pDb = &db->aDb[p->iDb]; |
| 241 memId = p->regCtr; | 239 memId = p->regCtr; |
| 240 assert( sqlite3SchemaMutexHeld(db, 0, pDb->pSchema) ); |
| 242 sqlite3OpenTable(pParse, 0, p->iDb, pDb->pSchema->pSeqTab, OP_OpenRead); | 241 sqlite3OpenTable(pParse, 0, p->iDb, pDb->pSchema->pSeqTab, OP_OpenRead); |
| 243 addr = sqlite3VdbeCurrentAddr(v); | 242 addr = sqlite3VdbeCurrentAddr(v); |
| 244 sqlite3VdbeAddOp4(v, OP_String8, 0, memId-1, 0, p->pTab->zName, 0); | 243 sqlite3VdbeAddOp4(v, OP_String8, 0, memId-1, 0, p->pTab->zName, 0); |
| 245 sqlite3VdbeAddOp2(v, OP_Rewind, 0, addr+9); | 244 sqlite3VdbeAddOp2(v, OP_Rewind, 0, addr+9); |
| 246 sqlite3VdbeAddOp3(v, OP_Column, 0, 0, memId); | 245 sqlite3VdbeAddOp3(v, OP_Column, 0, 0, memId); |
| 247 sqlite3VdbeAddOp3(v, OP_Ne, memId-1, addr+7, memId); | 246 sqlite3VdbeAddOp3(v, OP_Ne, memId-1, addr+7, memId); |
| 248 sqlite3VdbeChangeP5(v, SQLITE_JUMPIFNULL); | 247 sqlite3VdbeChangeP5(v, SQLITE_JUMPIFNULL); |
| 249 sqlite3VdbeAddOp2(v, OP_Rowid, 0, memId+1); | 248 sqlite3VdbeAddOp2(v, OP_Rowid, 0, memId+1); |
| 250 sqlite3VdbeAddOp3(v, OP_Column, 0, 1, memId); | 249 sqlite3VdbeAddOp3(v, OP_Column, 0, 1, memId); |
| 251 sqlite3VdbeAddOp2(v, OP_Goto, 0, addr+9); | 250 sqlite3VdbeAddOp2(v, OP_Goto, 0, addr+9); |
| (...skipping 30 matching lines...) Expand all Loading... |
| 282 sqlite3 *db = pParse->db; | 281 sqlite3 *db = pParse->db; |
| 283 | 282 |
| 284 assert( v ); | 283 assert( v ); |
| 285 for(p = pParse->pAinc; p; p = p->pNext){ | 284 for(p = pParse->pAinc; p; p = p->pNext){ |
| 286 Db *pDb = &db->aDb[p->iDb]; | 285 Db *pDb = &db->aDb[p->iDb]; |
| 287 int j1, j2, j3, j4, j5; | 286 int j1, j2, j3, j4, j5; |
| 288 int iRec; | 287 int iRec; |
| 289 int memId = p->regCtr; | 288 int memId = p->regCtr; |
| 290 | 289 |
| 291 iRec = sqlite3GetTempReg(pParse); | 290 iRec = sqlite3GetTempReg(pParse); |
| 291 assert( sqlite3SchemaMutexHeld(db, 0, pDb->pSchema) ); |
| 292 sqlite3OpenTable(pParse, 0, p->iDb, pDb->pSchema->pSeqTab, OP_OpenWrite); | 292 sqlite3OpenTable(pParse, 0, p->iDb, pDb->pSchema->pSeqTab, OP_OpenWrite); |
| 293 j1 = sqlite3VdbeAddOp1(v, OP_NotNull, memId+1); | 293 j1 = sqlite3VdbeAddOp1(v, OP_NotNull, memId+1); |
| 294 j2 = sqlite3VdbeAddOp0(v, OP_Rewind); | 294 j2 = sqlite3VdbeAddOp0(v, OP_Rewind); |
| 295 j3 = sqlite3VdbeAddOp3(v, OP_Column, 0, 0, iRec); | 295 j3 = sqlite3VdbeAddOp3(v, OP_Column, 0, 0, iRec); |
| 296 j4 = sqlite3VdbeAddOp3(v, OP_Eq, memId-1, 0, iRec); | 296 j4 = sqlite3VdbeAddOp3(v, OP_Eq, memId-1, 0, iRec); |
| 297 sqlite3VdbeAddOp2(v, OP_Next, 0, j3); | 297 sqlite3VdbeAddOp2(v, OP_Next, 0, j3); |
| 298 sqlite3VdbeJumpHere(v, j2); | 298 sqlite3VdbeJumpHere(v, j2); |
| 299 sqlite3VdbeAddOp2(v, OP_NewRowid, 0, memId+1); | 299 sqlite3VdbeAddOp2(v, OP_NewRowid, 0, memId+1); |
| 300 j5 = sqlite3VdbeAddOp0(v, OP_Goto); | 300 j5 = sqlite3VdbeAddOp0(v, OP_Goto); |
| 301 sqlite3VdbeJumpHere(v, j4); | 301 sqlite3VdbeJumpHere(v, j4); |
| (...skipping 158 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 460 Db *pDb; /* The database containing table being inserted into */ | 460 Db *pDb; /* The database containing table being inserted into */ |
| 461 int appendFlag = 0; /* True if the insert is likely to be an append */ | 461 int appendFlag = 0; /* True if the insert is likely to be an append */ |
| 462 | 462 |
| 463 /* Register allocations */ | 463 /* Register allocations */ |
| 464 int regFromSelect = 0;/* Base register for data coming from SELECT */ | 464 int regFromSelect = 0;/* Base register for data coming from SELECT */ |
| 465 int regAutoinc = 0; /* Register holding the AUTOINCREMENT counter */ | 465 int regAutoinc = 0; /* Register holding the AUTOINCREMENT counter */ |
| 466 int regRowCount = 0; /* Memory cell used for the row counter */ | 466 int regRowCount = 0; /* Memory cell used for the row counter */ |
| 467 int regIns; /* Block of regs holding rowid+data being inserted */ | 467 int regIns; /* Block of regs holding rowid+data being inserted */ |
| 468 int regRowid; /* registers holding insert rowid */ | 468 int regRowid; /* registers holding insert rowid */ |
| 469 int regData; /* register holding first column to insert */ | 469 int regData; /* register holding first column to insert */ |
| 470 int regRecord; /* Holds the assemblied row record */ | |
| 471 int regEof = 0; /* Register recording end of SELECT data */ | 470 int regEof = 0; /* Register recording end of SELECT data */ |
| 472 int *aRegIdx = 0; /* One register allocated to each index */ | 471 int *aRegIdx = 0; /* One register allocated to each index */ |
| 473 | 472 |
| 474 #ifndef SQLITE_OMIT_TRIGGER | 473 #ifndef SQLITE_OMIT_TRIGGER |
| 475 int isView; /* True if attempting to insert into a view */ | 474 int isView; /* True if attempting to insert into a view */ |
| 476 Trigger *pTrigger; /* List of triggers on pTab, if required */ | 475 Trigger *pTrigger; /* List of triggers on pTab, if required */ |
| 477 int tmask; /* Mask of trigger times */ | 476 int tmask; /* Mask of trigger times */ |
| 478 #endif | 477 #endif |
| 479 | 478 |
| 480 db = pParse->db; | 479 db = pParse->db; |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 722 } | 721 } |
| 723 break; | 722 break; |
| 724 } | 723 } |
| 725 } | 724 } |
| 726 if( j>=pTab->nCol ){ | 725 if( j>=pTab->nCol ){ |
| 727 if( sqlite3IsRowid(pColumn->a[i].zName) ){ | 726 if( sqlite3IsRowid(pColumn->a[i].zName) ){ |
| 728 keyColumn = i; | 727 keyColumn = i; |
| 729 }else{ | 728 }else{ |
| 730 sqlite3ErrorMsg(pParse, "table %S has no column named %s", | 729 sqlite3ErrorMsg(pParse, "table %S has no column named %s", |
| 731 pTabList, 0, pColumn->a[i].zName); | 730 pTabList, 0, pColumn->a[i].zName); |
| 732 pParse->nErr++; | 731 pParse->checkSchema = 1; |
| 733 goto insert_cleanup; | 732 goto insert_cleanup; |
| 734 } | 733 } |
| 735 } | 734 } |
| 736 } | 735 } |
| 737 } | 736 } |
| 738 | 737 |
| 739 /* If there is no IDLIST term but the table has an integer primary | 738 /* If there is no IDLIST term but the table has an integer primary |
| 740 ** key, the set the keyColumn variable to the primary key column index | 739 ** key, the set the keyColumn variable to the primary key column index |
| 741 ** in the original table definition. | 740 ** in the original table definition. |
| 742 */ | 741 */ |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 789 ** goto C | 788 ** goto C |
| 790 ** D: ... | 789 ** D: ... |
| 791 */ | 790 */ |
| 792 addrCont = sqlite3VdbeAddOp1(v, OP_Yield, dest.iParm); | 791 addrCont = sqlite3VdbeAddOp1(v, OP_Yield, dest.iParm); |
| 793 addrInsTop = sqlite3VdbeAddOp1(v, OP_If, regEof); | 792 addrInsTop = sqlite3VdbeAddOp1(v, OP_If, regEof); |
| 794 } | 793 } |
| 795 | 794 |
| 796 /* Allocate registers for holding the rowid of the new row, | 795 /* Allocate registers for holding the rowid of the new row, |
| 797 ** the content of the new row, and the assemblied row record. | 796 ** the content of the new row, and the assemblied row record. |
| 798 */ | 797 */ |
| 799 regRecord = ++pParse->nMem; | |
| 800 regRowid = regIns = pParse->nMem+1; | 798 regRowid = regIns = pParse->nMem+1; |
| 801 pParse->nMem += pTab->nCol + 1; | 799 pParse->nMem += pTab->nCol + 1; |
| 802 if( IsVirtual(pTab) ){ | 800 if( IsVirtual(pTab) ){ |
| 803 regRowid++; | 801 regRowid++; |
| 804 pParse->nMem++; | 802 pParse->nMem++; |
| 805 } | 803 } |
| 806 regData = regRowid+1; | 804 regData = regRowid+1; |
| 807 | 805 |
| 808 /* Run the BEFORE and INSTEAD OF triggers, if there are any | 806 /* Run the BEFORE and INSTEAD OF triggers, if there are any |
| 809 */ | 807 */ |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 841 /* Create the new column data | 839 /* Create the new column data |
| 842 */ | 840 */ |
| 843 for(i=0; i<pTab->nCol; i++){ | 841 for(i=0; i<pTab->nCol; i++){ |
| 844 if( pColumn==0 ){ | 842 if( pColumn==0 ){ |
| 845 j = i; | 843 j = i; |
| 846 }else{ | 844 }else{ |
| 847 for(j=0; j<pColumn->nId; j++){ | 845 for(j=0; j<pColumn->nId; j++){ |
| 848 if( pColumn->a[j].idx==i ) break; | 846 if( pColumn->a[j].idx==i ) break; |
| 849 } | 847 } |
| 850 } | 848 } |
| 851 if( pColumn && j>=pColumn->nId ){ | 849 if( (!useTempTable && !pList) || (pColumn && j>=pColumn->nId) ){ |
| 852 sqlite3ExprCode(pParse, pTab->aCol[i].pDflt, regCols+i+1); | 850 sqlite3ExprCode(pParse, pTab->aCol[i].pDflt, regCols+i+1); |
| 853 }else if( useTempTable ){ | 851 }else if( useTempTable ){ |
| 854 sqlite3VdbeAddOp3(v, OP_Column, srcTab, j, regCols+i+1); | 852 sqlite3VdbeAddOp3(v, OP_Column, srcTab, j, regCols+i+1); |
| 855 }else{ | 853 }else{ |
| 856 assert( pSelect==0 ); /* Otherwise useTempTable is true */ | 854 assert( pSelect==0 ); /* Otherwise useTempTable is true */ |
| 857 sqlite3ExprCodeAndCache(pParse, pList->a[j].pExpr, regCols+i+1); | 855 sqlite3ExprCodeAndCache(pParse, pList->a[j].pExpr, regCols+i+1); |
| 858 } | 856 } |
| 859 } | 857 } |
| 860 | 858 |
| 861 /* If this is an INSERT on a view with an INSTEAD OF INSERT trigger, | 859 /* If this is an INSERT on a view with an INSTEAD OF INSERT trigger, |
| 862 ** do not attempt any conversions before assembling the record. | 860 ** do not attempt any conversions before assembling the record. |
| 863 ** If this is a real table, attempt conversions as required by the | 861 ** If this is a real table, attempt conversions as required by the |
| 864 ** table column affinities. | 862 ** table column affinities. |
| 865 */ | 863 */ |
| 866 if( !isView ){ | 864 if( !isView ){ |
| 867 sqlite3VdbeAddOp2(v, OP_Affinity, regCols+1, pTab->nCol); | 865 sqlite3VdbeAddOp2(v, OP_Affinity, regCols+1, pTab->nCol); |
| 868 sqlite3TableAffinityStr(v, pTab); | 866 sqlite3TableAffinityStr(v, pTab); |
| 869 } | 867 } |
| 870 | 868 |
| 871 /* Fire BEFORE or INSTEAD OF triggers */ | 869 /* Fire BEFORE or INSTEAD OF triggers */ |
| 872 sqlite3CodeRowTrigger(pParse, pTrigger, TK_INSERT, 0, TRIGGER_BEFORE, | 870 sqlite3CodeRowTrigger(pParse, pTrigger, TK_INSERT, 0, TRIGGER_BEFORE, |
| 873 pTab, -1, regCols-pTab->nCol-1, onError, endOfLoop); | 871 pTab, regCols-pTab->nCol-1, onError, endOfLoop); |
| 874 | 872 |
| 875 sqlite3ReleaseTempRange(pParse, regCols, pTab->nCol+1); | 873 sqlite3ReleaseTempRange(pParse, regCols, pTab->nCol+1); |
| 876 } | 874 } |
| 877 | 875 |
| 878 /* Push the record number for the new entry onto the stack. The | 876 /* Push the record number for the new entry onto the stack. The |
| 879 ** record number is a randomly generate integer created by NewRowid | 877 ** record number is a randomly generate integer created by NewRowid |
| 880 ** except when the table has an INTEGER PRIMARY KEY column, in which | 878 ** except when the table has an INTEGER PRIMARY KEY column, in which |
| 881 ** case the record number is the same as that column. | 879 ** case the record number is the same as that column. |
| 882 */ | 880 */ |
| 883 if( !isView ){ | 881 if( !isView ){ |
| (...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 972 sqlite3VtabMakeWritable(pParse, pTab); | 970 sqlite3VtabMakeWritable(pParse, pTab); |
| 973 sqlite3VdbeAddOp4(v, OP_VUpdate, 1, pTab->nCol+2, regIns, pVTab, P4_VTAB); | 971 sqlite3VdbeAddOp4(v, OP_VUpdate, 1, pTab->nCol+2, regIns, pVTab, P4_VTAB); |
| 974 sqlite3MayAbort(pParse); | 972 sqlite3MayAbort(pParse); |
| 975 }else | 973 }else |
| 976 #endif | 974 #endif |
| 977 { | 975 { |
| 978 int isReplace; /* Set to true if constraints may cause a replace */ | 976 int isReplace; /* Set to true if constraints may cause a replace */ |
| 979 sqlite3GenerateConstraintChecks(pParse, pTab, baseCur, regIns, aRegIdx, | 977 sqlite3GenerateConstraintChecks(pParse, pTab, baseCur, regIns, aRegIdx, |
| 980 keyColumn>=0, 0, onError, endOfLoop, &isReplace | 978 keyColumn>=0, 0, onError, endOfLoop, &isReplace |
| 981 ); | 979 ); |
| 980 sqlite3FkCheck(pParse, pTab, 0, regIns); |
| 982 sqlite3CompleteInsertion( | 981 sqlite3CompleteInsertion( |
| 983 pParse, pTab, baseCur, regIns, aRegIdx, 0, appendFlag, isReplace==0 | 982 pParse, pTab, baseCur, regIns, aRegIdx, 0, appendFlag, isReplace==0 |
| 984 ); | 983 ); |
| 985 } | 984 } |
| 986 } | 985 } |
| 987 | 986 |
| 988 /* Update the count of rows that are inserted | 987 /* Update the count of rows that are inserted |
| 989 */ | 988 */ |
| 990 if( (db->flags & SQLITE_CountRows)!=0 ){ | 989 if( (db->flags & SQLITE_CountRows)!=0 ){ |
| 991 sqlite3VdbeAddOp2(v, OP_AddImm, regRowCount, 1); | 990 sqlite3VdbeAddOp2(v, OP_AddImm, regRowCount, 1); |
| 992 } | 991 } |
| 993 | 992 |
| 994 if( pTrigger ){ | 993 if( pTrigger ){ |
| 995 /* Code AFTER triggers */ | 994 /* Code AFTER triggers */ |
| 996 sqlite3CodeRowTrigger(pParse, pTrigger, TK_INSERT, 0, TRIGGER_AFTER, | 995 sqlite3CodeRowTrigger(pParse, pTrigger, TK_INSERT, 0, TRIGGER_AFTER, |
| 997 pTab, -1, regData-2-pTab->nCol, onError, endOfLoop); | 996 pTab, regData-2-pTab->nCol, onError, endOfLoop); |
| 998 } | 997 } |
| 999 | 998 |
| 1000 /* The bottom of the main insertion loop, if the data source | 999 /* The bottom of the main insertion loop, if the data source |
| 1001 ** is a SELECT statement. | 1000 ** is a SELECT statement. |
| 1002 */ | 1001 */ |
| 1003 sqlite3VdbeResolveLabel(v, endOfLoop); | 1002 sqlite3VdbeResolveLabel(v, endOfLoop); |
| 1004 if( useTempTable ){ | 1003 if( useTempTable ){ |
| 1005 sqlite3VdbeAddOp2(v, OP_Next, srcTab, addrCont); | 1004 sqlite3VdbeAddOp2(v, OP_Next, srcTab, addrCont); |
| 1006 sqlite3VdbeJumpHere(v, addrInsTop); | 1005 sqlite3VdbeJumpHere(v, addrInsTop); |
| 1007 sqlite3VdbeAddOp1(v, OP_Close, srcTab); | 1006 sqlite3VdbeAddOp1(v, OP_Close, srcTab); |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1039 } | 1038 } |
| 1040 | 1039 |
| 1041 insert_cleanup: | 1040 insert_cleanup: |
| 1042 sqlite3SrcListDelete(db, pTabList); | 1041 sqlite3SrcListDelete(db, pTabList); |
| 1043 sqlite3ExprListDelete(db, pList); | 1042 sqlite3ExprListDelete(db, pList); |
| 1044 sqlite3SelectDelete(db, pSelect); | 1043 sqlite3SelectDelete(db, pSelect); |
| 1045 sqlite3IdListDelete(db, pColumn); | 1044 sqlite3IdListDelete(db, pColumn); |
| 1046 sqlite3DbFree(db, aRegIdx); | 1045 sqlite3DbFree(db, aRegIdx); |
| 1047 } | 1046 } |
| 1048 | 1047 |
| 1048 /* Make sure "isView" and other macros defined above are undefined. Otherwise |
| 1049 ** thely may interfere with compilation of other functions in this file |
| 1050 ** (or in another file, if this file becomes part of the amalgamation). */ |
| 1051 #ifdef isView |
| 1052 #undef isView |
| 1053 #endif |
| 1054 #ifdef pTrigger |
| 1055 #undef pTrigger |
| 1056 #endif |
| 1057 #ifdef tmask |
| 1058 #undef tmask |
| 1059 #endif |
| 1060 |
| 1061 |
| 1049 /* | 1062 /* |
| 1050 ** Generate code to do constraint checks prior to an INSERT or an UPDATE. | 1063 ** Generate code to do constraint checks prior to an INSERT or an UPDATE. |
| 1051 ** | 1064 ** |
| 1052 ** The input is a range of consecutive registers as follows: | 1065 ** The input is a range of consecutive registers as follows: |
| 1053 ** | 1066 ** |
| 1054 ** 1. The rowid of the row after the update. | 1067 ** 1. The rowid of the row after the update. |
| 1055 ** | 1068 ** |
| 1056 ** 2. The data in the first column of the entry after the update. | 1069 ** 2. The data in the first column of the entry after the update. |
| 1057 ** | 1070 ** |
| 1058 ** i. Data from middle columns... | 1071 ** i. Data from middle columns... |
| (...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1168 onError = OE_Abort; | 1181 onError = OE_Abort; |
| 1169 } | 1182 } |
| 1170 assert( onError==OE_Rollback || onError==OE_Abort || onError==OE_Fail | 1183 assert( onError==OE_Rollback || onError==OE_Abort || onError==OE_Fail |
| 1171 || onError==OE_Ignore || onError==OE_Replace ); | 1184 || onError==OE_Ignore || onError==OE_Replace ); |
| 1172 switch( onError ){ | 1185 switch( onError ){ |
| 1173 case OE_Abort: | 1186 case OE_Abort: |
| 1174 sqlite3MayAbort(pParse); | 1187 sqlite3MayAbort(pParse); |
| 1175 case OE_Rollback: | 1188 case OE_Rollback: |
| 1176 case OE_Fail: { | 1189 case OE_Fail: { |
| 1177 char *zMsg; | 1190 char *zMsg; |
| 1178 j1 = sqlite3VdbeAddOp3(v, OP_HaltIfNull, | 1191 sqlite3VdbeAddOp3(v, OP_HaltIfNull, |
| 1179 SQLITE_CONSTRAINT, onError, regData+i); | 1192 SQLITE_CONSTRAINT, onError, regData+i); |
| 1180 zMsg = sqlite3MPrintf(pParse->db, "%s.%s may not be NULL", | 1193 zMsg = sqlite3MPrintf(pParse->db, "%s.%s may not be NULL", |
| 1181 pTab->zName, pTab->aCol[i].zName); | 1194 pTab->zName, pTab->aCol[i].zName); |
| 1182 sqlite3VdbeChangeP4(v, -1, zMsg, P4_DYNAMIC); | 1195 sqlite3VdbeChangeP4(v, -1, zMsg, P4_DYNAMIC); |
| 1183 break; | 1196 break; |
| 1184 } | 1197 } |
| 1185 case OE_Ignore: { | 1198 case OE_Ignore: { |
| 1186 sqlite3VdbeAddOp2(v, OP_IsNull, regData+i, ignoreDest); | 1199 sqlite3VdbeAddOp2(v, OP_IsNull, regData+i, ignoreDest); |
| 1187 break; | 1200 break; |
| 1188 } | 1201 } |
| (...skipping 11 matching lines...) Expand all Loading... |
| 1200 */ | 1213 */ |
| 1201 #ifndef SQLITE_OMIT_CHECK | 1214 #ifndef SQLITE_OMIT_CHECK |
| 1202 if( pTab->pCheck && (pParse->db->flags & SQLITE_IgnoreChecks)==0 ){ | 1215 if( pTab->pCheck && (pParse->db->flags & SQLITE_IgnoreChecks)==0 ){ |
| 1203 int allOk = sqlite3VdbeMakeLabel(v); | 1216 int allOk = sqlite3VdbeMakeLabel(v); |
| 1204 pParse->ckBase = regData; | 1217 pParse->ckBase = regData; |
| 1205 sqlite3ExprIfTrue(pParse, pTab->pCheck, allOk, SQLITE_JUMPIFNULL); | 1218 sqlite3ExprIfTrue(pParse, pTab->pCheck, allOk, SQLITE_JUMPIFNULL); |
| 1206 onError = overrideError!=OE_Default ? overrideError : OE_Abort; | 1219 onError = overrideError!=OE_Default ? overrideError : OE_Abort; |
| 1207 if( onError==OE_Ignore ){ | 1220 if( onError==OE_Ignore ){ |
| 1208 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); | 1221 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); |
| 1209 }else{ | 1222 }else{ |
| 1223 if( onError==OE_Replace ) onError = OE_Abort; /* IMP: R-15569-63625 */ |
| 1210 sqlite3HaltConstraint(pParse, onError, 0, 0); | 1224 sqlite3HaltConstraint(pParse, onError, 0, 0); |
| 1211 } | 1225 } |
| 1212 sqlite3VdbeResolveLabel(v, allOk); | 1226 sqlite3VdbeResolveLabel(v, allOk); |
| 1213 } | 1227 } |
| 1214 #endif /* !defined(SQLITE_OMIT_CHECK) */ | 1228 #endif /* !defined(SQLITE_OMIT_CHECK) */ |
| 1215 | 1229 |
| 1216 /* If we have an INTEGER PRIMARY KEY, make sure the primary key | 1230 /* If we have an INTEGER PRIMARY KEY, make sure the primary key |
| 1217 ** of the new record does not previously exist. Except, if this | 1231 ** of the new record does not previously exist. Except, if this |
| 1218 ** is an UPDATE and the primary key is not changing, that is OK. | 1232 ** is an UPDATE and the primary key is not changing, that is OK. |
| 1219 */ | 1233 */ |
| 1220 if( rowidChng ){ | 1234 if( rowidChng ){ |
| 1221 onError = pTab->keyConf; | 1235 onError = pTab->keyConf; |
| 1222 if( overrideError!=OE_Default ){ | 1236 if( overrideError!=OE_Default ){ |
| 1223 onError = overrideError; | 1237 onError = overrideError; |
| 1224 }else if( onError==OE_Default ){ | 1238 }else if( onError==OE_Default ){ |
| 1225 onError = OE_Abort; | 1239 onError = OE_Abort; |
| 1226 } | 1240 } |
| 1227 | 1241 |
| 1228 if( onError!=OE_Replace || pTab->pIndex ){ | 1242 if( isUpdate ){ |
| 1229 if( isUpdate ){ | 1243 j2 = sqlite3VdbeAddOp3(v, OP_Eq, regRowid, 0, rowidChng); |
| 1230 j2 = sqlite3VdbeAddOp3(v, OP_Eq, regRowid, 0, rowidChng); | 1244 } |
| 1245 j3 = sqlite3VdbeAddOp3(v, OP_NotExists, baseCur, 0, regRowid); |
| 1246 switch( onError ){ |
| 1247 default: { |
| 1248 onError = OE_Abort; |
| 1249 /* Fall thru into the next case */ |
| 1231 } | 1250 } |
| 1232 j3 = sqlite3VdbeAddOp3(v, OP_NotExists, baseCur, 0, regRowid); | 1251 case OE_Rollback: |
| 1233 switch( onError ){ | 1252 case OE_Abort: |
| 1234 default: { | 1253 case OE_Fail: { |
| 1235 onError = OE_Abort; | 1254 sqlite3HaltConstraint( |
| 1236 /* Fall thru into the next case */ | 1255 pParse, onError, "PRIMARY KEY must be unique", P4_STATIC); |
| 1256 break; |
| 1257 } |
| 1258 case OE_Replace: { |
| 1259 /* If there are DELETE triggers on this table and the |
| 1260 ** recursive-triggers flag is set, call GenerateRowDelete() to |
| 1261 ** remove the conflicting row from the the table. This will fire |
| 1262 ** the triggers and remove both the table and index b-tree entries. |
| 1263 ** |
| 1264 ** Otherwise, if there are no triggers or the recursive-triggers |
| 1265 ** flag is not set, but the table has one or more indexes, call |
| 1266 ** GenerateRowIndexDelete(). This removes the index b-tree entries |
| 1267 ** only. The table b-tree entry will be replaced by the new entry |
| 1268 ** when it is inserted. |
| 1269 ** |
| 1270 ** If either GenerateRowDelete() or GenerateRowIndexDelete() is called, |
| 1271 ** also invoke MultiWrite() to indicate that this VDBE may require |
| 1272 ** statement rollback (if the statement is aborted after the delete |
| 1273 ** takes place). Earlier versions called sqlite3MultiWrite() regardless, |
| 1274 ** but being more selective here allows statements like: |
| 1275 ** |
| 1276 ** REPLACE INTO t(rowid) VALUES($newrowid) |
| 1277 ** |
| 1278 ** to run without a statement journal if there are no indexes on the |
| 1279 ** table. |
| 1280 */ |
| 1281 Trigger *pTrigger = 0; |
| 1282 if( pParse->db->flags&SQLITE_RecTriggers ){ |
| 1283 pTrigger = sqlite3TriggersExist(pParse, pTab, TK_DELETE, 0, 0); |
| 1237 } | 1284 } |
| 1238 case OE_Rollback: | 1285 if( pTrigger || sqlite3FkRequired(pParse, pTab, 0, 0) ){ |
| 1239 case OE_Abort: | 1286 sqlite3MultiWrite(pParse); |
| 1240 case OE_Fail: { | 1287 sqlite3GenerateRowDelete( |
| 1241 sqlite3HaltConstraint( | 1288 pParse, pTab, baseCur, regRowid, 0, pTrigger, OE_Replace |
| 1242 pParse, onError, "PRIMARY KEY must be unique", P4_STATIC); | 1289 ); |
| 1243 break; | 1290 }else if( pTab->pIndex ){ |
| 1291 sqlite3MultiWrite(pParse); |
| 1292 sqlite3GenerateRowIndexDelete(pParse, pTab, baseCur, 0); |
| 1244 } | 1293 } |
| 1245 case OE_Replace: { | 1294 seenReplace = 1; |
| 1246 /* If there are DELETE triggers on this table and the | 1295 break; |
| 1247 ** recursive-triggers flag is set, call GenerateRowDelete() to | |
| 1248 ** remove the conflicting row from the the table. This will fire | |
| 1249 ** the triggers and remove both the table and index b-tree entries. | |
| 1250 ** | |
| 1251 ** Otherwise, if there are no triggers or the recursive-triggers | |
| 1252 ** flag is not set, call GenerateRowIndexDelete(). This removes | |
| 1253 ** the index b-tree entries only. The table b-tree entry will be | |
| 1254 ** replaced by the new entry when it is inserted. */ | |
| 1255 Trigger *pTrigger = 0; | |
| 1256 if( pParse->db->flags&SQLITE_RecTriggers ){ | |
| 1257 pTrigger = sqlite3TriggersExist(pParse, pTab, TK_DELETE, 0, 0); | |
| 1258 } | |
| 1259 if( pTrigger ){ | |
| 1260 sqlite3GenerateRowDelete( | |
| 1261 pParse, pTab, baseCur, regRowid, 0, pTrigger, OE_Replace | |
| 1262 ); | |
| 1263 }else{ | |
| 1264 sqlite3GenerateRowIndexDelete(pParse, pTab, baseCur, 0); | |
| 1265 } | |
| 1266 seenReplace = 1; | |
| 1267 break; | |
| 1268 } | |
| 1269 case OE_Ignore: { | |
| 1270 assert( seenReplace==0 ); | |
| 1271 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); | |
| 1272 break; | |
| 1273 } | |
| 1274 } | 1296 } |
| 1275 sqlite3VdbeJumpHere(v, j3); | 1297 case OE_Ignore: { |
| 1276 if( isUpdate ){ | 1298 assert( seenReplace==0 ); |
| 1277 sqlite3VdbeJumpHere(v, j2); | 1299 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); |
| 1300 break; |
| 1278 } | 1301 } |
| 1279 } | 1302 } |
| 1303 sqlite3VdbeJumpHere(v, j3); |
| 1304 if( isUpdate ){ |
| 1305 sqlite3VdbeJumpHere(v, j2); |
| 1306 } |
| 1280 } | 1307 } |
| 1281 | 1308 |
| 1282 /* Test all UNIQUE constraints by creating entries for each UNIQUE | 1309 /* Test all UNIQUE constraints by creating entries for each UNIQUE |
| 1283 ** index and making sure that duplicate entries do not already exist. | 1310 ** index and making sure that duplicate entries do not already exist. |
| 1284 ** Add the new records to the indices as we go. | 1311 ** Add the new records to the indices as we go. |
| 1285 */ | 1312 */ |
| 1286 for(iCur=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, iCur++){ | 1313 for(iCur=0, pIdx=pTab->pIndex; pIdx; pIdx=pIdx->pNext, iCur++){ |
| 1287 int regIdx; | 1314 int regIdx; |
| 1288 int regR; | 1315 int regR; |
| 1289 | 1316 |
| 1290 if( aRegIdx[iCur]==0 ) continue; /* Skip unused indices */ | 1317 if( aRegIdx[iCur]==0 ) continue; /* Skip unused indices */ |
| 1291 | 1318 |
| 1292 /* Create a key for accessing the index entry */ | 1319 /* Create a key for accessing the index entry */ |
| 1293 regIdx = sqlite3GetTempRange(pParse, pIdx->nColumn+1); | 1320 regIdx = sqlite3GetTempRange(pParse, pIdx->nColumn+1); |
| 1294 for(i=0; i<pIdx->nColumn; i++){ | 1321 for(i=0; i<pIdx->nColumn; i++){ |
| 1295 int idx = pIdx->aiColumn[i]; | 1322 int idx = pIdx->aiColumn[i]; |
| 1296 if( idx==pTab->iPKey ){ | 1323 if( idx==pTab->iPKey ){ |
| 1297 sqlite3VdbeAddOp2(v, OP_SCopy, regRowid, regIdx+i); | 1324 sqlite3VdbeAddOp2(v, OP_SCopy, regRowid, regIdx+i); |
| 1298 }else{ | 1325 }else{ |
| 1299 sqlite3VdbeAddOp2(v, OP_SCopy, regData+idx, regIdx+i); | 1326 sqlite3VdbeAddOp2(v, OP_SCopy, regData+idx, regIdx+i); |
| 1300 } | 1327 } |
| 1301 } | 1328 } |
| 1302 sqlite3VdbeAddOp2(v, OP_SCopy, regRowid, regIdx+i); | 1329 sqlite3VdbeAddOp2(v, OP_SCopy, regRowid, regIdx+i); |
| 1303 sqlite3VdbeAddOp3(v, OP_MakeRecord, regIdx, pIdx->nColumn+1, aRegIdx[iCur]); | 1330 sqlite3VdbeAddOp3(v, OP_MakeRecord, regIdx, pIdx->nColumn+1, aRegIdx[iCur]); |
| 1304 sqlite3VdbeChangeP4(v, -1, sqlite3IndexAffinityStr(v, pIdx), 0); | 1331 sqlite3VdbeChangeP4(v, -1, sqlite3IndexAffinityStr(v, pIdx), P4_TRANSIENT); |
| 1305 sqlite3ExprCacheAffinityChange(pParse, regIdx, pIdx->nColumn+1); | 1332 sqlite3ExprCacheAffinityChange(pParse, regIdx, pIdx->nColumn+1); |
| 1306 | 1333 |
| 1307 /* Find out what action to take in case there is an indexing conflict */ | 1334 /* Find out what action to take in case there is an indexing conflict */ |
| 1308 onError = pIdx->onError; | 1335 onError = pIdx->onError; |
| 1309 if( onError==OE_None ){ | 1336 if( onError==OE_None ){ |
| 1310 sqlite3ReleaseTempRange(pParse, regIdx, pIdx->nColumn+1); | 1337 sqlite3ReleaseTempRange(pParse, regIdx, pIdx->nColumn+1); |
| 1311 continue; /* pIdx is not a UNIQUE index */ | 1338 continue; /* pIdx is not a UNIQUE index */ |
| 1312 } | 1339 } |
| 1313 if( overrideError!=OE_Default ){ | 1340 if( overrideError!=OE_Default ){ |
| 1314 onError = overrideError; | 1341 onError = overrideError; |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1357 break; | 1384 break; |
| 1358 } | 1385 } |
| 1359 case OE_Ignore: { | 1386 case OE_Ignore: { |
| 1360 assert( seenReplace==0 ); | 1387 assert( seenReplace==0 ); |
| 1361 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); | 1388 sqlite3VdbeAddOp2(v, OP_Goto, 0, ignoreDest); |
| 1362 break; | 1389 break; |
| 1363 } | 1390 } |
| 1364 default: { | 1391 default: { |
| 1365 Trigger *pTrigger = 0; | 1392 Trigger *pTrigger = 0; |
| 1366 assert( onError==OE_Replace ); | 1393 assert( onError==OE_Replace ); |
| 1394 sqlite3MultiWrite(pParse); |
| 1367 if( pParse->db->flags&SQLITE_RecTriggers ){ | 1395 if( pParse->db->flags&SQLITE_RecTriggers ){ |
| 1368 pTrigger = sqlite3TriggersExist(pParse, pTab, TK_DELETE, 0, 0); | 1396 pTrigger = sqlite3TriggersExist(pParse, pTab, TK_DELETE, 0, 0); |
| 1369 } | 1397 } |
| 1370 sqlite3GenerateRowDelete( | 1398 sqlite3GenerateRowDelete( |
| 1371 pParse, pTab, baseCur, regR, 0, pTrigger, OE_Replace | 1399 pParse, pTab, baseCur, regR, 0, pTrigger, OE_Replace |
| 1372 ); | 1400 ); |
| 1373 seenReplace = 1; | 1401 seenReplace = 1; |
| 1374 break; | 1402 break; |
| 1375 } | 1403 } |
| 1376 } | 1404 } |
| 1377 sqlite3VdbeJumpHere(v, j3); | 1405 sqlite3VdbeJumpHere(v, j3); |
| 1378 sqlite3ReleaseTempReg(pParse, regR); | 1406 sqlite3ReleaseTempReg(pParse, regR); |
| 1379 } | 1407 } |
| 1380 | 1408 |
| 1381 if( pbMayReplace ){ | 1409 if( pbMayReplace ){ |
| 1382 *pbMayReplace = seenReplace; | 1410 *pbMayReplace = seenReplace; |
| 1383 } | 1411 } |
| 1384 } | 1412 } |
| 1385 | 1413 |
| 1386 /* | 1414 /* |
| 1387 ** This routine generates code to finish the INSERT or UPDATE operation | 1415 ** This routine generates code to finish the INSERT or UPDATE operation |
| 1388 ** that was started by a prior call to sqlite3GenerateConstraintChecks. | 1416 ** that was started by a prior call to sqlite3GenerateConstraintChecks. |
| 1389 ** A consecutive range of registers starting at regRowid contains the | 1417 ** A consecutive range of registers starting at regRowid contains the |
| 1390 ** rowid and the content to be inserted. | 1418 ** rowid and the content to be inserted. |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1433 pik_flags |= (isUpdate?OPFLAG_ISUPDATE:OPFLAG_LASTROWID); | 1461 pik_flags |= (isUpdate?OPFLAG_ISUPDATE:OPFLAG_LASTROWID); |
| 1434 } | 1462 } |
| 1435 if( appendBias ){ | 1463 if( appendBias ){ |
| 1436 pik_flags |= OPFLAG_APPEND; | 1464 pik_flags |= OPFLAG_APPEND; |
| 1437 } | 1465 } |
| 1438 if( useSeekResult ){ | 1466 if( useSeekResult ){ |
| 1439 pik_flags |= OPFLAG_USESEEKRESULT; | 1467 pik_flags |= OPFLAG_USESEEKRESULT; |
| 1440 } | 1468 } |
| 1441 sqlite3VdbeAddOp3(v, OP_Insert, baseCur, regRec, regRowid); | 1469 sqlite3VdbeAddOp3(v, OP_Insert, baseCur, regRec, regRowid); |
| 1442 if( !pParse->nested ){ | 1470 if( !pParse->nested ){ |
| 1443 sqlite3VdbeChangeP4(v, -1, pTab->zName, P4_STATIC); | 1471 sqlite3VdbeChangeP4(v, -1, pTab->zName, P4_TRANSIENT); |
| 1444 } | 1472 } |
| 1445 sqlite3VdbeChangeP5(v, pik_flags); | 1473 sqlite3VdbeChangeP5(v, pik_flags); |
| 1446 } | 1474 } |
| 1447 | 1475 |
| 1448 /* | 1476 /* |
| 1449 ** Generate code that will open cursors for a table and for all | 1477 ** Generate code that will open cursors for a table and for all |
| 1450 ** indices of that table. The "baseCur" parameter is the cursor number used | 1478 ** indices of that table. The "baseCur" parameter is the cursor number used |
| 1451 ** for the table. Indices are opened on subsequent cursors. | 1479 ** for the table. Indices are opened on subsequent cursors. |
| 1452 ** | 1480 ** |
| 1453 ** Return the number of indices on the table. | 1481 ** Return the number of indices on the table. |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1695 destHasUniqueIdx = 1; | 1723 destHasUniqueIdx = 1; |
| 1696 } | 1724 } |
| 1697 for(pSrcIdx=pSrc->pIndex; pSrcIdx; pSrcIdx=pSrcIdx->pNext){ | 1725 for(pSrcIdx=pSrc->pIndex; pSrcIdx; pSrcIdx=pSrcIdx->pNext){ |
| 1698 if( xferCompatibleIndex(pDestIdx, pSrcIdx) ) break; | 1726 if( xferCompatibleIndex(pDestIdx, pSrcIdx) ) break; |
| 1699 } | 1727 } |
| 1700 if( pSrcIdx==0 ){ | 1728 if( pSrcIdx==0 ){ |
| 1701 return 0; /* pDestIdx has no corresponding index in pSrc */ | 1729 return 0; /* pDestIdx has no corresponding index in pSrc */ |
| 1702 } | 1730 } |
| 1703 } | 1731 } |
| 1704 #ifndef SQLITE_OMIT_CHECK | 1732 #ifndef SQLITE_OMIT_CHECK |
| 1705 if( pDest->pCheck && !sqlite3ExprCompare(pSrc->pCheck, pDest->pCheck) ){ | 1733 if( pDest->pCheck && sqlite3ExprCompare(pSrc->pCheck, pDest->pCheck) ){ |
| 1706 return 0; /* Tables have different CHECK constraints. Ticket #2252 */ | 1734 return 0; /* Tables have different CHECK constraints. Ticket #2252 */ |
| 1707 } | 1735 } |
| 1708 #endif | 1736 #endif |
| 1709 | 1737 |
| 1710 /* If we get this far, it means either: | 1738 /* If we get this far, it means either: |
| 1711 ** | 1739 ** |
| 1712 ** * We can always do the transfer if the table contains an | 1740 ** * We can always do the transfer if the table contains an |
| 1713 ** an integer primary key | 1741 ** an integer primary key |
| 1714 ** | 1742 ** |
| 1715 ** * We can conditionally do the transfer if the destination | 1743 ** * We can conditionally do the transfer if the destination |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1793 if( emptyDestTest ){ | 1821 if( emptyDestTest ){ |
| 1794 sqlite3VdbeAddOp2(v, OP_Halt, SQLITE_OK, 0); | 1822 sqlite3VdbeAddOp2(v, OP_Halt, SQLITE_OK, 0); |
| 1795 sqlite3VdbeJumpHere(v, emptyDestTest); | 1823 sqlite3VdbeJumpHere(v, emptyDestTest); |
| 1796 sqlite3VdbeAddOp2(v, OP_Close, iDest, 0); | 1824 sqlite3VdbeAddOp2(v, OP_Close, iDest, 0); |
| 1797 return 0; | 1825 return 0; |
| 1798 }else{ | 1826 }else{ |
| 1799 return 1; | 1827 return 1; |
| 1800 } | 1828 } |
| 1801 } | 1829 } |
| 1802 #endif /* SQLITE_OMIT_XFER_OPT */ | 1830 #endif /* SQLITE_OMIT_XFER_OPT */ |
| 1803 | |
| 1804 /* Make sure "isView" gets undefined in case this file becomes part of | |
| 1805 ** the amalgamation - so that subsequent files do not see isView as a | |
| 1806 ** macro. */ | |
| 1807 #undef isView | |
| OLD | NEW |