/ Hex Artifact Content
Login

Artifact f93110888ddc246215e9ba1f831d3d375bfd8355:


0000: 2f 2a 0a 2a 2a 20 32 30 30 37 20 4d 61 79 20 31  /*.** 2007 May 1
0010: 0a 2a 2a 0a 2a 2a 20 54 68 65 20 61 75 74 68 6f  .**.** The autho
0020: 72 20 64 69 73 63 6c 61 69 6d 73 20 63 6f 70 79  r disclaims copy
0030: 72 69 67 68 74 20 74 6f 20 74 68 69 73 20 73 6f  right to this so
0040: 75 72 63 65 20 63 6f 64 65 2e 20 20 49 6e 20 70  urce code.  In p
0050: 6c 61 63 65 20 6f 66 0a 2a 2a 20 61 20 6c 65 67  lace of.** a leg
0060: 61 6c 20 6e 6f 74 69 63 65 2c 20 68 65 72 65 20  al notice, here 
0070: 69 73 20 61 20 62 6c 65 73 73 69 6e 67 3a 0a 2a  is a blessing:.*
0080: 2a 0a 2a 2a 20 20 20 20 4d 61 79 20 79 6f 75 20  *.**    May you 
0090: 64 6f 20 67 6f 6f 64 20 61 6e 64 20 6e 6f 74 20  do good and not 
00a0: 65 76 69 6c 2e 0a 2a 2a 20 20 20 20 4d 61 79 20  evil..**    May 
00b0: 79 6f 75 20 66 69 6e 64 20 66 6f 72 67 69 76 65  you find forgive
00c0: 6e 65 73 73 20 66 6f 72 20 79 6f 75 72 73 65 6c  ness for yoursel
00d0: 66 20 61 6e 64 20 66 6f 72 67 69 76 65 20 6f 74  f and forgive ot
00e0: 68 65 72 73 2e 0a 2a 2a 20 20 20 20 4d 61 79 20  hers..**    May 
00f0: 79 6f 75 20 73 68 61 72 65 20 66 72 65 65 6c 79  you share freely
0100: 2c 20 6e 65 76 65 72 20 74 61 6b 69 6e 67 20 6d  , never taking m
0110: 6f 72 65 20 74 68 61 6e 20 79 6f 75 20 67 69 76  ore than you giv
0120: 65 2e 0a 2a 2a 0a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  e..**.**********
0130: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0140: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0150: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a  ****************
0160: 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 2a 0a  ***************.
0170: 2a 2a 0a 2a 2a 20 54 68 69 73 20 66 69 6c 65 20  **.** This file 
0180: 63 6f 6e 74 61 69 6e 73 20 63 6f 64 65 20 75 73  contains code us
0190: 65 64 20 74 6f 20 69 6d 70 6c 65 6d 65 6e 74 20  ed to implement 
01a0: 69 6e 63 72 65 6d 65 6e 74 61 6c 20 42 4c 4f 42  incremental BLOB
01b0: 20 49 2f 4f 2e 0a 2a 2a 0a 2a 2a 20 24 49 64 3a   I/O..**.** $Id:
01c0: 20 76 64 62 65 62 6c 6f 62 2e 63 2c 76 20 31 2e   vdbeblob.c,v 1.
01d0: 32 35 20 32 30 30 38 2f 30 37 2f 32 38 20 31 39  25 2008/07/28 19
01e0: 3a 33 34 3a 35 34 20 64 72 68 20 45 78 70 20 24  :34:54 drh Exp $
01f0: 0a 2a 2f 0a 0a 23 69 6e 63 6c 75 64 65 20 22 73  .*/..#include "s
0200: 71 6c 69 74 65 49 6e 74 2e 68 22 0a 23 69 6e 63  qliteInt.h".#inc
0210: 6c 75 64 65 20 22 76 64 62 65 49 6e 74 2e 68 22  lude "vdbeInt.h"
0220: 0a 0a 23 69 66 6e 64 65 66 20 53 51 4c 49 54 45  ..#ifndef SQLITE
0230: 5f 4f 4d 49 54 5f 49 4e 43 52 42 4c 4f 42 0a 0a  _OMIT_INCRBLOB..
0240: 2f 2a 0a 2a 2a 20 56 61 6c 69 64 20 73 71 6c 69  /*.** Valid sqli
0250: 74 65 33 5f 62 6c 6f 62 2a 20 68 61 6e 64 6c 65  te3_blob* handle
0260: 73 20 70 6f 69 6e 74 20 74 6f 20 49 6e 63 72 62  s point to Incrb
0270: 6c 6f 62 20 73 74 72 75 63 74 75 72 65 73 2e 0a  lob structures..
0280: 2a 2f 0a 74 79 70 65 64 65 66 20 73 74 72 75 63  */.typedef struc
0290: 74 20 49 6e 63 72 62 6c 6f 62 20 49 6e 63 72 62  t Incrblob Incrb
02a0: 6c 6f 62 3b 0a 73 74 72 75 63 74 20 49 6e 63 72  lob;.struct Incr
02b0: 62 6c 6f 62 20 7b 0a 20 20 69 6e 74 20 66 6c 61  blob {.  int fla
02c0: 67 73 3b 20 20 20 20 20 20 20 20 20 20 20 20 20  gs;             
02d0: 20 2f 2a 20 43 6f 70 79 20 6f 66 20 22 66 6c 61   /* Copy of "fla
02e0: 67 73 22 20 70 61 73 73 65 64 20 74 6f 20 73 71  gs" passed to sq
02f0: 6c 69 74 65 33 5f 62 6c 6f 62 5f 6f 70 65 6e 28  lite3_blob_open(
0300: 29 20 2a 2f 0a 20 20 69 6e 74 20 6e 42 79 74 65  ) */.  int nByte
0310: 3b 20 20 20 20 20 20 20 20 20 20 20 20 20 20 2f  ;              /
0320: 2a 20 53 69 7a 65 20 6f 66 20 6f 70 65 6e 20 62  * Size of open b
0330: 6c 6f 62 2c 20 69 6e 20 62 79 74 65 73 20 2a 2f  lob, in bytes */
0340: 0a 20 20 69 6e 74 20 69 4f 66 66 73 65 74 3b 20  .  int iOffset; 
0350: 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20 42 79             /* By
0360: 74 65 20 6f 66 66 73 65 74 20 6f 66 20 62 6c 6f  te offset of blo
0370: 62 20 69 6e 20 63 75 72 73 6f 72 20 64 61 74 61  b in cursor data
0380: 20 2a 2f 0a 20 20 42 74 43 75 72 73 6f 72 20 2a   */.  BtCursor *
0390: 70 43 73 72 3b 20 20 20 20 20 20 20 20 20 2f 2a  pCsr;         /*
03a0: 20 43 75 72 73 6f 72 20 70 6f 69 6e 74 69 6e 67   Cursor pointing
03b0: 20 61 74 20 62 6c 6f 62 20 72 6f 77 20 2a 2f 0a   at blob row */.
03c0: 20 20 73 71 6c 69 74 65 33 5f 73 74 6d 74 20 2a    sqlite3_stmt *
03d0: 70 53 74 6d 74 3b 20 20 20 20 2f 2a 20 53 74 61  pStmt;    /* Sta
03e0: 74 65 6d 65 6e 74 20 68 6f 6c 64 69 6e 67 20 63  tement holding c
03f0: 75 72 73 6f 72 20 6f 70 65 6e 20 2a 2f 0a 20 20  ursor open */.  
0400: 73 71 6c 69 74 65 33 20 2a 64 62 3b 20 20 20 20  sqlite3 *db;    
0410: 20 20 20 20 20 20 20 20 2f 2a 20 54 68 65 20 61          /* The a
0420: 73 73 6f 63 69 61 74 65 64 20 64 61 74 61 62 61  ssociated databa
0430: 73 65 20 2a 2f 0a 7d 3b 0a 0a 2f 2a 0a 2a 2a 20  se */.};../*.** 
0440: 4f 70 65 6e 20 61 20 62 6c 6f 62 20 68 61 6e 64  Open a blob hand
0450: 6c 65 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74  le..*/.int sqlit
0460: 65 33 5f 62 6c 6f 62 5f 6f 70 65 6e 28 0a 20 20  e3_blob_open(.  
0470: 73 71 6c 69 74 65 33 2a 20 64 62 2c 20 20 20 20  sqlite3* db,    
0480: 20 20 20 20 20 20 20 20 2f 2a 20 54 68 65 20 64          /* The d
0490: 61 74 61 62 61 73 65 20 63 6f 6e 6e 65 63 74 69  atabase connecti
04a0: 6f 6e 20 2a 2f 0a 20 20 63 6f 6e 73 74 20 63 68  on */.  const ch
04b0: 61 72 20 2a 7a 44 62 2c 20 20 20 20 20 20 20 20  ar *zDb,        
04c0: 2f 2a 20 54 68 65 20 61 74 74 61 63 68 65 64 20  /* The attached 
04d0: 64 61 74 61 62 61 73 65 20 63 6f 6e 74 61 69 6e  database contain
04e0: 69 6e 67 20 74 68 65 20 62 6c 6f 62 20 2a 2f 0a  ing the blob */.
04f0: 20 20 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 54    const char *zT
0500: 61 62 6c 65 2c 20 20 20 20 20 2f 2a 20 54 68 65  able,     /* The
0510: 20 74 61 62 6c 65 20 63 6f 6e 74 61 69 6e 69 6e   table containin
0520: 67 20 74 68 65 20 62 6c 6f 62 20 2a 2f 0a 20 20  g the blob */.  
0530: 63 6f 6e 73 74 20 63 68 61 72 20 2a 7a 43 6f 6c  const char *zCol
0540: 75 6d 6e 2c 20 20 20 20 2f 2a 20 54 68 65 20 63  umn,    /* The c
0550: 6f 6c 75 6d 6e 20 63 6f 6e 74 61 69 6e 69 6e 67  olumn containing
0560: 20 74 68 65 20 62 6c 6f 62 20 2a 2f 0a 20 20 73   the blob */.  s
0570: 71 6c 69 74 65 5f 69 6e 74 36 34 20 69 52 6f 77  qlite_int64 iRow
0580: 2c 20 20 20 20 20 20 2f 2a 20 54 68 65 20 72 6f  ,      /* The ro
0590: 77 20 63 6f 6e 74 61 69 6e 69 6e 67 20 74 68 65  w containing the
05a0: 20 67 6c 6f 62 20 2a 2f 0a 20 20 69 6e 74 20 66   glob */.  int f
05b0: 6c 61 67 73 2c 20 20 20 20 20 20 20 20 20 20 20  lags,           
05c0: 20 20 20 2f 2a 20 54 72 75 65 20 2d 3e 20 72 65     /* True -> re
05d0: 61 64 2f 77 72 69 74 65 20 61 63 63 65 73 73 2c  ad/write access,
05e0: 20 66 61 6c 73 65 20 2d 3e 20 72 65 61 64 2d 6f   false -> read-o
05f0: 6e 6c 79 20 2a 2f 0a 20 20 73 71 6c 69 74 65 33  nly */.  sqlite3
0600: 5f 62 6c 6f 62 20 2a 2a 70 70 42 6c 6f 62 20 20  _blob **ppBlob  
0610: 20 2f 2a 20 48 61 6e 64 6c 65 20 66 6f 72 20 61   /* Handle for a
0620: 63 63 65 73 73 69 6e 67 20 74 68 65 20 62 6c 6f  ccessing the blo
0630: 62 20 72 65 74 75 72 6e 65 64 20 68 65 72 65 20  b returned here 
0640: 2a 2f 0a 29 7b 0a 20 20 69 6e 74 20 6e 41 74 74  */.){.  int nAtt
0650: 65 6d 70 74 20 3d 20 30 3b 0a 20 20 69 6e 74 20  empt = 0;.  int 
0660: 69 43 6f 6c 3b 20 20 20 20 20 20 20 20 20 20 20  iCol;           
0670: 20 20 20 20 2f 2a 20 49 6e 64 65 78 20 6f 66 20      /* Index of 
0680: 7a 43 6f 6c 75 6d 6e 20 69 6e 20 72 6f 77 2d 72  zColumn in row-r
0690: 65 63 6f 72 64 20 2a 2f 0a 0a 20 20 2f 2a 20 54  ecord */..  /* T
06a0: 68 69 73 20 56 44 42 45 20 70 72 6f 67 72 61 6d  his VDBE program
06b0: 20 73 65 65 6b 73 20 61 20 62 74 72 65 65 20 63   seeks a btree c
06c0: 75 72 73 6f 72 20 74 6f 20 74 68 65 20 69 64 65  ursor to the ide
06d0: 6e 74 69 66 69 65 64 20 0a 20 20 2a 2a 20 64 62  ntified .  ** db
06e0: 2f 74 61 62 6c 65 2f 72 6f 77 20 65 6e 74 72 79  /table/row entry
06f0: 2e 20 54 68 65 20 72 65 61 73 6f 6e 20 66 6f 72  . The reason for
0700: 20 75 73 69 6e 67 20 61 20 76 64 62 65 20 70 72   using a vdbe pr
0710: 6f 67 72 61 6d 20 69 6e 73 74 65 61 64 0a 20 20  ogram instead.  
0720: 2a 2a 20 6f 66 20 77 72 69 74 69 6e 67 20 63 6f  ** of writing co
0730: 64 65 20 74 6f 20 75 73 65 20 74 68 65 20 62 2d  de to use the b-
0740: 74 72 65 65 20 6c 61 79 65 72 20 64 69 72 65 63  tree layer direc
0750: 74 6c 79 20 69 73 20 74 68 61 74 20 74 68 65 0a  tly is that the.
0760: 20 20 2a 2a 20 76 64 62 65 20 70 72 6f 67 72 61    ** vdbe progra
0770: 6d 20 77 69 6c 6c 20 74 61 6b 65 20 61 64 76 61  m will take adva
0780: 6e 74 61 67 65 20 6f 66 20 74 68 65 20 76 61 72  ntage of the var
0790: 69 6f 75 73 20 74 72 61 6e 73 61 63 74 69 6f 6e  ious transaction
07a0: 2c 0a 20 20 2a 2a 20 6c 6f 63 6b 69 6e 67 20 61  ,.  ** locking a
07b0: 6e 64 20 65 72 72 6f 72 20 68 61 6e 64 6c 69 6e  nd error handlin
07c0: 67 20 69 6e 66 72 61 73 74 72 75 63 74 75 72 65  g infrastructure
07d0: 20 62 75 69 6c 74 20 69 6e 74 6f 20 74 68 65 20   built into the 
07e0: 76 64 62 65 2e 0a 20 20 2a 2a 0a 20 20 2a 2a 20  vdbe..  **.  ** 
07f0: 41 66 74 65 72 20 73 65 65 6b 69 6e 67 20 74 68  After seeking th
0800: 65 20 63 75 72 73 6f 72 2c 20 74 68 65 20 76 64  e cursor, the vd
0810: 62 65 20 65 78 65 63 75 74 65 73 20 61 6e 20 4f  be executes an O
0820: 50 5f 52 65 73 75 6c 74 52 6f 77 2e 0a 20 20 2a  P_ResultRow..  *
0830: 2a 20 43 6f 64 65 20 65 78 74 65 72 6e 61 6c 20  * Code external 
0840: 74 6f 20 74 68 65 20 56 64 62 65 20 74 68 65 6e  to the Vdbe then
0850: 20 22 62 6f 72 72 6f 77 73 22 20 74 68 65 20 62   "borrows" the b
0860: 2d 74 72 65 65 20 63 75 72 73 6f 72 20 61 6e 64  -tree cursor and
0870: 0a 20 20 2a 2a 20 75 73 65 73 20 69 74 20 74 6f  .  ** uses it to
0880: 20 69 6d 70 6c 65 6d 65 6e 74 20 74 68 65 20 62   implement the b
0890: 6c 6f 62 5f 72 65 61 64 28 29 2c 20 62 6c 6f 62  lob_read(), blob
08a0: 5f 77 72 69 74 65 28 29 20 61 6e 64 20 0a 20 20  _write() and .  
08b0: 2a 2a 20 62 6c 6f 62 5f 62 79 74 65 73 28 29 20  ** blob_bytes() 
08c0: 66 75 6e 63 74 69 6f 6e 73 2e 0a 20 20 2a 2a 0a  functions..  **.
08d0: 20 20 2a 2a 20 54 68 65 20 73 71 6c 69 74 65 33    ** The sqlite3
08e0: 5f 62 6c 6f 62 5f 63 6c 6f 73 65 28 29 20 66 75  _blob_close() fu
08f0: 6e 63 74 69 6f 6e 20 66 69 6e 61 6c 69 7a 65 73  nction finalizes
0900: 20 74 68 65 20 76 64 62 65 20 70 72 6f 67 72 61   the vdbe progra
0910: 6d 2c 0a 20 20 2a 2a 20 77 68 69 63 68 20 63 6c  m,.  ** which cl
0920: 6f 73 65 73 20 74 68 65 20 62 2d 74 72 65 65 20  oses the b-tree 
0930: 63 75 72 73 6f 72 20 61 6e 64 20 28 70 6f 73 73  cursor and (poss
0940: 69 62 6c 79 29 20 63 6f 6d 6d 69 74 73 20 74 68  ibly) commits th
0950: 65 20 0a 20 20 2a 2a 20 74 72 61 6e 73 61 63 74  e .  ** transact
0960: 69 6f 6e 2e 0a 20 20 2a 2f 0a 20 20 73 74 61 74  ion..  */.  stat
0970: 69 63 20 63 6f 6e 73 74 20 56 64 62 65 4f 70 4c  ic const VdbeOpL
0980: 69 73 74 20 6f 70 65 6e 42 6c 6f 62 5b 5d 20 3d  ist openBlob[] =
0990: 20 7b 0a 20 20 20 20 7b 4f 50 5f 54 72 61 6e 73   {.    {OP_Trans
09a0: 61 63 74 69 6f 6e 2c 20 30 2c 20 30 2c 20 30 7d  action, 0, 0, 0}
09b0: 2c 20 20 20 20 20 2f 2a 20 30 3a 20 53 74 61 72  ,     /* 0: Star
09c0: 74 20 61 20 74 72 61 6e 73 61 63 74 69 6f 6e 20  t a transaction 
09d0: 2a 2f 0a 20 20 20 20 7b 4f 50 5f 56 65 72 69 66  */.    {OP_Verif
09e0: 79 43 6f 6f 6b 69 65 2c 20 30 2c 20 30 2c 20 30  yCookie, 0, 0, 0
09f0: 7d 2c 20 20 20 20 2f 2a 20 31 3a 20 43 68 65 63  },    /* 1: Chec
0a00: 6b 20 74 68 65 20 73 63 68 65 6d 61 20 63 6f 6f  k the schema coo
0a10: 6b 69 65 20 2a 2f 0a 0a 20 20 20 20 2f 2a 20 4f  kie */..    /* O
0a20: 6e 65 20 6f 66 20 74 68 65 20 66 6f 6c 6c 6f 77  ne of the follow
0a30: 69 6e 67 20 74 77 6f 20 69 6e 73 74 72 75 63 74  ing two instruct
0a40: 69 6f 6e 73 20 69 73 20 72 65 70 6c 61 63 65 64  ions is replaced
0a50: 20 62 79 20 61 6e 0a 20 20 20 20 2a 2a 20 4f 50   by an.    ** OP
0a60: 5f 4e 6f 6f 70 20 62 65 66 6f 72 65 20 65 78 65  _Noop before exe
0a70: 63 74 69 6f 6e 2e 0a 20 20 20 20 2a 2f 0a 20 20  ction..    */.  
0a80: 20 20 7b 4f 50 5f 53 65 74 4e 75 6d 43 6f 6c 75    {OP_SetNumColu
0a90: 6d 6e 73 2c 20 30 2c 20 30 2c 20 30 7d 2c 20 20  mns, 0, 0, 0},  
0aa0: 20 2f 2a 20 32 3a 20 4e 75 6d 20 63 6f 6c 73 20   /* 2: Num cols 
0ab0: 66 6f 72 20 63 75 72 73 6f 72 20 2a 2f 0a 20 20  for cursor */.  
0ac0: 20 20 7b 4f 50 5f 4f 70 65 6e 52 65 61 64 2c 20    {OP_OpenRead, 
0ad0: 30 2c 20 30 2c 20 30 7d 2c 20 20 20 20 20 20 20  0, 0, 0},       
0ae0: 20 2f 2a 20 33 3a 20 4f 70 65 6e 20 63 75 72 73   /* 3: Open curs
0af0: 6f 72 20 30 20 66 6f 72 20 72 65 61 64 69 6e 67  or 0 for reading
0b00: 20 2a 2f 0a 20 20 20 20 7b 4f 50 5f 53 65 74 4e   */.    {OP_SetN
0b10: 75 6d 43 6f 6c 75 6d 6e 73 2c 20 30 2c 20 30 2c  umColumns, 0, 0,
0b20: 20 30 7d 2c 20 20 20 2f 2a 20 34 3a 20 4e 75 6d   0},   /* 4: Num
0b30: 20 63 6f 6c 73 20 66 6f 72 20 63 75 72 73 6f 72   cols for cursor
0b40: 20 2a 2f 0a 20 20 20 20 7b 4f 50 5f 4f 70 65 6e   */.    {OP_Open
0b50: 57 72 69 74 65 2c 20 30 2c 20 30 2c 20 30 7d 2c  Write, 0, 0, 0},
0b60: 20 20 20 20 20 20 20 2f 2a 20 35 3a 20 4f 70 65         /* 5: Ope
0b70: 6e 20 63 75 72 73 6f 72 20 30 20 66 6f 72 20 72  n cursor 0 for r
0b80: 65 61 64 2f 77 72 69 74 65 20 2a 2f 0a 0a 20 20  ead/write */..  
0b90: 20 20 7b 4f 50 5f 56 61 72 69 61 62 6c 65 2c 20    {OP_Variable, 
0ba0: 31 2c 20 31 2c 20 30 7d 2c 20 20 20 20 20 20 20  1, 1, 0},       
0bb0: 20 2f 2a 20 36 3a 20 50 75 73 68 20 74 68 65 20   /* 6: Push the 
0bc0: 72 6f 77 69 64 20 74 6f 20 74 68 65 20 73 74 61  rowid to the sta
0bd0: 63 6b 20 2a 2f 0a 20 20 20 20 7b 4f 50 5f 4e 6f  ck */.    {OP_No
0be0: 74 45 78 69 73 74 73 2c 20 30 2c 20 31 30 2c 20  tExists, 0, 10, 
0bf0: 31 7d 2c 20 20 20 20 20 20 2f 2a 20 37 3a 20 53  1},      /* 7: S
0c00: 65 65 6b 20 74 68 65 20 63 75 72 73 6f 72 20 2a  eek the cursor *
0c10: 2f 0a 20 20 20 20 7b 4f 50 5f 43 6f 6c 75 6d 6e  /.    {OP_Column
0c20: 2c 20 30 2c 20 30 2c 20 31 7d 2c 20 20 20 20 20  , 0, 0, 1},     
0c30: 20 20 20 20 20 2f 2a 20 38 20 20 2a 2f 0a 20 20       /* 8  */.  
0c40: 20 20 7b 4f 50 5f 52 65 73 75 6c 74 52 6f 77 2c    {OP_ResultRow,
0c50: 20 31 2c 20 30 2c 20 30 7d 2c 20 20 20 20 20 20   1, 0, 0},      
0c60: 20 2f 2a 20 39 20 20 2a 2f 0a 20 20 20 20 7b 4f   /* 9  */.    {O
0c70: 50 5f 43 6c 6f 73 65 2c 20 30 2c 20 30 2c 20 30  P_Close, 0, 0, 0
0c80: 7d 2c 20 20 20 20 20 20 20 20 20 20 20 2f 2a 20  },           /* 
0c90: 31 30 20 20 2a 2f 0a 20 20 20 20 7b 4f 50 5f 48  10  */.    {OP_H
0ca0: 61 6c 74 2c 20 30 2c 20 30 2c 20 30 7d 2c 20 20  alt, 0, 0, 0},  
0cb0: 20 20 20 20 20 20 20 20 20 20 2f 2a 20 31 31 20            /* 11 
0cc0: 2a 2f 0a 20 20 7d 3b 0a 0a 20 20 56 64 62 65 20  */.  };..  Vdbe 
0cd0: 2a 76 20 3d 20 30 3b 0a 20 20 69 6e 74 20 72 63  *v = 0;.  int rc
0ce0: 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a 20 20   = SQLITE_OK;.  
0cf0: 63 68 61 72 20 7a 45 72 72 5b 31 32 38 5d 3b 0a  char zErr[128];.
0d00: 0a 20 20 7a 45 72 72 5b 30 5d 20 3d 20 30 3b 0a  .  zErr[0] = 0;.
0d10: 20 20 73 71 6c 69 74 65 33 5f 6d 75 74 65 78 5f    sqlite3_mutex_
0d20: 65 6e 74 65 72 28 64 62 2d 3e 6d 75 74 65 78 29  enter(db->mutex)
0d30: 3b 0a 20 20 64 6f 20 7b 0a 20 20 20 20 50 61 72  ;.  do {.    Par
0d40: 73 65 20 73 50 61 72 73 65 3b 0a 20 20 20 20 54  se sParse;.    T
0d50: 61 62 6c 65 20 2a 70 54 61 62 3b 0a 0a 20 20 20  able *pTab;..   
0d60: 20 6d 65 6d 73 65 74 28 26 73 50 61 72 73 65 2c   memset(&sParse,
0d70: 20 30 2c 20 73 69 7a 65 6f 66 28 50 61 72 73 65   0, sizeof(Parse
0d80: 29 29 3b 0a 20 20 20 20 73 50 61 72 73 65 2e 64  ));.    sParse.d
0d90: 62 20 3d 20 64 62 3b 0a 0a 20 20 20 20 69 66 28  b = db;..    if(
0da0: 20 73 71 6c 69 74 65 33 53 61 66 65 74 79 4f 6e   sqlite3SafetyOn
0db0: 28 64 62 29 20 29 7b 0a 20 20 20 20 20 20 73 71  (db) ){.      sq
0dc0: 6c 69 74 65 33 5f 6d 75 74 65 78 5f 6c 65 61 76  lite3_mutex_leav
0dd0: 65 28 64 62 2d 3e 6d 75 74 65 78 29 3b 0a 20 20  e(db->mutex);.  
0de0: 20 20 20 20 72 65 74 75 72 6e 20 53 51 4c 49 54      return SQLIT
0df0: 45 5f 4d 49 53 55 53 45 3b 0a 20 20 20 20 7d 0a  E_MISUSE;.    }.
0e00: 0a 20 20 20 20 73 71 6c 69 74 65 33 42 74 72 65  .    sqlite3Btre
0e10: 65 45 6e 74 65 72 41 6c 6c 28 64 62 29 3b 0a 20  eEnterAll(db);. 
0e20: 20 20 20 70 54 61 62 20 3d 20 73 71 6c 69 74 65     pTab = sqlite
0e30: 33 4c 6f 63 61 74 65 54 61 62 6c 65 28 26 73 50  3LocateTable(&sP
0e40: 61 72 73 65 2c 20 30 2c 20 7a 54 61 62 6c 65 2c  arse, 0, zTable,
0e50: 20 7a 44 62 29 3b 0a 20 20 20 20 69 66 28 20 70   zDb);.    if( p
0e60: 54 61 62 20 26 26 20 49 73 56 69 72 74 75 61 6c  Tab && IsVirtual
0e70: 28 70 54 61 62 29 20 29 7b 0a 20 20 20 20 20 20  (pTab) ){.      
0e80: 70 54 61 62 20 3d 20 30 3b 0a 20 20 20 20 20 20  pTab = 0;.      
0e90: 73 71 6c 69 74 65 33 45 72 72 6f 72 4d 73 67 28  sqlite3ErrorMsg(
0ea0: 26 73 50 61 72 73 65 2c 20 22 63 61 6e 6e 6f 74  &sParse, "cannot
0eb0: 20 6f 70 65 6e 20 76 69 72 74 75 61 6c 20 74 61   open virtual ta
0ec0: 62 6c 65 3a 20 25 73 22 2c 20 7a 54 61 62 6c 65  ble: %s", zTable
0ed0: 29 3b 0a 20 20 20 20 7d 0a 23 69 66 6e 64 65 66  );.    }.#ifndef
0ee0: 20 53 51 4c 49 54 45 5f 4f 4d 49 54 5f 56 49 45   SQLITE_OMIT_VIE
0ef0: 57 0a 20 20 20 20 69 66 28 20 70 54 61 62 20 26  W.    if( pTab &
0f00: 26 20 70 54 61 62 2d 3e 70 53 65 6c 65 63 74 20  & pTab->pSelect 
0f10: 29 7b 0a 20 20 20 20 20 20 70 54 61 62 20 3d 20  ){.      pTab = 
0f20: 30 3b 0a 20 20 20 20 20 20 73 71 6c 69 74 65 33  0;.      sqlite3
0f30: 45 72 72 6f 72 4d 73 67 28 26 73 50 61 72 73 65  ErrorMsg(&sParse
0f40: 2c 20 22 63 61 6e 6e 6f 74 20 6f 70 65 6e 20 76  , "cannot open v
0f50: 69 65 77 3a 20 25 73 22 2c 20 7a 54 61 62 6c 65  iew: %s", zTable
0f60: 29 3b 0a 20 20 20 20 7d 0a 23 65 6e 64 69 66 0a  );.    }.#endif.
0f70: 20 20 20 20 69 66 28 20 21 70 54 61 62 20 29 7b      if( !pTab ){
0f80: 0a 20 20 20 20 20 20 69 66 28 20 73 50 61 72 73  .      if( sPars
0f90: 65 2e 7a 45 72 72 4d 73 67 20 29 7b 0a 20 20 20  e.zErrMsg ){.   
0fa0: 20 20 20 20 20 73 71 6c 69 74 65 33 5f 73 6e 70       sqlite3_snp
0fb0: 72 69 6e 74 66 28 73 69 7a 65 6f 66 28 7a 45 72  rintf(sizeof(zEr
0fc0: 72 29 2c 20 7a 45 72 72 2c 20 22 25 73 22 2c 20  r), zErr, "%s", 
0fd0: 73 50 61 72 73 65 2e 7a 45 72 72 4d 73 67 29 3b  sParse.zErrMsg);
0fe0: 0a 20 20 20 20 20 20 7d 0a 20 20 20 20 20 20 73  .      }.      s
0ff0: 71 6c 69 74 65 33 44 62 46 72 65 65 28 64 62 2c  qlite3DbFree(db,
1000: 20 73 50 61 72 73 65 2e 7a 45 72 72 4d 73 67 29   sParse.zErrMsg)
1010: 3b 0a 20 20 20 20 20 20 72 63 20 3d 20 53 51 4c  ;.      rc = SQL
1020: 49 54 45 5f 45 52 52 4f 52 3b 0a 20 20 20 20 20  ITE_ERROR;.     
1030: 20 28 76 6f 69 64 29 73 71 6c 69 74 65 33 53 61   (void)sqlite3Sa
1040: 66 65 74 79 4f 66 66 28 64 62 29 3b 0a 20 20 20  fetyOff(db);.   
1050: 20 20 20 73 71 6c 69 74 65 33 42 74 72 65 65 4c     sqlite3BtreeL
1060: 65 61 76 65 41 6c 6c 28 64 62 29 3b 0a 20 20 20  eaveAll(db);.   
1070: 20 20 20 67 6f 74 6f 20 62 6c 6f 62 5f 6f 70 65     goto blob_ope
1080: 6e 5f 6f 75 74 3b 0a 20 20 20 20 7d 0a 0a 20 20  n_out;.    }..  
1090: 20 20 2f 2a 20 4e 6f 77 20 73 65 61 72 63 68 20    /* Now search 
10a0: 70 54 61 62 20 66 6f 72 20 74 68 65 20 65 78 61  pTab for the exa
10b0: 63 74 20 63 6f 6c 75 6d 6e 2e 20 2a 2f 0a 20 20  ct column. */.  
10c0: 20 20 66 6f 72 28 69 43 6f 6c 3d 30 3b 20 69 43    for(iCol=0; iC
10d0: 6f 6c 20 3c 20 70 54 61 62 2d 3e 6e 43 6f 6c 3b  ol < pTab->nCol;
10e0: 20 69 43 6f 6c 2b 2b 29 20 7b 0a 20 20 20 20 20   iCol++) {.     
10f0: 20 69 66 28 20 73 71 6c 69 74 65 33 53 74 72 49   if( sqlite3StrI
1100: 43 6d 70 28 70 54 61 62 2d 3e 61 43 6f 6c 5b 69  Cmp(pTab->aCol[i
1110: 43 6f 6c 5d 2e 7a 4e 61 6d 65 2c 20 7a 43 6f 6c  Col].zName, zCol
1120: 75 6d 6e 29 3d 3d 30 20 29 7b 0a 20 20 20 20 20  umn)==0 ){.     
1130: 20 20 20 62 72 65 61 6b 3b 0a 20 20 20 20 20 20     break;.      
1140: 7d 0a 20 20 20 20 7d 0a 20 20 20 20 69 66 28 20  }.    }.    if( 
1150: 69 43 6f 6c 3d 3d 70 54 61 62 2d 3e 6e 43 6f 6c  iCol==pTab->nCol
1160: 20 29 7b 0a 20 20 20 20 20 20 73 71 6c 69 74 65   ){.      sqlite
1170: 33 5f 73 6e 70 72 69 6e 74 66 28 73 69 7a 65 6f  3_snprintf(sizeo
1180: 66 28 7a 45 72 72 29 2c 20 7a 45 72 72 2c 20 22  f(zErr), zErr, "
1190: 6e 6f 20 73 75 63 68 20 63 6f 6c 75 6d 6e 3a 20  no such column: 
11a0: 5c 22 25 73 5c 22 22 2c 20 7a 43 6f 6c 75 6d 6e  \"%s\"", zColumn
11b0: 29 3b 0a 20 20 20 20 20 20 72 63 20 3d 20 53 51  );.      rc = SQ
11c0: 4c 49 54 45 5f 45 52 52 4f 52 3b 0a 20 20 20 20  LITE_ERROR;.    
11d0: 20 20 28 76 6f 69 64 29 73 71 6c 69 74 65 33 53    (void)sqlite3S
11e0: 61 66 65 74 79 4f 66 66 28 64 62 29 3b 0a 20 20  afetyOff(db);.  
11f0: 20 20 20 20 73 71 6c 69 74 65 33 42 74 72 65 65      sqlite3Btree
1200: 4c 65 61 76 65 41 6c 6c 28 64 62 29 3b 0a 20 20  LeaveAll(db);.  
1210: 20 20 20 20 67 6f 74 6f 20 62 6c 6f 62 5f 6f 70      goto blob_op
1220: 65 6e 5f 6f 75 74 3b 0a 20 20 20 20 7d 0a 0a 20  en_out;.    }.. 
1230: 20 20 20 2f 2a 20 49 66 20 74 68 65 20 76 61 6c     /* If the val
1240: 75 65 20 69 73 20 62 65 69 6e 67 20 6f 70 65 6e  ue is being open
1250: 65 64 20 66 6f 72 20 77 72 69 74 69 6e 67 2c 20  ed for writing, 
1260: 63 68 65 63 6b 20 74 68 61 74 20 74 68 65 0a 20  check that the. 
1270: 20 20 20 2a 2a 20 63 6f 6c 75 6d 6e 20 69 73 20     ** column is 
1280: 6e 6f 74 20 69 6e 64 65 78 65 64 2e 20 49 74 20  not indexed. It 
1290: 69 73 20 61 67 61 69 6e 73 74 20 74 68 65 20 72  is against the r
12a0: 75 6c 65 73 20 74 6f 20 6f 70 65 6e 20 61 6e 0a  ules to open an.
12b0: 20 20 20 20 2a 2a 20 69 6e 64 65 78 65 64 20 63      ** indexed c
12c0: 6f 6c 75 6d 6e 20 66 6f 72 20 77 72 69 74 69 6e  olumn for writin
12d0: 67 2e 0a 20 20 20 20 2a 2f 0a 20 20 20 20 69 66  g..    */.    if
12e0: 28 20 66 6c 61 67 73 20 29 7b 0a 20 20 20 20 20  ( flags ){.     
12f0: 20 49 6e 64 65 78 20 2a 70 49 64 78 3b 0a 20 20   Index *pIdx;.  
1300: 20 20 20 20 66 6f 72 28 70 49 64 78 3d 70 54 61      for(pIdx=pTa
1310: 62 2d 3e 70 49 6e 64 65 78 3b 20 70 49 64 78 3b  b->pIndex; pIdx;
1320: 20 70 49 64 78 3d 70 49 64 78 2d 3e 70 4e 65 78   pIdx=pIdx->pNex
1330: 74 29 7b 0a 20 20 20 20 20 20 20 20 69 6e 74 20  t){.        int 
1340: 6a 3b 0a 20 20 20 20 20 20 20 20 66 6f 72 28 6a  j;.        for(j
1350: 3d 30 3b 20 6a 3c 70 49 64 78 2d 3e 6e 43 6f 6c  =0; j<pIdx->nCol
1360: 75 6d 6e 3b 20 6a 2b 2b 29 7b 0a 20 20 20 20 20  umn; j++){.     
1370: 20 20 20 20 20 69 66 28 20 70 49 64 78 2d 3e 61       if( pIdx->a
1380: 69 43 6f 6c 75 6d 6e 5b 6a 5d 3d 3d 69 43 6f 6c  iColumn[j]==iCol
1390: 20 29 7b 0a 20 20 20 20 20 20 20 20 20 20 20 20   ){.            
13a0: 73 71 6c 69 74 65 33 5f 73 6e 70 72 69 6e 74 66  sqlite3_snprintf
13b0: 28 73 69 7a 65 6f 66 28 7a 45 72 72 29 2c 20 7a  (sizeof(zErr), z
13c0: 45 72 72 2c 0a 20 20 20 20 20 20 20 20 20 20 20  Err,.           
13d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20                  
13e0: 20 20 22 63 61 6e 6e 6f 74 20 6f 70 65 6e 20 69    "cannot open i
13f0: 6e 64 65 78 65 64 20 63 6f 6c 75 6d 6e 20 66 6f  ndexed column fo
1400: 72 20 77 72 69 74 69 6e 67 22 29 3b 0a 20 20 20  r writing");.   
1410: 20 20 20 20 20 20 20 20 20 72 63 20 3d 20 53 51           rc = SQ
1420: 4c 49 54 45 5f 45 52 52 4f 52 3b 0a 20 20 20 20  LITE_ERROR;.    
1430: 20 20 20 20 20 20 20 20 28 76 6f 69 64 29 73 71          (void)sq
1440: 6c 69 74 65 33 53 61 66 65 74 79 4f 66 66 28 64  lite3SafetyOff(d
1450: 62 29 3b 0a 20 20 20 20 20 20 20 20 20 20 20 20  b);.            
1460: 73 71 6c 69 74 65 33 42 74 72 65 65 4c 65 61 76  sqlite3BtreeLeav
1470: 65 41 6c 6c 28 64 62 29 3b 0a 20 20 20 20 20 20  eAll(db);.      
1480: 20 20 20 20 20 20 67 6f 74 6f 20 62 6c 6f 62 5f        goto blob_
1490: 6f 70 65 6e 5f 6f 75 74 3b 0a 20 20 20 20 20 20  open_out;.      
14a0: 20 20 20 20 7d 0a 20 20 20 20 20 20 20 20 7d 0a      }.        }.
14b0: 20 20 20 20 20 20 7d 0a 20 20 20 20 7d 0a 0a 20        }.    }.. 
14c0: 20 20 20 76 20 3d 20 73 71 6c 69 74 65 33 56 64     v = sqlite3Vd
14d0: 62 65 43 72 65 61 74 65 28 64 62 29 3b 0a 20 20  beCreate(db);.  
14e0: 20 20 69 66 28 20 76 20 29 7b 0a 20 20 20 20 20    if( v ){.     
14f0: 20 69 6e 74 20 69 44 62 20 3d 20 73 71 6c 69 74   int iDb = sqlit
1500: 65 33 53 63 68 65 6d 61 54 6f 49 6e 64 65 78 28  e3SchemaToIndex(
1510: 64 62 2c 20 70 54 61 62 2d 3e 70 53 63 68 65 6d  db, pTab->pSchem
1520: 61 29 3b 0a 20 20 20 20 20 20 73 71 6c 69 74 65  a);.      sqlite
1530: 33 56 64 62 65 41 64 64 4f 70 4c 69 73 74 28 76  3VdbeAddOpList(v
1540: 2c 20 73 69 7a 65 6f 66 28 6f 70 65 6e 42 6c 6f  , sizeof(openBlo
1550: 62 29 2f 73 69 7a 65 6f 66 28 56 64 62 65 4f 70  b)/sizeof(VdbeOp
1560: 4c 69 73 74 29 2c 20 6f 70 65 6e 42 6c 6f 62 29  List), openBlob)
1570: 3b 0a 0a 20 20 20 20 20 20 2f 2a 20 43 6f 6e 66  ;..      /* Conf
1580: 69 67 75 72 65 20 74 68 65 20 4f 50 5f 54 72 61  igure the OP_Tra
1590: 6e 73 61 63 74 69 6f 6e 20 2a 2f 0a 20 20 20 20  nsaction */.    
15a0: 20 20 73 71 6c 69 74 65 33 56 64 62 65 43 68 61    sqlite3VdbeCha
15b0: 6e 67 65 50 31 28 76 2c 20 30 2c 20 69 44 62 29  ngeP1(v, 0, iDb)
15c0: 3b 0a 20 20 20 20 20 20 73 71 6c 69 74 65 33 56  ;.      sqlite3V
15d0: 64 62 65 43 68 61 6e 67 65 50 32 28 76 2c 20 30  dbeChangeP2(v, 0
15e0: 2c 20 28 66 6c 61 67 73 20 3f 20 31 20 3a 20 30  , (flags ? 1 : 0
15f0: 29 29 3b 0a 0a 20 20 20 20 20 20 2f 2a 20 43 6f  ));..      /* Co
1600: 6e 66 69 67 75 72 65 20 74 68 65 20 4f 50 5f 56  nfigure the OP_V
1610: 65 72 69 66 79 43 6f 6f 6b 69 65 20 2a 2f 0a 20  erifyCookie */. 
1620: 20 20 20 20 20 73 71 6c 69 74 65 33 56 64 62 65       sqlite3Vdbe
1630: 43 68 61 6e 67 65 50 31 28 76 2c 20 31 2c 20 69  ChangeP1(v, 1, i
1640: 44 62 29 3b 0a 20 20 20 20 20 20 73 71 6c 69 74  Db);.      sqlit
1650: 65 33 56 64 62 65 43 68 61 6e 67 65 50 32 28 76  e3VdbeChangeP2(v
1660: 2c 20 31 2c 20 70 54 61 62 2d 3e 70 53 63 68 65  , 1, pTab->pSche
1670: 6d 61 2d 3e 73 63 68 65 6d 61 5f 63 6f 6f 6b 69  ma->schema_cooki
1680: 65 29 3b 0a 0a 20 20 20 20 20 20 2f 2a 20 4d 61  e);..      /* Ma
1690: 6b 65 20 73 75 72 65 20 61 20 6d 75 74 65 78 20  ke sure a mutex 
16a0: 69 73 20 68 65 6c 64 20 6f 6e 20 74 68 65 20 74  is held on the t
16b0: 61 62 6c 65 20 74 6f 20 62 65 20 61 63 63 65 73  able to be acces
16c0: 73 65 64 20 2a 2f 0a 20 20 20 20 20 20 73 71 6c  sed */.      sql
16d0: 69 74 65 33 56 64 62 65 55 73 65 73 42 74 72 65  ite3VdbeUsesBtre
16e0: 65 28 76 2c 20 69 44 62 29 3b 20 0a 0a 20 20 20  e(v, iDb); ..   
16f0: 20 20 20 2f 2a 20 52 65 6d 6f 76 65 20 65 69 74     /* Remove eit
1700: 68 65 72 20 74 68 65 20 4f 50 5f 4f 70 65 6e 57  her the OP_OpenW
1710: 72 69 74 65 20 6f 72 20 4f 70 65 6e 52 65 61 64  rite or OpenRead
1720: 2e 20 53 65 74 20 74 68 65 20 50 32 20 0a 20 20  . Set the P2 .  
1730: 20 20 20 20 2a 2a 20 70 61 72 61 6d 65 74 65 72      ** parameter
1740: 20 6f 66 20 74 68 65 20 6f 74 68 65 72 20 74 6f   of the other to
1750: 20 70 54 61 62 2d 3e 74 6e 75 6d 2e 20 0a 20 20   pTab->tnum. .  
1760: 20 20 20 20 2a 2f 0a 20 20 20 20 20 20 73 71 6c      */.      sql
1770: 69 74 65 33 56 64 62 65 43 68 61 6e 67 65 54 6f  ite3VdbeChangeTo
1780: 4e 6f 6f 70 28 76 2c 20 28 66 6c 61 67 73 20 3f  Noop(v, (flags ?
1790: 20 33 20 3a 20 35 29 2c 20 31 29 3b 0a 20 20 20   3 : 5), 1);.   
17a0: 20 20 20 73 71 6c 69 74 65 33 56 64 62 65 43 68     sqlite3VdbeCh
17b0: 61 6e 67 65 50 32 28 76 2c 20 28 66 6c 61 67 73  angeP2(v, (flags
17c0: 20 3f 20 35 20 3a 20 33 29 2c 20 70 54 61 62 2d   ? 5 : 3), pTab-
17d0: 3e 74 6e 75 6d 29 3b 0a 20 20 20 20 20 20 73 71  >tnum);.      sq
17e0: 6c 69 74 65 33 56 64 62 65 43 68 61 6e 67 65 50  lite3VdbeChangeP
17f0: 33 28 76 2c 20 28 66 6c 61 67 73 20 3f 20 35 20  3(v, (flags ? 5 
1800: 3a 20 33 29 2c 20 69 44 62 29 3b 0a 0a 20 20 20  : 3), iDb);..   
1810: 20 20 20 2f 2a 20 43 6f 6e 66 69 67 75 72 65 20     /* Configure 
1820: 74 68 65 20 4f 50 5f 53 65 74 4e 75 6d 43 6f 6c  the OP_SetNumCol
1830: 75 6d 6e 73 2e 20 43 6f 6e 66 69 67 75 72 65 20  umns. Configure 
1840: 74 68 65 20 63 75 72 73 6f 72 20 74 6f 0a 20 20  the cursor to.  
1850: 20 20 20 20 2a 2a 20 74 68 69 6e 6b 20 74 68 61      ** think tha
1860: 74 20 74 68 65 20 74 61 62 6c 65 20 68 61 73 20  t the table has 
1870: 6f 6e 65 20 6d 6f 72 65 20 63 6f 6c 75 6d 6e 20  one more column 
1880: 74 68 61 6e 20 69 74 20 72 65 61 6c 6c 79 0a 20  than it really. 
1890: 20 20 20 20 20 2a 2a 20 64 6f 65 73 2e 20 41 6e       ** does. An
18a0: 20 4f 50 5f 43 6f 6c 75 6d 6e 20 74 6f 20 72 65   OP_Column to re
18b0: 74 72 69 65 76 65 20 74 68 69 73 20 69 6d 61 67  trieve this imag
18c0: 69 6e 61 72 79 20 63 6f 6c 75 6d 6e 20 77 69 6c  inary column wil
18d0: 6c 0a 20 20 20 20 20 20 2a 2a 20 61 6c 77 61 79  l.      ** alway
18e0: 73 20 72 65 74 75 72 6e 20 61 6e 20 53 51 4c 20  s return an SQL 
18f0: 4e 55 4c 4c 2e 20 54 68 69 73 20 69 73 20 75 73  NULL. This is us
1900: 65 66 75 6c 20 62 65 63 61 75 73 65 20 69 74 20  eful because it 
1910: 6d 65 61 6e 73 0a 20 20 20 20 20 20 2a 2a 20 77  means.      ** w
1920: 65 20 63 61 6e 20 69 6e 76 6f 6b 65 20 4f 50 5f  e can invoke OP_
1930: 43 6f 6c 75 6d 6e 20 74 6f 20 66 69 6c 6c 20 69  Column to fill i
1940: 6e 20 74 68 65 20 76 64 62 65 20 63 75 72 73 6f  n the vdbe curso
1950: 72 73 20 74 79 70 65 20 0a 20 20 20 20 20 20 2a  rs type .      *
1960: 2a 20 61 6e 64 20 6f 66 66 73 65 74 20 63 61 63  * and offset cac
1970: 68 65 20 77 69 74 68 6f 75 74 20 63 61 75 73 69  he without causi
1980: 6e 67 20 61 6e 79 20 49 4f 2e 0a 20 20 20 20 20  ng any IO..     
1990: 20 2a 2f 0a 20 20 20 20 20 20 73 71 6c 69 74 65   */.      sqlite
19a0: 33 56 64 62 65 43 68 61 6e 67 65 50 32 28 76 2c  3VdbeChangeP2(v,
19b0: 20 66 6c 61 67 73 20 3f 20 34 20 3a 20 32 2c 20   flags ? 4 : 2, 
19c0: 70 54 61 62 2d 3e 6e 43 6f 6c 2b 31 29 3b 0a 20  pTab->nCol+1);. 
19d0: 20 20 20 20 20 73 71 6c 69 74 65 33 56 64 62 65       sqlite3Vdbe
19e0: 43 68 61 6e 67 65 50 32 28 76 2c 20 38 2c 20 70  ChangeP2(v, 8, p
19f0: 54 61 62 2d 3e 6e 43 6f 6c 29 3b 0a 20 20 20 20  Tab->nCol);.    
1a00: 20 20 69 66 28 20 21 64 62 2d 3e 6d 61 6c 6c 6f    if( !db->mallo
1a10: 63 46 61 69 6c 65 64 20 29 7b 0a 20 20 20 20 20  cFailed ){.     
1a20: 20 20 20 73 71 6c 69 74 65 33 56 64 62 65 4d 61     sqlite3VdbeMa
1a30: 6b 65 52 65 61 64 79 28 76 2c 20 31 2c 20 31 2c  keReady(v, 1, 1,
1a40: 20 31 2c 20 30 29 3b 0a 20 20 20 20 20 20 7d 0a   1, 0);.      }.
1a50: 20 20 20 20 7d 0a 20 20 20 0a 20 20 20 20 73 71      }.   .    sq
1a60: 6c 69 74 65 33 42 74 72 65 65 4c 65 61 76 65 41  lite3BtreeLeaveA
1a70: 6c 6c 28 64 62 29 3b 0a 20 20 20 20 72 63 20 3d  ll(db);.    rc =
1a80: 20 73 71 6c 69 74 65 33 53 61 66 65 74 79 4f 66   sqlite3SafetyOf
1a90: 66 28 64 62 29 3b 0a 20 20 20 20 69 66 28 20 72  f(db);.    if( r
1aa0: 63 21 3d 53 51 4c 49 54 45 5f 4f 4b 20 7c 7c 20  c!=SQLITE_OK || 
1ab0: 64 62 2d 3e 6d 61 6c 6c 6f 63 46 61 69 6c 65 64  db->mallocFailed
1ac0: 20 29 7b 0a 20 20 20 20 20 20 67 6f 74 6f 20 62   ){.      goto b
1ad0: 6c 6f 62 5f 6f 70 65 6e 5f 6f 75 74 3b 0a 20 20  lob_open_out;.  
1ae0: 20 20 7d 0a 0a 20 20 20 20 73 71 6c 69 74 65 33    }..    sqlite3
1af0: 5f 62 69 6e 64 5f 69 6e 74 36 34 28 28 73 71 6c  _bind_int64((sql
1b00: 69 74 65 33 5f 73 74 6d 74 20 2a 29 76 2c 20 31  ite3_stmt *)v, 1
1b10: 2c 20 69 52 6f 77 29 3b 0a 20 20 20 20 72 63 20  , iRow);.    rc 
1b20: 3d 20 73 71 6c 69 74 65 33 5f 73 74 65 70 28 28  = sqlite3_step((
1b30: 73 71 6c 69 74 65 33 5f 73 74 6d 74 20 2a 29 76  sqlite3_stmt *)v
1b40: 29 3b 0a 20 20 20 20 69 66 28 20 72 63 21 3d 53  );.    if( rc!=S
1b50: 51 4c 49 54 45 5f 52 4f 57 20 29 7b 0a 20 20 20  QLITE_ROW ){.   
1b60: 20 20 20 6e 41 74 74 65 6d 70 74 2b 2b 3b 0a 20     nAttempt++;. 
1b70: 20 20 20 20 20 72 63 20 3d 20 73 71 6c 69 74 65       rc = sqlite
1b80: 33 5f 66 69 6e 61 6c 69 7a 65 28 28 73 71 6c 69  3_finalize((sqli
1b90: 74 65 33 5f 73 74 6d 74 20 2a 29 76 29 3b 0a 20  te3_stmt *)v);. 
1ba0: 20 20 20 20 20 73 71 6c 69 74 65 33 5f 73 6e 70       sqlite3_snp
1bb0: 72 69 6e 74 66 28 73 69 7a 65 6f 66 28 7a 45 72  rintf(sizeof(zEr
1bc0: 72 29 2c 20 7a 45 72 72 2c 20 73 71 6c 69 74 65  r), zErr, sqlite
1bd0: 33 5f 65 72 72 6d 73 67 28 64 62 29 29 3b 0a 20  3_errmsg(db));. 
1be0: 20 20 20 20 20 76 20 3d 20 30 3b 0a 20 20 20 20       v = 0;.    
1bf0: 7d 0a 20 20 7d 20 77 68 69 6c 65 28 20 6e 41 74  }.  } while( nAt
1c00: 74 65 6d 70 74 3c 35 20 26 26 20 72 63 3d 3d 53  tempt<5 && rc==S
1c10: 51 4c 49 54 45 5f 53 43 48 45 4d 41 20 29 3b 0a  QLITE_SCHEMA );.
1c20: 0a 20 20 69 66 28 20 72 63 3d 3d 53 51 4c 49 54  .  if( rc==SQLIT
1c30: 45 5f 52 4f 57 20 29 7b 0a 20 20 20 20 2f 2a 20  E_ROW ){.    /* 
1c40: 54 68 65 20 72 6f 77 2d 72 65 63 6f 72 64 20 68  The row-record h
1c50: 61 73 20 62 65 65 6e 20 6f 70 65 6e 65 64 20 73  as been opened s
1c60: 75 63 63 65 73 73 66 75 6c 6c 79 2e 20 43 68 65  uccessfully. Che
1c70: 63 6b 20 74 68 61 74 20 74 68 65 0a 20 20 20 20  ck that the.    
1c80: 2a 2a 20 63 6f 6c 75 6d 6e 20 69 6e 20 71 75 65  ** column in que
1c90: 73 74 69 6f 6e 20 63 6f 6e 74 61 69 6e 73 20 74  stion contains t
1ca0: 65 78 74 20 6f 72 20 61 20 62 6c 6f 62 2e 20 49  ext or a blob. I
1cb0: 66 20 69 74 20 63 6f 6e 74 61 69 6e 73 0a 20 20  f it contains.  
1cc0: 20 20 2a 2a 20 74 65 78 74 2c 20 69 74 20 69 73    ** text, it is
1cd0: 20 75 70 20 74 6f 20 74 68 65 20 63 61 6c 6c 65   up to the calle
1ce0: 72 20 74 6f 20 67 65 74 20 74 68 65 20 65 6e 63  r to get the enc
1cf0: 6f 64 69 6e 67 20 72 69 67 68 74 2e 0a 20 20 20  oding right..   
1d00: 20 2a 2f 0a 20 20 20 20 49 6e 63 72 62 6c 6f 62   */.    Incrblob
1d10: 20 2a 70 42 6c 6f 62 3b 0a 20 20 20 20 75 33 32   *pBlob;.    u32
1d20: 20 74 79 70 65 20 3d 20 76 2d 3e 61 70 43 73 72   type = v->apCsr
1d30: 5b 30 5d 2d 3e 61 54 79 70 65 5b 69 43 6f 6c 5d  [0]->aType[iCol]
1d40: 3b 0a 0a 20 20 20 20 69 66 28 20 74 79 70 65 3c  ;..    if( type<
1d50: 31 32 20 29 7b 0a 20 20 20 20 20 20 73 71 6c 69  12 ){.      sqli
1d60: 74 65 33 5f 73 6e 70 72 69 6e 74 66 28 73 69 7a  te3_snprintf(siz
1d70: 65 6f 66 28 7a 45 72 72 29 2c 20 7a 45 72 72 2c  eof(zErr), zErr,
1d80: 20 22 63 61 6e 6e 6f 74 20 6f 70 65 6e 20 76 61   "cannot open va
1d90: 6c 75 65 20 6f 66 20 74 79 70 65 20 25 73 22 2c  lue of type %s",
1da0: 0a 20 20 20 20 20 20 20 20 20 20 74 79 70 65 3d  .          type=
1db0: 3d 30 3f 22 6e 75 6c 6c 22 3a 20 74 79 70 65 3d  =0?"null": type=
1dc0: 3d 37 3f 22 72 65 61 6c 22 3a 20 22 69 6e 74 65  =7?"real": "inte
1dd0: 67 65 72 22 0a 20 20 20 20 20 20 29 3b 0a 20 20  ger".      );.  
1de0: 20 20 20 20 72 63 20 3d 20 53 51 4c 49 54 45 5f      rc = SQLITE_
1df0: 45 52 52 4f 52 3b 0a 20 20 20 20 20 20 67 6f 74  ERROR;.      got
1e00: 6f 20 62 6c 6f 62 5f 6f 70 65 6e 5f 6f 75 74 3b  o blob_open_out;
1e10: 0a 20 20 20 20 7d 0a 20 20 20 20 70 42 6c 6f 62  .    }.    pBlob
1e20: 20 3d 20 28 49 6e 63 72 62 6c 6f 62 20 2a 29 73   = (Incrblob *)s
1e30: 71 6c 69 74 65 33 44 62 4d 61 6c 6c 6f 63 5a 65  qlite3DbMallocZe
1e40: 72 6f 28 64 62 2c 20 73 69 7a 65 6f 66 28 49 6e  ro(db, sizeof(In
1e50: 63 72 62 6c 6f 62 29 29 3b 0a 20 20 20 20 69 66  crblob));.    if
1e60: 28 20 64 62 2d 3e 6d 61 6c 6c 6f 63 46 61 69 6c  ( db->mallocFail
1e70: 65 64 20 29 7b 0a 20 20 20 20 20 20 73 71 6c 69  ed ){.      sqli
1e80: 74 65 33 44 62 46 72 65 65 28 64 62 2c 20 70 42  te3DbFree(db, pB
1e90: 6c 6f 62 29 3b 0a 20 20 20 20 20 20 67 6f 74 6f  lob);.      goto
1ea0: 20 62 6c 6f 62 5f 6f 70 65 6e 5f 6f 75 74 3b 0a   blob_open_out;.
1eb0: 20 20 20 20 7d 0a 20 20 20 20 70 42 6c 6f 62 2d      }.    pBlob-
1ec0: 3e 66 6c 61 67 73 20 3d 20 66 6c 61 67 73 3b 0a  >flags = flags;.
1ed0: 20 20 20 20 70 42 6c 6f 62 2d 3e 70 43 73 72 20      pBlob->pCsr 
1ee0: 3d 20 20 76 2d 3e 61 70 43 73 72 5b 30 5d 2d 3e  =  v->apCsr[0]->
1ef0: 70 43 75 72 73 6f 72 3b 0a 20 20 20 20 73 71 6c  pCursor;.    sql
1f00: 69 74 65 33 42 74 72 65 65 45 6e 74 65 72 43 75  ite3BtreeEnterCu
1f10: 72 73 6f 72 28 70 42 6c 6f 62 2d 3e 70 43 73 72  rsor(pBlob->pCsr
1f20: 29 3b 0a 20 20 20 20 73 71 6c 69 74 65 33 42 74  );.    sqlite3Bt
1f30: 72 65 65 43 61 63 68 65 4f 76 65 72 66 6c 6f 77  reeCacheOverflow
1f40: 28 70 42 6c 6f 62 2d 3e 70 43 73 72 29 3b 0a 20  (pBlob->pCsr);. 
1f50: 20 20 20 73 71 6c 69 74 65 33 42 74 72 65 65 4c     sqlite3BtreeL
1f60: 65 61 76 65 43 75 72 73 6f 72 28 70 42 6c 6f 62  eaveCursor(pBlob
1f70: 2d 3e 70 43 73 72 29 3b 0a 20 20 20 20 70 42 6c  ->pCsr);.    pBl
1f80: 6f 62 2d 3e 70 53 74 6d 74 20 3d 20 28 73 71 6c  ob->pStmt = (sql
1f90: 69 74 65 33 5f 73 74 6d 74 20 2a 29 76 3b 0a 20  ite3_stmt *)v;. 
1fa0: 20 20 20 70 42 6c 6f 62 2d 3e 69 4f 66 66 73 65     pBlob->iOffse
1fb0: 74 20 3d 20 76 2d 3e 61 70 43 73 72 5b 30 5d 2d  t = v->apCsr[0]-
1fc0: 3e 61 4f 66 66 73 65 74 5b 69 43 6f 6c 5d 3b 0a  >aOffset[iCol];.
1fd0: 20 20 20 20 70 42 6c 6f 62 2d 3e 6e 42 79 74 65      pBlob->nByte
1fe0: 20 3d 20 73 71 6c 69 74 65 33 56 64 62 65 53 65   = sqlite3VdbeSe
1ff0: 72 69 61 6c 54 79 70 65 4c 65 6e 28 74 79 70 65  rialTypeLen(type
2000: 29 3b 0a 20 20 20 20 70 42 6c 6f 62 2d 3e 64 62  );.    pBlob->db
2010: 20 3d 20 64 62 3b 0a 20 20 20 20 2a 70 70 42 6c   = db;.    *ppBl
2020: 6f 62 20 3d 20 28 73 71 6c 69 74 65 33 5f 62 6c  ob = (sqlite3_bl
2030: 6f 62 20 2a 29 70 42 6c 6f 62 3b 0a 20 20 20 20  ob *)pBlob;.    
2040: 72 63 20 3d 20 53 51 4c 49 54 45 5f 4f 4b 3b 0a  rc = SQLITE_OK;.
2050: 20 20 7d 65 6c 73 65 20 69 66 28 20 72 63 3d 3d    }else if( rc==
2060: 53 51 4c 49 54 45 5f 4f 4b 20 29 7b 0a 20 20 20  SQLITE_OK ){.   
2070: 20 73 71 6c 69 74 65 33 5f 73 6e 70 72 69 6e 74   sqlite3_snprint
2080: 66 28 73 69 7a 65 6f 66 28 7a 45 72 72 29 2c 20  f(sizeof(zErr), 
2090: 7a 45 72 72 2c 20 22 6e 6f 20 73 75 63 68 20 72  zErr, "no such r
20a0: 6f 77 69 64 3a 20 25 6c 6c 64 22 2c 20 69 52 6f  owid: %lld", iRo
20b0: 77 29 3b 0a 20 20 20 20 72 63 20 3d 20 53 51 4c  w);.    rc = SQL
20c0: 49 54 45 5f 45 52 52 4f 52 3b 0a 20 20 7d 0a 0a  ITE_ERROR;.  }..
20d0: 62 6c 6f 62 5f 6f 70 65 6e 5f 6f 75 74 3a 0a 20  blob_open_out:. 
20e0: 20 7a 45 72 72 5b 73 69 7a 65 6f 66 28 7a 45 72   zErr[sizeof(zEr
20f0: 72 29 2d 31 5d 20 3d 20 27 5c 30 27 3b 0a 20 20  r)-1] = '\0';.  
2100: 69 66 28 20 72 63 21 3d 53 51 4c 49 54 45 5f 4f  if( rc!=SQLITE_O
2110: 4b 20 7c 7c 20 64 62 2d 3e 6d 61 6c 6c 6f 63 46  K || db->mallocF
2120: 61 69 6c 65 64 20 29 7b 0a 20 20 20 20 73 71 6c  ailed ){.    sql
2130: 69 74 65 33 5f 66 69 6e 61 6c 69 7a 65 28 28 73  ite3_finalize((s
2140: 71 6c 69 74 65 33 5f 73 74 6d 74 20 2a 29 76 29  qlite3_stmt *)v)
2150: 3b 0a 20 20 7d 0a 20 20 73 71 6c 69 74 65 33 45  ;.  }.  sqlite3E
2160: 72 72 6f 72 28 64 62 2c 20 72 63 2c 20 28 72 63  rror(db, rc, (rc
2170: 3d 3d 53 51 4c 49 54 45 5f 4f 4b 3f 30 3a 7a 45  ==SQLITE_OK?0:zE
2180: 72 72 29 29 3b 0a 20 20 72 63 20 3d 20 73 71 6c  rr));.  rc = sql
2190: 69 74 65 33 41 70 69 45 78 69 74 28 64 62 2c 20  ite3ApiExit(db, 
21a0: 72 63 29 3b 0a 20 20 73 71 6c 69 74 65 33 5f 6d  rc);.  sqlite3_m
21b0: 75 74 65 78 5f 6c 65 61 76 65 28 64 62 2d 3e 6d  utex_leave(db->m
21c0: 75 74 65 78 29 3b 0a 20 20 72 65 74 75 72 6e 20  utex);.  return 
21d0: 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 43 6c 6f  rc;.}../*.** Clo
21e0: 73 65 20 61 20 62 6c 6f 62 20 68 61 6e 64 6c 65  se a blob handle
21f0: 20 74 68 61 74 20 77 61 73 20 70 72 65 76 69 6f   that was previo
2200: 75 73 6c 79 20 63 72 65 61 74 65 64 20 75 73 69  usly created usi
2210: 6e 67 0a 2a 2a 20 73 71 6c 69 74 65 33 5f 62 6c  ng.** sqlite3_bl
2220: 6f 62 5f 6f 70 65 6e 28 29 2e 0a 2a 2f 0a 69 6e  ob_open()..*/.in
2230: 74 20 73 71 6c 69 74 65 33 5f 62 6c 6f 62 5f 63  t sqlite3_blob_c
2240: 6c 6f 73 65 28 73 71 6c 69 74 65 33 5f 62 6c 6f  lose(sqlite3_blo
2250: 62 20 2a 70 42 6c 6f 62 29 7b 0a 20 20 49 6e 63  b *pBlob){.  Inc
2260: 72 62 6c 6f 62 20 2a 70 20 3d 20 28 49 6e 63 72  rblob *p = (Incr
2270: 62 6c 6f 62 20 2a 29 70 42 6c 6f 62 3b 0a 20 20  blob *)pBlob;.  
2280: 69 6e 74 20 72 63 3b 0a 0a 20 20 72 63 20 3d 20  int rc;..  rc = 
2290: 73 71 6c 69 74 65 33 5f 66 69 6e 61 6c 69 7a 65  sqlite3_finalize
22a0: 28 70 2d 3e 70 53 74 6d 74 29 3b 0a 20 20 73 71  (p->pStmt);.  sq
22b0: 6c 69 74 65 33 44 62 46 72 65 65 28 70 2d 3e 64  lite3DbFree(p->d
22c0: 62 2c 20 70 29 3b 0a 20 20 72 65 74 75 72 6e 20  b, p);.  return 
22d0: 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a 20 50 65 72  rc;.}../*.** Per
22e0: 66 6f 72 6d 20 61 20 72 65 61 64 20 6f 72 20 77  form a read or w
22f0: 72 69 74 65 20 6f 70 65 72 61 74 69 6f 6e 20 6f  rite operation o
2300: 6e 20 61 20 62 6c 6f 62 0a 2a 2f 0a 73 74 61 74  n a blob.*/.stat
2310: 69 63 20 69 6e 74 20 62 6c 6f 62 52 65 61 64 57  ic int blobReadW
2320: 72 69 74 65 28 0a 20 20 73 71 6c 69 74 65 33 5f  rite(.  sqlite3_
2330: 62 6c 6f 62 20 2a 70 42 6c 6f 62 2c 20 0a 20 20  blob *pBlob, .  
2340: 76 6f 69 64 20 2a 7a 2c 20 0a 20 20 69 6e 74 20  void *z, .  int 
2350: 6e 2c 20 0a 20 20 69 6e 74 20 69 4f 66 66 73 65  n, .  int iOffse
2360: 74 2c 20 0a 20 20 69 6e 74 20 28 2a 78 43 61 6c  t, .  int (*xCal
2370: 6c 29 28 42 74 43 75 72 73 6f 72 2a 2c 20 75 33  l)(BtCursor*, u3
2380: 32 2c 20 75 33 32 2c 20 76 6f 69 64 2a 29 0a 29  2, u32, void*).)
2390: 7b 0a 20 20 69 6e 74 20 72 63 3b 0a 20 20 49 6e  {.  int rc;.  In
23a0: 63 72 62 6c 6f 62 20 2a 70 20 3d 20 28 49 6e 63  crblob *p = (Inc
23b0: 72 62 6c 6f 62 20 2a 29 70 42 6c 6f 62 3b 0a 20  rblob *)pBlob;. 
23c0: 20 56 64 62 65 20 2a 76 3b 0a 20 20 73 71 6c 69   Vdbe *v;.  sqli
23d0: 74 65 33 20 2a 64 62 20 3d 20 70 2d 3e 64 62 3b  te3 *db = p->db;
23e0: 20 20 0a 0a 20 20 2f 2a 20 52 65 71 75 65 73 74    ..  /* Request
23f0: 20 69 73 20 6f 75 74 20 6f 66 20 72 61 6e 67 65   is out of range
2400: 2e 20 52 65 74 75 72 6e 20 61 20 74 72 61 6e 73  . Return a trans
2410: 69 65 6e 74 20 65 72 72 6f 72 2e 20 2a 2f 0a 20  ient error. */. 
2420: 20 69 66 28 20 28 69 4f 66 66 73 65 74 2b 6e 29   if( (iOffset+n)
2430: 3e 70 2d 3e 6e 42 79 74 65 20 29 7b 0a 20 20 20  >p->nByte ){.   
2440: 20 72 65 74 75 72 6e 20 53 51 4c 49 54 45 5f 45   return SQLITE_E
2450: 52 52 4f 52 3b 0a 20 20 7d 0a 20 20 73 71 6c 69  RROR;.  }.  sqli
2460: 74 65 33 5f 6d 75 74 65 78 5f 65 6e 74 65 72 28  te3_mutex_enter(
2470: 64 62 2d 3e 6d 75 74 65 78 29 3b 0a 0a 20 20 2f  db->mutex);..  /
2480: 2a 20 49 66 20 74 68 65 72 65 20 69 73 20 6e 6f  * If there is no
2490: 20 73 74 61 74 65 6d 65 6e 74 20 68 61 6e 64 6c   statement handl
24a0: 65 2c 20 74 68 65 6e 20 74 68 65 20 62 6c 6f 62  e, then the blob
24b0: 2d 68 61 6e 64 6c 65 20 68 61 73 0a 20 20 2a 2a  -handle has.  **
24c0: 20 61 6c 72 65 61 64 79 20 62 65 65 6e 20 69 6e   already been in
24d0: 76 61 6c 69 64 61 74 65 64 2e 20 52 65 74 75 72  validated. Retur
24e0: 6e 20 53 51 4c 49 54 45 5f 41 42 4f 52 54 20 69  n SQLITE_ABORT i
24f0: 6e 20 74 68 69 73 20 63 61 73 65 2e 0a 20 20 2a  n this case..  *
2500: 2f 0a 20 20 76 20 3d 20 28 56 64 62 65 2a 29 70  /.  v = (Vdbe*)p
2510: 2d 3e 70 53 74 6d 74 3b 0a 20 20 69 66 28 20 76  ->pStmt;.  if( v
2520: 3d 3d 30 20 29 7b 0a 20 20 20 20 72 63 20 3d 20  ==0 ){.    rc = 
2530: 53 51 4c 49 54 45 5f 41 42 4f 52 54 3b 0a 20 20  SQLITE_ABORT;.  
2540: 7d 65 6c 73 65 7b 0a 20 20 20 20 2f 2a 20 43 61  }else{.    /* Ca
2550: 6c 6c 20 65 69 74 68 65 72 20 42 74 72 65 65 44  ll either BtreeD
2560: 61 74 61 28 29 20 6f 72 20 42 74 72 65 65 50 75  ata() or BtreePu
2570: 74 44 61 74 61 28 29 2e 20 49 66 20 53 51 4c 49  tData(). If SQLI
2580: 54 45 5f 41 42 4f 52 54 20 69 73 0a 20 20 20 20  TE_ABORT is.    
2590: 2a 2a 20 72 65 74 75 72 6e 65 64 2c 20 63 6c 65  ** returned, cle
25a0: 61 6e 2d 75 70 20 74 68 65 20 73 74 61 74 65 6d  an-up the statem
25b0: 65 6e 74 20 68 61 6e 64 6c 65 2e 0a 20 20 20 20  ent handle..    
25c0: 2a 2f 0a 20 20 20 20 61 73 73 65 72 74 28 20 64  */.    assert( d
25d0: 62 20 3d 3d 20 76 2d 3e 64 62 20 29 3b 0a 20 20  b == v->db );.  
25e0: 20 20 73 71 6c 69 74 65 33 42 74 72 65 65 45 6e    sqlite3BtreeEn
25f0: 74 65 72 43 75 72 73 6f 72 28 70 2d 3e 70 43 73  terCursor(p->pCs
2600: 72 29 3b 0a 20 20 20 20 72 63 20 3d 20 78 43 61  r);.    rc = xCa
2610: 6c 6c 28 70 2d 3e 70 43 73 72 2c 20 69 4f 66 66  ll(p->pCsr, iOff
2620: 73 65 74 2b 70 2d 3e 69 4f 66 66 73 65 74 2c 20  set+p->iOffset, 
2630: 6e 2c 20 7a 29 3b 0a 20 20 20 20 73 71 6c 69 74  n, z);.    sqlit
2640: 65 33 42 74 72 65 65 4c 65 61 76 65 43 75 72 73  e3BtreeLeaveCurs
2650: 6f 72 28 70 2d 3e 70 43 73 72 29 3b 0a 20 20 20  or(p->pCsr);.   
2660: 20 69 66 28 20 72 63 3d 3d 53 51 4c 49 54 45 5f   if( rc==SQLITE_
2670: 41 42 4f 52 54 20 29 7b 0a 20 20 20 20 20 20 73  ABORT ){.      s
2680: 71 6c 69 74 65 33 56 64 62 65 46 69 6e 61 6c 69  qlite3VdbeFinali
2690: 7a 65 28 76 29 3b 0a 20 20 20 20 20 20 70 2d 3e  ze(v);.      p->
26a0: 70 53 74 6d 74 20 3d 20 30 3b 0a 20 20 20 20 7d  pStmt = 0;.    }
26b0: 65 6c 73 65 7b 0a 20 20 20 20 20 20 64 62 2d 3e  else{.      db->
26c0: 65 72 72 43 6f 64 65 20 3d 20 72 63 3b 0a 20 20  errCode = rc;.  
26d0: 20 20 20 20 76 2d 3e 72 63 20 3d 20 72 63 3b 0a      v->rc = rc;.
26e0: 20 20 20 20 7d 0a 20 20 7d 0a 20 20 72 63 20 3d      }.  }.  rc =
26f0: 20 73 71 6c 69 74 65 33 41 70 69 45 78 69 74 28   sqlite3ApiExit(
2700: 64 62 2c 20 72 63 29 3b 0a 20 20 73 71 6c 69 74  db, rc);.  sqlit
2710: 65 33 5f 6d 75 74 65 78 5f 6c 65 61 76 65 28 64  e3_mutex_leave(d
2720: 62 2d 3e 6d 75 74 65 78 29 3b 0a 20 20 72 65 74  b->mutex);.  ret
2730: 75 72 6e 20 72 63 3b 0a 7d 0a 0a 2f 2a 0a 2a 2a  urn rc;.}../*.**
2740: 20 52 65 61 64 20 64 61 74 61 20 66 72 6f 6d 20   Read data from 
2750: 61 20 62 6c 6f 62 20 68 61 6e 64 6c 65 2e 0a 2a  a blob handle..*
2760: 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 5f 62 6c  /.int sqlite3_bl
2770: 6f 62 5f 72 65 61 64 28 73 71 6c 69 74 65 33 5f  ob_read(sqlite3_
2780: 62 6c 6f 62 20 2a 70 42 6c 6f 62 2c 20 76 6f 69  blob *pBlob, voi
2790: 64 20 2a 7a 2c 20 69 6e 74 20 6e 2c 20 69 6e 74  d *z, int n, int
27a0: 20 69 4f 66 66 73 65 74 29 7b 0a 20 20 72 65 74   iOffset){.  ret
27b0: 75 72 6e 20 62 6c 6f 62 52 65 61 64 57 72 69 74  urn blobReadWrit
27c0: 65 28 70 42 6c 6f 62 2c 20 7a 2c 20 6e 2c 20 69  e(pBlob, z, n, i
27d0: 4f 66 66 73 65 74 2c 20 73 71 6c 69 74 65 33 42  Offset, sqlite3B
27e0: 74 72 65 65 44 61 74 61 29 3b 0a 7d 0a 0a 2f 2a  treeData);.}../*
27f0: 0a 2a 2a 20 57 72 69 74 65 20 64 61 74 61 20 74  .** Write data t
2800: 6f 20 61 20 62 6c 6f 62 20 68 61 6e 64 6c 65 2e  o a blob handle.
2810: 0a 2a 2f 0a 69 6e 74 20 73 71 6c 69 74 65 33 5f  .*/.int sqlite3_
2820: 62 6c 6f 62 5f 77 72 69 74 65 28 73 71 6c 69 74  blob_write(sqlit
2830: 65 33 5f 62 6c 6f 62 20 2a 70 42 6c 6f 62 2c 20  e3_blob *pBlob, 
2840: 63 6f 6e 73 74 20 76 6f 69 64 20 2a 7a 2c 20 69  const void *z, i
2850: 6e 74 20 6e 2c 20 69 6e 74 20 69 4f 66 66 73 65  nt n, int iOffse
2860: 74 29 7b 0a 20 20 72 65 74 75 72 6e 20 62 6c 6f  t){.  return blo
2870: 62 52 65 61 64 57 72 69 74 65 28 70 42 6c 6f 62  bReadWrite(pBlob
2880: 2c 20 28 76 6f 69 64 20 2a 29 7a 2c 20 6e 2c 20  , (void *)z, n, 
2890: 69 4f 66 66 73 65 74 2c 20 73 71 6c 69 74 65 33  iOffset, sqlite3
28a0: 42 74 72 65 65 50 75 74 44 61 74 61 29 3b 0a 7d  BtreePutData);.}
28b0: 0a 0a 2f 2a 0a 2a 2a 20 51 75 65 72 79 20 61 20  ../*.** Query a 
28c0: 62 6c 6f 62 20 68 61 6e 64 6c 65 20 66 6f 72 20  blob handle for 
28d0: 74 68 65 20 73 69 7a 65 20 6f 66 20 74 68 65 20  the size of the 
28e0: 64 61 74 61 2e 0a 2a 2a 0a 2a 2a 20 54 68 65 20  data..**.** The 
28f0: 49 6e 63 72 62 6c 6f 62 2e 6e 42 79 74 65 20 66  Incrblob.nByte f
2900: 69 65 6c 64 20 69 73 20 66 69 78 65 64 20 66 6f  ield is fixed fo
2910: 72 20 74 68 65 20 6c 69 66 65 74 69 6d 65 20 6f  r the lifetime o
2920: 66 20 74 68 65 20 49 6e 63 72 62 6c 6f 62 0a 2a  f the Incrblob.*
2930: 2a 20 73 6f 20 6e 6f 20 6d 75 74 65 78 20 69 73  * so no mutex is
2940: 20 72 65 71 75 69 72 65 64 20 66 6f 72 20 61 63   required for ac
2950: 63 65 73 73 2e 0a 2a 2f 0a 69 6e 74 20 73 71 6c  cess..*/.int sql
2960: 69 74 65 33 5f 62 6c 6f 62 5f 62 79 74 65 73 28  ite3_blob_bytes(
2970: 73 71 6c 69 74 65 33 5f 62 6c 6f 62 20 2a 70 42  sqlite3_blob *pB
2980: 6c 6f 62 29 7b 0a 20 20 49 6e 63 72 62 6c 6f 62  lob){.  Incrblob
2990: 20 2a 70 20 3d 20 28 49 6e 63 72 62 6c 6f 62 20   *p = (Incrblob 
29a0: 2a 29 70 42 6c 6f 62 3b 0a 20 20 72 65 74 75 72  *)pBlob;.  retur
29b0: 6e 20 70 2d 3e 6e 42 79 74 65 3b 0a 7d 0a 0a 23  n p->nByte;.}..#
29c0: 65 6e 64 69 66 20 2f 2a 20 23 69 66 6e 64 65 66  endif /* #ifndef
29d0: 20 53 51 4c 49 54 45 5f 4f 4d 49 54 5f 49 4e 43   SQLITE_OMIT_INC
29e0: 52 42 4c 4f 42 20 2a 2f 0a                       RBLOB */.