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. 600798693b2Sdan ** *paTwo[0] is not 0x00 - the "no value" placeholder), a copy of the *paOne 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 604798693b2Sdan ** to the "no value" placeholder, *pnVal is set to 1. 605798693b2Sdan */ 6065d607a6eSdan static u8 *sessionMergeValue( 607798693b2Sdan u8 **paOne, /* IN/OUT: Left-hand buffer pointer */ 608798693b2Sdan u8 **paTwo, /* IN/OUT: Right-hand buffer pointer */ 609798693b2Sdan int *pnVal /* OUT: Bytes in returned value */ 6105d607a6eSdan ){ 6115d607a6eSdan u8 *a1 = *paOne; 6125d607a6eSdan u8 *a2 = *paTwo; 6135d607a6eSdan u8 *pRet = 0; 6145d607a6eSdan int n1; 6155d607a6eSdan 6165d607a6eSdan assert( a1 ); 6175d607a6eSdan if( a2 ){ 6185d607a6eSdan int n2 = sessionSerialLen(a2); 6195d607a6eSdan if( *a2 ){ 6205d607a6eSdan *pnVal = n2; 6215d607a6eSdan pRet = a2; 6225d607a6eSdan } 6235d607a6eSdan *paTwo = &a2[n2]; 6245d607a6eSdan } 6255d607a6eSdan 6265d607a6eSdan n1 = sessionSerialLen(a1); 6275d607a6eSdan if( pRet==0 ){ 6285d607a6eSdan *pnVal = n1; 6295d607a6eSdan pRet = a1; 6305d607a6eSdan } 6315d607a6eSdan *paOne = &a1[n1]; 6325d607a6eSdan 6335d607a6eSdan return pRet; 6345d607a6eSdan } 6355d607a6eSdan 636798693b2Sdan /* 637798693b2Sdan ** This function is used by changeset_concat() to merge two UPDATE changes 638798693b2Sdan ** on the same row. 639798693b2Sdan */ 6405d607a6eSdan static int sessionMergeUpdate( 641798693b2Sdan u8 **paOut, /* IN/OUT: Pointer to output buffer */ 642798693b2Sdan SessionTable *pTab, /* Table change pertains to */ 643a71d2371Sdan int bPatchset, /* True if records are patchset records */ 644798693b2Sdan u8 *aOldRecord1, /* old.* record for first change */ 645798693b2Sdan u8 *aOldRecord2, /* old.* record for second change */ 646798693b2Sdan u8 *aNewRecord1, /* new.* record for first change */ 647798693b2Sdan u8 *aNewRecord2 /* new.* record for second change */ 6485d607a6eSdan ){ 6495d607a6eSdan u8 *aOld1 = aOldRecord1; 6505d607a6eSdan u8 *aOld2 = aOldRecord2; 6515d607a6eSdan u8 *aNew1 = aNewRecord1; 6525d607a6eSdan u8 *aNew2 = aNewRecord2; 6535d607a6eSdan 6545d607a6eSdan u8 *aOut = *paOut; 6555d607a6eSdan int i; 65664277f4aSdan 65764277f4aSdan if( bPatchset==0 ){ 6585d607a6eSdan int bRequired = 0; 6595d607a6eSdan 6605d607a6eSdan assert( aOldRecord1 && aNewRecord1 ); 6615d607a6eSdan 6625d607a6eSdan /* Write the old.* vector first. */ 6635d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6645d607a6eSdan int nOld; 6655d607a6eSdan u8 *aOld; 6665d607a6eSdan int nNew; 6675d607a6eSdan u8 *aNew; 6685d607a6eSdan 6695d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 6705d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 6715d607a6eSdan if( pTab->abPK[i] || nOld!=nNew || memcmp(aOld, aNew, nNew) ){ 6725d607a6eSdan if( pTab->abPK[i]==0 ) bRequired = 1; 6735d607a6eSdan memcpy(aOut, aOld, nOld); 6745d607a6eSdan aOut += nOld; 6755d607a6eSdan }else{ 6765d607a6eSdan *(aOut++) = '\0'; 6775d607a6eSdan } 6785d607a6eSdan } 6795d607a6eSdan 6805d607a6eSdan if( !bRequired ) return 0; 68164277f4aSdan } 6825d607a6eSdan 6835d607a6eSdan /* Write the new.* vector */ 6845d607a6eSdan aOld1 = aOldRecord1; 6855d607a6eSdan aOld2 = aOldRecord2; 6865d607a6eSdan aNew1 = aNewRecord1; 6875d607a6eSdan aNew2 = aNewRecord2; 6885d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6895d607a6eSdan int nOld; 6905d607a6eSdan u8 *aOld; 6915d607a6eSdan int nNew; 6925d607a6eSdan u8 *aNew; 6935d607a6eSdan 6945d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 6955d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 69664277f4aSdan if( bPatchset==0 69764277f4aSdan && (pTab->abPK[i] || (nOld==nNew && 0==memcmp(aOld, aNew, nNew))) 69864277f4aSdan ){ 6995d607a6eSdan *(aOut++) = '\0'; 7005d607a6eSdan }else{ 7015d607a6eSdan memcpy(aOut, aNew, nNew); 7025d607a6eSdan aOut += nNew; 7035d607a6eSdan } 7045d607a6eSdan } 7055d607a6eSdan 7065d607a6eSdan *paOut = aOut; 7075d607a6eSdan return 1; 7085d607a6eSdan } 7095d607a6eSdan 71077fc1d5bSdan /* 71177fc1d5bSdan ** This function is only called from within a pre-update-hook callback. 71277fc1d5bSdan ** It determines if the current pre-update-hook change affects the same row 71377fc1d5bSdan ** as the change stored in argument pChange. If so, it returns true. Otherwise 71477fc1d5bSdan ** if the pre-update-hook does not affect the same row as pChange, it returns 71577fc1d5bSdan ** false. 71677fc1d5bSdan */ 71777fc1d5bSdan static int sessionPreupdateEqual( 71877fc1d5bSdan sqlite3 *db, /* Database handle */ 71977fc1d5bSdan SessionTable *pTab, /* Table associated with change */ 72077fc1d5bSdan SessionChange *pChange, /* Change to compare to */ 72177fc1d5bSdan int op /* Current pre-update operation */ 722e8d5648eSdan ){ 72377fc1d5bSdan int iCol; /* Used to iterate through columns */ 72477fc1d5bSdan u8 *a = pChange->aRecord; /* Cursor used to scan change record */ 725e8d5648eSdan 72677fc1d5bSdan assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE ); 72777fc1d5bSdan for(iCol=0; iCol<pTab->nCol; iCol++){ 72877fc1d5bSdan if( !pTab->abPK[iCol] ){ 729798693b2Sdan a += sessionSerialLen(a); 730e8d5648eSdan }else{ 7316734007dSdan sqlite3_value *pVal; /* Value returned by preupdate_new/old */ 7326734007dSdan int rc; /* Error code from preupdate_new/old */ 733798693b2Sdan int eType = *a++; /* Type of value from change record */ 7346734007dSdan 7356734007dSdan /* The following calls to preupdate_new() and preupdate_old() can not 7366734007dSdan ** fail. This is because they cache their return values, and by the 7376734007dSdan ** time control flows to here they have already been called once from 7386734007dSdan ** within sessionPreupdateHash(). The first two asserts below verify 7396734007dSdan ** this (that the method has already been called). */ 74077fc1d5bSdan if( op==SQLITE_INSERT ){ 7416734007dSdan assert( db->pPreUpdate->pNewUnpacked || db->pPreUpdate->aNew ); 74277fc1d5bSdan rc = sqlite3_preupdate_new(db, iCol, &pVal); 743e8d5648eSdan }else{ 7446734007dSdan assert( db->pPreUpdate->pUnpacked ); 74577fc1d5bSdan rc = sqlite3_preupdate_old(db, iCol, &pVal); 746e8d5648eSdan } 7476734007dSdan assert( rc==SQLITE_OK ); 74877fc1d5bSdan if( sqlite3_value_type(pVal)!=eType ) return 0; 749e8d5648eSdan 75012ca0b56Sdan /* A SessionChange object never has a NULL value in a PK column */ 75112ca0b56Sdan assert( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT 75212ca0b56Sdan || eType==SQLITE_BLOB || eType==SQLITE_TEXT 75312ca0b56Sdan ); 75412ca0b56Sdan 75512ca0b56Sdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 756e8d5648eSdan i64 iVal = sessionGetI64(a); 757e8d5648eSdan a += 8; 758e8d5648eSdan if( eType==SQLITE_INTEGER ){ 75977fc1d5bSdan if( sqlite3_value_int64(pVal)!=iVal ) return 0; 760e8d5648eSdan }else{ 761e8d5648eSdan double rVal; 762e8d5648eSdan assert( sizeof(iVal)==8 && sizeof(rVal)==8 ); 763e8d5648eSdan memcpy(&rVal, &iVal, 8); 76477fc1d5bSdan if( sqlite3_value_double(pVal)!=rVal ) return 0; 765e8d5648eSdan } 76612ca0b56Sdan }else{ 767e8d5648eSdan int n; 768e8d5648eSdan const u8 *z; 769e8d5648eSdan a += sessionVarintGet(a, &n); 77077fc1d5bSdan if( sqlite3_value_bytes(pVal)!=n ) return 0; 77112ca0b56Sdan if( eType==SQLITE_TEXT ){ 77212ca0b56Sdan z = sqlite3_value_text(pVal); 77312ca0b56Sdan }else{ 77412ca0b56Sdan z = sqlite3_value_blob(pVal); 77512ca0b56Sdan } 77677fc1d5bSdan if( memcmp(a, z, n) ) return 0; 777e8d5648eSdan a += n; 778e8d5648eSdan break; 779e8d5648eSdan } 780e8d5648eSdan } 781e8d5648eSdan } 782e8d5648eSdan 78377fc1d5bSdan return 1; 7844fccf43aSdan } 7854fccf43aSdan 7864fccf43aSdan /* 7874fccf43aSdan ** If required, grow the hash table used to store changes on table pTab 7884fccf43aSdan ** (part of the session pSession). If a fatal OOM error occurs, set the 7894fccf43aSdan ** session object to failed and return SQLITE_ERROR. Otherwise, return 7904fccf43aSdan ** SQLITE_OK. 7914fccf43aSdan ** 7924fccf43aSdan ** It is possible that a non-fatal OOM error occurs in this function. In 7934fccf43aSdan ** that case the hash-table does not grow, but SQLITE_OK is returned anyway. 7944fccf43aSdan ** Growing the hash table in this case is a performance optimization only, 7954fccf43aSdan ** it is not required for correct operation. 7964fccf43aSdan */ 79764277f4aSdan static int sessionGrowHash(int bPatchset, SessionTable *pTab){ 7984fccf43aSdan if( pTab->nChange==0 || pTab->nEntry>=(pTab->nChange/2) ){ 7994fccf43aSdan int i; 8004fccf43aSdan SessionChange **apNew; 8014fccf43aSdan int nNew = (pTab->nChange ? pTab->nChange : 128) * 2; 8024fccf43aSdan 8034fccf43aSdan apNew = (SessionChange **)sqlite3_malloc(sizeof(SessionChange *) * nNew); 8044fccf43aSdan if( apNew==0 ){ 8054fccf43aSdan if( pTab->nChange==0 ){ 8064fccf43aSdan return SQLITE_ERROR; 8074fccf43aSdan } 8084fccf43aSdan return SQLITE_OK; 8094fccf43aSdan } 8104fccf43aSdan memset(apNew, 0, sizeof(SessionChange *) * nNew); 8114fccf43aSdan 8124fccf43aSdan for(i=0; i<pTab->nChange; i++){ 8134fccf43aSdan SessionChange *p; 8144fccf43aSdan SessionChange *pNext; 8154fccf43aSdan for(p=pTab->apChange[i]; p; p=pNext){ 81664277f4aSdan int bPkOnly = (p->op==SQLITE_DELETE && bPatchset); 81764277f4aSdan int iHash = sessionChangeHash(pTab, bPkOnly, p->aRecord, nNew); 8184fccf43aSdan pNext = p->pNext; 8194fccf43aSdan p->pNext = apNew[iHash]; 8204fccf43aSdan apNew[iHash] = p; 8214fccf43aSdan } 8224fccf43aSdan } 8234fccf43aSdan 8244fccf43aSdan sqlite3_free(pTab->apChange); 8254fccf43aSdan pTab->nChange = nNew; 8264fccf43aSdan pTab->apChange = apNew; 8274fccf43aSdan } 8284fccf43aSdan 8294fccf43aSdan return SQLITE_OK; 8304fccf43aSdan } 8314fccf43aSdan 832296c7658Sdan /* 833e8d5648eSdan ** This function queries the database for the names of the columns of table 834e8d5648eSdan ** zThis, in schema zDb. It is expected that the table has nCol columns. If 835e8d5648eSdan ** not, SQLITE_SCHEMA is returned and none of the output variables are 836e8d5648eSdan ** populated. 837e8d5648eSdan ** 83877fc1d5bSdan ** Otherwise, if they are not NULL, variable *pnCol is set to the number 83977fc1d5bSdan ** of columns in the database table and variable *pzTab is set to point to a 840e8d5648eSdan ** nul-terminated copy of the table name. *pazCol (if not NULL) is set to 841e8d5648eSdan ** point to an array of pointers to column names. And *pabPK (again, if not 842e8d5648eSdan ** NULL) is set to point to an array of booleans - true if the corresponding 843e8d5648eSdan ** column is part of the primary key. 844e8d5648eSdan ** 845e8d5648eSdan ** For example, if the table is declared as: 846e8d5648eSdan ** 847e8d5648eSdan ** CREATE TABLE tbl1(w, x, y, z, PRIMARY KEY(w, z)); 848e8d5648eSdan ** 84977fc1d5bSdan ** Then the four output variables are populated as follows: 850e8d5648eSdan ** 85177fc1d5bSdan ** *pnCol = 4 852e8d5648eSdan ** *pzTab = "tbl1" 853e8d5648eSdan ** *pazCol = {"w", "x", "y", "z"} 854e8d5648eSdan ** *pabPK = {1, 0, 0, 1} 855e8d5648eSdan ** 856e8d5648eSdan ** All returned buffers are part of the same single allocation, which must 857e8d5648eSdan ** be freed using sqlite3_free() by the caller. If pazCol was not NULL, then 858e8d5648eSdan ** pointer *pazCol should be freed to release all memory. Otherwise, pointer 859e8d5648eSdan ** *pabPK. It is illegal for both pazCol and pabPK to be NULL. 860e8d5648eSdan */ 861e8d5648eSdan static int sessionTableInfo( 862e8d5648eSdan sqlite3 *db, /* Database connection */ 863e8d5648eSdan const char *zDb, /* Name of attached database (e.g. "main") */ 864e8d5648eSdan const char *zThis, /* Table name */ 865ca62ad57Sdan int *pnCol, /* OUT: number of columns */ 866e8d5648eSdan const char **pzTab, /* OUT: Copy of zThis */ 867e8d5648eSdan const char ***pazCol, /* OUT: Array of column names for table */ 868e8d5648eSdan u8 **pabPK /* OUT: Array of booleans - true for PK col */ 869e8d5648eSdan ){ 870e8d5648eSdan char *zPragma; 871e8d5648eSdan sqlite3_stmt *pStmt; 872e8d5648eSdan int rc; 873e8d5648eSdan int nByte; 874e8d5648eSdan int nDbCol = 0; 875e8d5648eSdan int nThis; 876e8d5648eSdan int i; 877e8d5648eSdan u8 *pAlloc; 878db04571cSdan char **azCol = 0; 879e8d5648eSdan u8 *abPK; 880e8d5648eSdan 881db04571cSdan assert( pazCol && pabPK ); 882e8d5648eSdan 883cfdbde21Sdrh nThis = sqlite3Strlen30(zThis); 884e8d5648eSdan zPragma = sqlite3_mprintf("PRAGMA '%q'.table_info('%q')", zDb, zThis); 885e8d5648eSdan if( !zPragma ) return SQLITE_NOMEM; 886e8d5648eSdan 887e8d5648eSdan rc = sqlite3_prepare_v2(db, zPragma, -1, &pStmt, 0); 888e8d5648eSdan sqlite3_free(zPragma); 889e8d5648eSdan if( rc!=SQLITE_OK ) return rc; 890e8d5648eSdan 891e8d5648eSdan nByte = nThis + 1; 892e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 893e8d5648eSdan nByte += sqlite3_column_bytes(pStmt, 1); 894e8d5648eSdan nDbCol++; 895e8d5648eSdan } 896e8d5648eSdan rc = sqlite3_reset(pStmt); 897e8d5648eSdan 898e8d5648eSdan if( rc==SQLITE_OK ){ 899e8d5648eSdan nByte += nDbCol * (sizeof(const char *) + sizeof(u8) + 1); 900e8d5648eSdan pAlloc = sqlite3_malloc(nByte); 901e8d5648eSdan if( pAlloc==0 ){ 902e8d5648eSdan rc = SQLITE_NOMEM; 903e8d5648eSdan } 904e8d5648eSdan } 905e8d5648eSdan if( rc==SQLITE_OK ){ 906e8d5648eSdan azCol = (char **)pAlloc; 907ca62ad57Sdan pAlloc = (u8 *)&azCol[nDbCol]; 908e8d5648eSdan abPK = (u8 *)pAlloc; 909ca62ad57Sdan pAlloc = &abPK[nDbCol]; 910e8d5648eSdan if( pzTab ){ 911e8d5648eSdan memcpy(pAlloc, zThis, nThis+1); 912e8d5648eSdan *pzTab = (char *)pAlloc; 913e8d5648eSdan pAlloc += nThis+1; 914e8d5648eSdan } 915e8d5648eSdan 916e8d5648eSdan i = 0; 917e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 918e8d5648eSdan int nName = sqlite3_column_bytes(pStmt, 1); 919e8d5648eSdan const unsigned char *zName = sqlite3_column_text(pStmt, 1); 920e8d5648eSdan if( zName==0 ) break; 921e8d5648eSdan memcpy(pAlloc, zName, nName+1); 922e8d5648eSdan azCol[i] = (char *)pAlloc; 923e8d5648eSdan pAlloc += nName+1; 924db04571cSdan abPK[i] = sqlite3_column_int(pStmt, 5); 925e8d5648eSdan i++; 926e8d5648eSdan } 927e8d5648eSdan rc = sqlite3_reset(pStmt); 928e8d5648eSdan 929e8d5648eSdan } 930e8d5648eSdan 931e8d5648eSdan /* If successful, populate the output variables. Otherwise, zero them and 932e8d5648eSdan ** free any allocation made. An error code will be returned in this case. 933e8d5648eSdan */ 934e8d5648eSdan if( rc==SQLITE_OK ){ 935db04571cSdan *pazCol = (const char **)azCol; 936db04571cSdan *pabPK = abPK; 937ca62ad57Sdan *pnCol = nDbCol; 938e8d5648eSdan }else{ 939db04571cSdan *pazCol = 0; 940db04571cSdan *pabPK = 0; 941ca62ad57Sdan *pnCol = 0; 942e8d5648eSdan if( pzTab ) *pzTab = 0; 943db04571cSdan sqlite3_free(azCol); 944e8d5648eSdan } 945e8d5648eSdan sqlite3_finalize(pStmt); 946e8d5648eSdan return rc; 947e8d5648eSdan } 948e8d5648eSdan 949e8d5648eSdan /* 950296c7658Sdan ** This function is only called from within a pre-update handler for a 951296c7658Sdan ** write to table pTab, part of session pSession. If this is the first 952296c7658Sdan ** write to this table, set the SessionTable.nCol variable to the number 953296c7658Sdan ** of columns in the table. 954296c7658Sdan ** 955296c7658Sdan ** Otherwise, if this is not the first time this table has been written 956296c7658Sdan ** to, check that the number of columns in the table has not changed. If 957296c7658Sdan ** it has not, return zero. 958296c7658Sdan ** 959296c7658Sdan ** If the number of columns in the table has changed since the last write 960296c7658Sdan ** was recorded, set the session error-code to SQLITE_SCHEMA and return 961296c7658Sdan ** non-zero. Users are not allowed to change the number of columns in a table 962296c7658Sdan ** for which changes are being recorded by the session module. If they do so, 963296c7658Sdan ** it is an error. 964296c7658Sdan */ 9654fccf43aSdan static int sessionInitTable(sqlite3_session *pSession, SessionTable *pTab){ 9664fccf43aSdan if( pTab->nCol==0 ){ 967e8d5648eSdan assert( pTab->azCol==0 || pTab->abPK==0 ); 968e8d5648eSdan pSession->rc = sessionTableInfo(pSession->db, pSession->zDb, 969ca62ad57Sdan pTab->zName, &pTab->nCol, 0, &pTab->azCol, &pTab->abPK 970e8d5648eSdan ); 971ca62ad57Sdan } 972ca62ad57Sdan if( pSession->rc==SQLITE_OK 973ca62ad57Sdan && pTab->nCol!=sqlite3_preupdate_count(pSession->db) 974ca62ad57Sdan ){ 9754fccf43aSdan pSession->rc = SQLITE_SCHEMA; 9764fccf43aSdan } 977e8d5648eSdan return pSession->rc; 978e8d5648eSdan } 979e8d5648eSdan 98077fc1d5bSdan /* 98177fc1d5bSdan ** This function is only called from with a pre-update-hook reporting a 98277fc1d5bSdan ** change on table pTab (attached to session pSession). The type of change 98377fc1d5bSdan ** (UPDATE, INSERT, DELETE) is specified by the first argument. 98477fc1d5bSdan ** 98577fc1d5bSdan ** Unless one is already present or an error occurs, an entry is added 98677fc1d5bSdan ** to the changed-rows hash table associated with table pTab. 98777fc1d5bSdan */ 988e8d5648eSdan static void sessionPreupdateOneChange( 98977fc1d5bSdan int op, /* One of SQLITE_UPDATE, INSERT, DELETE */ 99077fc1d5bSdan sqlite3_session *pSession, /* Session object pTab is attached to */ 99177fc1d5bSdan SessionTable *pTab /* Table that change applies to */ 992e8d5648eSdan ){ 993e8d5648eSdan sqlite3 *db = pSession->db; 994e8d5648eSdan int iHash; 99527453faeSdan int bNullPk = 0; 996e8d5648eSdan int rc = SQLITE_OK; 997e8d5648eSdan 998e8d5648eSdan if( pSession->rc ) return; 999e8d5648eSdan 1000e8d5648eSdan /* Load table details if required */ 1001e8d5648eSdan if( sessionInitTable(pSession, pTab) ) return; 1002e8d5648eSdan 1003e8d5648eSdan /* Grow the hash table if required */ 100464277f4aSdan if( sessionGrowHash(0, pTab) ){ 10055d607a6eSdan pSession->rc = SQLITE_NOMEM; 10065d607a6eSdan return; 10075d607a6eSdan } 1008e8d5648eSdan 100980fe2d93Sdan /* Calculate the hash-key for this change. If the primary key of the row 101080fe2d93Sdan ** includes a NULL value, exit early. Such changes are ignored by the 101180fe2d93Sdan ** session module. */ 101227453faeSdan rc = sessionPreupdateHash(db, pTab, op==SQLITE_INSERT, &iHash, &bNullPk); 101380fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 101480fe2d93Sdan 101580fe2d93Sdan if( bNullPk==0 ){ 101680fe2d93Sdan /* Search the hash table for an existing record for this row. */ 1017b4480e94Sdan SessionChange *pC; 10186734007dSdan for(pC=pTab->apChange[iHash]; pC; pC=pC->pNext){ 101977fc1d5bSdan if( sessionPreupdateEqual(db, pTab, pC, op) ) break; 1020e8d5648eSdan } 102180fe2d93Sdan 1022e8d5648eSdan if( pC==0 ){ 1023e8d5648eSdan /* Create a new change object containing all the old values (if 1024e8d5648eSdan ** this is an SQLITE_UPDATE or SQLITE_DELETE), or just the PK 1025e8d5648eSdan ** values (if this is an INSERT). */ 1026b4480e94Sdan SessionChange *pChange; /* New change object */ 1027e8d5648eSdan int nByte; /* Number of bytes to allocate */ 1028e8d5648eSdan int i; /* Used to iterate through columns */ 1029e8d5648eSdan 1030b4480e94Sdan assert( rc==SQLITE_OK ); 1031e8d5648eSdan pTab->nEntry++; 1032e8d5648eSdan 1033e8d5648eSdan /* Figure out how large an allocation is required */ 1034e8d5648eSdan nByte = sizeof(SessionChange); 103580fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1036e8d5648eSdan sqlite3_value *p = 0; 1037e8d5648eSdan if( op!=SQLITE_INSERT ){ 103880fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_old(pSession->db, i, &p); 103980fe2d93Sdan assert( trc==SQLITE_OK ); 104080fe2d93Sdan }else if( pTab->abPK[i] ){ 104180fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_new(pSession->db, i, &p); 104280fe2d93Sdan assert( trc==SQLITE_OK ); 1043e8d5648eSdan } 104480fe2d93Sdan 104580fe2d93Sdan /* This may fail if SQLite value p contains a utf-16 string that must 104680fe2d93Sdan ** be converted to utf-8 and an OOM error occurs while doing so. */ 1047e8d5648eSdan rc = sessionSerializeValue(0, p, &nByte); 104880fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 1049e8d5648eSdan } 1050e8d5648eSdan 1051e8d5648eSdan /* Allocate the change object */ 1052e8d5648eSdan pChange = (SessionChange *)sqlite3_malloc(nByte); 1053e8d5648eSdan if( !pChange ){ 1054e8d5648eSdan rc = SQLITE_NOMEM; 105580fe2d93Sdan goto error_out; 1056e8d5648eSdan }else{ 1057e8d5648eSdan memset(pChange, 0, sizeof(SessionChange)); 1058e8d5648eSdan pChange->aRecord = (u8 *)&pChange[1]; 1059e8d5648eSdan } 1060e8d5648eSdan 106180fe2d93Sdan /* Populate the change object. None of the preupdate_old(), 106280fe2d93Sdan ** preupdate_new() or SerializeValue() calls below may fail as all 106380fe2d93Sdan ** required values and encodings have already been cached in memory. 106480fe2d93Sdan ** It is not possible for an OOM to occur in this block. */ 1065e8d5648eSdan nByte = 0; 106680fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1067e8d5648eSdan sqlite3_value *p = 0; 1068e8d5648eSdan if( op!=SQLITE_INSERT ){ 106980fe2d93Sdan sqlite3_preupdate_old(pSession->db, i, &p); 107080fe2d93Sdan }else if( pTab->abPK[i] ){ 107180fe2d93Sdan sqlite3_preupdate_new(pSession->db, i, &p); 1072e8d5648eSdan } 107380fe2d93Sdan sessionSerializeValue(&pChange->aRecord[nByte], p, &nByte); 1074e8d5648eSdan } 107580fe2d93Sdan 107680fe2d93Sdan /* Add the change to the hash-table */ 1077b4480e94Sdan if( pSession->bIndirect || sqlite3_preupdate_depth(pSession->db) ){ 1078b4480e94Sdan pChange->bIndirect = 1; 1079b4480e94Sdan } 108012ca0b56Sdan pChange->nRecord = nByte; 1081798693b2Sdan pChange->op = op; 1082e8d5648eSdan pChange->pNext = pTab->apChange[iHash]; 1083e8d5648eSdan pTab->apChange[iHash] = pChange; 108480fe2d93Sdan 108580fe2d93Sdan }else if( pC->bIndirect ){ 1086b4480e94Sdan /* If the existing change is considered "indirect", but this current 1087b4480e94Sdan ** change is "direct", mark the change object as direct. */ 1088b4480e94Sdan if( sqlite3_preupdate_depth(pSession->db)==0 && pSession->bIndirect==0 ){ 1089b4480e94Sdan pC->bIndirect = 0; 1090b4480e94Sdan } 1091e8d5648eSdan } 10924fccf43aSdan } 109312ca0b56Sdan 109412ca0b56Sdan /* If an error has occurred, mark the session object as failed. */ 109580fe2d93Sdan error_out: 109612ca0b56Sdan if( rc!=SQLITE_OK ){ 109712ca0b56Sdan pSession->rc = rc; 109812ca0b56Sdan } 109927453faeSdan } 11004fccf43aSdan 11014fccf43aSdan /* 11024fccf43aSdan ** The 'pre-update' hook registered by this module with SQLite databases. 11034fccf43aSdan */ 11044fccf43aSdan static void xPreUpdate( 11054fccf43aSdan void *pCtx, /* Copy of third arg to preupdate_hook() */ 11064fccf43aSdan sqlite3 *db, /* Database handle */ 11074fccf43aSdan int op, /* SQLITE_UPDATE, DELETE or INSERT */ 11084fccf43aSdan char const *zDb, /* Database name */ 11094fccf43aSdan char const *zName, /* Table name */ 11104fccf43aSdan sqlite3_int64 iKey1, /* Rowid of row about to be deleted/updated */ 11114fccf43aSdan sqlite3_int64 iKey2 /* New rowid value (for a rowid UPDATE) */ 11124fccf43aSdan ){ 11134fccf43aSdan sqlite3_session *pSession; 1114cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); 1115cfdbde21Sdrh int nName = sqlite3Strlen30(zName); 11164fccf43aSdan 11174c220252Sdan assert( sqlite3_mutex_held(db->mutex) ); 11184c220252Sdan 11194fccf43aSdan for(pSession=(sqlite3_session *)pCtx; pSession; pSession=pSession->pNext){ 11204fccf43aSdan SessionTable *pTab; 1121296c7658Sdan 1122e8d5648eSdan /* If this session is attached to a different database ("main", "temp" 1123e8d5648eSdan ** etc.), or if it is not currently enabled, there is nothing to do. Skip 1124e8d5648eSdan ** to the next session object attached to this database. */ 1125296c7658Sdan if( pSession->bEnable==0 ) continue; 11264fccf43aSdan if( pSession->rc ) continue; 11274fccf43aSdan if( sqlite3_strnicmp(zDb, pSession->zDb, nDb+1) ) continue; 1128296c7658Sdan 1129ff4d0f41Sdan for(pTab=pSession->pTable; pTab || pSession->bAutoAttach; pTab=pTab->pNext){ 1130ff4d0f41Sdan if( !pTab ){ 1131ff4d0f41Sdan /* This branch is taken if table zName has not yet been attached to 1132ff4d0f41Sdan ** this session and the auto-attach flag is set. */ 11337531a5a3Sdan 11347531a5a3Sdan /* If there is a table-filter configured, invoke it. If it returns 0, 11357531a5a3Sdan ** this change will not be recorded. Break out of the loop early in 11367531a5a3Sdan ** this case. */ 11377531a5a3Sdan if( pSession->xTableFilter 11387531a5a3Sdan && pSession->xTableFilter(pSession->pFilterCtx, zName)==0 11397531a5a3Sdan ){ 11407531a5a3Sdan break; 11417531a5a3Sdan } 11427531a5a3Sdan 1143ff4d0f41Sdan pSession->rc = sqlite3session_attach(pSession,zName); 1144245b49b2Sdan if( pSession->rc ) break; 1145ff4d0f41Sdan pTab = pSession->pTable; 1146ff4d0f41Sdan assert( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ); 1147ff4d0f41Sdan } 1148ff4d0f41Sdan 11494fccf43aSdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ){ 1150e8d5648eSdan sessionPreupdateOneChange(op, pSession, pTab); 1151e8d5648eSdan if( op==SQLITE_UPDATE ){ 1152e8d5648eSdan sessionPreupdateOneChange(SQLITE_INSERT, pSession, pTab); 11534fccf43aSdan } 11544fccf43aSdan break; 11554fccf43aSdan } 11564fccf43aSdan } 11574fccf43aSdan } 1158296c7658Sdan } 11594fccf43aSdan 11604fccf43aSdan /* 11614fccf43aSdan ** Create a session object. This session object will record changes to 11624fccf43aSdan ** database zDb attached to connection db. 11634fccf43aSdan */ 11644fccf43aSdan int sqlite3session_create( 11654fccf43aSdan sqlite3 *db, /* Database handle */ 11664fccf43aSdan const char *zDb, /* Name of db (e.g. "main") */ 11674fccf43aSdan sqlite3_session **ppSession /* OUT: New session object */ 11684fccf43aSdan ){ 1169296c7658Sdan sqlite3_session *pNew; /* Newly allocated session object */ 1170296c7658Sdan sqlite3_session *pOld; /* Session object already attached to db */ 1171cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); /* Length of zDb in bytes */ 11724fccf43aSdan 1173296c7658Sdan /* Zero the output value in case an error occurs. */ 11744fccf43aSdan *ppSession = 0; 11754fccf43aSdan 11764fccf43aSdan /* Allocate and populate the new session object. */ 11774fccf43aSdan pNew = (sqlite3_session *)sqlite3_malloc(sizeof(sqlite3_session) + nDb + 1); 11784fccf43aSdan if( !pNew ) return SQLITE_NOMEM; 11794fccf43aSdan memset(pNew, 0, sizeof(sqlite3_session)); 11804fccf43aSdan pNew->db = db; 11814fccf43aSdan pNew->zDb = (char *)&pNew[1]; 1182296c7658Sdan pNew->bEnable = 1; 11834fccf43aSdan memcpy(pNew->zDb, zDb, nDb+1); 11844fccf43aSdan 11854fccf43aSdan /* Add the new session object to the linked list of session objects 11864fccf43aSdan ** attached to database handle $db. Do this under the cover of the db 11874fccf43aSdan ** handle mutex. */ 11884fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 11894fccf43aSdan pOld = (sqlite3_session*)sqlite3_preupdate_hook(db, xPreUpdate, (void*)pNew); 11904fccf43aSdan pNew->pNext = pOld; 11914fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 11924fccf43aSdan 11934fccf43aSdan *ppSession = pNew; 11944fccf43aSdan return SQLITE_OK; 11954fccf43aSdan } 11964fccf43aSdan 119777fc1d5bSdan /* 119877fc1d5bSdan ** Free the list of table objects passed as the first argument. The contents 119977fc1d5bSdan ** of the changed-rows hash tables are also deleted. 120077fc1d5bSdan */ 12011ffe7c7fSdrh static void sessionDeleteTable(SessionTable *pList){ 12025d607a6eSdan SessionTable *pNext; 12035d607a6eSdan SessionTable *pTab; 12045d607a6eSdan 12055d607a6eSdan for(pTab=pList; pTab; pTab=pNext){ 12065d607a6eSdan int i; 12075d607a6eSdan pNext = pTab->pNext; 12085d607a6eSdan for(i=0; i<pTab->nChange; i++){ 12095d607a6eSdan SessionChange *p; 12105d607a6eSdan SessionChange *pNext; 12115d607a6eSdan for(p=pTab->apChange[i]; p; p=pNext){ 12125d607a6eSdan pNext = p->pNext; 12135d607a6eSdan sqlite3_free(p); 12145d607a6eSdan } 12155d607a6eSdan } 12165d607a6eSdan sqlite3_free((char*)pTab->azCol); /* cast works around VC++ bug */ 12175d607a6eSdan sqlite3_free(pTab->apChange); 12185d607a6eSdan sqlite3_free(pTab); 12195d607a6eSdan } 12205d607a6eSdan } 12215d607a6eSdan 12224fccf43aSdan /* 12234fccf43aSdan ** Delete a session object previously allocated using sqlite3session_create(). 12244fccf43aSdan */ 12254fccf43aSdan void sqlite3session_delete(sqlite3_session *pSession){ 12264fccf43aSdan sqlite3 *db = pSession->db; 12274fccf43aSdan sqlite3_session *pHead; 12284fccf43aSdan sqlite3_session **pp; 12294fccf43aSdan 1230296c7658Sdan /* Unlink the session from the linked list of sessions attached to the 1231296c7658Sdan ** database handle. Hold the db mutex while doing so. */ 12324fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 12334fccf43aSdan pHead = (sqlite3_session*)sqlite3_preupdate_hook(db, 0, 0); 12344fccf43aSdan for(pp=&pHead; (*pp)!=pSession; pp=&((*pp)->pNext)); 12354fccf43aSdan *pp = (*pp)->pNext; 12364fccf43aSdan if( pHead ) sqlite3_preupdate_hook(db, xPreUpdate, (void *)pHead); 12374fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 12384fccf43aSdan 1239296c7658Sdan /* Delete all attached table objects. And the contents of their 1240296c7658Sdan ** associated hash-tables. */ 12415d607a6eSdan sessionDeleteTable(pSession->pTable); 12424fccf43aSdan 1243296c7658Sdan /* Free the session object itself. */ 12444fccf43aSdan sqlite3_free(pSession); 12454fccf43aSdan } 12464fccf43aSdan 12474fccf43aSdan /* 12487531a5a3Sdan ** Set a table filter on a Session Object. 12497531a5a3Sdan */ 12507531a5a3Sdan void sqlite3session_table_filter( 12517531a5a3Sdan sqlite3_session *pSession, 12527531a5a3Sdan int(*xFilter)(void*, const char*), 12537531a5a3Sdan void *pCtx /* First argument passed to xFilter */ 12547531a5a3Sdan ){ 12557531a5a3Sdan pSession->bAutoAttach = 1; 12567531a5a3Sdan pSession->pFilterCtx = pCtx; 12577531a5a3Sdan pSession->xTableFilter = xFilter; 12587531a5a3Sdan } 12597531a5a3Sdan 12607531a5a3Sdan /* 12614fccf43aSdan ** Attach a table to a session. All subsequent changes made to the table 12624fccf43aSdan ** while the session object is enabled will be recorded. 12634fccf43aSdan ** 12644fccf43aSdan ** Only tables that have a PRIMARY KEY defined may be attached. It does 12654fccf43aSdan ** not matter if the PRIMARY KEY is an "INTEGER PRIMARY KEY" (rowid alias) 12664fccf43aSdan ** or not. 12674fccf43aSdan */ 12684fccf43aSdan int sqlite3session_attach( 12694fccf43aSdan sqlite3_session *pSession, /* Session object */ 12704fccf43aSdan const char *zName /* Table name */ 12714fccf43aSdan ){ 1272ff4d0f41Sdan int rc = SQLITE_OK; 1273ff4d0f41Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 1274ff4d0f41Sdan 1275ff4d0f41Sdan if( !zName ){ 1276ff4d0f41Sdan pSession->bAutoAttach = 1; 1277ff4d0f41Sdan }else{ 1278296c7658Sdan SessionTable *pTab; /* New table object (if required) */ 1279296c7658Sdan int nName; /* Number of bytes in string zName */ 12804fccf43aSdan 12814fccf43aSdan /* First search for an existing entry. If one is found, this call is 12824fccf43aSdan ** a no-op. Return early. */ 1283cfdbde21Sdrh nName = sqlite3Strlen30(zName); 12844fccf43aSdan for(pTab=pSession->pTable; pTab; pTab=pTab->pNext){ 12854c220252Sdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ) break; 12864fccf43aSdan } 12874fccf43aSdan 12884c220252Sdan if( !pTab ){ 12894fccf43aSdan /* Allocate new SessionTable object. */ 12904fccf43aSdan pTab = (SessionTable *)sqlite3_malloc(sizeof(SessionTable) + nName + 1); 12914c220252Sdan if( !pTab ){ 12924c220252Sdan rc = SQLITE_NOMEM; 12934c220252Sdan }else{ 12944fccf43aSdan /* Populate the new SessionTable object and link it into the list. */ 12954fccf43aSdan memset(pTab, 0, sizeof(SessionTable)); 12964fccf43aSdan pTab->zName = (char *)&pTab[1]; 12974fccf43aSdan memcpy(pTab->zName, zName, nName+1); 12984fccf43aSdan pTab->pNext = pSession->pTable; 12994fccf43aSdan pSession->pTable = pTab; 13004c220252Sdan } 13014c220252Sdan } 1302ff4d0f41Sdan } 13034fccf43aSdan 13044c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 13054c220252Sdan return rc; 13064fccf43aSdan } 13074fccf43aSdan 1308296c7658Sdan /* 1309296c7658Sdan ** Ensure that there is room in the buffer to append nByte bytes of data. 1310296c7658Sdan ** If not, use sqlite3_realloc() to grow the buffer so that there is. 1311296c7658Sdan ** 1312296c7658Sdan ** If successful, return zero. Otherwise, if an OOM condition is encountered, 1313296c7658Sdan ** set *pRc to SQLITE_NOMEM and return non-zero. 1314296c7658Sdan */ 13154fccf43aSdan static int sessionBufferGrow(SessionBuffer *p, int nByte, int *pRc){ 131680fe2d93Sdan if( *pRc==SQLITE_OK && p->nAlloc-p->nBuf<nByte ){ 13174fccf43aSdan u8 *aNew; 13184fccf43aSdan int nNew = p->nAlloc ? p->nAlloc : 128; 13194fccf43aSdan do { 13204fccf43aSdan nNew = nNew*2; 1321ef7a6304Sdan }while( nNew<(p->nBuf+nByte) ); 13224fccf43aSdan 13234fccf43aSdan aNew = (u8 *)sqlite3_realloc(p->aBuf, nNew); 13244fccf43aSdan if( 0==aNew ){ 13254fccf43aSdan *pRc = SQLITE_NOMEM; 132680fe2d93Sdan }else{ 13274fccf43aSdan p->aBuf = aNew; 13284fccf43aSdan p->nAlloc = nNew; 13294fccf43aSdan } 133080fe2d93Sdan } 133180fe2d93Sdan return (*pRc!=SQLITE_OK); 13324fccf43aSdan } 13334fccf43aSdan 1334296c7658Sdan /* 1335fa122adaSdan ** Append the value passed as the second argument to the buffer passed 1336fa122adaSdan ** as the first. 1337fa122adaSdan ** 1338fa122adaSdan ** This function is a no-op if *pRc is non-zero when it is called. 1339fa122adaSdan ** Otherwise, if an error occurs, *pRc is set to an SQLite error code 1340fa122adaSdan ** before returning. 1341fa122adaSdan */ 1342fa122adaSdan static void sessionAppendValue(SessionBuffer *p, sqlite3_value *pVal, int *pRc){ 1343fa122adaSdan int rc = *pRc; 1344fa122adaSdan if( rc==SQLITE_OK ){ 1345fa122adaSdan int nByte = 0; 1346fa122adaSdan sessionSerializeValue(0, pVal, &nByte); 1347fa122adaSdan sessionBufferGrow(p, nByte, &rc); 1348fa122adaSdan if( rc==SQLITE_OK ){ 1349fa122adaSdan rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); 1350fa122adaSdan p->nBuf += nByte; 1351fa122adaSdan }else{ 1352fa122adaSdan *pRc = rc; 1353fa122adaSdan } 1354fa122adaSdan } 1355fa122adaSdan } 1356fa122adaSdan 1357fa122adaSdan /* 1358296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1359296c7658Sdan ** called. Otherwise, append a single byte to the buffer. 1360296c7658Sdan ** 1361296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1362296c7658Sdan ** returning. 1363296c7658Sdan */ 13644fccf43aSdan static void sessionAppendByte(SessionBuffer *p, u8 v, int *pRc){ 136580fe2d93Sdan if( 0==sessionBufferGrow(p, 1, pRc) ){ 13664fccf43aSdan p->aBuf[p->nBuf++] = v; 13674fccf43aSdan } 13684fccf43aSdan } 13694fccf43aSdan 1370296c7658Sdan /* 1371296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1372296c7658Sdan ** called. Otherwise, append a single varint to the buffer. 1373296c7658Sdan ** 1374296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1375296c7658Sdan ** returning. 1376296c7658Sdan */ 1377cfdbde21Sdrh static void sessionAppendVarint(SessionBuffer *p, int v, int *pRc){ 137880fe2d93Sdan if( 0==sessionBufferGrow(p, 9, pRc) ){ 13794fccf43aSdan p->nBuf += sessionVarintPut(&p->aBuf[p->nBuf], v); 13804fccf43aSdan } 13814fccf43aSdan } 13824fccf43aSdan 1383296c7658Sdan /* 1384296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1385296c7658Sdan ** called. Otherwise, append a blob of data to the buffer. 1386296c7658Sdan ** 1387296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1388296c7658Sdan ** returning. 1389296c7658Sdan */ 13904fccf43aSdan static void sessionAppendBlob( 13914fccf43aSdan SessionBuffer *p, 13924fccf43aSdan const u8 *aBlob, 13934fccf43aSdan int nBlob, 13944fccf43aSdan int *pRc 13954fccf43aSdan ){ 139680fe2d93Sdan if( 0==sessionBufferGrow(p, nBlob, pRc) ){ 13974fccf43aSdan memcpy(&p->aBuf[p->nBuf], aBlob, nBlob); 13984fccf43aSdan p->nBuf += nBlob; 13994fccf43aSdan } 14004fccf43aSdan } 14014fccf43aSdan 1402296c7658Sdan /* 1403296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1404296c7658Sdan ** called. Otherwise, append a string to the buffer. All bytes in the string 1405296c7658Sdan ** up to (but not including) the nul-terminator are written to the buffer. 1406296c7658Sdan ** 1407296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1408296c7658Sdan ** returning. 1409296c7658Sdan */ 1410d5f0767cSdan static void sessionAppendStr( 1411d5f0767cSdan SessionBuffer *p, 1412d5f0767cSdan const char *zStr, 1413d5f0767cSdan int *pRc 1414d5f0767cSdan ){ 1415cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr); 141680fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1417d5f0767cSdan memcpy(&p->aBuf[p->nBuf], zStr, nStr); 1418d5f0767cSdan p->nBuf += nStr; 1419d5f0767cSdan } 1420d5f0767cSdan } 1421d5f0767cSdan 1422296c7658Sdan /* 1423296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1424296c7658Sdan ** called. Otherwise, append the string representation of integer iVal 1425296c7658Sdan ** to the buffer. No nul-terminator is written. 1426296c7658Sdan ** 1427296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1428296c7658Sdan ** returning. 1429296c7658Sdan */ 1430d5f0767cSdan static void sessionAppendInteger( 1431296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1432296c7658Sdan int iVal, /* Value to write the string rep. of */ 1433296c7658Sdan int *pRc /* IN/OUT: Error code */ 1434d5f0767cSdan ){ 1435d5f0767cSdan char aBuf[24]; 1436d5f0767cSdan sqlite3_snprintf(sizeof(aBuf)-1, aBuf, "%d", iVal); 1437d5f0767cSdan sessionAppendStr(p, aBuf, pRc); 1438d5f0767cSdan } 1439d5f0767cSdan 1440296c7658Sdan /* 1441296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1442296c7658Sdan ** called. Otherwise, append the string zStr enclosed in quotes (") and 1443296c7658Sdan ** with any embedded quote characters escaped to the buffer. No 1444296c7658Sdan ** nul-terminator byte is written. 1445296c7658Sdan ** 1446296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1447296c7658Sdan ** returning. 1448296c7658Sdan */ 1449d5f0767cSdan static void sessionAppendIdent( 1450296c7658Sdan SessionBuffer *p, /* Buffer to a append to */ 1451296c7658Sdan const char *zStr, /* String to quote, escape and append */ 1452296c7658Sdan int *pRc /* IN/OUT: Error code */ 1453d5f0767cSdan ){ 1454cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr)*2 + 2 + 1; 145580fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1456d5f0767cSdan char *zOut = (char *)&p->aBuf[p->nBuf]; 1457d5f0767cSdan const char *zIn = zStr; 1458d5f0767cSdan *zOut++ = '"'; 1459d5f0767cSdan while( *zIn ){ 1460d5f0767cSdan if( *zIn=='"' ) *zOut++ = '"'; 1461d5f0767cSdan *zOut++ = *(zIn++); 1462d5f0767cSdan } 1463d5f0767cSdan *zOut++ = '"'; 1464cfdbde21Sdrh p->nBuf = (int)((u8 *)zOut - p->aBuf); 1465d5f0767cSdan } 1466d5f0767cSdan } 1467d5f0767cSdan 1468296c7658Sdan /* 1469296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1470296c7658Sdan ** called. Otherwse, it appends the serialized version of the value stored 1471296c7658Sdan ** in column iCol of the row that SQL statement pStmt currently points 1472296c7658Sdan ** to to the buffer. 1473296c7658Sdan */ 14744fccf43aSdan static void sessionAppendCol( 1475296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1476296c7658Sdan sqlite3_stmt *pStmt, /* Handle pointing to row containing value */ 1477296c7658Sdan int iCol, /* Column to read value from */ 1478296c7658Sdan int *pRc /* IN/OUT: Error code */ 14794fccf43aSdan ){ 14804fccf43aSdan if( *pRc==SQLITE_OK ){ 14814fccf43aSdan int eType = sqlite3_column_type(pStmt, iCol); 14824fccf43aSdan sessionAppendByte(p, (u8)eType, pRc); 14834fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 14844fccf43aSdan sqlite3_int64 i; 14854fccf43aSdan u8 aBuf[8]; 14864fccf43aSdan if( eType==SQLITE_INTEGER ){ 14874fccf43aSdan i = sqlite3_column_int64(pStmt, iCol); 14884fccf43aSdan }else{ 14894fccf43aSdan double r = sqlite3_column_double(pStmt, iCol); 14904fccf43aSdan memcpy(&i, &r, 8); 14914fccf43aSdan } 1492296c7658Sdan sessionPutI64(aBuf, i); 14934fccf43aSdan sessionAppendBlob(p, aBuf, 8, pRc); 14944fccf43aSdan } 14954fccf43aSdan if( eType==SQLITE_BLOB || eType==SQLITE_TEXT ){ 14966734007dSdan u8 *z; 14976734007dSdan if( eType==SQLITE_BLOB ){ 14986734007dSdan z = (u8 *)sqlite3_column_blob(pStmt, iCol); 14996734007dSdan }else{ 15006734007dSdan z = (u8 *)sqlite3_column_text(pStmt, iCol); 15016734007dSdan } 15026734007dSdan if( z ){ 15034fccf43aSdan int nByte = sqlite3_column_bytes(pStmt, iCol); 15044fccf43aSdan sessionAppendVarint(p, nByte, pRc); 15056734007dSdan sessionAppendBlob(p, z, nByte, pRc); 15066734007dSdan }else{ 15076734007dSdan *pRc = SQLITE_NOMEM; 15086734007dSdan } 15094fccf43aSdan } 15104fccf43aSdan } 15114fccf43aSdan } 15124fccf43aSdan 1513296c7658Sdan /* 1514296c7658Sdan ** 151580fe2d93Sdan ** This function appends an update change to the buffer (see the comments 151680fe2d93Sdan ** under "CHANGESET FORMAT" at the top of the file). An update change 151780fe2d93Sdan ** consists of: 1518296c7658Sdan ** 1519296c7658Sdan ** 1 byte: SQLITE_UPDATE (0x17) 1520296c7658Sdan ** n bytes: old.* record (see RECORD FORMAT) 1521296c7658Sdan ** m bytes: new.* record (see RECORD FORMAT) 1522296c7658Sdan ** 1523296c7658Sdan ** The SessionChange object passed as the third argument contains the 1524296c7658Sdan ** values that were stored in the row when the session began (the old.* 1525296c7658Sdan ** values). The statement handle passed as the second argument points 1526296c7658Sdan ** at the current version of the row (the new.* values). 1527296c7658Sdan ** 1528296c7658Sdan ** If all of the old.* values are equal to their corresponding new.* value 1529296c7658Sdan ** (i.e. nothing has changed), then no data at all is appended to the buffer. 1530296c7658Sdan ** 1531296c7658Sdan ** Otherwise, the old.* record contains all primary key values and the 1532296c7658Sdan ** original values of any fields that have been modified. The new.* record 1533296c7658Sdan ** contains the new values of only those fields that have been modified. 1534296c7658Sdan */ 153580fe2d93Sdan static int sessionAppendUpdate( 1536296c7658Sdan SessionBuffer *pBuf, /* Buffer to append to */ 153773b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 1538296c7658Sdan sqlite3_stmt *pStmt, /* Statement handle pointing at new row */ 1539296c7658Sdan SessionChange *p, /* Object containing old values */ 154080fe2d93Sdan u8 *abPK /* Boolean array - true for PK columns */ 15414fccf43aSdan ){ 154280fe2d93Sdan int rc = SQLITE_OK; 1543296c7658Sdan SessionBuffer buf2 = {0,0,0}; /* Buffer to accumulate new.* record in */ 1544296c7658Sdan int bNoop = 1; /* Set to zero if any values are modified */ 15451f34f8ccSdan int nRewind = pBuf->nBuf; /* Set to zero if any values are modified */ 1546296c7658Sdan int i; /* Used to iterate through columns */ 1547296c7658Sdan u8 *pCsr = p->aRecord; /* Used to iterate through old.* values */ 1548296c7658Sdan 154980fe2d93Sdan sessionAppendByte(pBuf, SQLITE_UPDATE, &rc); 155080fe2d93Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 15514fccf43aSdan for(i=0; i<sqlite3_column_count(pStmt); i++){ 155237f133ecSdan int bChanged = 0; 15534fccf43aSdan int nAdvance; 15544fccf43aSdan int eType = *pCsr; 15554fccf43aSdan switch( eType ){ 15564fccf43aSdan case SQLITE_NULL: 15574fccf43aSdan nAdvance = 1; 15584fccf43aSdan if( sqlite3_column_type(pStmt, i)!=SQLITE_NULL ){ 155937f133ecSdan bChanged = 1; 15604fccf43aSdan } 15614fccf43aSdan break; 15624fccf43aSdan 15634fccf43aSdan case SQLITE_FLOAT: 15644fccf43aSdan case SQLITE_INTEGER: { 15654fccf43aSdan nAdvance = 9; 15664fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) ){ 15674fccf43aSdan sqlite3_int64 iVal = sessionGetI64(&pCsr[1]); 15684fccf43aSdan if( eType==SQLITE_INTEGER ){ 15694fccf43aSdan if( iVal==sqlite3_column_int64(pStmt, i) ) break; 15704fccf43aSdan }else{ 15714fccf43aSdan double dVal; 15724fccf43aSdan memcpy(&dVal, &iVal, 8); 15734fccf43aSdan if( dVal==sqlite3_column_double(pStmt, i) ) break; 15744fccf43aSdan } 15754fccf43aSdan } 157637f133ecSdan bChanged = 1; 15774fccf43aSdan break; 15784fccf43aSdan } 15794fccf43aSdan 1580e5754eecSdan default: { 15814fccf43aSdan int nByte; 15824fccf43aSdan int nHdr = 1 + sessionVarintGet(&pCsr[1], &nByte); 1583e5754eecSdan assert( eType==SQLITE_TEXT || eType==SQLITE_BLOB ); 15844fccf43aSdan nAdvance = nHdr + nByte; 15854fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) 15864fccf43aSdan && nByte==sqlite3_column_bytes(pStmt, i) 15874fccf43aSdan && 0==memcmp(&pCsr[nHdr], sqlite3_column_blob(pStmt, i), nByte) 15884fccf43aSdan ){ 15894fccf43aSdan break; 15904fccf43aSdan } 159137f133ecSdan bChanged = 1; 15924fccf43aSdan } 15934fccf43aSdan } 15944fccf43aSdan 159573b3c055Sdan /* If at least one field has been modified, this is not a no-op. */ 159673b3c055Sdan if( bChanged ) bNoop = 0; 159773b3c055Sdan 159873b3c055Sdan /* Add a field to the old.* record. This is omitted if this modules is 159973b3c055Sdan ** currently generating a patchset. */ 160073b3c055Sdan if( bPatchset==0 ){ 160137f133ecSdan if( bChanged || abPK[i] ){ 160280fe2d93Sdan sessionAppendBlob(pBuf, pCsr, nAdvance, &rc); 16034fccf43aSdan }else{ 160480fe2d93Sdan sessionAppendByte(pBuf, 0, &rc); 160537f133ecSdan } 160673b3c055Sdan } 160737f133ecSdan 160873b3c055Sdan /* Add a field to the new.* record. Or the only record if currently 160973b3c055Sdan ** generating a patchset. */ 161073b3c055Sdan if( bChanged || (bPatchset && abPK[i]) ){ 161180fe2d93Sdan sessionAppendCol(&buf2, pStmt, i, &rc); 161237f133ecSdan }else{ 161380fe2d93Sdan sessionAppendByte(&buf2, 0, &rc); 16144fccf43aSdan } 161537f133ecSdan 16164fccf43aSdan pCsr += nAdvance; 16174fccf43aSdan } 16184fccf43aSdan 16194fccf43aSdan if( bNoop ){ 16201f34f8ccSdan pBuf->nBuf = nRewind; 16214fccf43aSdan }else{ 162280fe2d93Sdan sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); 16234fccf43aSdan } 16241f34f8ccSdan sqlite3_free(buf2.aBuf); 162580fe2d93Sdan 162680fe2d93Sdan return rc; 1627d5f0767cSdan } 16284fccf43aSdan 1629a71d2371Sdan /* 1630a71d2371Sdan ** Append a DELETE change to the buffer passed as the first argument. Use 1631a71d2371Sdan ** the changeset format if argument bPatchset is zero, or the patchset 1632a71d2371Sdan ** format otherwise. 1633a71d2371Sdan */ 163473b3c055Sdan static int sessionAppendDelete( 163573b3c055Sdan SessionBuffer *pBuf, /* Buffer to append to */ 163673b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 163773b3c055Sdan SessionChange *p, /* Object containing old values */ 1638a71d2371Sdan int nCol, /* Number of columns in table */ 163973b3c055Sdan u8 *abPK /* Boolean array - true for PK columns */ 164073b3c055Sdan ){ 164173b3c055Sdan int rc = SQLITE_OK; 164273b3c055Sdan 164373b3c055Sdan sessionAppendByte(pBuf, SQLITE_DELETE, &rc); 164473b3c055Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 164573b3c055Sdan 164673b3c055Sdan if( bPatchset==0 ){ 164773b3c055Sdan sessionAppendBlob(pBuf, p->aRecord, p->nRecord, &rc); 164873b3c055Sdan }else{ 164973b3c055Sdan int i; 165073b3c055Sdan u8 *a = p->aRecord; 165173b3c055Sdan for(i=0; i<nCol; i++){ 165273b3c055Sdan u8 *pStart = a; 165373b3c055Sdan int eType = *a++; 165473b3c055Sdan 165573b3c055Sdan switch( eType ){ 165673b3c055Sdan case 0: 165773b3c055Sdan case SQLITE_NULL: 165873b3c055Sdan assert( abPK[i]==0 ); 165973b3c055Sdan break; 166073b3c055Sdan 166173b3c055Sdan case SQLITE_FLOAT: 166273b3c055Sdan case SQLITE_INTEGER: 166373b3c055Sdan a += 8; 166473b3c055Sdan break; 166573b3c055Sdan 166673b3c055Sdan default: { 166773b3c055Sdan int n; 166873b3c055Sdan a += sessionVarintGet(a, &n); 166973b3c055Sdan a += n; 167073b3c055Sdan break; 167173b3c055Sdan } 167273b3c055Sdan } 167373b3c055Sdan if( abPK[i] ){ 1674f5ab08c7Sdrh sessionAppendBlob(pBuf, pStart, (int)(a-pStart), &rc); 167573b3c055Sdan } 167673b3c055Sdan } 167773b3c055Sdan assert( (a - p->aRecord)==p->nRecord ); 167873b3c055Sdan } 167973b3c055Sdan 168073b3c055Sdan return rc; 168173b3c055Sdan } 168273b3c055Sdan 168377fc1d5bSdan /* 168477fc1d5bSdan ** Formulate and prepare a SELECT statement to retrieve a row from table 168577fc1d5bSdan ** zTab in database zDb based on its primary key. i.e. 168677fc1d5bSdan ** 168777fc1d5bSdan ** SELECT * FROM zDb.zTab WHERE pk1 = ? AND pk2 = ? AND ... 168877fc1d5bSdan */ 1689e8d5648eSdan static int sessionSelectStmt( 1690e8d5648eSdan sqlite3 *db, /* Database handle */ 1691d7fb7d24Sdan const char *zDb, /* Database name */ 1692e8d5648eSdan const char *zTab, /* Table name */ 169377fc1d5bSdan int nCol, /* Number of columns in table */ 169477fc1d5bSdan const char **azCol, /* Names of table columns */ 169577fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 169677fc1d5bSdan sqlite3_stmt **ppStmt /* OUT: Prepared SELECT statement */ 1697d5f0767cSdan ){ 1698e8d5648eSdan int rc = SQLITE_OK; 1699d5f0767cSdan int i; 1700e8d5648eSdan const char *zSep = ""; 1701e8d5648eSdan SessionBuffer buf = {0, 0, 0}; 1702d5f0767cSdan 1703e8d5648eSdan sessionAppendStr(&buf, "SELECT * FROM ", &rc); 1704d7fb7d24Sdan sessionAppendIdent(&buf, zDb, &rc); 1705d7fb7d24Sdan sessionAppendStr(&buf, ".", &rc); 1706e8d5648eSdan sessionAppendIdent(&buf, zTab, &rc); 1707e8d5648eSdan sessionAppendStr(&buf, " WHERE ", &rc); 1708e8d5648eSdan for(i=0; i<nCol; i++){ 1709e8d5648eSdan if( abPK[i] ){ 1710e8d5648eSdan sessionAppendStr(&buf, zSep, &rc); 1711e8d5648eSdan sessionAppendIdent(&buf, azCol[i], &rc); 1712e8d5648eSdan sessionAppendStr(&buf, " = ?", &rc); 1713e8d5648eSdan sessionAppendInteger(&buf, i+1, &rc); 1714e8d5648eSdan zSep = " AND "; 1715d5f0767cSdan } 1716d5f0767cSdan } 1717d5f0767cSdan if( rc==SQLITE_OK ){ 1718e8d5648eSdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, ppStmt, 0); 1719d5f0767cSdan } 1720e8d5648eSdan sqlite3_free(buf.aBuf); 1721e8d5648eSdan return rc; 1722d5f0767cSdan } 1723d5f0767cSdan 172477fc1d5bSdan /* 172577fc1d5bSdan ** Bind the PRIMARY KEY values from the change passed in argument pChange 172677fc1d5bSdan ** to the SELECT statement passed as the first argument. The SELECT statement 172777fc1d5bSdan ** is as prepared by function sessionSelectStmt(). 172877fc1d5bSdan ** 172977fc1d5bSdan ** Return SQLITE_OK if all PK values are successfully bound, or an SQLite 173077fc1d5bSdan ** error code (e.g. SQLITE_NOMEM) otherwise. 173177fc1d5bSdan */ 1732e8d5648eSdan static int sessionSelectBind( 173377fc1d5bSdan sqlite3_stmt *pSelect, /* SELECT from sessionSelectStmt() */ 173477fc1d5bSdan int nCol, /* Number of columns in table */ 173577fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 173677fc1d5bSdan SessionChange *pChange /* Change structure */ 1737e8d5648eSdan ){ 1738e8d5648eSdan int i; 1739e8d5648eSdan int rc = SQLITE_OK; 1740e5754eecSdan u8 *a = pChange->aRecord; 1741d5f0767cSdan 1742e8d5648eSdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 1743e8d5648eSdan int eType = *a++; 1744e8d5648eSdan 1745e8d5648eSdan switch( eType ){ 174680fe2d93Sdan case 0: 1747e8d5648eSdan case SQLITE_NULL: 1748e5754eecSdan assert( abPK[i]==0 ); 1749e8d5648eSdan break; 1750e8d5648eSdan 1751e8d5648eSdan case SQLITE_INTEGER: { 1752e8d5648eSdan if( abPK[i] ){ 1753e8d5648eSdan i64 iVal = sessionGetI64(a); 1754e8d5648eSdan rc = sqlite3_bind_int64(pSelect, i+1, iVal); 1755e8d5648eSdan } 1756e8d5648eSdan a += 8; 1757e8d5648eSdan break; 1758d5f0767cSdan } 1759296c7658Sdan 1760e8d5648eSdan case SQLITE_FLOAT: { 1761e8d5648eSdan if( abPK[i] ){ 1762e8d5648eSdan double rVal; 1763e8d5648eSdan i64 iVal = sessionGetI64(a); 1764e8d5648eSdan memcpy(&rVal, &iVal, 8); 17654e895da1Sdan rc = sqlite3_bind_double(pSelect, i+1, rVal); 1766d5f0767cSdan } 1767e8d5648eSdan a += 8; 1768e8d5648eSdan break; 1769e8d5648eSdan } 1770e8d5648eSdan 1771e8d5648eSdan case SQLITE_TEXT: { 1772e8d5648eSdan int n; 1773e8d5648eSdan a += sessionVarintGet(a, &n); 1774e8d5648eSdan if( abPK[i] ){ 1775e8d5648eSdan rc = sqlite3_bind_text(pSelect, i+1, (char *)a, n, SQLITE_TRANSIENT); 1776e8d5648eSdan } 1777e8d5648eSdan a += n; 1778e8d5648eSdan break; 1779e8d5648eSdan } 1780e8d5648eSdan 1781e5754eecSdan default: { 1782e8d5648eSdan int n; 1783e5754eecSdan assert( eType==SQLITE_BLOB ); 1784e8d5648eSdan a += sessionVarintGet(a, &n); 1785e8d5648eSdan if( abPK[i] ){ 1786e8d5648eSdan rc = sqlite3_bind_blob(pSelect, i+1, a, n, SQLITE_TRANSIENT); 1787e8d5648eSdan } 1788e8d5648eSdan a += n; 1789e8d5648eSdan break; 1790e8d5648eSdan } 1791e8d5648eSdan } 1792e8d5648eSdan } 1793e8d5648eSdan 1794d5f0767cSdan return rc; 17954fccf43aSdan } 17964fccf43aSdan 179777fc1d5bSdan /* 179877fc1d5bSdan ** This function is a no-op if *pRc is set to other than SQLITE_OK when it 179977fc1d5bSdan ** is called. Otherwise, append a serialized table header (part of the binary 180077fc1d5bSdan ** changeset format) to buffer *pBuf. If an error occurs, set *pRc to an 180177fc1d5bSdan ** SQLite error code before returning. 180277fc1d5bSdan */ 18035d607a6eSdan static void sessionAppendTableHdr( 1804a71d2371Sdan SessionBuffer *pBuf, /* Append header to this buffer */ 1805a71d2371Sdan int bPatchset, /* Use the patchset format if true */ 1806a71d2371Sdan SessionTable *pTab, /* Table object to append header for */ 1807a71d2371Sdan int *pRc /* IN/OUT: Error code */ 18085d607a6eSdan ){ 18095d607a6eSdan /* Write a table header */ 181073b3c055Sdan sessionAppendByte(pBuf, (bPatchset ? 'P' : 'T'), pRc); 18115d607a6eSdan sessionAppendVarint(pBuf, pTab->nCol, pRc); 18125d607a6eSdan sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc); 18134f528042Sdan sessionAppendBlob(pBuf, (u8 *)pTab->zName, (int)strlen(pTab->zName)+1, pRc); 18145d607a6eSdan } 18155d607a6eSdan 1816a71d2371Sdan /* 1817a71d2371Sdan ** Generate either a changeset (if argument bPatchset is zero) or a patchset 1818a71d2371Sdan ** (if it is non-zero) based on the current contents of the session object 1819a71d2371Sdan ** passed as the first argument. 1820a71d2371Sdan ** 1821a71d2371Sdan ** If no error occurs, SQLITE_OK is returned and the new changeset/patchset 1822a71d2371Sdan ** stored in output variables *pnChangeset and *ppChangeset. Or, if an error 1823a71d2371Sdan ** occurs, an SQLite error code is returned and both output variables set 1824a71d2371Sdan ** to 0. 1825a71d2371Sdan */ 182673b3c055Sdan int sessionGenerateChangeset( 18274fccf43aSdan sqlite3_session *pSession, /* Session object */ 182873b3c055Sdan int bPatchset, /* True for patchset, false for changeset */ 1829ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1830ef7a6304Sdan void *pOut, /* First argument for xOutput */ 18314fccf43aSdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 18324fccf43aSdan void **ppChangeset /* OUT: Buffer containing changeset */ 18334fccf43aSdan ){ 1834296c7658Sdan sqlite3 *db = pSession->db; /* Source database handle */ 1835296c7658Sdan SessionTable *pTab; /* Used to iterate through attached tables */ 1836296c7658Sdan SessionBuffer buf = {0,0,0}; /* Buffer in which to accumlate changeset */ 1837296c7658Sdan int rc; /* Return code */ 18384fccf43aSdan 1839ef7a6304Sdan assert( xOutput==0 || (pnChangeset==0 && ppChangeset==0 ) ); 1840ef7a6304Sdan 1841296c7658Sdan /* Zero the output variables in case an error occurs. If this session 1842296c7658Sdan ** object is already in the error state (sqlite3_session.rc != SQLITE_OK), 1843296c7658Sdan ** this call will be a no-op. */ 1844ef7a6304Sdan if( xOutput==0 ){ 18454fccf43aSdan *pnChangeset = 0; 18464fccf43aSdan *ppChangeset = 0; 1847ef7a6304Sdan } 1848e5754eecSdan 1849e5754eecSdan if( pSession->rc ) return pSession->rc; 1850e5754eecSdan rc = sqlite3_exec(pSession->db, "SAVEPOINT changeset", 0, 0, 0); 1851e5754eecSdan if( rc!=SQLITE_OK ) return rc; 1852e5754eecSdan 1853e5754eecSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 18544fccf43aSdan 18554fccf43aSdan for(pTab=pSession->pTable; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ 18564fccf43aSdan if( pTab->nEntry ){ 1857d7fb7d24Sdan const char *zName = pTab->zName; 1858a9605b91Sdan int nCol; /* Number of columns in table */ 1859a9605b91Sdan u8 *abPK; /* Primary key array */ 1860a9605b91Sdan const char **azCol = 0; /* Table columns */ 18611f34f8ccSdan int i; /* Used to iterate through hash buckets */ 18621f34f8ccSdan sqlite3_stmt *pSel = 0; /* SELECT statement to query table pTab */ 18631f34f8ccSdan int nRewind = buf.nBuf; /* Initial size of write buffer */ 18641f34f8ccSdan int nNoop; /* Size of buffer after writing tbl header */ 18654fccf43aSdan 1866a9605b91Sdan /* Check the table schema is still Ok. */ 1867a9605b91Sdan rc = sessionTableInfo(db, pSession->zDb, zName, &nCol, 0, &azCol, &abPK); 1868a9605b91Sdan if( !rc && (pTab->nCol!=nCol || memcmp(abPK, pTab->abPK, nCol)) ){ 1869a9605b91Sdan rc = SQLITE_SCHEMA; 1870a9605b91Sdan } 1871a9605b91Sdan 18724fccf43aSdan /* Write a table header */ 187373b3c055Sdan sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); 18744fccf43aSdan 18754fccf43aSdan /* Build and compile a statement to execute: */ 18764fccf43aSdan if( rc==SQLITE_OK ){ 1877d7fb7d24Sdan rc = sessionSelectStmt( 1878a9605b91Sdan db, pSession->zDb, zName, nCol, azCol, abPK, &pSel); 18794fccf43aSdan } 18804fccf43aSdan 18811f34f8ccSdan nNoop = buf.nBuf; 188212ca0b56Sdan for(i=0; i<pTab->nChange && rc==SQLITE_OK; i++){ 1883e8d5648eSdan SessionChange *p; /* Used to iterate through changes */ 1884e8d5648eSdan 18854fccf43aSdan for(p=pTab->apChange[i]; rc==SQLITE_OK && p; p=p->pNext){ 1886e5754eecSdan rc = sessionSelectBind(pSel, nCol, abPK, p); 188780fe2d93Sdan if( rc!=SQLITE_OK ) continue; 18881f34f8ccSdan if( sqlite3_step(pSel)==SQLITE_ROW ){ 1889798693b2Sdan if( p->op==SQLITE_INSERT ){ 18904fccf43aSdan int iCol; 18914fccf43aSdan sessionAppendByte(&buf, SQLITE_INSERT, &rc); 1892b4480e94Sdan sessionAppendByte(&buf, p->bIndirect, &rc); 1893e8d5648eSdan for(iCol=0; iCol<nCol; iCol++){ 18941f34f8ccSdan sessionAppendCol(&buf, pSel, iCol, &rc); 18954fccf43aSdan } 1896e8d5648eSdan }else{ 189773b3c055Sdan rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); 18984fccf43aSdan } 1899798693b2Sdan }else if( p->op!=SQLITE_INSERT ){ 1900a71d2371Sdan rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); 19014fccf43aSdan } 190212ca0b56Sdan if( rc==SQLITE_OK ){ 19031f34f8ccSdan rc = sqlite3_reset(pSel); 19044fccf43aSdan } 1905ef7a6304Sdan 1906ef7a6304Sdan /* If the buffer is now larger than SESSIONS_STR_CHUNK_SIZE, pass 1907ef7a6304Sdan ** its contents to the xOutput() callback. */ 1908ef7a6304Sdan if( xOutput 1909ef7a6304Sdan && rc==SQLITE_OK 1910ef7a6304Sdan && buf.nBuf>nNoop 1911ef7a6304Sdan && buf.nBuf>SESSIONS_STR_CHUNK_SIZE 1912ef7a6304Sdan ){ 1913ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1914ef7a6304Sdan nNoop = -1; 1915ef7a6304Sdan buf.nBuf = 0; 1916ef7a6304Sdan } 1917ef7a6304Sdan 19184fccf43aSdan } 1919e8d5648eSdan } 19204fccf43aSdan 19211f34f8ccSdan sqlite3_finalize(pSel); 19221f34f8ccSdan if( buf.nBuf==nNoop ){ 19234fccf43aSdan buf.nBuf = nRewind; 19244fccf43aSdan } 1925cfdbde21Sdrh sqlite3_free((char*)azCol); /* cast works around VC++ bug */ 19264fccf43aSdan } 19274fccf43aSdan } 19284fccf43aSdan 19294fccf43aSdan if( rc==SQLITE_OK ){ 1930ef7a6304Sdan if( xOutput==0 ){ 19314fccf43aSdan *pnChangeset = buf.nBuf; 19324fccf43aSdan *ppChangeset = buf.aBuf; 1933ef7a6304Sdan buf.aBuf = 0; 1934ef7a6304Sdan }else if( buf.nBuf>0 ){ 1935ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1936ef7a6304Sdan } 19374fccf43aSdan } 19384c220252Sdan 1939ef7a6304Sdan sqlite3_free(buf.aBuf); 1940e5754eecSdan sqlite3_exec(db, "RELEASE changeset", 0, 0, 0); 19414c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 19424fccf43aSdan return rc; 19434fccf43aSdan } 19444fccf43aSdan 1945296c7658Sdan /* 194673b3c055Sdan ** Obtain a changeset object containing all changes recorded by the 194773b3c055Sdan ** session object passed as the first argument. 194873b3c055Sdan ** 194973b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 195073b3c055Sdan ** using sqlite3_free(). 195173b3c055Sdan */ 195273b3c055Sdan int sqlite3session_changeset( 195373b3c055Sdan sqlite3_session *pSession, /* Session object */ 195473b3c055Sdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 195573b3c055Sdan void **ppChangeset /* OUT: Buffer containing changeset */ 195673b3c055Sdan ){ 1957ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, 0, 0, pnChangeset, ppChangeset); 1958ef7a6304Sdan } 1959ef7a6304Sdan 1960ef7a6304Sdan /* 1961ef7a6304Sdan ** Streaming version of sqlite3session_changeset(). 1962ef7a6304Sdan */ 1963ef7a6304Sdan int sqlite3session_changeset_str( 1964ef7a6304Sdan sqlite3_session *pSession, 1965ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1966ef7a6304Sdan void *pOut 1967ef7a6304Sdan ){ 1968ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, xOutput, pOut, 0, 0); 1969ef7a6304Sdan } 1970ef7a6304Sdan 1971ef7a6304Sdan /* 1972ef7a6304Sdan ** Streaming version of sqlite3session_patchset(). 1973ef7a6304Sdan */ 1974ef7a6304Sdan int sqlite3session_patchset_str( 1975ef7a6304Sdan sqlite3_session *pSession, 1976ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1977ef7a6304Sdan void *pOut 1978ef7a6304Sdan ){ 1979ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, xOutput, pOut, 0, 0); 198073b3c055Sdan } 198173b3c055Sdan 198273b3c055Sdan /* 198373b3c055Sdan ** Obtain a patchset object containing all changes recorded by the 198473b3c055Sdan ** session object passed as the first argument. 198573b3c055Sdan ** 198673b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 198773b3c055Sdan ** using sqlite3_free(). 198873b3c055Sdan */ 198973b3c055Sdan int sqlite3session_patchset( 199073b3c055Sdan sqlite3_session *pSession, /* Session object */ 199173b3c055Sdan int *pnPatchset, /* OUT: Size of buffer at *ppChangeset */ 199273b3c055Sdan void **ppPatchset /* OUT: Buffer containing changeset */ 199373b3c055Sdan ){ 1994ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, 0, 0, pnPatchset, ppPatchset); 199573b3c055Sdan } 199673b3c055Sdan 199773b3c055Sdan /* 1998296c7658Sdan ** Enable or disable the session object passed as the first argument. 1999296c7658Sdan */ 20004fccf43aSdan int sqlite3session_enable(sqlite3_session *pSession, int bEnable){ 20014c220252Sdan int ret; 20024c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2003296c7658Sdan if( bEnable>=0 ){ 2004296c7658Sdan pSession->bEnable = bEnable; 20054fccf43aSdan } 20064c220252Sdan ret = pSession->bEnable; 20074c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 20084c220252Sdan return ret; 2009296c7658Sdan } 20104fccf43aSdan 20114fccf43aSdan /* 2012b4480e94Sdan ** Enable or disable the session object passed as the first argument. 2013b4480e94Sdan */ 2014b4480e94Sdan int sqlite3session_indirect(sqlite3_session *pSession, int bIndirect){ 2015b4480e94Sdan int ret; 2016b4480e94Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2017b4480e94Sdan if( bIndirect>=0 ){ 2018b4480e94Sdan pSession->bIndirect = bIndirect; 2019b4480e94Sdan } 2020b4480e94Sdan ret = pSession->bIndirect; 2021b4480e94Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2022b4480e94Sdan return ret; 2023b4480e94Sdan } 2024b4480e94Sdan 2025b4480e94Sdan /* 2026b69ec348Sdan ** Return true if there have been no changes to monitored tables recorded 2027b69ec348Sdan ** by the session object passed as the only argument. 2028b69ec348Sdan */ 2029b69ec348Sdan int sqlite3session_isempty(sqlite3_session *pSession){ 2030b69ec348Sdan int ret = 0; 2031b69ec348Sdan SessionTable *pTab; 2032b69ec348Sdan 2033b69ec348Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2034b69ec348Sdan for(pTab=pSession->pTable; pTab && ret==0; pTab=pTab->pNext){ 2035b69ec348Sdan ret = (pTab->nEntry>0); 2036b69ec348Sdan } 2037b69ec348Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2038b69ec348Sdan 2039ff530326Sdan return (ret==0); 2040b69ec348Sdan } 2041b69ec348Sdan 2042b69ec348Sdan /* 2043ef7a6304Sdan ** Do the work for either sqlite3changeset_start() or start_str(). 20444fccf43aSdan */ 2045ef7a6304Sdan int sessionChangesetStart( 2046296c7658Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2047ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2048ef7a6304Sdan void *pIn, 2049296c7658Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2050296c7658Sdan void *pChangeset /* Pointer to buffer containing changeset */ 20514fccf43aSdan ){ 20524fccf43aSdan sqlite3_changeset_iter *pRet; /* Iterator to return */ 20534fccf43aSdan int nByte; /* Number of bytes to allocate for iterator */ 20544fccf43aSdan 2055ef7a6304Sdan assert( xInput==0 || (pChangeset==0 && nChangeset==0) ); 2056ef7a6304Sdan 2057296c7658Sdan /* Zero the output variable in case an error occurs. */ 2058296c7658Sdan *pp = 0; 20594fccf43aSdan 2060296c7658Sdan /* Allocate and initialize the iterator structure. */ 20614fccf43aSdan nByte = sizeof(sqlite3_changeset_iter); 20624fccf43aSdan pRet = (sqlite3_changeset_iter *)sqlite3_malloc(nByte); 20634fccf43aSdan if( !pRet ) return SQLITE_NOMEM; 20644fccf43aSdan memset(pRet, 0, sizeof(sqlite3_changeset_iter)); 20654757c658Sdan pRet->in.aData = (u8 *)pChangeset; 20664757c658Sdan pRet->in.nData = nChangeset; 2067ef7a6304Sdan pRet->in.xInput = xInput; 2068ef7a6304Sdan pRet->in.pIn = pIn; 2069ef7a6304Sdan pRet->in.iNext = 0; 2070ef7a6304Sdan pRet->in.bEof = (xInput ? 0 : 1); 20714fccf43aSdan 2072296c7658Sdan /* Populate the output variable and return success. */ 2073296c7658Sdan *pp = pRet; 20744fccf43aSdan return SQLITE_OK; 20754fccf43aSdan } 20764fccf43aSdan 2077296c7658Sdan /* 2078ef7a6304Sdan ** Create an iterator used to iterate through the contents of a changeset. 2079ef7a6304Sdan */ 2080ef7a6304Sdan int sqlite3changeset_start( 2081ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2082ef7a6304Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2083ef7a6304Sdan void *pChangeset /* Pointer to buffer containing changeset */ 2084ef7a6304Sdan ){ 2085ef7a6304Sdan return sessionChangesetStart(pp, 0, 0, nChangeset, pChangeset); 2086ef7a6304Sdan } 2087ef7a6304Sdan 2088ef7a6304Sdan /* 2089ef7a6304Sdan ** Streaming version of sqlite3changeset_start(). 2090ef7a6304Sdan */ 2091ef7a6304Sdan int sqlite3changeset_start_str( 2092ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2093ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2094ef7a6304Sdan void *pIn 2095ef7a6304Sdan ){ 2096ef7a6304Sdan return sessionChangesetStart(pp, xInput, pIn, 0, 0); 2097ef7a6304Sdan } 2098ef7a6304Sdan 2099ef7a6304Sdan /* 2100ef7a6304Sdan ** Ensure that there are at least nByte bytes available in the buffer. Or, 2101ef7a6304Sdan ** if there are not nByte bytes remaining in the input, that all available 2102ef7a6304Sdan ** data is in the buffer. 2103ef7a6304Sdan ** 2104ef7a6304Sdan ** Return an SQLite error code if an error occurs, or SQLITE_OK otherwise. 2105ef7a6304Sdan */ 21064757c658Sdan static int sessionInputBuffer(SessionInput *pIn, int nByte){ 2107ef7a6304Sdan int rc = SQLITE_OK; 21084757c658Sdan if( pIn->xInput ){ 21094757c658Sdan while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ 21104757c658Sdan int nNew = SESSIONS_STR_CHUNK_SIZE; 21114757c658Sdan 21124757c658Sdan if( pIn->iNext>=SESSIONS_STR_CHUNK_SIZE ){ 21134757c658Sdan int nMove = pIn->buf.nBuf - pIn->iNext; 21144757c658Sdan memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove); 21154757c658Sdan pIn->buf.nBuf -= pIn->iNext; 21164757c658Sdan pIn->iNext = 0; 21174757c658Sdan } 21184757c658Sdan 21194757c658Sdan if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){ 21204757c658Sdan rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); 21214757c658Sdan if( nNew==0 ){ 21224757c658Sdan pIn->bEof = 1; 21234757c658Sdan }else{ 21244757c658Sdan pIn->buf.nBuf += nNew; 21254757c658Sdan } 21264757c658Sdan } 21274757c658Sdan 21284757c658Sdan pIn->aData = pIn->buf.aBuf; 21294757c658Sdan pIn->nData = pIn->buf.nBuf; 21304757c658Sdan } 2131ef7a6304Sdan } 2132ef7a6304Sdan return rc; 2133ef7a6304Sdan } 2134ef7a6304Sdan 2135ef7a6304Sdan /* 2136ef7a6304Sdan ** When this function is called, *ppRec points to the start of a record 2137ef7a6304Sdan ** that contains nCol values. This function advances the pointer *ppRec 2138ef7a6304Sdan ** until it points to the byte immediately following that record. 2139ef7a6304Sdan */ 2140ef7a6304Sdan static void sessionSkipRecord( 2141ef7a6304Sdan u8 **ppRec, /* IN/OUT: Record pointer */ 2142ef7a6304Sdan int nCol /* Number of values in record */ 2143ef7a6304Sdan ){ 2144ef7a6304Sdan u8 *aRec = *ppRec; 2145ef7a6304Sdan int i; 2146ef7a6304Sdan for(i=0; i<nCol; i++){ 2147ef7a6304Sdan int eType = *aRec++; 2148ef7a6304Sdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2149ef7a6304Sdan int nByte; 2150ef7a6304Sdan aRec += sessionVarintGet((u8*)aRec, &nByte); 2151ef7a6304Sdan aRec += nByte; 2152ef7a6304Sdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2153ef7a6304Sdan aRec += 8; 2154ef7a6304Sdan } 2155ef7a6304Sdan } 2156ef7a6304Sdan 2157ef7a6304Sdan *ppRec = aRec; 2158ef7a6304Sdan } 2159ef7a6304Sdan 2160ef7a6304Sdan /* 21614757c658Sdan ** This function sets the value of the sqlite3_value object passed as the 21624757c658Sdan ** first argument to a copy of the string or blob held in the aData[] 21634757c658Sdan ** buffer. SQLITE_OK is returned if successful, or SQLITE_NOMEM if an OOM 21644757c658Sdan ** error occurs. 21654757c658Sdan */ 21664757c658Sdan static int sessionValueSetStr( 21674757c658Sdan sqlite3_value *pVal, /* Set the value of this object */ 21684757c658Sdan u8 *aData, /* Buffer containing string or blob data */ 21694757c658Sdan int nData, /* Size of buffer aData[] in bytes */ 21704757c658Sdan u8 enc /* String encoding (0 for blobs) */ 21714757c658Sdan ){ 21724757c658Sdan u8 *aCopy = sqlite3_malloc(nData); 21734757c658Sdan if( aCopy==0 ) return SQLITE_NOMEM; 21744757c658Sdan memcpy(aCopy, aData, nData); 21754757c658Sdan sqlite3ValueSetStr(pVal, nData, (char*)aCopy, enc, sqlite3_free); 21764757c658Sdan return SQLITE_OK; 21774757c658Sdan } 21784757c658Sdan 21794757c658Sdan /* 2180296c7658Sdan ** Deserialize a single record from a buffer in memory. See "RECORD FORMAT" 2181296c7658Sdan ** for details. 2182296c7658Sdan ** 2183296c7658Sdan ** When this function is called, *paChange points to the start of the record 2184296c7658Sdan ** to deserialize. Assuming no error occurs, *paChange is set to point to 2185296c7658Sdan ** one byte after the end of the same record before this function returns. 2186a71d2371Sdan ** If the argument abPK is NULL, then the record contains nCol values. Or, 2187a71d2371Sdan ** if abPK is other than NULL, then the record contains only the PK fields 2188a71d2371Sdan ** (in other words, it is a patchset DELETE record). 2189296c7658Sdan ** 2190296c7658Sdan ** If successful, each element of the apOut[] array (allocated by the caller) 2191296c7658Sdan ** is set to point to an sqlite3_value object containing the value read 2192296c7658Sdan ** from the corresponding position in the record. If that value is not 2193296c7658Sdan ** included in the record (i.e. because the record is part of an UPDATE change 2194296c7658Sdan ** and the field was not modified), the corresponding element of apOut[] is 2195296c7658Sdan ** set to NULL. 2196296c7658Sdan ** 2197296c7658Sdan ** It is the responsibility of the caller to free all sqlite_value structures 2198296c7658Sdan ** using sqlite3_free(). 2199296c7658Sdan ** 2200296c7658Sdan ** If an error occurs, an SQLite error code (e.g. SQLITE_NOMEM) is returned. 2201296c7658Sdan ** The apOut[] array may have been partially populated in this case. 2202296c7658Sdan */ 22034fccf43aSdan static int sessionReadRecord( 2204ef7a6304Sdan SessionInput *pIn, /* Input data */ 22054fccf43aSdan int nCol, /* Number of values in record */ 220673b3c055Sdan u8 *abPK, /* Array of primary key flags, or NULL */ 22074fccf43aSdan sqlite3_value **apOut /* Write values to this array */ 22084fccf43aSdan ){ 2209296c7658Sdan int i; /* Used to iterate through columns */ 2210ef7a6304Sdan int rc = SQLITE_OK; 22114fccf43aSdan 2212ef7a6304Sdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 2213ef7a6304Sdan int eType = 0; /* Type of value (SQLITE_NULL, TEXT etc.) */ 221473b3c055Sdan if( abPK && abPK[i]==0 ) continue; 2215ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2216ef7a6304Sdan if( rc==SQLITE_OK ){ 22174757c658Sdan eType = pIn->aData[pIn->iNext++]; 2218ef7a6304Sdan } 2219ef7a6304Sdan 222091ddd559Sdan assert( !apOut || apOut[i]==0 ); 22214fccf43aSdan if( eType ){ 222291ddd559Sdan if( apOut ){ 22234fccf43aSdan apOut[i] = sqlite3ValueNew(0); 2224ef7a6304Sdan if( !apOut[i] ) rc = SQLITE_NOMEM; 2225ef7a6304Sdan } 222691ddd559Sdan } 22274fccf43aSdan 2228ef7a6304Sdan if( rc==SQLITE_OK ){ 22294757c658Sdan u8 *aVal = &pIn->aData[pIn->iNext]; 22304fccf43aSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 22314fccf43aSdan int nByte; 2232ef7a6304Sdan pIn->iNext += sessionVarintGet(aVal, &nByte); 2233ef7a6304Sdan rc = sessionInputBuffer(pIn, nByte); 2234ef7a6304Sdan if( apOut && rc==SQLITE_OK ){ 22356734007dSdan u8 enc = (eType==SQLITE_TEXT ? SQLITE_UTF8 : 0); 22364757c658Sdan rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc); 223791ddd559Sdan } 2238ef7a6304Sdan pIn->iNext += nByte; 22394fccf43aSdan } 22404fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 224191ddd559Sdan if( apOut ){ 2242ef7a6304Sdan sqlite3_int64 v = sessionGetI64(aVal); 22434fccf43aSdan if( eType==SQLITE_INTEGER ){ 22444fccf43aSdan sqlite3VdbeMemSetInt64(apOut[i], v); 22454fccf43aSdan }else{ 22464fccf43aSdan double d; 22474e895da1Sdan memcpy(&d, &v, 8); 22484fccf43aSdan sqlite3VdbeMemSetDouble(apOut[i], d); 22494fccf43aSdan } 22504fccf43aSdan } 2251ef7a6304Sdan pIn->iNext += 8; 225291ddd559Sdan } 22534fccf43aSdan } 22544fccf43aSdan } 22554fccf43aSdan 2256ef7a6304Sdan return rc; 2257ef7a6304Sdan } 2258ef7a6304Sdan 2259ef7a6304Sdan /* 2260ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2261ef7a6304Sdan ** Specifically, to the following: 2262ef7a6304Sdan ** 2263ef7a6304Sdan ** + number of columns in table (varint) 2264ef7a6304Sdan ** + array of PK flags (1 byte per column), 2265ef7a6304Sdan ** + table name (nul terminated). 2266ef7a6304Sdan ** 2267ef7a6304Sdan ** This function ensures that all of the above is present in the input 2268ef7a6304Sdan ** buffer (i.e. that it can be accessed without any calls to xInput()). 2269ef7a6304Sdan ** If successful, SQLITE_OK is returned. Otherwise, an SQLite error code. 2270ef7a6304Sdan ** The input pointer is not moved. 2271ef7a6304Sdan */ 2272ef7a6304Sdan static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){ 2273ef7a6304Sdan int rc = SQLITE_OK; 2274ef7a6304Sdan int nCol = 0; 22754757c658Sdan int nRead = 0; 2276ef7a6304Sdan 2277ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2278ef7a6304Sdan if( rc==SQLITE_OK ){ 22794757c658Sdan nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol); 22804757c658Sdan rc = sessionInputBuffer(pIn, nRead+nCol+100); 22814757c658Sdan nRead += nCol; 2282ef7a6304Sdan } 22834757c658Sdan 2284ef7a6304Sdan while( rc==SQLITE_OK ){ 22854757c658Sdan while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){ 22864757c658Sdan nRead++; 2287ef7a6304Sdan } 22884757c658Sdan if( pIn->aData[pIn->iNext + nRead]==0 ) break; 22894757c658Sdan rc = sessionInputBuffer(pIn, nRead + 100); 22904757c658Sdan } 22914757c658Sdan if( pnByte ) *pnByte = nRead+1; 2292ef7a6304Sdan return rc; 2293ef7a6304Sdan } 2294ef7a6304Sdan 2295ef7a6304Sdan /* 2296fa122adaSdan ** The input pointer currently points to the first byte of the first field 2297fa122adaSdan ** of a record consisting of nCol columns. This function ensures the entire 2298fa122adaSdan ** record is buffered. 2299fa122adaSdan */ 2300fa122adaSdan static int sessionChangesetBufferRecord( 2301fa122adaSdan SessionInput *pIn, 2302fa122adaSdan int nCol, 2303fa122adaSdan int *pnByte 2304fa122adaSdan ){ 2305fa122adaSdan int rc = SQLITE_OK; 2306fa122adaSdan int nByte = 0; 2307fa122adaSdan int i; 2308fa122adaSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 2309fa122adaSdan int eType; 2310fa122adaSdan rc = sessionInputBuffer(pIn, nByte + 10); 2311fa122adaSdan if( rc==SQLITE_OK ){ 2312fa122adaSdan eType = pIn->aData[pIn->iNext + nByte++]; 2313fa122adaSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2314fa122adaSdan int n; 2315fa122adaSdan nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n); 2316fa122adaSdan nByte += n; 2317fa122adaSdan rc = sessionInputBuffer(pIn, nByte); 2318fa122adaSdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2319fa122adaSdan nByte += 8; 2320fa122adaSdan } 2321fa122adaSdan } 2322fa122adaSdan } 2323fa122adaSdan *pnByte = nByte; 2324fa122adaSdan return rc; 2325fa122adaSdan } 2326fa122adaSdan 2327fa122adaSdan /* 2328ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2329ef7a6304Sdan ** Specifically, to the following: 2330ef7a6304Sdan ** 2331ef7a6304Sdan ** + number of columns in table (varint) 2332ef7a6304Sdan ** + array of PK flags (1 byte per column), 2333ef7a6304Sdan ** + table name (nul terminated). 2334ef7a6304Sdan */ 2335ef7a6304Sdan static int sessionChangesetReadTblhdr(sqlite3_changeset_iter *p){ 2336ef7a6304Sdan int rc; 2337ef7a6304Sdan int nCopy; 2338ef7a6304Sdan assert( p->rc==SQLITE_OK ); 2339ef7a6304Sdan 2340ef7a6304Sdan rc = sessionChangesetBufferTblhdr(&p->in, &nCopy); 2341ef7a6304Sdan if( rc==SQLITE_OK ){ 2342ef7a6304Sdan int nByte; 2343ef7a6304Sdan int nVarint; 23444757c658Sdan nVarint = sessionVarintGet(&p->in.aData[p->in.iNext], &p->nCol); 2345ef7a6304Sdan nCopy -= nVarint; 2346ef7a6304Sdan p->in.iNext += nVarint; 2347ef7a6304Sdan nByte = p->nCol * sizeof(sqlite3_value*) * 2 + nCopy; 2348ef7a6304Sdan p->tblhdr.nBuf = 0; 2349ef7a6304Sdan sessionBufferGrow(&p->tblhdr, nByte, &rc); 2350ef7a6304Sdan } 2351ef7a6304Sdan 2352ef7a6304Sdan if( rc==SQLITE_OK ){ 2353ef7a6304Sdan int iPK = sizeof(sqlite3_value*)*p->nCol*2; 2354ef7a6304Sdan memset(p->tblhdr.aBuf, 0, iPK); 23554757c658Sdan memcpy(&p->tblhdr.aBuf[iPK], &p->in.aData[p->in.iNext], nCopy); 2356ef7a6304Sdan p->in.iNext += nCopy; 2357ef7a6304Sdan } 2358ef7a6304Sdan 2359ef7a6304Sdan p->apValue = (sqlite3_value**)p->tblhdr.aBuf; 2360ef7a6304Sdan p->abPK = (u8*)&p->apValue[p->nCol*2]; 2361ef7a6304Sdan p->zTab = (char*)&p->abPK[p->nCol]; 2362ef7a6304Sdan return (p->rc = rc); 23634fccf43aSdan } 23644fccf43aSdan 236577fc1d5bSdan /* 236677fc1d5bSdan ** Advance the changeset iterator to the next change. 236777fc1d5bSdan ** 236877fc1d5bSdan ** If both paRec and pnRec are NULL, then this function works like the public 236977fc1d5bSdan ** API sqlite3changeset_next(). If SQLITE_ROW is returned, then the 237077fc1d5bSdan ** sqlite3changeset_new() and old() APIs may be used to query for values. 237177fc1d5bSdan ** 237277fc1d5bSdan ** Otherwise, if paRec and pnRec are not NULL, then a pointer to the change 237377fc1d5bSdan ** record is written to *paRec before returning and the number of bytes in 237477fc1d5bSdan ** the record to *pnRec. 237577fc1d5bSdan ** 237677fc1d5bSdan ** Either way, this function returns SQLITE_ROW if the iterator is 237777fc1d5bSdan ** successfully advanced to the next change in the changeset, an SQLite 237877fc1d5bSdan ** error code if an error occurs, or SQLITE_DONE if there are no further 237977fc1d5bSdan ** changes in the changeset. 238077fc1d5bSdan */ 23815d607a6eSdan static int sessionChangesetNext( 238277fc1d5bSdan sqlite3_changeset_iter *p, /* Changeset iterator */ 238377fc1d5bSdan u8 **paRec, /* If non-NULL, store record pointer here */ 238477fc1d5bSdan int *pnRec /* If non-NULL, store size of record here */ 23855d607a6eSdan ){ 23864fccf43aSdan int i; 2387ef7a6304Sdan u8 op; 23884fccf43aSdan 23895d607a6eSdan assert( (paRec==0 && pnRec==0) || (paRec && pnRec) ); 23905d607a6eSdan 2391296c7658Sdan /* If the iterator is in the error-state, return immediately. */ 23924fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 23934fccf43aSdan 23945d607a6eSdan /* Free the current contents of p->apValue[], if any. */ 23954fccf43aSdan if( p->apValue ){ 23964fccf43aSdan for(i=0; i<p->nCol*2; i++){ 23974fccf43aSdan sqlite3ValueFree(p->apValue[i]); 23984fccf43aSdan } 23994fccf43aSdan memset(p->apValue, 0, sizeof(sqlite3_value*)*p->nCol*2); 24004fccf43aSdan } 24014fccf43aSdan 2402ef7a6304Sdan /* Make sure the buffer contains at least 10 bytes of input data, or all 2403ef7a6304Sdan ** remaining data if there are less than 10 bytes available. This is 2404ef7a6304Sdan ** sufficient either for the 'T' or 'P' byte and the varint that follows 2405ef7a6304Sdan ** it, or for the two single byte values otherwise. */ 2406ef7a6304Sdan p->rc = sessionInputBuffer(&p->in, 2); 2407ef7a6304Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2408ef7a6304Sdan 24094fccf43aSdan /* If the iterator is already at the end of the changeset, return DONE. */ 24104757c658Sdan if( p->in.iNext>=p->in.nData ){ 24114fccf43aSdan return SQLITE_DONE; 24124fccf43aSdan } 24134fccf43aSdan 24144757c658Sdan op = p->in.aData[p->in.iNext++]; 2415ef7a6304Sdan if( op=='T' || op=='P' ){ 2416ef7a6304Sdan p->bPatchset = (op=='P'); 2417ef7a6304Sdan if( sessionChangesetReadTblhdr(p) ) return p->rc; 2418ef7a6304Sdan if( (p->rc = sessionInputBuffer(&p->in, 2)) ) return p->rc; 24194757c658Sdan op = p->in.aData[p->in.iNext++]; 24205d607a6eSdan } 24215d607a6eSdan 2422ef7a6304Sdan p->op = op; 24234757c658Sdan p->bIndirect = p->in.aData[p->in.iNext++]; 24244fccf43aSdan if( p->op!=SQLITE_UPDATE && p->op!=SQLITE_DELETE && p->op!=SQLITE_INSERT ){ 24254757c658Sdan return (p->rc = SQLITE_CORRUPT_BKPT); 24264fccf43aSdan } 24274fccf43aSdan 2428*cbf6d2d2Sdan if( paRec ){ 2429*cbf6d2d2Sdan int nVal; /* Number of values to buffer */ 2430*cbf6d2d2Sdan if( p->bPatchset==0 && op==SQLITE_UPDATE ){ 2431*cbf6d2d2Sdan nVal = p->nCol * 2; 2432*cbf6d2d2Sdan }else if( p->bPatchset && op==SQLITE_DELETE ){ 2433*cbf6d2d2Sdan nVal = 0; 2434*cbf6d2d2Sdan for(i=0; i<p->nCol; i++) if( p->abPK[i] ) nVal++; 2435*cbf6d2d2Sdan }else{ 2436*cbf6d2d2Sdan nVal = p->nCol; 2437*cbf6d2d2Sdan } 2438*cbf6d2d2Sdan p->rc = sessionChangesetBufferRecord(&p->in, nVal, pnRec); 2439*cbf6d2d2Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2440*cbf6d2d2Sdan *paRec = &p->in.aData[p->in.iNext]; 2441*cbf6d2d2Sdan p->in.iNext += *pnRec; 2442*cbf6d2d2Sdan }else{ 24435d607a6eSdan 24444fccf43aSdan /* If this is an UPDATE or DELETE, read the old.* record. */ 244573b3c055Sdan if( p->op!=SQLITE_INSERT && (p->bPatchset==0 || p->op==SQLITE_DELETE) ){ 244673b3c055Sdan u8 *abPK = p->bPatchset ? p->abPK : 0; 2447*cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, abPK, p->apValue); 24484fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24494fccf43aSdan } 24504fccf43aSdan 24514fccf43aSdan /* If this is an INSERT or UPDATE, read the new.* record. */ 24524fccf43aSdan if( p->op!=SQLITE_DELETE ){ 2453*cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, 0, &p->apValue[p->nCol]); 24544fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24554fccf43aSdan } 24564fccf43aSdan 2457*cbf6d2d2Sdan if( p->bPatchset && p->op==SQLITE_UPDATE ){ 245873b3c055Sdan /* If this is an UPDATE that is part of a patchset, then all PK and 245973b3c055Sdan ** modified fields are present in the new.* record. The old.* record 246073b3c055Sdan ** is currently completely empty. This block shifts the PK fields from 246173b3c055Sdan ** new.* to old.*, to accommodate the code that reads these arrays. */ 246273b3c055Sdan int i; 246373b3c055Sdan for(i=0; i<p->nCol; i++){ 246473b3c055Sdan assert( p->apValue[i]==0 ); 246573b3c055Sdan assert( p->abPK[i]==0 || p->apValue[i+p->nCol] ); 246673b3c055Sdan if( p->abPK[i] ){ 246773b3c055Sdan p->apValue[i] = p->apValue[i+p->nCol]; 246873b3c055Sdan p->apValue[i+p->nCol] = 0; 246973b3c055Sdan } 247073b3c055Sdan } 247173b3c055Sdan } 2472*cbf6d2d2Sdan } 2473ef7a6304Sdan 24744fccf43aSdan return SQLITE_ROW; 24754fccf43aSdan } 24764fccf43aSdan 24774fccf43aSdan /* 24785d607a6eSdan ** Advance an iterator created by sqlite3changeset_start() to the next 24795d607a6eSdan ** change in the changeset. This function may return SQLITE_ROW, SQLITE_DONE 24805d607a6eSdan ** or SQLITE_CORRUPT. 24815d607a6eSdan ** 24825d607a6eSdan ** This function may not be called on iterators passed to a conflict handler 24835d607a6eSdan ** callback by changeset_apply(). 24845d607a6eSdan */ 24855d607a6eSdan int sqlite3changeset_next(sqlite3_changeset_iter *p){ 24865d607a6eSdan return sessionChangesetNext(p, 0, 0); 24875d607a6eSdan } 24885d607a6eSdan 24895d607a6eSdan /* 2490244593c8Sdan ** The following function extracts information on the current change 249177fc1d5bSdan ** from a changeset iterator. It may only be called after changeset_next() 24924fccf43aSdan ** has returned SQLITE_ROW. 24934fccf43aSdan */ 24944fccf43aSdan int sqlite3changeset_op( 2495296c7658Sdan sqlite3_changeset_iter *pIter, /* Iterator handle */ 24964fccf43aSdan const char **pzTab, /* OUT: Pointer to table name */ 24974fccf43aSdan int *pnCol, /* OUT: Number of columns in table */ 2498b4480e94Sdan int *pOp, /* OUT: SQLITE_INSERT, DELETE or UPDATE */ 2499b4480e94Sdan int *pbIndirect /* OUT: True if change is indirect */ 25004fccf43aSdan ){ 25014fccf43aSdan *pOp = pIter->op; 25024fccf43aSdan *pnCol = pIter->nCol; 25034fccf43aSdan *pzTab = pIter->zTab; 2504b4480e94Sdan if( pbIndirect ) *pbIndirect = pIter->bIndirect; 25054fccf43aSdan return SQLITE_OK; 25064fccf43aSdan } 25074fccf43aSdan 250877fc1d5bSdan /* 250977fc1d5bSdan ** Return information regarding the PRIMARY KEY and number of columns in 251077fc1d5bSdan ** the database table affected by the change that pIter currently points 251177fc1d5bSdan ** to. This function may only be called after changeset_next() returns 251277fc1d5bSdan ** SQLITE_ROW. 251377fc1d5bSdan */ 2514244593c8Sdan int sqlite3changeset_pk( 2515244593c8Sdan sqlite3_changeset_iter *pIter, /* Iterator object */ 2516244593c8Sdan unsigned char **pabPK, /* OUT: Array of boolean - true for PK cols */ 2517244593c8Sdan int *pnCol /* OUT: Number of entries in output array */ 2518244593c8Sdan ){ 2519244593c8Sdan *pabPK = pIter->abPK; 2520244593c8Sdan if( pnCol ) *pnCol = pIter->nCol; 2521244593c8Sdan return SQLITE_OK; 2522244593c8Sdan } 2523244593c8Sdan 2524296c7658Sdan /* 2525296c7658Sdan ** This function may only be called while the iterator is pointing to an 2526296c7658Sdan ** SQLITE_UPDATE or SQLITE_DELETE change (see sqlite3changeset_op()). 2527296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2528296c7658Sdan ** 2529296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2530296c7658Sdan ** iVal'th value in the old.* record. Or, if that particular value is not 2531296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2532296c7658Sdan ** was not modified and is not a PK column), set *ppValue to NULL. 2533296c7658Sdan ** 2534296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2535296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2536296c7658Sdan */ 25374fccf43aSdan int sqlite3changeset_old( 2538296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2539296c7658Sdan int iVal, /* Index of old.* value to retrieve */ 25404fccf43aSdan sqlite3_value **ppValue /* OUT: Old value (or NULL pointer) */ 25414fccf43aSdan ){ 2542d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_DELETE ){ 2543d5f0767cSdan return SQLITE_MISUSE; 2544d5f0767cSdan } 25454fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25464fccf43aSdan return SQLITE_RANGE; 25474fccf43aSdan } 25484fccf43aSdan *ppValue = pIter->apValue[iVal]; 25494fccf43aSdan return SQLITE_OK; 25504fccf43aSdan } 25514fccf43aSdan 2552296c7658Sdan /* 2553296c7658Sdan ** This function may only be called while the iterator is pointing to an 2554296c7658Sdan ** SQLITE_UPDATE or SQLITE_INSERT change (see sqlite3changeset_op()). 2555296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2556296c7658Sdan ** 2557296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2558296c7658Sdan ** iVal'th value in the new.* record. Or, if that particular value is not 2559296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2560296c7658Sdan ** was not modified), set *ppValue to NULL. 2561296c7658Sdan ** 2562296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2563296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2564296c7658Sdan */ 25654fccf43aSdan int sqlite3changeset_new( 2566296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2567296c7658Sdan int iVal, /* Index of new.* value to retrieve */ 25684fccf43aSdan sqlite3_value **ppValue /* OUT: New value (or NULL pointer) */ 25694fccf43aSdan ){ 2570d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_INSERT ){ 2571d5f0767cSdan return SQLITE_MISUSE; 2572d5f0767cSdan } 25734fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25744fccf43aSdan return SQLITE_RANGE; 25754fccf43aSdan } 25764fccf43aSdan *ppValue = pIter->apValue[pIter->nCol+iVal]; 25774fccf43aSdan return SQLITE_OK; 25784fccf43aSdan } 25794fccf43aSdan 2580296c7658Sdan /* 25817aa469cdSdan ** The following two macros are used internally. They are similar to the 25827aa469cdSdan ** sqlite3changeset_new() and sqlite3changeset_old() functions, except that 25837aa469cdSdan ** they omit all error checking and return a pointer to the requested value. 25847aa469cdSdan */ 25857aa469cdSdan #define sessionChangesetNew(pIter, iVal) (pIter)->apValue[(pIter)->nCol+(iVal)] 25867aa469cdSdan #define sessionChangesetOld(pIter, iVal) (pIter)->apValue[(iVal)] 25877aa469cdSdan 25887aa469cdSdan /* 2589296c7658Sdan ** This function may only be called with a changeset iterator that has been 2590296c7658Sdan ** passed to an SQLITE_CHANGESET_DATA or SQLITE_CHANGESET_CONFLICT 2591296c7658Sdan ** conflict-handler function. Otherwise, SQLITE_MISUSE is returned. 2592296c7658Sdan ** 2593296c7658Sdan ** If successful, *ppValue is set to point to an sqlite3_value structure 2594296c7658Sdan ** containing the iVal'th value of the conflicting record. 2595296c7658Sdan ** 2596296c7658Sdan ** If value iVal is out-of-range or some other error occurs, an SQLite error 2597296c7658Sdan ** code is returned. Otherwise, SQLITE_OK. 2598296c7658Sdan */ 2599d5f0767cSdan int sqlite3changeset_conflict( 2600296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2601296c7658Sdan int iVal, /* Index of conflict record value to fetch */ 2602d5f0767cSdan sqlite3_value **ppValue /* OUT: Value from conflicting row */ 2603d5f0767cSdan ){ 2604d5f0767cSdan if( !pIter->pConflict ){ 2605d5f0767cSdan return SQLITE_MISUSE; 2606d5f0767cSdan } 2607d5f0767cSdan if( iVal<0 || iVal>=sqlite3_column_count(pIter->pConflict) ){ 2608d5f0767cSdan return SQLITE_RANGE; 2609d5f0767cSdan } 2610d5f0767cSdan *ppValue = sqlite3_column_value(pIter->pConflict, iVal); 2611d5f0767cSdan return SQLITE_OK; 2612d5f0767cSdan } 2613d5f0767cSdan 26144fccf43aSdan /* 2615cb3e4b79Sdan ** This function may only be called with an iterator passed to an 2616cb3e4b79Sdan ** SQLITE_CHANGESET_FOREIGN_KEY conflict handler callback. In this case 2617cb3e4b79Sdan ** it sets the output variable to the total number of known foreign key 2618cb3e4b79Sdan ** violations in the destination database and returns SQLITE_OK. 2619cb3e4b79Sdan ** 2620cb3e4b79Sdan ** In all other cases this function returns SQLITE_MISUSE. 2621cb3e4b79Sdan */ 2622cb3e4b79Sdan int sqlite3changeset_fk_conflicts( 2623cb3e4b79Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2624cb3e4b79Sdan int *pnOut /* OUT: Number of FK violations */ 2625cb3e4b79Sdan ){ 2626cb3e4b79Sdan if( pIter->pConflict || pIter->apValue ){ 2627cb3e4b79Sdan return SQLITE_MISUSE; 2628cb3e4b79Sdan } 2629cb3e4b79Sdan *pnOut = pIter->nCol; 2630cb3e4b79Sdan return SQLITE_OK; 2631cb3e4b79Sdan } 2632cb3e4b79Sdan 2633cb3e4b79Sdan 2634cb3e4b79Sdan /* 26354fccf43aSdan ** Finalize an iterator allocated with sqlite3changeset_start(). 26364fccf43aSdan ** 26374fccf43aSdan ** This function may not be called on iterators passed to a conflict handler 26384fccf43aSdan ** callback by changeset_apply(). 26394fccf43aSdan */ 26404fccf43aSdan int sqlite3changeset_finalize(sqlite3_changeset_iter *p){ 2641*cbf6d2d2Sdan int rc = SQLITE_OK; 2642*cbf6d2d2Sdan if( p ){ 2643296c7658Sdan int i; /* Used to iterate through p->apValue[] */ 2644*cbf6d2d2Sdan rc = p->rc; 264512ca0b56Sdan if( p->apValue ){ 26464fccf43aSdan for(i=0; i<p->nCol*2; i++) sqlite3ValueFree(p->apValue[i]); 264712ca0b56Sdan } 2648ef7a6304Sdan sqlite3_free(p->tblhdr.aBuf); 26494757c658Sdan sqlite3_free(p->in.buf.aBuf); 26504fccf43aSdan sqlite3_free(p); 2651*cbf6d2d2Sdan } 26524fccf43aSdan return rc; 26534fccf43aSdan } 26544fccf43aSdan 2655fa122adaSdan static int sessionChangesetInvert( 2656fa122adaSdan SessionInput *pInput, /* Input changeset */ 2657fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2658fa122adaSdan void *pOut, 265991ddd559Sdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 266091ddd559Sdan void **ppInverted /* OUT: Inverse of pChangeset */ 266191ddd559Sdan ){ 2662cfec7eeeSdan int rc = SQLITE_OK; /* Return value */ 2663fa122adaSdan SessionBuffer sOut; /* Output buffer */ 2664cfec7eeeSdan int nCol = 0; /* Number of cols in current table */ 2665cfec7eeeSdan u8 *abPK = 0; /* PK array for current table */ 2666cfec7eeeSdan sqlite3_value **apVal = 0; /* Space for values for UPDATE inversion */ 2667ef7a6304Sdan SessionBuffer sPK = {0, 0, 0}; /* PK array for current table */ 266891ddd559Sdan 2669fa122adaSdan /* Initialize the output buffer */ 2670fa122adaSdan memset(&sOut, 0, sizeof(SessionBuffer)); 2671fa122adaSdan 267291ddd559Sdan /* Zero the output variables in case an error occurs. */ 2673fa122adaSdan if( ppInverted ){ 267491ddd559Sdan *ppInverted = 0; 267591ddd559Sdan *pnInverted = 0; 2676fa122adaSdan } 267791ddd559Sdan 2678fa122adaSdan while( 1 ){ 2679ef7a6304Sdan u8 eType; 2680fa122adaSdan 2681fa122adaSdan /* Test for EOF. */ 2682fa122adaSdan if( (rc = sessionInputBuffer(pInput, 2)) ) goto finished_invert; 2683fa122adaSdan if( pInput->iNext>=pInput->nData ) break; 2684fa122adaSdan eType = pInput->aData[pInput->iNext]; 2685fa122adaSdan 268691ddd559Sdan switch( eType ){ 268791ddd559Sdan case 'T': { 2688244593c8Sdan /* A 'table' record consists of: 2689244593c8Sdan ** 2690244593c8Sdan ** * A constant 'T' character, 2691244593c8Sdan ** * Number of columns in said table (a varint), 2692ef7a6304Sdan ** * An array of nCol bytes (sPK), 2693244593c8Sdan ** * A nul-terminated table name. 2694244593c8Sdan */ 2695ef7a6304Sdan int nByte; 2696fa122adaSdan int nVar; 2697fa122adaSdan pInput->iNext++; 2698fa122adaSdan if( (rc = sessionChangesetBufferTblhdr(pInput, &nByte)) ){ 2699ef7a6304Sdan goto finished_invert; 2700ef7a6304Sdan } 2701fa122adaSdan nVar = sessionVarintGet(&pInput->aData[pInput->iNext], &nCol); 2702ef7a6304Sdan sPK.nBuf = 0; 2703fa122adaSdan sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc); 2704fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2705fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2706ef7a6304Sdan if( rc ) goto finished_invert; 2707fa122adaSdan 2708fa122adaSdan pInput->iNext += nByte; 2709cfec7eeeSdan sqlite3_free(apVal); 2710cfec7eeeSdan apVal = 0; 2711ef7a6304Sdan abPK = sPK.aBuf; 271291ddd559Sdan break; 271391ddd559Sdan } 271491ddd559Sdan 271591ddd559Sdan case SQLITE_INSERT: 271691ddd559Sdan case SQLITE_DELETE: { 271791ddd559Sdan int nByte; 2718fa122adaSdan int bIndirect = pInput->aData[pInput->iNext+1]; 2719fa122adaSdan int eType2 = (eType==SQLITE_DELETE ? SQLITE_INSERT : SQLITE_DELETE); 2720fa122adaSdan pInput->iNext += 2; 2721fa122adaSdan assert( rc==SQLITE_OK ); 2722fa122adaSdan rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); 2723fa122adaSdan sessionAppendByte(&sOut, eType2, &rc); 2724fa122adaSdan sessionAppendByte(&sOut, bIndirect, &rc); 2725fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2726fa122adaSdan pInput->iNext += nByte; 2727fa122adaSdan if( rc ) goto finished_invert; 272891ddd559Sdan break; 272991ddd559Sdan } 273091ddd559Sdan 273191ddd559Sdan case SQLITE_UPDATE: { 2732cfec7eeeSdan int iCol; 273391ddd559Sdan 2734cfec7eeeSdan if( 0==apVal ){ 2735cfec7eeeSdan apVal = (sqlite3_value **)sqlite3_malloc(sizeof(apVal[0])*nCol*2); 2736cfec7eeeSdan if( 0==apVal ){ 2737cfec7eeeSdan rc = SQLITE_NOMEM; 2738cfec7eeeSdan goto finished_invert; 2739cfec7eeeSdan } 2740cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2741cfec7eeeSdan } 274291ddd559Sdan 2743cfec7eeeSdan /* Write the header for the new UPDATE change. Same as the original. */ 2744fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2745fa122adaSdan sessionAppendByte(&sOut, pInput->aData[pInput->iNext+1], &rc); 274691ddd559Sdan 2747ef7a6304Sdan /* Read the old.* and new.* records for the update change. */ 2748fa122adaSdan pInput->iNext += 2; 2749fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[0]); 2750ef7a6304Sdan if( rc==SQLITE_OK ){ 2751fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[nCol]); 2752ef7a6304Sdan } 2753ef7a6304Sdan 2754cfec7eeeSdan /* Write the new old.* record. Consists of the PK columns from the 2755cfec7eeeSdan ** original old.* record, and the other values from the original 2756cfec7eeeSdan ** new.* record. */ 2757cfec7eeeSdan for(iCol=0; rc==SQLITE_OK && iCol<nCol; iCol++){ 2758cfec7eeeSdan sqlite3_value *pVal = apVal[iCol + (abPK[iCol] ? 0 : nCol)]; 2759fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2760cfec7eeeSdan } 2761cfec7eeeSdan 2762cfec7eeeSdan /* Write the new new.* record. Consists of a copy of all values 2763cfec7eeeSdan ** from the original old.* record, except for the PK columns, which 2764cfec7eeeSdan ** are set to "undefined". */ 2765cfec7eeeSdan for(iCol=0; rc==SQLITE_OK && iCol<nCol; iCol++){ 2766cfec7eeeSdan sqlite3_value *pVal = (abPK[iCol] ? 0 : apVal[iCol]); 2767fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2768cfec7eeeSdan } 2769cfec7eeeSdan 2770cfec7eeeSdan for(iCol=0; iCol<nCol*2; iCol++){ 2771cfec7eeeSdan sqlite3ValueFree(apVal[iCol]); 2772cfec7eeeSdan } 2773cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2774cfec7eeeSdan if( rc!=SQLITE_OK ){ 2775cfec7eeeSdan goto finished_invert; 2776cfec7eeeSdan } 2777cfec7eeeSdan 277891ddd559Sdan break; 277991ddd559Sdan } 278091ddd559Sdan 278191ddd559Sdan default: 27824757c658Sdan rc = SQLITE_CORRUPT_BKPT; 2783cfec7eeeSdan goto finished_invert; 278491ddd559Sdan } 2785fa122adaSdan 2786fa122adaSdan assert( rc==SQLITE_OK ); 2787fa122adaSdan if( xOutput && sOut.nBuf>=SESSIONS_STR_CHUNK_SIZE ){ 2788fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2789fa122adaSdan sOut.nBuf = 0; 2790fa122adaSdan if( rc!=SQLITE_OK ) goto finished_invert; 2791fa122adaSdan } 279291ddd559Sdan } 279391ddd559Sdan 2794cfec7eeeSdan assert( rc==SQLITE_OK ); 2795fa122adaSdan if( pnInverted ){ 2796fa122adaSdan *pnInverted = sOut.nBuf; 2797fa122adaSdan *ppInverted = sOut.aBuf; 2798fa122adaSdan sOut.aBuf = 0; 2799fa122adaSdan }else if( sOut.nBuf>0 ){ 2800fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2801fa122adaSdan } 2802cfec7eeeSdan 2803cfec7eeeSdan finished_invert: 2804fa122adaSdan sqlite3_free(sOut.aBuf); 2805cfec7eeeSdan sqlite3_free(apVal); 2806ef7a6304Sdan sqlite3_free(sPK.aBuf); 2807cfec7eeeSdan return rc; 280891ddd559Sdan } 280991ddd559Sdan 2810fa122adaSdan 2811fa122adaSdan /* 2812fa122adaSdan ** Invert a changeset object. 2813fa122adaSdan */ 2814fa122adaSdan int sqlite3changeset_invert( 2815fa122adaSdan int nChangeset, /* Number of bytes in input */ 2816fa122adaSdan const void *pChangeset, /* Input changeset */ 2817fa122adaSdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 2818fa122adaSdan void **ppInverted /* OUT: Inverse of pChangeset */ 2819fa122adaSdan ){ 2820fa122adaSdan SessionInput sInput; 2821fa122adaSdan 2822fa122adaSdan /* Set up the input stream */ 2823fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2824fa122adaSdan sInput.nData = nChangeset; 2825fa122adaSdan sInput.aData = (u8*)pChangeset; 2826fa122adaSdan 2827fa122adaSdan return sessionChangesetInvert(&sInput, 0, 0, pnInverted, ppInverted); 2828fa122adaSdan } 2829fa122adaSdan 2830fa122adaSdan /* 2831fa122adaSdan ** Streaming version of sqlite3changeset_invert(). 2832fa122adaSdan */ 2833fa122adaSdan int sqlite3changeset_invert_str( 2834fa122adaSdan int (*xInput)(void *pIn, void *pData, int *pnData), 2835fa122adaSdan void *pIn, 2836fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2837fa122adaSdan void *pOut 2838fa122adaSdan ){ 2839fa122adaSdan SessionInput sInput; 2840fa122adaSdan int rc; 2841fa122adaSdan 2842fa122adaSdan /* Set up the input stream */ 2843fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2844fa122adaSdan sInput.xInput = xInput; 2845fa122adaSdan sInput.pIn = pIn; 2846fa122adaSdan 2847fa122adaSdan rc = sessionChangesetInvert(&sInput, xOutput, pOut, 0, 0); 2848fa122adaSdan sqlite3_free(sInput.buf.aBuf); 2849fa122adaSdan return rc; 2850fa122adaSdan } 2851fa122adaSdan 28520c698471Sdan typedef struct SessionApplyCtx SessionApplyCtx; 28530c698471Sdan struct SessionApplyCtx { 28540c698471Sdan sqlite3 *db; 28550c698471Sdan sqlite3_stmt *pDelete; /* DELETE statement */ 2856cfec7eeeSdan sqlite3_stmt *pUpdate; /* UPDATE statement */ 28570c698471Sdan sqlite3_stmt *pInsert; /* INSERT statement */ 28580c698471Sdan sqlite3_stmt *pSelect; /* SELECT statement */ 28590c698471Sdan int nCol; /* Size of azCol[] and abPK[] arrays */ 28600c698471Sdan const char **azCol; /* Array of column names */ 28610c698471Sdan u8 *abPK; /* Boolean array - true if column is in PK */ 28620c698471Sdan }; 28630c698471Sdan 2864d5f0767cSdan /* 2865d5f0767cSdan ** Formulate a statement to DELETE a row from database db. Assuming a table 2866d5f0767cSdan ** structure like this: 2867d5f0767cSdan ** 2868d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2869d5f0767cSdan ** 2870d5f0767cSdan ** The DELETE statement looks like this: 2871d5f0767cSdan ** 2872db04571cSdan ** DELETE FROM x WHERE a = :1 AND c = :3 AND (:5 OR b IS :2 AND d IS :4) 2873d5f0767cSdan ** 2874d5f0767cSdan ** Variable :5 (nCol+1) is a boolean. It should be set to 0 if we require 2875d5f0767cSdan ** matching b and d values, or 1 otherwise. The second case comes up if the 2876d5f0767cSdan ** conflict handler is invoked with NOTFOUND and returns CHANGESET_REPLACE. 2877296c7658Sdan ** 2878296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pDelete is left 2879296c7658Sdan ** pointing to the prepared version of the SQL statement. 2880d5f0767cSdan */ 2881d5f0767cSdan static int sessionDeleteRow( 2882d5f0767cSdan sqlite3 *db, /* Database handle */ 2883d5f0767cSdan const char *zTab, /* Table name */ 28840c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2885d5f0767cSdan ){ 2886296c7658Sdan int i; 2887296c7658Sdan const char *zSep = ""; 2888d5f0767cSdan int rc = SQLITE_OK; 2889d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 28907cf7df7dSdan int nPk = 0; 2891d5f0767cSdan 2892d5f0767cSdan sessionAppendStr(&buf, "DELETE FROM ", &rc); 2893d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2894296c7658Sdan sessionAppendStr(&buf, " WHERE ", &rc); 2895296c7658Sdan 2896296c7658Sdan for(i=0; i<p->nCol; i++){ 2897296c7658Sdan if( p->abPK[i] ){ 28987cf7df7dSdan nPk++; 2899296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2900296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2901296c7658Sdan sessionAppendStr(&buf, " = ?", &rc); 2902296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2903296c7658Sdan zSep = " AND "; 2904296c7658Sdan } 2905296c7658Sdan } 2906296c7658Sdan 29077cf7df7dSdan if( nPk<p->nCol ){ 2908296c7658Sdan sessionAppendStr(&buf, " AND (?", &rc); 2909296c7658Sdan sessionAppendInteger(&buf, p->nCol+1, &rc); 2910296c7658Sdan sessionAppendStr(&buf, " OR ", &rc); 2911296c7658Sdan 2912296c7658Sdan zSep = ""; 2913296c7658Sdan for(i=0; i<p->nCol; i++){ 2914296c7658Sdan if( !p->abPK[i] ){ 2915296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2916296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2917296c7658Sdan sessionAppendStr(&buf, " IS ?", &rc); 2918296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2919296c7658Sdan zSep = "AND "; 2920296c7658Sdan } 2921296c7658Sdan } 2922296c7658Sdan sessionAppendStr(&buf, ")", &rc); 29237cf7df7dSdan } 2924d5f0767cSdan 2925d5f0767cSdan if( rc==SQLITE_OK ){ 29260c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); 2927d5f0767cSdan } 2928d5f0767cSdan sqlite3_free(buf.aBuf); 2929d5f0767cSdan 2930d5f0767cSdan return rc; 2931d5f0767cSdan } 2932d5f0767cSdan 2933d5f0767cSdan /* 2934d5f0767cSdan ** Formulate and prepare a statement to UPDATE a row from database db. 2935d5f0767cSdan ** Assuming a table structure like this: 2936d5f0767cSdan ** 2937d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2938d5f0767cSdan ** 2939d5f0767cSdan ** The UPDATE statement looks like this: 2940d5f0767cSdan ** 2941d5f0767cSdan ** UPDATE x SET 2942d5f0767cSdan ** a = CASE WHEN ?2 THEN ?3 ELSE a END, 2943964cbd46Sdan ** b = CASE WHEN ?5 THEN ?6 ELSE b END, 2944964cbd46Sdan ** c = CASE WHEN ?8 THEN ?9 ELSE c END, 2945964cbd46Sdan ** d = CASE WHEN ?11 THEN ?12 ELSE d END 2946d5f0767cSdan ** WHERE a = ?1 AND c = ?7 AND (?13 OR 2947964cbd46Sdan ** (?5==0 OR b IS ?4) AND (?11==0 OR d IS ?10) AND 2948d5f0767cSdan ** ) 2949d5f0767cSdan ** 2950d5f0767cSdan ** For each column in the table, there are three variables to bind: 2951d5f0767cSdan ** 2952d5f0767cSdan ** ?(i*3+1) The old.* value of the column, if any. 2953d5f0767cSdan ** ?(i*3+2) A boolean flag indicating that the value is being modified. 2954d5f0767cSdan ** ?(i*3+3) The new.* value of the column, if any. 2955d5f0767cSdan ** 2956d5f0767cSdan ** Also, a boolean flag that, if set to true, causes the statement to update 2957d5f0767cSdan ** a row even if the non-PK values do not match. This is required if the 2958d5f0767cSdan ** conflict-handler is invoked with CHANGESET_DATA and returns 2959d5f0767cSdan ** CHANGESET_REPLACE. This is variable "?(nCol*3+1)". 2960d5f0767cSdan ** 2961296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pUpdate is left 2962296c7658Sdan ** pointing to the prepared version of the SQL statement. 2963d5f0767cSdan */ 2964d5f0767cSdan static int sessionUpdateRow( 2965d5f0767cSdan sqlite3 *db, /* Database handle */ 2966d5f0767cSdan const char *zTab, /* Table name */ 29670c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2968d5f0767cSdan ){ 2969d5f0767cSdan int rc = SQLITE_OK; 2970d5f0767cSdan int i; 2971d5f0767cSdan const char *zSep = ""; 2972d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 2973d5f0767cSdan 2974d5f0767cSdan /* Append "UPDATE tbl SET " */ 2975d5f0767cSdan sessionAppendStr(&buf, "UPDATE ", &rc); 2976d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2977d5f0767cSdan sessionAppendStr(&buf, " SET ", &rc); 2978d5f0767cSdan 2979d5f0767cSdan /* Append the assignments */ 29800c698471Sdan for(i=0; i<p->nCol; i++){ 2981d5f0767cSdan sessionAppendStr(&buf, zSep, &rc); 29820c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2983d5f0767cSdan sessionAppendStr(&buf, " = CASE WHEN ?", &rc); 2984d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 2985d5f0767cSdan sessionAppendStr(&buf, " THEN ?", &rc); 2986d5f0767cSdan sessionAppendInteger(&buf, i*3+3, &rc); 2987d5f0767cSdan sessionAppendStr(&buf, " ELSE ", &rc); 29880c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2989d5f0767cSdan sessionAppendStr(&buf, " END", &rc); 2990d5f0767cSdan zSep = ", "; 2991d5f0767cSdan } 2992d5f0767cSdan 2993d5f0767cSdan /* Append the PK part of the WHERE clause */ 2994d5f0767cSdan sessionAppendStr(&buf, " WHERE ", &rc); 29950c698471Sdan for(i=0; i<p->nCol; i++){ 29960c698471Sdan if( p->abPK[i] ){ 29970c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2998d5f0767cSdan sessionAppendStr(&buf, " = ?", &rc); 2999d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3000d5f0767cSdan sessionAppendStr(&buf, " AND ", &rc); 3001d5f0767cSdan } 3002d5f0767cSdan } 3003d5f0767cSdan 3004d5f0767cSdan /* Append the non-PK part of the WHERE clause */ 3005d5f0767cSdan sessionAppendStr(&buf, " (?", &rc); 30060c698471Sdan sessionAppendInteger(&buf, p->nCol*3+1, &rc); 3007d5f0767cSdan sessionAppendStr(&buf, " OR 1", &rc); 30080c698471Sdan for(i=0; i<p->nCol; i++){ 30090c698471Sdan if( !p->abPK[i] ){ 3010d5f0767cSdan sessionAppendStr(&buf, " AND (?", &rc); 3011d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 3012d5f0767cSdan sessionAppendStr(&buf, "=0 OR ", &rc); 30130c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3014d5f0767cSdan sessionAppendStr(&buf, " IS ?", &rc); 3015d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3016d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3017d5f0767cSdan } 3018d5f0767cSdan } 3019d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3020d5f0767cSdan 3021d5f0767cSdan if( rc==SQLITE_OK ){ 30220c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pUpdate, 0); 3023d5f0767cSdan } 3024d5f0767cSdan sqlite3_free(buf.aBuf); 3025d5f0767cSdan 3026d5f0767cSdan return rc; 3027d5f0767cSdan } 3028d5f0767cSdan 3029296c7658Sdan /* 3030296c7658Sdan ** Formulate and prepare an SQL statement to query table zTab by primary 3031296c7658Sdan ** key. Assuming the following table structure: 3032296c7658Sdan ** 3033296c7658Sdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 3034296c7658Sdan ** 3035296c7658Sdan ** The SELECT statement looks like this: 3036296c7658Sdan ** 3037296c7658Sdan ** SELECT * FROM x WHERE a = ?1 AND c = ?3 3038296c7658Sdan ** 3039296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pSelect is left 3040296c7658Sdan ** pointing to the prepared version of the SQL statement. 3041296c7658Sdan */ 3042d5f0767cSdan static int sessionSelectRow( 3043d5f0767cSdan sqlite3 *db, /* Database handle */ 3044d5f0767cSdan const char *zTab, /* Table name */ 30450c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 3046d5f0767cSdan ){ 3047d7fb7d24Sdan return sessionSelectStmt( 3048d7fb7d24Sdan db, "main", zTab, p->nCol, p->azCol, p->abPK, &p->pSelect); 3049d5f0767cSdan } 3050d5f0767cSdan 3051296c7658Sdan /* 3052296c7658Sdan ** Formulate and prepare an INSERT statement to add a record to table zTab. 3053296c7658Sdan ** For example: 3054296c7658Sdan ** 3055296c7658Sdan ** INSERT INTO main."zTab" VALUES(?1, ?2, ?3 ...); 3056296c7658Sdan ** 3057296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pInsert is left 3058296c7658Sdan ** pointing to the prepared version of the SQL statement. 3059296c7658Sdan */ 30600c698471Sdan static int sessionInsertRow( 30610c698471Sdan sqlite3 *db, /* Database handle */ 30620c698471Sdan const char *zTab, /* Table name */ 30630c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 30640c698471Sdan ){ 30650c698471Sdan int rc = SQLITE_OK; 30660c698471Sdan int i; 30670c698471Sdan SessionBuffer buf = {0, 0, 0}; 30680c698471Sdan 30690c698471Sdan sessionAppendStr(&buf, "INSERT INTO main.", &rc); 30700c698471Sdan sessionAppendIdent(&buf, zTab, &rc); 30710c698471Sdan sessionAppendStr(&buf, " VALUES(?", &rc); 30720c698471Sdan for(i=1; i<p->nCol; i++){ 30730c698471Sdan sessionAppendStr(&buf, ", ?", &rc); 30740c698471Sdan } 30750c698471Sdan sessionAppendStr(&buf, ")", &rc); 30760c698471Sdan 30770c698471Sdan if( rc==SQLITE_OK ){ 30780c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); 30790c698471Sdan } 30800c698471Sdan sqlite3_free(buf.aBuf); 30810c698471Sdan return rc; 30820c698471Sdan } 30830c698471Sdan 3084296c7658Sdan /* 30857aa469cdSdan ** A wrapper around sqlite3_bind_value() that detects an extra problem. 30867aa469cdSdan ** See comments in the body of this function for details. 30877aa469cdSdan */ 30887aa469cdSdan static int sessionBindValue( 30897aa469cdSdan sqlite3_stmt *pStmt, /* Statement to bind value to */ 30907aa469cdSdan int i, /* Parameter number to bind to */ 30917aa469cdSdan sqlite3_value *pVal /* Value to bind */ 30927aa469cdSdan ){ 30935671ef69Sdrh int eType = sqlite3_value_type(pVal); 3094082c96dfSdan /* COVERAGE: The (pVal->z==0) branch is never true using current versions 3095082c96dfSdan ** of SQLite. If a malloc fails in an sqlite3_value_xxx() function, either 3096082c96dfSdan ** the (pVal->z) variable remains as it was or the type of the value is 3097082c96dfSdan ** set to SQLITE_NULL. */ 30985671ef69Sdrh if( (eType==SQLITE_TEXT || eType==SQLITE_BLOB) && pVal->z==0 ){ 30997aa469cdSdan /* This condition occurs when an earlier OOM in a call to 31007aa469cdSdan ** sqlite3_value_text() or sqlite3_value_blob() (perhaps from within 3101082c96dfSdan ** a conflict-handler) has zeroed the pVal->z pointer. Return NOMEM. */ 31027aa469cdSdan return SQLITE_NOMEM; 31037aa469cdSdan } 31047aa469cdSdan return sqlite3_bind_value(pStmt, i, pVal); 31057aa469cdSdan } 31067aa469cdSdan 31077aa469cdSdan /* 3108db04571cSdan ** Iterator pIter must point to an SQLITE_INSERT entry. This function 3109db04571cSdan ** transfers new.* values from the current iterator entry to statement 3110db04571cSdan ** pStmt. The table being inserted into has nCol columns. 3111db04571cSdan ** 3112db04571cSdan ** New.* value $i 0 from the iterator is bound to variable ($i+1) of 3113db04571cSdan ** statement pStmt. If parameter abPK is NULL, all values from 0 to (nCol-1) 3114db04571cSdan ** are transfered to the statement. Otherwise, if abPK is not NULL, it points 3115db04571cSdan ** to an array nCol elements in size. In this case only those values for 3116db04571cSdan ** which abPK[$i] is true are read from the iterator and bound to the 3117db04571cSdan ** statement. 3118db04571cSdan ** 3119db04571cSdan ** An SQLite error code is returned if an error occurs. Otherwise, SQLITE_OK. 3120db04571cSdan */ 31217aa469cdSdan static int sessionBindRow( 3122db04571cSdan sqlite3_changeset_iter *pIter, /* Iterator to read values from */ 31237aa469cdSdan int(*xValue)(sqlite3_changeset_iter *, int, sqlite3_value **), 3124db04571cSdan int nCol, /* Number of columns */ 3125db04571cSdan u8 *abPK, /* If not NULL, bind only if true */ 3126db04571cSdan sqlite3_stmt *pStmt /* Bind values to this statement */ 3127db04571cSdan ){ 3128db04571cSdan int i; 3129db04571cSdan int rc = SQLITE_OK; 31307aa469cdSdan 31317aa469cdSdan /* Neither sqlite3changeset_old or sqlite3changeset_new can fail if the 31327aa469cdSdan ** argument iterator points to a suitable entry. Make sure that xValue 31337aa469cdSdan ** is one of these to guarantee that it is safe to ignore the return 31347aa469cdSdan ** in the code below. */ 31357aa469cdSdan assert( xValue==sqlite3changeset_old || xValue==sqlite3changeset_new ); 31367aa469cdSdan 3137db04571cSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 3138db04571cSdan if( !abPK || abPK[i] ){ 3139db04571cSdan sqlite3_value *pVal; 31407aa469cdSdan (void)xValue(pIter, i, &pVal); 31417aa469cdSdan rc = sessionBindValue(pStmt, i+1, pVal); 3142db04571cSdan } 3143db04571cSdan } 3144db04571cSdan return rc; 3145db04571cSdan } 3146db04571cSdan 3147db04571cSdan /* 3148296c7658Sdan ** SQL statement pSelect is as generated by the sessionSelectRow() function. 3149296c7658Sdan ** This function binds the primary key values from the change that changeset 3150296c7658Sdan ** iterator pIter points to to the SELECT and attempts to seek to the table 3151296c7658Sdan ** entry. If a row is found, the SELECT statement left pointing at the row 3152296c7658Sdan ** and SQLITE_ROW is returned. Otherwise, if no row is found and no error 3153296c7658Sdan ** has occured, the statement is reset and SQLITE_OK is returned. If an 31547aa469cdSdan ** error occurs, the statement is reset and an SQLite error code is returned. 31557aa469cdSdan ** 31567aa469cdSdan ** If this function returns SQLITE_ROW, the caller must eventually reset() 31577aa469cdSdan ** statement pSelect. If any other value is returned, the statement does 31587aa469cdSdan ** not require a reset(). 3159296c7658Sdan ** 3160296c7658Sdan ** If the iterator currently points to an INSERT record, bind values from the 3161db04571cSdan ** new.* record to the SELECT statement. Or, if it points to a DELETE or 3162db04571cSdan ** UPDATE, bind values from the old.* record. 3163296c7658Sdan */ 31640c698471Sdan static int sessionSeekToRow( 316537f133ecSdan sqlite3 *db, /* Database handle */ 316637f133ecSdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 316737f133ecSdan u8 *abPK, /* Primary key flags array */ 31680c698471Sdan sqlite3_stmt *pSelect /* SELECT statement from sessionSelectRow() */ 316937f133ecSdan ){ 31707aa469cdSdan int rc; /* Return code */ 3171296c7658Sdan int nCol; /* Number of columns in table */ 3172296c7658Sdan int op; /* Changset operation (SQLITE_UPDATE etc.) */ 3173296c7658Sdan const char *zDummy; /* Unused */ 317437f133ecSdan 3175b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 31767aa469cdSdan rc = sessionBindRow(pIter, 3177db04571cSdan op==SQLITE_INSERT ? sqlite3changeset_new : sqlite3changeset_old, 3178db04571cSdan nCol, abPK, pSelect 3179db04571cSdan ); 31800c698471Sdan 31810c698471Sdan if( rc==SQLITE_OK ){ 31820c698471Sdan rc = sqlite3_step(pSelect); 31830c698471Sdan if( rc!=SQLITE_ROW ) rc = sqlite3_reset(pSelect); 31840c698471Sdan } 31850c698471Sdan 31860c698471Sdan return rc; 31870c698471Sdan } 31880c698471Sdan 3189296c7658Sdan /* 3190296c7658Sdan ** Invoke the conflict handler for the change that the changeset iterator 3191296c7658Sdan ** currently points to. 3192296c7658Sdan ** 3193296c7658Sdan ** Argument eType must be either CHANGESET_DATA or CHANGESET_CONFLICT. 3194296c7658Sdan ** If argument pbReplace is NULL, then the type of conflict handler invoked 3195296c7658Sdan ** depends solely on eType, as follows: 3196296c7658Sdan ** 3197296c7658Sdan ** eType value Value passed to xConflict 3198296c7658Sdan ** ------------------------------------------------- 3199296c7658Sdan ** CHANGESET_DATA CHANGESET_NOTFOUND 3200296c7658Sdan ** CHANGESET_CONFLICT CHANGESET_CONSTRAINT 3201296c7658Sdan ** 3202296c7658Sdan ** Or, if pbReplace is not NULL, then an attempt is made to find an existing 3203296c7658Sdan ** record with the same primary key as the record about to be deleted, updated 3204296c7658Sdan ** or inserted. If such a record can be found, it is available to the conflict 3205296c7658Sdan ** handler as the "conflicting" record. In this case the type of conflict 3206296c7658Sdan ** handler invoked is as follows: 3207296c7658Sdan ** 3208296c7658Sdan ** eType value PK Record found? Value passed to xConflict 3209296c7658Sdan ** ---------------------------------------------------------------- 3210296c7658Sdan ** CHANGESET_DATA Yes CHANGESET_DATA 3211296c7658Sdan ** CHANGESET_DATA No CHANGESET_NOTFOUND 3212296c7658Sdan ** CHANGESET_CONFLICT Yes CHANGESET_CONFLICT 3213296c7658Sdan ** CHANGESET_CONFLICT No CHANGESET_CONSTRAINT 3214296c7658Sdan ** 3215296c7658Sdan ** If pbReplace is not NULL, and a record with a matching PK is found, and 3216296c7658Sdan ** the conflict handler function returns SQLITE_CHANGESET_REPLACE, *pbReplace 3217296c7658Sdan ** is set to non-zero before returning SQLITE_OK. 3218296c7658Sdan ** 3219296c7658Sdan ** If the conflict handler returns SQLITE_CHANGESET_ABORT, SQLITE_ABORT is 3220296c7658Sdan ** returned. Or, if the conflict handler returns an invalid value, 3221296c7658Sdan ** SQLITE_MISUSE. If the conflict handler returns SQLITE_CHANGESET_OMIT, 3222296c7658Sdan ** this function returns SQLITE_OK. 3223296c7658Sdan */ 32240c698471Sdan static int sessionConflictHandler( 3225296c7658Sdan int eType, /* Either CHANGESET_DATA or CONFLICT */ 3226296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 32270c698471Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 32280c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter*), 3229296c7658Sdan void *pCtx, /* First argument for conflict handler */ 3230296c7658Sdan int *pbReplace /* OUT: Set to true if PK row is found */ 32310c698471Sdan ){ 3232296c7658Sdan int res; /* Value returned by conflict handler */ 32330c698471Sdan int rc; 32340c698471Sdan int nCol; 32350c698471Sdan int op; 32360c698471Sdan const char *zDummy; 32370c698471Sdan 3238b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 32390c698471Sdan 32400c698471Sdan assert( eType==SQLITE_CHANGESET_CONFLICT || eType==SQLITE_CHANGESET_DATA ); 32410c698471Sdan assert( SQLITE_CHANGESET_CONFLICT+1==SQLITE_CHANGESET_CONSTRAINT ); 32420c698471Sdan assert( SQLITE_CHANGESET_DATA+1==SQLITE_CHANGESET_NOTFOUND ); 324337f133ecSdan 324437f133ecSdan /* Bind the new.* PRIMARY KEY values to the SELECT statement. */ 32450c698471Sdan if( pbReplace ){ 32460c698471Sdan rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); 32470c698471Sdan }else{ 3248db04571cSdan rc = SQLITE_OK; 32490c698471Sdan } 32500c698471Sdan 32510c698471Sdan if( rc==SQLITE_ROW ){ 32520c698471Sdan /* There exists another row with the new.* primary key. */ 32530c698471Sdan pIter->pConflict = p->pSelect; 32540c698471Sdan res = xConflict(pCtx, eType, pIter); 32550c698471Sdan pIter->pConflict = 0; 32560c698471Sdan rc = sqlite3_reset(p->pSelect); 3257db04571cSdan }else if( rc==SQLITE_OK ){ 32580c698471Sdan /* No other row with the new.* primary key. */ 32590c698471Sdan res = xConflict(pCtx, eType+1, pIter); 32600c698471Sdan if( res==SQLITE_CHANGESET_REPLACE ) rc = SQLITE_MISUSE; 326137f133ecSdan } 326237f133ecSdan 326337f133ecSdan if( rc==SQLITE_OK ){ 32640c698471Sdan switch( res ){ 32650c698471Sdan case SQLITE_CHANGESET_REPLACE: 3266f51e5f6cSdan assert( pbReplace ); 3267f51e5f6cSdan *pbReplace = 1; 32680c698471Sdan break; 32690c698471Sdan 32700c698471Sdan case SQLITE_CHANGESET_OMIT: 32710c698471Sdan break; 32720c698471Sdan 32730c698471Sdan case SQLITE_CHANGESET_ABORT: 32740c698471Sdan rc = SQLITE_ABORT; 32750c698471Sdan break; 32760c698471Sdan 32770c698471Sdan default: 32780c698471Sdan rc = SQLITE_MISUSE; 32790c698471Sdan break; 32800c698471Sdan } 32810c698471Sdan } 32820c698471Sdan 32830c698471Sdan return rc; 32840c698471Sdan } 32850c698471Sdan 3286296c7658Sdan /* 3287296c7658Sdan ** Attempt to apply the change that the iterator passed as the first argument 3288296c7658Sdan ** currently points to to the database. If a conflict is encountered, invoke 3289296c7658Sdan ** the conflict handler callback. 3290296c7658Sdan ** 3291296c7658Sdan ** If argument pbRetry is NULL, then ignore any CHANGESET_DATA conflict. If 3292296c7658Sdan ** one is encountered, update or delete the row with the matching primary key 3293296c7658Sdan ** instead. Or, if pbRetry is not NULL and a CHANGESET_DATA conflict occurs, 3294296c7658Sdan ** invoke the conflict handler. If it returns CHANGESET_REPLACE, set *pbRetry 3295296c7658Sdan ** to true before returning. In this case the caller will invoke this function 3296296c7658Sdan ** again, this time with pbRetry set to NULL. 3297296c7658Sdan ** 3298296c7658Sdan ** If argument pbReplace is NULL and a CHANGESET_CONFLICT conflict is 3299296c7658Sdan ** encountered invoke the conflict handler with CHANGESET_CONSTRAINT instead. 3300296c7658Sdan ** Or, if pbReplace is not NULL, invoke it with CHANGESET_CONFLICT. If such 3301296c7658Sdan ** an invocation returns SQLITE_CHANGESET_REPLACE, set *pbReplace to true 3302296c7658Sdan ** before retrying. In this case the caller attempts to remove the conflicting 3303296c7658Sdan ** row before invoking this function again, this time with pbReplace set 3304296c7658Sdan ** to NULL. 3305296c7658Sdan ** 3306296c7658Sdan ** If any conflict handler returns SQLITE_CHANGESET_ABORT, this function 3307296c7658Sdan ** returns SQLITE_ABORT. Otherwise, if no error occurs, SQLITE_OK is 3308296c7658Sdan ** returned. 3309296c7658Sdan */ 33100c698471Sdan static int sessionApplyOneOp( 3311296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 3312296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 33130c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter *), 3314296c7658Sdan void *pCtx, /* First argument for the conflict handler */ 3315296c7658Sdan int *pbReplace, /* OUT: True to remove PK row and retry */ 3316296c7658Sdan int *pbRetry /* OUT: True to retry. */ 33170c698471Sdan ){ 33180c698471Sdan const char *zDummy; 33190c698471Sdan int op; 33200c698471Sdan int nCol; 33210c698471Sdan int rc = SQLITE_OK; 33220c698471Sdan 33230c698471Sdan assert( p->pDelete && p->pUpdate && p->pInsert && p->pSelect ); 33240c698471Sdan assert( p->azCol && p->abPK ); 33250c698471Sdan assert( !pbReplace || *pbReplace==0 ); 33260c698471Sdan 3327b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 33280c698471Sdan 33290c698471Sdan if( op==SQLITE_DELETE ){ 33300c698471Sdan 333173b3c055Sdan /* Bind values to the DELETE statement. If conflict handling is required, 333273b3c055Sdan ** bind values for all columns and set bound variable (nCol+1) to true. 333373b3c055Sdan ** Or, if conflict handling is not required, bind just the PK column 333473b3c055Sdan ** values and, if it exists, set (nCol+1) to false. Conflict handling 333573b3c055Sdan ** is not required if: 333673b3c055Sdan ** 333773b3c055Sdan ** * this is a patchset, or 333873b3c055Sdan ** * (pbRetry==0), or 333973b3c055Sdan ** * all columns of the table are PK columns (in this case there is 334073b3c055Sdan ** no (nCol+1) variable to bind to). 334173b3c055Sdan */ 334273b3c055Sdan u8 *abPK = (pIter->bPatchset ? p->abPK : 0); 334373b3c055Sdan rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); 33447cf7df7dSdan if( rc==SQLITE_OK && sqlite3_bind_parameter_count(p->pDelete)>nCol ){ 334573b3c055Sdan rc = sqlite3_bind_int(p->pDelete, nCol+1, (pbRetry==0 || abPK)); 33467cf7df7dSdan } 33470c698471Sdan if( rc!=SQLITE_OK ) return rc; 33480c698471Sdan 33490c698471Sdan sqlite3_step(p->pDelete); 33500c698471Sdan rc = sqlite3_reset(p->pDelete); 33510c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 33520c698471Sdan rc = sessionConflictHandler( 33530c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 33540c698471Sdan ); 335535e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 33560c698471Sdan rc = sessionConflictHandler( 33570c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 33580c698471Sdan ); 33590c698471Sdan } 33600c698471Sdan 33610c698471Sdan }else if( op==SQLITE_UPDATE ){ 33620c698471Sdan int i; 33630c698471Sdan 33640c698471Sdan /* Bind values to the UPDATE statement. */ 33650c698471Sdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 33667aa469cdSdan sqlite3_value *pOld = sessionChangesetOld(pIter, i); 33677aa469cdSdan sqlite3_value *pNew = sessionChangesetNew(pIter, i); 33687aa469cdSdan 33690c698471Sdan sqlite3_bind_int(p->pUpdate, i*3+2, !!pNew); 33707aa469cdSdan if( pOld ){ 33717aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+1, pOld); 33727aa469cdSdan } 33737aa469cdSdan if( rc==SQLITE_OK && pNew ){ 33747aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+3, pNew); 33750c698471Sdan } 33760c698471Sdan } 337773b3c055Sdan if( rc==SQLITE_OK ){ 337873b3c055Sdan sqlite3_bind_int(p->pUpdate, nCol*3+1, pbRetry==0 || pIter->bPatchset); 337973b3c055Sdan } 33800c698471Sdan if( rc!=SQLITE_OK ) return rc; 33810c698471Sdan 33820c698471Sdan /* Attempt the UPDATE. In the case of a NOTFOUND or DATA conflict, 33830c698471Sdan ** the result will be SQLITE_OK with 0 rows modified. */ 33840c698471Sdan sqlite3_step(p->pUpdate); 33850c698471Sdan rc = sqlite3_reset(p->pUpdate); 33860c698471Sdan 33870c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 33880c698471Sdan /* A NOTFOUND or DATA error. Search the table to see if it contains 33890c698471Sdan ** a row with a matching primary key. If so, this is a DATA conflict. 33900c698471Sdan ** Otherwise, if there is no primary key match, it is a NOTFOUND. */ 33910c698471Sdan 33920c698471Sdan rc = sessionConflictHandler( 33930c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 33940c698471Sdan ); 33950c698471Sdan 339635e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 3397db04571cSdan /* This is always a CONSTRAINT conflict. */ 3398db04571cSdan rc = sessionConflictHandler( 3399db04571cSdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 34000c698471Sdan ); 34010c698471Sdan } 34020c698471Sdan 34030c698471Sdan }else{ 34040c698471Sdan assert( op==SQLITE_INSERT ); 34057aa469cdSdan rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); 34060c698471Sdan if( rc!=SQLITE_OK ) return rc; 34070c698471Sdan 34080c698471Sdan sqlite3_step(p->pInsert); 34090c698471Sdan rc = sqlite3_reset(p->pInsert); 341035e2858eSdan if( (rc&0xff)==SQLITE_CONSTRAINT ){ 34110c698471Sdan rc = sessionConflictHandler( 34120c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, pbReplace 34130c698471Sdan ); 341437f133ecSdan } 341537f133ecSdan } 341637f133ecSdan 341737f133ecSdan return rc; 341837f133ecSdan } 341937f133ecSdan 3420296c7658Sdan /* 34214757c658Sdan ** Argument pIter is a changeset iterator that has been initialized, but 34224757c658Sdan ** not yet passed to sqlite3changeset_next(). This function applies the 34234757c658Sdan ** changeset to the main database attached to handle "db". The supplied 34244757c658Sdan ** conflict handler callback is invoked to resolve any conflicts encountered 34254757c658Sdan ** while applying the change. 3426296c7658Sdan */ 34274757c658Sdan static int sessionChangesetApply( 3428296c7658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 34294757c658Sdan sqlite3_changeset_iter *pIter, /* Changeset to apply */ 343040368988Sdan int(*xFilter)( 343140368988Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 343240368988Sdan const char *zTab /* Table name */ 343340368988Sdan ), 3434d5f0767cSdan int(*xConflict)( 3435d5f0767cSdan void *pCtx, /* Copy of fifth arg to _apply() */ 3436d5f0767cSdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 3437d5f0767cSdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 3438d5f0767cSdan ), 3439296c7658Sdan void *pCtx /* First argument passed to xConflict */ 3440d5f0767cSdan ){ 3441ca62ad57Sdan int schemaMismatch = 0; 3442296c7658Sdan int rc; /* Return code */ 3443d5f0767cSdan const char *zTab = 0; /* Name of current table */ 3444cfdbde21Sdrh int nTab = 0; /* Result of sqlite3Strlen30(zTab) */ 3445296c7658Sdan SessionApplyCtx sApply; /* changeset_apply() context object */ 3446d5f0767cSdan 3447082c96dfSdan assert( xConflict!=0 ); 3448082c96dfSdan 34490c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34504c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 34510c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT changeset_apply", 0, 0, 0); 3452cb3e4b79Sdan if( rc==SQLITE_OK ){ 3453cb3e4b79Sdan rc = sqlite3_exec(db, "PRAGMA defer_foreign_keys = 1", 0, 0, 0); 3454cb3e4b79Sdan } 34550c698471Sdan while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter) ){ 34560c698471Sdan int nCol; 3457d5f0767cSdan int op; 34580c698471Sdan int bReplace = 0; 34590c698471Sdan int bRetry = 0; 34600c698471Sdan const char *zNew; 3461ca62ad57Sdan 3462b4480e94Sdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); 3463d5f0767cSdan 34640c698471Sdan if( zTab==0 || sqlite3_strnicmp(zNew, zTab, nTab+1) ){ 3465ca62ad57Sdan u8 *abPK; 3466ca62ad57Sdan 3467cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 34680c698471Sdan sqlite3_finalize(sApply.pDelete); 34690c698471Sdan sqlite3_finalize(sApply.pUpdate); 34700c698471Sdan sqlite3_finalize(sApply.pInsert); 34710c698471Sdan sqlite3_finalize(sApply.pSelect); 34720c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34730c698471Sdan sApply.db = db; 347437f133ecSdan 347540368988Sdan /* If an xFilter() callback was specified, invoke it now. If the 347640368988Sdan ** xFilter callback returns zero, skip this table. If it returns 347740368988Sdan ** non-zero, proceed. */ 347840368988Sdan schemaMismatch = (xFilter && (0==xFilter(pCtx, zNew))); 347940368988Sdan if( schemaMismatch ){ 348040368988Sdan zTab = sqlite3_mprintf("%s", zNew); 34814f528042Sdan nTab = (int)strlen(zTab); 348240368988Sdan sApply.azCol = (const char **)zTab; 348340368988Sdan }else{ 3484ca62ad57Sdan sqlite3changeset_pk(pIter, &abPK, 0); 3485296c7658Sdan rc = sessionTableInfo( 3486ca62ad57Sdan db, "main", zNew, &sApply.nCol, &zTab, &sApply.azCol, &sApply.abPK 3487ca62ad57Sdan ); 3488ca62ad57Sdan if( rc!=SQLITE_OK ) break; 34890c698471Sdan 3490ca62ad57Sdan if( sApply.nCol==0 ){ 3491ca62ad57Sdan schemaMismatch = 1; 3492ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3493ca62ad57Sdan "sqlite3changeset_apply(): no such table: %s", zTab 3494ca62ad57Sdan ); 3495ca62ad57Sdan } 3496ca62ad57Sdan else if( sApply.nCol!=nCol ){ 3497ca62ad57Sdan schemaMismatch = 1; 3498ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3499ca62ad57Sdan "sqlite3changeset_apply(): table %s has %d columns, expected %d", 3500ca62ad57Sdan zTab, sApply.nCol, nCol 3501ca62ad57Sdan ); 3502ca62ad57Sdan } 3503ca62ad57Sdan else if( memcmp(sApply.abPK, abPK, nCol)!=0 ){ 3504ca62ad57Sdan schemaMismatch = 1; 350540368988Sdan sqlite3_log(SQLITE_SCHEMA, "sqlite3changeset_apply(): " 350640368988Sdan "primary key mismatch for table %s", zTab 3507ca62ad57Sdan ); 3508ca62ad57Sdan } 3509ca62ad57Sdan else if( 3510ca62ad57Sdan (rc = sessionSelectRow(db, zTab, &sApply)) 35110c698471Sdan || (rc = sessionUpdateRow(db, zTab, &sApply)) 35120c698471Sdan || (rc = sessionDeleteRow(db, zTab, &sApply)) 35130c698471Sdan || (rc = sessionInsertRow(db, zTab, &sApply)) 351437f133ecSdan ){ 351537f133ecSdan break; 351637f133ecSdan } 3517cfdbde21Sdrh nTab = sqlite3Strlen30(zTab); 3518d5f0767cSdan } 351940368988Sdan } 3520d5f0767cSdan 3521ca62ad57Sdan /* If there is a schema mismatch on the current table, proceed to the 3522ca62ad57Sdan ** next change. A log message has already been issued. */ 3523ca62ad57Sdan if( schemaMismatch ) continue; 3524ca62ad57Sdan 35250c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, &bRetry); 35260c698471Sdan 35270c698471Sdan if( rc==SQLITE_OK && bRetry ){ 35280c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, 0); 35290c698471Sdan } 35300c698471Sdan 35310c698471Sdan if( bReplace ){ 3532db04571cSdan assert( pIter->op==SQLITE_INSERT ); 35330c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT replace_op", 0, 0, 0); 35340c698471Sdan if( rc==SQLITE_OK ){ 35357aa469cdSdan rc = sessionBindRow(pIter, 3536db04571cSdan sqlite3changeset_new, sApply.nCol, sApply.abPK, sApply.pDelete); 35370c698471Sdan sqlite3_bind_int(sApply.pDelete, sApply.nCol+1, 1); 35380c698471Sdan } 35390c698471Sdan if( rc==SQLITE_OK ){ 35400c698471Sdan sqlite3_step(sApply.pDelete); 35410c698471Sdan rc = sqlite3_reset(sApply.pDelete); 35420c698471Sdan } 35430c698471Sdan if( rc==SQLITE_OK ){ 35440c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, 0, 0); 35450c698471Sdan } 35460c698471Sdan if( rc==SQLITE_OK ){ 35470c698471Sdan rc = sqlite3_exec(db, "RELEASE replace_op", 0, 0, 0); 35480c698471Sdan } 35490c698471Sdan } 35500c698471Sdan } 3551d5f0767cSdan 3552296c7658Sdan if( rc==SQLITE_OK ){ 3553296c7658Sdan rc = sqlite3changeset_finalize(pIter); 3554296c7658Sdan }else{ 3555296c7658Sdan sqlite3changeset_finalize(pIter); 3556296c7658Sdan } 3557d5f0767cSdan 3558d5f0767cSdan if( rc==SQLITE_OK ){ 355907001c45Sdrh int nFk, notUsed; 356007001c45Sdrh sqlite3_db_status(db, SQLITE_DBSTATUS_DEFERRED_FKS, &nFk, ¬Used, 0); 356107001c45Sdrh if( nFk!=0 ){ 3562cb3e4b79Sdan int res = SQLITE_CHANGESET_ABORT; 3563cb3e4b79Sdan sqlite3_changeset_iter sIter; 3564cb3e4b79Sdan memset(&sIter, 0, sizeof(sIter)); 3565cb3e4b79Sdan sIter.nCol = nFk; 3566cb3e4b79Sdan res = xConflict(pCtx, SQLITE_CHANGESET_FOREIGN_KEY, &sIter); 3567cb3e4b79Sdan if( res!=SQLITE_CHANGESET_OMIT ){ 3568cb3e4b79Sdan rc = SQLITE_CONSTRAINT; 3569cb3e4b79Sdan } 3570cb3e4b79Sdan } 3571cb3e4b79Sdan } 3572cb3e4b79Sdan sqlite3_exec(db, "PRAGMA defer_foreign_keys = 0", 0, 0, 0); 3573cb3e4b79Sdan 3574cb3e4b79Sdan if( rc==SQLITE_OK ){ 3575d5f0767cSdan rc = sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3576d5f0767cSdan }else{ 3577d5f0767cSdan sqlite3_exec(db, "ROLLBACK TO changeset_apply", 0, 0, 0); 3578d5f0767cSdan sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3579d5f0767cSdan } 3580d5f0767cSdan 35810c698471Sdan sqlite3_finalize(sApply.pInsert); 35820c698471Sdan sqlite3_finalize(sApply.pDelete); 35830c698471Sdan sqlite3_finalize(sApply.pUpdate); 35840c698471Sdan sqlite3_finalize(sApply.pSelect); 3585cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 35864c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 3587d5f0767cSdan return rc; 3588d5f0767cSdan } 358991ddd559Sdan 359077fc1d5bSdan /* 35914757c658Sdan ** Apply the changeset passed via pChangeset/nChangeset to the main database 35924757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 35934757c658Sdan ** to resolve any conflicts encountered while applying the change. 35944757c658Sdan */ 35954757c658Sdan int sqlite3changeset_apply( 35964757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 35974757c658Sdan int nChangeset, /* Size of changeset in bytes */ 35984757c658Sdan void *pChangeset, /* Changeset blob */ 35994757c658Sdan int(*xFilter)( 36004757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36014757c658Sdan const char *zTab /* Table name */ 36024757c658Sdan ), 36034757c658Sdan int(*xConflict)( 36044757c658Sdan void *pCtx, /* Copy of fifth arg to _apply() */ 36054757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36064757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36074757c658Sdan ), 36084757c658Sdan void *pCtx /* First argument passed to xConflict */ 36094757c658Sdan ){ 36104757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 36114757c658Sdan int rc = sqlite3changeset_start(&pIter, nChangeset, pChangeset); 36124757c658Sdan if( rc==SQLITE_OK ){ 36134757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36144757c658Sdan } 36154757c658Sdan return rc; 36164757c658Sdan } 36174757c658Sdan 36184757c658Sdan /* 36194757c658Sdan ** Apply the changeset passed via xInput/pIn to the main database 36204757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 36214757c658Sdan ** to resolve any conflicts encountered while applying the change. 36224757c658Sdan */ 36234757c658Sdan int sqlite3changeset_apply_str( 36244757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 36254757c658Sdan int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */ 36264757c658Sdan void *pIn, /* First arg for xInput */ 36274757c658Sdan int(*xFilter)( 36284757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36294757c658Sdan const char *zTab /* Table name */ 36304757c658Sdan ), 36314757c658Sdan int(*xConflict)( 36324757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36334757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36344757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36354757c658Sdan ), 36364757c658Sdan void *pCtx /* First argument passed to xConflict */ 36374757c658Sdan ){ 36384757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 36394757c658Sdan int rc = sqlite3changeset_start_str(&pIter, xInput, pIn); 36404757c658Sdan if( rc==SQLITE_OK ){ 36414757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36424757c658Sdan } 36434757c658Sdan return rc; 36444757c658Sdan } 36454757c658Sdan 36464757c658Sdan /* 364777fc1d5bSdan ** This function is called to merge two changes to the same row together as 364877fc1d5bSdan ** part of an sqlite3changeset_concat() operation. A new change object is 364977fc1d5bSdan ** allocated and a pointer to it stored in *ppNew. 365077fc1d5bSdan */ 36515d607a6eSdan static int sessionChangeMerge( 365277fc1d5bSdan SessionTable *pTab, /* Table structure */ 365364277f4aSdan int bPatchset, /* True for patchsets */ 365477fc1d5bSdan SessionChange *pExist, /* Existing change */ 365577fc1d5bSdan int op2, /* Second change operation */ 365677fc1d5bSdan int bIndirect, /* True if second change is indirect */ 365777fc1d5bSdan u8 *aRec, /* Second change record */ 365877fc1d5bSdan int nRec, /* Number of bytes in aRec */ 365977fc1d5bSdan SessionChange **ppNew /* OUT: Merged change */ 36605d607a6eSdan ){ 36615d607a6eSdan SessionChange *pNew = 0; 36625d607a6eSdan 36635d607a6eSdan if( !pExist ){ 3664*cbf6d2d2Sdan pNew = (SessionChange *)sqlite3_malloc(sizeof(SessionChange) + nRec); 36655d607a6eSdan if( !pNew ){ 36665d607a6eSdan return SQLITE_NOMEM; 36675d607a6eSdan } 36685d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 3669798693b2Sdan pNew->op = op2; 36705d607a6eSdan pNew->bIndirect = bIndirect; 36715d607a6eSdan pNew->nRecord = nRec; 3672*cbf6d2d2Sdan pNew->aRecord = (u8*)&pNew[1]; 3673*cbf6d2d2Sdan memcpy(pNew->aRecord, aRec, nRec); 36745d607a6eSdan }else{ 3675798693b2Sdan int op1 = pExist->op; 36765d607a6eSdan 36775d607a6eSdan /* 36785d607a6eSdan ** op1=INSERT, op2=INSERT -> Unsupported. Discard op2. 36795d607a6eSdan ** op1=INSERT, op2=UPDATE -> INSERT. 36805d607a6eSdan ** op1=INSERT, op2=DELETE -> (none) 36815d607a6eSdan ** 36825d607a6eSdan ** op1=UPDATE, op2=INSERT -> Unsupported. Discard op2. 36835d607a6eSdan ** op1=UPDATE, op2=UPDATE -> UPDATE. 36845d607a6eSdan ** op1=UPDATE, op2=DELETE -> DELETE. 36855d607a6eSdan ** 36865d607a6eSdan ** op1=DELETE, op2=INSERT -> UPDATE. 36875d607a6eSdan ** op1=DELETE, op2=UPDATE -> Unsupported. Discard op2. 36885d607a6eSdan ** op1=DELETE, op2=DELETE -> Unsupported. Discard op2. 36895d607a6eSdan */ 36905d607a6eSdan if( (op1==SQLITE_INSERT && op2==SQLITE_INSERT) 36915d607a6eSdan || (op1==SQLITE_UPDATE && op2==SQLITE_INSERT) 36925d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_UPDATE) 36935d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_DELETE) 36945d607a6eSdan ){ 36955d607a6eSdan pNew = pExist; 36965d607a6eSdan }else if( op1==SQLITE_INSERT && op2==SQLITE_DELETE ){ 36975d607a6eSdan sqlite3_free(pExist); 36985d607a6eSdan assert( pNew==0 ); 36995d607a6eSdan }else{ 370064277f4aSdan u8 *aExist = pExist->aRecord; 37015d607a6eSdan int nByte; 37025d607a6eSdan u8 *aCsr; 37035d607a6eSdan 370464277f4aSdan /* Allocate a new SessionChange object. Ensure that the aRecord[] 370564277f4aSdan ** buffer of the new object is large enough to hold any record that 370664277f4aSdan ** may be generated by combining the input records. */ 37075d607a6eSdan nByte = sizeof(SessionChange) + pExist->nRecord + nRec; 37085d607a6eSdan pNew = (SessionChange *)sqlite3_malloc(nByte); 37095d607a6eSdan if( !pNew ){ 37101756ae10Sdan sqlite3_free(pExist); 37115d607a6eSdan return SQLITE_NOMEM; 37125d607a6eSdan } 37135d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 37145d607a6eSdan pNew->bIndirect = (bIndirect && pExist->bIndirect); 37155d607a6eSdan aCsr = pNew->aRecord = (u8 *)&pNew[1]; 37165d607a6eSdan 3717b08a1efaSdan if( op1==SQLITE_INSERT ){ /* INSERT + UPDATE */ 37185d607a6eSdan u8 *a1 = aRec; 3719b08a1efaSdan assert( op2==SQLITE_UPDATE ); 3720798693b2Sdan pNew->op = SQLITE_INSERT; 3721ef7a6304Sdan if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); 372264277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aExist, a1); 3723b08a1efaSdan }else if( op1==SQLITE_DELETE ){ /* DELETE + INSERT */ 3724b08a1efaSdan assert( op2==SQLITE_INSERT ); 3725798693b2Sdan pNew->op = SQLITE_UPDATE; 372664277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aExist, 0, aRec, 0) ){ 3727b08a1efaSdan sqlite3_free(pNew); 3728b08a1efaSdan pNew = 0; 37295d607a6eSdan } 3730b08a1efaSdan }else if( op2==SQLITE_UPDATE ){ /* UPDATE + UPDATE */ 373164277f4aSdan u8 *a1 = aExist; 37325d607a6eSdan u8 *a2 = aRec; 3733cfec7eeeSdan assert( op1==SQLITE_UPDATE ); 373464277f4aSdan if( bPatchset==0 ){ 3735ef7a6304Sdan sessionSkipRecord(&a1, pTab->nCol); 3736ef7a6304Sdan sessionSkipRecord(&a2, pTab->nCol); 373764277f4aSdan } 3738798693b2Sdan pNew->op = SQLITE_UPDATE; 373964277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aRec, aExist,a1,a2) ){ 37405d607a6eSdan sqlite3_free(pNew); 37415d607a6eSdan pNew = 0; 37425d607a6eSdan } 3743b08a1efaSdan }else{ /* UPDATE + DELETE */ 3744b08a1efaSdan assert( op1==SQLITE_UPDATE && op2==SQLITE_DELETE ); 3745798693b2Sdan pNew->op = SQLITE_DELETE; 374664277f4aSdan if( bPatchset ){ 374764277f4aSdan memcpy(aCsr, aRec, nRec); 374864277f4aSdan aCsr += nRec; 374964277f4aSdan }else{ 375064277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aRec, aExist); 375164277f4aSdan } 37525d607a6eSdan } 37535d607a6eSdan 37545d607a6eSdan if( pNew ){ 37554f528042Sdan pNew->nRecord = (int)(aCsr - pNew->aRecord); 37565d607a6eSdan } 37575d607a6eSdan sqlite3_free(pExist); 37585d607a6eSdan } 37595d607a6eSdan } 37605d607a6eSdan 37615d607a6eSdan *ppNew = pNew; 37625d607a6eSdan return SQLITE_OK; 37635d607a6eSdan } 37645d607a6eSdan 376577fc1d5bSdan /* 376677fc1d5bSdan ** Add all changes in the changeset passed via the first two arguments to 376777fc1d5bSdan ** hash tables. 376877fc1d5bSdan */ 3769*cbf6d2d2Sdan static int sessionAddChangeset( 3770*cbf6d2d2Sdan sqlite3_changeset_iter *pIter, /* Iterator to read from */ 377177fc1d5bSdan SessionTable **ppTabList /* IN/OUT: List of table objects */ 37725d607a6eSdan ){ 37735d607a6eSdan u8 *aRec; 37745d607a6eSdan int nRec; 3775*cbf6d2d2Sdan int rc = SQLITE_OK; 37765d607a6eSdan SessionTable *pTab = 0; 37775d607a6eSdan 37785d607a6eSdan while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec) ){ 37795d607a6eSdan const char *zNew; 37805d607a6eSdan int nCol; 37815d607a6eSdan int op; 37825d607a6eSdan int iHash; 37835d607a6eSdan int bIndirect; 37845d607a6eSdan SessionChange *pChange; 37855d607a6eSdan SessionChange *pExist = 0; 37865d607a6eSdan SessionChange **pp; 37875d607a6eSdan 3788*cbf6d2d2Sdan #if 0 378964277f4aSdan assert( bPatchset==0 || bPatchset==1 ); 379064277f4aSdan assert( pIter->bPatchset==0 || pIter->bPatchset==1 ); 379164277f4aSdan if( pIter->bPatchset!=bPatchset ){ 379264277f4aSdan rc = SQLITE_ERROR; 379364277f4aSdan break; 379464277f4aSdan } 3795*cbf6d2d2Sdan #endif 379664277f4aSdan 37975d607a6eSdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); 3798ef7a6304Sdan if( !pTab || sqlite3_stricmp(zNew, pTab->zName) ){ 37995d607a6eSdan /* Search the list for a matching table */ 38004f528042Sdan int nNew = (int)strlen(zNew); 3801f29123b5Sdan u8 *abPK; 3802f29123b5Sdan 3803f29123b5Sdan sqlite3changeset_pk(pIter, &abPK, 0); 38045d607a6eSdan for(pTab = *ppTabList; pTab; pTab=pTab->pNext){ 38055d607a6eSdan if( 0==sqlite3_strnicmp(pTab->zName, zNew, nNew+1) ) break; 38065d607a6eSdan } 38075d607a6eSdan if( !pTab ){ 3808ef7a6304Sdan pTab = sqlite3_malloc(sizeof(SessionTable) + nCol + nNew+1); 3809f29123b5Sdan if( !pTab ){ 3810f29123b5Sdan rc = SQLITE_NOMEM; 3811f29123b5Sdan break; 3812f29123b5Sdan } 38135d607a6eSdan memset(pTab, 0, sizeof(SessionTable)); 38145d607a6eSdan pTab->pNext = *ppTabList; 3815f29123b5Sdan pTab->nCol = nCol; 3816ef7a6304Sdan pTab->abPK = (u8*)&pTab[1]; 3817ef7a6304Sdan memcpy(pTab->abPK, abPK, nCol); 3818ef7a6304Sdan pTab->zName = (char*)&pTab->abPK[nCol]; 3819ef7a6304Sdan memcpy(pTab->zName, zNew, nNew+1); 38205d607a6eSdan *ppTabList = pTab; 3821f29123b5Sdan }else if( pTab->nCol!=nCol || memcmp(pTab->abPK, abPK, nCol) ){ 3822f29123b5Sdan rc = SQLITE_SCHEMA; 3823f29123b5Sdan break; 38245d607a6eSdan } 38255d607a6eSdan } 38265d607a6eSdan 3827*cbf6d2d2Sdan if( sessionGrowHash(pIter->bPatchset, pTab) ){ 38281756ae10Sdan rc = SQLITE_NOMEM; 38291756ae10Sdan break; 38301756ae10Sdan } 383164277f4aSdan iHash = sessionChangeHash( 3832*cbf6d2d2Sdan pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange 383364277f4aSdan ); 38345d607a6eSdan 38355d607a6eSdan /* Search for existing entry. If found, remove it from the hash table. 38365d607a6eSdan ** Code below may link it back in. 38375d607a6eSdan */ 38385d607a6eSdan for(pp=&pTab->apChange[iHash]; *pp; pp=&(*pp)->pNext){ 383964277f4aSdan int bPkOnly1 = 0; 384064277f4aSdan int bPkOnly2 = 0; 3841*cbf6d2d2Sdan if( pIter->bPatchset ){ 384264277f4aSdan bPkOnly1 = (*pp)->op==SQLITE_DELETE; 384364277f4aSdan bPkOnly2 = op==SQLITE_DELETE; 384464277f4aSdan } 384564277f4aSdan if( sessionChangeEqual(pTab, bPkOnly1, (*pp)->aRecord, bPkOnly2, aRec) ){ 38465d607a6eSdan pExist = *pp; 38475d607a6eSdan *pp = (*pp)->pNext; 38485d607a6eSdan pTab->nEntry--; 38495d607a6eSdan break; 38505d607a6eSdan } 38515d607a6eSdan } 38525d607a6eSdan 385364277f4aSdan rc = sessionChangeMerge(pTab, 3854*cbf6d2d2Sdan pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange 385564277f4aSdan ); 38565d607a6eSdan if( rc ) break; 38575d607a6eSdan if( pChange ){ 38585d607a6eSdan pChange->pNext = pTab->apChange[iHash]; 38595d607a6eSdan pTab->apChange[iHash] = pChange; 38605d607a6eSdan pTab->nEntry++; 38615d607a6eSdan } 38625d607a6eSdan } 38635d607a6eSdan 3864*cbf6d2d2Sdan if( rc==SQLITE_OK ) rc = pIter->rc; 38655d607a6eSdan return rc; 38665d607a6eSdan } 38675d607a6eSdan 38685d607a6eSdan /* 38695d607a6eSdan ** 1. Iterate through the left-hand changeset. Add an entry to a table 38705d607a6eSdan ** specific hash table for each change in the changeset. The hash table 38715d607a6eSdan ** key is the PK of the row affected by the change. 38725d607a6eSdan ** 38735d607a6eSdan ** 2. Then interate through the right-hand changeset. Attempt to add an 38745d607a6eSdan ** entry to a hash table for each component change. If a change already 38755d607a6eSdan ** exists with the same PK values, combine the two into a single change. 38765d607a6eSdan ** 38775d607a6eSdan ** 3. Write an output changeset based on the contents of the hash table. 38785d607a6eSdan */ 3879*cbf6d2d2Sdan int sessionChangesetConcat( 3880*cbf6d2d2Sdan sqlite3_changeset_iter *pLeft, 3881*cbf6d2d2Sdan sqlite3_changeset_iter *pRight, 3882*cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 3883*cbf6d2d2Sdan void *pOut, 3884*cbf6d2d2Sdan int *pnOut, 3885*cbf6d2d2Sdan void **ppOut 38865d607a6eSdan ){ 38875d607a6eSdan SessionTable *pList = 0; /* List of SessionTable objects */ 38885d607a6eSdan int rc; /* Return code */ 388964277f4aSdan int bPatch; /* True for a patchset */ 38905d607a6eSdan 3891*cbf6d2d2Sdan assert( xOutput==0 || (ppOut==0 && pnOut==0) ); 38925d607a6eSdan 3893*cbf6d2d2Sdan rc = sessionAddChangeset(pLeft, &pList); 38945d607a6eSdan if( rc==SQLITE_OK ){ 3895*cbf6d2d2Sdan rc = sessionAddChangeset(pRight, &pList); 38965d607a6eSdan } 3897*cbf6d2d2Sdan bPatch = pLeft->bPatchset || pRight->bPatchset; 38985d607a6eSdan 38995d607a6eSdan /* Create the serialized output changeset based on the contents of the 39005d607a6eSdan ** hash tables attached to the SessionTable objects in list pList. 39015d607a6eSdan */ 39025d607a6eSdan if( rc==SQLITE_OK ){ 39035d607a6eSdan SessionTable *pTab; 39045d607a6eSdan SessionBuffer buf = {0, 0, 0}; 3905*cbf6d2d2Sdan for(pTab=pList; pTab && rc==SQLITE_OK; pTab=pTab->pNext){ 39065d607a6eSdan int i; 39075d607a6eSdan if( pTab->nEntry==0 ) continue; 39085d607a6eSdan 390964277f4aSdan sessionAppendTableHdr(&buf, bPatch, pTab, &rc); 39105d607a6eSdan for(i=0; i<pTab->nChange; i++){ 39115d607a6eSdan SessionChange *p; 39125d607a6eSdan for(p=pTab->apChange[i]; p; p=p->pNext){ 3913798693b2Sdan sessionAppendByte(&buf, p->op, &rc); 39145d607a6eSdan sessionAppendByte(&buf, p->bIndirect, &rc); 39155d607a6eSdan sessionAppendBlob(&buf, p->aRecord, p->nRecord, &rc); 39165d607a6eSdan } 39175d607a6eSdan } 3918*cbf6d2d2Sdan 3919*cbf6d2d2Sdan if( rc==SQLITE_OK && xOutput && buf.nBuf>=SESSIONS_STR_CHUNK_SIZE ){ 3920*cbf6d2d2Sdan rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3921*cbf6d2d2Sdan buf.nBuf = 0; 3922*cbf6d2d2Sdan } 39235d607a6eSdan } 39245d607a6eSdan 39255d607a6eSdan if( rc==SQLITE_OK ){ 3926*cbf6d2d2Sdan if( xOutput ){ 3927*cbf6d2d2Sdan if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3928*cbf6d2d2Sdan }else{ 39295d607a6eSdan *ppOut = buf.aBuf; 39305d607a6eSdan *pnOut = buf.nBuf; 3931*cbf6d2d2Sdan buf.aBuf = 0; 39325d607a6eSdan } 39335d607a6eSdan } 3934*cbf6d2d2Sdan sqlite3_free(buf.aBuf); 3935*cbf6d2d2Sdan } 39365d607a6eSdan 39375d607a6eSdan sessionDeleteTable(pList); 39385d607a6eSdan return rc; 39395d607a6eSdan } 39405d607a6eSdan 3941*cbf6d2d2Sdan /* 3942*cbf6d2d2Sdan ** Combine two changesets together. 3943*cbf6d2d2Sdan */ 3944*cbf6d2d2Sdan int sqlite3changeset_concat( 3945*cbf6d2d2Sdan int nLeft, /* Number of bytes in lhs input */ 3946*cbf6d2d2Sdan void *pLeft, /* Lhs input changeset */ 3947*cbf6d2d2Sdan int nRight /* Number of bytes in rhs input */, 3948*cbf6d2d2Sdan void *pRight, /* Rhs input changeset */ 3949*cbf6d2d2Sdan int *pnOut, /* OUT: Number of bytes in output changeset */ 3950*cbf6d2d2Sdan void **ppOut /* OUT: changeset (left <concat> right) */ 3951*cbf6d2d2Sdan ){ 3952*cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 3953*cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 3954*cbf6d2d2Sdan int rc; 3955*cbf6d2d2Sdan 3956*cbf6d2d2Sdan *pnOut = 0; 3957*cbf6d2d2Sdan *ppOut = 0; 3958*cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter1, nLeft, pLeft); 3959*cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3960*cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter2, nRight, pRight); 3961*cbf6d2d2Sdan } 3962*cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3963*cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, 0, 0, pnOut, ppOut); 3964*cbf6d2d2Sdan } 3965*cbf6d2d2Sdan 3966*cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 3967*cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 3968*cbf6d2d2Sdan return rc; 3969*cbf6d2d2Sdan } 3970*cbf6d2d2Sdan 3971*cbf6d2d2Sdan /* 3972*cbf6d2d2Sdan ** Streaming version of sqlite3changeset_concat(). 3973*cbf6d2d2Sdan */ 3974*cbf6d2d2Sdan int sqlite3changeset_concat_str( 3975*cbf6d2d2Sdan int (*xInputA)(void *pIn, void *pData, int *pnData), 3976*cbf6d2d2Sdan void *pInA, 3977*cbf6d2d2Sdan int (*xInputB)(void *pIn, void *pData, int *pnData), 3978*cbf6d2d2Sdan void *pInB, 3979*cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 3980*cbf6d2d2Sdan void *pOut 3981*cbf6d2d2Sdan ){ 3982*cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 3983*cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 3984*cbf6d2d2Sdan int rc; 3985*cbf6d2d2Sdan 3986*cbf6d2d2Sdan rc = sqlite3changeset_start_str(&pIter1, xInputA, pInA); 3987*cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3988*cbf6d2d2Sdan rc = sqlite3changeset_start_str(&pIter2, xInputB, pInB); 3989*cbf6d2d2Sdan } 3990*cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3991*cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, xOutput, pOut, 0, 0); 3992*cbf6d2d2Sdan } 3993*cbf6d2d2Sdan 3994*cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 3995*cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 3996*cbf6d2d2Sdan return rc; 3997*cbf6d2d2Sdan } 3998*cbf6d2d2Sdan 39999b1c62d4Sdrh #endif /* SQLITE_ENABLE_SESSION && SQLITE_ENABLE_PREUPDATE_HOOK */ 4000