/ Hex Artifact Content
Login

Artifact 37fb1c87d7b3ccaff194411ff8344d9cc056bd98:


0000: 0a 23 69 66 20 21 64 65 66 69 6e 65 64 28 53 51  .#if !defined(SQ
0010: 4c 49 54 45 5f 54 45 53 54 29 20 7c 7c 20 28 64  LITE_TEST) || (d
0020: 65 66 69 6e 65 64 28 53 51 4c 49 54 45 5f 45 4e  efined(SQLITE_EN
0030: 41 42 4c 45 5f 53 45 53 53 49 4f 4e 29 20 26 26  ABLE_SESSION) &&
0040: 20 64 65 66 69 6e 65 64 28 53 51 4c 49 54 45 5f   defined(SQLITE_
0050: 45 4e 41 42 4c 45 5f 50 52 45 55 50 44 41 54 45  ENABLE_PREUPDATE
0060: 5f 48 4f 4f 4b 29 29 0a 0a 23 69 6e 63 6c 75 64  _HOOK))..#includ
0070: 65 20 22 73 71 6c 69 74 65 33 73 65 73 73 69 6f  e "sqlite3sessio
0080: 6e 2e 68 22 0a 23 69 6e 63 6c 75 64 65 20 22 73  n.h".#include "s
0090: 71 6c 69 74 65 33 63 68 61 6e 67 65 62 61 74 63  qlite3changebatc
00a0: 68 2e 68 22 0a 0a 23 69 6e 63 6c 75 64 65 20 3c  h.h"..#include <
00b0: 61 73 73 65 72 74 2e 68 3e 0a 23 69 6e 63 6c 75  assert.h>.#inclu
00c0: 64 65 20 3c 73 74 72 69 6e 67 2e 68 3e 0a 0a 74  de <string.h>..t
00d0: 79 70 65 64 65 66 20 73 74 72 75 63 74 20 42 61  ypedef struct Ba
00e0: 74 63 68 54 61 62 6c 65 20 42 61 74 63 68 54 61  tchTable BatchTa
00f0: 62 6c 65 3b 0a 74 79 70 65 64 65 66 20 73 74 72  ble;.typedef str
0100: 75 63 74 20 42 61 74 63 68 49 6e 64 65 78 20 42  uct BatchIndex B
0110: 61 74 63 68 49 6e 64 65 78 3b 0a 74 79 70 65 64  atchIndex;.typed
0120: 65 66 20 73 74 72 75 63 74 20 42 61 74 63 68 49  ef struct BatchI
0130: 6e 64 65 78 45 6e 74 72 79 20 42 61 74 63 68 49  ndexEntry BatchI
0140: 6e 64 65 78 45 6e 74 72 79 3b 0a 74 79 70 65 64  ndexEntry;.typed
0150: 65 66 20 73 74 72 75 63 74 20 42 61 74 63 68 48  ef struct BatchH
0160: 61 73 68 20 42 61 74 63 68 48 61 73 68 3b 0a 0a  ash BatchHash;..
0170: 73 74 72 75 63 74 20 73 71 6c 69 74 65 33 5f 63  struct sqlite3_c
0180: 68 61 6e 67 65 62 61 74 63 68 20 7b 0a 20 20 73  hangebatch {.  s
0190: 71 6c 69 74 65 33 20 2a 64 62 3b 20 20 20 20 20  qlite3 *db;     
01a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f                 /
01b0: 2a 20 44 61 74 61 62 61 73 65 20 68 61 6e 64 6c  * Database handl
01c0: 65 20 75 73 65 64 20 74 6f 20 72 65 61 64 20 73  e used to read s
01d0: 63 68 65 6d 61 20 2a 2f 0a 20 20 42 61 74 63 68  chema */.  Batch
01e0: 54 61 62 6c 65 20 2a 70 54 61 62 3b 20 20 20 20  Table *pTab;    
01f0: 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 46 69             /* Fi
0200: 72 73 74 20 69 6e 20 6c 69 6e 6b 65 64 20 6c 69  rst in linked li
0210: 73 74 20 6f 66 20 74 61 62 6c 65 73 20 2a 2f 0a  st of tables */.
0220: 20 20 69 6e 74 20 69 43 68 61 6e 67 65 73 65 74    int iChangeset
0230: 49 64 3b 20 20 20 20 20 20 20 20 20 20 20 20 20  Id;             
0240: 20 20 2f 2a 20 43 75 72 72 65 6e 74 20 63 68 61    /* Current cha
0250: 6e 67 65 73 65 74 20 69 64 20 2a 2f 0a 20 20 69  ngeset id */.  i
0260: 6e 74 20 69 4e 65 78 74 49 64 78 49 64 3b 20 20  nt iNextIdxId;  
0270: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f                 /
0280: 2a 20 4e 65 78 74 20 61 76 61 69 6c 61 62 6c 65  * Next available
0290: 20 69 6e 64 65 78 20 69 64 20 2a 2f 0a 20 20 69   index id */.  i
02a0: 6e 74 20 6e 45 6e 74 72 79 3b 20 20 20 20 20 20  nt nEntry;      
02b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f                 /
02c0: 2a 20 4e 75 6d 62 65 72 20 6f 66 20 65 6e 74 72  * Number of entr
02d0: 69 65 73 20 69 6e 20 68 61 73 68 20 74 61 62 6c  ies in hash tabl
02e0: 65 20 2a 2f 0a 20 20 69 6e 74 20 6e 48 61 73 68  e */.  int nHash
02f0: 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20  ;               
0300: 20 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72         /* Number
0310: 20 6f 66 20 68 61 73 68 20 62 75 63 6b 65 74 73   of hash buckets
0320: 20 2a 2f 0a 20 20 42 61 74 63 68 49 6e 64 65 78   */.  BatchIndex
0330: 45 6e 74 72 79 20 2a 2a 61 70 48 61 73 68 3b 20  Entry **apHash; 
0340: 20 20 20 20 20 20 2f 2a 20 41 72 72 61 79 20 6f        /* Array o
0350: 66 20 68 61 73 68 20 62 75 63 6b 65 74 73 20 2a  f hash buckets *
0360: 2f 0a 7d 3b 0a 0a 73 74 72 75 63 74 20 42 61 74  /.};..struct Bat
0370: 63 68 54 61 62 6c 65 20 7b 0a 20 20 42 61 74 63  chTable {.  Batc
0380: 68 49 6e 64 65 78 20 2a 70 49 64 78 3b 20 20 20  hIndex *pIdx;   
0390: 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 46              /* F
03a0: 69 72 73 74 20 69 6e 20 6c 69 6e 6b 65 64 20 6c  irst in linked l
03b0: 69 73 74 20 6f 66 20 55 4e 49 51 55 45 20 69 6e  ist of UNIQUE in
03c0: 64 65 78 65 73 20 2a 2f 0a 20 20 42 61 74 63 68  dexes */.  Batch
03d0: 54 61 62 6c 65 20 2a 70 4e 65 78 74 3b 20 20 20  Table *pNext;   
03e0: 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 4e 65             /* Ne
03f0: 78 74 20 74 61 62 6c 65 20 2a 2f 0a 20 20 63 68  xt table */.  ch
0400: 61 72 20 7a 54 61 62 5b 31 5d 3b 20 20 20 20 20  ar zTab[1];     
0410: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a                /*
0420: 20 54 61 62 6c 65 20 6e 61 6d 65 20 2a 2f 0a 7d   Table name */.}
0430: 3b 0a 0a 73 74 72 75 63 74 20 42 61 74 63 68 49  ;..struct BatchI
0440: 6e 64 65 78 20 7b 0a 20 20 42 61 74 63 68 49 6e  ndex {.  BatchIn
0450: 64 65 78 20 2a 70 4e 65 78 74 3b 20 20 20 20 20  dex *pNext;     
0460: 20 20 20 20 20 20 20 20 20 2f 2a 20 4e 65 78 74           /* Next
0470: 20 69 6e 64 65 78 20 6f 6e 20 73 61 6d 65 20 74   index on same t
0480: 61 62 6c 65 20 2a 2f 0a 20 20 69 6e 74 20 69 49  able */.  int iI
0490: 64 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20  d;              
04a0: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 49 6e 64            /* Ind
04b0: 65 78 20 69 64 20 28 61 73 73 69 67 6e 65 64 20  ex id (assigned 
04c0: 69 6e 74 65 72 6e 61 6c 6c 79 29 20 2a 2f 0a 20  internally) */. 
04d0: 20 69 6e 74 20 62 50 6b 3b 20 20 20 20 20 20 20   int bPk;       
04e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
04f0: 20 2f 2a 20 54 72 75 65 20 66 6f 72 20 50 4b 20   /* True for PK 
0500: 69 6e 64 65 78 20 2a 2f 0a 20 20 69 6e 74 20 6e  index */.  int n
0510: 43 6f 6c 3b 20 20 20 20 20 20 20 20 20 20 20 20  Col;            
0520: 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 53 69             /* Si
0530: 7a 65 20 6f 66 20 61 69 43 6f 6c 5b 5d 20 61 72  ze of aiCol[] ar
0540: 72 61 79 20 2a 2f 0a 20 20 69 6e 74 20 2a 61 69  ray */.  int *ai
0550: 43 6f 6c 3b 20 20 20 20 20 20 20 20 20 20 20 20  Col;            
0560: 20 20 20 20 20 20 20 20 20 2f 2a 20 41 72 72 61           /* Arra
0570: 79 20 6f 66 20 63 6f 6c 75 6d 6e 73 20 74 68 61  y of columns tha
0580: 74 20 6d 61 6b 65 20 75 70 20 69 6e 64 65 78 20  t make up index 
0590: 2a 2f 0a 7d 3b 0a 0a 73 74 72 75 63 74 20 42 61  */.};..struct Ba
05a0: 74 63 68 49 6e 64 65 78 45 6e 74 72 79 20 7b 0a  tchIndexEntry {.
05b0: 20 20 42 61 74 63 68 49 6e 64 65 78 45 6e 74 72    BatchIndexEntr
05c0: 79 20 2a 70 4e 65 78 74 3b 20 20 20 20 20 20 20  y *pNext;       
05d0: 20 20 2f 2a 20 4e 65 78 74 20 63 6f 6c 6c 69 64    /* Next collid
05e0: 69 6e 67 20 68 61 73 68 20 74 61 62 6c 65 20 65  ing hash table e
05f0: 6e 74 72 79 20 2a 2f 0a 20 20 69 6e 74 20 69 43  ntry */.  int iC
0600: 68 61 6e 67 65 73 65 74 49 64 3b 20 20 20 20 20  hangesetId;     
0610: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 49 64 20            /* Id 
0620: 6f 66 20 61 73 73 6f 63 69 61 74 65 64 20 63 68  of associated ch
0630: 61 6e 67 65 73 65 74 20 2a 2f 0a 20 20 69 6e 74  angeset */.  int
0640: 20 69 49 64 78 49 64 3b 20 20 20 20 20 20 20 20   iIdxId;        
0650: 20 20 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20               /* 
0660: 49 64 20 6f 66 20 69 6e 64 65 78 20 74 68 69 73  Id of index this
0670: 20 6b 65 79 20 69 73 20 66 72 6f 6d 20 2a 2f 0a   key is from */.
0680: 20 20 69 6e 74 20 73 7a 52 65 63 6f 72 64 3b 0a    int szRecord;.
0690: 20 20 63 68 61 72 20 61 52 65 63 6f 72 64 5b 31    char aRecord[1
06a0: 5d 3b 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a 20 41 6c 6c  ];.};../*.** All
06b0: 6f 63 61 74 65 20 61 6e 64 20 7a 65 72 6f 20 61  ocate and zero a
06c0: 20 62 6c 6f 63 6b 20 6f 66 20 6e 42 79 74 65 20   block of nByte 
06d0: 62 79 74 65 73 2e 20 4d 75 73 74 20 62 65 20 66  bytes. Must be f
06e0: 72 65 65 64 20 75 73 69 6e 67 20 63 62 46 72 65  reed using cbFre
06f0: 65 28 29 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 76  e()..*/.static v
0700: 6f 69 64 20 2a 63 62 4d 61 6c 6c 6f 63 28 69 6e  oid *cbMalloc(in
0710: 74 20 2a 70 52 63 2c 20 69 6e 74 20 6e 42 79 74  t *pRc, int nByt
0720: 65 29 7b 0a 20 20 76 6f 69 64 20 2a 70 52 65 74  e){.  void *pRet
0730: 3b 0a 0a 20 20 69 66 28 20 2a 70 52 63 20 29 7b  ;..  if( *pRc ){
0740: 0a 20 20 20 20 70 52 65 74 20 3d 20 30 3b 0a 20  .    pRet = 0;. 
0750: 20 7d 65 6c 73 65 7b 0a 20 20 20 20 70 52 65 74   }else{.    pRet
0760: 20 3d 20 73 71 6c 69 74 65 33 5f 6d 61 6c 6c 6f   = sqlite3_mallo
0770: 63 28 6e 42 79 74 65 29 3b 0a 20 20 20 20 69 66  c(nByte);.    if
0780: 28 20 70 52 65 74 20 29 7b 0a 20 20 20 20 20 20  ( pRet ){.      
0790: 6d 65 6d 73 65 74 28 70 52 65 74 2c 20 30 2c 20  memset(pRet, 0, 
07a0: 6e 42 79 74 65 29 3b 0a 20 20 20 20 7d 65 6c 73  nByte);.    }els
07b0: 65 7b 0a 20 20 20 20 20 20 2a 70 52 63 20 3d 20  e{.      *pRc = 
07c0: 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d 3b 0a 20 20  SQLITE_NOMEM;.  
07d0: 20 20 7d 0a 20 20 7d 0a 0a 20 20 72 65 74 75 72    }.  }..  retur
07e0: 6e 20 70 52 65 74 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a  n pRet;.}../*.**
07f0: 20 46 72 65 65 20 61 6e 20 61 6c 6c 6f 63 61 74   Free an allocat
0800: 69 6f 6e 20 6d 61 64 65 20 62 79 20 63 62 4d 61  ion made by cbMa
0810: 6c 6c 6f 63 28 29 2e 0a 2a 2f 0a 73 74 61 74 69  lloc()..*/.stati
0820: 63 20 76 6f 69 64 20 63 62 46 72 65 65 28 76 6f  c void cbFree(vo
0830: 69 64 20 2a 70 29 7b 0a 20 20 73 71 6c 69 74 65  id *p){.  sqlite
0840: 33 5f 66 72 65 65 28 70 29 3b 0a 7d 0a 0a 2f 2a  3_free(p);.}../*
0850: 0a 2a 2a 20 52 65 74 75 72 6e 20 74 68 65 20 68  .** Return the h
0860: 61 73 68 20 62 75 63 6b 65 74 20 74 68 61 74 20  ash bucket that 
0870: 70 45 6e 74 72 79 20 62 65 6c 6f 6e 67 73 20 69  pEntry belongs i
0880: 6e 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74  n..*/.static int
0890: 20 63 62 48 61 73 68 28 73 71 6c 69 74 65 33 5f   cbHash(sqlite3_
08a0: 63 68 61 6e 67 65 62 61 74 63 68 20 2a 70 2c 20  changebatch *p, 
08b0: 42 61 74 63 68 49 6e 64 65 78 45 6e 74 72 79 20  BatchIndexEntry 
08c0: 2a 70 45 6e 74 72 79 29 7b 0a 20 20 75 6e 73 69  *pEntry){.  unsi
08d0: 67 6e 65 64 20 69 6e 74 20 69 48 61 73 68 20 3d  gned int iHash =
08e0: 20 28 75 6e 73 69 67 6e 65 64 20 69 6e 74 29 70   (unsigned int)p
08f0: 45 6e 74 72 79 2d 3e 69 49 64 78 49 64 3b 0a 20  Entry->iIdxId;. 
0900: 20 75 6e 73 69 67 6e 65 64 20 63 68 61 72 20 2a   unsigned char *
0910: 70 45 6e 64 20 3d 20 28 75 6e 73 69 67 6e 65 64  pEnd = (unsigned
0920: 20 63 68 61 72 2a 29 26 70 45 6e 74 72 79 2d 3e   char*)&pEntry->
0930: 61 52 65 63 6f 72 64 5b 70 45 6e 74 72 79 2d 3e  aRecord[pEntry->
0940: 73 7a 52 65 63 6f 72 64 5d 3b 0a 20 20 75 6e 73  szRecord];.  uns
0950: 69 67 6e 65 64 20 63 68 61 72 20 2a 70 49 74 65  igned char *pIte
0960: 72 3b 0a 0a 20 20 66 6f 72 28 70 49 74 65 72 3d  r;..  for(pIter=
0970: 70 45 6e 74 72 79 2d 3e 61 52 65 63 6f 72 64 3b  pEntry->aRecord;
0980: 20 70 49 74 65 72 3c 70 45 6e 64 3b 20 70 49 74   pIter<pEnd; pIt
0990: 65 72 2b 2b 29 7b 0a 20 20 20 20 69 48 61 73 68  er++){.    iHash
09a0: 20 2b 3d 20 28 69 48 61 73 68 20 3c 3c 20 37 29   += (iHash << 7)
09b0: 20 2b 20 2a 70 49 74 65 72 3b 0a 20 20 7d 0a 0a   + *pIter;.  }..
09c0: 20 20 72 65 74 75 72 6e 20 28 69 6e 74 29 28 69    return (int)(i
09d0: 48 61 73 68 20 25 20 70 2d 3e 6e 48 61 73 68 29  Hash % p->nHash)
09e0: 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 52 65 73 69 7a  ;.}../*.** Resiz
09f0: 65 20 74 68 65 20 68 61 73 68 20 74 61 62 6c 65  e the hash table
0a00: 2e 0a 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74 20  ..*/.static int 
0a10: 63 62 48 61 73 68 52 65 73 69 7a 65 28 73 71 6c  cbHashResize(sql
0a20: 69 74 65 33 5f 63 68 61 6e 67 65 62 61 74 63 68  ite3_changebatch
0a30: 20 2a 70 29 7b 0a 20 20 69 6e 74 20 72 63 20 3d   *p){.  int rc =
0a40: 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 42 61   SQLITE_OK;.  Ba
0a50: 74 63 68 49 6e 64 65 78 45 6e 74 72 79 20 2a 2a  tchIndexEntry **
0a60: 61 70 4e 65 77 3b 0a 20 20 69 6e 74 20 6e 4e 65  apNew;.  int nNe
0a70: 77 20 3d 20 28 70 2d 3e 6e 48 61 73 68 20 3f 20  w = (p->nHash ? 
0a80: 70 2d 3e 6e 48 61 73 68 2a 32 20 3a 20 35 31 32  p->nHash*2 : 512
0a90: 29 3b 0a 20 20 69 6e 74 20 69 3b 0a 0a 20 20 61  );.  int i;..  a
0aa0: 70 4e 65 77 20 3d 20 63 62 4d 61 6c 6c 6f 63 28  pNew = cbMalloc(
0ab0: 26 72 63 2c 20 73 69 7a 65 6f 66 28 42 61 74 63  &rc, sizeof(Batc
0ac0: 68 49 6e 64 65 78 45 6e 74 72 79 2a 29 20 2a 20  hIndexEntry*) * 
0ad0: 6e 4e 65 77 29 3b 0a 20 20 69 66 28 20 72 63 3d  nNew);.  if( rc=
0ae0: 3d 53 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20  =SQLITE_OK ){.  
0af0: 20 20 69 6e 74 20 6e 48 61 73 68 20 3d 20 70 2d    int nHash = p-
0b00: 3e 6e 48 61 73 68 3b 0a 20 20 20 20 70 2d 3e 6e  >nHash;.    p->n
0b10: 48 61 73 68 20 3d 20 6e 4e 65 77 3b 0a 20 20 20  Hash = nNew;.   
0b20: 20 66 6f 72 28 69 3d 30 3b 20 69 3c 6e 48 61 73   for(i=0; i<nHas
0b30: 68 3b 20 69 2b 2b 29 7b 0a 20 20 20 20 20 20 42  h; i++){.      B
0b40: 61 74 63 68 49 6e 64 65 78 45 6e 74 72 79 20 2a  atchIndexEntry *
0b50: 70 45 6e 74 72 79 3b 0a 20 20 20 20 20 20 77 68  pEntry;.      wh
0b60: 69 6c 65 28 20 70 45 6e 74 72 79 3d 70 2d 3e 61  ile( pEntry=p->a
0b70: 70 48 61 73 68 5b 69 5d 20 29 7b 0a 20 20 20 20  pHash[i] ){.    
0b80: 20 20 20 20 69 6e 74 20 69 48 61 73 68 20 3d 20      int iHash = 
0b90: 63 62 48 61 73 68 28 70 2c 20 70 45 6e 74 72 79  cbHash(p, pEntry
0ba0: 29 3b 0a 20 20 20 20 20 20 20 20 70 2d 3e 61 70  );.        p->ap
0bb0: 48 61 73 68 5b 69 5d 20 3d 20 70 45 6e 74 72 79  Hash[i] = pEntry
0bc0: 2d 3e 70 4e 65 78 74 3b 0a 20 20 20 20 20 20 20  ->pNext;.       
0bd0: 20 70 45 6e 74 72 79 2d 3e 70 4e 65 78 74 20 3d   pEntry->pNext =
0be0: 20 61 70 4e 65 77 5b 69 48 61 73 68 5d 3b 0a 20   apNew[iHash];. 
0bf0: 20 20 20 20 20 20 20 61 70 4e 65 77 5b 69 48 61         apNew[iHa
0c00: 73 68 5d 20 3d 20 70 45 6e 74 72 79 3b 0a 20 20  sh] = pEntry;.  
0c10: 20 20 20 20 7d 0a 20 20 20 20 7d 0a 0a 20 20 20      }.    }..   
0c20: 20 63 62 46 72 65 65 28 70 2d 3e 61 70 48 61 73   cbFree(p->apHas
0c30: 68 29 3b 0a 20 20 20 20 70 2d 3e 61 70 48 61 73  h);.    p->apHas
0c40: 68 20 3d 20 61 70 4e 65 77 3b 0a 20 20 7d 0a 0a  h = apNew;.  }..
0c50: 20 20 72 65 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a    return rc;.}..
0c60: 0a 2f 2a 0a 2a 2a 20 41 6c 6c 6f 63 61 74 65 20  ./*.** Allocate 
0c70: 61 20 6e 65 77 20 73 71 6c 69 74 65 33 5f 63 68  a new sqlite3_ch
0c80: 61 6e 67 65 62 61 74 63 68 20 6f 62 6a 65 63 74  angebatch object
0c90: 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33  ..*/.int sqlite3
0ca0: 63 68 61 6e 67 65 62 61 74 63 68 5f 6e 65 77 28  changebatch_new(
0cb0: 73 71 6c 69 74 65 33 20 2a 64 62 2c 20 73 71 6c  sqlite3 *db, sql
0cc0: 69 74 65 33 5f 63 68 61 6e 67 65 62 61 74 63 68  ite3_changebatch
0cd0: 20 2a 2a 70 70 29 7b 0a 20 20 73 71 6c 69 74 65   **pp){.  sqlite
0ce0: 33 5f 63 68 61 6e 67 65 62 61 74 63 68 20 2a 70  3_changebatch *p
0cf0: 52 65 74 3b 0a 20 20 69 6e 74 20 72 63 20 3d 20  Ret;.  int rc = 
0d00: 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20 2a 70 70  SQLITE_OK;.  *pp
0d10: 20 3d 20 70 52 65 74 20 3d 20 28 73 71 6c 69 74   = pRet = (sqlit
0d20: 65 33 5f 63 68 61 6e 67 65 62 61 74 63 68 2a 29  e3_changebatch*)
0d30: 63 62 4d 61 6c 6c 6f 63 28 26 72 63 2c 20 73 69  cbMalloc(&rc, si
0d40: 7a 65 6f 66 28 73 71 6c 69 74 65 33 5f 63 68 61  zeof(sqlite3_cha
0d50: 6e 67 65 62 61 74 63 68 29 29 3b 0a 20 20 69 66  ngebatch));.  if
0d60: 28 20 70 52 65 74 20 29 7b 0a 20 20 20 20 70 52  ( pRet ){.    pR
0d70: 65 74 2d 3e 64 62 20 3d 20 64 62 3b 0a 20 20 7d  et->db = db;.  }
0d80: 0a 20 20 72 65 74 75 72 6e 20 72 63 3b 0a 7d 0a  .  return rc;.}.
0d90: 0a 2f 2a 0a 2a 2a 20 41 64 64 20 61 20 42 61 74  ./*.** Add a Bat
0da0: 63 68 49 6e 64 65 78 20 65 6e 74 72 79 20 66 6f  chIndex entry fo
0db0: 72 20 69 6e 64 65 78 20 7a 49 64 78 20 74 6f 20  r index zIdx to 
0dc0: 74 61 62 6c 65 20 70 54 61 62 2e 0a 2a 2f 0a 73  table pTab..*/.s
0dd0: 74 61 74 69 63 20 69 6e 74 20 63 62 41 64 64 49  tatic int cbAddI
0de0: 6e 64 65 78 28 0a 20 20 73 71 6c 69 74 65 33 5f  ndex(.  sqlite3_
0df0: 63 68 61 6e 67 65 62 61 74 63 68 20 2a 70 2c 20  changebatch *p, 
0e00: 0a 20 20 42 61 74 63 68 54 61 62 6c 65 20 2a 70  .  BatchTable *p
0e10: 54 61 62 2c 20 0a 20 20 63 6f 6e 73 74 20 63 68  Tab, .  const ch
0e20: 61 72 20 2a 7a 49 64 78 2c 20 0a 20 20 69 6e 74  ar *zIdx, .  int
0e30: 20 62 50 6b 0a 29 7b 0a 20 20 69 6e 74 20 6e 43   bPk.){.  int nC
0e40: 6f 6c 20 3d 20 30 3b 0a 20 20 73 71 6c 69 74 65  ol = 0;.  sqlite
0e50: 33 5f 73 74 6d 74 20 2a 70 49 6e 64 65 78 49 6e  3_stmt *pIndexIn
0e60: 66 6f 20 3d 20 30 3b 0a 20 20 42 61 74 63 68 49  fo = 0;.  BatchI
0e70: 6e 64 65 78 20 2a 70 4e 65 77 20 3d 20 30 3b 0a  ndex *pNew = 0;.
0e80: 20 20 69 6e 74 20 72 63 3b 0a 20 20 63 68 61 72    int rc;.  char
0e90: 20 2a 7a 49 6e 64 65 78 49 6e 66 6f 3b 0a 0a 20   *zIndexInfo;.. 
0ea0: 20 7a 49 6e 64 65 78 49 6e 66 6f 20 3d 20 28 63   zIndexInfo = (c
0eb0: 68 61 72 2a 29 73 71 6c 69 74 65 33 5f 6d 70 72  har*)sqlite3_mpr
0ec0: 69 6e 74 66 28 22 50 52 41 47 4d 41 20 6d 61 69  intf("PRAGMA mai
0ed0: 6e 2e 69 6e 64 65 78 5f 69 6e 66 6f 20 3d 20 25  n.index_info = %
0ee0: 51 22 2c 20 7a 49 64 78 29 3b 0a 20 20 69 66 28  Q", zIdx);.  if(
0ef0: 20 7a 49 6e 64 65 78 49 6e 66 6f 20 29 7b 0a 20   zIndexInfo ){. 
0f00: 20 20 20 72 63 20 3d 20 73 71 6c 69 74 65 33 5f     rc = sqlite3_
0f10: 70 72 65 70 61 72 65 5f 76 32 28 70 2d 3e 64 62  prepare_v2(p->db
0f20: 2c 20 7a 49 6e 64 65 78 49 6e 66 6f 2c 20 2d 31  , zIndexInfo, -1
0f30: 2c 20 26 70 49 6e 64 65 78 49 6e 66 6f 2c 20 30  , &pIndexInfo, 0
0f40: 29 3b 0a 20 20 20 20 73 71 6c 69 74 65 33 5f 66  );.    sqlite3_f
0f50: 72 65 65 28 7a 49 6e 64 65 78 49 6e 66 6f 29 3b  ree(zIndexInfo);
0f60: 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 72 63  .  }else{.    rc
0f70: 20 3d 20 53 51 4c 49 54 45 5f 4e 4f 4d 45 4d 3b   = SQLITE_NOMEM;
0f80: 0a 20 20 7d 0a 0a 20 20 69 66 28 20 72 63 3d 3d  .  }..  if( rc==
0f90: 53 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20  SQLITE_OK ){.   
0fa0: 20 69 6e 74 20 72 63 32 3b 0a 20 20 20 20 77 68   int rc2;.    wh
0fb0: 69 6c 65 28 20 53 51 4c 49 54 45 5f 52 4f 57 3d  ile( SQLITE_ROW=
0fc0: 3d 73 71 6c 69 74 65 33 5f 73 74 65 70 28 70 49  =sqlite3_step(pI
0fd0: 6e 64 65 78 49 6e 66 6f 29 20 29 7b 20 6e 43 6f  ndexInfo) ){ nCo
0fe0: 6c 2b 2b 3b 20 7d 0a 20 20 20 20 72 63 32 20 3d  l++; }.    rc2 =
0ff0: 20 73 71 6c 69 74 65 33 5f 72 65 73 65 74 28 70   sqlite3_reset(p
1000: 49 6e 64 65 78 49 6e 66 6f 29 3b 0a 20 20 20 20  IndexInfo);.    
1010: 69 66 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f  if( rc==SQLITE_O
1020: 4b 20 29 20 72 63 20 3d 20 72 63 32 3b 0a 20 20  K ) rc = rc2;.  
1030: 7d 0a 0a 20 20 70 4e 65 77 20 3d 20 28 42 61 74  }..  pNew = (Bat
1040: 63 68 49 6e 64 65 78 2a 29 63 62 4d 61 6c 6c 6f  chIndex*)cbMallo
1050: 63 28 26 72 63 2c 20 73 69 7a 65 6f 66 28 42 61  c(&rc, sizeof(Ba
1060: 74 63 68 49 6e 64 65 78 29 20 2b 20 73 69 7a 65  tchIndex) + size
1070: 6f 66 28 69 6e 74 29 20 2a 20 6e 43 6f 6c 29 3b  of(int) * nCol);
1080: 0a 20 20 69 66 28 20 72 63 3d 3d 53 51 4c 49 54  .  if( rc==SQLIT
1090: 45 5f 4f 4b 20 29 7b 0a 20 20 20 20 69 6e 74 20  E_OK ){.    int 
10a0: 72 63 32 3b 0a 20 20 20 20 70 4e 65 77 2d 3e 6e  rc2;.    pNew->n
10b0: 43 6f 6c 20 3d 20 6e 43 6f 6c 3b 0a 20 20 20 20  Col = nCol;.    
10c0: 70 4e 65 77 2d 3e 62 50 6b 20 3d 20 62 50 6b 3b  pNew->bPk = bPk;
10d0: 0a 20 20 20 20 70 4e 65 77 2d 3e 61 69 43 6f 6c  .    pNew->aiCol
10e0: 20 3d 20 28 69 6e 74 2a 29 26 70 4e 65 77 5b 31   = (int*)&pNew[1
10f0: 5d 3b 0a 20 20 20 20 70 4e 65 77 2d 3e 69 49 64  ];.    pNew->iId
1100: 20 3d 20 70 2d 3e 69 4e 65 78 74 49 64 78 49 64   = p->iNextIdxId
1110: 2b 2b 3b 0a 20 20 20 20 77 68 69 6c 65 28 20 53  ++;.    while( S
1120: 51 4c 49 54 45 5f 52 4f 57 3d 3d 73 71 6c 69 74  QLITE_ROW==sqlit
1130: 65 33 5f 73 74 65 70 28 70 49 6e 64 65 78 49 6e  e3_step(pIndexIn
1140: 66 6f 29 20 29 7b 20 0a 20 20 20 20 20 20 69 6e  fo) ){ .      in
1150: 74 20 69 20 3d 20 73 71 6c 69 74 65 33 5f 63 6f  t i = sqlite3_co
1160: 6c 75 6d 6e 5f 69 6e 74 28 70 49 6e 64 65 78 49  lumn_int(pIndexI
1170: 6e 66 6f 2c 20 30 29 3b 0a 20 20 20 20 20 20 69  nfo, 0);.      i
1180: 6e 74 20 6a 20 3d 20 73 71 6c 69 74 65 33 5f 63  nt j = sqlite3_c
1190: 6f 6c 75 6d 6e 5f 69 6e 74 28 70 49 6e 64 65 78  olumn_int(pIndex
11a0: 49 6e 66 6f 2c 20 31 29 3b 0a 20 20 20 20 20 20  Info, 1);.      
11b0: 70 4e 65 77 2d 3e 61 69 43 6f 6c 5b 69 5d 20 3d  pNew->aiCol[i] =
11c0: 20 6a 3b 0a 20 20 20 20 7d 0a 20 20 20 20 72 63   j;.    }.    rc
11d0: 32 20 3d 20 73 71 6c 69 74 65 33 5f 72 65 73 65  2 = sqlite3_rese
11e0: 74 28 70 49 6e 64 65 78 49 6e 66 6f 29 3b 0a 20  t(pIndexInfo);. 
11f0: 20 20 20 69 66 28 20 72 63 3d 3d 53 51 4c 49 54     if( rc==SQLIT
1200: 45 5f 4f 4b 20 29 20 72 63 20 3d 20 72 63 32 3b  E_OK ) rc = rc2;
1210: 0a 20 20 7d 0a 0a 20 20 69 66 28 20 72 63 3d 3d  .  }..  if( rc==
1220: 53 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20  SQLITE_OK ){.   
1230: 20 70 4e 65 77 2d 3e 70 4e 65 78 74 20 3d 20 70   pNew->pNext = p
1240: 54 61 62 2d 3e 70 49 64 78 3b 0a 20 20 20 20 70  Tab->pIdx;.    p
1250: 54 61 62 2d 3e 70 49 64 78 20 3d 20 70 4e 65 77  Tab->pIdx = pNew
1260: 3b 0a 20 20 7d 65 6c 73 65 7b 0a 20 20 20 20 63  ;.  }else{.    c
1270: 62 46 72 65 65 28 70 4e 65 77 29 3b 0a 20 20 7d  bFree(pNew);.  }
1280: 0a 20 20 73 71 6c 69 74 65 33 5f 66 69 6e 61 6c  .  sqlite3_final
1290: 69 7a 65 28 70 49 6e 64 65 78 49 6e 66 6f 29 3b  ize(pIndexInfo);
12a0: 0a 0a 20 20 72 65 74 75 72 6e 20 72 63 3b 0a 7d  ..  return rc;.}
12b0: 0a 0a 2f 2a 0a 2a 2a 20 46 69 6e 64 20 6f 72 20  ../*.** Find or 
12c0: 63 72 65 61 74 65 20 74 68 65 20 42 61 74 63 68  create the Batch
12d0: 54 61 62 6c 65 20 6f 62 6a 65 63 74 20 6e 61 6d  Table object nam
12e0: 65 64 20 7a 54 61 62 2e 0a 2a 2f 0a 73 74 61 74  ed zTab..*/.stat
12f0: 69 63 20 69 6e 74 20 63 62 46 69 6e 64 54 61 62  ic int cbFindTab
1300: 6c 65 28 0a 20 20 73 71 6c 69 74 65 33 5f 63 68  le(.  sqlite3_ch
1310: 61 6e 67 65 62 61 74 63 68 20 2a 70 2c 20 0a 20  angebatch *p, . 
1320: 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 54 61   const char *zTa
1330: 62 2c 20 0a 20 20 42 61 74 63 68 54 61 62 6c 65  b, .  BatchTable
1340: 20 2a 2a 70 70 54 61 62 0a 29 7b 0a 20 20 42 61   **ppTab.){.  Ba
1350: 74 63 68 54 61 62 6c 65 20 2a 70 52 65 74 20 3d  tchTable *pRet =
1360: 20 30 3b 0a 20 20 69 6e 74 20 72 63 20 3d 20 53   0;.  int rc = S
1370: 51 4c 49 54 45 5f 4f 4b 3b 0a 0a 20 20 66 6f 72  QLITE_OK;..  for
1380: 28 70 52 65 74 3d 70 2d 3e 70 54 61 62 3b 20 70  (pRet=p->pTab; p
1390: 52 65 74 3b 20 70 52 65 74 3d 70 52 65 74 2d 3e  Ret; pRet=pRet->
13a0: 70 4e 65 78 74 29 7b 0a 20 20 20 20 69 66 28 20  pNext){.    if( 
13b0: 30 3d 3d 73 71 6c 69 74 65 33 5f 73 74 72 69 63  0==sqlite3_stric
13c0: 6d 70 28 7a 54 61 62 2c 20 70 52 65 74 2d 3e 7a  mp(zTab, pRet->z
13d0: 54 61 62 29 20 29 20 62 72 65 61 6b 3b 0a 20 20  Tab) ) break;.  
13e0: 7d 0a 0a 20 20 69 66 28 20 70 52 65 74 3d 3d 30  }..  if( pRet==0
13f0: 20 29 7b 0a 20 20 20 20 69 6e 74 20 6e 54 61 62   ){.    int nTab
1400: 20 3d 20 73 74 72 6c 65 6e 28 7a 54 61 62 29 3b   = strlen(zTab);
1410: 0a 20 20 20 20 70 52 65 74 20 3d 20 28 42 61 74  .    pRet = (Bat
1420: 63 68 54 61 62 6c 65 2a 29 63 62 4d 61 6c 6c 6f  chTable*)cbMallo
1430: 63 28 26 72 63 2c 20 6e 54 61 62 20 2b 20 73 69  c(&rc, nTab + si
1440: 7a 65 6f 66 28 42 61 74 63 68 54 61 62 6c 65 29  zeof(BatchTable)
1450: 29 3b 0a 20 20 20 20 69 66 28 20 70 52 65 74 20  );.    if( pRet 
1460: 29 7b 0a 20 20 20 20 20 20 73 71 6c 69 74 65 33  ){.      sqlite3
1470: 5f 73 74 6d 74 20 2a 70 49 6e 64 65 78 4c 69 73  _stmt *pIndexLis
1480: 74 20 3d 20 30 3b 0a 20 20 20 20 20 20 63 68 61  t = 0;.      cha
1490: 72 20 2a 7a 49 6e 64 65 78 4c 69 73 74 20 3d 20  r *zIndexList = 
14a0: 30 3b 0a 20 20 20 20 20 20 69 6e 74 20 72 63 32  0;.      int rc2
14b0: 3b 0a 20 20 20 20 20 20 6d 65 6d 63 70 79 28 70  ;.      memcpy(p
14c0: 52 65 74 2d 3e 7a 54 61 62 2c 20 7a 54 61 62 2c  Ret->zTab, zTab,
14d0: 20 6e 54 61 62 29 3b 0a 0a 20 20 20 20 20 20 7a   nTab);..      z
14e0: 49 6e 64 65 78 4c 69 73 74 20 3d 20 73 71 6c 69  IndexList = sqli
14f0: 74 65 33 5f 6d 70 72 69 6e 74 66 28 22 50 52 41  te3_mprintf("PRA
1500: 47 4d 41 20 6d 61 69 6e 2e 69 6e 64 65 78 5f 6c  GMA main.index_l
1510: 69 73 74 20 3d 20 25 51 22 2c 20 7a 54 61 62 29  ist = %Q", zTab)
1520: 3b 0a 20 20 20 20 20 20 69 66 28 20 7a 49 6e 64  ;.      if( zInd
1530: 65 78 4c 69 73 74 3d 3d 30 20 29 7b 0a 20 20 20  exList==0 ){.   
1540: 20 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45       rc = SQLITE
1550: 5f 4e 4f 4d 45 4d 3b 0a 20 20 20 20 20 20 7d 65  _NOMEM;.      }e
1560: 6c 73 65 7b 0a 20 20 20 20 20 20 20 20 72 63 20  lse{.        rc 
1570: 3d 20 73 71 6c 69 74 65 33 5f 70 72 65 70 61 72  = sqlite3_prepar
1580: 65 5f 76 32 28 70 2d 3e 64 62 2c 20 7a 49 6e 64  e_v2(p->db, zInd
1590: 65 78 4c 69 73 74 2c 20 2d 31 2c 20 26 70 49 6e  exList, -1, &pIn
15a0: 64 65 78 4c 69 73 74 2c 20 30 29 3b 0a 20 20 20  dexList, 0);.   
15b0: 20 20 20 20 20 73 71 6c 69 74 65 33 5f 66 72 65       sqlite3_fre
15c0: 65 28 7a 49 6e 64 65 78 4c 69 73 74 29 3b 0a 20  e(zIndexList);. 
15d0: 20 20 20 20 20 7d 0a 0a 20 20 20 20 20 20 77 68       }..      wh
15e0: 69 6c 65 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f  ile( rc==SQLITE_
15f0: 4f 4b 20 26 26 20 53 51 4c 49 54 45 5f 52 4f 57  OK && SQLITE_ROW
1600: 3d 3d 73 71 6c 69 74 65 33 5f 73 74 65 70 28 70  ==sqlite3_step(p
1610: 49 6e 64 65 78 4c 69 73 74 29 20 29 7b 0a 20 20  IndexList) ){.  
1620: 20 20 20 20 20 20 69 66 28 20 73 71 6c 69 74 65        if( sqlite
1630: 33 5f 63 6f 6c 75 6d 6e 5f 69 6e 74 28 70 49 6e  3_column_int(pIn
1640: 64 65 78 4c 69 73 74 2c 20 32 29 20 29 7b 0a 20  dexList, 2) ){. 
1650: 20 20 20 20 20 20 20 20 20 63 6f 6e 73 74 20 63           const c
1660: 68 61 72 20 2a 7a 49 64 78 20 3d 20 28 63 6f 6e  har *zIdx = (con
1670: 73 74 20 63 68 61 72 2a 29 73 71 6c 69 74 65 33  st char*)sqlite3
1680: 5f 63 6f 6c 75 6d 6e 5f 74 65 78 74 28 70 49 6e  _column_text(pIn
1690: 64 65 78 4c 69 73 74 2c 20 31 29 3b 0a 20 20 20  dexList, 1);.   
16a0: 20 20 20 20 20 20 20 63 6f 6e 73 74 20 63 68 61         const cha
16b0: 72 20 2a 7a 54 79 70 20 3d 20 28 63 6f 6e 73 74  r *zTyp = (const
16c0: 20 63 68 61 72 2a 29 73 71 6c 69 74 65 33 5f 63   char*)sqlite3_c
16d0: 6f 6c 75 6d 6e 5f 74 65 78 74 28 70 49 6e 64 65  olumn_text(pInde
16e0: 78 4c 69 73 74 2c 20 33 29 3b 0a 20 20 20 20 20  xList, 3);.     
16f0: 20 20 20 20 20 72 63 20 3d 20 63 62 41 64 64 49       rc = cbAddI
1700: 6e 64 65 78 28 70 2c 20 70 52 65 74 2c 20 7a 49  ndex(p, pRet, zI
1710: 64 78 2c 20 28 7a 54 79 70 5b 30 5d 3d 3d 27 70  dx, (zTyp[0]=='p
1720: 27 29 29 3b 0a 20 20 20 20 20 20 20 20 7d 0a 20  '));.        }. 
1730: 20 20 20 20 20 7d 0a 20 20 20 20 20 20 72 63 32       }.      rc2
1740: 20 3d 20 73 71 6c 69 74 65 33 5f 66 69 6e 61 6c   = sqlite3_final
1750: 69 7a 65 28 70 49 6e 64 65 78 4c 69 73 74 29 3b  ize(pIndexList);
1760: 0a 20 20 20 20 20 20 69 66 28 20 72 63 3d 3d 53  .      if( rc==S
1770: 51 4c 49 54 45 5f 4f 4b 20 29 20 72 63 20 3d 20  QLITE_OK ) rc = 
1780: 72 63 32 3b 0a 0a 20 20 20 20 20 20 69 66 28 20  rc2;..      if( 
1790: 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 29 7b  rc==SQLITE_OK ){
17a0: 0a 20 20 20 20 20 20 20 20 70 52 65 74 2d 3e 70  .        pRet->p
17b0: 4e 65 78 74 20 3d 20 70 2d 3e 70 54 61 62 3b 0a  Next = p->pTab;.
17c0: 20 20 20 20 20 20 20 20 70 2d 3e 70 54 61 62 20          p->pTab 
17d0: 3d 20 70 52 65 74 3b 0a 20 20 20 20 20 20 7d 0a  = pRet;.      }.
17e0: 20 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 2a 70 70      }.  }..  *pp
17f0: 54 61 62 20 3d 20 70 52 65 74 3b 0a 20 20 72 65  Tab = pRet;.  re
1800: 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 73 74 61 74  turn rc;.}..stat
1810: 69 63 20 69 6e 74 20 63 62 41 64 64 54 6f 48 61  ic int cbAddToHa
1820: 73 68 28 0a 20 20 73 71 6c 69 74 65 33 5f 63 68  sh(.  sqlite3_ch
1830: 61 6e 67 65 62 61 74 63 68 20 2a 70 2c 20 0a 20  angebatch *p, . 
1840: 20 73 71 6c 69 74 65 33 5f 63 68 61 6e 67 65 73   sqlite3_changes
1850: 65 74 5f 69 74 65 72 20 2a 70 49 74 65 72 2c 20  et_iter *pIter, 
1860: 0a 20 20 42 61 74 63 68 49 6e 64 65 78 20 2a 70  .  BatchIndex *p
1870: 49 64 78 2c 20 0a 20 20 69 6e 74 20 28 2a 78 56  Idx, .  int (*xV
1880: 61 6c 29 28 73 71 6c 69 74 65 33 5f 63 68 61 6e  al)(sqlite3_chan
1890: 67 65 73 65 74 5f 69 74 65 72 2a 2c 69 6e 74 2c  geset_iter*,int,
18a0: 73 71 6c 69 74 65 33 5f 76 61 6c 75 65 2a 2a 29  sqlite3_value**)
18b0: 2c 0a 20 20 69 6e 74 20 2a 70 62 43 6f 6e 66 0a  ,.  int *pbConf.
18c0: 29 7b 0a 20 20 42 61 74 63 68 49 6e 64 65 78 45  ){.  BatchIndexE
18d0: 6e 74 72 79 20 2a 70 4e 65 77 3b 0a 20 20 69 6e  ntry *pNew;.  in
18e0: 74 20 73 7a 20 3d 20 70 49 64 78 2d 3e 6e 43 6f  t sz = pIdx->nCo
18f0: 6c 3b 0a 20 20 69 6e 74 20 69 3b 0a 20 20 69 6e  l;.  int i;.  in
1900: 74 20 69 4f 75 74 20 3d 20 30 3b 0a 20 20 69 6e  t iOut = 0;.  in
1910: 74 20 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b  t rc = SQLITE_OK
1920: 3b 0a 0a 20 20 66 6f 72 28 69 3d 30 3b 20 72 63  ;..  for(i=0; rc
1930: 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 26 26 20 69  ==SQLITE_OK && i
1940: 3c 70 49 64 78 2d 3e 6e 43 6f 6c 3b 20 69 2b 2b  <pIdx->nCol; i++
1950: 29 7b 0a 20 20 20 20 73 71 6c 69 74 65 33 5f 76  ){.    sqlite3_v
1960: 61 6c 75 65 20 2a 70 56 61 6c 3b 0a 20 20 20 20  alue *pVal;.    
1970: 72 63 20 3d 20 78 56 61 6c 28 70 49 74 65 72 2c  rc = xVal(pIter,
1980: 20 70 49 64 78 2d 3e 61 69 43 6f 6c 5b 69 5d 2c   pIdx->aiCol[i],
1990: 20 26 70 56 61 6c 29 3b 0a 20 20 20 20 69 66 28   &pVal);.    if(
19a0: 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 29   rc==SQLITE_OK )
19b0: 7b 0a 20 20 20 20 20 20 69 6e 74 20 65 54 79 70  {.      int eTyp
19c0: 65 20 3d 20 30 3b 0a 20 20 20 20 20 20 69 66 28  e = 0;.      if(
19d0: 20 70 56 61 6c 20 29 7b 0a 20 20 20 20 20 20 20   pVal ){.       
19e0: 20 65 54 79 70 65 20 3d 20 73 71 6c 69 74 65 33   eType = sqlite3
19f0: 5f 76 61 6c 75 65 5f 74 79 70 65 28 70 56 61 6c  _value_type(pVal
1a00: 29 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 20  );.      }.     
1a10: 20 73 77 69 74 63 68 28 20 65 54 79 70 65 20 29   switch( eType )
1a20: 7b 0a 20 20 20 20 20 20 20 20 63 61 73 65 20 30  {.        case 0
1a30: 3a 0a 20 20 20 20 20 20 20 20 63 61 73 65 20 53  :.        case S
1a40: 51 4c 49 54 45 5f 4e 55 4c 4c 3a 0a 20 20 20 20  QLITE_NULL:.    
1a50: 20 20 20 20 20 20 72 65 74 75 72 6e 20 53 51 4c        return SQL
1a60: 49 54 45 5f 4f 4b 3b 0a 0a 20 20 20 20 20 20 20  ITE_OK;..       
1a70: 20 63 61 73 65 20 53 51 4c 49 54 45 5f 49 4e 54   case SQLITE_INT
1a80: 45 47 45 52 3a 0a 20 20 20 20 20 20 20 20 20 20  EGER:.          
1a90: 73 7a 20 2b 3d 20 38 3b 0a 20 20 20 20 20 20 20  sz += 8;.       
1aa0: 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20     break;.      
1ab0: 20 20 63 61 73 65 20 53 51 4c 49 54 45 5f 46 4c    case SQLITE_FL
1ac0: 4f 41 54 3a 0a 20 20 20 20 20 20 20 20 20 20 73  OAT:.          s
1ad0: 7a 20 2b 3d 20 38 3b 0a 20 20 20 20 20 20 20 20  z += 8;.        
1ae0: 20 20 62 72 65 61 6b 3b 0a 0a 20 20 20 20 20 20    break;..      
1af0: 20 20 64 65 66 61 75 6c 74 3a 0a 20 20 20 20 20    default:.     
1b00: 20 20 20 20 20 61 73 73 65 72 74 28 20 65 54 79       assert( eTy
1b10: 70 65 3d 3d 53 51 4c 49 54 45 5f 54 45 58 54 20  pe==SQLITE_TEXT 
1b20: 7c 7c 20 65 54 79 70 65 3d 3d 53 51 4c 49 54 45  || eType==SQLITE
1b30: 5f 42 4c 4f 42 20 29 3b 0a 20 20 20 20 20 20 20  _BLOB );.       
1b40: 20 20 20 73 7a 20 2b 3d 20 73 71 6c 69 74 65 33     sz += sqlite3
1b50: 5f 76 61 6c 75 65 5f 62 79 74 65 73 28 70 56 61  _value_bytes(pVa
1b60: 6c 29 3b 0a 20 20 20 20 20 20 20 20 20 20 62 72  l);.          br
1b70: 65 61 6b 3b 0a 20 20 20 20 20 20 7d 0a 20 20 20  eak;.      }.   
1b80: 20 7d 0a 20 20 7d 0a 0a 20 20 70 4e 65 77 20 3d   }.  }..  pNew =
1b90: 20 63 62 4d 61 6c 6c 6f 63 28 26 72 63 2c 20 73   cbMalloc(&rc, s
1ba0: 69 7a 65 6f 66 28 42 61 74 63 68 49 6e 64 65 78  izeof(BatchIndex
1bb0: 45 6e 74 72 79 29 20 2b 20 73 7a 29 3b 0a 20 20  Entry) + sz);.  
1bc0: 69 66 28 20 70 4e 65 77 20 29 7b 0a 20 20 20 20  if( pNew ){.    
1bd0: 70 4e 65 77 2d 3e 69 43 68 61 6e 67 65 73 65 74  pNew->iChangeset
1be0: 49 64 20 3d 20 70 2d 3e 69 43 68 61 6e 67 65 73  Id = p->iChanges
1bf0: 65 74 49 64 3b 0a 20 20 20 20 70 4e 65 77 2d 3e  etId;.    pNew->
1c00: 69 49 64 78 49 64 20 3d 20 70 49 64 78 2d 3e 69  iIdxId = pIdx->i
1c10: 49 64 3b 0a 20 20 20 20 70 4e 65 77 2d 3e 73 7a  Id;.    pNew->sz
1c20: 52 65 63 6f 72 64 20 3d 20 73 7a 3b 0a 0a 20 20  Record = sz;..  
1c30: 20 20 66 6f 72 28 69 3d 30 3b 20 72 63 3d 3d 53    for(i=0; rc==S
1c40: 51 4c 49 54 45 5f 4f 4b 20 26 26 20 69 3c 70 49  QLITE_OK && i<pI
1c50: 64 78 2d 3e 6e 43 6f 6c 3b 20 69 2b 2b 29 7b 0a  dx->nCol; i++){.
1c60: 20 20 20 20 20 20 73 71 6c 69 74 65 33 5f 76 61        sqlite3_va
1c70: 6c 75 65 20 2a 70 56 61 6c 3b 0a 20 20 20 20 20  lue *pVal;.     
1c80: 20 72 63 20 3d 20 78 56 61 6c 28 70 49 74 65 72   rc = xVal(pIter
1c90: 2c 20 70 49 64 78 2d 3e 61 69 43 6f 6c 5b 69 5d  , pIdx->aiCol[i]
1ca0: 2c 20 26 70 56 61 6c 29 3b 0a 20 20 20 20 20 20  , &pVal);.      
1cb0: 69 66 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f 4f  if( rc==SQLITE_O
1cc0: 4b 20 29 7b 0a 20 20 20 20 20 20 20 20 69 6e 74  K ){.        int
1cd0: 20 65 54 79 70 65 20 3d 20 73 71 6c 69 74 65 33   eType = sqlite3
1ce0: 5f 76 61 6c 75 65 5f 74 79 70 65 28 70 56 61 6c  _value_type(pVal
1cf0: 29 3b 0a 20 20 20 20 20 20 20 20 70 4e 65 77 2d  );.        pNew-
1d00: 3e 61 52 65 63 6f 72 64 5b 69 4f 75 74 2b 2b 5d  >aRecord[iOut++]
1d10: 20 3d 20 65 54 79 70 65 3b 0a 20 20 20 20 20 20   = eType;.      
1d20: 20 20 73 77 69 74 63 68 28 20 65 54 79 70 65 20    switch( eType 
1d30: 29 7b 0a 20 20 20 20 20 20 20 20 20 20 63 61 73  ){.          cas
1d40: 65 20 53 51 4c 49 54 45 5f 49 4e 54 45 47 45 52  e SQLITE_INTEGER
1d50: 3a 20 7b 0a 20 20 20 20 20 20 20 20 20 20 20 20  : {.            
1d60: 73 71 6c 69 74 65 33 5f 69 6e 74 36 34 20 69 36  sqlite3_int64 i6
1d70: 34 20 3d 20 73 71 6c 69 74 65 33 5f 76 61 6c 75  4 = sqlite3_valu
1d80: 65 5f 69 6e 74 36 34 28 70 56 61 6c 29 3b 0a 20  e_int64(pVal);. 
1d90: 20 20 20 20 20 20 20 20 20 20 20 6d 65 6d 63 70             memcp
1da0: 79 28 26 70 4e 65 77 2d 3e 61 52 65 63 6f 72 64  y(&pNew->aRecord
1db0: 5b 69 4f 75 74 5d 2c 20 26 69 36 34 2c 20 38 29  [iOut], &i64, 8)
1dc0: 3b 0a 20 20 20 20 20 20 20 20 20 20 20 20 69 4f  ;.            iO
1dd0: 75 74 20 2b 3d 20 38 3b 0a 20 20 20 20 20 20 20  ut += 8;.       
1de0: 20 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20       break;.    
1df0: 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20 20        }.        
1e00: 20 20 63 61 73 65 20 53 51 4c 49 54 45 5f 46 4c    case SQLITE_FL
1e10: 4f 41 54 3a 20 7b 0a 20 20 20 20 20 20 20 20 20  OAT: {.         
1e20: 20 20 20 64 6f 75 62 6c 65 20 64 36 34 20 3d 20     double d64 = 
1e30: 73 71 6c 69 74 65 33 5f 76 61 6c 75 65 5f 64 6f  sqlite3_value_do
1e40: 75 62 6c 65 28 70 56 61 6c 29 3b 0a 20 20 20 20  uble(pVal);.    
1e50: 20 20 20 20 20 20 20 20 6d 65 6d 63 70 79 28 26          memcpy(&
1e60: 70 4e 65 77 2d 3e 61 52 65 63 6f 72 64 5b 69 4f  pNew->aRecord[iO
1e70: 75 74 5d 2c 20 26 64 36 34 2c 20 73 69 7a 65 6f  ut], &d64, sizeo
1e80: 66 28 64 6f 75 62 6c 65 29 29 3b 0a 20 20 20 20  f(double));.    
1e90: 20 20 20 20 20 20 20 20 69 4f 75 74 20 2b 3d 20          iOut += 
1ea0: 73 69 7a 65 6f 66 28 64 6f 75 62 6c 65 29 3b 0a  sizeof(double);.
1eb0: 20 20 20 20 20 20 20 20 20 20 20 20 62 72 65 61              brea
1ec0: 6b 3b 0a 20 20 20 20 20 20 20 20 20 20 7d 0a 0a  k;.          }..
1ed0: 20 20 20 20 20 20 20 20 20 20 64 65 66 61 75 6c            defaul
1ee0: 74 3a 20 7b 0a 20 20 20 20 20 20 20 20 20 20 20  t: {.           
1ef0: 20 69 6e 74 20 6e 42 79 74 65 20 3d 20 73 71 6c   int nByte = sql
1f00: 69 74 65 33 5f 76 61 6c 75 65 5f 62 79 74 65 73  ite3_value_bytes
1f10: 28 70 56 61 6c 29 3b 0a 20 20 20 20 20 20 20 20  (pVal);.        
1f20: 20 20 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a      const char *
1f30: 7a 20 3d 20 28 63 6f 6e 73 74 20 63 68 61 72 2a  z = (const char*
1f40: 29 73 71 6c 69 74 65 33 5f 76 61 6c 75 65 5f 62  )sqlite3_value_b
1f50: 6c 6f 62 28 70 56 61 6c 29 3b 0a 20 20 20 20 20  lob(pVal);.     
1f60: 20 20 20 20 20 20 20 6d 65 6d 63 70 79 28 26 70         memcpy(&p
1f70: 4e 65 77 2d 3e 61 52 65 63 6f 72 64 5b 69 4f 75  New->aRecord[iOu
1f80: 74 5d 2c 20 7a 2c 20 6e 42 79 74 65 29 3b 0a 20  t], z, nByte);. 
1f90: 20 20 20 20 20 20 20 20 20 20 20 69 4f 75 74 20             iOut 
1fa0: 2b 3d 20 6e 42 79 74 65 3b 0a 20 20 20 20 20 20  += nByte;.      
1fb0: 20 20 20 20 20 20 62 72 65 61 6b 3b 0a 20 20 20        break;.   
1fc0: 20 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 20         }.       
1fd0: 20 7d 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 7d   }.      }.    }
1fe0: 0a 20 20 7d 0a 0a 20 20 69 66 28 20 72 63 3d 3d  .  }..  if( rc==
1ff0: 53 51 4c 49 54 45 5f 4f 4b 20 26 26 20 70 2d 3e  SQLITE_OK && p->
2000: 6e 45 6e 74 72 79 3e 3d 28 70 2d 3e 6e 48 61 73  nEntry>=(p->nHas
2010: 68 2f 32 29 20 29 7b 0a 20 20 20 20 72 63 20 3d  h/2) ){.    rc =
2020: 20 63 62 48 61 73 68 52 65 73 69 7a 65 28 70 29   cbHashResize(p)
2030: 3b 0a 20 20 7d 0a 0a 20 20 69 66 28 20 72 63 3d  ;.  }..  if( rc=
2040: 3d 53 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20  =SQLITE_OK ){.  
2050: 20 20 42 61 74 63 68 49 6e 64 65 78 45 6e 74 72    BatchIndexEntr
2060: 79 20 2a 70 49 74 65 72 3b 0a 20 20 20 20 69 6e  y *pIter;.    in
2070: 74 20 69 48 61 73 68 20 3d 20 63 62 48 61 73 68  t iHash = cbHash
2080: 28 70 2c 20 70 4e 65 77 29 3b 0a 0a 20 20 20 20  (p, pNew);..    
2090: 61 73 73 65 72 74 28 20 69 48 61 73 68 3e 3d 30  assert( iHash>=0
20a0: 20 26 26 20 69 48 61 73 68 3c 70 2d 3e 6e 48 61   && iHash<p->nHa
20b0: 73 68 20 29 3b 0a 20 20 20 20 66 6f 72 28 70 49  sh );.    for(pI
20c0: 74 65 72 3d 70 2d 3e 61 70 48 61 73 68 5b 69 48  ter=p->apHash[iH
20d0: 61 73 68 5d 3b 20 70 49 74 65 72 3b 20 70 49 74  ash]; pIter; pIt
20e0: 65 72 3d 70 49 74 65 72 2d 3e 70 4e 65 78 74 29  er=pIter->pNext)
20f0: 7b 0a 20 20 20 20 20 20 69 66 28 20 70 4e 65 77  {.      if( pNew
2100: 2d 3e 73 7a 52 65 63 6f 72 64 3d 3d 70 49 74 65  ->szRecord==pIte
2110: 72 2d 3e 73 7a 52 65 63 6f 72 64 20 0a 20 20 20  r->szRecord .   
2120: 20 20 20 20 26 26 20 30 3d 3d 6d 65 6d 63 6d 70      && 0==memcmp
2130: 28 70 4e 65 77 2d 3e 61 52 65 63 6f 72 64 2c 20  (pNew->aRecord, 
2140: 70 49 74 65 72 2d 3e 61 52 65 63 6f 72 64 2c 20  pIter->aRecord, 
2150: 70 4e 65 77 2d 3e 73 7a 52 65 63 6f 72 64 29 0a  pNew->szRecord).
2160: 20 20 20 20 20 20 29 7b 0a 20 20 20 20 20 20 20        ){.       
2170: 20 69 66 28 20 70 4e 65 77 2d 3e 69 43 68 61 6e   if( pNew->iChan
2180: 67 65 73 65 74 49 64 21 3d 70 49 74 65 72 2d 3e  gesetId!=pIter->
2190: 69 43 68 61 6e 67 65 73 65 74 49 64 20 29 7b 0a  iChangesetId ){.
21a0: 20 20 20 20 20 20 20 20 20 20 2a 70 62 43 6f 6e            *pbCon
21b0: 66 20 3d 20 31 3b 0a 20 20 20 20 20 20 20 20 7d  f = 1;.        }
21c0: 0a 20 20 20 20 20 20 20 20 63 62 46 72 65 65 28  .        cbFree(
21d0: 70 4e 65 77 29 3b 0a 20 20 20 20 20 20 20 20 70  pNew);.        p
21e0: 4e 65 77 20 3d 20 30 3b 0a 20 20 20 20 20 20 20  New = 0;.       
21f0: 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20 7d 0a   break;.      }.
2200: 20 20 20 20 7d 0a 0a 20 20 20 20 69 66 28 20 70      }..    if( p
2210: 4e 65 77 20 29 7b 0a 20 20 20 20 20 20 70 4e 65  New ){.      pNe
2220: 77 2d 3e 70 4e 65 78 74 20 3d 20 70 2d 3e 61 70  w->pNext = p->ap
2230: 48 61 73 68 5b 69 48 61 73 68 5d 3b 0a 20 20 20  Hash[iHash];.   
2240: 20 20 20 70 2d 3e 61 70 48 61 73 68 5b 69 48 61     p->apHash[iHa
2250: 73 68 5d 20 3d 20 70 4e 65 77 3b 0a 20 20 20 20  sh] = pNew;.    
2260: 20 20 70 2d 3e 6e 45 6e 74 72 79 2b 2b 3b 0a 20    p->nEntry++;. 
2270: 20 20 20 7d 0a 20 20 7d 0a 0a 20 20 70 2d 3e 69     }.  }..  p->i
2280: 43 68 61 6e 67 65 73 65 74 49 64 2b 2b 3b 0a 20  ChangesetId++;. 
2290: 20 72 65 74 75 72 6e 20 72 63 3b 0a 7d 0a 0a 0a   return rc;.}...
22a0: 2f 2a 0a 2a 2a 20 41 64 64 20 61 20 63 68 61 6e  /*.** Add a chan
22b0: 67 65 73 65 74 20 74 6f 20 74 68 65 20 63 75 72  geset to the cur
22c0: 72 65 6e 74 20 62 61 74 63 68 2e 0a 2a 2f 0a 69  rent batch..*/.i
22d0: 6e 74 20 73 71 6c 69 74 65 33 63 68 61 6e 67 65  nt sqlite3change
22e0: 62 61 74 63 68 5f 61 64 64 28 73 71 6c 69 74 65  batch_add(sqlite
22f0: 33 5f 63 68 61 6e 67 65 62 61 74 63 68 20 2a 70  3_changebatch *p
2300: 2c 20 76 6f 69 64 20 2a 70 42 75 66 2c 20 69 6e  , void *pBuf, in
2310: 74 20 6e 42 75 66 29 7b 0a 20 20 73 71 6c 69 74  t nBuf){.  sqlit
2320: 65 33 5f 63 68 61 6e 67 65 73 65 74 5f 69 74 65  e3_changeset_ite
2330: 72 20 2a 70 49 74 65 72 3b 20 20 2f 2a 20 49 74  r *pIter;  /* It
2340: 65 72 61 74 6f 72 20 6f 70 65 6e 65 64 20 6f 6e  erator opened on
2350: 20 70 42 75 66 2f 6e 42 75 66 20 2a 2f 0a 20 20   pBuf/nBuf */.  
2360: 69 6e 74 20 72 63 3b 20 20 20 20 20 20 20 20 20  int rc;         
2370: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
2380: 2f 2a 20 52 65 74 75 72 6e 20 63 6f 64 65 20 2a  /* Return code *
2390: 2f 0a 20 20 69 6e 74 20 62 43 6f 6e 66 20 3d 20  /.  int bConf = 
23a0: 30 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20  0;              
23b0: 20 20 20 20 2f 2a 20 43 6f 6e 66 6c 69 63 74 20      /* Conflict 
23c0: 77 61 73 20 64 65 74 65 63 74 65 64 20 2a 2f 0a  was detected */.
23d0: 0a 20 20 72 63 20 3d 20 73 71 6c 69 74 65 33 63  .  rc = sqlite3c
23e0: 68 61 6e 67 65 73 65 74 5f 73 74 61 72 74 28 26  hangeset_start(&
23f0: 70 49 74 65 72 2c 20 6e 42 75 66 2c 20 70 42 75  pIter, nBuf, pBu
2400: 66 29 3b 0a 20 20 69 66 28 20 72 63 3d 3d 53 51  f);.  if( rc==SQ
2410: 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20 20 69  LITE_OK ){.    i
2420: 6e 74 20 72 63 32 3b 0a 20 20 20 20 66 6f 72 28  nt rc2;.    for(
2430: 72 63 32 20 3d 20 73 71 6c 69 74 65 33 63 68 61  rc2 = sqlite3cha
2440: 6e 67 65 73 65 74 5f 6e 65 78 74 28 70 49 74 65  ngeset_next(pIte
2450: 72 29 3b 0a 20 20 20 20 20 20 20 20 72 63 32 3d  r);.        rc2=
2460: 3d 53 51 4c 49 54 45 5f 52 4f 57 3b 0a 20 20 20  =SQLITE_ROW;.   
2470: 20 20 20 20 20 72 63 32 20 3d 20 73 71 6c 69 74       rc2 = sqlit
2480: 65 33 63 68 61 6e 67 65 73 65 74 5f 6e 65 78 74  e3changeset_next
2490: 28 70 49 74 65 72 29 0a 20 20 20 20 29 7b 0a 20  (pIter).    ){. 
24a0: 20 20 20 20 20 42 61 74 63 68 54 61 62 6c 65 20       BatchTable 
24b0: 2a 70 54 61 62 3b 0a 20 20 20 20 20 20 42 61 74  *pTab;.      Bat
24c0: 63 68 49 6e 64 65 78 20 2a 70 49 64 78 3b 0a 20  chIndex *pIdx;. 
24d0: 20 20 20 20 20 63 6f 6e 73 74 20 63 68 61 72 20       const char 
24e0: 2a 7a 54 61 62 3b 20 20 20 20 20 20 20 20 20 20  *zTab;          
24f0: 20 2f 2a 20 54 61 62 6c 65 20 74 68 69 73 20 63   /* Table this c
2500: 68 61 6e 67 65 20 61 70 70 6c 69 65 73 20 74 6f  hange applies to
2510: 20 2a 2f 0a 20 20 20 20 20 20 69 6e 74 20 6e 43   */.      int nC
2520: 6f 6c 3b 20 20 20 20 20 20 20 20 20 20 20 20 20  ol;             
2530: 20 20 20 20 20 20 2f 2a 20 4e 75 6d 62 65 72 20        /* Number 
2540: 6f 66 20 63 6f 6c 75 6d 6e 73 20 69 6e 20 74 61  of columns in ta
2550: 62 6c 65 20 2a 2f 0a 20 20 20 20 20 20 69 6e 74  ble */.      int
2560: 20 6f 70 3b 20 20 20 20 20 20 20 20 20 20 20 20   op;            
2570: 20 20 20 20 20 20 20 20 20 2f 2a 20 55 50 44 41           /* UPDA
2580: 54 45 2c 20 49 4e 53 45 52 54 20 6f 72 20 44 45  TE, INSERT or DE
2590: 4c 45 54 45 20 2a 2f 0a 0a 20 20 20 20 20 20 73  LETE */..      s
25a0: 71 6c 69 74 65 33 63 68 61 6e 67 65 73 65 74 5f  qlite3changeset_
25b0: 6f 70 28 70 49 74 65 72 2c 20 26 7a 54 61 62 2c  op(pIter, &zTab,
25c0: 20 26 6e 43 6f 6c 2c 20 26 6f 70 2c 20 30 29 3b   &nCol, &op, 0);
25d0: 0a 20 20 20 20 20 20 61 73 73 65 72 74 28 20 6f  .      assert( o
25e0: 70 3d 3d 53 51 4c 49 54 45 5f 49 4e 53 45 52 54  p==SQLITE_INSERT
25f0: 20 7c 7c 20 6f 70 3d 3d 53 51 4c 49 54 45 5f 55   || op==SQLITE_U
2600: 50 44 41 54 45 20 7c 7c 20 6f 70 3d 3d 53 51 4c  PDATE || op==SQL
2610: 49 54 45 5f 44 45 4c 45 54 45 20 29 3b 0a 0a 20  ITE_DELETE );.. 
2620: 20 20 20 20 20 72 63 20 3d 20 63 62 46 69 6e 64       rc = cbFind
2630: 54 61 62 6c 65 28 70 2c 20 7a 54 61 62 2c 20 26  Table(p, zTab, &
2640: 70 54 61 62 29 3b 0a 20 20 20 20 20 20 66 6f 72  pTab);.      for
2650: 28 70 49 64 78 3d 70 54 61 62 2d 3e 70 49 64 78  (pIdx=pTab->pIdx
2660: 3b 20 70 49 64 78 20 26 26 20 72 63 3d 3d 53 51  ; pIdx && rc==SQ
2670: 4c 49 54 45 5f 4f 4b 3b 20 70 49 64 78 3d 70 49  LITE_OK; pIdx=pI
2680: 64 78 2d 3e 70 4e 65 78 74 29 7b 0a 20 20 20 20  dx->pNext){.    
2690: 20 20 20 20 69 66 28 20 6f 70 3d 3d 53 51 4c 49      if( op==SQLI
26a0: 54 45 5f 55 50 44 41 54 45 20 26 26 20 70 49 64  TE_UPDATE && pId
26b0: 78 2d 3e 62 50 6b 20 29 20 63 6f 6e 74 69 6e 75  x->bPk ) continu
26c0: 65 3b 0a 20 20 20 20 20 20 20 20 69 66 28 20 6f  e;.        if( o
26d0: 70 3d 3d 53 51 4c 49 54 45 5f 55 50 44 41 54 45  p==SQLITE_UPDATE
26e0: 20 7c 7c 20 6f 70 3d 3d 53 51 4c 49 54 45 5f 44   || op==SQLITE_D
26f0: 45 4c 45 54 45 20 29 7b 0a 20 20 20 20 20 20 20  ELETE ){.       
2700: 20 20 20 72 63 20 3d 20 63 62 41 64 64 54 6f 48     rc = cbAddToH
2710: 61 73 68 28 70 2c 20 70 49 74 65 72 2c 20 70 49  ash(p, pIter, pI
2720: 64 78 2c 20 73 71 6c 69 74 65 33 63 68 61 6e 67  dx, sqlite3chang
2730: 65 73 65 74 5f 6f 6c 64 2c 20 26 62 43 6f 6e 66  eset_old, &bConf
2740: 29 3b 0a 20 20 20 20 20 20 20 20 7d 0a 20 20 20  );.        }.   
2750: 20 20 20 20 20 69 66 28 20 6f 70 3d 3d 53 51 4c       if( op==SQL
2760: 49 54 45 5f 55 50 44 41 54 45 20 7c 7c 20 6f 70  ITE_UPDATE || op
2770: 3d 3d 53 51 4c 49 54 45 5f 49 4e 53 45 52 54 20  ==SQLITE_INSERT 
2780: 29 7b 0a 20 20 20 20 20 20 20 20 20 20 72 63 20  ){.          rc 
2790: 3d 20 63 62 41 64 64 54 6f 48 61 73 68 28 70 2c  = cbAddToHash(p,
27a0: 20 70 49 74 65 72 2c 20 70 49 64 78 2c 20 73 71   pIter, pIdx, sq
27b0: 6c 69 74 65 33 63 68 61 6e 67 65 73 65 74 5f 6e  lite3changeset_n
27c0: 65 77 2c 20 26 62 43 6f 6e 66 29 3b 0a 20 20 20  ew, &bConf);.   
27d0: 20 20 20 20 20 7d 0a 20 20 20 20 20 20 7d 0a 20       }.      }. 
27e0: 20 20 20 20 20 69 66 28 20 72 63 21 3d 53 51 4c       if( rc!=SQL
27f0: 49 54 45 5f 4f 4b 20 29 20 62 72 65 61 6b 3b 0a  ITE_OK ) break;.
2800: 20 20 20 20 7d 0a 0a 20 20 20 20 72 63 32 20 3d      }..    rc2 =
2810: 20 73 71 6c 69 74 65 33 63 68 61 6e 67 65 73 65   sqlite3changese
2820: 74 5f 66 69 6e 61 6c 69 7a 65 28 70 49 74 65 72  t_finalize(pIter
2830: 29 3b 0a 20 20 20 20 69 66 28 20 72 63 3d 3d 53  );.    if( rc==S
2840: 51 4c 49 54 45 5f 4f 4b 20 29 20 72 63 20 3d 20  QLITE_OK ) rc = 
2850: 72 63 32 3b 0a 20 20 7d 0a 0a 20 20 69 66 28 20  rc2;.  }..  if( 
2860: 72 63 3d 3d 53 51 4c 49 54 45 5f 4f 4b 20 26 26  rc==SQLITE_OK &&
2870: 20 62 43 6f 6e 66 20 29 7b 0a 20 20 20 20 72 63   bConf ){.    rc
2880: 20 3d 20 53 51 4c 49 54 45 5f 43 4f 4e 53 54 52   = SQLITE_CONSTR
2890: 41 49 4e 54 3b 0a 20 20 7d 0a 20 20 72 65 74 75  AINT;.  }.  retu
28a0: 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20  rn rc;.}../*.** 
28b0: 5a 65 72 6f 20 61 6e 20 65 78 69 73 74 69 6e 67  Zero an existing
28c0: 20 63 68 61 6e 67 65 62 61 74 63 68 20 6f 62 6a   changebatch obj
28d0: 65 63 74 2e 0a 2a 2f 0a 76 6f 69 64 20 73 71 6c  ect..*/.void sql
28e0: 69 74 65 33 63 68 61 6e 67 65 62 61 74 63 68 5f  ite3changebatch_
28f0: 7a 65 72 6f 28 73 71 6c 69 74 65 33 5f 63 68 61  zero(sqlite3_cha
2900: 6e 67 65 62 61 74 63 68 20 2a 70 29 7b 0a 20 20  ngebatch *p){.  
2910: 69 6e 74 20 69 3b 0a 20 20 66 6f 72 28 69 3d 30  int i;.  for(i=0
2920: 3b 20 69 3c 70 2d 3e 6e 48 61 73 68 3b 20 69 2b  ; i<p->nHash; i+
2930: 2b 29 7b 0a 20 20 20 20 42 61 74 63 68 49 6e 64  +){.    BatchInd
2940: 65 78 45 6e 74 72 79 20 2a 70 45 6e 74 72 79 3b  exEntry *pEntry;
2950: 0a 20 20 20 20 42 61 74 63 68 49 6e 64 65 78 45  .    BatchIndexE
2960: 6e 74 72 79 20 2a 70 4e 65 78 74 3b 0a 20 20 20  ntry *pNext;.   
2970: 20 66 6f 72 28 70 45 6e 74 72 79 3d 70 2d 3e 61   for(pEntry=p->a
2980: 70 48 61 73 68 5b 69 5d 3b 20 70 45 6e 74 72 79  pHash[i]; pEntry
2990: 3b 20 70 45 6e 74 72 79 3d 70 4e 65 78 74 29 7b  ; pEntry=pNext){
29a0: 0a 20 20 20 20 20 20 70 4e 65 78 74 20 3d 20 70  .      pNext = p
29b0: 45 6e 74 72 79 2d 3e 70 4e 65 78 74 3b 0a 20 20  Entry->pNext;.  
29c0: 20 20 20 20 63 62 46 72 65 65 28 70 45 6e 74 72      cbFree(pEntr
29d0: 79 29 3b 0a 20 20 20 20 7d 0a 20 20 7d 0a 20 20  y);.    }.  }.  
29e0: 63 62 46 72 65 65 28 70 2d 3e 61 70 48 61 73 68  cbFree(p->apHash
29f0: 29 3b 0a 20 20 70 2d 3e 6e 48 61 73 68 20 3d 20  );.  p->nHash = 
2a00: 30 3b 0a 20 20 70 2d 3e 61 70 48 61 73 68 20 3d  0;.  p->apHash =
2a10: 20 30 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 44 65 6c   0;.}../*.** Del
2a20: 65 74 65 20 61 20 63 68 61 6e 67 65 62 61 74 63  ete a changebatc
2a30: 68 20 6f 62 6a 65 63 74 2e 0a 2a 2f 0a 76 6f 69  h object..*/.voi
2a40: 64 20 73 71 6c 69 74 65 33 63 68 61 6e 67 65 62  d sqlite3changeb
2a50: 61 74 63 68 5f 64 65 6c 65 74 65 28 73 71 6c 69  atch_delete(sqli
2a60: 74 65 33 5f 63 68 61 6e 67 65 62 61 74 63 68 20  te3_changebatch 
2a70: 2a 70 29 7b 0a 20 20 42 61 74 63 68 54 61 62 6c  *p){.  BatchTabl
2a80: 65 20 2a 70 54 61 62 3b 0a 20 20 42 61 74 63 68  e *pTab;.  Batch
2a90: 54 61 62 6c 65 20 2a 70 54 61 62 4e 65 78 74 3b  Table *pTabNext;
2aa0: 0a 0a 20 20 73 71 6c 69 74 65 33 63 68 61 6e 67  ..  sqlite3chang
2ab0: 65 62 61 74 63 68 5f 7a 65 72 6f 28 70 29 3b 0a  ebatch_zero(p);.
2ac0: 20 20 66 6f 72 28 70 54 61 62 3d 70 2d 3e 70 54    for(pTab=p->pT
2ad0: 61 62 3b 20 70 54 61 62 3b 20 70 54 61 62 3d 70  ab; pTab; pTab=p
2ae0: 54 61 62 4e 65 78 74 29 7b 0a 20 20 20 20 42 61  TabNext){.    Ba
2af0: 74 63 68 49 6e 64 65 78 20 2a 70 49 64 78 3b 0a  tchIndex *pIdx;.
2b00: 20 20 20 20 42 61 74 63 68 49 6e 64 65 78 20 2a      BatchIndex *
2b10: 70 49 64 78 4e 65 78 74 3b 0a 20 20 20 20 66 6f  pIdxNext;.    fo
2b20: 72 28 70 49 64 78 3d 70 54 61 62 2d 3e 70 49 64  r(pIdx=pTab->pId
2b30: 78 3b 20 70 49 64 78 3b 20 70 49 64 78 3d 70 49  x; pIdx; pIdx=pI
2b40: 64 78 4e 65 78 74 29 7b 0a 20 20 20 20 20 20 70  dxNext){.      p
2b50: 49 64 78 4e 65 78 74 20 3d 20 70 49 64 78 2d 3e  IdxNext = pIdx->
2b60: 70 4e 65 78 74 3b 0a 20 20 20 20 20 20 63 62 46  pNext;.      cbF
2b70: 72 65 65 28 70 49 64 78 29 3b 0a 20 20 20 20 7d  ree(pIdx);.    }
2b80: 0a 20 20 20 20 70 54 61 62 4e 65 78 74 20 3d 20  .    pTabNext = 
2b90: 70 54 61 62 2d 3e 70 4e 65 78 74 3b 0a 20 20 20  pTab->pNext;.   
2ba0: 20 63 62 46 72 65 65 28 70 54 61 62 29 3b 0a 20   cbFree(pTab);. 
2bb0: 20 7d 0a 20 20 63 62 46 72 65 65 28 70 29 3b 0a   }.  cbFree(p);.
2bc0: 7d 0a 0a 23 65 6e 64 69 66 20 2f 2a 20 53 51 4c  }..#endif /* SQL
2bd0: 49 54 45 5f 45 4e 41 42 4c 45 5f 53 45 53 53 49  ITE_ENABLE_SESSI
2be0: 4f 4e 20 26 26 20 53 51 4c 49 54 45 5f 45 4e 41  ON && SQLITE_ENA
2bf0: 42 4c 45 5f 50 52 45 55 50 44 41 54 45 5f 48 4f  BLE_PREUPDATE_HO
2c00: 4f 4b 20 2a 2f 0a                                OK */.