14fccf43aSdan 29b1c62d4Sdrh #if defined(SQLITE_ENABLE_SESSION) && defined(SQLITE_ENABLE_PREUPDATE_HOOK) 34fccf43aSdan #include "sqlite3session.h" 44fccf43aSdan #include <assert.h> 54fccf43aSdan #include <string.h> 64fccf43aSdan 75d8a2984Sdan #ifndef SQLITE_AMALGAMATION 84fccf43aSdan # include "sqliteInt.h" 94fccf43aSdan # include "vdbeInt.h" 105d8a2984Sdan #endif 114fccf43aSdan 124fccf43aSdan typedef struct SessionTable SessionTable; 134fccf43aSdan typedef struct SessionChange SessionChange; 14296c7658Sdan typedef struct SessionBuffer SessionBuffer; 15ef7a6304Sdan typedef struct SessionInput SessionInput; 16ef7a6304Sdan 17ef7a6304Sdan /* 18ef7a6304Sdan ** Minimum chunk size used by streaming versions of functions. 19ef7a6304Sdan */ 204757c658Sdan #ifdef SQLITE_TEST 214757c658Sdan #define SESSIONS_STR_CHUNK_SIZE 1 224757c658Sdan #else 23ef7a6304Sdan #define SESSIONS_STR_CHUNK_SIZE 1024 244757c658Sdan #endif 254fccf43aSdan 26296c7658Sdan /* 27296c7658Sdan ** Session handle structure. 28296c7658Sdan */ 294fccf43aSdan struct sqlite3_session { 304fccf43aSdan sqlite3 *db; /* Database handle session is attached to */ 314fccf43aSdan char *zDb; /* Name of database session is attached to */ 32296c7658Sdan int bEnable; /* True if currently recording */ 33b4480e94Sdan int bIndirect; /* True if all changes are indirect */ 34ff4d0f41Sdan int bAutoAttach; /* True to auto-attach tables */ 354fccf43aSdan int rc; /* Non-zero if an error has occurred */ 367531a5a3Sdan void *pFilterCtx; /* First argument to pass to xTableFilter */ 377531a5a3Sdan int (*xTableFilter)(void *pCtx, const char *zTab); 384fccf43aSdan sqlite3_session *pNext; /* Next session object on same db. */ 394fccf43aSdan SessionTable *pTable; /* List of attached tables */ 404fccf43aSdan }; 414fccf43aSdan 424fccf43aSdan /* 43ef7a6304Sdan ** Instances of this structure are used to build strings or binary records. 44ef7a6304Sdan */ 45ef7a6304Sdan struct SessionBuffer { 46ef7a6304Sdan u8 *aBuf; /* Pointer to changeset buffer */ 47ef7a6304Sdan int nBuf; /* Size of buffer aBuf */ 48ef7a6304Sdan int nAlloc; /* Size of allocation containing aBuf */ 49ef7a6304Sdan }; 50ef7a6304Sdan 51ef7a6304Sdan /* 52ef7a6304Sdan ** An object of this type is used internally as an abstraction for the 53ef7a6304Sdan ** input data read by changeset iterators. Input data may be supplied 54ef7a6304Sdan ** either as a single large buffer (sqlite3changeset_start()) or using 55ef7a6304Sdan ** a stream function (sqlite3changeset_start_str()). 56ef7a6304Sdan */ 57ef7a6304Sdan struct SessionInput { 584757c658Sdan int iNext; /* Offset in aData[] of next change */ 594757c658Sdan u8 *aData; /* Pointer to buffer containing changeset */ 604757c658Sdan int nData; /* Number of bytes in aData */ 614757c658Sdan 62ef7a6304Sdan SessionBuffer buf; /* Current read buffer */ 63ef7a6304Sdan int (*xInput)(void*, void*, int*); /* Input stream call (or NULL) */ 64ef7a6304Sdan void *pIn; /* First argument to xInput */ 65ef7a6304Sdan int bEof; /* Set to true after xInput finished */ 66ef7a6304Sdan }; 67ef7a6304Sdan 68ef7a6304Sdan /* 69296c7658Sdan ** Structure for changeset iterators. 70296c7658Sdan */ 71296c7658Sdan struct sqlite3_changeset_iter { 72ef7a6304Sdan SessionInput in; /* Input buffer or stream */ 73ef7a6304Sdan SessionBuffer tblhdr; /* Buffer to hold apValue/zTab/abPK/ */ 7473b3c055Sdan int bPatchset; /* True if this is a patchset */ 75296c7658Sdan int rc; /* Iterator error code */ 76296c7658Sdan sqlite3_stmt *pConflict; /* Points to conflicting row, if any */ 77296c7658Sdan char *zTab; /* Current table */ 78296c7658Sdan int nCol; /* Number of columns in zTab */ 79296c7658Sdan int op; /* Current operation */ 80b4480e94Sdan int bIndirect; /* True if current change was indirect */ 81244593c8Sdan u8 *abPK; /* Primary key array */ 82296c7658Sdan sqlite3_value **apValue; /* old.* and new.* values */ 83296c7658Sdan }; 84296c7658Sdan 85296c7658Sdan /* 864fccf43aSdan ** Each session object maintains a set of the following structures, one 874fccf43aSdan ** for each table the session object is monitoring. The structures are 884fccf43aSdan ** stored in a linked list starting at sqlite3_session.pTable. 894fccf43aSdan ** 904fccf43aSdan ** The keys of the SessionTable.aChange[] hash table are all rows that have 914fccf43aSdan ** been modified in any way since the session object was attached to the 924fccf43aSdan ** table. 934fccf43aSdan ** 944fccf43aSdan ** The data associated with each hash-table entry is a structure containing 954fccf43aSdan ** a subset of the initial values that the modified row contained at the 964fccf43aSdan ** start of the session. Or no initial values if the row was inserted. 974fccf43aSdan */ 984fccf43aSdan struct SessionTable { 994fccf43aSdan SessionTable *pNext; 1004fccf43aSdan char *zName; /* Local name of table */ 1014fccf43aSdan int nCol; /* Number of columns in table zName */ 102e8d5648eSdan const char **azCol; /* Column names */ 103e8d5648eSdan u8 *abPK; /* Array of primary key flags */ 104296c7658Sdan int nEntry; /* Total number of entries in hash table */ 1054fccf43aSdan int nChange; /* Size of apChange[] array */ 1064fccf43aSdan SessionChange **apChange; /* Hash table buckets */ 1074fccf43aSdan }; 1084fccf43aSdan 1094fccf43aSdan /* 1104fccf43aSdan ** RECORD FORMAT: 1114fccf43aSdan ** 1124fccf43aSdan ** The following record format is similar to (but not compatible with) that 1134fccf43aSdan ** used in SQLite database files. This format is used as part of the 1144fccf43aSdan ** change-set binary format, and so must be architecture independent. 1154fccf43aSdan ** 1164fccf43aSdan ** Unlike the SQLite database record format, each field is self-contained - 1174fccf43aSdan ** there is no separation of header and data. Each field begins with a 1184fccf43aSdan ** single byte describing its type, as follows: 1194fccf43aSdan ** 1204fccf43aSdan ** 0x00: Undefined value. 1214fccf43aSdan ** 0x01: Integer value. 1224fccf43aSdan ** 0x02: Real value. 1234fccf43aSdan ** 0x03: Text value. 1244fccf43aSdan ** 0x04: Blob value. 1254fccf43aSdan ** 0x05: SQL NULL value. 1264fccf43aSdan ** 1274fccf43aSdan ** Note that the above match the definitions of SQLITE_INTEGER, SQLITE_TEXT 1284fccf43aSdan ** and so on in sqlite3.h. For undefined and NULL values, the field consists 1294fccf43aSdan ** only of the single type byte. For other types of values, the type byte 1304fccf43aSdan ** is followed by: 1314fccf43aSdan ** 1324fccf43aSdan ** Text values: 1334fccf43aSdan ** A varint containing the number of bytes in the value (encoded using 1344fccf43aSdan ** UTF-8). Followed by a buffer containing the UTF-8 representation 1354fccf43aSdan ** of the text value. There is no nul terminator. 1364fccf43aSdan ** 1374fccf43aSdan ** Blob values: 1384fccf43aSdan ** A varint containing the number of bytes in the value, followed by 1394fccf43aSdan ** a buffer containing the value itself. 1404fccf43aSdan ** 1414fccf43aSdan ** Integer values: 1424fccf43aSdan ** An 8-byte big-endian integer value. 1434fccf43aSdan ** 1444fccf43aSdan ** Real values: 1454fccf43aSdan ** An 8-byte big-endian IEEE 754-2008 real value. 1464fccf43aSdan ** 1474fccf43aSdan ** Varint values are encoded in the same way as varints in the SQLite 1484fccf43aSdan ** record format. 1494fccf43aSdan ** 1504fccf43aSdan ** CHANGESET FORMAT: 1514fccf43aSdan ** 1524fccf43aSdan ** A changeset is a collection of DELETE, UPDATE and INSERT operations on 1534fccf43aSdan ** one or more tables. Operations on a single table are grouped together, 1544fccf43aSdan ** but may occur in any order (i.e. deletes, updates and inserts are all 1554fccf43aSdan ** mixed together). 1564fccf43aSdan ** 1574fccf43aSdan ** Each group of changes begins with a table header: 1584fccf43aSdan ** 1594fccf43aSdan ** 1 byte: Constant 0x54 (capital 'T') 1604fccf43aSdan ** Varint: Big-endian integer set to the number of columns in the table. 16173b3c055Sdan ** nCol bytes: 0x01 for PK columns, 0x00 otherwise. 1624fccf43aSdan ** N bytes: Unqualified table name (encoded using UTF-8). Nul-terminated. 1634fccf43aSdan ** 1644fccf43aSdan ** Followed by one or more changes to the table. 1654fccf43aSdan ** 1664fccf43aSdan ** 1 byte: Either SQLITE_INSERT, UPDATE or DELETE. 1675d607a6eSdan ** 1 byte: The "indirect-change" flag. 1684fccf43aSdan ** old.* record: (delete and update only) 1694fccf43aSdan ** new.* record: (insert and update only) 17073b3c055Sdan ** 17173b3c055Sdan ** PATCHSET FORMAT: 17273b3c055Sdan ** 17373b3c055Sdan ** A patchset is also a collection of changes. It is similar to a changeset, 17473b3c055Sdan ** but omits those fields that are not useful if no conflict resolution 17573b3c055Sdan ** is required when applying the changeset. 17673b3c055Sdan ** 17773b3c055Sdan ** Each group of changes begins with a table header: 17873b3c055Sdan ** 17973b3c055Sdan ** 1 byte: Constant 0x50 (capital 'P') 18073b3c055Sdan ** Varint: Big-endian integer set to the number of columns in the table. 18173b3c055Sdan ** nCol bytes: 0x01 for PK columns, 0x00 otherwise. 18273b3c055Sdan ** N bytes: Unqualified table name (encoded using UTF-8). Nul-terminated. 18373b3c055Sdan ** 18473b3c055Sdan ** Followed by one or more changes to the table. 18573b3c055Sdan ** 18673b3c055Sdan ** 1 byte: Either SQLITE_INSERT, UPDATE or DELETE. 18773b3c055Sdan ** 1 byte: The "indirect-change" flag. 18873b3c055Sdan ** single record: (PK fields for DELETE, or full record for INSERT/UPDATE). 1894fccf43aSdan */ 1904fccf43aSdan 1914fccf43aSdan /* 1924fccf43aSdan ** For each row modified during a session, there exists a single instance of 1934fccf43aSdan ** this structure stored in a SessionTable.aChange[] hash table. 1944fccf43aSdan */ 1954fccf43aSdan struct SessionChange { 196798693b2Sdan int op; /* One of UPDATE, DELETE, INSERT */ 197b4480e94Sdan int bIndirect; /* True if this change is "indirect" */ 1984fccf43aSdan int nRecord; /* Number of bytes in buffer aRecord[] */ 1994fccf43aSdan u8 *aRecord; /* Buffer containing old.* record */ 2004fccf43aSdan SessionChange *pNext; /* For hash-table collisions */ 2014fccf43aSdan }; 2024fccf43aSdan 203296c7658Sdan /* 204296c7658Sdan ** Write a varint with value iVal into the buffer at aBuf. Return the 205296c7658Sdan ** number of bytes written. 206296c7658Sdan */ 207296c7658Sdan static int sessionVarintPut(u8 *aBuf, int iVal){ 208296c7658Sdan return putVarint32(aBuf, iVal); 2094fccf43aSdan } 2104fccf43aSdan 211296c7658Sdan /* 212296c7658Sdan ** Return the number of bytes required to store value iVal as a varint. 213296c7658Sdan */ 214296c7658Sdan static int sessionVarintLen(int iVal){ 215296c7658Sdan return sqlite3VarintLen(iVal); 216296c7658Sdan } 217296c7658Sdan 218296c7658Sdan /* 219296c7658Sdan ** Read a varint value from aBuf[] into *piVal. Return the number of 220296c7658Sdan ** bytes read. 221296c7658Sdan */ 2224fccf43aSdan static int sessionVarintGet(u8 *aBuf, int *piVal){ 223296c7658Sdan return getVarint32(aBuf, *piVal); 2244fccf43aSdan } 2254fccf43aSdan 226296c7658Sdan /* 227296c7658Sdan ** Read a 64-bit big-endian integer value from buffer aRec[]. Return 228296c7658Sdan ** the value read. 229296c7658Sdan */ 2304fccf43aSdan static sqlite3_int64 sessionGetI64(u8 *aRec){ 2314fccf43aSdan return (((sqlite3_int64)aRec[0]) << 56) 2324fccf43aSdan + (((sqlite3_int64)aRec[1]) << 48) 2334fccf43aSdan + (((sqlite3_int64)aRec[2]) << 40) 2344fccf43aSdan + (((sqlite3_int64)aRec[3]) << 32) 2354fccf43aSdan + (((sqlite3_int64)aRec[4]) << 24) 2364fccf43aSdan + (((sqlite3_int64)aRec[5]) << 16) 2374fccf43aSdan + (((sqlite3_int64)aRec[6]) << 8) 2384fccf43aSdan + (((sqlite3_int64)aRec[7]) << 0); 2394fccf43aSdan } 2404fccf43aSdan 2414fccf43aSdan /* 242296c7658Sdan ** Write a 64-bit big-endian integer value to the buffer aBuf[]. 243296c7658Sdan */ 244296c7658Sdan static void sessionPutI64(u8 *aBuf, sqlite3_int64 i){ 245296c7658Sdan aBuf[0] = (i>>56) & 0xFF; 246296c7658Sdan aBuf[1] = (i>>48) & 0xFF; 247296c7658Sdan aBuf[2] = (i>>40) & 0xFF; 248296c7658Sdan aBuf[3] = (i>>32) & 0xFF; 249296c7658Sdan aBuf[4] = (i>>24) & 0xFF; 250296c7658Sdan aBuf[5] = (i>>16) & 0xFF; 251296c7658Sdan aBuf[6] = (i>> 8) & 0xFF; 252296c7658Sdan aBuf[7] = (i>> 0) & 0xFF; 253296c7658Sdan } 254296c7658Sdan 255296c7658Sdan /* 2564fccf43aSdan ** This function is used to serialize the contents of value pValue (see 2574fccf43aSdan ** comment titled "RECORD FORMAT" above). 2584fccf43aSdan ** 2594fccf43aSdan ** If it is non-NULL, the serialized form of the value is written to 2604fccf43aSdan ** buffer aBuf. *pnWrite is set to the number of bytes written before 2614fccf43aSdan ** returning. Or, if aBuf is NULL, the only thing this function does is 2624fccf43aSdan ** set *pnWrite. 2634fccf43aSdan ** 2644fccf43aSdan ** If no error occurs, SQLITE_OK is returned. Or, if an OOM error occurs 2654fccf43aSdan ** within a call to sqlite3_value_text() (may fail if the db is utf-16)) 2664fccf43aSdan ** SQLITE_NOMEM is returned. 2674fccf43aSdan */ 2684fccf43aSdan static int sessionSerializeValue( 2694fccf43aSdan u8 *aBuf, /* If non-NULL, write serialized value here */ 2704fccf43aSdan sqlite3_value *pValue, /* Value to serialize */ 2714fccf43aSdan int *pnWrite /* IN/OUT: Increment by bytes written */ 2724fccf43aSdan ){ 273296c7658Sdan int nByte; /* Size of serialized value in bytes */ 2744fccf43aSdan 27580fe2d93Sdan if( pValue ){ 27680fe2d93Sdan int eType; /* Value type (SQLITE_NULL, TEXT etc.) */ 27780fe2d93Sdan 2784fccf43aSdan eType = sqlite3_value_type(pValue); 2794fccf43aSdan if( aBuf ) aBuf[0] = eType; 2804fccf43aSdan 2814fccf43aSdan switch( eType ){ 2824fccf43aSdan case SQLITE_NULL: 2834fccf43aSdan nByte = 1; 2844fccf43aSdan break; 2854fccf43aSdan 2864fccf43aSdan case SQLITE_INTEGER: 2874fccf43aSdan case SQLITE_FLOAT: 2884fccf43aSdan if( aBuf ){ 2894fccf43aSdan /* TODO: SQLite does something special to deal with mixed-endian 2904fccf43aSdan ** floating point values (e.g. ARM7). This code probably should 2914fccf43aSdan ** too. */ 2924fccf43aSdan u64 i; 2934fccf43aSdan if( eType==SQLITE_INTEGER ){ 2944fccf43aSdan i = (u64)sqlite3_value_int64(pValue); 2954fccf43aSdan }else{ 2964fccf43aSdan double r; 2974fccf43aSdan assert( sizeof(double)==8 && sizeof(u64)==8 ); 2984fccf43aSdan r = sqlite3_value_double(pValue); 2994fccf43aSdan memcpy(&i, &r, 8); 3004fccf43aSdan } 301296c7658Sdan sessionPutI64(&aBuf[1], i); 3024fccf43aSdan } 3034fccf43aSdan nByte = 9; 3044fccf43aSdan break; 3054fccf43aSdan 3064e895da1Sdan default: { 30780fe2d93Sdan u8 *z; 30880fe2d93Sdan int n; 30980fe2d93Sdan int nVarint; 31080fe2d93Sdan 3114e895da1Sdan assert( eType==SQLITE_TEXT || eType==SQLITE_BLOB ); 31280fe2d93Sdan if( eType==SQLITE_TEXT ){ 31380fe2d93Sdan z = (u8 *)sqlite3_value_text(pValue); 31480fe2d93Sdan }else{ 31580fe2d93Sdan z = (u8 *)sqlite3_value_blob(pValue); 31680fe2d93Sdan } 31780fe2d93Sdan if( z==0 ) return SQLITE_NOMEM; 31880fe2d93Sdan n = sqlite3_value_bytes(pValue); 31980fe2d93Sdan nVarint = sessionVarintLen(n); 32080fe2d93Sdan 3214fccf43aSdan if( aBuf ){ 3224fccf43aSdan sessionVarintPut(&aBuf[1], n); 3234fccf43aSdan memcpy(&aBuf[nVarint + 1], eType==SQLITE_TEXT ? 3244fccf43aSdan sqlite3_value_text(pValue) : sqlite3_value_blob(pValue), n 3254fccf43aSdan ); 3264fccf43aSdan } 3274fccf43aSdan 3284fccf43aSdan nByte = 1 + nVarint + n; 3294fccf43aSdan break; 3304fccf43aSdan } 3314fccf43aSdan } 33280fe2d93Sdan }else{ 33380fe2d93Sdan nByte = 1; 33480fe2d93Sdan if( aBuf ) aBuf[0] = '\0'; 33580fe2d93Sdan } 3364fccf43aSdan 337fa122adaSdan if( pnWrite ) *pnWrite += nByte; 3384fccf43aSdan return SQLITE_OK; 3394fccf43aSdan } 3404fccf43aSdan 341fa122adaSdan 342798693b2Sdan /* 343798693b2Sdan ** This macro is used to calculate hash key values for data structures. In 344798693b2Sdan ** order to use this macro, the entire data structure must be represented 345798693b2Sdan ** as a series of unsigned integers. In order to calculate a hash-key value 346798693b2Sdan ** for a data structure represented as three such integers, the macro may 347798693b2Sdan ** then be used as follows: 348798693b2Sdan ** 349798693b2Sdan ** int hash_key_value; 350798693b2Sdan ** hash_key_value = HASH_APPEND(0, <value 1>); 351798693b2Sdan ** hash_key_value = HASH_APPEND(hash_key_value, <value 2>); 352798693b2Sdan ** hash_key_value = HASH_APPEND(hash_key_value, <value 3>); 353798693b2Sdan ** 354798693b2Sdan ** In practice, the data structures this macro is used for are the primary 355798693b2Sdan ** key values of modified rows. 356798693b2Sdan */ 3574131639cSdan #define HASH_APPEND(hash, add) ((hash) << 3) ^ (hash) ^ (unsigned int)(add) 358798693b2Sdan 359798693b2Sdan /* 360798693b2Sdan ** Append the hash of the 64-bit integer passed as the second argument to the 361798693b2Sdan ** hash-key value passed as the first. Return the new hash-key value. 362798693b2Sdan */ 3634131639cSdan static unsigned int sessionHashAppendI64(unsigned int h, i64 i){ 364e8d5648eSdan h = HASH_APPEND(h, i & 0xFFFFFFFF); 365e8d5648eSdan return HASH_APPEND(h, (i>>32)&0xFFFFFFFF); 366e8d5648eSdan } 367798693b2Sdan 368798693b2Sdan /* 369798693b2Sdan ** Append the hash of the blob passed via the second and third arguments to 370798693b2Sdan ** the hash-key value passed as the first. Return the new hash-key value. 371798693b2Sdan */ 3724131639cSdan static unsigned int sessionHashAppendBlob(unsigned int h, int n, const u8 *z){ 373e8d5648eSdan int i; 374e8d5648eSdan for(i=0; i<n; i++) h = HASH_APPEND(h, z[i]); 375e8d5648eSdan return h; 376e8d5648eSdan } 377e8d5648eSdan 3784fccf43aSdan /* 379798693b2Sdan ** Append the hash of the data type passed as the second argument to the 380798693b2Sdan ** hash-key value passed as the first. Return the new hash-key value. 381798693b2Sdan */ 382798693b2Sdan static unsigned int sessionHashAppendType(unsigned int h, int eType){ 383798693b2Sdan return HASH_APPEND(h, eType); 384798693b2Sdan } 385798693b2Sdan 386798693b2Sdan /* 3874131639cSdan ** This function may only be called from within a pre-update callback. 3884131639cSdan ** It calculates a hash based on the primary key values of the old.* or 389798693b2Sdan ** new.* row currently available and, assuming no error occurs, writes it to 390798693b2Sdan ** *piHash before returning. If the primary key contains one or more NULL 391798693b2Sdan ** values, *pbNullPK is set to true before returning. 392798693b2Sdan ** 393798693b2Sdan ** If an error occurs, an SQLite error code is returned and the final values 394798693b2Sdan ** of *piHash asn *pbNullPK are undefined. Otherwise, SQLITE_OK is returned 395798693b2Sdan ** and the output variables are set as described above. 3964fccf43aSdan */ 397798693b2Sdan static int sessionPreupdateHash( 398e8d5648eSdan sqlite3 *db, /* Database handle */ 399e8d5648eSdan SessionTable *pTab, /* Session table handle */ 400e8d5648eSdan int bNew, /* True to hash the new.* PK */ 40127453faeSdan int *piHash, /* OUT: Hash value */ 402798693b2Sdan int *pbNullPK /* OUT: True if there are NULL values in PK */ 403e8d5648eSdan ){ 4044131639cSdan unsigned int h = 0; /* Hash value to return */ 4054131639cSdan int i; /* Used to iterate through columns */ 406e8d5648eSdan 40727453faeSdan assert( *pbNullPK==0 ); 408e8d5648eSdan assert( pTab->nCol==sqlite3_preupdate_count(db) ); 409e8d5648eSdan for(i=0; i<pTab->nCol; i++){ 410e8d5648eSdan if( pTab->abPK[i] ){ 411e8d5648eSdan int rc; 412e8d5648eSdan int eType; 413e8d5648eSdan sqlite3_value *pVal; 414e8d5648eSdan 415e8d5648eSdan if( bNew ){ 416e8d5648eSdan rc = sqlite3_preupdate_new(db, i, &pVal); 417e8d5648eSdan }else{ 418e8d5648eSdan rc = sqlite3_preupdate_old(db, i, &pVal); 419e8d5648eSdan } 42012ca0b56Sdan if( rc!=SQLITE_OK ) return rc; 421e8d5648eSdan 422e8d5648eSdan eType = sqlite3_value_type(pVal); 423798693b2Sdan h = sessionHashAppendType(h, eType); 4246734007dSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 425e8d5648eSdan i64 iVal; 426e8d5648eSdan if( eType==SQLITE_INTEGER ){ 427e8d5648eSdan iVal = sqlite3_value_int64(pVal); 428e8d5648eSdan }else{ 429e8d5648eSdan double rVal = sqlite3_value_double(pVal); 430e8d5648eSdan assert( sizeof(iVal)==8 && sizeof(rVal)==8 ); 431e8d5648eSdan memcpy(&iVal, &rVal, 8); 432e8d5648eSdan } 433e8d5648eSdan h = sessionHashAppendI64(h, iVal); 4346734007dSdan }else if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 4356734007dSdan const u8 *z; 4366734007dSdan if( eType==SQLITE_TEXT ){ 4376734007dSdan z = (const u8 *)sqlite3_value_text(pVal); 4386734007dSdan }else{ 4396734007dSdan z = (const u8 *)sqlite3_value_blob(pVal); 440e8d5648eSdan } 4416734007dSdan if( !z ) return SQLITE_NOMEM; 4426734007dSdan h = sessionHashAppendBlob(h, sqlite3_value_bytes(pVal), z); 4436734007dSdan }else{ 44427453faeSdan assert( eType==SQLITE_NULL ); 44527453faeSdan *pbNullPK = 1; 446e8d5648eSdan } 447e8d5648eSdan } 448e8d5648eSdan } 449e8d5648eSdan 450e8d5648eSdan *piHash = (h % pTab->nChange); 451e8d5648eSdan return SQLITE_OK; 452e8d5648eSdan } 453e8d5648eSdan 4544131639cSdan /* 4556cda207fSdan ** The buffer that the argument points to contains a serialized SQL value. 4566cda207fSdan ** Return the number of bytes of space occupied by the value (including 4576cda207fSdan ** the type byte). 4586cda207fSdan */ 4596cda207fSdan static int sessionSerialLen(u8 *a){ 4606cda207fSdan int e = *a; 4616cda207fSdan int n; 4626cda207fSdan if( e==0 ) return 1; 4636cda207fSdan if( e==SQLITE_NULL ) return 1; 4646cda207fSdan if( e==SQLITE_INTEGER || e==SQLITE_FLOAT ) return 9; 4656cda207fSdan return sessionVarintGet(&a[1], &n) + 1 + n; 4666cda207fSdan } 4676cda207fSdan 4686cda207fSdan /* 4695d607a6eSdan ** Based on the primary key values stored in change aRecord, calculate a 470798693b2Sdan ** hash key. Assume the has table has nBucket buckets. The hash keys 4714131639cSdan ** calculated by this function are compatible with those calculated by 4724131639cSdan ** sessionPreupdateHash(). 47364277f4aSdan ** 47464277f4aSdan ** The bPkOnly argument is non-zero if the record at aRecord[] is from 47564277f4aSdan ** a patchset DELETE. In this case the non-PK fields are omitted entirely. 4764131639cSdan */ 4774131639cSdan static unsigned int sessionChangeHash( 4784131639cSdan SessionTable *pTab, /* Table handle */ 47964277f4aSdan int bPkOnly, /* Record consists of PK fields only */ 4805d607a6eSdan u8 *aRecord, /* Change record */ 4814131639cSdan int nBucket /* Assume this many buckets in hash table */ 482e8d5648eSdan ){ 4834131639cSdan unsigned int h = 0; /* Value to return */ 4844131639cSdan int i; /* Used to iterate through columns */ 4855d607a6eSdan u8 *a = aRecord; /* Used to iterate through change record */ 486e8d5648eSdan 487e8d5648eSdan for(i=0; i<pTab->nCol; i++){ 4886cda207fSdan int eType = *a; 489e8d5648eSdan int isPK = pTab->abPK[i]; 49064277f4aSdan if( bPkOnly && isPK==0 ) continue; 491e8d5648eSdan 49227453faeSdan /* It is not possible for eType to be SQLITE_NULL here. The session 49327453faeSdan ** module does not record changes for rows with NULL values stored in 49427453faeSdan ** primary key columns. */ 49527453faeSdan assert( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT 49627453faeSdan || eType==SQLITE_TEXT || eType==SQLITE_BLOB 4976cda207fSdan || eType==SQLITE_NULL || eType==0 49827453faeSdan ); 4996cda207fSdan assert( !isPK || (eType!=0 && eType!=SQLITE_NULL) ); 50027453faeSdan 5016cda207fSdan if( isPK ){ 5026cda207fSdan a++; 503798693b2Sdan h = sessionHashAppendType(h, eType); 50427453faeSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 5056734007dSdan h = sessionHashAppendI64(h, sessionGetI64(a)); 506e8d5648eSdan a += 8; 50727453faeSdan }else{ 508e8d5648eSdan int n; 509e8d5648eSdan a += sessionVarintGet(a, &n); 5106734007dSdan h = sessionHashAppendBlob(h, n, a); 511e8d5648eSdan a += n; 512e8d5648eSdan } 5136cda207fSdan }else{ 5146cda207fSdan a += sessionSerialLen(a); 5156cda207fSdan } 516e8d5648eSdan } 517e8d5648eSdan return (h % nBucket); 518e8d5648eSdan } 519e8d5648eSdan 520798693b2Sdan /* 521798693b2Sdan ** Arguments aLeft and aRight are pointers to change records for table pTab. 522798693b2Sdan ** This function returns true if the two records apply to the same row (i.e. 523798693b2Sdan ** have the same values stored in the primary key columns), or false 524798693b2Sdan ** otherwise. 525798693b2Sdan */ 5265d607a6eSdan static int sessionChangeEqual( 527798693b2Sdan SessionTable *pTab, /* Table used for PK definition */ 528a71d2371Sdan int bLeftPkOnly, /* True if aLeft[] contains PK fields only */ 5295d607a6eSdan u8 *aLeft, /* Change record */ 530a71d2371Sdan int bRightPkOnly, /* True if aRight[] contains PK fields only */ 5315d607a6eSdan u8 *aRight /* Change record */ 5325d607a6eSdan ){ 533798693b2Sdan u8 *a1 = aLeft; /* Cursor to iterate through aLeft */ 534798693b2Sdan u8 *a2 = aRight; /* Cursor to iterate through aRight */ 535798693b2Sdan int iCol; /* Used to iterate through table columns */ 5365d607a6eSdan 537798693b2Sdan for(iCol=0; iCol<pTab->nCol; iCol++){ 5385d607a6eSdan int n1 = sessionSerialLen(a1); 5395d607a6eSdan int n2 = sessionSerialLen(a2); 5405d607a6eSdan 541798693b2Sdan if( pTab->abPK[iCol] && (n1!=n2 || memcmp(a1, a2, n1)) ){ 5425d607a6eSdan return 0; 5435d607a6eSdan } 54464277f4aSdan if( pTab->abPK[iCol] || bLeftPkOnly==0 ) a1 += n1; 54564277f4aSdan if( pTab->abPK[iCol] || bRightPkOnly==0 ) a2 += n2; 5465d607a6eSdan } 5475d607a6eSdan 5485d607a6eSdan return 1; 5495d607a6eSdan } 5505d607a6eSdan 551798693b2Sdan /* 552798693b2Sdan ** Arguments aLeft and aRight both point to buffers containing change 553798693b2Sdan ** records with nCol columns. This function "merges" the two records into 554798693b2Sdan ** a single records which is written to the buffer at *paOut. *paOut is 555798693b2Sdan ** then set to point to one byte after the last byte written before 556798693b2Sdan ** returning. 557798693b2Sdan ** 558798693b2Sdan ** The merging of records is done as follows: For each column, if the 559798693b2Sdan ** aRight record contains a value for the column, copy the value from 560798693b2Sdan ** their. Otherwise, if aLeft contains a value, copy it. If neither 561798693b2Sdan ** record contains a value for a given column, then neither does the 562798693b2Sdan ** output record. 563798693b2Sdan */ 5645d607a6eSdan static void sessionMergeRecord( 5655d607a6eSdan u8 **paOut, 566798693b2Sdan int nCol, 5675d607a6eSdan u8 *aLeft, 5685d607a6eSdan u8 *aRight 5695d607a6eSdan ){ 570798693b2Sdan u8 *a1 = aLeft; /* Cursor used to iterate through aLeft */ 571798693b2Sdan u8 *a2 = aRight; /* Cursor used to iterate through aRight */ 572798693b2Sdan u8 *aOut = *paOut; /* Output cursor */ 573798693b2Sdan int iCol; /* Used to iterate from 0 to nCol */ 5745d607a6eSdan 575798693b2Sdan for(iCol=0; iCol<nCol; iCol++){ 5765d607a6eSdan int n1 = sessionSerialLen(a1); 5775d607a6eSdan int n2 = sessionSerialLen(a2); 5785d607a6eSdan if( *a2 ){ 5795d607a6eSdan memcpy(aOut, a2, n2); 5805d607a6eSdan aOut += n2; 5815d607a6eSdan }else{ 5825d607a6eSdan memcpy(aOut, a1, n1); 5835d607a6eSdan aOut += n1; 5845d607a6eSdan } 5855d607a6eSdan a1 += n1; 5865d607a6eSdan a2 += n2; 5875d607a6eSdan } 5885d607a6eSdan 5895d607a6eSdan *paOut = aOut; 5905d607a6eSdan } 5915d607a6eSdan 592798693b2Sdan /* 593798693b2Sdan ** This is a helper function used by sessionMergeUpdate(). 594798693b2Sdan ** 595798693b2Sdan ** When this function is called, both *paOne and *paTwo point to a value 596798693b2Sdan ** within a change record. Before it returns, both have been advanced so 597798693b2Sdan ** as to point to the next value in the record. 598798693b2Sdan ** 599798693b2Sdan ** If, when this function is called, *paTwo points to a valid value (i.e. 600*fa29ecc4Sdan ** *paTwo[0] is not 0x00 - the "no value" placeholder), a copy of the *paTwo 601798693b2Sdan ** pointer is returned and *pnVal is set to the number of bytes in the 602798693b2Sdan ** serialized value. Otherwise, a copy of *paOne is returned and *pnVal 603798693b2Sdan ** set to the number of bytes in the value at *paOne. If *paOne points 604*fa29ecc4Sdan ** to the "no value" placeholder, *pnVal is set to 1. In other words: 605*fa29ecc4Sdan ** 606*fa29ecc4Sdan ** if( *paTwo is valid ) return *paTwo; 607*fa29ecc4Sdan ** return *paOne; 608*fa29ecc4Sdan ** 609798693b2Sdan */ 6105d607a6eSdan static u8 *sessionMergeValue( 611798693b2Sdan u8 **paOne, /* IN/OUT: Left-hand buffer pointer */ 612798693b2Sdan u8 **paTwo, /* IN/OUT: Right-hand buffer pointer */ 613798693b2Sdan int *pnVal /* OUT: Bytes in returned value */ 6145d607a6eSdan ){ 6155d607a6eSdan u8 *a1 = *paOne; 6165d607a6eSdan u8 *a2 = *paTwo; 6175d607a6eSdan u8 *pRet = 0; 6185d607a6eSdan int n1; 6195d607a6eSdan 6205d607a6eSdan assert( a1 ); 6215d607a6eSdan if( a2 ){ 6225d607a6eSdan int n2 = sessionSerialLen(a2); 6235d607a6eSdan if( *a2 ){ 6245d607a6eSdan *pnVal = n2; 6255d607a6eSdan pRet = a2; 6265d607a6eSdan } 6275d607a6eSdan *paTwo = &a2[n2]; 6285d607a6eSdan } 6295d607a6eSdan 6305d607a6eSdan n1 = sessionSerialLen(a1); 6315d607a6eSdan if( pRet==0 ){ 6325d607a6eSdan *pnVal = n1; 6335d607a6eSdan pRet = a1; 6345d607a6eSdan } 6355d607a6eSdan *paOne = &a1[n1]; 6365d607a6eSdan 6375d607a6eSdan return pRet; 6385d607a6eSdan } 6395d607a6eSdan 640798693b2Sdan /* 641798693b2Sdan ** This function is used by changeset_concat() to merge two UPDATE changes 642798693b2Sdan ** on the same row. 643798693b2Sdan */ 6445d607a6eSdan static int sessionMergeUpdate( 645798693b2Sdan u8 **paOut, /* IN/OUT: Pointer to output buffer */ 646798693b2Sdan SessionTable *pTab, /* Table change pertains to */ 647a71d2371Sdan int bPatchset, /* True if records are patchset records */ 648798693b2Sdan u8 *aOldRecord1, /* old.* record for first change */ 649798693b2Sdan u8 *aOldRecord2, /* old.* record for second change */ 650798693b2Sdan u8 *aNewRecord1, /* new.* record for first change */ 651798693b2Sdan u8 *aNewRecord2 /* new.* record for second change */ 6525d607a6eSdan ){ 6535d607a6eSdan u8 *aOld1 = aOldRecord1; 6545d607a6eSdan u8 *aOld2 = aOldRecord2; 6555d607a6eSdan u8 *aNew1 = aNewRecord1; 6565d607a6eSdan u8 *aNew2 = aNewRecord2; 6575d607a6eSdan 6585d607a6eSdan u8 *aOut = *paOut; 6595d607a6eSdan int i; 66064277f4aSdan 66164277f4aSdan if( bPatchset==0 ){ 6625d607a6eSdan int bRequired = 0; 6635d607a6eSdan 6645d607a6eSdan assert( aOldRecord1 && aNewRecord1 ); 6655d607a6eSdan 6665d607a6eSdan /* Write the old.* vector first. */ 6675d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6685d607a6eSdan int nOld; 6695d607a6eSdan u8 *aOld; 6705d607a6eSdan int nNew; 6715d607a6eSdan u8 *aNew; 6725d607a6eSdan 6735d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 6745d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 6755d607a6eSdan if( pTab->abPK[i] || nOld!=nNew || memcmp(aOld, aNew, nNew) ){ 6765d607a6eSdan if( pTab->abPK[i]==0 ) bRequired = 1; 6775d607a6eSdan memcpy(aOut, aOld, nOld); 6785d607a6eSdan aOut += nOld; 6795d607a6eSdan }else{ 6805d607a6eSdan *(aOut++) = '\0'; 6815d607a6eSdan } 6825d607a6eSdan } 6835d607a6eSdan 6845d607a6eSdan if( !bRequired ) return 0; 68564277f4aSdan } 6865d607a6eSdan 6875d607a6eSdan /* Write the new.* vector */ 6885d607a6eSdan aOld1 = aOldRecord1; 6895d607a6eSdan aOld2 = aOldRecord2; 6905d607a6eSdan aNew1 = aNewRecord1; 6915d607a6eSdan aNew2 = aNewRecord2; 6925d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6935d607a6eSdan int nOld; 6945d607a6eSdan u8 *aOld; 6955d607a6eSdan int nNew; 6965d607a6eSdan u8 *aNew; 6975d607a6eSdan 6985d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 6995d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 70064277f4aSdan if( bPatchset==0 70164277f4aSdan && (pTab->abPK[i] || (nOld==nNew && 0==memcmp(aOld, aNew, nNew))) 70264277f4aSdan ){ 7035d607a6eSdan *(aOut++) = '\0'; 7045d607a6eSdan }else{ 7055d607a6eSdan memcpy(aOut, aNew, nNew); 7065d607a6eSdan aOut += nNew; 7075d607a6eSdan } 7085d607a6eSdan } 7095d607a6eSdan 7105d607a6eSdan *paOut = aOut; 7115d607a6eSdan return 1; 7125d607a6eSdan } 7135d607a6eSdan 71477fc1d5bSdan /* 71577fc1d5bSdan ** This function is only called from within a pre-update-hook callback. 71677fc1d5bSdan ** It determines if the current pre-update-hook change affects the same row 71777fc1d5bSdan ** as the change stored in argument pChange. If so, it returns true. Otherwise 71877fc1d5bSdan ** if the pre-update-hook does not affect the same row as pChange, it returns 71977fc1d5bSdan ** false. 72077fc1d5bSdan */ 72177fc1d5bSdan static int sessionPreupdateEqual( 72277fc1d5bSdan sqlite3 *db, /* Database handle */ 72377fc1d5bSdan SessionTable *pTab, /* Table associated with change */ 72477fc1d5bSdan SessionChange *pChange, /* Change to compare to */ 72577fc1d5bSdan int op /* Current pre-update operation */ 726e8d5648eSdan ){ 72777fc1d5bSdan int iCol; /* Used to iterate through columns */ 72877fc1d5bSdan u8 *a = pChange->aRecord; /* Cursor used to scan change record */ 729e8d5648eSdan 73077fc1d5bSdan assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE ); 73177fc1d5bSdan for(iCol=0; iCol<pTab->nCol; iCol++){ 73277fc1d5bSdan if( !pTab->abPK[iCol] ){ 733798693b2Sdan a += sessionSerialLen(a); 734e8d5648eSdan }else{ 7356734007dSdan sqlite3_value *pVal; /* Value returned by preupdate_new/old */ 7366734007dSdan int rc; /* Error code from preupdate_new/old */ 737798693b2Sdan int eType = *a++; /* Type of value from change record */ 7386734007dSdan 7396734007dSdan /* The following calls to preupdate_new() and preupdate_old() can not 7406734007dSdan ** fail. This is because they cache their return values, and by the 7416734007dSdan ** time control flows to here they have already been called once from 7426734007dSdan ** within sessionPreupdateHash(). The first two asserts below verify 7436734007dSdan ** this (that the method has already been called). */ 74477fc1d5bSdan if( op==SQLITE_INSERT ){ 7456734007dSdan assert( db->pPreUpdate->pNewUnpacked || db->pPreUpdate->aNew ); 74677fc1d5bSdan rc = sqlite3_preupdate_new(db, iCol, &pVal); 747e8d5648eSdan }else{ 7486734007dSdan assert( db->pPreUpdate->pUnpacked ); 74977fc1d5bSdan rc = sqlite3_preupdate_old(db, iCol, &pVal); 750e8d5648eSdan } 7516734007dSdan assert( rc==SQLITE_OK ); 75277fc1d5bSdan if( sqlite3_value_type(pVal)!=eType ) return 0; 753e8d5648eSdan 75412ca0b56Sdan /* A SessionChange object never has a NULL value in a PK column */ 75512ca0b56Sdan assert( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT 75612ca0b56Sdan || eType==SQLITE_BLOB || eType==SQLITE_TEXT 75712ca0b56Sdan ); 75812ca0b56Sdan 75912ca0b56Sdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 760e8d5648eSdan i64 iVal = sessionGetI64(a); 761e8d5648eSdan a += 8; 762e8d5648eSdan if( eType==SQLITE_INTEGER ){ 76377fc1d5bSdan if( sqlite3_value_int64(pVal)!=iVal ) return 0; 764e8d5648eSdan }else{ 765e8d5648eSdan double rVal; 766e8d5648eSdan assert( sizeof(iVal)==8 && sizeof(rVal)==8 ); 767e8d5648eSdan memcpy(&rVal, &iVal, 8); 76877fc1d5bSdan if( sqlite3_value_double(pVal)!=rVal ) return 0; 769e8d5648eSdan } 77012ca0b56Sdan }else{ 771e8d5648eSdan int n; 772e8d5648eSdan const u8 *z; 773e8d5648eSdan a += sessionVarintGet(a, &n); 77477fc1d5bSdan if( sqlite3_value_bytes(pVal)!=n ) return 0; 77512ca0b56Sdan if( eType==SQLITE_TEXT ){ 77612ca0b56Sdan z = sqlite3_value_text(pVal); 77712ca0b56Sdan }else{ 77812ca0b56Sdan z = sqlite3_value_blob(pVal); 77912ca0b56Sdan } 78077fc1d5bSdan if( memcmp(a, z, n) ) return 0; 781e8d5648eSdan a += n; 782e8d5648eSdan break; 783e8d5648eSdan } 784e8d5648eSdan } 785e8d5648eSdan } 786e8d5648eSdan 78777fc1d5bSdan return 1; 7884fccf43aSdan } 7894fccf43aSdan 7904fccf43aSdan /* 7914fccf43aSdan ** If required, grow the hash table used to store changes on table pTab 7924fccf43aSdan ** (part of the session pSession). If a fatal OOM error occurs, set the 7934fccf43aSdan ** session object to failed and return SQLITE_ERROR. Otherwise, return 7944fccf43aSdan ** SQLITE_OK. 7954fccf43aSdan ** 7964fccf43aSdan ** It is possible that a non-fatal OOM error occurs in this function. In 7974fccf43aSdan ** that case the hash-table does not grow, but SQLITE_OK is returned anyway. 7984fccf43aSdan ** Growing the hash table in this case is a performance optimization only, 7994fccf43aSdan ** it is not required for correct operation. 8004fccf43aSdan */ 80164277f4aSdan static int sessionGrowHash(int bPatchset, SessionTable *pTab){ 8024fccf43aSdan if( pTab->nChange==0 || pTab->nEntry>=(pTab->nChange/2) ){ 8034fccf43aSdan int i; 8044fccf43aSdan SessionChange **apNew; 8054fccf43aSdan int nNew = (pTab->nChange ? pTab->nChange : 128) * 2; 8064fccf43aSdan 8074fccf43aSdan apNew = (SessionChange **)sqlite3_malloc(sizeof(SessionChange *) * nNew); 8084fccf43aSdan if( apNew==0 ){ 8094fccf43aSdan if( pTab->nChange==0 ){ 8104fccf43aSdan return SQLITE_ERROR; 8114fccf43aSdan } 8124fccf43aSdan return SQLITE_OK; 8134fccf43aSdan } 8144fccf43aSdan memset(apNew, 0, sizeof(SessionChange *) * nNew); 8154fccf43aSdan 8164fccf43aSdan for(i=0; i<pTab->nChange; i++){ 8174fccf43aSdan SessionChange *p; 8184fccf43aSdan SessionChange *pNext; 8194fccf43aSdan for(p=pTab->apChange[i]; p; p=pNext){ 82064277f4aSdan int bPkOnly = (p->op==SQLITE_DELETE && bPatchset); 82164277f4aSdan int iHash = sessionChangeHash(pTab, bPkOnly, p->aRecord, nNew); 8224fccf43aSdan pNext = p->pNext; 8234fccf43aSdan p->pNext = apNew[iHash]; 8244fccf43aSdan apNew[iHash] = p; 8254fccf43aSdan } 8264fccf43aSdan } 8274fccf43aSdan 8284fccf43aSdan sqlite3_free(pTab->apChange); 8294fccf43aSdan pTab->nChange = nNew; 8304fccf43aSdan pTab->apChange = apNew; 8314fccf43aSdan } 8324fccf43aSdan 8334fccf43aSdan return SQLITE_OK; 8344fccf43aSdan } 8354fccf43aSdan 836296c7658Sdan /* 837e8d5648eSdan ** This function queries the database for the names of the columns of table 838e8d5648eSdan ** zThis, in schema zDb. It is expected that the table has nCol columns. If 839e8d5648eSdan ** not, SQLITE_SCHEMA is returned and none of the output variables are 840e8d5648eSdan ** populated. 841e8d5648eSdan ** 84277fc1d5bSdan ** Otherwise, if they are not NULL, variable *pnCol is set to the number 84377fc1d5bSdan ** of columns in the database table and variable *pzTab is set to point to a 844e8d5648eSdan ** nul-terminated copy of the table name. *pazCol (if not NULL) is set to 845e8d5648eSdan ** point to an array of pointers to column names. And *pabPK (again, if not 846e8d5648eSdan ** NULL) is set to point to an array of booleans - true if the corresponding 847e8d5648eSdan ** column is part of the primary key. 848e8d5648eSdan ** 849e8d5648eSdan ** For example, if the table is declared as: 850e8d5648eSdan ** 851e8d5648eSdan ** CREATE TABLE tbl1(w, x, y, z, PRIMARY KEY(w, z)); 852e8d5648eSdan ** 85377fc1d5bSdan ** Then the four output variables are populated as follows: 854e8d5648eSdan ** 85577fc1d5bSdan ** *pnCol = 4 856e8d5648eSdan ** *pzTab = "tbl1" 857e8d5648eSdan ** *pazCol = {"w", "x", "y", "z"} 858e8d5648eSdan ** *pabPK = {1, 0, 0, 1} 859e8d5648eSdan ** 860e8d5648eSdan ** All returned buffers are part of the same single allocation, which must 861e8d5648eSdan ** be freed using sqlite3_free() by the caller. If pazCol was not NULL, then 862e8d5648eSdan ** pointer *pazCol should be freed to release all memory. Otherwise, pointer 863e8d5648eSdan ** *pabPK. It is illegal for both pazCol and pabPK to be NULL. 864e8d5648eSdan */ 865e8d5648eSdan static int sessionTableInfo( 866e8d5648eSdan sqlite3 *db, /* Database connection */ 867e8d5648eSdan const char *zDb, /* Name of attached database (e.g. "main") */ 868e8d5648eSdan const char *zThis, /* Table name */ 869ca62ad57Sdan int *pnCol, /* OUT: number of columns */ 870e8d5648eSdan const char **pzTab, /* OUT: Copy of zThis */ 871e8d5648eSdan const char ***pazCol, /* OUT: Array of column names for table */ 872e8d5648eSdan u8 **pabPK /* OUT: Array of booleans - true for PK col */ 873e8d5648eSdan ){ 874e8d5648eSdan char *zPragma; 875e8d5648eSdan sqlite3_stmt *pStmt; 876e8d5648eSdan int rc; 877e8d5648eSdan int nByte; 878e8d5648eSdan int nDbCol = 0; 879e8d5648eSdan int nThis; 880e8d5648eSdan int i; 881e8d5648eSdan u8 *pAlloc; 882db04571cSdan char **azCol = 0; 883e8d5648eSdan u8 *abPK; 884e8d5648eSdan 885db04571cSdan assert( pazCol && pabPK ); 886e8d5648eSdan 887cfdbde21Sdrh nThis = sqlite3Strlen30(zThis); 888e8d5648eSdan zPragma = sqlite3_mprintf("PRAGMA '%q'.table_info('%q')", zDb, zThis); 889e8d5648eSdan if( !zPragma ) return SQLITE_NOMEM; 890e8d5648eSdan 891e8d5648eSdan rc = sqlite3_prepare_v2(db, zPragma, -1, &pStmt, 0); 892e8d5648eSdan sqlite3_free(zPragma); 893e8d5648eSdan if( rc!=SQLITE_OK ) return rc; 894e8d5648eSdan 895e8d5648eSdan nByte = nThis + 1; 896e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 897e8d5648eSdan nByte += sqlite3_column_bytes(pStmt, 1); 898e8d5648eSdan nDbCol++; 899e8d5648eSdan } 900e8d5648eSdan rc = sqlite3_reset(pStmt); 901e8d5648eSdan 902e8d5648eSdan if( rc==SQLITE_OK ){ 903e8d5648eSdan nByte += nDbCol * (sizeof(const char *) + sizeof(u8) + 1); 904e8d5648eSdan pAlloc = sqlite3_malloc(nByte); 905e8d5648eSdan if( pAlloc==0 ){ 906e8d5648eSdan rc = SQLITE_NOMEM; 907e8d5648eSdan } 908e8d5648eSdan } 909e8d5648eSdan if( rc==SQLITE_OK ){ 910e8d5648eSdan azCol = (char **)pAlloc; 911ca62ad57Sdan pAlloc = (u8 *)&azCol[nDbCol]; 912e8d5648eSdan abPK = (u8 *)pAlloc; 913ca62ad57Sdan pAlloc = &abPK[nDbCol]; 914e8d5648eSdan if( pzTab ){ 915e8d5648eSdan memcpy(pAlloc, zThis, nThis+1); 916e8d5648eSdan *pzTab = (char *)pAlloc; 917e8d5648eSdan pAlloc += nThis+1; 918e8d5648eSdan } 919e8d5648eSdan 920e8d5648eSdan i = 0; 921e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 922e8d5648eSdan int nName = sqlite3_column_bytes(pStmt, 1); 923e8d5648eSdan const unsigned char *zName = sqlite3_column_text(pStmt, 1); 924e8d5648eSdan if( zName==0 ) break; 925e8d5648eSdan memcpy(pAlloc, zName, nName+1); 926e8d5648eSdan azCol[i] = (char *)pAlloc; 927e8d5648eSdan pAlloc += nName+1; 928db04571cSdan abPK[i] = sqlite3_column_int(pStmt, 5); 929e8d5648eSdan i++; 930e8d5648eSdan } 931e8d5648eSdan rc = sqlite3_reset(pStmt); 932e8d5648eSdan 933e8d5648eSdan } 934e8d5648eSdan 935e8d5648eSdan /* If successful, populate the output variables. Otherwise, zero them and 936e8d5648eSdan ** free any allocation made. An error code will be returned in this case. 937e8d5648eSdan */ 938e8d5648eSdan if( rc==SQLITE_OK ){ 939db04571cSdan *pazCol = (const char **)azCol; 940db04571cSdan *pabPK = abPK; 941ca62ad57Sdan *pnCol = nDbCol; 942e8d5648eSdan }else{ 943db04571cSdan *pazCol = 0; 944db04571cSdan *pabPK = 0; 945ca62ad57Sdan *pnCol = 0; 946e8d5648eSdan if( pzTab ) *pzTab = 0; 947db04571cSdan sqlite3_free(azCol); 948e8d5648eSdan } 949e8d5648eSdan sqlite3_finalize(pStmt); 950e8d5648eSdan return rc; 951e8d5648eSdan } 952e8d5648eSdan 953e8d5648eSdan /* 954296c7658Sdan ** This function is only called from within a pre-update handler for a 955296c7658Sdan ** write to table pTab, part of session pSession. If this is the first 956296c7658Sdan ** write to this table, set the SessionTable.nCol variable to the number 957296c7658Sdan ** of columns in the table. 958296c7658Sdan ** 959296c7658Sdan ** Otherwise, if this is not the first time this table has been written 960296c7658Sdan ** to, check that the number of columns in the table has not changed. If 961296c7658Sdan ** it has not, return zero. 962296c7658Sdan ** 963296c7658Sdan ** If the number of columns in the table has changed since the last write 964296c7658Sdan ** was recorded, set the session error-code to SQLITE_SCHEMA and return 965296c7658Sdan ** non-zero. Users are not allowed to change the number of columns in a table 966296c7658Sdan ** for which changes are being recorded by the session module. If they do so, 967296c7658Sdan ** it is an error. 968296c7658Sdan */ 9694fccf43aSdan static int sessionInitTable(sqlite3_session *pSession, SessionTable *pTab){ 9704fccf43aSdan if( pTab->nCol==0 ){ 971e8d5648eSdan assert( pTab->azCol==0 || pTab->abPK==0 ); 972e8d5648eSdan pSession->rc = sessionTableInfo(pSession->db, pSession->zDb, 973ca62ad57Sdan pTab->zName, &pTab->nCol, 0, &pTab->azCol, &pTab->abPK 974e8d5648eSdan ); 975ca62ad57Sdan } 976ca62ad57Sdan if( pSession->rc==SQLITE_OK 977ca62ad57Sdan && pTab->nCol!=sqlite3_preupdate_count(pSession->db) 978ca62ad57Sdan ){ 9794fccf43aSdan pSession->rc = SQLITE_SCHEMA; 9804fccf43aSdan } 981e8d5648eSdan return pSession->rc; 982e8d5648eSdan } 983e8d5648eSdan 98477fc1d5bSdan /* 98577fc1d5bSdan ** This function is only called from with a pre-update-hook reporting a 98677fc1d5bSdan ** change on table pTab (attached to session pSession). The type of change 98777fc1d5bSdan ** (UPDATE, INSERT, DELETE) is specified by the first argument. 98877fc1d5bSdan ** 98977fc1d5bSdan ** Unless one is already present or an error occurs, an entry is added 99077fc1d5bSdan ** to the changed-rows hash table associated with table pTab. 99177fc1d5bSdan */ 992e8d5648eSdan static void sessionPreupdateOneChange( 99377fc1d5bSdan int op, /* One of SQLITE_UPDATE, INSERT, DELETE */ 99477fc1d5bSdan sqlite3_session *pSession, /* Session object pTab is attached to */ 99577fc1d5bSdan SessionTable *pTab /* Table that change applies to */ 996e8d5648eSdan ){ 997e8d5648eSdan sqlite3 *db = pSession->db; 998e8d5648eSdan int iHash; 99927453faeSdan int bNullPk = 0; 1000e8d5648eSdan int rc = SQLITE_OK; 1001e8d5648eSdan 1002e8d5648eSdan if( pSession->rc ) return; 1003e8d5648eSdan 1004e8d5648eSdan /* Load table details if required */ 1005e8d5648eSdan if( sessionInitTable(pSession, pTab) ) return; 1006e8d5648eSdan 1007e8d5648eSdan /* Grow the hash table if required */ 100864277f4aSdan if( sessionGrowHash(0, pTab) ){ 10095d607a6eSdan pSession->rc = SQLITE_NOMEM; 10105d607a6eSdan return; 10115d607a6eSdan } 1012e8d5648eSdan 101380fe2d93Sdan /* Calculate the hash-key for this change. If the primary key of the row 101480fe2d93Sdan ** includes a NULL value, exit early. Such changes are ignored by the 101580fe2d93Sdan ** session module. */ 101627453faeSdan rc = sessionPreupdateHash(db, pTab, op==SQLITE_INSERT, &iHash, &bNullPk); 101780fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 101880fe2d93Sdan 101980fe2d93Sdan if( bNullPk==0 ){ 102080fe2d93Sdan /* Search the hash table for an existing record for this row. */ 1021b4480e94Sdan SessionChange *pC; 10226734007dSdan for(pC=pTab->apChange[iHash]; pC; pC=pC->pNext){ 102377fc1d5bSdan if( sessionPreupdateEqual(db, pTab, pC, op) ) break; 1024e8d5648eSdan } 102580fe2d93Sdan 1026e8d5648eSdan if( pC==0 ){ 1027e8d5648eSdan /* Create a new change object containing all the old values (if 1028e8d5648eSdan ** this is an SQLITE_UPDATE or SQLITE_DELETE), or just the PK 1029e8d5648eSdan ** values (if this is an INSERT). */ 1030b4480e94Sdan SessionChange *pChange; /* New change object */ 1031e8d5648eSdan int nByte; /* Number of bytes to allocate */ 1032e8d5648eSdan int i; /* Used to iterate through columns */ 1033e8d5648eSdan 1034b4480e94Sdan assert( rc==SQLITE_OK ); 1035e8d5648eSdan pTab->nEntry++; 1036e8d5648eSdan 1037e8d5648eSdan /* Figure out how large an allocation is required */ 1038e8d5648eSdan nByte = sizeof(SessionChange); 103980fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1040e8d5648eSdan sqlite3_value *p = 0; 1041e8d5648eSdan if( op!=SQLITE_INSERT ){ 104280fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_old(pSession->db, i, &p); 104380fe2d93Sdan assert( trc==SQLITE_OK ); 104480fe2d93Sdan }else if( pTab->abPK[i] ){ 104580fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_new(pSession->db, i, &p); 104680fe2d93Sdan assert( trc==SQLITE_OK ); 1047e8d5648eSdan } 104880fe2d93Sdan 104980fe2d93Sdan /* This may fail if SQLite value p contains a utf-16 string that must 105080fe2d93Sdan ** be converted to utf-8 and an OOM error occurs while doing so. */ 1051e8d5648eSdan rc = sessionSerializeValue(0, p, &nByte); 105280fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 1053e8d5648eSdan } 1054e8d5648eSdan 1055e8d5648eSdan /* Allocate the change object */ 1056e8d5648eSdan pChange = (SessionChange *)sqlite3_malloc(nByte); 1057e8d5648eSdan if( !pChange ){ 1058e8d5648eSdan rc = SQLITE_NOMEM; 105980fe2d93Sdan goto error_out; 1060e8d5648eSdan }else{ 1061e8d5648eSdan memset(pChange, 0, sizeof(SessionChange)); 1062e8d5648eSdan pChange->aRecord = (u8 *)&pChange[1]; 1063e8d5648eSdan } 1064e8d5648eSdan 106580fe2d93Sdan /* Populate the change object. None of the preupdate_old(), 106680fe2d93Sdan ** preupdate_new() or SerializeValue() calls below may fail as all 106780fe2d93Sdan ** required values and encodings have already been cached in memory. 106880fe2d93Sdan ** It is not possible for an OOM to occur in this block. */ 1069e8d5648eSdan nByte = 0; 107080fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1071e8d5648eSdan sqlite3_value *p = 0; 1072e8d5648eSdan if( op!=SQLITE_INSERT ){ 107380fe2d93Sdan sqlite3_preupdate_old(pSession->db, i, &p); 107480fe2d93Sdan }else if( pTab->abPK[i] ){ 107580fe2d93Sdan sqlite3_preupdate_new(pSession->db, i, &p); 1076e8d5648eSdan } 107780fe2d93Sdan sessionSerializeValue(&pChange->aRecord[nByte], p, &nByte); 1078e8d5648eSdan } 107980fe2d93Sdan 108080fe2d93Sdan /* Add the change to the hash-table */ 1081b4480e94Sdan if( pSession->bIndirect || sqlite3_preupdate_depth(pSession->db) ){ 1082b4480e94Sdan pChange->bIndirect = 1; 1083b4480e94Sdan } 108412ca0b56Sdan pChange->nRecord = nByte; 1085798693b2Sdan pChange->op = op; 1086e8d5648eSdan pChange->pNext = pTab->apChange[iHash]; 1087e8d5648eSdan pTab->apChange[iHash] = pChange; 108880fe2d93Sdan 108980fe2d93Sdan }else if( pC->bIndirect ){ 1090b4480e94Sdan /* If the existing change is considered "indirect", but this current 1091b4480e94Sdan ** change is "direct", mark the change object as direct. */ 1092b4480e94Sdan if( sqlite3_preupdate_depth(pSession->db)==0 && pSession->bIndirect==0 ){ 1093b4480e94Sdan pC->bIndirect = 0; 1094b4480e94Sdan } 1095e8d5648eSdan } 10964fccf43aSdan } 109712ca0b56Sdan 109812ca0b56Sdan /* If an error has occurred, mark the session object as failed. */ 109980fe2d93Sdan error_out: 110012ca0b56Sdan if( rc!=SQLITE_OK ){ 110112ca0b56Sdan pSession->rc = rc; 110212ca0b56Sdan } 110327453faeSdan } 11044fccf43aSdan 11054fccf43aSdan /* 11064fccf43aSdan ** The 'pre-update' hook registered by this module with SQLite databases. 11074fccf43aSdan */ 11084fccf43aSdan static void xPreUpdate( 11094fccf43aSdan void *pCtx, /* Copy of third arg to preupdate_hook() */ 11104fccf43aSdan sqlite3 *db, /* Database handle */ 11114fccf43aSdan int op, /* SQLITE_UPDATE, DELETE or INSERT */ 11124fccf43aSdan char const *zDb, /* Database name */ 11134fccf43aSdan char const *zName, /* Table name */ 11144fccf43aSdan sqlite3_int64 iKey1, /* Rowid of row about to be deleted/updated */ 11154fccf43aSdan sqlite3_int64 iKey2 /* New rowid value (for a rowid UPDATE) */ 11164fccf43aSdan ){ 11174fccf43aSdan sqlite3_session *pSession; 1118cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); 1119cfdbde21Sdrh int nName = sqlite3Strlen30(zName); 11204fccf43aSdan 11214c220252Sdan assert( sqlite3_mutex_held(db->mutex) ); 11224c220252Sdan 11234fccf43aSdan for(pSession=(sqlite3_session *)pCtx; pSession; pSession=pSession->pNext){ 11244fccf43aSdan SessionTable *pTab; 1125296c7658Sdan 1126e8d5648eSdan /* If this session is attached to a different database ("main", "temp" 1127e8d5648eSdan ** etc.), or if it is not currently enabled, there is nothing to do. Skip 1128e8d5648eSdan ** to the next session object attached to this database. */ 1129296c7658Sdan if( pSession->bEnable==0 ) continue; 11304fccf43aSdan if( pSession->rc ) continue; 11314fccf43aSdan if( sqlite3_strnicmp(zDb, pSession->zDb, nDb+1) ) continue; 1132296c7658Sdan 1133ff4d0f41Sdan for(pTab=pSession->pTable; pTab || pSession->bAutoAttach; pTab=pTab->pNext){ 1134ff4d0f41Sdan if( !pTab ){ 1135ff4d0f41Sdan /* This branch is taken if table zName has not yet been attached to 1136ff4d0f41Sdan ** this session and the auto-attach flag is set. */ 11377531a5a3Sdan 11387531a5a3Sdan /* If there is a table-filter configured, invoke it. If it returns 0, 11397531a5a3Sdan ** this change will not be recorded. Break out of the loop early in 11407531a5a3Sdan ** this case. */ 11417531a5a3Sdan if( pSession->xTableFilter 11427531a5a3Sdan && pSession->xTableFilter(pSession->pFilterCtx, zName)==0 11437531a5a3Sdan ){ 11447531a5a3Sdan break; 11457531a5a3Sdan } 11467531a5a3Sdan 1147ff4d0f41Sdan pSession->rc = sqlite3session_attach(pSession,zName); 1148245b49b2Sdan if( pSession->rc ) break; 1149ff4d0f41Sdan pTab = pSession->pTable; 1150ff4d0f41Sdan assert( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ); 1151ff4d0f41Sdan } 1152ff4d0f41Sdan 11534fccf43aSdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ){ 1154e8d5648eSdan sessionPreupdateOneChange(op, pSession, pTab); 1155e8d5648eSdan if( op==SQLITE_UPDATE ){ 1156e8d5648eSdan sessionPreupdateOneChange(SQLITE_INSERT, pSession, pTab); 11574fccf43aSdan } 11584fccf43aSdan break; 11594fccf43aSdan } 11604fccf43aSdan } 11614fccf43aSdan } 1162296c7658Sdan } 11634fccf43aSdan 11644fccf43aSdan /* 11654fccf43aSdan ** Create a session object. This session object will record changes to 11664fccf43aSdan ** database zDb attached to connection db. 11674fccf43aSdan */ 11684fccf43aSdan int sqlite3session_create( 11694fccf43aSdan sqlite3 *db, /* Database handle */ 11704fccf43aSdan const char *zDb, /* Name of db (e.g. "main") */ 11714fccf43aSdan sqlite3_session **ppSession /* OUT: New session object */ 11724fccf43aSdan ){ 1173296c7658Sdan sqlite3_session *pNew; /* Newly allocated session object */ 1174296c7658Sdan sqlite3_session *pOld; /* Session object already attached to db */ 1175cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); /* Length of zDb in bytes */ 11764fccf43aSdan 1177296c7658Sdan /* Zero the output value in case an error occurs. */ 11784fccf43aSdan *ppSession = 0; 11794fccf43aSdan 11804fccf43aSdan /* Allocate and populate the new session object. */ 11814fccf43aSdan pNew = (sqlite3_session *)sqlite3_malloc(sizeof(sqlite3_session) + nDb + 1); 11824fccf43aSdan if( !pNew ) return SQLITE_NOMEM; 11834fccf43aSdan memset(pNew, 0, sizeof(sqlite3_session)); 11844fccf43aSdan pNew->db = db; 11854fccf43aSdan pNew->zDb = (char *)&pNew[1]; 1186296c7658Sdan pNew->bEnable = 1; 11874fccf43aSdan memcpy(pNew->zDb, zDb, nDb+1); 11884fccf43aSdan 11894fccf43aSdan /* Add the new session object to the linked list of session objects 11904fccf43aSdan ** attached to database handle $db. Do this under the cover of the db 11914fccf43aSdan ** handle mutex. */ 11924fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 11934fccf43aSdan pOld = (sqlite3_session*)sqlite3_preupdate_hook(db, xPreUpdate, (void*)pNew); 11944fccf43aSdan pNew->pNext = pOld; 11954fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 11964fccf43aSdan 11974fccf43aSdan *ppSession = pNew; 11984fccf43aSdan return SQLITE_OK; 11994fccf43aSdan } 12004fccf43aSdan 120177fc1d5bSdan /* 120277fc1d5bSdan ** Free the list of table objects passed as the first argument. The contents 120377fc1d5bSdan ** of the changed-rows hash tables are also deleted. 120477fc1d5bSdan */ 12051ffe7c7fSdrh static void sessionDeleteTable(SessionTable *pList){ 12065d607a6eSdan SessionTable *pNext; 12075d607a6eSdan SessionTable *pTab; 12085d607a6eSdan 12095d607a6eSdan for(pTab=pList; pTab; pTab=pNext){ 12105d607a6eSdan int i; 12115d607a6eSdan pNext = pTab->pNext; 12125d607a6eSdan for(i=0; i<pTab->nChange; i++){ 12135d607a6eSdan SessionChange *p; 12145d607a6eSdan SessionChange *pNext; 12155d607a6eSdan for(p=pTab->apChange[i]; p; p=pNext){ 12165d607a6eSdan pNext = p->pNext; 12175d607a6eSdan sqlite3_free(p); 12185d607a6eSdan } 12195d607a6eSdan } 12205d607a6eSdan sqlite3_free((char*)pTab->azCol); /* cast works around VC++ bug */ 12215d607a6eSdan sqlite3_free(pTab->apChange); 12225d607a6eSdan sqlite3_free(pTab); 12235d607a6eSdan } 12245d607a6eSdan } 12255d607a6eSdan 12264fccf43aSdan /* 12274fccf43aSdan ** Delete a session object previously allocated using sqlite3session_create(). 12284fccf43aSdan */ 12294fccf43aSdan void sqlite3session_delete(sqlite3_session *pSession){ 12304fccf43aSdan sqlite3 *db = pSession->db; 12314fccf43aSdan sqlite3_session *pHead; 12324fccf43aSdan sqlite3_session **pp; 12334fccf43aSdan 1234296c7658Sdan /* Unlink the session from the linked list of sessions attached to the 1235296c7658Sdan ** database handle. Hold the db mutex while doing so. */ 12364fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 12374fccf43aSdan pHead = (sqlite3_session*)sqlite3_preupdate_hook(db, 0, 0); 12384fccf43aSdan for(pp=&pHead; (*pp)!=pSession; pp=&((*pp)->pNext)); 12394fccf43aSdan *pp = (*pp)->pNext; 12404fccf43aSdan if( pHead ) sqlite3_preupdate_hook(db, xPreUpdate, (void *)pHead); 12414fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 12424fccf43aSdan 1243296c7658Sdan /* Delete all attached table objects. And the contents of their 1244296c7658Sdan ** associated hash-tables. */ 12455d607a6eSdan sessionDeleteTable(pSession->pTable); 12464fccf43aSdan 1247296c7658Sdan /* Free the session object itself. */ 12484fccf43aSdan sqlite3_free(pSession); 12494fccf43aSdan } 12504fccf43aSdan 12514fccf43aSdan /* 12527531a5a3Sdan ** Set a table filter on a Session Object. 12537531a5a3Sdan */ 12547531a5a3Sdan void sqlite3session_table_filter( 12557531a5a3Sdan sqlite3_session *pSession, 12567531a5a3Sdan int(*xFilter)(void*, const char*), 12577531a5a3Sdan void *pCtx /* First argument passed to xFilter */ 12587531a5a3Sdan ){ 12597531a5a3Sdan pSession->bAutoAttach = 1; 12607531a5a3Sdan pSession->pFilterCtx = pCtx; 12617531a5a3Sdan pSession->xTableFilter = xFilter; 12627531a5a3Sdan } 12637531a5a3Sdan 12647531a5a3Sdan /* 12654fccf43aSdan ** Attach a table to a session. All subsequent changes made to the table 12664fccf43aSdan ** while the session object is enabled will be recorded. 12674fccf43aSdan ** 12684fccf43aSdan ** Only tables that have a PRIMARY KEY defined may be attached. It does 12694fccf43aSdan ** not matter if the PRIMARY KEY is an "INTEGER PRIMARY KEY" (rowid alias) 12704fccf43aSdan ** or not. 12714fccf43aSdan */ 12724fccf43aSdan int sqlite3session_attach( 12734fccf43aSdan sqlite3_session *pSession, /* Session object */ 12744fccf43aSdan const char *zName /* Table name */ 12754fccf43aSdan ){ 1276ff4d0f41Sdan int rc = SQLITE_OK; 1277ff4d0f41Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 1278ff4d0f41Sdan 1279ff4d0f41Sdan if( !zName ){ 1280ff4d0f41Sdan pSession->bAutoAttach = 1; 1281ff4d0f41Sdan }else{ 1282296c7658Sdan SessionTable *pTab; /* New table object (if required) */ 1283296c7658Sdan int nName; /* Number of bytes in string zName */ 12844fccf43aSdan 12854fccf43aSdan /* First search for an existing entry. If one is found, this call is 12864fccf43aSdan ** a no-op. Return early. */ 1287cfdbde21Sdrh nName = sqlite3Strlen30(zName); 12884fccf43aSdan for(pTab=pSession->pTable; pTab; pTab=pTab->pNext){ 12894c220252Sdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ) break; 12904fccf43aSdan } 12914fccf43aSdan 12924c220252Sdan if( !pTab ){ 12934fccf43aSdan /* Allocate new SessionTable object. */ 12944fccf43aSdan pTab = (SessionTable *)sqlite3_malloc(sizeof(SessionTable) + nName + 1); 12954c220252Sdan if( !pTab ){ 12964c220252Sdan rc = SQLITE_NOMEM; 12974c220252Sdan }else{ 12984fccf43aSdan /* Populate the new SessionTable object and link it into the list. */ 12994fccf43aSdan memset(pTab, 0, sizeof(SessionTable)); 13004fccf43aSdan pTab->zName = (char *)&pTab[1]; 13014fccf43aSdan memcpy(pTab->zName, zName, nName+1); 13024fccf43aSdan pTab->pNext = pSession->pTable; 13034fccf43aSdan pSession->pTable = pTab; 13044c220252Sdan } 13054c220252Sdan } 1306ff4d0f41Sdan } 13074fccf43aSdan 13084c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 13094c220252Sdan return rc; 13104fccf43aSdan } 13114fccf43aSdan 1312296c7658Sdan /* 1313296c7658Sdan ** Ensure that there is room in the buffer to append nByte bytes of data. 1314296c7658Sdan ** If not, use sqlite3_realloc() to grow the buffer so that there is. 1315296c7658Sdan ** 1316296c7658Sdan ** If successful, return zero. Otherwise, if an OOM condition is encountered, 1317296c7658Sdan ** set *pRc to SQLITE_NOMEM and return non-zero. 1318296c7658Sdan */ 13194fccf43aSdan static int sessionBufferGrow(SessionBuffer *p, int nByte, int *pRc){ 132080fe2d93Sdan if( *pRc==SQLITE_OK && p->nAlloc-p->nBuf<nByte ){ 13214fccf43aSdan u8 *aNew; 13224fccf43aSdan int nNew = p->nAlloc ? p->nAlloc : 128; 13234fccf43aSdan do { 13244fccf43aSdan nNew = nNew*2; 1325ef7a6304Sdan }while( nNew<(p->nBuf+nByte) ); 13264fccf43aSdan 13274fccf43aSdan aNew = (u8 *)sqlite3_realloc(p->aBuf, nNew); 13284fccf43aSdan if( 0==aNew ){ 13294fccf43aSdan *pRc = SQLITE_NOMEM; 133080fe2d93Sdan }else{ 13314fccf43aSdan p->aBuf = aNew; 13324fccf43aSdan p->nAlloc = nNew; 13334fccf43aSdan } 133480fe2d93Sdan } 133580fe2d93Sdan return (*pRc!=SQLITE_OK); 13364fccf43aSdan } 13374fccf43aSdan 1338296c7658Sdan /* 1339fa122adaSdan ** Append the value passed as the second argument to the buffer passed 1340fa122adaSdan ** as the first. 1341fa122adaSdan ** 1342fa122adaSdan ** This function is a no-op if *pRc is non-zero when it is called. 1343fa122adaSdan ** Otherwise, if an error occurs, *pRc is set to an SQLite error code 1344fa122adaSdan ** before returning. 1345fa122adaSdan */ 1346fa122adaSdan static void sessionAppendValue(SessionBuffer *p, sqlite3_value *pVal, int *pRc){ 1347fa122adaSdan int rc = *pRc; 1348fa122adaSdan if( rc==SQLITE_OK ){ 1349fa122adaSdan int nByte = 0; 1350fa122adaSdan sessionSerializeValue(0, pVal, &nByte); 1351fa122adaSdan sessionBufferGrow(p, nByte, &rc); 1352fa122adaSdan if( rc==SQLITE_OK ){ 1353fa122adaSdan rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); 1354fa122adaSdan p->nBuf += nByte; 1355fa122adaSdan }else{ 1356fa122adaSdan *pRc = rc; 1357fa122adaSdan } 1358fa122adaSdan } 1359fa122adaSdan } 1360fa122adaSdan 1361fa122adaSdan /* 1362296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1363296c7658Sdan ** called. Otherwise, append a single byte to the buffer. 1364296c7658Sdan ** 1365296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1366296c7658Sdan ** returning. 1367296c7658Sdan */ 13684fccf43aSdan static void sessionAppendByte(SessionBuffer *p, u8 v, int *pRc){ 136980fe2d93Sdan if( 0==sessionBufferGrow(p, 1, pRc) ){ 13704fccf43aSdan p->aBuf[p->nBuf++] = v; 13714fccf43aSdan } 13724fccf43aSdan } 13734fccf43aSdan 1374296c7658Sdan /* 1375296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1376296c7658Sdan ** called. Otherwise, append a single varint to the buffer. 1377296c7658Sdan ** 1378296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1379296c7658Sdan ** returning. 1380296c7658Sdan */ 1381cfdbde21Sdrh static void sessionAppendVarint(SessionBuffer *p, int v, int *pRc){ 138280fe2d93Sdan if( 0==sessionBufferGrow(p, 9, pRc) ){ 13834fccf43aSdan p->nBuf += sessionVarintPut(&p->aBuf[p->nBuf], v); 13844fccf43aSdan } 13854fccf43aSdan } 13864fccf43aSdan 1387296c7658Sdan /* 1388296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1389296c7658Sdan ** called. Otherwise, append a blob of data to the buffer. 1390296c7658Sdan ** 1391296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1392296c7658Sdan ** returning. 1393296c7658Sdan */ 13944fccf43aSdan static void sessionAppendBlob( 13954fccf43aSdan SessionBuffer *p, 13964fccf43aSdan const u8 *aBlob, 13974fccf43aSdan int nBlob, 13984fccf43aSdan int *pRc 13994fccf43aSdan ){ 140080fe2d93Sdan if( 0==sessionBufferGrow(p, nBlob, pRc) ){ 14014fccf43aSdan memcpy(&p->aBuf[p->nBuf], aBlob, nBlob); 14024fccf43aSdan p->nBuf += nBlob; 14034fccf43aSdan } 14044fccf43aSdan } 14054fccf43aSdan 1406296c7658Sdan /* 1407296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1408296c7658Sdan ** called. Otherwise, append a string to the buffer. All bytes in the string 1409296c7658Sdan ** up to (but not including) the nul-terminator are written to the buffer. 1410296c7658Sdan ** 1411296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1412296c7658Sdan ** returning. 1413296c7658Sdan */ 1414d5f0767cSdan static void sessionAppendStr( 1415d5f0767cSdan SessionBuffer *p, 1416d5f0767cSdan const char *zStr, 1417d5f0767cSdan int *pRc 1418d5f0767cSdan ){ 1419cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr); 142080fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1421d5f0767cSdan memcpy(&p->aBuf[p->nBuf], zStr, nStr); 1422d5f0767cSdan p->nBuf += nStr; 1423d5f0767cSdan } 1424d5f0767cSdan } 1425d5f0767cSdan 1426296c7658Sdan /* 1427296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1428296c7658Sdan ** called. Otherwise, append the string representation of integer iVal 1429296c7658Sdan ** to the buffer. No nul-terminator is written. 1430296c7658Sdan ** 1431296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1432296c7658Sdan ** returning. 1433296c7658Sdan */ 1434d5f0767cSdan static void sessionAppendInteger( 1435296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1436296c7658Sdan int iVal, /* Value to write the string rep. of */ 1437296c7658Sdan int *pRc /* IN/OUT: Error code */ 1438d5f0767cSdan ){ 1439d5f0767cSdan char aBuf[24]; 1440d5f0767cSdan sqlite3_snprintf(sizeof(aBuf)-1, aBuf, "%d", iVal); 1441d5f0767cSdan sessionAppendStr(p, aBuf, pRc); 1442d5f0767cSdan } 1443d5f0767cSdan 1444296c7658Sdan /* 1445296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1446296c7658Sdan ** called. Otherwise, append the string zStr enclosed in quotes (") and 1447296c7658Sdan ** with any embedded quote characters escaped to the buffer. No 1448296c7658Sdan ** nul-terminator byte is written. 1449296c7658Sdan ** 1450296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1451296c7658Sdan ** returning. 1452296c7658Sdan */ 1453d5f0767cSdan static void sessionAppendIdent( 1454296c7658Sdan SessionBuffer *p, /* Buffer to a append to */ 1455296c7658Sdan const char *zStr, /* String to quote, escape and append */ 1456296c7658Sdan int *pRc /* IN/OUT: Error code */ 1457d5f0767cSdan ){ 1458cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr)*2 + 2 + 1; 145980fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1460d5f0767cSdan char *zOut = (char *)&p->aBuf[p->nBuf]; 1461d5f0767cSdan const char *zIn = zStr; 1462d5f0767cSdan *zOut++ = '"'; 1463d5f0767cSdan while( *zIn ){ 1464d5f0767cSdan if( *zIn=='"' ) *zOut++ = '"'; 1465d5f0767cSdan *zOut++ = *(zIn++); 1466d5f0767cSdan } 1467d5f0767cSdan *zOut++ = '"'; 1468cfdbde21Sdrh p->nBuf = (int)((u8 *)zOut - p->aBuf); 1469d5f0767cSdan } 1470d5f0767cSdan } 1471d5f0767cSdan 1472296c7658Sdan /* 1473296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1474296c7658Sdan ** called. Otherwse, it appends the serialized version of the value stored 1475296c7658Sdan ** in column iCol of the row that SQL statement pStmt currently points 1476296c7658Sdan ** to to the buffer. 1477296c7658Sdan */ 14784fccf43aSdan static void sessionAppendCol( 1479296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1480296c7658Sdan sqlite3_stmt *pStmt, /* Handle pointing to row containing value */ 1481296c7658Sdan int iCol, /* Column to read value from */ 1482296c7658Sdan int *pRc /* IN/OUT: Error code */ 14834fccf43aSdan ){ 14844fccf43aSdan if( *pRc==SQLITE_OK ){ 14854fccf43aSdan int eType = sqlite3_column_type(pStmt, iCol); 14864fccf43aSdan sessionAppendByte(p, (u8)eType, pRc); 14874fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 14884fccf43aSdan sqlite3_int64 i; 14894fccf43aSdan u8 aBuf[8]; 14904fccf43aSdan if( eType==SQLITE_INTEGER ){ 14914fccf43aSdan i = sqlite3_column_int64(pStmt, iCol); 14924fccf43aSdan }else{ 14934fccf43aSdan double r = sqlite3_column_double(pStmt, iCol); 14944fccf43aSdan memcpy(&i, &r, 8); 14954fccf43aSdan } 1496296c7658Sdan sessionPutI64(aBuf, i); 14974fccf43aSdan sessionAppendBlob(p, aBuf, 8, pRc); 14984fccf43aSdan } 14994fccf43aSdan if( eType==SQLITE_BLOB || eType==SQLITE_TEXT ){ 15006734007dSdan u8 *z; 15016734007dSdan if( eType==SQLITE_BLOB ){ 15026734007dSdan z = (u8 *)sqlite3_column_blob(pStmt, iCol); 15036734007dSdan }else{ 15046734007dSdan z = (u8 *)sqlite3_column_text(pStmt, iCol); 15056734007dSdan } 15066734007dSdan if( z ){ 15074fccf43aSdan int nByte = sqlite3_column_bytes(pStmt, iCol); 15084fccf43aSdan sessionAppendVarint(p, nByte, pRc); 15096734007dSdan sessionAppendBlob(p, z, nByte, pRc); 15106734007dSdan }else{ 15116734007dSdan *pRc = SQLITE_NOMEM; 15126734007dSdan } 15134fccf43aSdan } 15144fccf43aSdan } 15154fccf43aSdan } 15164fccf43aSdan 1517296c7658Sdan /* 1518296c7658Sdan ** 151980fe2d93Sdan ** This function appends an update change to the buffer (see the comments 152080fe2d93Sdan ** under "CHANGESET FORMAT" at the top of the file). An update change 152180fe2d93Sdan ** consists of: 1522296c7658Sdan ** 1523296c7658Sdan ** 1 byte: SQLITE_UPDATE (0x17) 1524296c7658Sdan ** n bytes: old.* record (see RECORD FORMAT) 1525296c7658Sdan ** m bytes: new.* record (see RECORD FORMAT) 1526296c7658Sdan ** 1527296c7658Sdan ** The SessionChange object passed as the third argument contains the 1528296c7658Sdan ** values that were stored in the row when the session began (the old.* 1529296c7658Sdan ** values). The statement handle passed as the second argument points 1530296c7658Sdan ** at the current version of the row (the new.* values). 1531296c7658Sdan ** 1532296c7658Sdan ** If all of the old.* values are equal to their corresponding new.* value 1533296c7658Sdan ** (i.e. nothing has changed), then no data at all is appended to the buffer. 1534296c7658Sdan ** 1535296c7658Sdan ** Otherwise, the old.* record contains all primary key values and the 1536296c7658Sdan ** original values of any fields that have been modified. The new.* record 1537296c7658Sdan ** contains the new values of only those fields that have been modified. 1538296c7658Sdan */ 153980fe2d93Sdan static int sessionAppendUpdate( 1540296c7658Sdan SessionBuffer *pBuf, /* Buffer to append to */ 154173b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 1542296c7658Sdan sqlite3_stmt *pStmt, /* Statement handle pointing at new row */ 1543296c7658Sdan SessionChange *p, /* Object containing old values */ 154480fe2d93Sdan u8 *abPK /* Boolean array - true for PK columns */ 15454fccf43aSdan ){ 154680fe2d93Sdan int rc = SQLITE_OK; 1547296c7658Sdan SessionBuffer buf2 = {0,0,0}; /* Buffer to accumulate new.* record in */ 1548296c7658Sdan int bNoop = 1; /* Set to zero if any values are modified */ 15491f34f8ccSdan int nRewind = pBuf->nBuf; /* Set to zero if any values are modified */ 1550296c7658Sdan int i; /* Used to iterate through columns */ 1551296c7658Sdan u8 *pCsr = p->aRecord; /* Used to iterate through old.* values */ 1552296c7658Sdan 155380fe2d93Sdan sessionAppendByte(pBuf, SQLITE_UPDATE, &rc); 155480fe2d93Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 15554fccf43aSdan for(i=0; i<sqlite3_column_count(pStmt); i++){ 155637f133ecSdan int bChanged = 0; 15574fccf43aSdan int nAdvance; 15584fccf43aSdan int eType = *pCsr; 15594fccf43aSdan switch( eType ){ 15604fccf43aSdan case SQLITE_NULL: 15614fccf43aSdan nAdvance = 1; 15624fccf43aSdan if( sqlite3_column_type(pStmt, i)!=SQLITE_NULL ){ 156337f133ecSdan bChanged = 1; 15644fccf43aSdan } 15654fccf43aSdan break; 15664fccf43aSdan 15674fccf43aSdan case SQLITE_FLOAT: 15684fccf43aSdan case SQLITE_INTEGER: { 15694fccf43aSdan nAdvance = 9; 15704fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) ){ 15714fccf43aSdan sqlite3_int64 iVal = sessionGetI64(&pCsr[1]); 15724fccf43aSdan if( eType==SQLITE_INTEGER ){ 15734fccf43aSdan if( iVal==sqlite3_column_int64(pStmt, i) ) break; 15744fccf43aSdan }else{ 15754fccf43aSdan double dVal; 15764fccf43aSdan memcpy(&dVal, &iVal, 8); 15774fccf43aSdan if( dVal==sqlite3_column_double(pStmt, i) ) break; 15784fccf43aSdan } 15794fccf43aSdan } 158037f133ecSdan bChanged = 1; 15814fccf43aSdan break; 15824fccf43aSdan } 15834fccf43aSdan 1584e5754eecSdan default: { 15854fccf43aSdan int nByte; 15864fccf43aSdan int nHdr = 1 + sessionVarintGet(&pCsr[1], &nByte); 1587e5754eecSdan assert( eType==SQLITE_TEXT || eType==SQLITE_BLOB ); 15884fccf43aSdan nAdvance = nHdr + nByte; 15894fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) 15904fccf43aSdan && nByte==sqlite3_column_bytes(pStmt, i) 15914fccf43aSdan && 0==memcmp(&pCsr[nHdr], sqlite3_column_blob(pStmt, i), nByte) 15924fccf43aSdan ){ 15934fccf43aSdan break; 15944fccf43aSdan } 159537f133ecSdan bChanged = 1; 15964fccf43aSdan } 15974fccf43aSdan } 15984fccf43aSdan 159973b3c055Sdan /* If at least one field has been modified, this is not a no-op. */ 160073b3c055Sdan if( bChanged ) bNoop = 0; 160173b3c055Sdan 160273b3c055Sdan /* Add a field to the old.* record. This is omitted if this modules is 160373b3c055Sdan ** currently generating a patchset. */ 160473b3c055Sdan if( bPatchset==0 ){ 160537f133ecSdan if( bChanged || abPK[i] ){ 160680fe2d93Sdan sessionAppendBlob(pBuf, pCsr, nAdvance, &rc); 16074fccf43aSdan }else{ 160880fe2d93Sdan sessionAppendByte(pBuf, 0, &rc); 160937f133ecSdan } 161073b3c055Sdan } 161137f133ecSdan 161273b3c055Sdan /* Add a field to the new.* record. Or the only record if currently 161373b3c055Sdan ** generating a patchset. */ 161473b3c055Sdan if( bChanged || (bPatchset && abPK[i]) ){ 161580fe2d93Sdan sessionAppendCol(&buf2, pStmt, i, &rc); 161637f133ecSdan }else{ 161780fe2d93Sdan sessionAppendByte(&buf2, 0, &rc); 16184fccf43aSdan } 161937f133ecSdan 16204fccf43aSdan pCsr += nAdvance; 16214fccf43aSdan } 16224fccf43aSdan 16234fccf43aSdan if( bNoop ){ 16241f34f8ccSdan pBuf->nBuf = nRewind; 16254fccf43aSdan }else{ 162680fe2d93Sdan sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); 16274fccf43aSdan } 16281f34f8ccSdan sqlite3_free(buf2.aBuf); 162980fe2d93Sdan 163080fe2d93Sdan return rc; 1631d5f0767cSdan } 16324fccf43aSdan 1633a71d2371Sdan /* 1634a71d2371Sdan ** Append a DELETE change to the buffer passed as the first argument. Use 1635a71d2371Sdan ** the changeset format if argument bPatchset is zero, or the patchset 1636a71d2371Sdan ** format otherwise. 1637a71d2371Sdan */ 163873b3c055Sdan static int sessionAppendDelete( 163973b3c055Sdan SessionBuffer *pBuf, /* Buffer to append to */ 164073b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 164173b3c055Sdan SessionChange *p, /* Object containing old values */ 1642a71d2371Sdan int nCol, /* Number of columns in table */ 164373b3c055Sdan u8 *abPK /* Boolean array - true for PK columns */ 164473b3c055Sdan ){ 164573b3c055Sdan int rc = SQLITE_OK; 164673b3c055Sdan 164773b3c055Sdan sessionAppendByte(pBuf, SQLITE_DELETE, &rc); 164873b3c055Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 164973b3c055Sdan 165073b3c055Sdan if( bPatchset==0 ){ 165173b3c055Sdan sessionAppendBlob(pBuf, p->aRecord, p->nRecord, &rc); 165273b3c055Sdan }else{ 165373b3c055Sdan int i; 165473b3c055Sdan u8 *a = p->aRecord; 165573b3c055Sdan for(i=0; i<nCol; i++){ 165673b3c055Sdan u8 *pStart = a; 165773b3c055Sdan int eType = *a++; 165873b3c055Sdan 165973b3c055Sdan switch( eType ){ 166073b3c055Sdan case 0: 166173b3c055Sdan case SQLITE_NULL: 166273b3c055Sdan assert( abPK[i]==0 ); 166373b3c055Sdan break; 166473b3c055Sdan 166573b3c055Sdan case SQLITE_FLOAT: 166673b3c055Sdan case SQLITE_INTEGER: 166773b3c055Sdan a += 8; 166873b3c055Sdan break; 166973b3c055Sdan 167073b3c055Sdan default: { 167173b3c055Sdan int n; 167273b3c055Sdan a += sessionVarintGet(a, &n); 167373b3c055Sdan a += n; 167473b3c055Sdan break; 167573b3c055Sdan } 167673b3c055Sdan } 167773b3c055Sdan if( abPK[i] ){ 1678f5ab08c7Sdrh sessionAppendBlob(pBuf, pStart, (int)(a-pStart), &rc); 167973b3c055Sdan } 168073b3c055Sdan } 168173b3c055Sdan assert( (a - p->aRecord)==p->nRecord ); 168273b3c055Sdan } 168373b3c055Sdan 168473b3c055Sdan return rc; 168573b3c055Sdan } 168673b3c055Sdan 168777fc1d5bSdan /* 168877fc1d5bSdan ** Formulate and prepare a SELECT statement to retrieve a row from table 168977fc1d5bSdan ** zTab in database zDb based on its primary key. i.e. 169077fc1d5bSdan ** 169177fc1d5bSdan ** SELECT * FROM zDb.zTab WHERE pk1 = ? AND pk2 = ? AND ... 169277fc1d5bSdan */ 1693e8d5648eSdan static int sessionSelectStmt( 1694e8d5648eSdan sqlite3 *db, /* Database handle */ 1695d7fb7d24Sdan const char *zDb, /* Database name */ 1696e8d5648eSdan const char *zTab, /* Table name */ 169777fc1d5bSdan int nCol, /* Number of columns in table */ 169877fc1d5bSdan const char **azCol, /* Names of table columns */ 169977fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 170077fc1d5bSdan sqlite3_stmt **ppStmt /* OUT: Prepared SELECT statement */ 1701d5f0767cSdan ){ 1702e8d5648eSdan int rc = SQLITE_OK; 1703d5f0767cSdan int i; 1704e8d5648eSdan const char *zSep = ""; 1705e8d5648eSdan SessionBuffer buf = {0, 0, 0}; 1706d5f0767cSdan 1707e8d5648eSdan sessionAppendStr(&buf, "SELECT * FROM ", &rc); 1708d7fb7d24Sdan sessionAppendIdent(&buf, zDb, &rc); 1709d7fb7d24Sdan sessionAppendStr(&buf, ".", &rc); 1710e8d5648eSdan sessionAppendIdent(&buf, zTab, &rc); 1711e8d5648eSdan sessionAppendStr(&buf, " WHERE ", &rc); 1712e8d5648eSdan for(i=0; i<nCol; i++){ 1713e8d5648eSdan if( abPK[i] ){ 1714e8d5648eSdan sessionAppendStr(&buf, zSep, &rc); 1715e8d5648eSdan sessionAppendIdent(&buf, azCol[i], &rc); 1716e8d5648eSdan sessionAppendStr(&buf, " = ?", &rc); 1717e8d5648eSdan sessionAppendInteger(&buf, i+1, &rc); 1718e8d5648eSdan zSep = " AND "; 1719d5f0767cSdan } 1720d5f0767cSdan } 1721d5f0767cSdan if( rc==SQLITE_OK ){ 1722e8d5648eSdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, ppStmt, 0); 1723d5f0767cSdan } 1724e8d5648eSdan sqlite3_free(buf.aBuf); 1725e8d5648eSdan return rc; 1726d5f0767cSdan } 1727d5f0767cSdan 172877fc1d5bSdan /* 172977fc1d5bSdan ** Bind the PRIMARY KEY values from the change passed in argument pChange 173077fc1d5bSdan ** to the SELECT statement passed as the first argument. The SELECT statement 173177fc1d5bSdan ** is as prepared by function sessionSelectStmt(). 173277fc1d5bSdan ** 173377fc1d5bSdan ** Return SQLITE_OK if all PK values are successfully bound, or an SQLite 173477fc1d5bSdan ** error code (e.g. SQLITE_NOMEM) otherwise. 173577fc1d5bSdan */ 1736e8d5648eSdan static int sessionSelectBind( 173777fc1d5bSdan sqlite3_stmt *pSelect, /* SELECT from sessionSelectStmt() */ 173877fc1d5bSdan int nCol, /* Number of columns in table */ 173977fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 174077fc1d5bSdan SessionChange *pChange /* Change structure */ 1741e8d5648eSdan ){ 1742e8d5648eSdan int i; 1743e8d5648eSdan int rc = SQLITE_OK; 1744e5754eecSdan u8 *a = pChange->aRecord; 1745d5f0767cSdan 1746e8d5648eSdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 1747e8d5648eSdan int eType = *a++; 1748e8d5648eSdan 1749e8d5648eSdan switch( eType ){ 175080fe2d93Sdan case 0: 1751e8d5648eSdan case SQLITE_NULL: 1752e5754eecSdan assert( abPK[i]==0 ); 1753e8d5648eSdan break; 1754e8d5648eSdan 1755e8d5648eSdan case SQLITE_INTEGER: { 1756e8d5648eSdan if( abPK[i] ){ 1757e8d5648eSdan i64 iVal = sessionGetI64(a); 1758e8d5648eSdan rc = sqlite3_bind_int64(pSelect, i+1, iVal); 1759e8d5648eSdan } 1760e8d5648eSdan a += 8; 1761e8d5648eSdan break; 1762d5f0767cSdan } 1763296c7658Sdan 1764e8d5648eSdan case SQLITE_FLOAT: { 1765e8d5648eSdan if( abPK[i] ){ 1766e8d5648eSdan double rVal; 1767e8d5648eSdan i64 iVal = sessionGetI64(a); 1768e8d5648eSdan memcpy(&rVal, &iVal, 8); 17694e895da1Sdan rc = sqlite3_bind_double(pSelect, i+1, rVal); 1770d5f0767cSdan } 1771e8d5648eSdan a += 8; 1772e8d5648eSdan break; 1773e8d5648eSdan } 1774e8d5648eSdan 1775e8d5648eSdan case SQLITE_TEXT: { 1776e8d5648eSdan int n; 1777e8d5648eSdan a += sessionVarintGet(a, &n); 1778e8d5648eSdan if( abPK[i] ){ 1779e8d5648eSdan rc = sqlite3_bind_text(pSelect, i+1, (char *)a, n, SQLITE_TRANSIENT); 1780e8d5648eSdan } 1781e8d5648eSdan a += n; 1782e8d5648eSdan break; 1783e8d5648eSdan } 1784e8d5648eSdan 1785e5754eecSdan default: { 1786e8d5648eSdan int n; 1787e5754eecSdan assert( eType==SQLITE_BLOB ); 1788e8d5648eSdan a += sessionVarintGet(a, &n); 1789e8d5648eSdan if( abPK[i] ){ 1790e8d5648eSdan rc = sqlite3_bind_blob(pSelect, i+1, a, n, SQLITE_TRANSIENT); 1791e8d5648eSdan } 1792e8d5648eSdan a += n; 1793e8d5648eSdan break; 1794e8d5648eSdan } 1795e8d5648eSdan } 1796e8d5648eSdan } 1797e8d5648eSdan 1798d5f0767cSdan return rc; 17994fccf43aSdan } 18004fccf43aSdan 180177fc1d5bSdan /* 180277fc1d5bSdan ** This function is a no-op if *pRc is set to other than SQLITE_OK when it 180377fc1d5bSdan ** is called. Otherwise, append a serialized table header (part of the binary 180477fc1d5bSdan ** changeset format) to buffer *pBuf. If an error occurs, set *pRc to an 180577fc1d5bSdan ** SQLite error code before returning. 180677fc1d5bSdan */ 18075d607a6eSdan static void sessionAppendTableHdr( 1808a71d2371Sdan SessionBuffer *pBuf, /* Append header to this buffer */ 1809a71d2371Sdan int bPatchset, /* Use the patchset format if true */ 1810a71d2371Sdan SessionTable *pTab, /* Table object to append header for */ 1811a71d2371Sdan int *pRc /* IN/OUT: Error code */ 18125d607a6eSdan ){ 18135d607a6eSdan /* Write a table header */ 181473b3c055Sdan sessionAppendByte(pBuf, (bPatchset ? 'P' : 'T'), pRc); 18155d607a6eSdan sessionAppendVarint(pBuf, pTab->nCol, pRc); 18165d607a6eSdan sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc); 18174f528042Sdan sessionAppendBlob(pBuf, (u8 *)pTab->zName, (int)strlen(pTab->zName)+1, pRc); 18185d607a6eSdan } 18195d607a6eSdan 1820a71d2371Sdan /* 1821a71d2371Sdan ** Generate either a changeset (if argument bPatchset is zero) or a patchset 1822a71d2371Sdan ** (if it is non-zero) based on the current contents of the session object 1823a71d2371Sdan ** passed as the first argument. 1824a71d2371Sdan ** 1825a71d2371Sdan ** If no error occurs, SQLITE_OK is returned and the new changeset/patchset 1826a71d2371Sdan ** stored in output variables *pnChangeset and *ppChangeset. Or, if an error 1827a71d2371Sdan ** occurs, an SQLite error code is returned and both output variables set 1828a71d2371Sdan ** to 0. 1829a71d2371Sdan */ 183073b3c055Sdan int sessionGenerateChangeset( 18314fccf43aSdan sqlite3_session *pSession, /* Session object */ 183273b3c055Sdan int bPatchset, /* True for patchset, false for changeset */ 1833ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1834ef7a6304Sdan void *pOut, /* First argument for xOutput */ 18354fccf43aSdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 18364fccf43aSdan void **ppChangeset /* OUT: Buffer containing changeset */ 18374fccf43aSdan ){ 1838296c7658Sdan sqlite3 *db = pSession->db; /* Source database handle */ 1839296c7658Sdan SessionTable *pTab; /* Used to iterate through attached tables */ 1840296c7658Sdan SessionBuffer buf = {0,0,0}; /* Buffer in which to accumlate changeset */ 1841296c7658Sdan int rc; /* Return code */ 18424fccf43aSdan 1843ef7a6304Sdan assert( xOutput==0 || (pnChangeset==0 && ppChangeset==0 ) ); 1844ef7a6304Sdan 1845296c7658Sdan /* Zero the output variables in case an error occurs. If this session 1846296c7658Sdan ** object is already in the error state (sqlite3_session.rc != SQLITE_OK), 1847296c7658Sdan ** this call will be a no-op. */ 1848ef7a6304Sdan if( xOutput==0 ){ 18494fccf43aSdan *pnChangeset = 0; 18504fccf43aSdan *ppChangeset = 0; 1851ef7a6304Sdan } 1852e5754eecSdan 1853e5754eecSdan if( pSession->rc ) return pSession->rc; 1854e5754eecSdan rc = sqlite3_exec(pSession->db, "SAVEPOINT changeset", 0, 0, 0); 1855e5754eecSdan if( rc!=SQLITE_OK ) return rc; 1856e5754eecSdan 1857e5754eecSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 18584fccf43aSdan 18594fccf43aSdan for(pTab=pSession->pTable; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ 18604fccf43aSdan if( pTab->nEntry ){ 1861d7fb7d24Sdan const char *zName = pTab->zName; 1862a9605b91Sdan int nCol; /* Number of columns in table */ 1863a9605b91Sdan u8 *abPK; /* Primary key array */ 1864a9605b91Sdan const char **azCol = 0; /* Table columns */ 18651f34f8ccSdan int i; /* Used to iterate through hash buckets */ 18661f34f8ccSdan sqlite3_stmt *pSel = 0; /* SELECT statement to query table pTab */ 18671f34f8ccSdan int nRewind = buf.nBuf; /* Initial size of write buffer */ 18681f34f8ccSdan int nNoop; /* Size of buffer after writing tbl header */ 18694fccf43aSdan 1870a9605b91Sdan /* Check the table schema is still Ok. */ 1871a9605b91Sdan rc = sessionTableInfo(db, pSession->zDb, zName, &nCol, 0, &azCol, &abPK); 1872a9605b91Sdan if( !rc && (pTab->nCol!=nCol || memcmp(abPK, pTab->abPK, nCol)) ){ 1873a9605b91Sdan rc = SQLITE_SCHEMA; 1874a9605b91Sdan } 1875a9605b91Sdan 18764fccf43aSdan /* Write a table header */ 187773b3c055Sdan sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); 18784fccf43aSdan 18794fccf43aSdan /* Build and compile a statement to execute: */ 18804fccf43aSdan if( rc==SQLITE_OK ){ 1881d7fb7d24Sdan rc = sessionSelectStmt( 1882a9605b91Sdan db, pSession->zDb, zName, nCol, azCol, abPK, &pSel); 18834fccf43aSdan } 18844fccf43aSdan 18851f34f8ccSdan nNoop = buf.nBuf; 188612ca0b56Sdan for(i=0; i<pTab->nChange && rc==SQLITE_OK; i++){ 1887e8d5648eSdan SessionChange *p; /* Used to iterate through changes */ 1888e8d5648eSdan 18894fccf43aSdan for(p=pTab->apChange[i]; rc==SQLITE_OK && p; p=p->pNext){ 1890e5754eecSdan rc = sessionSelectBind(pSel, nCol, abPK, p); 189180fe2d93Sdan if( rc!=SQLITE_OK ) continue; 18921f34f8ccSdan if( sqlite3_step(pSel)==SQLITE_ROW ){ 1893798693b2Sdan if( p->op==SQLITE_INSERT ){ 18944fccf43aSdan int iCol; 18954fccf43aSdan sessionAppendByte(&buf, SQLITE_INSERT, &rc); 1896b4480e94Sdan sessionAppendByte(&buf, p->bIndirect, &rc); 1897e8d5648eSdan for(iCol=0; iCol<nCol; iCol++){ 18981f34f8ccSdan sessionAppendCol(&buf, pSel, iCol, &rc); 18994fccf43aSdan } 1900e8d5648eSdan }else{ 190173b3c055Sdan rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); 19024fccf43aSdan } 1903798693b2Sdan }else if( p->op!=SQLITE_INSERT ){ 1904a71d2371Sdan rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); 19054fccf43aSdan } 190612ca0b56Sdan if( rc==SQLITE_OK ){ 19071f34f8ccSdan rc = sqlite3_reset(pSel); 19084fccf43aSdan } 1909ef7a6304Sdan 1910ef7a6304Sdan /* If the buffer is now larger than SESSIONS_STR_CHUNK_SIZE, pass 1911ef7a6304Sdan ** its contents to the xOutput() callback. */ 1912ef7a6304Sdan if( xOutput 1913ef7a6304Sdan && rc==SQLITE_OK 1914ef7a6304Sdan && buf.nBuf>nNoop 1915ef7a6304Sdan && buf.nBuf>SESSIONS_STR_CHUNK_SIZE 1916ef7a6304Sdan ){ 1917ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1918ef7a6304Sdan nNoop = -1; 1919ef7a6304Sdan buf.nBuf = 0; 1920ef7a6304Sdan } 1921ef7a6304Sdan 19224fccf43aSdan } 1923e8d5648eSdan } 19244fccf43aSdan 19251f34f8ccSdan sqlite3_finalize(pSel); 19261f34f8ccSdan if( buf.nBuf==nNoop ){ 19274fccf43aSdan buf.nBuf = nRewind; 19284fccf43aSdan } 1929cfdbde21Sdrh sqlite3_free((char*)azCol); /* cast works around VC++ bug */ 19304fccf43aSdan } 19314fccf43aSdan } 19324fccf43aSdan 19334fccf43aSdan if( rc==SQLITE_OK ){ 1934ef7a6304Sdan if( xOutput==0 ){ 19354fccf43aSdan *pnChangeset = buf.nBuf; 19364fccf43aSdan *ppChangeset = buf.aBuf; 1937ef7a6304Sdan buf.aBuf = 0; 1938ef7a6304Sdan }else if( buf.nBuf>0 ){ 1939ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1940ef7a6304Sdan } 19414fccf43aSdan } 19424c220252Sdan 1943ef7a6304Sdan sqlite3_free(buf.aBuf); 1944e5754eecSdan sqlite3_exec(db, "RELEASE changeset", 0, 0, 0); 19454c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 19464fccf43aSdan return rc; 19474fccf43aSdan } 19484fccf43aSdan 1949296c7658Sdan /* 195073b3c055Sdan ** Obtain a changeset object containing all changes recorded by the 195173b3c055Sdan ** session object passed as the first argument. 195273b3c055Sdan ** 195373b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 195473b3c055Sdan ** using sqlite3_free(). 195573b3c055Sdan */ 195673b3c055Sdan int sqlite3session_changeset( 195773b3c055Sdan sqlite3_session *pSession, /* Session object */ 195873b3c055Sdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 195973b3c055Sdan void **ppChangeset /* OUT: Buffer containing changeset */ 196073b3c055Sdan ){ 1961ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, 0, 0, pnChangeset, ppChangeset); 1962ef7a6304Sdan } 1963ef7a6304Sdan 1964ef7a6304Sdan /* 1965ef7a6304Sdan ** Streaming version of sqlite3session_changeset(). 1966ef7a6304Sdan */ 1967ef7a6304Sdan int sqlite3session_changeset_str( 1968ef7a6304Sdan sqlite3_session *pSession, 1969ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1970ef7a6304Sdan void *pOut 1971ef7a6304Sdan ){ 1972ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, xOutput, pOut, 0, 0); 1973ef7a6304Sdan } 1974ef7a6304Sdan 1975ef7a6304Sdan /* 1976ef7a6304Sdan ** Streaming version of sqlite3session_patchset(). 1977ef7a6304Sdan */ 1978ef7a6304Sdan int sqlite3session_patchset_str( 1979ef7a6304Sdan sqlite3_session *pSession, 1980ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1981ef7a6304Sdan void *pOut 1982ef7a6304Sdan ){ 1983ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, xOutput, pOut, 0, 0); 198473b3c055Sdan } 198573b3c055Sdan 198673b3c055Sdan /* 198773b3c055Sdan ** Obtain a patchset object containing all changes recorded by the 198873b3c055Sdan ** session object passed as the first argument. 198973b3c055Sdan ** 199073b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 199173b3c055Sdan ** using sqlite3_free(). 199273b3c055Sdan */ 199373b3c055Sdan int sqlite3session_patchset( 199473b3c055Sdan sqlite3_session *pSession, /* Session object */ 199573b3c055Sdan int *pnPatchset, /* OUT: Size of buffer at *ppChangeset */ 199673b3c055Sdan void **ppPatchset /* OUT: Buffer containing changeset */ 199773b3c055Sdan ){ 1998ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, 0, 0, pnPatchset, ppPatchset); 199973b3c055Sdan } 200073b3c055Sdan 200173b3c055Sdan /* 2002296c7658Sdan ** Enable or disable the session object passed as the first argument. 2003296c7658Sdan */ 20044fccf43aSdan int sqlite3session_enable(sqlite3_session *pSession, int bEnable){ 20054c220252Sdan int ret; 20064c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2007296c7658Sdan if( bEnable>=0 ){ 2008296c7658Sdan pSession->bEnable = bEnable; 20094fccf43aSdan } 20104c220252Sdan ret = pSession->bEnable; 20114c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 20124c220252Sdan return ret; 2013296c7658Sdan } 20144fccf43aSdan 20154fccf43aSdan /* 2016b4480e94Sdan ** Enable or disable the session object passed as the first argument. 2017b4480e94Sdan */ 2018b4480e94Sdan int sqlite3session_indirect(sqlite3_session *pSession, int bIndirect){ 2019b4480e94Sdan int ret; 2020b4480e94Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2021b4480e94Sdan if( bIndirect>=0 ){ 2022b4480e94Sdan pSession->bIndirect = bIndirect; 2023b4480e94Sdan } 2024b4480e94Sdan ret = pSession->bIndirect; 2025b4480e94Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2026b4480e94Sdan return ret; 2027b4480e94Sdan } 2028b4480e94Sdan 2029b4480e94Sdan /* 2030b69ec348Sdan ** Return true if there have been no changes to monitored tables recorded 2031b69ec348Sdan ** by the session object passed as the only argument. 2032b69ec348Sdan */ 2033b69ec348Sdan int sqlite3session_isempty(sqlite3_session *pSession){ 2034b69ec348Sdan int ret = 0; 2035b69ec348Sdan SessionTable *pTab; 2036b69ec348Sdan 2037b69ec348Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2038b69ec348Sdan for(pTab=pSession->pTable; pTab && ret==0; pTab=pTab->pNext){ 2039b69ec348Sdan ret = (pTab->nEntry>0); 2040b69ec348Sdan } 2041b69ec348Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2042b69ec348Sdan 2043ff530326Sdan return (ret==0); 2044b69ec348Sdan } 2045b69ec348Sdan 2046b69ec348Sdan /* 2047ef7a6304Sdan ** Do the work for either sqlite3changeset_start() or start_str(). 20484fccf43aSdan */ 2049ef7a6304Sdan int sessionChangesetStart( 2050296c7658Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2051ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2052ef7a6304Sdan void *pIn, 2053296c7658Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2054296c7658Sdan void *pChangeset /* Pointer to buffer containing changeset */ 20554fccf43aSdan ){ 20564fccf43aSdan sqlite3_changeset_iter *pRet; /* Iterator to return */ 20574fccf43aSdan int nByte; /* Number of bytes to allocate for iterator */ 20584fccf43aSdan 2059ef7a6304Sdan assert( xInput==0 || (pChangeset==0 && nChangeset==0) ); 2060ef7a6304Sdan 2061296c7658Sdan /* Zero the output variable in case an error occurs. */ 2062296c7658Sdan *pp = 0; 20634fccf43aSdan 2064296c7658Sdan /* Allocate and initialize the iterator structure. */ 20654fccf43aSdan nByte = sizeof(sqlite3_changeset_iter); 20664fccf43aSdan pRet = (sqlite3_changeset_iter *)sqlite3_malloc(nByte); 20674fccf43aSdan if( !pRet ) return SQLITE_NOMEM; 20684fccf43aSdan memset(pRet, 0, sizeof(sqlite3_changeset_iter)); 20694757c658Sdan pRet->in.aData = (u8 *)pChangeset; 20704757c658Sdan pRet->in.nData = nChangeset; 2071ef7a6304Sdan pRet->in.xInput = xInput; 2072ef7a6304Sdan pRet->in.pIn = pIn; 2073ef7a6304Sdan pRet->in.iNext = 0; 2074ef7a6304Sdan pRet->in.bEof = (xInput ? 0 : 1); 20754fccf43aSdan 2076296c7658Sdan /* Populate the output variable and return success. */ 2077296c7658Sdan *pp = pRet; 20784fccf43aSdan return SQLITE_OK; 20794fccf43aSdan } 20804fccf43aSdan 2081296c7658Sdan /* 2082ef7a6304Sdan ** Create an iterator used to iterate through the contents of a changeset. 2083ef7a6304Sdan */ 2084ef7a6304Sdan int sqlite3changeset_start( 2085ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2086ef7a6304Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2087ef7a6304Sdan void *pChangeset /* Pointer to buffer containing changeset */ 2088ef7a6304Sdan ){ 2089ef7a6304Sdan return sessionChangesetStart(pp, 0, 0, nChangeset, pChangeset); 2090ef7a6304Sdan } 2091ef7a6304Sdan 2092ef7a6304Sdan /* 2093ef7a6304Sdan ** Streaming version of sqlite3changeset_start(). 2094ef7a6304Sdan */ 2095ef7a6304Sdan int sqlite3changeset_start_str( 2096ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2097ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2098ef7a6304Sdan void *pIn 2099ef7a6304Sdan ){ 2100ef7a6304Sdan return sessionChangesetStart(pp, xInput, pIn, 0, 0); 2101ef7a6304Sdan } 2102ef7a6304Sdan 2103ef7a6304Sdan /* 2104ef7a6304Sdan ** Ensure that there are at least nByte bytes available in the buffer. Or, 2105ef7a6304Sdan ** if there are not nByte bytes remaining in the input, that all available 2106ef7a6304Sdan ** data is in the buffer. 2107ef7a6304Sdan ** 2108ef7a6304Sdan ** Return an SQLite error code if an error occurs, or SQLITE_OK otherwise. 2109ef7a6304Sdan */ 21104757c658Sdan static int sessionInputBuffer(SessionInput *pIn, int nByte){ 2111ef7a6304Sdan int rc = SQLITE_OK; 21124757c658Sdan if( pIn->xInput ){ 21134757c658Sdan while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ 21144757c658Sdan int nNew = SESSIONS_STR_CHUNK_SIZE; 21154757c658Sdan 21164757c658Sdan if( pIn->iNext>=SESSIONS_STR_CHUNK_SIZE ){ 21174757c658Sdan int nMove = pIn->buf.nBuf - pIn->iNext; 21184757c658Sdan memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove); 21194757c658Sdan pIn->buf.nBuf -= pIn->iNext; 21204757c658Sdan pIn->iNext = 0; 21214757c658Sdan } 21224757c658Sdan 21234757c658Sdan if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){ 21244757c658Sdan rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); 21254757c658Sdan if( nNew==0 ){ 21264757c658Sdan pIn->bEof = 1; 21274757c658Sdan }else{ 21284757c658Sdan pIn->buf.nBuf += nNew; 21294757c658Sdan } 21304757c658Sdan } 21314757c658Sdan 21324757c658Sdan pIn->aData = pIn->buf.aBuf; 21334757c658Sdan pIn->nData = pIn->buf.nBuf; 21344757c658Sdan } 2135ef7a6304Sdan } 2136ef7a6304Sdan return rc; 2137ef7a6304Sdan } 2138ef7a6304Sdan 2139ef7a6304Sdan /* 2140ef7a6304Sdan ** When this function is called, *ppRec points to the start of a record 2141ef7a6304Sdan ** that contains nCol values. This function advances the pointer *ppRec 2142ef7a6304Sdan ** until it points to the byte immediately following that record. 2143ef7a6304Sdan */ 2144ef7a6304Sdan static void sessionSkipRecord( 2145ef7a6304Sdan u8 **ppRec, /* IN/OUT: Record pointer */ 2146ef7a6304Sdan int nCol /* Number of values in record */ 2147ef7a6304Sdan ){ 2148ef7a6304Sdan u8 *aRec = *ppRec; 2149ef7a6304Sdan int i; 2150ef7a6304Sdan for(i=0; i<nCol; i++){ 2151ef7a6304Sdan int eType = *aRec++; 2152ef7a6304Sdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2153ef7a6304Sdan int nByte; 2154ef7a6304Sdan aRec += sessionVarintGet((u8*)aRec, &nByte); 2155ef7a6304Sdan aRec += nByte; 2156ef7a6304Sdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2157ef7a6304Sdan aRec += 8; 2158ef7a6304Sdan } 2159ef7a6304Sdan } 2160ef7a6304Sdan 2161ef7a6304Sdan *ppRec = aRec; 2162ef7a6304Sdan } 2163ef7a6304Sdan 2164ef7a6304Sdan /* 21654757c658Sdan ** This function sets the value of the sqlite3_value object passed as the 21664757c658Sdan ** first argument to a copy of the string or blob held in the aData[] 21674757c658Sdan ** buffer. SQLITE_OK is returned if successful, or SQLITE_NOMEM if an OOM 21684757c658Sdan ** error occurs. 21694757c658Sdan */ 21704757c658Sdan static int sessionValueSetStr( 21714757c658Sdan sqlite3_value *pVal, /* Set the value of this object */ 21724757c658Sdan u8 *aData, /* Buffer containing string or blob data */ 21734757c658Sdan int nData, /* Size of buffer aData[] in bytes */ 21744757c658Sdan u8 enc /* String encoding (0 for blobs) */ 21754757c658Sdan ){ 21764757c658Sdan u8 *aCopy = sqlite3_malloc(nData); 21774757c658Sdan if( aCopy==0 ) return SQLITE_NOMEM; 21784757c658Sdan memcpy(aCopy, aData, nData); 21794757c658Sdan sqlite3ValueSetStr(pVal, nData, (char*)aCopy, enc, sqlite3_free); 21804757c658Sdan return SQLITE_OK; 21814757c658Sdan } 21824757c658Sdan 21834757c658Sdan /* 2184296c7658Sdan ** Deserialize a single record from a buffer in memory. See "RECORD FORMAT" 2185296c7658Sdan ** for details. 2186296c7658Sdan ** 2187296c7658Sdan ** When this function is called, *paChange points to the start of the record 2188296c7658Sdan ** to deserialize. Assuming no error occurs, *paChange is set to point to 2189296c7658Sdan ** one byte after the end of the same record before this function returns. 2190a71d2371Sdan ** If the argument abPK is NULL, then the record contains nCol values. Or, 2191a71d2371Sdan ** if abPK is other than NULL, then the record contains only the PK fields 2192a71d2371Sdan ** (in other words, it is a patchset DELETE record). 2193296c7658Sdan ** 2194296c7658Sdan ** If successful, each element of the apOut[] array (allocated by the caller) 2195296c7658Sdan ** is set to point to an sqlite3_value object containing the value read 2196296c7658Sdan ** from the corresponding position in the record. If that value is not 2197296c7658Sdan ** included in the record (i.e. because the record is part of an UPDATE change 2198296c7658Sdan ** and the field was not modified), the corresponding element of apOut[] is 2199296c7658Sdan ** set to NULL. 2200296c7658Sdan ** 2201296c7658Sdan ** It is the responsibility of the caller to free all sqlite_value structures 2202296c7658Sdan ** using sqlite3_free(). 2203296c7658Sdan ** 2204296c7658Sdan ** If an error occurs, an SQLite error code (e.g. SQLITE_NOMEM) is returned. 2205296c7658Sdan ** The apOut[] array may have been partially populated in this case. 2206296c7658Sdan */ 22074fccf43aSdan static int sessionReadRecord( 2208ef7a6304Sdan SessionInput *pIn, /* Input data */ 22094fccf43aSdan int nCol, /* Number of values in record */ 221073b3c055Sdan u8 *abPK, /* Array of primary key flags, or NULL */ 22114fccf43aSdan sqlite3_value **apOut /* Write values to this array */ 22124fccf43aSdan ){ 2213296c7658Sdan int i; /* Used to iterate through columns */ 2214ef7a6304Sdan int rc = SQLITE_OK; 22154fccf43aSdan 2216ef7a6304Sdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 2217ef7a6304Sdan int eType = 0; /* Type of value (SQLITE_NULL, TEXT etc.) */ 221873b3c055Sdan if( abPK && abPK[i]==0 ) continue; 2219ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2220ef7a6304Sdan if( rc==SQLITE_OK ){ 22214757c658Sdan eType = pIn->aData[pIn->iNext++]; 2222ef7a6304Sdan } 2223ef7a6304Sdan 222491ddd559Sdan assert( !apOut || apOut[i]==0 ); 22254fccf43aSdan if( eType ){ 222691ddd559Sdan if( apOut ){ 22274fccf43aSdan apOut[i] = sqlite3ValueNew(0); 2228ef7a6304Sdan if( !apOut[i] ) rc = SQLITE_NOMEM; 2229ef7a6304Sdan } 223091ddd559Sdan } 22314fccf43aSdan 2232ef7a6304Sdan if( rc==SQLITE_OK ){ 22334757c658Sdan u8 *aVal = &pIn->aData[pIn->iNext]; 22344fccf43aSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 22354fccf43aSdan int nByte; 2236ef7a6304Sdan pIn->iNext += sessionVarintGet(aVal, &nByte); 2237ef7a6304Sdan rc = sessionInputBuffer(pIn, nByte); 2238ef7a6304Sdan if( apOut && rc==SQLITE_OK ){ 22396734007dSdan u8 enc = (eType==SQLITE_TEXT ? SQLITE_UTF8 : 0); 22404757c658Sdan rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc); 224191ddd559Sdan } 2242ef7a6304Sdan pIn->iNext += nByte; 22434fccf43aSdan } 22444fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 224591ddd559Sdan if( apOut ){ 2246ef7a6304Sdan sqlite3_int64 v = sessionGetI64(aVal); 22474fccf43aSdan if( eType==SQLITE_INTEGER ){ 22484fccf43aSdan sqlite3VdbeMemSetInt64(apOut[i], v); 22494fccf43aSdan }else{ 22504fccf43aSdan double d; 22514e895da1Sdan memcpy(&d, &v, 8); 22524fccf43aSdan sqlite3VdbeMemSetDouble(apOut[i], d); 22534fccf43aSdan } 22544fccf43aSdan } 2255ef7a6304Sdan pIn->iNext += 8; 225691ddd559Sdan } 22574fccf43aSdan } 22584fccf43aSdan } 22594fccf43aSdan 2260ef7a6304Sdan return rc; 2261ef7a6304Sdan } 2262ef7a6304Sdan 2263ef7a6304Sdan /* 2264ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2265ef7a6304Sdan ** Specifically, to the following: 2266ef7a6304Sdan ** 2267ef7a6304Sdan ** + number of columns in table (varint) 2268ef7a6304Sdan ** + array of PK flags (1 byte per column), 2269ef7a6304Sdan ** + table name (nul terminated). 2270ef7a6304Sdan ** 2271ef7a6304Sdan ** This function ensures that all of the above is present in the input 2272ef7a6304Sdan ** buffer (i.e. that it can be accessed without any calls to xInput()). 2273ef7a6304Sdan ** If successful, SQLITE_OK is returned. Otherwise, an SQLite error code. 2274ef7a6304Sdan ** The input pointer is not moved. 2275ef7a6304Sdan */ 2276ef7a6304Sdan static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){ 2277ef7a6304Sdan int rc = SQLITE_OK; 2278ef7a6304Sdan int nCol = 0; 22794757c658Sdan int nRead = 0; 2280ef7a6304Sdan 2281ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2282ef7a6304Sdan if( rc==SQLITE_OK ){ 22834757c658Sdan nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol); 22844757c658Sdan rc = sessionInputBuffer(pIn, nRead+nCol+100); 22854757c658Sdan nRead += nCol; 2286ef7a6304Sdan } 22874757c658Sdan 2288ef7a6304Sdan while( rc==SQLITE_OK ){ 22894757c658Sdan while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){ 22904757c658Sdan nRead++; 2291ef7a6304Sdan } 22924757c658Sdan if( pIn->aData[pIn->iNext + nRead]==0 ) break; 22934757c658Sdan rc = sessionInputBuffer(pIn, nRead + 100); 22944757c658Sdan } 22954757c658Sdan if( pnByte ) *pnByte = nRead+1; 2296ef7a6304Sdan return rc; 2297ef7a6304Sdan } 2298ef7a6304Sdan 2299ef7a6304Sdan /* 2300fa122adaSdan ** The input pointer currently points to the first byte of the first field 2301fa122adaSdan ** of a record consisting of nCol columns. This function ensures the entire 2302fa122adaSdan ** record is buffered. 2303fa122adaSdan */ 2304fa122adaSdan static int sessionChangesetBufferRecord( 2305fa122adaSdan SessionInput *pIn, 2306fa122adaSdan int nCol, 2307fa122adaSdan int *pnByte 2308fa122adaSdan ){ 2309fa122adaSdan int rc = SQLITE_OK; 2310fa122adaSdan int nByte = 0; 2311fa122adaSdan int i; 2312fa122adaSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 2313fa122adaSdan int eType; 2314fa122adaSdan rc = sessionInputBuffer(pIn, nByte + 10); 2315fa122adaSdan if( rc==SQLITE_OK ){ 2316fa122adaSdan eType = pIn->aData[pIn->iNext + nByte++]; 2317fa122adaSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2318fa122adaSdan int n; 2319fa122adaSdan nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n); 2320fa122adaSdan nByte += n; 2321fa122adaSdan rc = sessionInputBuffer(pIn, nByte); 2322fa122adaSdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2323fa122adaSdan nByte += 8; 2324fa122adaSdan } 2325fa122adaSdan } 2326fa122adaSdan } 2327fa122adaSdan *pnByte = nByte; 2328fa122adaSdan return rc; 2329fa122adaSdan } 2330fa122adaSdan 2331fa122adaSdan /* 2332ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2333ef7a6304Sdan ** Specifically, to the following: 2334ef7a6304Sdan ** 2335ef7a6304Sdan ** + number of columns in table (varint) 2336ef7a6304Sdan ** + array of PK flags (1 byte per column), 2337ef7a6304Sdan ** + table name (nul terminated). 2338ef7a6304Sdan */ 2339ef7a6304Sdan static int sessionChangesetReadTblhdr(sqlite3_changeset_iter *p){ 2340ef7a6304Sdan int rc; 2341ef7a6304Sdan int nCopy; 2342ef7a6304Sdan assert( p->rc==SQLITE_OK ); 2343ef7a6304Sdan 2344ef7a6304Sdan rc = sessionChangesetBufferTblhdr(&p->in, &nCopy); 2345ef7a6304Sdan if( rc==SQLITE_OK ){ 2346ef7a6304Sdan int nByte; 2347ef7a6304Sdan int nVarint; 23484757c658Sdan nVarint = sessionVarintGet(&p->in.aData[p->in.iNext], &p->nCol); 2349ef7a6304Sdan nCopy -= nVarint; 2350ef7a6304Sdan p->in.iNext += nVarint; 2351ef7a6304Sdan nByte = p->nCol * sizeof(sqlite3_value*) * 2 + nCopy; 2352ef7a6304Sdan p->tblhdr.nBuf = 0; 2353ef7a6304Sdan sessionBufferGrow(&p->tblhdr, nByte, &rc); 2354ef7a6304Sdan } 2355ef7a6304Sdan 2356ef7a6304Sdan if( rc==SQLITE_OK ){ 2357ef7a6304Sdan int iPK = sizeof(sqlite3_value*)*p->nCol*2; 2358ef7a6304Sdan memset(p->tblhdr.aBuf, 0, iPK); 23594757c658Sdan memcpy(&p->tblhdr.aBuf[iPK], &p->in.aData[p->in.iNext], nCopy); 2360ef7a6304Sdan p->in.iNext += nCopy; 2361ef7a6304Sdan } 2362ef7a6304Sdan 2363ef7a6304Sdan p->apValue = (sqlite3_value**)p->tblhdr.aBuf; 2364ef7a6304Sdan p->abPK = (u8*)&p->apValue[p->nCol*2]; 2365ef7a6304Sdan p->zTab = (char*)&p->abPK[p->nCol]; 2366ef7a6304Sdan return (p->rc = rc); 23674fccf43aSdan } 23684fccf43aSdan 236977fc1d5bSdan /* 237077fc1d5bSdan ** Advance the changeset iterator to the next change. 237177fc1d5bSdan ** 237277fc1d5bSdan ** If both paRec and pnRec are NULL, then this function works like the public 237377fc1d5bSdan ** API sqlite3changeset_next(). If SQLITE_ROW is returned, then the 237477fc1d5bSdan ** sqlite3changeset_new() and old() APIs may be used to query for values. 237577fc1d5bSdan ** 237677fc1d5bSdan ** Otherwise, if paRec and pnRec are not NULL, then a pointer to the change 237777fc1d5bSdan ** record is written to *paRec before returning and the number of bytes in 237877fc1d5bSdan ** the record to *pnRec. 237977fc1d5bSdan ** 238077fc1d5bSdan ** Either way, this function returns SQLITE_ROW if the iterator is 238177fc1d5bSdan ** successfully advanced to the next change in the changeset, an SQLite 238277fc1d5bSdan ** error code if an error occurs, or SQLITE_DONE if there are no further 238377fc1d5bSdan ** changes in the changeset. 238477fc1d5bSdan */ 23855d607a6eSdan static int sessionChangesetNext( 238677fc1d5bSdan sqlite3_changeset_iter *p, /* Changeset iterator */ 238777fc1d5bSdan u8 **paRec, /* If non-NULL, store record pointer here */ 238877fc1d5bSdan int *pnRec /* If non-NULL, store size of record here */ 23895d607a6eSdan ){ 23904fccf43aSdan int i; 2391ef7a6304Sdan u8 op; 23924fccf43aSdan 23935d607a6eSdan assert( (paRec==0 && pnRec==0) || (paRec && pnRec) ); 23945d607a6eSdan 2395296c7658Sdan /* If the iterator is in the error-state, return immediately. */ 23964fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 23974fccf43aSdan 23985d607a6eSdan /* Free the current contents of p->apValue[], if any. */ 23994fccf43aSdan if( p->apValue ){ 24004fccf43aSdan for(i=0; i<p->nCol*2; i++){ 24014fccf43aSdan sqlite3ValueFree(p->apValue[i]); 24024fccf43aSdan } 24034fccf43aSdan memset(p->apValue, 0, sizeof(sqlite3_value*)*p->nCol*2); 24044fccf43aSdan } 24054fccf43aSdan 2406ef7a6304Sdan /* Make sure the buffer contains at least 10 bytes of input data, or all 2407ef7a6304Sdan ** remaining data if there are less than 10 bytes available. This is 2408ef7a6304Sdan ** sufficient either for the 'T' or 'P' byte and the varint that follows 2409ef7a6304Sdan ** it, or for the two single byte values otherwise. */ 2410ef7a6304Sdan p->rc = sessionInputBuffer(&p->in, 2); 2411ef7a6304Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2412ef7a6304Sdan 24134fccf43aSdan /* If the iterator is already at the end of the changeset, return DONE. */ 24144757c658Sdan if( p->in.iNext>=p->in.nData ){ 24154fccf43aSdan return SQLITE_DONE; 24164fccf43aSdan } 24174fccf43aSdan 24184757c658Sdan op = p->in.aData[p->in.iNext++]; 2419ef7a6304Sdan if( op=='T' || op=='P' ){ 2420ef7a6304Sdan p->bPatchset = (op=='P'); 2421ef7a6304Sdan if( sessionChangesetReadTblhdr(p) ) return p->rc; 2422ef7a6304Sdan if( (p->rc = sessionInputBuffer(&p->in, 2)) ) return p->rc; 24234757c658Sdan op = p->in.aData[p->in.iNext++]; 24245d607a6eSdan } 24255d607a6eSdan 2426ef7a6304Sdan p->op = op; 24274757c658Sdan p->bIndirect = p->in.aData[p->in.iNext++]; 24284fccf43aSdan if( p->op!=SQLITE_UPDATE && p->op!=SQLITE_DELETE && p->op!=SQLITE_INSERT ){ 24294757c658Sdan return (p->rc = SQLITE_CORRUPT_BKPT); 24304fccf43aSdan } 24314fccf43aSdan 2432cbf6d2d2Sdan if( paRec ){ 2433cbf6d2d2Sdan int nVal; /* Number of values to buffer */ 2434cbf6d2d2Sdan if( p->bPatchset==0 && op==SQLITE_UPDATE ){ 2435cbf6d2d2Sdan nVal = p->nCol * 2; 2436cbf6d2d2Sdan }else if( p->bPatchset && op==SQLITE_DELETE ){ 2437cbf6d2d2Sdan nVal = 0; 2438cbf6d2d2Sdan for(i=0; i<p->nCol; i++) if( p->abPK[i] ) nVal++; 2439cbf6d2d2Sdan }else{ 2440cbf6d2d2Sdan nVal = p->nCol; 2441cbf6d2d2Sdan } 2442cbf6d2d2Sdan p->rc = sessionChangesetBufferRecord(&p->in, nVal, pnRec); 2443cbf6d2d2Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2444cbf6d2d2Sdan *paRec = &p->in.aData[p->in.iNext]; 2445cbf6d2d2Sdan p->in.iNext += *pnRec; 2446cbf6d2d2Sdan }else{ 24475d607a6eSdan 24484fccf43aSdan /* If this is an UPDATE or DELETE, read the old.* record. */ 244973b3c055Sdan if( p->op!=SQLITE_INSERT && (p->bPatchset==0 || p->op==SQLITE_DELETE) ){ 245073b3c055Sdan u8 *abPK = p->bPatchset ? p->abPK : 0; 2451cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, abPK, p->apValue); 24524fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24534fccf43aSdan } 24544fccf43aSdan 24554fccf43aSdan /* If this is an INSERT or UPDATE, read the new.* record. */ 24564fccf43aSdan if( p->op!=SQLITE_DELETE ){ 2457cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, 0, &p->apValue[p->nCol]); 24584fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24594fccf43aSdan } 24604fccf43aSdan 2461cbf6d2d2Sdan if( p->bPatchset && p->op==SQLITE_UPDATE ){ 246273b3c055Sdan /* If this is an UPDATE that is part of a patchset, then all PK and 246373b3c055Sdan ** modified fields are present in the new.* record. The old.* record 246473b3c055Sdan ** is currently completely empty. This block shifts the PK fields from 246573b3c055Sdan ** new.* to old.*, to accommodate the code that reads these arrays. */ 246673b3c055Sdan int i; 246773b3c055Sdan for(i=0; i<p->nCol; i++){ 246873b3c055Sdan assert( p->apValue[i]==0 ); 246973b3c055Sdan assert( p->abPK[i]==0 || p->apValue[i+p->nCol] ); 247073b3c055Sdan if( p->abPK[i] ){ 247173b3c055Sdan p->apValue[i] = p->apValue[i+p->nCol]; 247273b3c055Sdan p->apValue[i+p->nCol] = 0; 247373b3c055Sdan } 247473b3c055Sdan } 247573b3c055Sdan } 2476cbf6d2d2Sdan } 2477ef7a6304Sdan 24784fccf43aSdan return SQLITE_ROW; 24794fccf43aSdan } 24804fccf43aSdan 24814fccf43aSdan /* 24825d607a6eSdan ** Advance an iterator created by sqlite3changeset_start() to the next 24835d607a6eSdan ** change in the changeset. This function may return SQLITE_ROW, SQLITE_DONE 24845d607a6eSdan ** or SQLITE_CORRUPT. 24855d607a6eSdan ** 24865d607a6eSdan ** This function may not be called on iterators passed to a conflict handler 24875d607a6eSdan ** callback by changeset_apply(). 24885d607a6eSdan */ 24895d607a6eSdan int sqlite3changeset_next(sqlite3_changeset_iter *p){ 24905d607a6eSdan return sessionChangesetNext(p, 0, 0); 24915d607a6eSdan } 24925d607a6eSdan 24935d607a6eSdan /* 2494244593c8Sdan ** The following function extracts information on the current change 249577fc1d5bSdan ** from a changeset iterator. It may only be called after changeset_next() 24964fccf43aSdan ** has returned SQLITE_ROW. 24974fccf43aSdan */ 24984fccf43aSdan int sqlite3changeset_op( 2499296c7658Sdan sqlite3_changeset_iter *pIter, /* Iterator handle */ 25004fccf43aSdan const char **pzTab, /* OUT: Pointer to table name */ 25014fccf43aSdan int *pnCol, /* OUT: Number of columns in table */ 2502b4480e94Sdan int *pOp, /* OUT: SQLITE_INSERT, DELETE or UPDATE */ 2503b4480e94Sdan int *pbIndirect /* OUT: True if change is indirect */ 25044fccf43aSdan ){ 25054fccf43aSdan *pOp = pIter->op; 25064fccf43aSdan *pnCol = pIter->nCol; 25074fccf43aSdan *pzTab = pIter->zTab; 2508b4480e94Sdan if( pbIndirect ) *pbIndirect = pIter->bIndirect; 25094fccf43aSdan return SQLITE_OK; 25104fccf43aSdan } 25114fccf43aSdan 251277fc1d5bSdan /* 251377fc1d5bSdan ** Return information regarding the PRIMARY KEY and number of columns in 251477fc1d5bSdan ** the database table affected by the change that pIter currently points 251577fc1d5bSdan ** to. This function may only be called after changeset_next() returns 251677fc1d5bSdan ** SQLITE_ROW. 251777fc1d5bSdan */ 2518244593c8Sdan int sqlite3changeset_pk( 2519244593c8Sdan sqlite3_changeset_iter *pIter, /* Iterator object */ 2520244593c8Sdan unsigned char **pabPK, /* OUT: Array of boolean - true for PK cols */ 2521244593c8Sdan int *pnCol /* OUT: Number of entries in output array */ 2522244593c8Sdan ){ 2523244593c8Sdan *pabPK = pIter->abPK; 2524244593c8Sdan if( pnCol ) *pnCol = pIter->nCol; 2525244593c8Sdan return SQLITE_OK; 2526244593c8Sdan } 2527244593c8Sdan 2528296c7658Sdan /* 2529296c7658Sdan ** This function may only be called while the iterator is pointing to an 2530296c7658Sdan ** SQLITE_UPDATE or SQLITE_DELETE change (see sqlite3changeset_op()). 2531296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2532296c7658Sdan ** 2533296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2534296c7658Sdan ** iVal'th value in the old.* record. Or, if that particular value is not 2535296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2536296c7658Sdan ** was not modified and is not a PK column), set *ppValue to NULL. 2537296c7658Sdan ** 2538296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2539296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2540296c7658Sdan */ 25414fccf43aSdan int sqlite3changeset_old( 2542296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2543296c7658Sdan int iVal, /* Index of old.* value to retrieve */ 25444fccf43aSdan sqlite3_value **ppValue /* OUT: Old value (or NULL pointer) */ 25454fccf43aSdan ){ 2546d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_DELETE ){ 2547d5f0767cSdan return SQLITE_MISUSE; 2548d5f0767cSdan } 25494fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25504fccf43aSdan return SQLITE_RANGE; 25514fccf43aSdan } 25524fccf43aSdan *ppValue = pIter->apValue[iVal]; 25534fccf43aSdan return SQLITE_OK; 25544fccf43aSdan } 25554fccf43aSdan 2556296c7658Sdan /* 2557296c7658Sdan ** This function may only be called while the iterator is pointing to an 2558296c7658Sdan ** SQLITE_UPDATE or SQLITE_INSERT change (see sqlite3changeset_op()). 2559296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2560296c7658Sdan ** 2561296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2562296c7658Sdan ** iVal'th value in the new.* record. Or, if that particular value is not 2563296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2564296c7658Sdan ** was not modified), set *ppValue to NULL. 2565296c7658Sdan ** 2566296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2567296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2568296c7658Sdan */ 25694fccf43aSdan int sqlite3changeset_new( 2570296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2571296c7658Sdan int iVal, /* Index of new.* value to retrieve */ 25724fccf43aSdan sqlite3_value **ppValue /* OUT: New value (or NULL pointer) */ 25734fccf43aSdan ){ 2574d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_INSERT ){ 2575d5f0767cSdan return SQLITE_MISUSE; 2576d5f0767cSdan } 25774fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25784fccf43aSdan return SQLITE_RANGE; 25794fccf43aSdan } 25804fccf43aSdan *ppValue = pIter->apValue[pIter->nCol+iVal]; 25814fccf43aSdan return SQLITE_OK; 25824fccf43aSdan } 25834fccf43aSdan 2584296c7658Sdan /* 25857aa469cdSdan ** The following two macros are used internally. They are similar to the 25867aa469cdSdan ** sqlite3changeset_new() and sqlite3changeset_old() functions, except that 25877aa469cdSdan ** they omit all error checking and return a pointer to the requested value. 25887aa469cdSdan */ 25897aa469cdSdan #define sessionChangesetNew(pIter, iVal) (pIter)->apValue[(pIter)->nCol+(iVal)] 25907aa469cdSdan #define sessionChangesetOld(pIter, iVal) (pIter)->apValue[(iVal)] 25917aa469cdSdan 25927aa469cdSdan /* 2593296c7658Sdan ** This function may only be called with a changeset iterator that has been 2594296c7658Sdan ** passed to an SQLITE_CHANGESET_DATA or SQLITE_CHANGESET_CONFLICT 2595296c7658Sdan ** conflict-handler function. Otherwise, SQLITE_MISUSE is returned. 2596296c7658Sdan ** 2597296c7658Sdan ** If successful, *ppValue is set to point to an sqlite3_value structure 2598296c7658Sdan ** containing the iVal'th value of the conflicting record. 2599296c7658Sdan ** 2600296c7658Sdan ** If value iVal is out-of-range or some other error occurs, an SQLite error 2601296c7658Sdan ** code is returned. Otherwise, SQLITE_OK. 2602296c7658Sdan */ 2603d5f0767cSdan int sqlite3changeset_conflict( 2604296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2605296c7658Sdan int iVal, /* Index of conflict record value to fetch */ 2606d5f0767cSdan sqlite3_value **ppValue /* OUT: Value from conflicting row */ 2607d5f0767cSdan ){ 2608d5f0767cSdan if( !pIter->pConflict ){ 2609d5f0767cSdan return SQLITE_MISUSE; 2610d5f0767cSdan } 2611d5f0767cSdan if( iVal<0 || iVal>=sqlite3_column_count(pIter->pConflict) ){ 2612d5f0767cSdan return SQLITE_RANGE; 2613d5f0767cSdan } 2614d5f0767cSdan *ppValue = sqlite3_column_value(pIter->pConflict, iVal); 2615d5f0767cSdan return SQLITE_OK; 2616d5f0767cSdan } 2617d5f0767cSdan 26184fccf43aSdan /* 2619cb3e4b79Sdan ** This function may only be called with an iterator passed to an 2620cb3e4b79Sdan ** SQLITE_CHANGESET_FOREIGN_KEY conflict handler callback. In this case 2621cb3e4b79Sdan ** it sets the output variable to the total number of known foreign key 2622cb3e4b79Sdan ** violations in the destination database and returns SQLITE_OK. 2623cb3e4b79Sdan ** 2624cb3e4b79Sdan ** In all other cases this function returns SQLITE_MISUSE. 2625cb3e4b79Sdan */ 2626cb3e4b79Sdan int sqlite3changeset_fk_conflicts( 2627cb3e4b79Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2628cb3e4b79Sdan int *pnOut /* OUT: Number of FK violations */ 2629cb3e4b79Sdan ){ 2630cb3e4b79Sdan if( pIter->pConflict || pIter->apValue ){ 2631cb3e4b79Sdan return SQLITE_MISUSE; 2632cb3e4b79Sdan } 2633cb3e4b79Sdan *pnOut = pIter->nCol; 2634cb3e4b79Sdan return SQLITE_OK; 2635cb3e4b79Sdan } 2636cb3e4b79Sdan 2637cb3e4b79Sdan 2638cb3e4b79Sdan /* 26394fccf43aSdan ** Finalize an iterator allocated with sqlite3changeset_start(). 26404fccf43aSdan ** 26414fccf43aSdan ** This function may not be called on iterators passed to a conflict handler 26424fccf43aSdan ** callback by changeset_apply(). 26434fccf43aSdan */ 26444fccf43aSdan int sqlite3changeset_finalize(sqlite3_changeset_iter *p){ 2645cbf6d2d2Sdan int rc = SQLITE_OK; 2646cbf6d2d2Sdan if( p ){ 2647296c7658Sdan int i; /* Used to iterate through p->apValue[] */ 2648cbf6d2d2Sdan rc = p->rc; 264912ca0b56Sdan if( p->apValue ){ 26504fccf43aSdan for(i=0; i<p->nCol*2; i++) sqlite3ValueFree(p->apValue[i]); 265112ca0b56Sdan } 2652ef7a6304Sdan sqlite3_free(p->tblhdr.aBuf); 26534757c658Sdan sqlite3_free(p->in.buf.aBuf); 26544fccf43aSdan sqlite3_free(p); 2655cbf6d2d2Sdan } 26564fccf43aSdan return rc; 26574fccf43aSdan } 26584fccf43aSdan 2659fa122adaSdan static int sessionChangesetInvert( 2660fa122adaSdan SessionInput *pInput, /* Input changeset */ 2661fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2662fa122adaSdan void *pOut, 266391ddd559Sdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 266491ddd559Sdan void **ppInverted /* OUT: Inverse of pChangeset */ 266591ddd559Sdan ){ 2666cfec7eeeSdan int rc = SQLITE_OK; /* Return value */ 2667fa122adaSdan SessionBuffer sOut; /* Output buffer */ 2668cfec7eeeSdan int nCol = 0; /* Number of cols in current table */ 2669cfec7eeeSdan u8 *abPK = 0; /* PK array for current table */ 2670cfec7eeeSdan sqlite3_value **apVal = 0; /* Space for values for UPDATE inversion */ 2671ef7a6304Sdan SessionBuffer sPK = {0, 0, 0}; /* PK array for current table */ 267291ddd559Sdan 2673fa122adaSdan /* Initialize the output buffer */ 2674fa122adaSdan memset(&sOut, 0, sizeof(SessionBuffer)); 2675fa122adaSdan 267691ddd559Sdan /* Zero the output variables in case an error occurs. */ 2677fa122adaSdan if( ppInverted ){ 267891ddd559Sdan *ppInverted = 0; 267991ddd559Sdan *pnInverted = 0; 2680fa122adaSdan } 268191ddd559Sdan 2682fa122adaSdan while( 1 ){ 2683ef7a6304Sdan u8 eType; 2684fa122adaSdan 2685fa122adaSdan /* Test for EOF. */ 2686fa122adaSdan if( (rc = sessionInputBuffer(pInput, 2)) ) goto finished_invert; 2687fa122adaSdan if( pInput->iNext>=pInput->nData ) break; 2688fa122adaSdan eType = pInput->aData[pInput->iNext]; 2689fa122adaSdan 269091ddd559Sdan switch( eType ){ 269191ddd559Sdan case 'T': { 2692244593c8Sdan /* A 'table' record consists of: 2693244593c8Sdan ** 2694244593c8Sdan ** * A constant 'T' character, 2695244593c8Sdan ** * Number of columns in said table (a varint), 2696ef7a6304Sdan ** * An array of nCol bytes (sPK), 2697244593c8Sdan ** * A nul-terminated table name. 2698244593c8Sdan */ 2699ef7a6304Sdan int nByte; 2700fa122adaSdan int nVar; 2701fa122adaSdan pInput->iNext++; 2702fa122adaSdan if( (rc = sessionChangesetBufferTblhdr(pInput, &nByte)) ){ 2703ef7a6304Sdan goto finished_invert; 2704ef7a6304Sdan } 2705fa122adaSdan nVar = sessionVarintGet(&pInput->aData[pInput->iNext], &nCol); 2706ef7a6304Sdan sPK.nBuf = 0; 2707fa122adaSdan sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc); 2708fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2709fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2710ef7a6304Sdan if( rc ) goto finished_invert; 2711fa122adaSdan 2712fa122adaSdan pInput->iNext += nByte; 2713cfec7eeeSdan sqlite3_free(apVal); 2714cfec7eeeSdan apVal = 0; 2715ef7a6304Sdan abPK = sPK.aBuf; 271691ddd559Sdan break; 271791ddd559Sdan } 271891ddd559Sdan 271991ddd559Sdan case SQLITE_INSERT: 272091ddd559Sdan case SQLITE_DELETE: { 272191ddd559Sdan int nByte; 2722fa122adaSdan int bIndirect = pInput->aData[pInput->iNext+1]; 2723fa122adaSdan int eType2 = (eType==SQLITE_DELETE ? SQLITE_INSERT : SQLITE_DELETE); 2724fa122adaSdan pInput->iNext += 2; 2725fa122adaSdan assert( rc==SQLITE_OK ); 2726fa122adaSdan rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); 2727fa122adaSdan sessionAppendByte(&sOut, eType2, &rc); 2728fa122adaSdan sessionAppendByte(&sOut, bIndirect, &rc); 2729fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2730fa122adaSdan pInput->iNext += nByte; 2731fa122adaSdan if( rc ) goto finished_invert; 273291ddd559Sdan break; 273391ddd559Sdan } 273491ddd559Sdan 273591ddd559Sdan case SQLITE_UPDATE: { 2736cfec7eeeSdan int iCol; 273791ddd559Sdan 2738cfec7eeeSdan if( 0==apVal ){ 2739cfec7eeeSdan apVal = (sqlite3_value **)sqlite3_malloc(sizeof(apVal[0])*nCol*2); 2740cfec7eeeSdan if( 0==apVal ){ 2741cfec7eeeSdan rc = SQLITE_NOMEM; 2742cfec7eeeSdan goto finished_invert; 2743cfec7eeeSdan } 2744cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2745cfec7eeeSdan } 274691ddd559Sdan 2747cfec7eeeSdan /* Write the header for the new UPDATE change. Same as the original. */ 2748fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2749fa122adaSdan sessionAppendByte(&sOut, pInput->aData[pInput->iNext+1], &rc); 275091ddd559Sdan 2751ef7a6304Sdan /* Read the old.* and new.* records for the update change. */ 2752fa122adaSdan pInput->iNext += 2; 2753fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[0]); 2754ef7a6304Sdan if( rc==SQLITE_OK ){ 2755fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[nCol]); 2756ef7a6304Sdan } 2757ef7a6304Sdan 2758cfec7eeeSdan /* Write the new old.* record. Consists of the PK columns from the 2759cfec7eeeSdan ** original old.* record, and the other values from the original 2760cfec7eeeSdan ** new.* record. */ 2761cfec7eeeSdan for(iCol=0; rc==SQLITE_OK && iCol<nCol; iCol++){ 2762cfec7eeeSdan sqlite3_value *pVal = apVal[iCol + (abPK[iCol] ? 0 : nCol)]; 2763fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2764cfec7eeeSdan } 2765cfec7eeeSdan 2766cfec7eeeSdan /* Write the new new.* record. Consists of a copy of all values 2767cfec7eeeSdan ** from the original old.* record, except for the PK columns, which 2768cfec7eeeSdan ** are set to "undefined". */ 2769cfec7eeeSdan for(iCol=0; rc==SQLITE_OK && iCol<nCol; iCol++){ 2770cfec7eeeSdan sqlite3_value *pVal = (abPK[iCol] ? 0 : apVal[iCol]); 2771fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2772cfec7eeeSdan } 2773cfec7eeeSdan 2774cfec7eeeSdan for(iCol=0; iCol<nCol*2; iCol++){ 2775cfec7eeeSdan sqlite3ValueFree(apVal[iCol]); 2776cfec7eeeSdan } 2777cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2778cfec7eeeSdan if( rc!=SQLITE_OK ){ 2779cfec7eeeSdan goto finished_invert; 2780cfec7eeeSdan } 2781cfec7eeeSdan 278291ddd559Sdan break; 278391ddd559Sdan } 278491ddd559Sdan 278591ddd559Sdan default: 27864757c658Sdan rc = SQLITE_CORRUPT_BKPT; 2787cfec7eeeSdan goto finished_invert; 278891ddd559Sdan } 2789fa122adaSdan 2790fa122adaSdan assert( rc==SQLITE_OK ); 2791fa122adaSdan if( xOutput && sOut.nBuf>=SESSIONS_STR_CHUNK_SIZE ){ 2792fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2793fa122adaSdan sOut.nBuf = 0; 2794fa122adaSdan if( rc!=SQLITE_OK ) goto finished_invert; 2795fa122adaSdan } 279691ddd559Sdan } 279791ddd559Sdan 2798cfec7eeeSdan assert( rc==SQLITE_OK ); 2799fa122adaSdan if( pnInverted ){ 2800fa122adaSdan *pnInverted = sOut.nBuf; 2801fa122adaSdan *ppInverted = sOut.aBuf; 2802fa122adaSdan sOut.aBuf = 0; 2803fa122adaSdan }else if( sOut.nBuf>0 ){ 2804fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2805fa122adaSdan } 2806cfec7eeeSdan 2807cfec7eeeSdan finished_invert: 2808fa122adaSdan sqlite3_free(sOut.aBuf); 2809cfec7eeeSdan sqlite3_free(apVal); 2810ef7a6304Sdan sqlite3_free(sPK.aBuf); 2811cfec7eeeSdan return rc; 281291ddd559Sdan } 281391ddd559Sdan 2814fa122adaSdan 2815fa122adaSdan /* 2816fa122adaSdan ** Invert a changeset object. 2817fa122adaSdan */ 2818fa122adaSdan int sqlite3changeset_invert( 2819fa122adaSdan int nChangeset, /* Number of bytes in input */ 2820fa122adaSdan const void *pChangeset, /* Input changeset */ 2821fa122adaSdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 2822fa122adaSdan void **ppInverted /* OUT: Inverse of pChangeset */ 2823fa122adaSdan ){ 2824fa122adaSdan SessionInput sInput; 2825fa122adaSdan 2826fa122adaSdan /* Set up the input stream */ 2827fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2828fa122adaSdan sInput.nData = nChangeset; 2829fa122adaSdan sInput.aData = (u8*)pChangeset; 2830fa122adaSdan 2831fa122adaSdan return sessionChangesetInvert(&sInput, 0, 0, pnInverted, ppInverted); 2832fa122adaSdan } 2833fa122adaSdan 2834fa122adaSdan /* 2835fa122adaSdan ** Streaming version of sqlite3changeset_invert(). 2836fa122adaSdan */ 2837fa122adaSdan int sqlite3changeset_invert_str( 2838fa122adaSdan int (*xInput)(void *pIn, void *pData, int *pnData), 2839fa122adaSdan void *pIn, 2840fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2841fa122adaSdan void *pOut 2842fa122adaSdan ){ 2843fa122adaSdan SessionInput sInput; 2844fa122adaSdan int rc; 2845fa122adaSdan 2846fa122adaSdan /* Set up the input stream */ 2847fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2848fa122adaSdan sInput.xInput = xInput; 2849fa122adaSdan sInput.pIn = pIn; 2850fa122adaSdan 2851fa122adaSdan rc = sessionChangesetInvert(&sInput, xOutput, pOut, 0, 0); 2852fa122adaSdan sqlite3_free(sInput.buf.aBuf); 2853fa122adaSdan return rc; 2854fa122adaSdan } 2855fa122adaSdan 28560c698471Sdan typedef struct SessionApplyCtx SessionApplyCtx; 28570c698471Sdan struct SessionApplyCtx { 28580c698471Sdan sqlite3 *db; 28590c698471Sdan sqlite3_stmt *pDelete; /* DELETE statement */ 2860cfec7eeeSdan sqlite3_stmt *pUpdate; /* UPDATE statement */ 28610c698471Sdan sqlite3_stmt *pInsert; /* INSERT statement */ 28620c698471Sdan sqlite3_stmt *pSelect; /* SELECT statement */ 28630c698471Sdan int nCol; /* Size of azCol[] and abPK[] arrays */ 28640c698471Sdan const char **azCol; /* Array of column names */ 28650c698471Sdan u8 *abPK; /* Boolean array - true if column is in PK */ 28660c698471Sdan }; 28670c698471Sdan 2868d5f0767cSdan /* 2869d5f0767cSdan ** Formulate a statement to DELETE a row from database db. Assuming a table 2870d5f0767cSdan ** structure like this: 2871d5f0767cSdan ** 2872d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2873d5f0767cSdan ** 2874d5f0767cSdan ** The DELETE statement looks like this: 2875d5f0767cSdan ** 2876db04571cSdan ** DELETE FROM x WHERE a = :1 AND c = :3 AND (:5 OR b IS :2 AND d IS :4) 2877d5f0767cSdan ** 2878d5f0767cSdan ** Variable :5 (nCol+1) is a boolean. It should be set to 0 if we require 2879d5f0767cSdan ** matching b and d values, or 1 otherwise. The second case comes up if the 2880d5f0767cSdan ** conflict handler is invoked with NOTFOUND and returns CHANGESET_REPLACE. 2881296c7658Sdan ** 2882296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pDelete is left 2883296c7658Sdan ** pointing to the prepared version of the SQL statement. 2884d5f0767cSdan */ 2885d5f0767cSdan static int sessionDeleteRow( 2886d5f0767cSdan sqlite3 *db, /* Database handle */ 2887d5f0767cSdan const char *zTab, /* Table name */ 28880c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2889d5f0767cSdan ){ 2890296c7658Sdan int i; 2891296c7658Sdan const char *zSep = ""; 2892d5f0767cSdan int rc = SQLITE_OK; 2893d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 28947cf7df7dSdan int nPk = 0; 2895d5f0767cSdan 2896d5f0767cSdan sessionAppendStr(&buf, "DELETE FROM ", &rc); 2897d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2898296c7658Sdan sessionAppendStr(&buf, " WHERE ", &rc); 2899296c7658Sdan 2900296c7658Sdan for(i=0; i<p->nCol; i++){ 2901296c7658Sdan if( p->abPK[i] ){ 29027cf7df7dSdan nPk++; 2903296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2904296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2905296c7658Sdan sessionAppendStr(&buf, " = ?", &rc); 2906296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2907296c7658Sdan zSep = " AND "; 2908296c7658Sdan } 2909296c7658Sdan } 2910296c7658Sdan 29117cf7df7dSdan if( nPk<p->nCol ){ 2912296c7658Sdan sessionAppendStr(&buf, " AND (?", &rc); 2913296c7658Sdan sessionAppendInteger(&buf, p->nCol+1, &rc); 2914296c7658Sdan sessionAppendStr(&buf, " OR ", &rc); 2915296c7658Sdan 2916296c7658Sdan zSep = ""; 2917296c7658Sdan for(i=0; i<p->nCol; i++){ 2918296c7658Sdan if( !p->abPK[i] ){ 2919296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2920296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2921296c7658Sdan sessionAppendStr(&buf, " IS ?", &rc); 2922296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2923296c7658Sdan zSep = "AND "; 2924296c7658Sdan } 2925296c7658Sdan } 2926296c7658Sdan sessionAppendStr(&buf, ")", &rc); 29277cf7df7dSdan } 2928d5f0767cSdan 2929d5f0767cSdan if( rc==SQLITE_OK ){ 29300c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); 2931d5f0767cSdan } 2932d5f0767cSdan sqlite3_free(buf.aBuf); 2933d5f0767cSdan 2934d5f0767cSdan return rc; 2935d5f0767cSdan } 2936d5f0767cSdan 2937d5f0767cSdan /* 2938d5f0767cSdan ** Formulate and prepare a statement to UPDATE a row from database db. 2939d5f0767cSdan ** Assuming a table structure like this: 2940d5f0767cSdan ** 2941d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2942d5f0767cSdan ** 2943d5f0767cSdan ** The UPDATE statement looks like this: 2944d5f0767cSdan ** 2945d5f0767cSdan ** UPDATE x SET 2946d5f0767cSdan ** a = CASE WHEN ?2 THEN ?3 ELSE a END, 2947964cbd46Sdan ** b = CASE WHEN ?5 THEN ?6 ELSE b END, 2948964cbd46Sdan ** c = CASE WHEN ?8 THEN ?9 ELSE c END, 2949964cbd46Sdan ** d = CASE WHEN ?11 THEN ?12 ELSE d END 2950d5f0767cSdan ** WHERE a = ?1 AND c = ?7 AND (?13 OR 2951964cbd46Sdan ** (?5==0 OR b IS ?4) AND (?11==0 OR d IS ?10) AND 2952d5f0767cSdan ** ) 2953d5f0767cSdan ** 2954d5f0767cSdan ** For each column in the table, there are three variables to bind: 2955d5f0767cSdan ** 2956d5f0767cSdan ** ?(i*3+1) The old.* value of the column, if any. 2957d5f0767cSdan ** ?(i*3+2) A boolean flag indicating that the value is being modified. 2958d5f0767cSdan ** ?(i*3+3) The new.* value of the column, if any. 2959d5f0767cSdan ** 2960d5f0767cSdan ** Also, a boolean flag that, if set to true, causes the statement to update 2961d5f0767cSdan ** a row even if the non-PK values do not match. This is required if the 2962d5f0767cSdan ** conflict-handler is invoked with CHANGESET_DATA and returns 2963d5f0767cSdan ** CHANGESET_REPLACE. This is variable "?(nCol*3+1)". 2964d5f0767cSdan ** 2965296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pUpdate is left 2966296c7658Sdan ** pointing to the prepared version of the SQL statement. 2967d5f0767cSdan */ 2968d5f0767cSdan static int sessionUpdateRow( 2969d5f0767cSdan sqlite3 *db, /* Database handle */ 2970d5f0767cSdan const char *zTab, /* Table name */ 29710c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2972d5f0767cSdan ){ 2973d5f0767cSdan int rc = SQLITE_OK; 2974d5f0767cSdan int i; 2975d5f0767cSdan const char *zSep = ""; 2976d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 2977d5f0767cSdan 2978d5f0767cSdan /* Append "UPDATE tbl SET " */ 2979d5f0767cSdan sessionAppendStr(&buf, "UPDATE ", &rc); 2980d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2981d5f0767cSdan sessionAppendStr(&buf, " SET ", &rc); 2982d5f0767cSdan 2983d5f0767cSdan /* Append the assignments */ 29840c698471Sdan for(i=0; i<p->nCol; i++){ 2985d5f0767cSdan sessionAppendStr(&buf, zSep, &rc); 29860c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2987d5f0767cSdan sessionAppendStr(&buf, " = CASE WHEN ?", &rc); 2988d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 2989d5f0767cSdan sessionAppendStr(&buf, " THEN ?", &rc); 2990d5f0767cSdan sessionAppendInteger(&buf, i*3+3, &rc); 2991d5f0767cSdan sessionAppendStr(&buf, " ELSE ", &rc); 29920c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2993d5f0767cSdan sessionAppendStr(&buf, " END", &rc); 2994d5f0767cSdan zSep = ", "; 2995d5f0767cSdan } 2996d5f0767cSdan 2997d5f0767cSdan /* Append the PK part of the WHERE clause */ 2998d5f0767cSdan sessionAppendStr(&buf, " WHERE ", &rc); 29990c698471Sdan for(i=0; i<p->nCol; i++){ 30000c698471Sdan if( p->abPK[i] ){ 30010c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3002d5f0767cSdan sessionAppendStr(&buf, " = ?", &rc); 3003d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3004d5f0767cSdan sessionAppendStr(&buf, " AND ", &rc); 3005d5f0767cSdan } 3006d5f0767cSdan } 3007d5f0767cSdan 3008d5f0767cSdan /* Append the non-PK part of the WHERE clause */ 3009d5f0767cSdan sessionAppendStr(&buf, " (?", &rc); 30100c698471Sdan sessionAppendInteger(&buf, p->nCol*3+1, &rc); 3011d5f0767cSdan sessionAppendStr(&buf, " OR 1", &rc); 30120c698471Sdan for(i=0; i<p->nCol; i++){ 30130c698471Sdan if( !p->abPK[i] ){ 3014d5f0767cSdan sessionAppendStr(&buf, " AND (?", &rc); 3015d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 3016d5f0767cSdan sessionAppendStr(&buf, "=0 OR ", &rc); 30170c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3018d5f0767cSdan sessionAppendStr(&buf, " IS ?", &rc); 3019d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3020d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3021d5f0767cSdan } 3022d5f0767cSdan } 3023d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3024d5f0767cSdan 3025d5f0767cSdan if( rc==SQLITE_OK ){ 30260c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pUpdate, 0); 3027d5f0767cSdan } 3028d5f0767cSdan sqlite3_free(buf.aBuf); 3029d5f0767cSdan 3030d5f0767cSdan return rc; 3031d5f0767cSdan } 3032d5f0767cSdan 3033296c7658Sdan /* 3034296c7658Sdan ** Formulate and prepare an SQL statement to query table zTab by primary 3035296c7658Sdan ** key. Assuming the following table structure: 3036296c7658Sdan ** 3037296c7658Sdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 3038296c7658Sdan ** 3039296c7658Sdan ** The SELECT statement looks like this: 3040296c7658Sdan ** 3041296c7658Sdan ** SELECT * FROM x WHERE a = ?1 AND c = ?3 3042296c7658Sdan ** 3043296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pSelect is left 3044296c7658Sdan ** pointing to the prepared version of the SQL statement. 3045296c7658Sdan */ 3046d5f0767cSdan static int sessionSelectRow( 3047d5f0767cSdan sqlite3 *db, /* Database handle */ 3048d5f0767cSdan const char *zTab, /* Table name */ 30490c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 3050d5f0767cSdan ){ 3051d7fb7d24Sdan return sessionSelectStmt( 3052d7fb7d24Sdan db, "main", zTab, p->nCol, p->azCol, p->abPK, &p->pSelect); 3053d5f0767cSdan } 3054d5f0767cSdan 3055296c7658Sdan /* 3056296c7658Sdan ** Formulate and prepare an INSERT statement to add a record to table zTab. 3057296c7658Sdan ** For example: 3058296c7658Sdan ** 3059296c7658Sdan ** INSERT INTO main."zTab" VALUES(?1, ?2, ?3 ...); 3060296c7658Sdan ** 3061296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pInsert is left 3062296c7658Sdan ** pointing to the prepared version of the SQL statement. 3063296c7658Sdan */ 30640c698471Sdan static int sessionInsertRow( 30650c698471Sdan sqlite3 *db, /* Database handle */ 30660c698471Sdan const char *zTab, /* Table name */ 30670c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 30680c698471Sdan ){ 30690c698471Sdan int rc = SQLITE_OK; 30700c698471Sdan int i; 30710c698471Sdan SessionBuffer buf = {0, 0, 0}; 30720c698471Sdan 30730c698471Sdan sessionAppendStr(&buf, "INSERT INTO main.", &rc); 30740c698471Sdan sessionAppendIdent(&buf, zTab, &rc); 30750c698471Sdan sessionAppendStr(&buf, " VALUES(?", &rc); 30760c698471Sdan for(i=1; i<p->nCol; i++){ 30770c698471Sdan sessionAppendStr(&buf, ", ?", &rc); 30780c698471Sdan } 30790c698471Sdan sessionAppendStr(&buf, ")", &rc); 30800c698471Sdan 30810c698471Sdan if( rc==SQLITE_OK ){ 30820c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); 30830c698471Sdan } 30840c698471Sdan sqlite3_free(buf.aBuf); 30850c698471Sdan return rc; 30860c698471Sdan } 30870c698471Sdan 3088296c7658Sdan /* 30897aa469cdSdan ** A wrapper around sqlite3_bind_value() that detects an extra problem. 30907aa469cdSdan ** See comments in the body of this function for details. 30917aa469cdSdan */ 30927aa469cdSdan static int sessionBindValue( 30937aa469cdSdan sqlite3_stmt *pStmt, /* Statement to bind value to */ 30947aa469cdSdan int i, /* Parameter number to bind to */ 30957aa469cdSdan sqlite3_value *pVal /* Value to bind */ 30967aa469cdSdan ){ 30975671ef69Sdrh int eType = sqlite3_value_type(pVal); 3098082c96dfSdan /* COVERAGE: The (pVal->z==0) branch is never true using current versions 3099082c96dfSdan ** of SQLite. If a malloc fails in an sqlite3_value_xxx() function, either 3100082c96dfSdan ** the (pVal->z) variable remains as it was or the type of the value is 3101082c96dfSdan ** set to SQLITE_NULL. */ 31025671ef69Sdrh if( (eType==SQLITE_TEXT || eType==SQLITE_BLOB) && pVal->z==0 ){ 31037aa469cdSdan /* This condition occurs when an earlier OOM in a call to 31047aa469cdSdan ** sqlite3_value_text() or sqlite3_value_blob() (perhaps from within 3105082c96dfSdan ** a conflict-handler) has zeroed the pVal->z pointer. Return NOMEM. */ 31067aa469cdSdan return SQLITE_NOMEM; 31077aa469cdSdan } 31087aa469cdSdan return sqlite3_bind_value(pStmt, i, pVal); 31097aa469cdSdan } 31107aa469cdSdan 31117aa469cdSdan /* 3112db04571cSdan ** Iterator pIter must point to an SQLITE_INSERT entry. This function 3113db04571cSdan ** transfers new.* values from the current iterator entry to statement 3114db04571cSdan ** pStmt. The table being inserted into has nCol columns. 3115db04571cSdan ** 3116db04571cSdan ** New.* value $i 0 from the iterator is bound to variable ($i+1) of 3117db04571cSdan ** statement pStmt. If parameter abPK is NULL, all values from 0 to (nCol-1) 3118db04571cSdan ** are transfered to the statement. Otherwise, if abPK is not NULL, it points 3119db04571cSdan ** to an array nCol elements in size. In this case only those values for 3120db04571cSdan ** which abPK[$i] is true are read from the iterator and bound to the 3121db04571cSdan ** statement. 3122db04571cSdan ** 3123db04571cSdan ** An SQLite error code is returned if an error occurs. Otherwise, SQLITE_OK. 3124db04571cSdan */ 31257aa469cdSdan static int sessionBindRow( 3126db04571cSdan sqlite3_changeset_iter *pIter, /* Iterator to read values from */ 31277aa469cdSdan int(*xValue)(sqlite3_changeset_iter *, int, sqlite3_value **), 3128db04571cSdan int nCol, /* Number of columns */ 3129db04571cSdan u8 *abPK, /* If not NULL, bind only if true */ 3130db04571cSdan sqlite3_stmt *pStmt /* Bind values to this statement */ 3131db04571cSdan ){ 3132db04571cSdan int i; 3133db04571cSdan int rc = SQLITE_OK; 31347aa469cdSdan 31357aa469cdSdan /* Neither sqlite3changeset_old or sqlite3changeset_new can fail if the 31367aa469cdSdan ** argument iterator points to a suitable entry. Make sure that xValue 31377aa469cdSdan ** is one of these to guarantee that it is safe to ignore the return 31387aa469cdSdan ** in the code below. */ 31397aa469cdSdan assert( xValue==sqlite3changeset_old || xValue==sqlite3changeset_new ); 31407aa469cdSdan 3141db04571cSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 3142db04571cSdan if( !abPK || abPK[i] ){ 3143db04571cSdan sqlite3_value *pVal; 31447aa469cdSdan (void)xValue(pIter, i, &pVal); 31457aa469cdSdan rc = sessionBindValue(pStmt, i+1, pVal); 3146db04571cSdan } 3147db04571cSdan } 3148db04571cSdan return rc; 3149db04571cSdan } 3150db04571cSdan 3151db04571cSdan /* 3152296c7658Sdan ** SQL statement pSelect is as generated by the sessionSelectRow() function. 3153296c7658Sdan ** This function binds the primary key values from the change that changeset 3154296c7658Sdan ** iterator pIter points to to the SELECT and attempts to seek to the table 3155296c7658Sdan ** entry. If a row is found, the SELECT statement left pointing at the row 3156296c7658Sdan ** and SQLITE_ROW is returned. Otherwise, if no row is found and no error 3157296c7658Sdan ** has occured, the statement is reset and SQLITE_OK is returned. If an 31587aa469cdSdan ** error occurs, the statement is reset and an SQLite error code is returned. 31597aa469cdSdan ** 31607aa469cdSdan ** If this function returns SQLITE_ROW, the caller must eventually reset() 31617aa469cdSdan ** statement pSelect. If any other value is returned, the statement does 31627aa469cdSdan ** not require a reset(). 3163296c7658Sdan ** 3164296c7658Sdan ** If the iterator currently points to an INSERT record, bind values from the 3165db04571cSdan ** new.* record to the SELECT statement. Or, if it points to a DELETE or 3166db04571cSdan ** UPDATE, bind values from the old.* record. 3167296c7658Sdan */ 31680c698471Sdan static int sessionSeekToRow( 316937f133ecSdan sqlite3 *db, /* Database handle */ 317037f133ecSdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 317137f133ecSdan u8 *abPK, /* Primary key flags array */ 31720c698471Sdan sqlite3_stmt *pSelect /* SELECT statement from sessionSelectRow() */ 317337f133ecSdan ){ 31747aa469cdSdan int rc; /* Return code */ 3175296c7658Sdan int nCol; /* Number of columns in table */ 3176296c7658Sdan int op; /* Changset operation (SQLITE_UPDATE etc.) */ 3177296c7658Sdan const char *zDummy; /* Unused */ 317837f133ecSdan 3179b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 31807aa469cdSdan rc = sessionBindRow(pIter, 3181db04571cSdan op==SQLITE_INSERT ? sqlite3changeset_new : sqlite3changeset_old, 3182db04571cSdan nCol, abPK, pSelect 3183db04571cSdan ); 31840c698471Sdan 31850c698471Sdan if( rc==SQLITE_OK ){ 31860c698471Sdan rc = sqlite3_step(pSelect); 31870c698471Sdan if( rc!=SQLITE_ROW ) rc = sqlite3_reset(pSelect); 31880c698471Sdan } 31890c698471Sdan 31900c698471Sdan return rc; 31910c698471Sdan } 31920c698471Sdan 3193296c7658Sdan /* 3194296c7658Sdan ** Invoke the conflict handler for the change that the changeset iterator 3195296c7658Sdan ** currently points to. 3196296c7658Sdan ** 3197296c7658Sdan ** Argument eType must be either CHANGESET_DATA or CHANGESET_CONFLICT. 3198296c7658Sdan ** If argument pbReplace is NULL, then the type of conflict handler invoked 3199296c7658Sdan ** depends solely on eType, as follows: 3200296c7658Sdan ** 3201296c7658Sdan ** eType value Value passed to xConflict 3202296c7658Sdan ** ------------------------------------------------- 3203296c7658Sdan ** CHANGESET_DATA CHANGESET_NOTFOUND 3204296c7658Sdan ** CHANGESET_CONFLICT CHANGESET_CONSTRAINT 3205296c7658Sdan ** 3206296c7658Sdan ** Or, if pbReplace is not NULL, then an attempt is made to find an existing 3207296c7658Sdan ** record with the same primary key as the record about to be deleted, updated 3208296c7658Sdan ** or inserted. If such a record can be found, it is available to the conflict 3209296c7658Sdan ** handler as the "conflicting" record. In this case the type of conflict 3210296c7658Sdan ** handler invoked is as follows: 3211296c7658Sdan ** 3212296c7658Sdan ** eType value PK Record found? Value passed to xConflict 3213296c7658Sdan ** ---------------------------------------------------------------- 3214296c7658Sdan ** CHANGESET_DATA Yes CHANGESET_DATA 3215296c7658Sdan ** CHANGESET_DATA No CHANGESET_NOTFOUND 3216296c7658Sdan ** CHANGESET_CONFLICT Yes CHANGESET_CONFLICT 3217296c7658Sdan ** CHANGESET_CONFLICT No CHANGESET_CONSTRAINT 3218296c7658Sdan ** 3219296c7658Sdan ** If pbReplace is not NULL, and a record with a matching PK is found, and 3220296c7658Sdan ** the conflict handler function returns SQLITE_CHANGESET_REPLACE, *pbReplace 3221296c7658Sdan ** is set to non-zero before returning SQLITE_OK. 3222296c7658Sdan ** 3223296c7658Sdan ** If the conflict handler returns SQLITE_CHANGESET_ABORT, SQLITE_ABORT is 3224296c7658Sdan ** returned. Or, if the conflict handler returns an invalid value, 3225296c7658Sdan ** SQLITE_MISUSE. If the conflict handler returns SQLITE_CHANGESET_OMIT, 3226296c7658Sdan ** this function returns SQLITE_OK. 3227296c7658Sdan */ 32280c698471Sdan static int sessionConflictHandler( 3229296c7658Sdan int eType, /* Either CHANGESET_DATA or CONFLICT */ 3230296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 32310c698471Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 32320c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter*), 3233296c7658Sdan void *pCtx, /* First argument for conflict handler */ 3234296c7658Sdan int *pbReplace /* OUT: Set to true if PK row is found */ 32350c698471Sdan ){ 3236296c7658Sdan int res; /* Value returned by conflict handler */ 32370c698471Sdan int rc; 32380c698471Sdan int nCol; 32390c698471Sdan int op; 32400c698471Sdan const char *zDummy; 32410c698471Sdan 3242b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 32430c698471Sdan 32440c698471Sdan assert( eType==SQLITE_CHANGESET_CONFLICT || eType==SQLITE_CHANGESET_DATA ); 32450c698471Sdan assert( SQLITE_CHANGESET_CONFLICT+1==SQLITE_CHANGESET_CONSTRAINT ); 32460c698471Sdan assert( SQLITE_CHANGESET_DATA+1==SQLITE_CHANGESET_NOTFOUND ); 324737f133ecSdan 324837f133ecSdan /* Bind the new.* PRIMARY KEY values to the SELECT statement. */ 32490c698471Sdan if( pbReplace ){ 32500c698471Sdan rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); 32510c698471Sdan }else{ 3252db04571cSdan rc = SQLITE_OK; 32530c698471Sdan } 32540c698471Sdan 32550c698471Sdan if( rc==SQLITE_ROW ){ 32560c698471Sdan /* There exists another row with the new.* primary key. */ 32570c698471Sdan pIter->pConflict = p->pSelect; 32580c698471Sdan res = xConflict(pCtx, eType, pIter); 32590c698471Sdan pIter->pConflict = 0; 32600c698471Sdan rc = sqlite3_reset(p->pSelect); 3261db04571cSdan }else if( rc==SQLITE_OK ){ 32620c698471Sdan /* No other row with the new.* primary key. */ 32630c698471Sdan res = xConflict(pCtx, eType+1, pIter); 32640c698471Sdan if( res==SQLITE_CHANGESET_REPLACE ) rc = SQLITE_MISUSE; 326537f133ecSdan } 326637f133ecSdan 326737f133ecSdan if( rc==SQLITE_OK ){ 32680c698471Sdan switch( res ){ 32690c698471Sdan case SQLITE_CHANGESET_REPLACE: 3270f51e5f6cSdan assert( pbReplace ); 3271f51e5f6cSdan *pbReplace = 1; 32720c698471Sdan break; 32730c698471Sdan 32740c698471Sdan case SQLITE_CHANGESET_OMIT: 32750c698471Sdan break; 32760c698471Sdan 32770c698471Sdan case SQLITE_CHANGESET_ABORT: 32780c698471Sdan rc = SQLITE_ABORT; 32790c698471Sdan break; 32800c698471Sdan 32810c698471Sdan default: 32820c698471Sdan rc = SQLITE_MISUSE; 32830c698471Sdan break; 32840c698471Sdan } 32850c698471Sdan } 32860c698471Sdan 32870c698471Sdan return rc; 32880c698471Sdan } 32890c698471Sdan 3290296c7658Sdan /* 3291296c7658Sdan ** Attempt to apply the change that the iterator passed as the first argument 3292296c7658Sdan ** currently points to to the database. If a conflict is encountered, invoke 3293296c7658Sdan ** the conflict handler callback. 3294296c7658Sdan ** 3295296c7658Sdan ** If argument pbRetry is NULL, then ignore any CHANGESET_DATA conflict. If 3296296c7658Sdan ** one is encountered, update or delete the row with the matching primary key 3297296c7658Sdan ** instead. Or, if pbRetry is not NULL and a CHANGESET_DATA conflict occurs, 3298296c7658Sdan ** invoke the conflict handler. If it returns CHANGESET_REPLACE, set *pbRetry 3299296c7658Sdan ** to true before returning. In this case the caller will invoke this function 3300296c7658Sdan ** again, this time with pbRetry set to NULL. 3301296c7658Sdan ** 3302296c7658Sdan ** If argument pbReplace is NULL and a CHANGESET_CONFLICT conflict is 3303296c7658Sdan ** encountered invoke the conflict handler with CHANGESET_CONSTRAINT instead. 3304296c7658Sdan ** Or, if pbReplace is not NULL, invoke it with CHANGESET_CONFLICT. If such 3305296c7658Sdan ** an invocation returns SQLITE_CHANGESET_REPLACE, set *pbReplace to true 3306296c7658Sdan ** before retrying. In this case the caller attempts to remove the conflicting 3307296c7658Sdan ** row before invoking this function again, this time with pbReplace set 3308296c7658Sdan ** to NULL. 3309296c7658Sdan ** 3310296c7658Sdan ** If any conflict handler returns SQLITE_CHANGESET_ABORT, this function 3311296c7658Sdan ** returns SQLITE_ABORT. Otherwise, if no error occurs, SQLITE_OK is 3312296c7658Sdan ** returned. 3313296c7658Sdan */ 33140c698471Sdan static int sessionApplyOneOp( 3315296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 3316296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 33170c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter *), 3318296c7658Sdan void *pCtx, /* First argument for the conflict handler */ 3319296c7658Sdan int *pbReplace, /* OUT: True to remove PK row and retry */ 3320296c7658Sdan int *pbRetry /* OUT: True to retry. */ 33210c698471Sdan ){ 33220c698471Sdan const char *zDummy; 33230c698471Sdan int op; 33240c698471Sdan int nCol; 33250c698471Sdan int rc = SQLITE_OK; 33260c698471Sdan 33270c698471Sdan assert( p->pDelete && p->pUpdate && p->pInsert && p->pSelect ); 33280c698471Sdan assert( p->azCol && p->abPK ); 33290c698471Sdan assert( !pbReplace || *pbReplace==0 ); 33300c698471Sdan 3331b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 33320c698471Sdan 33330c698471Sdan if( op==SQLITE_DELETE ){ 33340c698471Sdan 333573b3c055Sdan /* Bind values to the DELETE statement. If conflict handling is required, 333673b3c055Sdan ** bind values for all columns and set bound variable (nCol+1) to true. 333773b3c055Sdan ** Or, if conflict handling is not required, bind just the PK column 333873b3c055Sdan ** values and, if it exists, set (nCol+1) to false. Conflict handling 333973b3c055Sdan ** is not required if: 334073b3c055Sdan ** 334173b3c055Sdan ** * this is a patchset, or 334273b3c055Sdan ** * (pbRetry==0), or 334373b3c055Sdan ** * all columns of the table are PK columns (in this case there is 334473b3c055Sdan ** no (nCol+1) variable to bind to). 334573b3c055Sdan */ 334673b3c055Sdan u8 *abPK = (pIter->bPatchset ? p->abPK : 0); 334773b3c055Sdan rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); 33487cf7df7dSdan if( rc==SQLITE_OK && sqlite3_bind_parameter_count(p->pDelete)>nCol ){ 334973b3c055Sdan rc = sqlite3_bind_int(p->pDelete, nCol+1, (pbRetry==0 || abPK)); 33507cf7df7dSdan } 33510c698471Sdan if( rc!=SQLITE_OK ) return rc; 33520c698471Sdan 33530c698471Sdan sqlite3_step(p->pDelete); 33540c698471Sdan rc = sqlite3_reset(p->pDelete); 33550c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 33560c698471Sdan rc = sessionConflictHandler( 33570c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 33580c698471Sdan ); 335935e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 33600c698471Sdan rc = sessionConflictHandler( 33610c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 33620c698471Sdan ); 33630c698471Sdan } 33640c698471Sdan 33650c698471Sdan }else if( op==SQLITE_UPDATE ){ 33660c698471Sdan int i; 33670c698471Sdan 33680c698471Sdan /* Bind values to the UPDATE statement. */ 33690c698471Sdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 33707aa469cdSdan sqlite3_value *pOld = sessionChangesetOld(pIter, i); 33717aa469cdSdan sqlite3_value *pNew = sessionChangesetNew(pIter, i); 33727aa469cdSdan 33730c698471Sdan sqlite3_bind_int(p->pUpdate, i*3+2, !!pNew); 33747aa469cdSdan if( pOld ){ 33757aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+1, pOld); 33767aa469cdSdan } 33777aa469cdSdan if( rc==SQLITE_OK && pNew ){ 33787aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+3, pNew); 33790c698471Sdan } 33800c698471Sdan } 338173b3c055Sdan if( rc==SQLITE_OK ){ 338273b3c055Sdan sqlite3_bind_int(p->pUpdate, nCol*3+1, pbRetry==0 || pIter->bPatchset); 338373b3c055Sdan } 33840c698471Sdan if( rc!=SQLITE_OK ) return rc; 33850c698471Sdan 33860c698471Sdan /* Attempt the UPDATE. In the case of a NOTFOUND or DATA conflict, 33870c698471Sdan ** the result will be SQLITE_OK with 0 rows modified. */ 33880c698471Sdan sqlite3_step(p->pUpdate); 33890c698471Sdan rc = sqlite3_reset(p->pUpdate); 33900c698471Sdan 33910c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 33920c698471Sdan /* A NOTFOUND or DATA error. Search the table to see if it contains 33930c698471Sdan ** a row with a matching primary key. If so, this is a DATA conflict. 33940c698471Sdan ** Otherwise, if there is no primary key match, it is a NOTFOUND. */ 33950c698471Sdan 33960c698471Sdan rc = sessionConflictHandler( 33970c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 33980c698471Sdan ); 33990c698471Sdan 340035e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 3401db04571cSdan /* This is always a CONSTRAINT conflict. */ 3402db04571cSdan rc = sessionConflictHandler( 3403db04571cSdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 34040c698471Sdan ); 34050c698471Sdan } 34060c698471Sdan 34070c698471Sdan }else{ 34080c698471Sdan assert( op==SQLITE_INSERT ); 34097aa469cdSdan rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); 34100c698471Sdan if( rc!=SQLITE_OK ) return rc; 34110c698471Sdan 34120c698471Sdan sqlite3_step(p->pInsert); 34130c698471Sdan rc = sqlite3_reset(p->pInsert); 341435e2858eSdan if( (rc&0xff)==SQLITE_CONSTRAINT ){ 34150c698471Sdan rc = sessionConflictHandler( 34160c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, pbReplace 34170c698471Sdan ); 341837f133ecSdan } 341937f133ecSdan } 342037f133ecSdan 342137f133ecSdan return rc; 342237f133ecSdan } 342337f133ecSdan 3424296c7658Sdan /* 34254757c658Sdan ** Argument pIter is a changeset iterator that has been initialized, but 34264757c658Sdan ** not yet passed to sqlite3changeset_next(). This function applies the 34274757c658Sdan ** changeset to the main database attached to handle "db". The supplied 34284757c658Sdan ** conflict handler callback is invoked to resolve any conflicts encountered 34294757c658Sdan ** while applying the change. 3430296c7658Sdan */ 34314757c658Sdan static int sessionChangesetApply( 3432296c7658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 34334757c658Sdan sqlite3_changeset_iter *pIter, /* Changeset to apply */ 343440368988Sdan int(*xFilter)( 343540368988Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 343640368988Sdan const char *zTab /* Table name */ 343740368988Sdan ), 3438d5f0767cSdan int(*xConflict)( 3439d5f0767cSdan void *pCtx, /* Copy of fifth arg to _apply() */ 3440d5f0767cSdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 3441d5f0767cSdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 3442d5f0767cSdan ), 3443296c7658Sdan void *pCtx /* First argument passed to xConflict */ 3444d5f0767cSdan ){ 3445ca62ad57Sdan int schemaMismatch = 0; 3446296c7658Sdan int rc; /* Return code */ 3447d5f0767cSdan const char *zTab = 0; /* Name of current table */ 3448cfdbde21Sdrh int nTab = 0; /* Result of sqlite3Strlen30(zTab) */ 3449296c7658Sdan SessionApplyCtx sApply; /* changeset_apply() context object */ 3450d5f0767cSdan 3451082c96dfSdan assert( xConflict!=0 ); 3452082c96dfSdan 34530c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34544c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 34550c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT changeset_apply", 0, 0, 0); 3456cb3e4b79Sdan if( rc==SQLITE_OK ){ 3457cb3e4b79Sdan rc = sqlite3_exec(db, "PRAGMA defer_foreign_keys = 1", 0, 0, 0); 3458cb3e4b79Sdan } 34590c698471Sdan while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter) ){ 34600c698471Sdan int nCol; 3461d5f0767cSdan int op; 34620c698471Sdan int bReplace = 0; 34630c698471Sdan int bRetry = 0; 34640c698471Sdan const char *zNew; 3465ca62ad57Sdan 3466b4480e94Sdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); 3467d5f0767cSdan 34680c698471Sdan if( zTab==0 || sqlite3_strnicmp(zNew, zTab, nTab+1) ){ 3469ca62ad57Sdan u8 *abPK; 3470ca62ad57Sdan 3471cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 34720c698471Sdan sqlite3_finalize(sApply.pDelete); 34730c698471Sdan sqlite3_finalize(sApply.pUpdate); 34740c698471Sdan sqlite3_finalize(sApply.pInsert); 34750c698471Sdan sqlite3_finalize(sApply.pSelect); 34760c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34770c698471Sdan sApply.db = db; 347837f133ecSdan 347940368988Sdan /* If an xFilter() callback was specified, invoke it now. If the 348040368988Sdan ** xFilter callback returns zero, skip this table. If it returns 348140368988Sdan ** non-zero, proceed. */ 348240368988Sdan schemaMismatch = (xFilter && (0==xFilter(pCtx, zNew))); 348340368988Sdan if( schemaMismatch ){ 348440368988Sdan zTab = sqlite3_mprintf("%s", zNew); 34854f528042Sdan nTab = (int)strlen(zTab); 348640368988Sdan sApply.azCol = (const char **)zTab; 348740368988Sdan }else{ 3488ca62ad57Sdan sqlite3changeset_pk(pIter, &abPK, 0); 3489296c7658Sdan rc = sessionTableInfo( 3490ca62ad57Sdan db, "main", zNew, &sApply.nCol, &zTab, &sApply.azCol, &sApply.abPK 3491ca62ad57Sdan ); 3492ca62ad57Sdan if( rc!=SQLITE_OK ) break; 34930c698471Sdan 3494ca62ad57Sdan if( sApply.nCol==0 ){ 3495ca62ad57Sdan schemaMismatch = 1; 3496ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3497ca62ad57Sdan "sqlite3changeset_apply(): no such table: %s", zTab 3498ca62ad57Sdan ); 3499ca62ad57Sdan } 3500ca62ad57Sdan else if( sApply.nCol!=nCol ){ 3501ca62ad57Sdan schemaMismatch = 1; 3502ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3503ca62ad57Sdan "sqlite3changeset_apply(): table %s has %d columns, expected %d", 3504ca62ad57Sdan zTab, sApply.nCol, nCol 3505ca62ad57Sdan ); 3506ca62ad57Sdan } 3507ca62ad57Sdan else if( memcmp(sApply.abPK, abPK, nCol)!=0 ){ 3508ca62ad57Sdan schemaMismatch = 1; 350940368988Sdan sqlite3_log(SQLITE_SCHEMA, "sqlite3changeset_apply(): " 351040368988Sdan "primary key mismatch for table %s", zTab 3511ca62ad57Sdan ); 3512ca62ad57Sdan } 3513ca62ad57Sdan else if( 3514ca62ad57Sdan (rc = sessionSelectRow(db, zTab, &sApply)) 35150c698471Sdan || (rc = sessionUpdateRow(db, zTab, &sApply)) 35160c698471Sdan || (rc = sessionDeleteRow(db, zTab, &sApply)) 35170c698471Sdan || (rc = sessionInsertRow(db, zTab, &sApply)) 351837f133ecSdan ){ 351937f133ecSdan break; 352037f133ecSdan } 3521cfdbde21Sdrh nTab = sqlite3Strlen30(zTab); 3522d5f0767cSdan } 352340368988Sdan } 3524d5f0767cSdan 3525ca62ad57Sdan /* If there is a schema mismatch on the current table, proceed to the 3526ca62ad57Sdan ** next change. A log message has already been issued. */ 3527ca62ad57Sdan if( schemaMismatch ) continue; 3528ca62ad57Sdan 35290c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, &bRetry); 35300c698471Sdan 35310c698471Sdan if( rc==SQLITE_OK && bRetry ){ 35320c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, 0); 35330c698471Sdan } 35340c698471Sdan 35350c698471Sdan if( bReplace ){ 3536db04571cSdan assert( pIter->op==SQLITE_INSERT ); 35370c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT replace_op", 0, 0, 0); 35380c698471Sdan if( rc==SQLITE_OK ){ 35397aa469cdSdan rc = sessionBindRow(pIter, 3540db04571cSdan sqlite3changeset_new, sApply.nCol, sApply.abPK, sApply.pDelete); 35410c698471Sdan sqlite3_bind_int(sApply.pDelete, sApply.nCol+1, 1); 35420c698471Sdan } 35430c698471Sdan if( rc==SQLITE_OK ){ 35440c698471Sdan sqlite3_step(sApply.pDelete); 35450c698471Sdan rc = sqlite3_reset(sApply.pDelete); 35460c698471Sdan } 35470c698471Sdan if( rc==SQLITE_OK ){ 35480c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, 0, 0); 35490c698471Sdan } 35500c698471Sdan if( rc==SQLITE_OK ){ 35510c698471Sdan rc = sqlite3_exec(db, "RELEASE replace_op", 0, 0, 0); 35520c698471Sdan } 35530c698471Sdan } 35540c698471Sdan } 3555d5f0767cSdan 3556296c7658Sdan if( rc==SQLITE_OK ){ 3557296c7658Sdan rc = sqlite3changeset_finalize(pIter); 3558296c7658Sdan }else{ 3559296c7658Sdan sqlite3changeset_finalize(pIter); 3560296c7658Sdan } 3561d5f0767cSdan 3562d5f0767cSdan if( rc==SQLITE_OK ){ 356307001c45Sdrh int nFk, notUsed; 356407001c45Sdrh sqlite3_db_status(db, SQLITE_DBSTATUS_DEFERRED_FKS, &nFk, ¬Used, 0); 356507001c45Sdrh if( nFk!=0 ){ 3566cb3e4b79Sdan int res = SQLITE_CHANGESET_ABORT; 3567cb3e4b79Sdan sqlite3_changeset_iter sIter; 3568cb3e4b79Sdan memset(&sIter, 0, sizeof(sIter)); 3569cb3e4b79Sdan sIter.nCol = nFk; 3570cb3e4b79Sdan res = xConflict(pCtx, SQLITE_CHANGESET_FOREIGN_KEY, &sIter); 3571cb3e4b79Sdan if( res!=SQLITE_CHANGESET_OMIT ){ 3572cb3e4b79Sdan rc = SQLITE_CONSTRAINT; 3573cb3e4b79Sdan } 3574cb3e4b79Sdan } 3575cb3e4b79Sdan } 3576cb3e4b79Sdan sqlite3_exec(db, "PRAGMA defer_foreign_keys = 0", 0, 0, 0); 3577cb3e4b79Sdan 3578cb3e4b79Sdan if( rc==SQLITE_OK ){ 3579d5f0767cSdan rc = sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3580d5f0767cSdan }else{ 3581d5f0767cSdan sqlite3_exec(db, "ROLLBACK TO changeset_apply", 0, 0, 0); 3582d5f0767cSdan sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3583d5f0767cSdan } 3584d5f0767cSdan 35850c698471Sdan sqlite3_finalize(sApply.pInsert); 35860c698471Sdan sqlite3_finalize(sApply.pDelete); 35870c698471Sdan sqlite3_finalize(sApply.pUpdate); 35880c698471Sdan sqlite3_finalize(sApply.pSelect); 3589cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 35904c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 3591d5f0767cSdan return rc; 3592d5f0767cSdan } 359391ddd559Sdan 359477fc1d5bSdan /* 35954757c658Sdan ** Apply the changeset passed via pChangeset/nChangeset to the main database 35964757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 35974757c658Sdan ** to resolve any conflicts encountered while applying the change. 35984757c658Sdan */ 35994757c658Sdan int sqlite3changeset_apply( 36004757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 36014757c658Sdan int nChangeset, /* Size of changeset in bytes */ 36024757c658Sdan void *pChangeset, /* Changeset blob */ 36034757c658Sdan int(*xFilter)( 36044757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36054757c658Sdan const char *zTab /* Table name */ 36064757c658Sdan ), 36074757c658Sdan int(*xConflict)( 36084757c658Sdan void *pCtx, /* Copy of fifth arg to _apply() */ 36094757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36104757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36114757c658Sdan ), 36124757c658Sdan void *pCtx /* First argument passed to xConflict */ 36134757c658Sdan ){ 36144757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 36154757c658Sdan int rc = sqlite3changeset_start(&pIter, nChangeset, pChangeset); 36164757c658Sdan if( rc==SQLITE_OK ){ 36174757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36184757c658Sdan } 36194757c658Sdan return rc; 36204757c658Sdan } 36214757c658Sdan 36224757c658Sdan /* 36234757c658Sdan ** Apply the changeset passed via xInput/pIn to the main database 36244757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 36254757c658Sdan ** to resolve any conflicts encountered while applying the change. 36264757c658Sdan */ 36274757c658Sdan int sqlite3changeset_apply_str( 36284757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 36294757c658Sdan int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */ 36304757c658Sdan void *pIn, /* First arg for xInput */ 36314757c658Sdan int(*xFilter)( 36324757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36334757c658Sdan const char *zTab /* Table name */ 36344757c658Sdan ), 36354757c658Sdan int(*xConflict)( 36364757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36374757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36384757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36394757c658Sdan ), 36404757c658Sdan void *pCtx /* First argument passed to xConflict */ 36414757c658Sdan ){ 36424757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 36434757c658Sdan int rc = sqlite3changeset_start_str(&pIter, xInput, pIn); 36444757c658Sdan if( rc==SQLITE_OK ){ 36454757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36464757c658Sdan } 36474757c658Sdan return rc; 36484757c658Sdan } 36494757c658Sdan 36504757c658Sdan /* 365177fc1d5bSdan ** This function is called to merge two changes to the same row together as 365277fc1d5bSdan ** part of an sqlite3changeset_concat() operation. A new change object is 365377fc1d5bSdan ** allocated and a pointer to it stored in *ppNew. 365477fc1d5bSdan */ 36555d607a6eSdan static int sessionChangeMerge( 365677fc1d5bSdan SessionTable *pTab, /* Table structure */ 365764277f4aSdan int bPatchset, /* True for patchsets */ 365877fc1d5bSdan SessionChange *pExist, /* Existing change */ 365977fc1d5bSdan int op2, /* Second change operation */ 366077fc1d5bSdan int bIndirect, /* True if second change is indirect */ 366177fc1d5bSdan u8 *aRec, /* Second change record */ 366277fc1d5bSdan int nRec, /* Number of bytes in aRec */ 366377fc1d5bSdan SessionChange **ppNew /* OUT: Merged change */ 36645d607a6eSdan ){ 36655d607a6eSdan SessionChange *pNew = 0; 36665d607a6eSdan 36675d607a6eSdan if( !pExist ){ 3668cbf6d2d2Sdan pNew = (SessionChange *)sqlite3_malloc(sizeof(SessionChange) + nRec); 36695d607a6eSdan if( !pNew ){ 36705d607a6eSdan return SQLITE_NOMEM; 36715d607a6eSdan } 36725d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 3673798693b2Sdan pNew->op = op2; 36745d607a6eSdan pNew->bIndirect = bIndirect; 36755d607a6eSdan pNew->nRecord = nRec; 3676cbf6d2d2Sdan pNew->aRecord = (u8*)&pNew[1]; 3677cbf6d2d2Sdan memcpy(pNew->aRecord, aRec, nRec); 36785d607a6eSdan }else{ 3679798693b2Sdan int op1 = pExist->op; 36805d607a6eSdan 36815d607a6eSdan /* 36825d607a6eSdan ** op1=INSERT, op2=INSERT -> Unsupported. Discard op2. 36835d607a6eSdan ** op1=INSERT, op2=UPDATE -> INSERT. 36845d607a6eSdan ** op1=INSERT, op2=DELETE -> (none) 36855d607a6eSdan ** 36865d607a6eSdan ** op1=UPDATE, op2=INSERT -> Unsupported. Discard op2. 36875d607a6eSdan ** op1=UPDATE, op2=UPDATE -> UPDATE. 36885d607a6eSdan ** op1=UPDATE, op2=DELETE -> DELETE. 36895d607a6eSdan ** 36905d607a6eSdan ** op1=DELETE, op2=INSERT -> UPDATE. 36915d607a6eSdan ** op1=DELETE, op2=UPDATE -> Unsupported. Discard op2. 36925d607a6eSdan ** op1=DELETE, op2=DELETE -> Unsupported. Discard op2. 36935d607a6eSdan */ 36945d607a6eSdan if( (op1==SQLITE_INSERT && op2==SQLITE_INSERT) 36955d607a6eSdan || (op1==SQLITE_UPDATE && op2==SQLITE_INSERT) 36965d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_UPDATE) 36975d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_DELETE) 36985d607a6eSdan ){ 36995d607a6eSdan pNew = pExist; 37005d607a6eSdan }else if( op1==SQLITE_INSERT && op2==SQLITE_DELETE ){ 37015d607a6eSdan sqlite3_free(pExist); 37025d607a6eSdan assert( pNew==0 ); 37035d607a6eSdan }else{ 370464277f4aSdan u8 *aExist = pExist->aRecord; 37055d607a6eSdan int nByte; 37065d607a6eSdan u8 *aCsr; 37075d607a6eSdan 370864277f4aSdan /* Allocate a new SessionChange object. Ensure that the aRecord[] 370964277f4aSdan ** buffer of the new object is large enough to hold any record that 371064277f4aSdan ** may be generated by combining the input records. */ 37115d607a6eSdan nByte = sizeof(SessionChange) + pExist->nRecord + nRec; 37125d607a6eSdan pNew = (SessionChange *)sqlite3_malloc(nByte); 37135d607a6eSdan if( !pNew ){ 37141756ae10Sdan sqlite3_free(pExist); 37155d607a6eSdan return SQLITE_NOMEM; 37165d607a6eSdan } 37175d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 37185d607a6eSdan pNew->bIndirect = (bIndirect && pExist->bIndirect); 37195d607a6eSdan aCsr = pNew->aRecord = (u8 *)&pNew[1]; 37205d607a6eSdan 3721b08a1efaSdan if( op1==SQLITE_INSERT ){ /* INSERT + UPDATE */ 37225d607a6eSdan u8 *a1 = aRec; 3723b08a1efaSdan assert( op2==SQLITE_UPDATE ); 3724798693b2Sdan pNew->op = SQLITE_INSERT; 3725ef7a6304Sdan if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); 372664277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aExist, a1); 3727b08a1efaSdan }else if( op1==SQLITE_DELETE ){ /* DELETE + INSERT */ 3728b08a1efaSdan assert( op2==SQLITE_INSERT ); 3729798693b2Sdan pNew->op = SQLITE_UPDATE; 3730*fa29ecc4Sdan if( bPatchset ){ 3731*fa29ecc4Sdan memcpy(aCsr, aRec, nRec); 3732*fa29ecc4Sdan aCsr += nRec; 3733*fa29ecc4Sdan }else{ 373464277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aExist, 0,aRec,0) ){ 3735b08a1efaSdan sqlite3_free(pNew); 3736b08a1efaSdan pNew = 0; 37375d607a6eSdan } 3738*fa29ecc4Sdan } 3739b08a1efaSdan }else if( op2==SQLITE_UPDATE ){ /* UPDATE + UPDATE */ 374064277f4aSdan u8 *a1 = aExist; 37415d607a6eSdan u8 *a2 = aRec; 3742cfec7eeeSdan assert( op1==SQLITE_UPDATE ); 374364277f4aSdan if( bPatchset==0 ){ 3744ef7a6304Sdan sessionSkipRecord(&a1, pTab->nCol); 3745ef7a6304Sdan sessionSkipRecord(&a2, pTab->nCol); 374664277f4aSdan } 3747798693b2Sdan pNew->op = SQLITE_UPDATE; 374864277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aRec, aExist,a1,a2) ){ 37495d607a6eSdan sqlite3_free(pNew); 37505d607a6eSdan pNew = 0; 37515d607a6eSdan } 3752b08a1efaSdan }else{ /* UPDATE + DELETE */ 3753b08a1efaSdan assert( op1==SQLITE_UPDATE && op2==SQLITE_DELETE ); 3754798693b2Sdan pNew->op = SQLITE_DELETE; 375564277f4aSdan if( bPatchset ){ 375664277f4aSdan memcpy(aCsr, aRec, nRec); 375764277f4aSdan aCsr += nRec; 375864277f4aSdan }else{ 375964277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aRec, aExist); 376064277f4aSdan } 37615d607a6eSdan } 37625d607a6eSdan 37635d607a6eSdan if( pNew ){ 37644f528042Sdan pNew->nRecord = (int)(aCsr - pNew->aRecord); 37655d607a6eSdan } 37665d607a6eSdan sqlite3_free(pExist); 37675d607a6eSdan } 37685d607a6eSdan } 37695d607a6eSdan 37705d607a6eSdan *ppNew = pNew; 37715d607a6eSdan return SQLITE_OK; 37725d607a6eSdan } 37735d607a6eSdan 377477fc1d5bSdan /* 377577fc1d5bSdan ** Add all changes in the changeset passed via the first two arguments to 377677fc1d5bSdan ** hash tables. 377777fc1d5bSdan */ 3778cbf6d2d2Sdan static int sessionAddChangeset( 3779cbf6d2d2Sdan sqlite3_changeset_iter *pIter, /* Iterator to read from */ 378077fc1d5bSdan SessionTable **ppTabList /* IN/OUT: List of table objects */ 37815d607a6eSdan ){ 37825d607a6eSdan u8 *aRec; 37835d607a6eSdan int nRec; 3784cbf6d2d2Sdan int rc = SQLITE_OK; 37855d607a6eSdan SessionTable *pTab = 0; 37865d607a6eSdan 37875d607a6eSdan while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec) ){ 37885d607a6eSdan const char *zNew; 37895d607a6eSdan int nCol; 37905d607a6eSdan int op; 37915d607a6eSdan int iHash; 37925d607a6eSdan int bIndirect; 37935d607a6eSdan SessionChange *pChange; 37945d607a6eSdan SessionChange *pExist = 0; 37955d607a6eSdan SessionChange **pp; 37965d607a6eSdan 3797cbf6d2d2Sdan #if 0 379864277f4aSdan assert( bPatchset==0 || bPatchset==1 ); 379964277f4aSdan assert( pIter->bPatchset==0 || pIter->bPatchset==1 ); 380064277f4aSdan if( pIter->bPatchset!=bPatchset ){ 380164277f4aSdan rc = SQLITE_ERROR; 380264277f4aSdan break; 380364277f4aSdan } 3804cbf6d2d2Sdan #endif 380564277f4aSdan 38065d607a6eSdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); 3807ef7a6304Sdan if( !pTab || sqlite3_stricmp(zNew, pTab->zName) ){ 38085d607a6eSdan /* Search the list for a matching table */ 38094f528042Sdan int nNew = (int)strlen(zNew); 3810f29123b5Sdan u8 *abPK; 3811f29123b5Sdan 3812f29123b5Sdan sqlite3changeset_pk(pIter, &abPK, 0); 38135d607a6eSdan for(pTab = *ppTabList; pTab; pTab=pTab->pNext){ 38145d607a6eSdan if( 0==sqlite3_strnicmp(pTab->zName, zNew, nNew+1) ) break; 38155d607a6eSdan } 38165d607a6eSdan if( !pTab ){ 3817ef7a6304Sdan pTab = sqlite3_malloc(sizeof(SessionTable) + nCol + nNew+1); 3818f29123b5Sdan if( !pTab ){ 3819f29123b5Sdan rc = SQLITE_NOMEM; 3820f29123b5Sdan break; 3821f29123b5Sdan } 38225d607a6eSdan memset(pTab, 0, sizeof(SessionTable)); 38235d607a6eSdan pTab->pNext = *ppTabList; 3824f29123b5Sdan pTab->nCol = nCol; 3825ef7a6304Sdan pTab->abPK = (u8*)&pTab[1]; 3826ef7a6304Sdan memcpy(pTab->abPK, abPK, nCol); 3827ef7a6304Sdan pTab->zName = (char*)&pTab->abPK[nCol]; 3828ef7a6304Sdan memcpy(pTab->zName, zNew, nNew+1); 38295d607a6eSdan *ppTabList = pTab; 3830f29123b5Sdan }else if( pTab->nCol!=nCol || memcmp(pTab->abPK, abPK, nCol) ){ 3831f29123b5Sdan rc = SQLITE_SCHEMA; 3832f29123b5Sdan break; 38335d607a6eSdan } 38345d607a6eSdan } 38355d607a6eSdan 3836cbf6d2d2Sdan if( sessionGrowHash(pIter->bPatchset, pTab) ){ 38371756ae10Sdan rc = SQLITE_NOMEM; 38381756ae10Sdan break; 38391756ae10Sdan } 384064277f4aSdan iHash = sessionChangeHash( 3841cbf6d2d2Sdan pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange 384264277f4aSdan ); 38435d607a6eSdan 38445d607a6eSdan /* Search for existing entry. If found, remove it from the hash table. 38455d607a6eSdan ** Code below may link it back in. 38465d607a6eSdan */ 38475d607a6eSdan for(pp=&pTab->apChange[iHash]; *pp; pp=&(*pp)->pNext){ 384864277f4aSdan int bPkOnly1 = 0; 384964277f4aSdan int bPkOnly2 = 0; 3850cbf6d2d2Sdan if( pIter->bPatchset ){ 385164277f4aSdan bPkOnly1 = (*pp)->op==SQLITE_DELETE; 385264277f4aSdan bPkOnly2 = op==SQLITE_DELETE; 385364277f4aSdan } 385464277f4aSdan if( sessionChangeEqual(pTab, bPkOnly1, (*pp)->aRecord, bPkOnly2, aRec) ){ 38555d607a6eSdan pExist = *pp; 38565d607a6eSdan *pp = (*pp)->pNext; 38575d607a6eSdan pTab->nEntry--; 38585d607a6eSdan break; 38595d607a6eSdan } 38605d607a6eSdan } 38615d607a6eSdan 386264277f4aSdan rc = sessionChangeMerge(pTab, 3863cbf6d2d2Sdan pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange 386464277f4aSdan ); 38655d607a6eSdan if( rc ) break; 38665d607a6eSdan if( pChange ){ 38675d607a6eSdan pChange->pNext = pTab->apChange[iHash]; 38685d607a6eSdan pTab->apChange[iHash] = pChange; 38695d607a6eSdan pTab->nEntry++; 38705d607a6eSdan } 38715d607a6eSdan } 38725d607a6eSdan 3873cbf6d2d2Sdan if( rc==SQLITE_OK ) rc = pIter->rc; 38745d607a6eSdan return rc; 38755d607a6eSdan } 38765d607a6eSdan 38775d607a6eSdan /* 38785d607a6eSdan ** 1. Iterate through the left-hand changeset. Add an entry to a table 38795d607a6eSdan ** specific hash table for each change in the changeset. The hash table 38805d607a6eSdan ** key is the PK of the row affected by the change. 38815d607a6eSdan ** 38825d607a6eSdan ** 2. Then interate through the right-hand changeset. Attempt to add an 38835d607a6eSdan ** entry to a hash table for each component change. If a change already 38845d607a6eSdan ** exists with the same PK values, combine the two into a single change. 38855d607a6eSdan ** 38865d607a6eSdan ** 3. Write an output changeset based on the contents of the hash table. 38875d607a6eSdan */ 3888cbf6d2d2Sdan int sessionChangesetConcat( 3889cbf6d2d2Sdan sqlite3_changeset_iter *pLeft, 3890cbf6d2d2Sdan sqlite3_changeset_iter *pRight, 3891cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 3892cbf6d2d2Sdan void *pOut, 3893cbf6d2d2Sdan int *pnOut, 3894cbf6d2d2Sdan void **ppOut 38955d607a6eSdan ){ 38965d607a6eSdan SessionTable *pList = 0; /* List of SessionTable objects */ 38975d607a6eSdan int rc; /* Return code */ 389864277f4aSdan int bPatch; /* True for a patchset */ 38995d607a6eSdan 3900cbf6d2d2Sdan assert( xOutput==0 || (ppOut==0 && pnOut==0) ); 39015d607a6eSdan 3902cbf6d2d2Sdan rc = sessionAddChangeset(pLeft, &pList); 39035d607a6eSdan if( rc==SQLITE_OK ){ 3904cbf6d2d2Sdan rc = sessionAddChangeset(pRight, &pList); 39055d607a6eSdan } 3906cbf6d2d2Sdan bPatch = pLeft->bPatchset || pRight->bPatchset; 39075d607a6eSdan 39085d607a6eSdan /* Create the serialized output changeset based on the contents of the 39095d607a6eSdan ** hash tables attached to the SessionTable objects in list pList. 39105d607a6eSdan */ 39115d607a6eSdan if( rc==SQLITE_OK ){ 39125d607a6eSdan SessionTable *pTab; 39135d607a6eSdan SessionBuffer buf = {0, 0, 0}; 3914cbf6d2d2Sdan for(pTab=pList; pTab && rc==SQLITE_OK; pTab=pTab->pNext){ 39155d607a6eSdan int i; 39165d607a6eSdan if( pTab->nEntry==0 ) continue; 39175d607a6eSdan 391864277f4aSdan sessionAppendTableHdr(&buf, bPatch, pTab, &rc); 39195d607a6eSdan for(i=0; i<pTab->nChange; i++){ 39205d607a6eSdan SessionChange *p; 39215d607a6eSdan for(p=pTab->apChange[i]; p; p=p->pNext){ 3922798693b2Sdan sessionAppendByte(&buf, p->op, &rc); 39235d607a6eSdan sessionAppendByte(&buf, p->bIndirect, &rc); 39245d607a6eSdan sessionAppendBlob(&buf, p->aRecord, p->nRecord, &rc); 39255d607a6eSdan } 39265d607a6eSdan } 3927cbf6d2d2Sdan 3928cbf6d2d2Sdan if( rc==SQLITE_OK && xOutput && buf.nBuf>=SESSIONS_STR_CHUNK_SIZE ){ 3929cbf6d2d2Sdan rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3930cbf6d2d2Sdan buf.nBuf = 0; 3931cbf6d2d2Sdan } 39325d607a6eSdan } 39335d607a6eSdan 39345d607a6eSdan if( rc==SQLITE_OK ){ 3935cbf6d2d2Sdan if( xOutput ){ 3936cbf6d2d2Sdan if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3937cbf6d2d2Sdan }else{ 39385d607a6eSdan *ppOut = buf.aBuf; 39395d607a6eSdan *pnOut = buf.nBuf; 3940cbf6d2d2Sdan buf.aBuf = 0; 39415d607a6eSdan } 39425d607a6eSdan } 3943cbf6d2d2Sdan sqlite3_free(buf.aBuf); 3944cbf6d2d2Sdan } 39455d607a6eSdan 39465d607a6eSdan sessionDeleteTable(pList); 39475d607a6eSdan return rc; 39485d607a6eSdan } 39495d607a6eSdan 3950cbf6d2d2Sdan /* 3951cbf6d2d2Sdan ** Combine two changesets together. 3952cbf6d2d2Sdan */ 3953cbf6d2d2Sdan int sqlite3changeset_concat( 3954cbf6d2d2Sdan int nLeft, /* Number of bytes in lhs input */ 3955cbf6d2d2Sdan void *pLeft, /* Lhs input changeset */ 3956cbf6d2d2Sdan int nRight /* Number of bytes in rhs input */, 3957cbf6d2d2Sdan void *pRight, /* Rhs input changeset */ 3958cbf6d2d2Sdan int *pnOut, /* OUT: Number of bytes in output changeset */ 3959cbf6d2d2Sdan void **ppOut /* OUT: changeset (left <concat> right) */ 3960cbf6d2d2Sdan ){ 3961cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 3962cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 3963cbf6d2d2Sdan int rc; 3964cbf6d2d2Sdan 3965cbf6d2d2Sdan *pnOut = 0; 3966cbf6d2d2Sdan *ppOut = 0; 3967cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter1, nLeft, pLeft); 3968cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3969cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter2, nRight, pRight); 3970cbf6d2d2Sdan } 3971cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3972cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, 0, 0, pnOut, ppOut); 3973cbf6d2d2Sdan } 3974cbf6d2d2Sdan 3975cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 3976cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 3977cbf6d2d2Sdan return rc; 3978cbf6d2d2Sdan } 3979cbf6d2d2Sdan 3980cbf6d2d2Sdan /* 3981cbf6d2d2Sdan ** Streaming version of sqlite3changeset_concat(). 3982cbf6d2d2Sdan */ 3983cbf6d2d2Sdan int sqlite3changeset_concat_str( 3984cbf6d2d2Sdan int (*xInputA)(void *pIn, void *pData, int *pnData), 3985cbf6d2d2Sdan void *pInA, 3986cbf6d2d2Sdan int (*xInputB)(void *pIn, void *pData, int *pnData), 3987cbf6d2d2Sdan void *pInB, 3988cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 3989cbf6d2d2Sdan void *pOut 3990cbf6d2d2Sdan ){ 3991cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 3992cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 3993cbf6d2d2Sdan int rc; 3994cbf6d2d2Sdan 3995cbf6d2d2Sdan rc = sqlite3changeset_start_str(&pIter1, xInputA, pInA); 3996cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3997cbf6d2d2Sdan rc = sqlite3changeset_start_str(&pIter2, xInputB, pInB); 3998cbf6d2d2Sdan } 3999cbf6d2d2Sdan if( rc==SQLITE_OK ){ 4000cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, xOutput, pOut, 0, 0); 4001cbf6d2d2Sdan } 4002cbf6d2d2Sdan 4003cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 4004cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 4005cbf6d2d2Sdan return rc; 4006cbf6d2d2Sdan } 4007cbf6d2d2Sdan 40089b1c62d4Sdrh #endif /* SQLITE_ENABLE_SESSION && SQLITE_ENABLE_PREUPDATE_HOOK */ 4009