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 */ 20f1a08ad8Sdrh #ifndef SESSIONS_STRM_CHUNK_SIZE 214757c658Sdan # ifdef SQLITE_TEST 22f1a08ad8Sdrh # define SESSIONS_STRM_CHUNK_SIZE 64 234757c658Sdan # else 24f1a08ad8Sdrh # define SESSIONS_STRM_CHUNK_SIZE 1024 25f1a08ad8Sdrh # endif 264757c658Sdan #endif 274fccf43aSdan 28296c7658Sdan /* 29296c7658Sdan ** Session handle structure. 30296c7658Sdan */ 314fccf43aSdan struct sqlite3_session { 324fccf43aSdan sqlite3 *db; /* Database handle session is attached to */ 334fccf43aSdan char *zDb; /* Name of database session is attached to */ 34296c7658Sdan int bEnable; /* True if currently recording */ 35b4480e94Sdan int bIndirect; /* True if all changes are indirect */ 36ff4d0f41Sdan int bAutoAttach; /* True to auto-attach tables */ 374fccf43aSdan int rc; /* Non-zero if an error has occurred */ 387531a5a3Sdan void *pFilterCtx; /* First argument to pass to xTableFilter */ 397531a5a3Sdan int (*xTableFilter)(void *pCtx, const char *zTab); 404fccf43aSdan sqlite3_session *pNext; /* Next session object on same db. */ 414fccf43aSdan SessionTable *pTable; /* List of attached tables */ 424fccf43aSdan }; 434fccf43aSdan 444fccf43aSdan /* 45ef7a6304Sdan ** Instances of this structure are used to build strings or binary records. 46ef7a6304Sdan */ 47ef7a6304Sdan struct SessionBuffer { 48ef7a6304Sdan u8 *aBuf; /* Pointer to changeset buffer */ 49ef7a6304Sdan int nBuf; /* Size of buffer aBuf */ 50ef7a6304Sdan int nAlloc; /* Size of allocation containing aBuf */ 51ef7a6304Sdan }; 52ef7a6304Sdan 53ef7a6304Sdan /* 5416228167Sdan ** An object of this type is used internally as an abstraction for 5516228167Sdan ** input data. Input data may be supplied either as a single large buffer 5616228167Sdan ** (e.g. sqlite3changeset_start()) or using a stream function (e.g. 57f1a08ad8Sdrh ** sqlite3changeset_start_strm()). 58ef7a6304Sdan */ 59ef7a6304Sdan struct SessionInput { 604757c658Sdan int iNext; /* Offset in aData[] of next change */ 614757c658Sdan u8 *aData; /* Pointer to buffer containing changeset */ 624757c658Sdan int nData; /* Number of bytes in aData */ 634757c658Sdan 64ef7a6304Sdan SessionBuffer buf; /* Current read buffer */ 65ef7a6304Sdan int (*xInput)(void*, void*, int*); /* Input stream call (or NULL) */ 66ef7a6304Sdan void *pIn; /* First argument to xInput */ 67ef7a6304Sdan int bEof; /* Set to true after xInput finished */ 68ef7a6304Sdan }; 69ef7a6304Sdan 70ef7a6304Sdan /* 71296c7658Sdan ** Structure for changeset iterators. 72296c7658Sdan */ 73296c7658Sdan struct sqlite3_changeset_iter { 74ef7a6304Sdan SessionInput in; /* Input buffer or stream */ 75ef7a6304Sdan SessionBuffer tblhdr; /* Buffer to hold apValue/zTab/abPK/ */ 7673b3c055Sdan int bPatchset; /* True if this is a patchset */ 77296c7658Sdan int rc; /* Iterator error code */ 78296c7658Sdan sqlite3_stmt *pConflict; /* Points to conflicting row, if any */ 79296c7658Sdan char *zTab; /* Current table */ 80296c7658Sdan int nCol; /* Number of columns in zTab */ 81296c7658Sdan int op; /* Current operation */ 82b4480e94Sdan int bIndirect; /* True if current change was indirect */ 83244593c8Sdan u8 *abPK; /* Primary key array */ 84296c7658Sdan sqlite3_value **apValue; /* old.* and new.* values */ 85296c7658Sdan }; 86296c7658Sdan 87296c7658Sdan /* 884fccf43aSdan ** Each session object maintains a set of the following structures, one 894fccf43aSdan ** for each table the session object is monitoring. The structures are 904fccf43aSdan ** stored in a linked list starting at sqlite3_session.pTable. 914fccf43aSdan ** 924fccf43aSdan ** The keys of the SessionTable.aChange[] hash table are all rows that have 934fccf43aSdan ** been modified in any way since the session object was attached to the 944fccf43aSdan ** table. 954fccf43aSdan ** 964fccf43aSdan ** The data associated with each hash-table entry is a structure containing 974fccf43aSdan ** a subset of the initial values that the modified row contained at the 984fccf43aSdan ** start of the session. Or no initial values if the row was inserted. 994fccf43aSdan */ 1004fccf43aSdan struct SessionTable { 1014fccf43aSdan SessionTable *pNext; 1024fccf43aSdan char *zName; /* Local name of table */ 1034fccf43aSdan int nCol; /* Number of columns in table zName */ 104e8d5648eSdan const char **azCol; /* Column names */ 105e8d5648eSdan u8 *abPK; /* Array of primary key flags */ 106296c7658Sdan int nEntry; /* Total number of entries in hash table */ 1074fccf43aSdan int nChange; /* Size of apChange[] array */ 1084fccf43aSdan SessionChange **apChange; /* Hash table buckets */ 1094fccf43aSdan }; 1104fccf43aSdan 1114fccf43aSdan /* 1124fccf43aSdan ** RECORD FORMAT: 1134fccf43aSdan ** 1144fccf43aSdan ** The following record format is similar to (but not compatible with) that 1154fccf43aSdan ** used in SQLite database files. This format is used as part of the 1164fccf43aSdan ** change-set binary format, and so must be architecture independent. 1174fccf43aSdan ** 1184fccf43aSdan ** Unlike the SQLite database record format, each field is self-contained - 1194fccf43aSdan ** there is no separation of header and data. Each field begins with a 1204fccf43aSdan ** single byte describing its type, as follows: 1214fccf43aSdan ** 1224fccf43aSdan ** 0x00: Undefined value. 1234fccf43aSdan ** 0x01: Integer value. 1244fccf43aSdan ** 0x02: Real value. 1254fccf43aSdan ** 0x03: Text value. 1264fccf43aSdan ** 0x04: Blob value. 1274fccf43aSdan ** 0x05: SQL NULL value. 1284fccf43aSdan ** 1294fccf43aSdan ** Note that the above match the definitions of SQLITE_INTEGER, SQLITE_TEXT 1304fccf43aSdan ** and so on in sqlite3.h. For undefined and NULL values, the field consists 1314fccf43aSdan ** only of the single type byte. For other types of values, the type byte 1324fccf43aSdan ** is followed by: 1334fccf43aSdan ** 1344fccf43aSdan ** Text values: 1354fccf43aSdan ** A varint containing the number of bytes in the value (encoded using 1364fccf43aSdan ** UTF-8). Followed by a buffer containing the UTF-8 representation 1374fccf43aSdan ** of the text value. There is no nul terminator. 1384fccf43aSdan ** 1394fccf43aSdan ** Blob values: 1404fccf43aSdan ** A varint containing the number of bytes in the value, followed by 1414fccf43aSdan ** a buffer containing the value itself. 1424fccf43aSdan ** 1434fccf43aSdan ** Integer values: 1444fccf43aSdan ** An 8-byte big-endian integer value. 1454fccf43aSdan ** 1464fccf43aSdan ** Real values: 1474fccf43aSdan ** An 8-byte big-endian IEEE 754-2008 real value. 1484fccf43aSdan ** 1494fccf43aSdan ** Varint values are encoded in the same way as varints in the SQLite 1504fccf43aSdan ** record format. 1514fccf43aSdan ** 1524fccf43aSdan ** CHANGESET FORMAT: 1534fccf43aSdan ** 1544fccf43aSdan ** A changeset is a collection of DELETE, UPDATE and INSERT operations on 1554fccf43aSdan ** one or more tables. Operations on a single table are grouped together, 1564fccf43aSdan ** but may occur in any order (i.e. deletes, updates and inserts are all 1574fccf43aSdan ** mixed together). 1584fccf43aSdan ** 1594fccf43aSdan ** Each group of changes begins with a table header: 1604fccf43aSdan ** 1614fccf43aSdan ** 1 byte: Constant 0x54 (capital 'T') 1624fccf43aSdan ** Varint: Big-endian integer set to the number of columns in the table. 16373b3c055Sdan ** nCol bytes: 0x01 for PK columns, 0x00 otherwise. 1644fccf43aSdan ** N bytes: Unqualified table name (encoded using UTF-8). Nul-terminated. 1654fccf43aSdan ** 1664fccf43aSdan ** Followed by one or more changes to the table. 1674fccf43aSdan ** 1684fccf43aSdan ** 1 byte: Either SQLITE_INSERT, UPDATE or DELETE. 1695d607a6eSdan ** 1 byte: The "indirect-change" flag. 1704fccf43aSdan ** old.* record: (delete and update only) 1714fccf43aSdan ** new.* record: (insert and update only) 17273b3c055Sdan ** 17373b3c055Sdan ** PATCHSET FORMAT: 17473b3c055Sdan ** 17573b3c055Sdan ** A patchset is also a collection of changes. It is similar to a changeset, 17673b3c055Sdan ** but omits those fields that are not useful if no conflict resolution 17773b3c055Sdan ** is required when applying the changeset. 17873b3c055Sdan ** 17973b3c055Sdan ** Each group of changes begins with a table header: 18073b3c055Sdan ** 18173b3c055Sdan ** 1 byte: Constant 0x50 (capital 'P') 18273b3c055Sdan ** Varint: Big-endian integer set to the number of columns in the table. 18373b3c055Sdan ** nCol bytes: 0x01 for PK columns, 0x00 otherwise. 18473b3c055Sdan ** N bytes: Unqualified table name (encoded using UTF-8). Nul-terminated. 18573b3c055Sdan ** 18673b3c055Sdan ** Followed by one or more changes to the table. 18773b3c055Sdan ** 18873b3c055Sdan ** 1 byte: Either SQLITE_INSERT, UPDATE or DELETE. 18973b3c055Sdan ** 1 byte: The "indirect-change" flag. 19073b3c055Sdan ** single record: (PK fields for DELETE, or full record for INSERT/UPDATE). 1914fccf43aSdan */ 1924fccf43aSdan 1934fccf43aSdan /* 1944fccf43aSdan ** For each row modified during a session, there exists a single instance of 1954fccf43aSdan ** this structure stored in a SessionTable.aChange[] hash table. 1964fccf43aSdan */ 1974fccf43aSdan struct SessionChange { 198798693b2Sdan int op; /* One of UPDATE, DELETE, INSERT */ 199b4480e94Sdan int bIndirect; /* True if this change is "indirect" */ 2004fccf43aSdan int nRecord; /* Number of bytes in buffer aRecord[] */ 2014fccf43aSdan u8 *aRecord; /* Buffer containing old.* record */ 2024fccf43aSdan SessionChange *pNext; /* For hash-table collisions */ 2034fccf43aSdan }; 2044fccf43aSdan 205296c7658Sdan /* 206296c7658Sdan ** Write a varint with value iVal into the buffer at aBuf. Return the 207296c7658Sdan ** number of bytes written. 208296c7658Sdan */ 209296c7658Sdan static int sessionVarintPut(u8 *aBuf, int iVal){ 210296c7658Sdan return putVarint32(aBuf, iVal); 2114fccf43aSdan } 2124fccf43aSdan 213296c7658Sdan /* 214296c7658Sdan ** Return the number of bytes required to store value iVal as a varint. 215296c7658Sdan */ 216296c7658Sdan static int sessionVarintLen(int iVal){ 217296c7658Sdan return sqlite3VarintLen(iVal); 218296c7658Sdan } 219296c7658Sdan 220296c7658Sdan /* 221296c7658Sdan ** Read a varint value from aBuf[] into *piVal. Return the number of 222296c7658Sdan ** bytes read. 223296c7658Sdan */ 2244fccf43aSdan static int sessionVarintGet(u8 *aBuf, int *piVal){ 225296c7658Sdan return getVarint32(aBuf, *piVal); 2264fccf43aSdan } 2274fccf43aSdan 228296c7658Sdan /* 229296c7658Sdan ** Read a 64-bit big-endian integer value from buffer aRec[]. Return 230296c7658Sdan ** the value read. 231296c7658Sdan */ 2324fccf43aSdan static sqlite3_int64 sessionGetI64(u8 *aRec){ 2334fccf43aSdan return (((sqlite3_int64)aRec[0]) << 56) 2344fccf43aSdan + (((sqlite3_int64)aRec[1]) << 48) 2354fccf43aSdan + (((sqlite3_int64)aRec[2]) << 40) 2364fccf43aSdan + (((sqlite3_int64)aRec[3]) << 32) 2374fccf43aSdan + (((sqlite3_int64)aRec[4]) << 24) 2384fccf43aSdan + (((sqlite3_int64)aRec[5]) << 16) 2394fccf43aSdan + (((sqlite3_int64)aRec[6]) << 8) 2404fccf43aSdan + (((sqlite3_int64)aRec[7]) << 0); 2414fccf43aSdan } 2424fccf43aSdan 2434fccf43aSdan /* 244296c7658Sdan ** Write a 64-bit big-endian integer value to the buffer aBuf[]. 245296c7658Sdan */ 246296c7658Sdan static void sessionPutI64(u8 *aBuf, sqlite3_int64 i){ 247296c7658Sdan aBuf[0] = (i>>56) & 0xFF; 248296c7658Sdan aBuf[1] = (i>>48) & 0xFF; 249296c7658Sdan aBuf[2] = (i>>40) & 0xFF; 250296c7658Sdan aBuf[3] = (i>>32) & 0xFF; 251296c7658Sdan aBuf[4] = (i>>24) & 0xFF; 252296c7658Sdan aBuf[5] = (i>>16) & 0xFF; 253296c7658Sdan aBuf[6] = (i>> 8) & 0xFF; 254296c7658Sdan aBuf[7] = (i>> 0) & 0xFF; 255296c7658Sdan } 256296c7658Sdan 257296c7658Sdan /* 2584fccf43aSdan ** This function is used to serialize the contents of value pValue (see 2594fccf43aSdan ** comment titled "RECORD FORMAT" above). 2604fccf43aSdan ** 2614fccf43aSdan ** If it is non-NULL, the serialized form of the value is written to 2624fccf43aSdan ** buffer aBuf. *pnWrite is set to the number of bytes written before 2634fccf43aSdan ** returning. Or, if aBuf is NULL, the only thing this function does is 2644fccf43aSdan ** set *pnWrite. 2654fccf43aSdan ** 2664fccf43aSdan ** If no error occurs, SQLITE_OK is returned. Or, if an OOM error occurs 2674fccf43aSdan ** within a call to sqlite3_value_text() (may fail if the db is utf-16)) 2684fccf43aSdan ** SQLITE_NOMEM is returned. 2694fccf43aSdan */ 2704fccf43aSdan static int sessionSerializeValue( 2714fccf43aSdan u8 *aBuf, /* If non-NULL, write serialized value here */ 2724fccf43aSdan sqlite3_value *pValue, /* Value to serialize */ 2734fccf43aSdan int *pnWrite /* IN/OUT: Increment by bytes written */ 2744fccf43aSdan ){ 275296c7658Sdan int nByte; /* Size of serialized value in bytes */ 2764fccf43aSdan 27780fe2d93Sdan if( pValue ){ 27880fe2d93Sdan int eType; /* Value type (SQLITE_NULL, TEXT etc.) */ 27980fe2d93Sdan 2804fccf43aSdan eType = sqlite3_value_type(pValue); 2814fccf43aSdan if( aBuf ) aBuf[0] = eType; 2824fccf43aSdan 2834fccf43aSdan switch( eType ){ 2844fccf43aSdan case SQLITE_NULL: 2854fccf43aSdan nByte = 1; 2864fccf43aSdan break; 2874fccf43aSdan 2884fccf43aSdan case SQLITE_INTEGER: 2894fccf43aSdan case SQLITE_FLOAT: 2904fccf43aSdan if( aBuf ){ 2914fccf43aSdan /* TODO: SQLite does something special to deal with mixed-endian 2924fccf43aSdan ** floating point values (e.g. ARM7). This code probably should 2934fccf43aSdan ** too. */ 2944fccf43aSdan u64 i; 2954fccf43aSdan if( eType==SQLITE_INTEGER ){ 2964fccf43aSdan i = (u64)sqlite3_value_int64(pValue); 2974fccf43aSdan }else{ 2984fccf43aSdan double r; 2994fccf43aSdan assert( sizeof(double)==8 && sizeof(u64)==8 ); 3004fccf43aSdan r = sqlite3_value_double(pValue); 3014fccf43aSdan memcpy(&i, &r, 8); 3024fccf43aSdan } 303296c7658Sdan sessionPutI64(&aBuf[1], i); 3044fccf43aSdan } 3054fccf43aSdan nByte = 9; 3064fccf43aSdan break; 3074fccf43aSdan 3084e895da1Sdan default: { 30980fe2d93Sdan u8 *z; 31080fe2d93Sdan int n; 31180fe2d93Sdan int nVarint; 31280fe2d93Sdan 3134e895da1Sdan assert( eType==SQLITE_TEXT || eType==SQLITE_BLOB ); 31480fe2d93Sdan if( eType==SQLITE_TEXT ){ 31580fe2d93Sdan z = (u8 *)sqlite3_value_text(pValue); 31680fe2d93Sdan }else{ 31780fe2d93Sdan z = (u8 *)sqlite3_value_blob(pValue); 31880fe2d93Sdan } 31980fe2d93Sdan if( z==0 ) return SQLITE_NOMEM; 32080fe2d93Sdan n = sqlite3_value_bytes(pValue); 32180fe2d93Sdan nVarint = sessionVarintLen(n); 32280fe2d93Sdan 3234fccf43aSdan if( aBuf ){ 3244fccf43aSdan sessionVarintPut(&aBuf[1], n); 3254fccf43aSdan memcpy(&aBuf[nVarint + 1], eType==SQLITE_TEXT ? 3264fccf43aSdan sqlite3_value_text(pValue) : sqlite3_value_blob(pValue), n 3274fccf43aSdan ); 3284fccf43aSdan } 3294fccf43aSdan 3304fccf43aSdan nByte = 1 + nVarint + n; 3314fccf43aSdan break; 3324fccf43aSdan } 3334fccf43aSdan } 33480fe2d93Sdan }else{ 33580fe2d93Sdan nByte = 1; 33680fe2d93Sdan if( aBuf ) aBuf[0] = '\0'; 33780fe2d93Sdan } 3384fccf43aSdan 339fa122adaSdan if( pnWrite ) *pnWrite += nByte; 3404fccf43aSdan return SQLITE_OK; 3414fccf43aSdan } 3424fccf43aSdan 343fa122adaSdan 344798693b2Sdan /* 345798693b2Sdan ** This macro is used to calculate hash key values for data structures. In 346798693b2Sdan ** order to use this macro, the entire data structure must be represented 347798693b2Sdan ** as a series of unsigned integers. In order to calculate a hash-key value 348798693b2Sdan ** for a data structure represented as three such integers, the macro may 349798693b2Sdan ** then be used as follows: 350798693b2Sdan ** 351798693b2Sdan ** int hash_key_value; 352798693b2Sdan ** hash_key_value = HASH_APPEND(0, <value 1>); 353798693b2Sdan ** hash_key_value = HASH_APPEND(hash_key_value, <value 2>); 354798693b2Sdan ** hash_key_value = HASH_APPEND(hash_key_value, <value 3>); 355798693b2Sdan ** 356798693b2Sdan ** In practice, the data structures this macro is used for are the primary 357798693b2Sdan ** key values of modified rows. 358798693b2Sdan */ 3594131639cSdan #define HASH_APPEND(hash, add) ((hash) << 3) ^ (hash) ^ (unsigned int)(add) 360798693b2Sdan 361798693b2Sdan /* 362798693b2Sdan ** Append the hash of the 64-bit integer passed as the second argument to the 363798693b2Sdan ** hash-key value passed as the first. Return the new hash-key value. 364798693b2Sdan */ 3654131639cSdan static unsigned int sessionHashAppendI64(unsigned int h, i64 i){ 366e8d5648eSdan h = HASH_APPEND(h, i & 0xFFFFFFFF); 367e8d5648eSdan return HASH_APPEND(h, (i>>32)&0xFFFFFFFF); 368e8d5648eSdan } 369798693b2Sdan 370798693b2Sdan /* 371798693b2Sdan ** Append the hash of the blob passed via the second and third arguments to 372798693b2Sdan ** the hash-key value passed as the first. Return the new hash-key value. 373798693b2Sdan */ 3744131639cSdan static unsigned int sessionHashAppendBlob(unsigned int h, int n, const u8 *z){ 375e8d5648eSdan int i; 376e8d5648eSdan for(i=0; i<n; i++) h = HASH_APPEND(h, z[i]); 377e8d5648eSdan return h; 378e8d5648eSdan } 379e8d5648eSdan 3804fccf43aSdan /* 381798693b2Sdan ** Append the hash of the data type passed as the second argument to the 382798693b2Sdan ** hash-key value passed as the first. Return the new hash-key value. 383798693b2Sdan */ 384798693b2Sdan static unsigned int sessionHashAppendType(unsigned int h, int eType){ 385798693b2Sdan return HASH_APPEND(h, eType); 386798693b2Sdan } 387798693b2Sdan 388798693b2Sdan /* 3894131639cSdan ** This function may only be called from within a pre-update callback. 3904131639cSdan ** It calculates a hash based on the primary key values of the old.* or 391798693b2Sdan ** new.* row currently available and, assuming no error occurs, writes it to 392798693b2Sdan ** *piHash before returning. If the primary key contains one or more NULL 393798693b2Sdan ** values, *pbNullPK is set to true before returning. 394798693b2Sdan ** 395798693b2Sdan ** If an error occurs, an SQLite error code is returned and the final values 396798693b2Sdan ** of *piHash asn *pbNullPK are undefined. Otherwise, SQLITE_OK is returned 397798693b2Sdan ** and the output variables are set as described above. 3984fccf43aSdan */ 399798693b2Sdan static int sessionPreupdateHash( 400e8d5648eSdan sqlite3 *db, /* Database handle */ 401e8d5648eSdan SessionTable *pTab, /* Session table handle */ 402e8d5648eSdan int bNew, /* True to hash the new.* PK */ 40327453faeSdan int *piHash, /* OUT: Hash value */ 404798693b2Sdan int *pbNullPK /* OUT: True if there are NULL values in PK */ 405e8d5648eSdan ){ 4064131639cSdan unsigned int h = 0; /* Hash value to return */ 4074131639cSdan int i; /* Used to iterate through columns */ 408e8d5648eSdan 40927453faeSdan assert( *pbNullPK==0 ); 410e8d5648eSdan assert( pTab->nCol==sqlite3_preupdate_count(db) ); 411e8d5648eSdan for(i=0; i<pTab->nCol; i++){ 412e8d5648eSdan if( pTab->abPK[i] ){ 413e8d5648eSdan int rc; 414e8d5648eSdan int eType; 415e8d5648eSdan sqlite3_value *pVal; 416e8d5648eSdan 417e8d5648eSdan if( bNew ){ 418e8d5648eSdan rc = sqlite3_preupdate_new(db, i, &pVal); 419e8d5648eSdan }else{ 420e8d5648eSdan rc = sqlite3_preupdate_old(db, i, &pVal); 421e8d5648eSdan } 42212ca0b56Sdan if( rc!=SQLITE_OK ) return rc; 423e8d5648eSdan 424e8d5648eSdan eType = sqlite3_value_type(pVal); 425798693b2Sdan h = sessionHashAppendType(h, eType); 4266734007dSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 427e8d5648eSdan i64 iVal; 428e8d5648eSdan if( eType==SQLITE_INTEGER ){ 429e8d5648eSdan iVal = sqlite3_value_int64(pVal); 430e8d5648eSdan }else{ 431e8d5648eSdan double rVal = sqlite3_value_double(pVal); 432e8d5648eSdan assert( sizeof(iVal)==8 && sizeof(rVal)==8 ); 433e8d5648eSdan memcpy(&iVal, &rVal, 8); 434e8d5648eSdan } 435e8d5648eSdan h = sessionHashAppendI64(h, iVal); 4366734007dSdan }else if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 4376734007dSdan const u8 *z; 4386734007dSdan if( eType==SQLITE_TEXT ){ 4396734007dSdan z = (const u8 *)sqlite3_value_text(pVal); 4406734007dSdan }else{ 4416734007dSdan z = (const u8 *)sqlite3_value_blob(pVal); 442e8d5648eSdan } 4436734007dSdan if( !z ) return SQLITE_NOMEM; 4446734007dSdan h = sessionHashAppendBlob(h, sqlite3_value_bytes(pVal), z); 4456734007dSdan }else{ 44627453faeSdan assert( eType==SQLITE_NULL ); 44727453faeSdan *pbNullPK = 1; 448e8d5648eSdan } 449e8d5648eSdan } 450e8d5648eSdan } 451e8d5648eSdan 452e8d5648eSdan *piHash = (h % pTab->nChange); 453e8d5648eSdan return SQLITE_OK; 454e8d5648eSdan } 455e8d5648eSdan 4564131639cSdan /* 4576cda207fSdan ** The buffer that the argument points to contains a serialized SQL value. 4586cda207fSdan ** Return the number of bytes of space occupied by the value (including 4596cda207fSdan ** the type byte). 4606cda207fSdan */ 4616cda207fSdan static int sessionSerialLen(u8 *a){ 4626cda207fSdan int e = *a; 4636cda207fSdan int n; 4646cda207fSdan if( e==0 ) return 1; 4656cda207fSdan if( e==SQLITE_NULL ) return 1; 4666cda207fSdan if( e==SQLITE_INTEGER || e==SQLITE_FLOAT ) return 9; 4676cda207fSdan return sessionVarintGet(&a[1], &n) + 1 + n; 4686cda207fSdan } 4696cda207fSdan 4706cda207fSdan /* 4715d607a6eSdan ** Based on the primary key values stored in change aRecord, calculate a 472798693b2Sdan ** hash key. Assume the has table has nBucket buckets. The hash keys 4734131639cSdan ** calculated by this function are compatible with those calculated by 4744131639cSdan ** sessionPreupdateHash(). 47564277f4aSdan ** 47664277f4aSdan ** The bPkOnly argument is non-zero if the record at aRecord[] is from 47764277f4aSdan ** a patchset DELETE. In this case the non-PK fields are omitted entirely. 4784131639cSdan */ 4794131639cSdan static unsigned int sessionChangeHash( 4804131639cSdan SessionTable *pTab, /* Table handle */ 48164277f4aSdan int bPkOnly, /* Record consists of PK fields only */ 4825d607a6eSdan u8 *aRecord, /* Change record */ 4834131639cSdan int nBucket /* Assume this many buckets in hash table */ 484e8d5648eSdan ){ 4854131639cSdan unsigned int h = 0; /* Value to return */ 4864131639cSdan int i; /* Used to iterate through columns */ 4875d607a6eSdan u8 *a = aRecord; /* Used to iterate through change record */ 488e8d5648eSdan 489e8d5648eSdan for(i=0; i<pTab->nCol; i++){ 4906cda207fSdan int eType = *a; 491e8d5648eSdan int isPK = pTab->abPK[i]; 49264277f4aSdan if( bPkOnly && isPK==0 ) continue; 493e8d5648eSdan 49427453faeSdan /* It is not possible for eType to be SQLITE_NULL here. The session 49527453faeSdan ** module does not record changes for rows with NULL values stored in 49627453faeSdan ** primary key columns. */ 49727453faeSdan assert( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT 49827453faeSdan || eType==SQLITE_TEXT || eType==SQLITE_BLOB 4996cda207fSdan || eType==SQLITE_NULL || eType==0 50027453faeSdan ); 5016cda207fSdan assert( !isPK || (eType!=0 && eType!=SQLITE_NULL) ); 50227453faeSdan 5036cda207fSdan if( isPK ){ 5046cda207fSdan a++; 505798693b2Sdan h = sessionHashAppendType(h, eType); 50627453faeSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 5076734007dSdan h = sessionHashAppendI64(h, sessionGetI64(a)); 508e8d5648eSdan a += 8; 50927453faeSdan }else{ 510e8d5648eSdan int n; 511e8d5648eSdan a += sessionVarintGet(a, &n); 5126734007dSdan h = sessionHashAppendBlob(h, n, a); 513e8d5648eSdan a += n; 514e8d5648eSdan } 5156cda207fSdan }else{ 5166cda207fSdan a += sessionSerialLen(a); 5176cda207fSdan } 518e8d5648eSdan } 519e8d5648eSdan return (h % nBucket); 520e8d5648eSdan } 521e8d5648eSdan 522798693b2Sdan /* 523798693b2Sdan ** Arguments aLeft and aRight are pointers to change records for table pTab. 524798693b2Sdan ** This function returns true if the two records apply to the same row (i.e. 525798693b2Sdan ** have the same values stored in the primary key columns), or false 526798693b2Sdan ** otherwise. 527798693b2Sdan */ 5285d607a6eSdan static int sessionChangeEqual( 529798693b2Sdan SessionTable *pTab, /* Table used for PK definition */ 530a71d2371Sdan int bLeftPkOnly, /* True if aLeft[] contains PK fields only */ 5315d607a6eSdan u8 *aLeft, /* Change record */ 532a71d2371Sdan int bRightPkOnly, /* True if aRight[] contains PK fields only */ 5335d607a6eSdan u8 *aRight /* Change record */ 5345d607a6eSdan ){ 535798693b2Sdan u8 *a1 = aLeft; /* Cursor to iterate through aLeft */ 536798693b2Sdan u8 *a2 = aRight; /* Cursor to iterate through aRight */ 537798693b2Sdan int iCol; /* Used to iterate through table columns */ 5385d607a6eSdan 539798693b2Sdan for(iCol=0; iCol<pTab->nCol; iCol++){ 5405d607a6eSdan int n1 = sessionSerialLen(a1); 5415d607a6eSdan int n2 = sessionSerialLen(a2); 5425d607a6eSdan 543798693b2Sdan if( pTab->abPK[iCol] && (n1!=n2 || memcmp(a1, a2, n1)) ){ 5445d607a6eSdan return 0; 5455d607a6eSdan } 54664277f4aSdan if( pTab->abPK[iCol] || bLeftPkOnly==0 ) a1 += n1; 54764277f4aSdan if( pTab->abPK[iCol] || bRightPkOnly==0 ) a2 += n2; 5485d607a6eSdan } 5495d607a6eSdan 5505d607a6eSdan return 1; 5515d607a6eSdan } 5525d607a6eSdan 553798693b2Sdan /* 554798693b2Sdan ** Arguments aLeft and aRight both point to buffers containing change 555798693b2Sdan ** records with nCol columns. This function "merges" the two records into 556798693b2Sdan ** a single records which is written to the buffer at *paOut. *paOut is 557798693b2Sdan ** then set to point to one byte after the last byte written before 558798693b2Sdan ** returning. 559798693b2Sdan ** 560798693b2Sdan ** The merging of records is done as follows: For each column, if the 561798693b2Sdan ** aRight record contains a value for the column, copy the value from 562798693b2Sdan ** their. Otherwise, if aLeft contains a value, copy it. If neither 563798693b2Sdan ** record contains a value for a given column, then neither does the 564798693b2Sdan ** output record. 565798693b2Sdan */ 5665d607a6eSdan static void sessionMergeRecord( 5675d607a6eSdan u8 **paOut, 568798693b2Sdan int nCol, 5695d607a6eSdan u8 *aLeft, 5705d607a6eSdan u8 *aRight 5715d607a6eSdan ){ 572798693b2Sdan u8 *a1 = aLeft; /* Cursor used to iterate through aLeft */ 573798693b2Sdan u8 *a2 = aRight; /* Cursor used to iterate through aRight */ 574798693b2Sdan u8 *aOut = *paOut; /* Output cursor */ 575798693b2Sdan int iCol; /* Used to iterate from 0 to nCol */ 5765d607a6eSdan 577798693b2Sdan for(iCol=0; iCol<nCol; iCol++){ 5785d607a6eSdan int n1 = sessionSerialLen(a1); 5795d607a6eSdan int n2 = sessionSerialLen(a2); 5805d607a6eSdan if( *a2 ){ 5815d607a6eSdan memcpy(aOut, a2, n2); 5825d607a6eSdan aOut += n2; 5835d607a6eSdan }else{ 5845d607a6eSdan memcpy(aOut, a1, n1); 5855d607a6eSdan aOut += n1; 5865d607a6eSdan } 5875d607a6eSdan a1 += n1; 5885d607a6eSdan a2 += n2; 5895d607a6eSdan } 5905d607a6eSdan 5915d607a6eSdan *paOut = aOut; 5925d607a6eSdan } 5935d607a6eSdan 594798693b2Sdan /* 595798693b2Sdan ** This is a helper function used by sessionMergeUpdate(). 596798693b2Sdan ** 597798693b2Sdan ** When this function is called, both *paOne and *paTwo point to a value 598798693b2Sdan ** within a change record. Before it returns, both have been advanced so 599798693b2Sdan ** as to point to the next value in the record. 600798693b2Sdan ** 601798693b2Sdan ** If, when this function is called, *paTwo points to a valid value (i.e. 602fa29ecc4Sdan ** *paTwo[0] is not 0x00 - the "no value" placeholder), a copy of the *paTwo 603798693b2Sdan ** pointer is returned and *pnVal is set to the number of bytes in the 604798693b2Sdan ** serialized value. Otherwise, a copy of *paOne is returned and *pnVal 605798693b2Sdan ** set to the number of bytes in the value at *paOne. If *paOne points 606fa29ecc4Sdan ** to the "no value" placeholder, *pnVal is set to 1. In other words: 607fa29ecc4Sdan ** 608fa29ecc4Sdan ** if( *paTwo is valid ) return *paTwo; 609fa29ecc4Sdan ** return *paOne; 610fa29ecc4Sdan ** 611798693b2Sdan */ 6125d607a6eSdan static u8 *sessionMergeValue( 613798693b2Sdan u8 **paOne, /* IN/OUT: Left-hand buffer pointer */ 614798693b2Sdan u8 **paTwo, /* IN/OUT: Right-hand buffer pointer */ 615798693b2Sdan int *pnVal /* OUT: Bytes in returned value */ 6165d607a6eSdan ){ 6175d607a6eSdan u8 *a1 = *paOne; 6185d607a6eSdan u8 *a2 = *paTwo; 6195d607a6eSdan u8 *pRet = 0; 6205d607a6eSdan int n1; 6215d607a6eSdan 6225d607a6eSdan assert( a1 ); 6235d607a6eSdan if( a2 ){ 6245d607a6eSdan int n2 = sessionSerialLen(a2); 6255d607a6eSdan if( *a2 ){ 6265d607a6eSdan *pnVal = n2; 6275d607a6eSdan pRet = a2; 6285d607a6eSdan } 6295d607a6eSdan *paTwo = &a2[n2]; 6305d607a6eSdan } 6315d607a6eSdan 6325d607a6eSdan n1 = sessionSerialLen(a1); 6335d607a6eSdan if( pRet==0 ){ 6345d607a6eSdan *pnVal = n1; 6355d607a6eSdan pRet = a1; 6365d607a6eSdan } 6375d607a6eSdan *paOne = &a1[n1]; 6385d607a6eSdan 6395d607a6eSdan return pRet; 6405d607a6eSdan } 6415d607a6eSdan 642798693b2Sdan /* 643798693b2Sdan ** This function is used by changeset_concat() to merge two UPDATE changes 644798693b2Sdan ** on the same row. 645798693b2Sdan */ 6465d607a6eSdan static int sessionMergeUpdate( 647798693b2Sdan u8 **paOut, /* IN/OUT: Pointer to output buffer */ 648798693b2Sdan SessionTable *pTab, /* Table change pertains to */ 649a71d2371Sdan int bPatchset, /* True if records are patchset records */ 650798693b2Sdan u8 *aOldRecord1, /* old.* record for first change */ 651798693b2Sdan u8 *aOldRecord2, /* old.* record for second change */ 652798693b2Sdan u8 *aNewRecord1, /* new.* record for first change */ 653798693b2Sdan u8 *aNewRecord2 /* new.* record for second change */ 6545d607a6eSdan ){ 6555d607a6eSdan u8 *aOld1 = aOldRecord1; 6565d607a6eSdan u8 *aOld2 = aOldRecord2; 6575d607a6eSdan u8 *aNew1 = aNewRecord1; 6585d607a6eSdan u8 *aNew2 = aNewRecord2; 6595d607a6eSdan 6605d607a6eSdan u8 *aOut = *paOut; 6615d607a6eSdan int i; 66264277f4aSdan 66364277f4aSdan if( bPatchset==0 ){ 6645d607a6eSdan int bRequired = 0; 6655d607a6eSdan 6665d607a6eSdan assert( aOldRecord1 && aNewRecord1 ); 6675d607a6eSdan 6685d607a6eSdan /* Write the old.* vector first. */ 6695d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6705d607a6eSdan int nOld; 6715d607a6eSdan u8 *aOld; 6725d607a6eSdan int nNew; 6735d607a6eSdan u8 *aNew; 6745d607a6eSdan 6755d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 6765d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 6775d607a6eSdan if( pTab->abPK[i] || nOld!=nNew || memcmp(aOld, aNew, nNew) ){ 6785d607a6eSdan if( pTab->abPK[i]==0 ) bRequired = 1; 6795d607a6eSdan memcpy(aOut, aOld, nOld); 6805d607a6eSdan aOut += nOld; 6815d607a6eSdan }else{ 6825d607a6eSdan *(aOut++) = '\0'; 6835d607a6eSdan } 6845d607a6eSdan } 6855d607a6eSdan 6865d607a6eSdan if( !bRequired ) return 0; 68764277f4aSdan } 6885d607a6eSdan 6895d607a6eSdan /* Write the new.* vector */ 6905d607a6eSdan aOld1 = aOldRecord1; 6915d607a6eSdan aOld2 = aOldRecord2; 6925d607a6eSdan aNew1 = aNewRecord1; 6935d607a6eSdan aNew2 = aNewRecord2; 6945d607a6eSdan for(i=0; i<pTab->nCol; i++){ 6955d607a6eSdan int nOld; 6965d607a6eSdan u8 *aOld; 6975d607a6eSdan int nNew; 6985d607a6eSdan u8 *aNew; 6995d607a6eSdan 7005d607a6eSdan aOld = sessionMergeValue(&aOld1, &aOld2, &nOld); 7015d607a6eSdan aNew = sessionMergeValue(&aNew1, &aNew2, &nNew); 70264277f4aSdan if( bPatchset==0 70364277f4aSdan && (pTab->abPK[i] || (nOld==nNew && 0==memcmp(aOld, aNew, nNew))) 70464277f4aSdan ){ 7055d607a6eSdan *(aOut++) = '\0'; 7065d607a6eSdan }else{ 7075d607a6eSdan memcpy(aOut, aNew, nNew); 7085d607a6eSdan aOut += nNew; 7095d607a6eSdan } 7105d607a6eSdan } 7115d607a6eSdan 7125d607a6eSdan *paOut = aOut; 7135d607a6eSdan return 1; 7145d607a6eSdan } 7155d607a6eSdan 71677fc1d5bSdan /* 71777fc1d5bSdan ** This function is only called from within a pre-update-hook callback. 71877fc1d5bSdan ** It determines if the current pre-update-hook change affects the same row 71977fc1d5bSdan ** as the change stored in argument pChange. If so, it returns true. Otherwise 72077fc1d5bSdan ** if the pre-update-hook does not affect the same row as pChange, it returns 72177fc1d5bSdan ** false. 72277fc1d5bSdan */ 72377fc1d5bSdan static int sessionPreupdateEqual( 72477fc1d5bSdan sqlite3 *db, /* Database handle */ 72577fc1d5bSdan SessionTable *pTab, /* Table associated with change */ 72677fc1d5bSdan SessionChange *pChange, /* Change to compare to */ 72777fc1d5bSdan int op /* Current pre-update operation */ 728e8d5648eSdan ){ 72977fc1d5bSdan int iCol; /* Used to iterate through columns */ 73077fc1d5bSdan u8 *a = pChange->aRecord; /* Cursor used to scan change record */ 731e8d5648eSdan 73277fc1d5bSdan assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE ); 73377fc1d5bSdan for(iCol=0; iCol<pTab->nCol; iCol++){ 73477fc1d5bSdan if( !pTab->abPK[iCol] ){ 735798693b2Sdan a += sessionSerialLen(a); 736e8d5648eSdan }else{ 7376734007dSdan sqlite3_value *pVal; /* Value returned by preupdate_new/old */ 7386734007dSdan int rc; /* Error code from preupdate_new/old */ 739798693b2Sdan int eType = *a++; /* Type of value from change record */ 7406734007dSdan 7416734007dSdan /* The following calls to preupdate_new() and preupdate_old() can not 7426734007dSdan ** fail. This is because they cache their return values, and by the 7436734007dSdan ** time control flows to here they have already been called once from 7446734007dSdan ** within sessionPreupdateHash(). The first two asserts below verify 7456734007dSdan ** this (that the method has already been called). */ 74677fc1d5bSdan if( op==SQLITE_INSERT ){ 7476734007dSdan assert( db->pPreUpdate->pNewUnpacked || db->pPreUpdate->aNew ); 74877fc1d5bSdan rc = sqlite3_preupdate_new(db, iCol, &pVal); 749e8d5648eSdan }else{ 7506734007dSdan assert( db->pPreUpdate->pUnpacked ); 75177fc1d5bSdan rc = sqlite3_preupdate_old(db, iCol, &pVal); 752e8d5648eSdan } 7536734007dSdan assert( rc==SQLITE_OK ); 75477fc1d5bSdan if( sqlite3_value_type(pVal)!=eType ) return 0; 755e8d5648eSdan 75612ca0b56Sdan /* A SessionChange object never has a NULL value in a PK column */ 75712ca0b56Sdan assert( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT 75812ca0b56Sdan || eType==SQLITE_BLOB || eType==SQLITE_TEXT 75912ca0b56Sdan ); 76012ca0b56Sdan 76112ca0b56Sdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 762e8d5648eSdan i64 iVal = sessionGetI64(a); 763e8d5648eSdan a += 8; 764e8d5648eSdan if( eType==SQLITE_INTEGER ){ 76577fc1d5bSdan if( sqlite3_value_int64(pVal)!=iVal ) return 0; 766e8d5648eSdan }else{ 767e8d5648eSdan double rVal; 768e8d5648eSdan assert( sizeof(iVal)==8 && sizeof(rVal)==8 ); 769e8d5648eSdan memcpy(&rVal, &iVal, 8); 77077fc1d5bSdan if( sqlite3_value_double(pVal)!=rVal ) return 0; 771e8d5648eSdan } 77212ca0b56Sdan }else{ 773e8d5648eSdan int n; 774e8d5648eSdan const u8 *z; 775e8d5648eSdan a += sessionVarintGet(a, &n); 77677fc1d5bSdan if( sqlite3_value_bytes(pVal)!=n ) return 0; 77712ca0b56Sdan if( eType==SQLITE_TEXT ){ 77812ca0b56Sdan z = sqlite3_value_text(pVal); 77912ca0b56Sdan }else{ 78012ca0b56Sdan z = sqlite3_value_blob(pVal); 78112ca0b56Sdan } 78277fc1d5bSdan if( memcmp(a, z, n) ) return 0; 783e8d5648eSdan a += n; 784e8d5648eSdan break; 785e8d5648eSdan } 786e8d5648eSdan } 787e8d5648eSdan } 788e8d5648eSdan 78977fc1d5bSdan return 1; 7904fccf43aSdan } 7914fccf43aSdan 7924fccf43aSdan /* 7934fccf43aSdan ** If required, grow the hash table used to store changes on table pTab 7944fccf43aSdan ** (part of the session pSession). If a fatal OOM error occurs, set the 7954fccf43aSdan ** session object to failed and return SQLITE_ERROR. Otherwise, return 7964fccf43aSdan ** SQLITE_OK. 7974fccf43aSdan ** 7984fccf43aSdan ** It is possible that a non-fatal OOM error occurs in this function. In 7994fccf43aSdan ** that case the hash-table does not grow, but SQLITE_OK is returned anyway. 8004fccf43aSdan ** Growing the hash table in this case is a performance optimization only, 8014fccf43aSdan ** it is not required for correct operation. 8024fccf43aSdan */ 80364277f4aSdan static int sessionGrowHash(int bPatchset, SessionTable *pTab){ 8044fccf43aSdan if( pTab->nChange==0 || pTab->nEntry>=(pTab->nChange/2) ){ 8054fccf43aSdan int i; 8064fccf43aSdan SessionChange **apNew; 8074fccf43aSdan int nNew = (pTab->nChange ? pTab->nChange : 128) * 2; 8084fccf43aSdan 8094fccf43aSdan apNew = (SessionChange **)sqlite3_malloc(sizeof(SessionChange *) * nNew); 8104fccf43aSdan if( apNew==0 ){ 8114fccf43aSdan if( pTab->nChange==0 ){ 8124fccf43aSdan return SQLITE_ERROR; 8134fccf43aSdan } 8144fccf43aSdan return SQLITE_OK; 8154fccf43aSdan } 8164fccf43aSdan memset(apNew, 0, sizeof(SessionChange *) * nNew); 8174fccf43aSdan 8184fccf43aSdan for(i=0; i<pTab->nChange; i++){ 8194fccf43aSdan SessionChange *p; 8204fccf43aSdan SessionChange *pNext; 8214fccf43aSdan for(p=pTab->apChange[i]; p; p=pNext){ 82264277f4aSdan int bPkOnly = (p->op==SQLITE_DELETE && bPatchset); 82364277f4aSdan int iHash = sessionChangeHash(pTab, bPkOnly, p->aRecord, nNew); 8244fccf43aSdan pNext = p->pNext; 8254fccf43aSdan p->pNext = apNew[iHash]; 8264fccf43aSdan apNew[iHash] = p; 8274fccf43aSdan } 8284fccf43aSdan } 8294fccf43aSdan 8304fccf43aSdan sqlite3_free(pTab->apChange); 8314fccf43aSdan pTab->nChange = nNew; 8324fccf43aSdan pTab->apChange = apNew; 8334fccf43aSdan } 8344fccf43aSdan 8354fccf43aSdan return SQLITE_OK; 8364fccf43aSdan } 8374fccf43aSdan 838296c7658Sdan /* 839e8d5648eSdan ** This function queries the database for the names of the columns of table 840e8d5648eSdan ** zThis, in schema zDb. It is expected that the table has nCol columns. If 841e8d5648eSdan ** not, SQLITE_SCHEMA is returned and none of the output variables are 842e8d5648eSdan ** populated. 843e8d5648eSdan ** 84477fc1d5bSdan ** Otherwise, if they are not NULL, variable *pnCol is set to the number 84577fc1d5bSdan ** of columns in the database table and variable *pzTab is set to point to a 846e8d5648eSdan ** nul-terminated copy of the table name. *pazCol (if not NULL) is set to 847e8d5648eSdan ** point to an array of pointers to column names. And *pabPK (again, if not 848e8d5648eSdan ** NULL) is set to point to an array of booleans - true if the corresponding 849e8d5648eSdan ** column is part of the primary key. 850e8d5648eSdan ** 851e8d5648eSdan ** For example, if the table is declared as: 852e8d5648eSdan ** 853e8d5648eSdan ** CREATE TABLE tbl1(w, x, y, z, PRIMARY KEY(w, z)); 854e8d5648eSdan ** 85577fc1d5bSdan ** Then the four output variables are populated as follows: 856e8d5648eSdan ** 85777fc1d5bSdan ** *pnCol = 4 858e8d5648eSdan ** *pzTab = "tbl1" 859e8d5648eSdan ** *pazCol = {"w", "x", "y", "z"} 860e8d5648eSdan ** *pabPK = {1, 0, 0, 1} 861e8d5648eSdan ** 862e8d5648eSdan ** All returned buffers are part of the same single allocation, which must 863e8d5648eSdan ** be freed using sqlite3_free() by the caller. If pazCol was not NULL, then 864e8d5648eSdan ** pointer *pazCol should be freed to release all memory. Otherwise, pointer 865e8d5648eSdan ** *pabPK. It is illegal for both pazCol and pabPK to be NULL. 866e8d5648eSdan */ 867e8d5648eSdan static int sessionTableInfo( 868e8d5648eSdan sqlite3 *db, /* Database connection */ 869e8d5648eSdan const char *zDb, /* Name of attached database (e.g. "main") */ 870e8d5648eSdan const char *zThis, /* Table name */ 871ca62ad57Sdan int *pnCol, /* OUT: number of columns */ 872e8d5648eSdan const char **pzTab, /* OUT: Copy of zThis */ 873e8d5648eSdan const char ***pazCol, /* OUT: Array of column names for table */ 874e8d5648eSdan u8 **pabPK /* OUT: Array of booleans - true for PK col */ 875e8d5648eSdan ){ 876e8d5648eSdan char *zPragma; 877e8d5648eSdan sqlite3_stmt *pStmt; 878e8d5648eSdan int rc; 879e8d5648eSdan int nByte; 880e8d5648eSdan int nDbCol = 0; 881e8d5648eSdan int nThis; 882e8d5648eSdan int i; 883e8d5648eSdan u8 *pAlloc; 884db04571cSdan char **azCol = 0; 885e8d5648eSdan u8 *abPK; 886e8d5648eSdan 887db04571cSdan assert( pazCol && pabPK ); 888e8d5648eSdan 889cfdbde21Sdrh nThis = sqlite3Strlen30(zThis); 890e8d5648eSdan zPragma = sqlite3_mprintf("PRAGMA '%q'.table_info('%q')", zDb, zThis); 891e8d5648eSdan if( !zPragma ) return SQLITE_NOMEM; 892e8d5648eSdan 893e8d5648eSdan rc = sqlite3_prepare_v2(db, zPragma, -1, &pStmt, 0); 894e8d5648eSdan sqlite3_free(zPragma); 895e8d5648eSdan if( rc!=SQLITE_OK ) return rc; 896e8d5648eSdan 897e8d5648eSdan nByte = nThis + 1; 898e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 899e8d5648eSdan nByte += sqlite3_column_bytes(pStmt, 1); 900e8d5648eSdan nDbCol++; 901e8d5648eSdan } 902e8d5648eSdan rc = sqlite3_reset(pStmt); 903e8d5648eSdan 904e8d5648eSdan if( rc==SQLITE_OK ){ 905e8d5648eSdan nByte += nDbCol * (sizeof(const char *) + sizeof(u8) + 1); 906e8d5648eSdan pAlloc = sqlite3_malloc(nByte); 907e8d5648eSdan if( pAlloc==0 ){ 908e8d5648eSdan rc = SQLITE_NOMEM; 909e8d5648eSdan } 910e8d5648eSdan } 911e8d5648eSdan if( rc==SQLITE_OK ){ 912e8d5648eSdan azCol = (char **)pAlloc; 913ca62ad57Sdan pAlloc = (u8 *)&azCol[nDbCol]; 914e8d5648eSdan abPK = (u8 *)pAlloc; 915ca62ad57Sdan pAlloc = &abPK[nDbCol]; 916e8d5648eSdan if( pzTab ){ 917e8d5648eSdan memcpy(pAlloc, zThis, nThis+1); 918e8d5648eSdan *pzTab = (char *)pAlloc; 919e8d5648eSdan pAlloc += nThis+1; 920e8d5648eSdan } 921e8d5648eSdan 922e8d5648eSdan i = 0; 923e8d5648eSdan while( SQLITE_ROW==sqlite3_step(pStmt) ){ 924e8d5648eSdan int nName = sqlite3_column_bytes(pStmt, 1); 925e8d5648eSdan const unsigned char *zName = sqlite3_column_text(pStmt, 1); 926e8d5648eSdan if( zName==0 ) break; 927e8d5648eSdan memcpy(pAlloc, zName, nName+1); 928e8d5648eSdan azCol[i] = (char *)pAlloc; 929e8d5648eSdan pAlloc += nName+1; 930db04571cSdan abPK[i] = sqlite3_column_int(pStmt, 5); 931e8d5648eSdan i++; 932e8d5648eSdan } 933e8d5648eSdan rc = sqlite3_reset(pStmt); 934e8d5648eSdan 935e8d5648eSdan } 936e8d5648eSdan 937e8d5648eSdan /* If successful, populate the output variables. Otherwise, zero them and 938e8d5648eSdan ** free any allocation made. An error code will be returned in this case. 939e8d5648eSdan */ 940e8d5648eSdan if( rc==SQLITE_OK ){ 941db04571cSdan *pazCol = (const char **)azCol; 942db04571cSdan *pabPK = abPK; 943ca62ad57Sdan *pnCol = nDbCol; 944e8d5648eSdan }else{ 945db04571cSdan *pazCol = 0; 946db04571cSdan *pabPK = 0; 947ca62ad57Sdan *pnCol = 0; 948e8d5648eSdan if( pzTab ) *pzTab = 0; 949db04571cSdan sqlite3_free(azCol); 950e8d5648eSdan } 951e8d5648eSdan sqlite3_finalize(pStmt); 952e8d5648eSdan return rc; 953e8d5648eSdan } 954e8d5648eSdan 955e8d5648eSdan /* 956296c7658Sdan ** This function is only called from within a pre-update handler for a 957296c7658Sdan ** write to table pTab, part of session pSession. If this is the first 958296c7658Sdan ** write to this table, set the SessionTable.nCol variable to the number 959296c7658Sdan ** of columns in the table. 960296c7658Sdan ** 961296c7658Sdan ** Otherwise, if this is not the first time this table has been written 962296c7658Sdan ** to, check that the number of columns in the table has not changed. If 963296c7658Sdan ** it has not, return zero. 964296c7658Sdan ** 965296c7658Sdan ** If the number of columns in the table has changed since the last write 966296c7658Sdan ** was recorded, set the session error-code to SQLITE_SCHEMA and return 967296c7658Sdan ** non-zero. Users are not allowed to change the number of columns in a table 968296c7658Sdan ** for which changes are being recorded by the session module. If they do so, 969296c7658Sdan ** it is an error. 970296c7658Sdan */ 9714fccf43aSdan static int sessionInitTable(sqlite3_session *pSession, SessionTable *pTab){ 9724fccf43aSdan if( pTab->nCol==0 ){ 973e8d5648eSdan assert( pTab->azCol==0 || pTab->abPK==0 ); 974e8d5648eSdan pSession->rc = sessionTableInfo(pSession->db, pSession->zDb, 975ca62ad57Sdan pTab->zName, &pTab->nCol, 0, &pTab->azCol, &pTab->abPK 976e8d5648eSdan ); 977ca62ad57Sdan } 978ca62ad57Sdan if( pSession->rc==SQLITE_OK 979ca62ad57Sdan && pTab->nCol!=sqlite3_preupdate_count(pSession->db) 980ca62ad57Sdan ){ 9814fccf43aSdan pSession->rc = SQLITE_SCHEMA; 9824fccf43aSdan } 983e8d5648eSdan return pSession->rc; 984e8d5648eSdan } 985e8d5648eSdan 98677fc1d5bSdan /* 98777fc1d5bSdan ** This function is only called from with a pre-update-hook reporting a 98877fc1d5bSdan ** change on table pTab (attached to session pSession). The type of change 98977fc1d5bSdan ** (UPDATE, INSERT, DELETE) is specified by the first argument. 99077fc1d5bSdan ** 99177fc1d5bSdan ** Unless one is already present or an error occurs, an entry is added 99277fc1d5bSdan ** to the changed-rows hash table associated with table pTab. 99377fc1d5bSdan */ 994e8d5648eSdan static void sessionPreupdateOneChange( 99577fc1d5bSdan int op, /* One of SQLITE_UPDATE, INSERT, DELETE */ 99677fc1d5bSdan sqlite3_session *pSession, /* Session object pTab is attached to */ 99777fc1d5bSdan SessionTable *pTab /* Table that change applies to */ 998e8d5648eSdan ){ 999e8d5648eSdan sqlite3 *db = pSession->db; 1000e8d5648eSdan int iHash; 100127453faeSdan int bNullPk = 0; 1002e8d5648eSdan int rc = SQLITE_OK; 1003e8d5648eSdan 1004e8d5648eSdan if( pSession->rc ) return; 1005e8d5648eSdan 1006e8d5648eSdan /* Load table details if required */ 1007e8d5648eSdan if( sessionInitTable(pSession, pTab) ) return; 1008e8d5648eSdan 1009e8d5648eSdan /* Grow the hash table if required */ 101064277f4aSdan if( sessionGrowHash(0, pTab) ){ 10115d607a6eSdan pSession->rc = SQLITE_NOMEM; 10125d607a6eSdan return; 10135d607a6eSdan } 1014e8d5648eSdan 101580fe2d93Sdan /* Calculate the hash-key for this change. If the primary key of the row 101680fe2d93Sdan ** includes a NULL value, exit early. Such changes are ignored by the 101780fe2d93Sdan ** session module. */ 101827453faeSdan rc = sessionPreupdateHash(db, pTab, op==SQLITE_INSERT, &iHash, &bNullPk); 101980fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 102080fe2d93Sdan 102180fe2d93Sdan if( bNullPk==0 ){ 102280fe2d93Sdan /* Search the hash table for an existing record for this row. */ 1023b4480e94Sdan SessionChange *pC; 10246734007dSdan for(pC=pTab->apChange[iHash]; pC; pC=pC->pNext){ 102577fc1d5bSdan if( sessionPreupdateEqual(db, pTab, pC, op) ) break; 1026e8d5648eSdan } 102780fe2d93Sdan 1028e8d5648eSdan if( pC==0 ){ 1029e8d5648eSdan /* Create a new change object containing all the old values (if 1030e8d5648eSdan ** this is an SQLITE_UPDATE or SQLITE_DELETE), or just the PK 1031e8d5648eSdan ** values (if this is an INSERT). */ 1032b4480e94Sdan SessionChange *pChange; /* New change object */ 1033e8d5648eSdan int nByte; /* Number of bytes to allocate */ 1034e8d5648eSdan int i; /* Used to iterate through columns */ 1035e8d5648eSdan 1036b4480e94Sdan assert( rc==SQLITE_OK ); 1037e8d5648eSdan pTab->nEntry++; 1038e8d5648eSdan 1039e8d5648eSdan /* Figure out how large an allocation is required */ 1040e8d5648eSdan nByte = sizeof(SessionChange); 104180fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1042e8d5648eSdan sqlite3_value *p = 0; 1043e8d5648eSdan if( op!=SQLITE_INSERT ){ 104480fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_old(pSession->db, i, &p); 104580fe2d93Sdan assert( trc==SQLITE_OK ); 104680fe2d93Sdan }else if( pTab->abPK[i] ){ 104780fe2d93Sdan TESTONLY(int trc = ) sqlite3_preupdate_new(pSession->db, i, &p); 104880fe2d93Sdan assert( trc==SQLITE_OK ); 1049e8d5648eSdan } 105080fe2d93Sdan 105180fe2d93Sdan /* This may fail if SQLite value p contains a utf-16 string that must 105280fe2d93Sdan ** be converted to utf-8 and an OOM error occurs while doing so. */ 1053e8d5648eSdan rc = sessionSerializeValue(0, p, &nByte); 105480fe2d93Sdan if( rc!=SQLITE_OK ) goto error_out; 1055e8d5648eSdan } 1056e8d5648eSdan 1057e8d5648eSdan /* Allocate the change object */ 1058e8d5648eSdan pChange = (SessionChange *)sqlite3_malloc(nByte); 1059e8d5648eSdan if( !pChange ){ 1060e8d5648eSdan rc = SQLITE_NOMEM; 106180fe2d93Sdan goto error_out; 1062e8d5648eSdan }else{ 1063e8d5648eSdan memset(pChange, 0, sizeof(SessionChange)); 1064e8d5648eSdan pChange->aRecord = (u8 *)&pChange[1]; 1065e8d5648eSdan } 1066e8d5648eSdan 106780fe2d93Sdan /* Populate the change object. None of the preupdate_old(), 106880fe2d93Sdan ** preupdate_new() or SerializeValue() calls below may fail as all 106980fe2d93Sdan ** required values and encodings have already been cached in memory. 107080fe2d93Sdan ** It is not possible for an OOM to occur in this block. */ 1071e8d5648eSdan nByte = 0; 107280fe2d93Sdan for(i=0; i<pTab->nCol; i++){ 1073e8d5648eSdan sqlite3_value *p = 0; 1074e8d5648eSdan if( op!=SQLITE_INSERT ){ 107580fe2d93Sdan sqlite3_preupdate_old(pSession->db, i, &p); 107680fe2d93Sdan }else if( pTab->abPK[i] ){ 107780fe2d93Sdan sqlite3_preupdate_new(pSession->db, i, &p); 1078e8d5648eSdan } 107980fe2d93Sdan sessionSerializeValue(&pChange->aRecord[nByte], p, &nByte); 1080e8d5648eSdan } 108180fe2d93Sdan 108280fe2d93Sdan /* Add the change to the hash-table */ 1083b4480e94Sdan if( pSession->bIndirect || sqlite3_preupdate_depth(pSession->db) ){ 1084b4480e94Sdan pChange->bIndirect = 1; 1085b4480e94Sdan } 108612ca0b56Sdan pChange->nRecord = nByte; 1087798693b2Sdan pChange->op = op; 1088e8d5648eSdan pChange->pNext = pTab->apChange[iHash]; 1089e8d5648eSdan pTab->apChange[iHash] = pChange; 109080fe2d93Sdan 109180fe2d93Sdan }else if( pC->bIndirect ){ 1092b4480e94Sdan /* If the existing change is considered "indirect", but this current 1093b4480e94Sdan ** change is "direct", mark the change object as direct. */ 1094b4480e94Sdan if( sqlite3_preupdate_depth(pSession->db)==0 && pSession->bIndirect==0 ){ 1095b4480e94Sdan pC->bIndirect = 0; 1096b4480e94Sdan } 1097e8d5648eSdan } 10984fccf43aSdan } 109912ca0b56Sdan 110012ca0b56Sdan /* If an error has occurred, mark the session object as failed. */ 110180fe2d93Sdan error_out: 110212ca0b56Sdan if( rc!=SQLITE_OK ){ 110312ca0b56Sdan pSession->rc = rc; 110412ca0b56Sdan } 110527453faeSdan } 11064fccf43aSdan 11074fccf43aSdan /* 11084fccf43aSdan ** The 'pre-update' hook registered by this module with SQLite databases. 11094fccf43aSdan */ 11104fccf43aSdan static void xPreUpdate( 11114fccf43aSdan void *pCtx, /* Copy of third arg to preupdate_hook() */ 11124fccf43aSdan sqlite3 *db, /* Database handle */ 11134fccf43aSdan int op, /* SQLITE_UPDATE, DELETE or INSERT */ 11144fccf43aSdan char const *zDb, /* Database name */ 11154fccf43aSdan char const *zName, /* Table name */ 11164fccf43aSdan sqlite3_int64 iKey1, /* Rowid of row about to be deleted/updated */ 11174fccf43aSdan sqlite3_int64 iKey2 /* New rowid value (for a rowid UPDATE) */ 11184fccf43aSdan ){ 11194fccf43aSdan sqlite3_session *pSession; 1120cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); 1121cfdbde21Sdrh int nName = sqlite3Strlen30(zName); 11224fccf43aSdan 11234c220252Sdan assert( sqlite3_mutex_held(db->mutex) ); 11244c220252Sdan 11254fccf43aSdan for(pSession=(sqlite3_session *)pCtx; pSession; pSession=pSession->pNext){ 11264fccf43aSdan SessionTable *pTab; 1127296c7658Sdan 1128e8d5648eSdan /* If this session is attached to a different database ("main", "temp" 1129e8d5648eSdan ** etc.), or if it is not currently enabled, there is nothing to do. Skip 1130e8d5648eSdan ** to the next session object attached to this database. */ 1131296c7658Sdan if( pSession->bEnable==0 ) continue; 11324fccf43aSdan if( pSession->rc ) continue; 11334fccf43aSdan if( sqlite3_strnicmp(zDb, pSession->zDb, nDb+1) ) continue; 1134296c7658Sdan 1135ff4d0f41Sdan for(pTab=pSession->pTable; pTab || pSession->bAutoAttach; pTab=pTab->pNext){ 1136ff4d0f41Sdan if( !pTab ){ 1137ff4d0f41Sdan /* This branch is taken if table zName has not yet been attached to 1138ff4d0f41Sdan ** this session and the auto-attach flag is set. */ 11397531a5a3Sdan 11407531a5a3Sdan /* If there is a table-filter configured, invoke it. If it returns 0, 11417531a5a3Sdan ** this change will not be recorded. Break out of the loop early in 11427531a5a3Sdan ** this case. */ 11437531a5a3Sdan if( pSession->xTableFilter 11447531a5a3Sdan && pSession->xTableFilter(pSession->pFilterCtx, zName)==0 11457531a5a3Sdan ){ 11467531a5a3Sdan break; 11477531a5a3Sdan } 11487531a5a3Sdan 1149ff4d0f41Sdan pSession->rc = sqlite3session_attach(pSession,zName); 1150245b49b2Sdan if( pSession->rc ) break; 1151ff4d0f41Sdan pTab = pSession->pTable; 1152ff4d0f41Sdan assert( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ); 1153ff4d0f41Sdan } 1154ff4d0f41Sdan 11554fccf43aSdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ){ 1156e8d5648eSdan sessionPreupdateOneChange(op, pSession, pTab); 1157e8d5648eSdan if( op==SQLITE_UPDATE ){ 1158e8d5648eSdan sessionPreupdateOneChange(SQLITE_INSERT, pSession, pTab); 11594fccf43aSdan } 11604fccf43aSdan break; 11614fccf43aSdan } 11624fccf43aSdan } 11634fccf43aSdan } 1164296c7658Sdan } 11654fccf43aSdan 11664fccf43aSdan /* 11674fccf43aSdan ** Create a session object. This session object will record changes to 11684fccf43aSdan ** database zDb attached to connection db. 11694fccf43aSdan */ 11704fccf43aSdan int sqlite3session_create( 11714fccf43aSdan sqlite3 *db, /* Database handle */ 11724fccf43aSdan const char *zDb, /* Name of db (e.g. "main") */ 11734fccf43aSdan sqlite3_session **ppSession /* OUT: New session object */ 11744fccf43aSdan ){ 1175296c7658Sdan sqlite3_session *pNew; /* Newly allocated session object */ 1176296c7658Sdan sqlite3_session *pOld; /* Session object already attached to db */ 1177cfdbde21Sdrh int nDb = sqlite3Strlen30(zDb); /* Length of zDb in bytes */ 11784fccf43aSdan 1179296c7658Sdan /* Zero the output value in case an error occurs. */ 11804fccf43aSdan *ppSession = 0; 11814fccf43aSdan 11824fccf43aSdan /* Allocate and populate the new session object. */ 11834fccf43aSdan pNew = (sqlite3_session *)sqlite3_malloc(sizeof(sqlite3_session) + nDb + 1); 11844fccf43aSdan if( !pNew ) return SQLITE_NOMEM; 11854fccf43aSdan memset(pNew, 0, sizeof(sqlite3_session)); 11864fccf43aSdan pNew->db = db; 11874fccf43aSdan pNew->zDb = (char *)&pNew[1]; 1188296c7658Sdan pNew->bEnable = 1; 11894fccf43aSdan memcpy(pNew->zDb, zDb, nDb+1); 11904fccf43aSdan 11914fccf43aSdan /* Add the new session object to the linked list of session objects 11924fccf43aSdan ** attached to database handle $db. Do this under the cover of the db 11934fccf43aSdan ** handle mutex. */ 11944fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 11954fccf43aSdan pOld = (sqlite3_session*)sqlite3_preupdate_hook(db, xPreUpdate, (void*)pNew); 11964fccf43aSdan pNew->pNext = pOld; 11974fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 11984fccf43aSdan 11994fccf43aSdan *ppSession = pNew; 12004fccf43aSdan return SQLITE_OK; 12014fccf43aSdan } 12024fccf43aSdan 120377fc1d5bSdan /* 120477fc1d5bSdan ** Free the list of table objects passed as the first argument. The contents 120577fc1d5bSdan ** of the changed-rows hash tables are also deleted. 120677fc1d5bSdan */ 12071ffe7c7fSdrh static void sessionDeleteTable(SessionTable *pList){ 12085d607a6eSdan SessionTable *pNext; 12095d607a6eSdan SessionTable *pTab; 12105d607a6eSdan 12115d607a6eSdan for(pTab=pList; pTab; pTab=pNext){ 12125d607a6eSdan int i; 12135d607a6eSdan pNext = pTab->pNext; 12145d607a6eSdan for(i=0; i<pTab->nChange; i++){ 12155d607a6eSdan SessionChange *p; 12165d607a6eSdan SessionChange *pNext; 12175d607a6eSdan for(p=pTab->apChange[i]; p; p=pNext){ 12185d607a6eSdan pNext = p->pNext; 12195d607a6eSdan sqlite3_free(p); 12205d607a6eSdan } 12215d607a6eSdan } 12225d607a6eSdan sqlite3_free((char*)pTab->azCol); /* cast works around VC++ bug */ 12235d607a6eSdan sqlite3_free(pTab->apChange); 12245d607a6eSdan sqlite3_free(pTab); 12255d607a6eSdan } 12265d607a6eSdan } 12275d607a6eSdan 12284fccf43aSdan /* 12294fccf43aSdan ** Delete a session object previously allocated using sqlite3session_create(). 12304fccf43aSdan */ 12314fccf43aSdan void sqlite3session_delete(sqlite3_session *pSession){ 12324fccf43aSdan sqlite3 *db = pSession->db; 12334fccf43aSdan sqlite3_session *pHead; 12344fccf43aSdan sqlite3_session **pp; 12354fccf43aSdan 1236296c7658Sdan /* Unlink the session from the linked list of sessions attached to the 1237296c7658Sdan ** database handle. Hold the db mutex while doing so. */ 12384fccf43aSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 12394fccf43aSdan pHead = (sqlite3_session*)sqlite3_preupdate_hook(db, 0, 0); 12404fccf43aSdan for(pp=&pHead; (*pp)!=pSession; pp=&((*pp)->pNext)); 12414fccf43aSdan *pp = (*pp)->pNext; 12424fccf43aSdan if( pHead ) sqlite3_preupdate_hook(db, xPreUpdate, (void *)pHead); 12434fccf43aSdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 12444fccf43aSdan 1245296c7658Sdan /* Delete all attached table objects. And the contents of their 1246296c7658Sdan ** associated hash-tables. */ 12475d607a6eSdan sessionDeleteTable(pSession->pTable); 12484fccf43aSdan 1249296c7658Sdan /* Free the session object itself. */ 12504fccf43aSdan sqlite3_free(pSession); 12514fccf43aSdan } 12524fccf43aSdan 12534fccf43aSdan /* 12547531a5a3Sdan ** Set a table filter on a Session Object. 12557531a5a3Sdan */ 12567531a5a3Sdan void sqlite3session_table_filter( 12577531a5a3Sdan sqlite3_session *pSession, 12587531a5a3Sdan int(*xFilter)(void*, const char*), 12597531a5a3Sdan void *pCtx /* First argument passed to xFilter */ 12607531a5a3Sdan ){ 12617531a5a3Sdan pSession->bAutoAttach = 1; 12627531a5a3Sdan pSession->pFilterCtx = pCtx; 12637531a5a3Sdan pSession->xTableFilter = xFilter; 12647531a5a3Sdan } 12657531a5a3Sdan 12667531a5a3Sdan /* 12674fccf43aSdan ** Attach a table to a session. All subsequent changes made to the table 12684fccf43aSdan ** while the session object is enabled will be recorded. 12694fccf43aSdan ** 12704fccf43aSdan ** Only tables that have a PRIMARY KEY defined may be attached. It does 12714fccf43aSdan ** not matter if the PRIMARY KEY is an "INTEGER PRIMARY KEY" (rowid alias) 12724fccf43aSdan ** or not. 12734fccf43aSdan */ 12744fccf43aSdan int sqlite3session_attach( 12754fccf43aSdan sqlite3_session *pSession, /* Session object */ 12764fccf43aSdan const char *zName /* Table name */ 12774fccf43aSdan ){ 1278ff4d0f41Sdan int rc = SQLITE_OK; 1279ff4d0f41Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 1280ff4d0f41Sdan 1281ff4d0f41Sdan if( !zName ){ 1282ff4d0f41Sdan pSession->bAutoAttach = 1; 1283ff4d0f41Sdan }else{ 1284296c7658Sdan SessionTable *pTab; /* New table object (if required) */ 1285296c7658Sdan int nName; /* Number of bytes in string zName */ 12864fccf43aSdan 12874fccf43aSdan /* First search for an existing entry. If one is found, this call is 12884fccf43aSdan ** a no-op. Return early. */ 1289cfdbde21Sdrh nName = sqlite3Strlen30(zName); 12904fccf43aSdan for(pTab=pSession->pTable; pTab; pTab=pTab->pNext){ 12914c220252Sdan if( 0==sqlite3_strnicmp(pTab->zName, zName, nName+1) ) break; 12924fccf43aSdan } 12934fccf43aSdan 12944c220252Sdan if( !pTab ){ 12954fccf43aSdan /* Allocate new SessionTable object. */ 12964fccf43aSdan pTab = (SessionTable *)sqlite3_malloc(sizeof(SessionTable) + nName + 1); 12974c220252Sdan if( !pTab ){ 12984c220252Sdan rc = SQLITE_NOMEM; 12994c220252Sdan }else{ 13004fccf43aSdan /* Populate the new SessionTable object and link it into the list. */ 13014fccf43aSdan memset(pTab, 0, sizeof(SessionTable)); 13024fccf43aSdan pTab->zName = (char *)&pTab[1]; 13034fccf43aSdan memcpy(pTab->zName, zName, nName+1); 13044fccf43aSdan pTab->pNext = pSession->pTable; 13054fccf43aSdan pSession->pTable = pTab; 13064c220252Sdan } 13074c220252Sdan } 1308ff4d0f41Sdan } 13094fccf43aSdan 13104c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 13114c220252Sdan return rc; 13124fccf43aSdan } 13134fccf43aSdan 1314296c7658Sdan /* 1315296c7658Sdan ** Ensure that there is room in the buffer to append nByte bytes of data. 1316296c7658Sdan ** If not, use sqlite3_realloc() to grow the buffer so that there is. 1317296c7658Sdan ** 1318296c7658Sdan ** If successful, return zero. Otherwise, if an OOM condition is encountered, 1319296c7658Sdan ** set *pRc to SQLITE_NOMEM and return non-zero. 1320296c7658Sdan */ 13214fccf43aSdan static int sessionBufferGrow(SessionBuffer *p, int nByte, int *pRc){ 132280fe2d93Sdan if( *pRc==SQLITE_OK && p->nAlloc-p->nBuf<nByte ){ 13234fccf43aSdan u8 *aNew; 13244fccf43aSdan int nNew = p->nAlloc ? p->nAlloc : 128; 13254fccf43aSdan do { 13264fccf43aSdan nNew = nNew*2; 1327ef7a6304Sdan }while( nNew<(p->nBuf+nByte) ); 13284fccf43aSdan 13294fccf43aSdan aNew = (u8 *)sqlite3_realloc(p->aBuf, nNew); 13304fccf43aSdan if( 0==aNew ){ 13314fccf43aSdan *pRc = SQLITE_NOMEM; 133280fe2d93Sdan }else{ 13334fccf43aSdan p->aBuf = aNew; 13344fccf43aSdan p->nAlloc = nNew; 13354fccf43aSdan } 133680fe2d93Sdan } 133780fe2d93Sdan return (*pRc!=SQLITE_OK); 13384fccf43aSdan } 13394fccf43aSdan 1340296c7658Sdan /* 1341fa122adaSdan ** Append the value passed as the second argument to the buffer passed 1342fa122adaSdan ** as the first. 1343fa122adaSdan ** 1344fa122adaSdan ** This function is a no-op if *pRc is non-zero when it is called. 1345fa122adaSdan ** Otherwise, if an error occurs, *pRc is set to an SQLite error code 1346fa122adaSdan ** before returning. 1347fa122adaSdan */ 1348fa122adaSdan static void sessionAppendValue(SessionBuffer *p, sqlite3_value *pVal, int *pRc){ 1349fa122adaSdan int rc = *pRc; 1350fa122adaSdan if( rc==SQLITE_OK ){ 1351fa122adaSdan int nByte = 0; 1352e8fa8c96Sdan rc = sessionSerializeValue(0, pVal, &nByte); 1353fa122adaSdan sessionBufferGrow(p, nByte, &rc); 1354fa122adaSdan if( rc==SQLITE_OK ){ 1355fa122adaSdan rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); 1356fa122adaSdan p->nBuf += nByte; 1357fa122adaSdan }else{ 1358fa122adaSdan *pRc = rc; 1359fa122adaSdan } 1360fa122adaSdan } 1361fa122adaSdan } 1362fa122adaSdan 1363fa122adaSdan /* 1364296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1365296c7658Sdan ** called. Otherwise, append a single byte to the buffer. 1366296c7658Sdan ** 1367296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1368296c7658Sdan ** returning. 1369296c7658Sdan */ 13704fccf43aSdan static void sessionAppendByte(SessionBuffer *p, u8 v, int *pRc){ 137180fe2d93Sdan if( 0==sessionBufferGrow(p, 1, pRc) ){ 13724fccf43aSdan p->aBuf[p->nBuf++] = v; 13734fccf43aSdan } 13744fccf43aSdan } 13754fccf43aSdan 1376296c7658Sdan /* 1377296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1378296c7658Sdan ** called. Otherwise, append a single varint to the buffer. 1379296c7658Sdan ** 1380296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1381296c7658Sdan ** returning. 1382296c7658Sdan */ 1383cfdbde21Sdrh static void sessionAppendVarint(SessionBuffer *p, int v, int *pRc){ 138480fe2d93Sdan if( 0==sessionBufferGrow(p, 9, pRc) ){ 13854fccf43aSdan p->nBuf += sessionVarintPut(&p->aBuf[p->nBuf], v); 13864fccf43aSdan } 13874fccf43aSdan } 13884fccf43aSdan 1389296c7658Sdan /* 1390296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1391296c7658Sdan ** called. Otherwise, append a blob of data to the buffer. 1392296c7658Sdan ** 1393296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1394296c7658Sdan ** returning. 1395296c7658Sdan */ 13964fccf43aSdan static void sessionAppendBlob( 13974fccf43aSdan SessionBuffer *p, 13984fccf43aSdan const u8 *aBlob, 13994fccf43aSdan int nBlob, 14004fccf43aSdan int *pRc 14014fccf43aSdan ){ 140280fe2d93Sdan if( 0==sessionBufferGrow(p, nBlob, pRc) ){ 14034fccf43aSdan memcpy(&p->aBuf[p->nBuf], aBlob, nBlob); 14044fccf43aSdan p->nBuf += nBlob; 14054fccf43aSdan } 14064fccf43aSdan } 14074fccf43aSdan 1408296c7658Sdan /* 1409296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1410296c7658Sdan ** called. Otherwise, append a string to the buffer. All bytes in the string 1411296c7658Sdan ** up to (but not including) the nul-terminator are written to the buffer. 1412296c7658Sdan ** 1413296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1414296c7658Sdan ** returning. 1415296c7658Sdan */ 1416d5f0767cSdan static void sessionAppendStr( 1417d5f0767cSdan SessionBuffer *p, 1418d5f0767cSdan const char *zStr, 1419d5f0767cSdan int *pRc 1420d5f0767cSdan ){ 1421cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr); 142280fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1423d5f0767cSdan memcpy(&p->aBuf[p->nBuf], zStr, nStr); 1424d5f0767cSdan p->nBuf += nStr; 1425d5f0767cSdan } 1426d5f0767cSdan } 1427d5f0767cSdan 1428296c7658Sdan /* 1429296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1430296c7658Sdan ** called. Otherwise, append the string representation of integer iVal 1431296c7658Sdan ** to the buffer. No nul-terminator is written. 1432296c7658Sdan ** 1433296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1434296c7658Sdan ** returning. 1435296c7658Sdan */ 1436d5f0767cSdan static void sessionAppendInteger( 1437296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1438296c7658Sdan int iVal, /* Value to write the string rep. of */ 1439296c7658Sdan int *pRc /* IN/OUT: Error code */ 1440d5f0767cSdan ){ 1441d5f0767cSdan char aBuf[24]; 1442d5f0767cSdan sqlite3_snprintf(sizeof(aBuf)-1, aBuf, "%d", iVal); 1443d5f0767cSdan sessionAppendStr(p, aBuf, pRc); 1444d5f0767cSdan } 1445d5f0767cSdan 1446296c7658Sdan /* 1447296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1448296c7658Sdan ** called. Otherwise, append the string zStr enclosed in quotes (") and 1449296c7658Sdan ** with any embedded quote characters escaped to the buffer. No 1450296c7658Sdan ** nul-terminator byte is written. 1451296c7658Sdan ** 1452296c7658Sdan ** If an OOM condition is encountered, set *pRc to SQLITE_NOMEM before 1453296c7658Sdan ** returning. 1454296c7658Sdan */ 1455d5f0767cSdan static void sessionAppendIdent( 1456296c7658Sdan SessionBuffer *p, /* Buffer to a append to */ 1457296c7658Sdan const char *zStr, /* String to quote, escape and append */ 1458296c7658Sdan int *pRc /* IN/OUT: Error code */ 1459d5f0767cSdan ){ 1460cfdbde21Sdrh int nStr = sqlite3Strlen30(zStr)*2 + 2 + 1; 146180fe2d93Sdan if( 0==sessionBufferGrow(p, nStr, pRc) ){ 1462d5f0767cSdan char *zOut = (char *)&p->aBuf[p->nBuf]; 1463d5f0767cSdan const char *zIn = zStr; 1464d5f0767cSdan *zOut++ = '"'; 1465d5f0767cSdan while( *zIn ){ 1466d5f0767cSdan if( *zIn=='"' ) *zOut++ = '"'; 1467d5f0767cSdan *zOut++ = *(zIn++); 1468d5f0767cSdan } 1469d5f0767cSdan *zOut++ = '"'; 1470cfdbde21Sdrh p->nBuf = (int)((u8 *)zOut - p->aBuf); 1471d5f0767cSdan } 1472d5f0767cSdan } 1473d5f0767cSdan 1474296c7658Sdan /* 1475296c7658Sdan ** This function is a no-op if *pRc is other than SQLITE_OK when it is 1476296c7658Sdan ** called. Otherwse, it appends the serialized version of the value stored 1477296c7658Sdan ** in column iCol of the row that SQL statement pStmt currently points 1478296c7658Sdan ** to to the buffer. 1479296c7658Sdan */ 14804fccf43aSdan static void sessionAppendCol( 1481296c7658Sdan SessionBuffer *p, /* Buffer to append to */ 1482296c7658Sdan sqlite3_stmt *pStmt, /* Handle pointing to row containing value */ 1483296c7658Sdan int iCol, /* Column to read value from */ 1484296c7658Sdan int *pRc /* IN/OUT: Error code */ 14854fccf43aSdan ){ 14864fccf43aSdan if( *pRc==SQLITE_OK ){ 14874fccf43aSdan int eType = sqlite3_column_type(pStmt, iCol); 14884fccf43aSdan sessionAppendByte(p, (u8)eType, pRc); 14894fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 14904fccf43aSdan sqlite3_int64 i; 14914fccf43aSdan u8 aBuf[8]; 14924fccf43aSdan if( eType==SQLITE_INTEGER ){ 14934fccf43aSdan i = sqlite3_column_int64(pStmt, iCol); 14944fccf43aSdan }else{ 14954fccf43aSdan double r = sqlite3_column_double(pStmt, iCol); 14964fccf43aSdan memcpy(&i, &r, 8); 14974fccf43aSdan } 1498296c7658Sdan sessionPutI64(aBuf, i); 14994fccf43aSdan sessionAppendBlob(p, aBuf, 8, pRc); 15004fccf43aSdan } 15014fccf43aSdan if( eType==SQLITE_BLOB || eType==SQLITE_TEXT ){ 15026734007dSdan u8 *z; 15036734007dSdan if( eType==SQLITE_BLOB ){ 15046734007dSdan z = (u8 *)sqlite3_column_blob(pStmt, iCol); 15056734007dSdan }else{ 15066734007dSdan z = (u8 *)sqlite3_column_text(pStmt, iCol); 15076734007dSdan } 15086734007dSdan if( z ){ 15094fccf43aSdan int nByte = sqlite3_column_bytes(pStmt, iCol); 15104fccf43aSdan sessionAppendVarint(p, nByte, pRc); 15116734007dSdan sessionAppendBlob(p, z, nByte, pRc); 15126734007dSdan }else{ 15136734007dSdan *pRc = SQLITE_NOMEM; 15146734007dSdan } 15154fccf43aSdan } 15164fccf43aSdan } 15174fccf43aSdan } 15184fccf43aSdan 1519296c7658Sdan /* 1520296c7658Sdan ** 152180fe2d93Sdan ** This function appends an update change to the buffer (see the comments 152280fe2d93Sdan ** under "CHANGESET FORMAT" at the top of the file). An update change 152380fe2d93Sdan ** consists of: 1524296c7658Sdan ** 1525296c7658Sdan ** 1 byte: SQLITE_UPDATE (0x17) 1526296c7658Sdan ** n bytes: old.* record (see RECORD FORMAT) 1527296c7658Sdan ** m bytes: new.* record (see RECORD FORMAT) 1528296c7658Sdan ** 1529296c7658Sdan ** The SessionChange object passed as the third argument contains the 1530296c7658Sdan ** values that were stored in the row when the session began (the old.* 1531296c7658Sdan ** values). The statement handle passed as the second argument points 1532296c7658Sdan ** at the current version of the row (the new.* values). 1533296c7658Sdan ** 1534296c7658Sdan ** If all of the old.* values are equal to their corresponding new.* value 1535296c7658Sdan ** (i.e. nothing has changed), then no data at all is appended to the buffer. 1536296c7658Sdan ** 1537296c7658Sdan ** Otherwise, the old.* record contains all primary key values and the 1538296c7658Sdan ** original values of any fields that have been modified. The new.* record 1539296c7658Sdan ** contains the new values of only those fields that have been modified. 1540296c7658Sdan */ 154180fe2d93Sdan static int sessionAppendUpdate( 1542296c7658Sdan SessionBuffer *pBuf, /* Buffer to append to */ 154373b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 1544296c7658Sdan sqlite3_stmt *pStmt, /* Statement handle pointing at new row */ 1545296c7658Sdan SessionChange *p, /* Object containing old values */ 154680fe2d93Sdan u8 *abPK /* Boolean array - true for PK columns */ 15474fccf43aSdan ){ 154880fe2d93Sdan int rc = SQLITE_OK; 1549296c7658Sdan SessionBuffer buf2 = {0,0,0}; /* Buffer to accumulate new.* record in */ 1550296c7658Sdan int bNoop = 1; /* Set to zero if any values are modified */ 15511f34f8ccSdan int nRewind = pBuf->nBuf; /* Set to zero if any values are modified */ 1552296c7658Sdan int i; /* Used to iterate through columns */ 1553296c7658Sdan u8 *pCsr = p->aRecord; /* Used to iterate through old.* values */ 1554296c7658Sdan 155580fe2d93Sdan sessionAppendByte(pBuf, SQLITE_UPDATE, &rc); 155680fe2d93Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 15574fccf43aSdan for(i=0; i<sqlite3_column_count(pStmt); i++){ 155837f133ecSdan int bChanged = 0; 15594fccf43aSdan int nAdvance; 15604fccf43aSdan int eType = *pCsr; 15614fccf43aSdan switch( eType ){ 15624fccf43aSdan case SQLITE_NULL: 15634fccf43aSdan nAdvance = 1; 15644fccf43aSdan if( sqlite3_column_type(pStmt, i)!=SQLITE_NULL ){ 156537f133ecSdan bChanged = 1; 15664fccf43aSdan } 15674fccf43aSdan break; 15684fccf43aSdan 15694fccf43aSdan case SQLITE_FLOAT: 15704fccf43aSdan case SQLITE_INTEGER: { 15714fccf43aSdan nAdvance = 9; 15724fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) ){ 15734fccf43aSdan sqlite3_int64 iVal = sessionGetI64(&pCsr[1]); 15744fccf43aSdan if( eType==SQLITE_INTEGER ){ 15754fccf43aSdan if( iVal==sqlite3_column_int64(pStmt, i) ) break; 15764fccf43aSdan }else{ 15774fccf43aSdan double dVal; 15784fccf43aSdan memcpy(&dVal, &iVal, 8); 15794fccf43aSdan if( dVal==sqlite3_column_double(pStmt, i) ) break; 15804fccf43aSdan } 15814fccf43aSdan } 158237f133ecSdan bChanged = 1; 15834fccf43aSdan break; 15844fccf43aSdan } 15854fccf43aSdan 1586e5754eecSdan default: { 15874fccf43aSdan int nByte; 15884fccf43aSdan int nHdr = 1 + sessionVarintGet(&pCsr[1], &nByte); 1589e5754eecSdan assert( eType==SQLITE_TEXT || eType==SQLITE_BLOB ); 15904fccf43aSdan nAdvance = nHdr + nByte; 15914fccf43aSdan if( eType==sqlite3_column_type(pStmt, i) 15924fccf43aSdan && nByte==sqlite3_column_bytes(pStmt, i) 15934fccf43aSdan && 0==memcmp(&pCsr[nHdr], sqlite3_column_blob(pStmt, i), nByte) 15944fccf43aSdan ){ 15954fccf43aSdan break; 15964fccf43aSdan } 159737f133ecSdan bChanged = 1; 15984fccf43aSdan } 15994fccf43aSdan } 16004fccf43aSdan 160173b3c055Sdan /* If at least one field has been modified, this is not a no-op. */ 160273b3c055Sdan if( bChanged ) bNoop = 0; 160373b3c055Sdan 160473b3c055Sdan /* Add a field to the old.* record. This is omitted if this modules is 160573b3c055Sdan ** currently generating a patchset. */ 160673b3c055Sdan if( bPatchset==0 ){ 160737f133ecSdan if( bChanged || abPK[i] ){ 160880fe2d93Sdan sessionAppendBlob(pBuf, pCsr, nAdvance, &rc); 16094fccf43aSdan }else{ 161080fe2d93Sdan sessionAppendByte(pBuf, 0, &rc); 161137f133ecSdan } 161273b3c055Sdan } 161337f133ecSdan 161473b3c055Sdan /* Add a field to the new.* record. Or the only record if currently 161573b3c055Sdan ** generating a patchset. */ 161673b3c055Sdan if( bChanged || (bPatchset && abPK[i]) ){ 161780fe2d93Sdan sessionAppendCol(&buf2, pStmt, i, &rc); 161837f133ecSdan }else{ 161980fe2d93Sdan sessionAppendByte(&buf2, 0, &rc); 16204fccf43aSdan } 162137f133ecSdan 16224fccf43aSdan pCsr += nAdvance; 16234fccf43aSdan } 16244fccf43aSdan 16254fccf43aSdan if( bNoop ){ 16261f34f8ccSdan pBuf->nBuf = nRewind; 16274fccf43aSdan }else{ 162880fe2d93Sdan sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); 16294fccf43aSdan } 16301f34f8ccSdan sqlite3_free(buf2.aBuf); 163180fe2d93Sdan 163280fe2d93Sdan return rc; 1633d5f0767cSdan } 16344fccf43aSdan 1635a71d2371Sdan /* 1636a71d2371Sdan ** Append a DELETE change to the buffer passed as the first argument. Use 1637a71d2371Sdan ** the changeset format if argument bPatchset is zero, or the patchset 1638a71d2371Sdan ** format otherwise. 1639a71d2371Sdan */ 164073b3c055Sdan static int sessionAppendDelete( 164173b3c055Sdan SessionBuffer *pBuf, /* Buffer to append to */ 164273b3c055Sdan int bPatchset, /* True for "patchset", 0 for "changeset" */ 164373b3c055Sdan SessionChange *p, /* Object containing old values */ 1644a71d2371Sdan int nCol, /* Number of columns in table */ 164573b3c055Sdan u8 *abPK /* Boolean array - true for PK columns */ 164673b3c055Sdan ){ 164773b3c055Sdan int rc = SQLITE_OK; 164873b3c055Sdan 164973b3c055Sdan sessionAppendByte(pBuf, SQLITE_DELETE, &rc); 165073b3c055Sdan sessionAppendByte(pBuf, p->bIndirect, &rc); 165173b3c055Sdan 165273b3c055Sdan if( bPatchset==0 ){ 165373b3c055Sdan sessionAppendBlob(pBuf, p->aRecord, p->nRecord, &rc); 165473b3c055Sdan }else{ 165573b3c055Sdan int i; 165673b3c055Sdan u8 *a = p->aRecord; 165773b3c055Sdan for(i=0; i<nCol; i++){ 165873b3c055Sdan u8 *pStart = a; 165973b3c055Sdan int eType = *a++; 166073b3c055Sdan 166173b3c055Sdan switch( eType ){ 166273b3c055Sdan case 0: 166373b3c055Sdan case SQLITE_NULL: 166473b3c055Sdan assert( abPK[i]==0 ); 166573b3c055Sdan break; 166673b3c055Sdan 166773b3c055Sdan case SQLITE_FLOAT: 166873b3c055Sdan case SQLITE_INTEGER: 166973b3c055Sdan a += 8; 167073b3c055Sdan break; 167173b3c055Sdan 167273b3c055Sdan default: { 167373b3c055Sdan int n; 167473b3c055Sdan a += sessionVarintGet(a, &n); 167573b3c055Sdan a += n; 167673b3c055Sdan break; 167773b3c055Sdan } 167873b3c055Sdan } 167973b3c055Sdan if( abPK[i] ){ 1680f5ab08c7Sdrh sessionAppendBlob(pBuf, pStart, (int)(a-pStart), &rc); 168173b3c055Sdan } 168273b3c055Sdan } 168373b3c055Sdan assert( (a - p->aRecord)==p->nRecord ); 168473b3c055Sdan } 168573b3c055Sdan 168673b3c055Sdan return rc; 168773b3c055Sdan } 168873b3c055Sdan 168977fc1d5bSdan /* 169077fc1d5bSdan ** Formulate and prepare a SELECT statement to retrieve a row from table 169177fc1d5bSdan ** zTab in database zDb based on its primary key. i.e. 169277fc1d5bSdan ** 169377fc1d5bSdan ** SELECT * FROM zDb.zTab WHERE pk1 = ? AND pk2 = ? AND ... 169477fc1d5bSdan */ 1695e8d5648eSdan static int sessionSelectStmt( 1696e8d5648eSdan sqlite3 *db, /* Database handle */ 1697d7fb7d24Sdan const char *zDb, /* Database name */ 1698e8d5648eSdan const char *zTab, /* Table name */ 169977fc1d5bSdan int nCol, /* Number of columns in table */ 170077fc1d5bSdan const char **azCol, /* Names of table columns */ 170177fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 170277fc1d5bSdan sqlite3_stmt **ppStmt /* OUT: Prepared SELECT statement */ 1703d5f0767cSdan ){ 1704e8d5648eSdan int rc = SQLITE_OK; 1705d5f0767cSdan int i; 1706e8d5648eSdan const char *zSep = ""; 1707e8d5648eSdan SessionBuffer buf = {0, 0, 0}; 1708d5f0767cSdan 1709e8d5648eSdan sessionAppendStr(&buf, "SELECT * FROM ", &rc); 1710d7fb7d24Sdan sessionAppendIdent(&buf, zDb, &rc); 1711d7fb7d24Sdan sessionAppendStr(&buf, ".", &rc); 1712e8d5648eSdan sessionAppendIdent(&buf, zTab, &rc); 1713e8d5648eSdan sessionAppendStr(&buf, " WHERE ", &rc); 1714e8d5648eSdan for(i=0; i<nCol; i++){ 1715e8d5648eSdan if( abPK[i] ){ 1716e8d5648eSdan sessionAppendStr(&buf, zSep, &rc); 1717e8d5648eSdan sessionAppendIdent(&buf, azCol[i], &rc); 1718e8d5648eSdan sessionAppendStr(&buf, " = ?", &rc); 1719e8d5648eSdan sessionAppendInteger(&buf, i+1, &rc); 1720e8d5648eSdan zSep = " AND "; 1721d5f0767cSdan } 1722d5f0767cSdan } 1723d5f0767cSdan if( rc==SQLITE_OK ){ 1724e8d5648eSdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, ppStmt, 0); 1725d5f0767cSdan } 1726e8d5648eSdan sqlite3_free(buf.aBuf); 1727e8d5648eSdan return rc; 1728d5f0767cSdan } 1729d5f0767cSdan 173077fc1d5bSdan /* 173177fc1d5bSdan ** Bind the PRIMARY KEY values from the change passed in argument pChange 173277fc1d5bSdan ** to the SELECT statement passed as the first argument. The SELECT statement 173377fc1d5bSdan ** is as prepared by function sessionSelectStmt(). 173477fc1d5bSdan ** 173577fc1d5bSdan ** Return SQLITE_OK if all PK values are successfully bound, or an SQLite 173677fc1d5bSdan ** error code (e.g. SQLITE_NOMEM) otherwise. 173777fc1d5bSdan */ 1738e8d5648eSdan static int sessionSelectBind( 173977fc1d5bSdan sqlite3_stmt *pSelect, /* SELECT from sessionSelectStmt() */ 174077fc1d5bSdan int nCol, /* Number of columns in table */ 174177fc1d5bSdan u8 *abPK, /* PRIMARY KEY array */ 174277fc1d5bSdan SessionChange *pChange /* Change structure */ 1743e8d5648eSdan ){ 1744e8d5648eSdan int i; 1745e8d5648eSdan int rc = SQLITE_OK; 1746e5754eecSdan u8 *a = pChange->aRecord; 1747d5f0767cSdan 1748e8d5648eSdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 1749e8d5648eSdan int eType = *a++; 1750e8d5648eSdan 1751e8d5648eSdan switch( eType ){ 175280fe2d93Sdan case 0: 1753e8d5648eSdan case SQLITE_NULL: 1754e5754eecSdan assert( abPK[i]==0 ); 1755e8d5648eSdan break; 1756e8d5648eSdan 1757e8d5648eSdan case SQLITE_INTEGER: { 1758e8d5648eSdan if( abPK[i] ){ 1759e8d5648eSdan i64 iVal = sessionGetI64(a); 1760e8d5648eSdan rc = sqlite3_bind_int64(pSelect, i+1, iVal); 1761e8d5648eSdan } 1762e8d5648eSdan a += 8; 1763e8d5648eSdan break; 1764d5f0767cSdan } 1765296c7658Sdan 1766e8d5648eSdan case SQLITE_FLOAT: { 1767e8d5648eSdan if( abPK[i] ){ 1768e8d5648eSdan double rVal; 1769e8d5648eSdan i64 iVal = sessionGetI64(a); 1770e8d5648eSdan memcpy(&rVal, &iVal, 8); 17714e895da1Sdan rc = sqlite3_bind_double(pSelect, i+1, rVal); 1772d5f0767cSdan } 1773e8d5648eSdan a += 8; 1774e8d5648eSdan break; 1775e8d5648eSdan } 1776e8d5648eSdan 1777e8d5648eSdan case SQLITE_TEXT: { 1778e8d5648eSdan int n; 1779e8d5648eSdan a += sessionVarintGet(a, &n); 1780e8d5648eSdan if( abPK[i] ){ 1781e8d5648eSdan rc = sqlite3_bind_text(pSelect, i+1, (char *)a, n, SQLITE_TRANSIENT); 1782e8d5648eSdan } 1783e8d5648eSdan a += n; 1784e8d5648eSdan break; 1785e8d5648eSdan } 1786e8d5648eSdan 1787e5754eecSdan default: { 1788e8d5648eSdan int n; 1789e5754eecSdan assert( eType==SQLITE_BLOB ); 1790e8d5648eSdan a += sessionVarintGet(a, &n); 1791e8d5648eSdan if( abPK[i] ){ 1792e8d5648eSdan rc = sqlite3_bind_blob(pSelect, i+1, a, n, SQLITE_TRANSIENT); 1793e8d5648eSdan } 1794e8d5648eSdan a += n; 1795e8d5648eSdan break; 1796e8d5648eSdan } 1797e8d5648eSdan } 1798e8d5648eSdan } 1799e8d5648eSdan 1800d5f0767cSdan return rc; 18014fccf43aSdan } 18024fccf43aSdan 180377fc1d5bSdan /* 180477fc1d5bSdan ** This function is a no-op if *pRc is set to other than SQLITE_OK when it 180577fc1d5bSdan ** is called. Otherwise, append a serialized table header (part of the binary 180677fc1d5bSdan ** changeset format) to buffer *pBuf. If an error occurs, set *pRc to an 180777fc1d5bSdan ** SQLite error code before returning. 180877fc1d5bSdan */ 18095d607a6eSdan static void sessionAppendTableHdr( 1810a71d2371Sdan SessionBuffer *pBuf, /* Append header to this buffer */ 1811a71d2371Sdan int bPatchset, /* Use the patchset format if true */ 1812a71d2371Sdan SessionTable *pTab, /* Table object to append header for */ 1813a71d2371Sdan int *pRc /* IN/OUT: Error code */ 18145d607a6eSdan ){ 18155d607a6eSdan /* Write a table header */ 181673b3c055Sdan sessionAppendByte(pBuf, (bPatchset ? 'P' : 'T'), pRc); 18175d607a6eSdan sessionAppendVarint(pBuf, pTab->nCol, pRc); 18185d607a6eSdan sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc); 18194f528042Sdan sessionAppendBlob(pBuf, (u8 *)pTab->zName, (int)strlen(pTab->zName)+1, pRc); 18205d607a6eSdan } 18215d607a6eSdan 1822a71d2371Sdan /* 1823a71d2371Sdan ** Generate either a changeset (if argument bPatchset is zero) or a patchset 1824a71d2371Sdan ** (if it is non-zero) based on the current contents of the session object 1825a71d2371Sdan ** passed as the first argument. 1826a71d2371Sdan ** 1827a71d2371Sdan ** If no error occurs, SQLITE_OK is returned and the new changeset/patchset 1828a71d2371Sdan ** stored in output variables *pnChangeset and *ppChangeset. Or, if an error 1829a71d2371Sdan ** occurs, an SQLite error code is returned and both output variables set 1830a71d2371Sdan ** to 0. 1831a71d2371Sdan */ 183273b3c055Sdan int sessionGenerateChangeset( 18334fccf43aSdan sqlite3_session *pSession, /* Session object */ 183473b3c055Sdan int bPatchset, /* True for patchset, false for changeset */ 1835ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1836ef7a6304Sdan void *pOut, /* First argument for xOutput */ 18374fccf43aSdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 18384fccf43aSdan void **ppChangeset /* OUT: Buffer containing changeset */ 18394fccf43aSdan ){ 1840296c7658Sdan sqlite3 *db = pSession->db; /* Source database handle */ 1841296c7658Sdan SessionTable *pTab; /* Used to iterate through attached tables */ 1842296c7658Sdan SessionBuffer buf = {0,0,0}; /* Buffer in which to accumlate changeset */ 1843296c7658Sdan int rc; /* Return code */ 18444fccf43aSdan 1845ef7a6304Sdan assert( xOutput==0 || (pnChangeset==0 && ppChangeset==0 ) ); 1846ef7a6304Sdan 1847296c7658Sdan /* Zero the output variables in case an error occurs. If this session 1848296c7658Sdan ** object is already in the error state (sqlite3_session.rc != SQLITE_OK), 1849296c7658Sdan ** this call will be a no-op. */ 1850ef7a6304Sdan if( xOutput==0 ){ 18514fccf43aSdan *pnChangeset = 0; 18524fccf43aSdan *ppChangeset = 0; 1853ef7a6304Sdan } 1854e5754eecSdan 1855e5754eecSdan if( pSession->rc ) return pSession->rc; 1856e5754eecSdan rc = sqlite3_exec(pSession->db, "SAVEPOINT changeset", 0, 0, 0); 1857e5754eecSdan if( rc!=SQLITE_OK ) return rc; 1858e5754eecSdan 1859e5754eecSdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 18604fccf43aSdan 18614fccf43aSdan for(pTab=pSession->pTable; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ 18624fccf43aSdan if( pTab->nEntry ){ 1863d7fb7d24Sdan const char *zName = pTab->zName; 1864a9605b91Sdan int nCol; /* Number of columns in table */ 1865a9605b91Sdan u8 *abPK; /* Primary key array */ 1866a9605b91Sdan const char **azCol = 0; /* Table columns */ 18671f34f8ccSdan int i; /* Used to iterate through hash buckets */ 18681f34f8ccSdan sqlite3_stmt *pSel = 0; /* SELECT statement to query table pTab */ 18691f34f8ccSdan int nRewind = buf.nBuf; /* Initial size of write buffer */ 18701f34f8ccSdan int nNoop; /* Size of buffer after writing tbl header */ 18714fccf43aSdan 1872a9605b91Sdan /* Check the table schema is still Ok. */ 1873a9605b91Sdan rc = sessionTableInfo(db, pSession->zDb, zName, &nCol, 0, &azCol, &abPK); 1874a9605b91Sdan if( !rc && (pTab->nCol!=nCol || memcmp(abPK, pTab->abPK, nCol)) ){ 1875a9605b91Sdan rc = SQLITE_SCHEMA; 1876a9605b91Sdan } 1877a9605b91Sdan 18784fccf43aSdan /* Write a table header */ 187973b3c055Sdan sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); 18804fccf43aSdan 18814fccf43aSdan /* Build and compile a statement to execute: */ 18824fccf43aSdan if( rc==SQLITE_OK ){ 1883d7fb7d24Sdan rc = sessionSelectStmt( 1884a9605b91Sdan db, pSession->zDb, zName, nCol, azCol, abPK, &pSel); 18854fccf43aSdan } 18864fccf43aSdan 18871f34f8ccSdan nNoop = buf.nBuf; 188812ca0b56Sdan for(i=0; i<pTab->nChange && rc==SQLITE_OK; i++){ 1889e8d5648eSdan SessionChange *p; /* Used to iterate through changes */ 1890e8d5648eSdan 18914fccf43aSdan for(p=pTab->apChange[i]; rc==SQLITE_OK && p; p=p->pNext){ 1892e5754eecSdan rc = sessionSelectBind(pSel, nCol, abPK, p); 189380fe2d93Sdan if( rc!=SQLITE_OK ) continue; 18941f34f8ccSdan if( sqlite3_step(pSel)==SQLITE_ROW ){ 1895798693b2Sdan if( p->op==SQLITE_INSERT ){ 18964fccf43aSdan int iCol; 18974fccf43aSdan sessionAppendByte(&buf, SQLITE_INSERT, &rc); 1898b4480e94Sdan sessionAppendByte(&buf, p->bIndirect, &rc); 1899e8d5648eSdan for(iCol=0; iCol<nCol; iCol++){ 19001f34f8ccSdan sessionAppendCol(&buf, pSel, iCol, &rc); 19014fccf43aSdan } 1902e8d5648eSdan }else{ 190373b3c055Sdan rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); 19044fccf43aSdan } 1905798693b2Sdan }else if( p->op!=SQLITE_INSERT ){ 1906a71d2371Sdan rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); 19074fccf43aSdan } 190812ca0b56Sdan if( rc==SQLITE_OK ){ 19091f34f8ccSdan rc = sqlite3_reset(pSel); 19104fccf43aSdan } 1911ef7a6304Sdan 1912f1a08ad8Sdrh /* If the buffer is now larger than SESSIONS_STRM_CHUNK_SIZE, pass 1913ef7a6304Sdan ** its contents to the xOutput() callback. */ 1914ef7a6304Sdan if( xOutput 1915ef7a6304Sdan && rc==SQLITE_OK 1916ef7a6304Sdan && buf.nBuf>nNoop 1917f1a08ad8Sdrh && buf.nBuf>SESSIONS_STRM_CHUNK_SIZE 1918ef7a6304Sdan ){ 1919ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1920ef7a6304Sdan nNoop = -1; 1921ef7a6304Sdan buf.nBuf = 0; 1922ef7a6304Sdan } 1923ef7a6304Sdan 19244fccf43aSdan } 1925e8d5648eSdan } 19264fccf43aSdan 19271f34f8ccSdan sqlite3_finalize(pSel); 19281f34f8ccSdan if( buf.nBuf==nNoop ){ 19294fccf43aSdan buf.nBuf = nRewind; 19304fccf43aSdan } 1931cfdbde21Sdrh sqlite3_free((char*)azCol); /* cast works around VC++ bug */ 19324fccf43aSdan } 19334fccf43aSdan } 19344fccf43aSdan 19354fccf43aSdan if( rc==SQLITE_OK ){ 1936ef7a6304Sdan if( xOutput==0 ){ 19374fccf43aSdan *pnChangeset = buf.nBuf; 19384fccf43aSdan *ppChangeset = buf.aBuf; 1939ef7a6304Sdan buf.aBuf = 0; 1940ef7a6304Sdan }else if( buf.nBuf>0 ){ 1941ef7a6304Sdan rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); 1942ef7a6304Sdan } 19434fccf43aSdan } 19444c220252Sdan 1945ef7a6304Sdan sqlite3_free(buf.aBuf); 1946e5754eecSdan sqlite3_exec(db, "RELEASE changeset", 0, 0, 0); 19474c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 19484fccf43aSdan return rc; 19494fccf43aSdan } 19504fccf43aSdan 1951296c7658Sdan /* 195273b3c055Sdan ** Obtain a changeset object containing all changes recorded by the 195373b3c055Sdan ** session object passed as the first argument. 195473b3c055Sdan ** 195573b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 195673b3c055Sdan ** using sqlite3_free(). 195773b3c055Sdan */ 195873b3c055Sdan int sqlite3session_changeset( 195973b3c055Sdan sqlite3_session *pSession, /* Session object */ 196073b3c055Sdan int *pnChangeset, /* OUT: Size of buffer at *ppChangeset */ 196173b3c055Sdan void **ppChangeset /* OUT: Buffer containing changeset */ 196273b3c055Sdan ){ 1963ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, 0, 0, pnChangeset, ppChangeset); 1964ef7a6304Sdan } 1965ef7a6304Sdan 1966ef7a6304Sdan /* 1967ef7a6304Sdan ** Streaming version of sqlite3session_changeset(). 1968ef7a6304Sdan */ 1969f1a08ad8Sdrh int sqlite3session_changeset_strm( 1970ef7a6304Sdan sqlite3_session *pSession, 1971ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1972ef7a6304Sdan void *pOut 1973ef7a6304Sdan ){ 1974ef7a6304Sdan return sessionGenerateChangeset(pSession, 0, xOutput, pOut, 0, 0); 1975ef7a6304Sdan } 1976ef7a6304Sdan 1977ef7a6304Sdan /* 1978ef7a6304Sdan ** Streaming version of sqlite3session_patchset(). 1979ef7a6304Sdan */ 1980f1a08ad8Sdrh int sqlite3session_patchset_strm( 1981ef7a6304Sdan sqlite3_session *pSession, 1982ef7a6304Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 1983ef7a6304Sdan void *pOut 1984ef7a6304Sdan ){ 1985ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, xOutput, pOut, 0, 0); 198673b3c055Sdan } 198773b3c055Sdan 198873b3c055Sdan /* 198973b3c055Sdan ** Obtain a patchset object containing all changes recorded by the 199073b3c055Sdan ** session object passed as the first argument. 199173b3c055Sdan ** 199273b3c055Sdan ** It is the responsibility of the caller to eventually free the buffer 199373b3c055Sdan ** using sqlite3_free(). 199473b3c055Sdan */ 199573b3c055Sdan int sqlite3session_patchset( 199673b3c055Sdan sqlite3_session *pSession, /* Session object */ 199773b3c055Sdan int *pnPatchset, /* OUT: Size of buffer at *ppChangeset */ 199873b3c055Sdan void **ppPatchset /* OUT: Buffer containing changeset */ 199973b3c055Sdan ){ 2000ef7a6304Sdan return sessionGenerateChangeset(pSession, 1, 0, 0, pnPatchset, ppPatchset); 200173b3c055Sdan } 200273b3c055Sdan 200373b3c055Sdan /* 2004296c7658Sdan ** Enable or disable the session object passed as the first argument. 2005296c7658Sdan */ 20064fccf43aSdan int sqlite3session_enable(sqlite3_session *pSession, int bEnable){ 20074c220252Sdan int ret; 20084c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2009296c7658Sdan if( bEnable>=0 ){ 2010296c7658Sdan pSession->bEnable = bEnable; 20114fccf43aSdan } 20124c220252Sdan ret = pSession->bEnable; 20134c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 20144c220252Sdan return ret; 2015296c7658Sdan } 20164fccf43aSdan 20174fccf43aSdan /* 2018b4480e94Sdan ** Enable or disable the session object passed as the first argument. 2019b4480e94Sdan */ 2020b4480e94Sdan int sqlite3session_indirect(sqlite3_session *pSession, int bIndirect){ 2021b4480e94Sdan int ret; 2022b4480e94Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2023b4480e94Sdan if( bIndirect>=0 ){ 2024b4480e94Sdan pSession->bIndirect = bIndirect; 2025b4480e94Sdan } 2026b4480e94Sdan ret = pSession->bIndirect; 2027b4480e94Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2028b4480e94Sdan return ret; 2029b4480e94Sdan } 2030b4480e94Sdan 2031b4480e94Sdan /* 2032b69ec348Sdan ** Return true if there have been no changes to monitored tables recorded 2033b69ec348Sdan ** by the session object passed as the only argument. 2034b69ec348Sdan */ 2035b69ec348Sdan int sqlite3session_isempty(sqlite3_session *pSession){ 2036b69ec348Sdan int ret = 0; 2037b69ec348Sdan SessionTable *pTab; 2038b69ec348Sdan 2039b69ec348Sdan sqlite3_mutex_enter(sqlite3_db_mutex(pSession->db)); 2040b69ec348Sdan for(pTab=pSession->pTable; pTab && ret==0; pTab=pTab->pNext){ 2041b69ec348Sdan ret = (pTab->nEntry>0); 2042b69ec348Sdan } 2043b69ec348Sdan sqlite3_mutex_leave(sqlite3_db_mutex(pSession->db)); 2044b69ec348Sdan 2045ff530326Sdan return (ret==0); 2046b69ec348Sdan } 2047b69ec348Sdan 2048b69ec348Sdan /* 2049f1a08ad8Sdrh ** Do the work for either sqlite3changeset_start() or start_strm(). 20504fccf43aSdan */ 2051ef7a6304Sdan int sessionChangesetStart( 2052296c7658Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2053ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2054ef7a6304Sdan void *pIn, 2055296c7658Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2056296c7658Sdan void *pChangeset /* Pointer to buffer containing changeset */ 20574fccf43aSdan ){ 20584fccf43aSdan sqlite3_changeset_iter *pRet; /* Iterator to return */ 20594fccf43aSdan int nByte; /* Number of bytes to allocate for iterator */ 20604fccf43aSdan 2061ef7a6304Sdan assert( xInput==0 || (pChangeset==0 && nChangeset==0) ); 2062ef7a6304Sdan 2063296c7658Sdan /* Zero the output variable in case an error occurs. */ 2064296c7658Sdan *pp = 0; 20654fccf43aSdan 2066296c7658Sdan /* Allocate and initialize the iterator structure. */ 20674fccf43aSdan nByte = sizeof(sqlite3_changeset_iter); 20684fccf43aSdan pRet = (sqlite3_changeset_iter *)sqlite3_malloc(nByte); 20694fccf43aSdan if( !pRet ) return SQLITE_NOMEM; 20704fccf43aSdan memset(pRet, 0, sizeof(sqlite3_changeset_iter)); 20714757c658Sdan pRet->in.aData = (u8 *)pChangeset; 20724757c658Sdan pRet->in.nData = nChangeset; 2073ef7a6304Sdan pRet->in.xInput = xInput; 2074ef7a6304Sdan pRet->in.pIn = pIn; 2075ef7a6304Sdan pRet->in.iNext = 0; 2076ef7a6304Sdan pRet->in.bEof = (xInput ? 0 : 1); 20774fccf43aSdan 2078296c7658Sdan /* Populate the output variable and return success. */ 2079296c7658Sdan *pp = pRet; 20804fccf43aSdan return SQLITE_OK; 20814fccf43aSdan } 20824fccf43aSdan 2083296c7658Sdan /* 2084ef7a6304Sdan ** Create an iterator used to iterate through the contents of a changeset. 2085ef7a6304Sdan */ 2086ef7a6304Sdan int sqlite3changeset_start( 2087ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2088ef7a6304Sdan int nChangeset, /* Size of buffer pChangeset in bytes */ 2089ef7a6304Sdan void *pChangeset /* Pointer to buffer containing changeset */ 2090ef7a6304Sdan ){ 2091ef7a6304Sdan return sessionChangesetStart(pp, 0, 0, nChangeset, pChangeset); 2092ef7a6304Sdan } 2093ef7a6304Sdan 2094ef7a6304Sdan /* 2095ef7a6304Sdan ** Streaming version of sqlite3changeset_start(). 2096ef7a6304Sdan */ 2097f1a08ad8Sdrh int sqlite3changeset_start_strm( 2098ef7a6304Sdan sqlite3_changeset_iter **pp, /* OUT: Changeset iterator handle */ 2099ef7a6304Sdan int (*xInput)(void *pIn, void *pData, int *pnData), 2100ef7a6304Sdan void *pIn 2101ef7a6304Sdan ){ 2102ef7a6304Sdan return sessionChangesetStart(pp, xInput, pIn, 0, 0); 2103ef7a6304Sdan } 2104ef7a6304Sdan 2105ef7a6304Sdan /* 2106ef7a6304Sdan ** Ensure that there are at least nByte bytes available in the buffer. Or, 2107ef7a6304Sdan ** if there are not nByte bytes remaining in the input, that all available 2108ef7a6304Sdan ** data is in the buffer. 2109ef7a6304Sdan ** 2110ef7a6304Sdan ** Return an SQLite error code if an error occurs, or SQLITE_OK otherwise. 2111ef7a6304Sdan */ 21124757c658Sdan static int sessionInputBuffer(SessionInput *pIn, int nByte){ 2113ef7a6304Sdan int rc = SQLITE_OK; 21144757c658Sdan if( pIn->xInput ){ 21154757c658Sdan while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ 2116f1a08ad8Sdrh int nNew = SESSIONS_STRM_CHUNK_SIZE; 21174757c658Sdan 2118f1a08ad8Sdrh if( pIn->iNext>=SESSIONS_STRM_CHUNK_SIZE ){ 21194757c658Sdan int nMove = pIn->buf.nBuf - pIn->iNext; 21204757c658Sdan memmove(pIn->buf.aBuf, &pIn->buf.aBuf[pIn->iNext], nMove); 21214757c658Sdan pIn->buf.nBuf -= pIn->iNext; 21224757c658Sdan pIn->iNext = 0; 21234757c658Sdan } 21244757c658Sdan 21254757c658Sdan if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){ 21264757c658Sdan rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); 21274757c658Sdan if( nNew==0 ){ 21284757c658Sdan pIn->bEof = 1; 21294757c658Sdan }else{ 21304757c658Sdan pIn->buf.nBuf += nNew; 21314757c658Sdan } 21324757c658Sdan } 21334757c658Sdan 21344757c658Sdan pIn->aData = pIn->buf.aBuf; 21354757c658Sdan pIn->nData = pIn->buf.nBuf; 21364757c658Sdan } 2137ef7a6304Sdan } 2138ef7a6304Sdan return rc; 2139ef7a6304Sdan } 2140ef7a6304Sdan 2141ef7a6304Sdan /* 2142ef7a6304Sdan ** When this function is called, *ppRec points to the start of a record 2143ef7a6304Sdan ** that contains nCol values. This function advances the pointer *ppRec 2144ef7a6304Sdan ** until it points to the byte immediately following that record. 2145ef7a6304Sdan */ 2146ef7a6304Sdan static void sessionSkipRecord( 2147ef7a6304Sdan u8 **ppRec, /* IN/OUT: Record pointer */ 2148ef7a6304Sdan int nCol /* Number of values in record */ 2149ef7a6304Sdan ){ 2150ef7a6304Sdan u8 *aRec = *ppRec; 2151ef7a6304Sdan int i; 2152ef7a6304Sdan for(i=0; i<nCol; i++){ 2153ef7a6304Sdan int eType = *aRec++; 2154ef7a6304Sdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2155ef7a6304Sdan int nByte; 2156ef7a6304Sdan aRec += sessionVarintGet((u8*)aRec, &nByte); 2157ef7a6304Sdan aRec += nByte; 2158ef7a6304Sdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2159ef7a6304Sdan aRec += 8; 2160ef7a6304Sdan } 2161ef7a6304Sdan } 2162ef7a6304Sdan 2163ef7a6304Sdan *ppRec = aRec; 2164ef7a6304Sdan } 2165ef7a6304Sdan 2166ef7a6304Sdan /* 21674757c658Sdan ** This function sets the value of the sqlite3_value object passed as the 21684757c658Sdan ** first argument to a copy of the string or blob held in the aData[] 21694757c658Sdan ** buffer. SQLITE_OK is returned if successful, or SQLITE_NOMEM if an OOM 21704757c658Sdan ** error occurs. 21714757c658Sdan */ 21724757c658Sdan static int sessionValueSetStr( 21734757c658Sdan sqlite3_value *pVal, /* Set the value of this object */ 21744757c658Sdan u8 *aData, /* Buffer containing string or blob data */ 21754757c658Sdan int nData, /* Size of buffer aData[] in bytes */ 21764757c658Sdan u8 enc /* String encoding (0 for blobs) */ 21774757c658Sdan ){ 217816228167Sdan /* In theory this code could just pass SQLITE_TRANSIENT as the final 217916228167Sdan ** argument to sqlite3ValueSetStr() and have the copy created 218016228167Sdan ** automatically. But doing so makes it difficult to detect any OOM 218116228167Sdan ** error. Hence the code to create the copy externally. */ 21824757c658Sdan u8 *aCopy = sqlite3_malloc(nData); 21834757c658Sdan if( aCopy==0 ) return SQLITE_NOMEM; 21844757c658Sdan memcpy(aCopy, aData, nData); 21854757c658Sdan sqlite3ValueSetStr(pVal, nData, (char*)aCopy, enc, sqlite3_free); 21864757c658Sdan return SQLITE_OK; 21874757c658Sdan } 21884757c658Sdan 21894757c658Sdan /* 2190296c7658Sdan ** Deserialize a single record from a buffer in memory. See "RECORD FORMAT" 2191296c7658Sdan ** for details. 2192296c7658Sdan ** 2193296c7658Sdan ** When this function is called, *paChange points to the start of the record 2194296c7658Sdan ** to deserialize. Assuming no error occurs, *paChange is set to point to 2195296c7658Sdan ** one byte after the end of the same record before this function returns. 2196a71d2371Sdan ** If the argument abPK is NULL, then the record contains nCol values. Or, 2197a71d2371Sdan ** if abPK is other than NULL, then the record contains only the PK fields 2198a71d2371Sdan ** (in other words, it is a patchset DELETE record). 2199296c7658Sdan ** 2200296c7658Sdan ** If successful, each element of the apOut[] array (allocated by the caller) 2201296c7658Sdan ** is set to point to an sqlite3_value object containing the value read 2202296c7658Sdan ** from the corresponding position in the record. If that value is not 2203296c7658Sdan ** included in the record (i.e. because the record is part of an UPDATE change 2204296c7658Sdan ** and the field was not modified), the corresponding element of apOut[] is 2205296c7658Sdan ** set to NULL. 2206296c7658Sdan ** 2207296c7658Sdan ** It is the responsibility of the caller to free all sqlite_value structures 2208296c7658Sdan ** using sqlite3_free(). 2209296c7658Sdan ** 2210296c7658Sdan ** If an error occurs, an SQLite error code (e.g. SQLITE_NOMEM) is returned. 2211296c7658Sdan ** The apOut[] array may have been partially populated in this case. 2212296c7658Sdan */ 22134fccf43aSdan static int sessionReadRecord( 2214ef7a6304Sdan SessionInput *pIn, /* Input data */ 22154fccf43aSdan int nCol, /* Number of values in record */ 221673b3c055Sdan u8 *abPK, /* Array of primary key flags, or NULL */ 22174fccf43aSdan sqlite3_value **apOut /* Write values to this array */ 22184fccf43aSdan ){ 2219296c7658Sdan int i; /* Used to iterate through columns */ 2220ef7a6304Sdan int rc = SQLITE_OK; 22214fccf43aSdan 2222ef7a6304Sdan for(i=0; i<nCol && rc==SQLITE_OK; i++){ 2223ef7a6304Sdan int eType = 0; /* Type of value (SQLITE_NULL, TEXT etc.) */ 222473b3c055Sdan if( abPK && abPK[i]==0 ) continue; 2225ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2226ef7a6304Sdan if( rc==SQLITE_OK ){ 22274757c658Sdan eType = pIn->aData[pIn->iNext++]; 2228ef7a6304Sdan } 2229ef7a6304Sdan 2230e8fa8c96Sdan assert( apOut[i]==0 ); 22314fccf43aSdan if( eType ){ 22324fccf43aSdan apOut[i] = sqlite3ValueNew(0); 2233ef7a6304Sdan if( !apOut[i] ) rc = SQLITE_NOMEM; 2234ef7a6304Sdan } 22354fccf43aSdan 2236ef7a6304Sdan if( rc==SQLITE_OK ){ 22374757c658Sdan u8 *aVal = &pIn->aData[pIn->iNext]; 22384fccf43aSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 22394fccf43aSdan int nByte; 2240ef7a6304Sdan pIn->iNext += sessionVarintGet(aVal, &nByte); 2241ef7a6304Sdan rc = sessionInputBuffer(pIn, nByte); 2242e8fa8c96Sdan if( rc==SQLITE_OK ){ 22436734007dSdan u8 enc = (eType==SQLITE_TEXT ? SQLITE_UTF8 : 0); 22444757c658Sdan rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc); 224591ddd559Sdan } 2246ef7a6304Sdan pIn->iNext += nByte; 22474fccf43aSdan } 22484fccf43aSdan if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2249ef7a6304Sdan sqlite3_int64 v = sessionGetI64(aVal); 22504fccf43aSdan if( eType==SQLITE_INTEGER ){ 22514fccf43aSdan sqlite3VdbeMemSetInt64(apOut[i], v); 22524fccf43aSdan }else{ 22534fccf43aSdan double d; 22544e895da1Sdan memcpy(&d, &v, 8); 22554fccf43aSdan sqlite3VdbeMemSetDouble(apOut[i], d); 22564fccf43aSdan } 2257ef7a6304Sdan pIn->iNext += 8; 225891ddd559Sdan } 22594fccf43aSdan } 22604fccf43aSdan } 22614fccf43aSdan 2262ef7a6304Sdan return rc; 2263ef7a6304Sdan } 2264ef7a6304Sdan 2265ef7a6304Sdan /* 2266ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2267ef7a6304Sdan ** Specifically, to the following: 2268ef7a6304Sdan ** 2269ef7a6304Sdan ** + number of columns in table (varint) 2270ef7a6304Sdan ** + array of PK flags (1 byte per column), 2271ef7a6304Sdan ** + table name (nul terminated). 2272ef7a6304Sdan ** 2273ef7a6304Sdan ** This function ensures that all of the above is present in the input 2274ef7a6304Sdan ** buffer (i.e. that it can be accessed without any calls to xInput()). 2275ef7a6304Sdan ** If successful, SQLITE_OK is returned. Otherwise, an SQLite error code. 2276ef7a6304Sdan ** The input pointer is not moved. 2277ef7a6304Sdan */ 2278ef7a6304Sdan static int sessionChangesetBufferTblhdr(SessionInput *pIn, int *pnByte){ 2279ef7a6304Sdan int rc = SQLITE_OK; 2280ef7a6304Sdan int nCol = 0; 22814757c658Sdan int nRead = 0; 2282ef7a6304Sdan 2283ef7a6304Sdan rc = sessionInputBuffer(pIn, 9); 2284ef7a6304Sdan if( rc==SQLITE_OK ){ 22854757c658Sdan nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol); 22864757c658Sdan rc = sessionInputBuffer(pIn, nRead+nCol+100); 22874757c658Sdan nRead += nCol; 2288ef7a6304Sdan } 22894757c658Sdan 2290ef7a6304Sdan while( rc==SQLITE_OK ){ 22914757c658Sdan while( (pIn->iNext + nRead)<pIn->nData && pIn->aData[pIn->iNext + nRead] ){ 22924757c658Sdan nRead++; 2293ef7a6304Sdan } 2294e8fa8c96Sdan if( (pIn->iNext + nRead)<pIn->nData ) break; 22954757c658Sdan rc = sessionInputBuffer(pIn, nRead + 100); 22964757c658Sdan } 2297e8fa8c96Sdan *pnByte = nRead+1; 2298ef7a6304Sdan return rc; 2299ef7a6304Sdan } 2300ef7a6304Sdan 2301ef7a6304Sdan /* 2302fa122adaSdan ** The input pointer currently points to the first byte of the first field 2303fa122adaSdan ** of a record consisting of nCol columns. This function ensures the entire 230416228167Sdan ** record is buffered. It does not move the input pointer. 230516228167Sdan ** 230616228167Sdan ** If successful, SQLITE_OK is returned and *pnByte is set to the size of 230716228167Sdan ** the record in bytes. Otherwise, an SQLite error code is returned. The 230816228167Sdan ** final value of *pnByte is undefined in this case. 2309fa122adaSdan */ 2310fa122adaSdan static int sessionChangesetBufferRecord( 231116228167Sdan SessionInput *pIn, /* Input data */ 231216228167Sdan int nCol, /* Number of columns in record */ 231316228167Sdan int *pnByte /* OUT: Size of record in bytes */ 2314fa122adaSdan ){ 2315fa122adaSdan int rc = SQLITE_OK; 2316fa122adaSdan int nByte = 0; 2317fa122adaSdan int i; 2318fa122adaSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 2319fa122adaSdan int eType; 2320fa122adaSdan rc = sessionInputBuffer(pIn, nByte + 10); 2321fa122adaSdan if( rc==SQLITE_OK ){ 2322fa122adaSdan eType = pIn->aData[pIn->iNext + nByte++]; 2323fa122adaSdan if( eType==SQLITE_TEXT || eType==SQLITE_BLOB ){ 2324fa122adaSdan int n; 2325fa122adaSdan nByte += sessionVarintGet(&pIn->aData[pIn->iNext+nByte], &n); 2326fa122adaSdan nByte += n; 2327fa122adaSdan rc = sessionInputBuffer(pIn, nByte); 2328fa122adaSdan }else if( eType==SQLITE_INTEGER || eType==SQLITE_FLOAT ){ 2329fa122adaSdan nByte += 8; 2330fa122adaSdan } 2331fa122adaSdan } 2332fa122adaSdan } 2333fa122adaSdan *pnByte = nByte; 2334fa122adaSdan return rc; 2335fa122adaSdan } 2336fa122adaSdan 2337fa122adaSdan /* 2338ef7a6304Sdan ** The input pointer currently points to the second byte of a table-header. 2339ef7a6304Sdan ** Specifically, to the following: 2340ef7a6304Sdan ** 2341ef7a6304Sdan ** + number of columns in table (varint) 2342ef7a6304Sdan ** + array of PK flags (1 byte per column), 2343ef7a6304Sdan ** + table name (nul terminated). 234416228167Sdan ** 234516228167Sdan ** This function decodes the table-header and populates the p->nCol, 234616228167Sdan ** p->zTab and p->abPK[] variables accordingly. The p->apValue[] array is 234716228167Sdan ** also allocated or resized according to the new value of p->nCol. The 234816228167Sdan ** input pointer is left pointing to the byte following the table header. 234916228167Sdan ** 235016228167Sdan ** If successful, SQLITE_OK is returned. Otherwise, an SQLite error code 235116228167Sdan ** is returned and the final values of the various fields enumerated above 235216228167Sdan ** are undefined. 2353ef7a6304Sdan */ 2354ef7a6304Sdan static int sessionChangesetReadTblhdr(sqlite3_changeset_iter *p){ 2355ef7a6304Sdan int rc; 2356ef7a6304Sdan int nCopy; 2357ef7a6304Sdan assert( p->rc==SQLITE_OK ); 2358ef7a6304Sdan 2359ef7a6304Sdan rc = sessionChangesetBufferTblhdr(&p->in, &nCopy); 2360ef7a6304Sdan if( rc==SQLITE_OK ){ 2361ef7a6304Sdan int nByte; 2362ef7a6304Sdan int nVarint; 23634757c658Sdan nVarint = sessionVarintGet(&p->in.aData[p->in.iNext], &p->nCol); 2364ef7a6304Sdan nCopy -= nVarint; 2365ef7a6304Sdan p->in.iNext += nVarint; 2366ef7a6304Sdan nByte = p->nCol * sizeof(sqlite3_value*) * 2 + nCopy; 2367ef7a6304Sdan p->tblhdr.nBuf = 0; 2368ef7a6304Sdan sessionBufferGrow(&p->tblhdr, nByte, &rc); 2369ef7a6304Sdan } 2370ef7a6304Sdan 2371ef7a6304Sdan if( rc==SQLITE_OK ){ 2372ef7a6304Sdan int iPK = sizeof(sqlite3_value*)*p->nCol*2; 2373ef7a6304Sdan memset(p->tblhdr.aBuf, 0, iPK); 23744757c658Sdan memcpy(&p->tblhdr.aBuf[iPK], &p->in.aData[p->in.iNext], nCopy); 2375ef7a6304Sdan p->in.iNext += nCopy; 2376ef7a6304Sdan } 2377ef7a6304Sdan 2378ef7a6304Sdan p->apValue = (sqlite3_value**)p->tblhdr.aBuf; 2379ef7a6304Sdan p->abPK = (u8*)&p->apValue[p->nCol*2]; 2380ef7a6304Sdan p->zTab = (char*)&p->abPK[p->nCol]; 2381ef7a6304Sdan return (p->rc = rc); 23824fccf43aSdan } 23834fccf43aSdan 238477fc1d5bSdan /* 238577fc1d5bSdan ** Advance the changeset iterator to the next change. 238677fc1d5bSdan ** 238777fc1d5bSdan ** If both paRec and pnRec are NULL, then this function works like the public 238877fc1d5bSdan ** API sqlite3changeset_next(). If SQLITE_ROW is returned, then the 238977fc1d5bSdan ** sqlite3changeset_new() and old() APIs may be used to query for values. 239077fc1d5bSdan ** 239177fc1d5bSdan ** Otherwise, if paRec and pnRec are not NULL, then a pointer to the change 239277fc1d5bSdan ** record is written to *paRec before returning and the number of bytes in 239377fc1d5bSdan ** the record to *pnRec. 239477fc1d5bSdan ** 239577fc1d5bSdan ** Either way, this function returns SQLITE_ROW if the iterator is 239677fc1d5bSdan ** successfully advanced to the next change in the changeset, an SQLite 239777fc1d5bSdan ** error code if an error occurs, or SQLITE_DONE if there are no further 239877fc1d5bSdan ** changes in the changeset. 239977fc1d5bSdan */ 24005d607a6eSdan static int sessionChangesetNext( 240177fc1d5bSdan sqlite3_changeset_iter *p, /* Changeset iterator */ 240277fc1d5bSdan u8 **paRec, /* If non-NULL, store record pointer here */ 240377fc1d5bSdan int *pnRec /* If non-NULL, store size of record here */ 24045d607a6eSdan ){ 24054fccf43aSdan int i; 2406ef7a6304Sdan u8 op; 24074fccf43aSdan 24085d607a6eSdan assert( (paRec==0 && pnRec==0) || (paRec && pnRec) ); 24095d607a6eSdan 2410296c7658Sdan /* If the iterator is in the error-state, return immediately. */ 24114fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24124fccf43aSdan 24135d607a6eSdan /* Free the current contents of p->apValue[], if any. */ 24144fccf43aSdan if( p->apValue ){ 24154fccf43aSdan for(i=0; i<p->nCol*2; i++){ 24164fccf43aSdan sqlite3ValueFree(p->apValue[i]); 24174fccf43aSdan } 24184fccf43aSdan memset(p->apValue, 0, sizeof(sqlite3_value*)*p->nCol*2); 24194fccf43aSdan } 24204fccf43aSdan 2421ef7a6304Sdan /* Make sure the buffer contains at least 10 bytes of input data, or all 2422ef7a6304Sdan ** remaining data if there are less than 10 bytes available. This is 2423ef7a6304Sdan ** sufficient either for the 'T' or 'P' byte and the varint that follows 2424ef7a6304Sdan ** it, or for the two single byte values otherwise. */ 2425ef7a6304Sdan p->rc = sessionInputBuffer(&p->in, 2); 2426ef7a6304Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2427ef7a6304Sdan 24284fccf43aSdan /* If the iterator is already at the end of the changeset, return DONE. */ 24294757c658Sdan if( p->in.iNext>=p->in.nData ){ 24304fccf43aSdan return SQLITE_DONE; 24314fccf43aSdan } 24324fccf43aSdan 24334757c658Sdan op = p->in.aData[p->in.iNext++]; 2434ef7a6304Sdan if( op=='T' || op=='P' ){ 2435ef7a6304Sdan p->bPatchset = (op=='P'); 2436ef7a6304Sdan if( sessionChangesetReadTblhdr(p) ) return p->rc; 2437ef7a6304Sdan if( (p->rc = sessionInputBuffer(&p->in, 2)) ) return p->rc; 24384757c658Sdan op = p->in.aData[p->in.iNext++]; 24395d607a6eSdan } 24405d607a6eSdan 2441ef7a6304Sdan p->op = op; 24424757c658Sdan p->bIndirect = p->in.aData[p->in.iNext++]; 24434fccf43aSdan if( p->op!=SQLITE_UPDATE && p->op!=SQLITE_DELETE && p->op!=SQLITE_INSERT ){ 24444757c658Sdan return (p->rc = SQLITE_CORRUPT_BKPT); 24454fccf43aSdan } 24464fccf43aSdan 2447cbf6d2d2Sdan if( paRec ){ 2448cbf6d2d2Sdan int nVal; /* Number of values to buffer */ 2449cbf6d2d2Sdan if( p->bPatchset==0 && op==SQLITE_UPDATE ){ 2450cbf6d2d2Sdan nVal = p->nCol * 2; 2451cbf6d2d2Sdan }else if( p->bPatchset && op==SQLITE_DELETE ){ 2452cbf6d2d2Sdan nVal = 0; 2453cbf6d2d2Sdan for(i=0; i<p->nCol; i++) if( p->abPK[i] ) nVal++; 2454cbf6d2d2Sdan }else{ 2455cbf6d2d2Sdan nVal = p->nCol; 2456cbf6d2d2Sdan } 2457cbf6d2d2Sdan p->rc = sessionChangesetBufferRecord(&p->in, nVal, pnRec); 2458cbf6d2d2Sdan if( p->rc!=SQLITE_OK ) return p->rc; 2459cbf6d2d2Sdan *paRec = &p->in.aData[p->in.iNext]; 2460cbf6d2d2Sdan p->in.iNext += *pnRec; 2461cbf6d2d2Sdan }else{ 24625d607a6eSdan 24634fccf43aSdan /* If this is an UPDATE or DELETE, read the old.* record. */ 246473b3c055Sdan if( p->op!=SQLITE_INSERT && (p->bPatchset==0 || p->op==SQLITE_DELETE) ){ 246573b3c055Sdan u8 *abPK = p->bPatchset ? p->abPK : 0; 2466cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, abPK, p->apValue); 24674fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24684fccf43aSdan } 24694fccf43aSdan 24704fccf43aSdan /* If this is an INSERT or UPDATE, read the new.* record. */ 24714fccf43aSdan if( p->op!=SQLITE_DELETE ){ 2472cbf6d2d2Sdan p->rc = sessionReadRecord(&p->in, p->nCol, 0, &p->apValue[p->nCol]); 24734fccf43aSdan if( p->rc!=SQLITE_OK ) return p->rc; 24744fccf43aSdan } 24754fccf43aSdan 2476cbf6d2d2Sdan if( p->bPatchset && p->op==SQLITE_UPDATE ){ 247773b3c055Sdan /* If this is an UPDATE that is part of a patchset, then all PK and 247873b3c055Sdan ** modified fields are present in the new.* record. The old.* record 247973b3c055Sdan ** is currently completely empty. This block shifts the PK fields from 248073b3c055Sdan ** new.* to old.*, to accommodate the code that reads these arrays. */ 248173b3c055Sdan int i; 248273b3c055Sdan for(i=0; i<p->nCol; i++){ 248373b3c055Sdan assert( p->apValue[i]==0 ); 248473b3c055Sdan assert( p->abPK[i]==0 || p->apValue[i+p->nCol] ); 248573b3c055Sdan if( p->abPK[i] ){ 248673b3c055Sdan p->apValue[i] = p->apValue[i+p->nCol]; 248773b3c055Sdan p->apValue[i+p->nCol] = 0; 248873b3c055Sdan } 248973b3c055Sdan } 249073b3c055Sdan } 2491cbf6d2d2Sdan } 2492ef7a6304Sdan 24934fccf43aSdan return SQLITE_ROW; 24944fccf43aSdan } 24954fccf43aSdan 24964fccf43aSdan /* 24975d607a6eSdan ** Advance an iterator created by sqlite3changeset_start() to the next 24985d607a6eSdan ** change in the changeset. This function may return SQLITE_ROW, SQLITE_DONE 24995d607a6eSdan ** or SQLITE_CORRUPT. 25005d607a6eSdan ** 25015d607a6eSdan ** This function may not be called on iterators passed to a conflict handler 25025d607a6eSdan ** callback by changeset_apply(). 25035d607a6eSdan */ 25045d607a6eSdan int sqlite3changeset_next(sqlite3_changeset_iter *p){ 25055d607a6eSdan return sessionChangesetNext(p, 0, 0); 25065d607a6eSdan } 25075d607a6eSdan 25085d607a6eSdan /* 2509244593c8Sdan ** The following function extracts information on the current change 251077fc1d5bSdan ** from a changeset iterator. It may only be called after changeset_next() 25114fccf43aSdan ** has returned SQLITE_ROW. 25124fccf43aSdan */ 25134fccf43aSdan int sqlite3changeset_op( 2514296c7658Sdan sqlite3_changeset_iter *pIter, /* Iterator handle */ 25154fccf43aSdan const char **pzTab, /* OUT: Pointer to table name */ 25164fccf43aSdan int *pnCol, /* OUT: Number of columns in table */ 2517b4480e94Sdan int *pOp, /* OUT: SQLITE_INSERT, DELETE or UPDATE */ 2518b4480e94Sdan int *pbIndirect /* OUT: True if change is indirect */ 25194fccf43aSdan ){ 25204fccf43aSdan *pOp = pIter->op; 25214fccf43aSdan *pnCol = pIter->nCol; 25224fccf43aSdan *pzTab = pIter->zTab; 2523b4480e94Sdan if( pbIndirect ) *pbIndirect = pIter->bIndirect; 25244fccf43aSdan return SQLITE_OK; 25254fccf43aSdan } 25264fccf43aSdan 252777fc1d5bSdan /* 252877fc1d5bSdan ** Return information regarding the PRIMARY KEY and number of columns in 252977fc1d5bSdan ** the database table affected by the change that pIter currently points 253077fc1d5bSdan ** to. This function may only be called after changeset_next() returns 253177fc1d5bSdan ** SQLITE_ROW. 253277fc1d5bSdan */ 2533244593c8Sdan int sqlite3changeset_pk( 2534244593c8Sdan sqlite3_changeset_iter *pIter, /* Iterator object */ 2535244593c8Sdan unsigned char **pabPK, /* OUT: Array of boolean - true for PK cols */ 2536244593c8Sdan int *pnCol /* OUT: Number of entries in output array */ 2537244593c8Sdan ){ 2538244593c8Sdan *pabPK = pIter->abPK; 2539244593c8Sdan if( pnCol ) *pnCol = pIter->nCol; 2540244593c8Sdan return SQLITE_OK; 2541244593c8Sdan } 2542244593c8Sdan 2543296c7658Sdan /* 2544296c7658Sdan ** This function may only be called while the iterator is pointing to an 2545296c7658Sdan ** SQLITE_UPDATE or SQLITE_DELETE change (see sqlite3changeset_op()). 2546296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2547296c7658Sdan ** 2548296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2549296c7658Sdan ** iVal'th value in the old.* record. Or, if that particular value is not 2550296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2551296c7658Sdan ** was not modified and is not a PK column), set *ppValue to NULL. 2552296c7658Sdan ** 2553296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2554296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2555296c7658Sdan */ 25564fccf43aSdan int sqlite3changeset_old( 2557296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2558296c7658Sdan int iVal, /* Index of old.* value to retrieve */ 25594fccf43aSdan sqlite3_value **ppValue /* OUT: Old value (or NULL pointer) */ 25604fccf43aSdan ){ 2561d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_DELETE ){ 2562d5f0767cSdan return SQLITE_MISUSE; 2563d5f0767cSdan } 25644fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25654fccf43aSdan return SQLITE_RANGE; 25664fccf43aSdan } 25674fccf43aSdan *ppValue = pIter->apValue[iVal]; 25684fccf43aSdan return SQLITE_OK; 25694fccf43aSdan } 25704fccf43aSdan 2571296c7658Sdan /* 2572296c7658Sdan ** This function may only be called while the iterator is pointing to an 2573296c7658Sdan ** SQLITE_UPDATE or SQLITE_INSERT change (see sqlite3changeset_op()). 2574296c7658Sdan ** Otherwise, SQLITE_MISUSE is returned. 2575296c7658Sdan ** 2576296c7658Sdan ** It sets *ppValue to point to an sqlite3_value structure containing the 2577296c7658Sdan ** iVal'th value in the new.* record. Or, if that particular value is not 2578296c7658Sdan ** included in the record (because the change is an UPDATE and the field 2579296c7658Sdan ** was not modified), set *ppValue to NULL. 2580296c7658Sdan ** 2581296c7658Sdan ** If value iVal is out-of-range, SQLITE_RANGE is returned and *ppValue is 2582296c7658Sdan ** not modified. Otherwise, SQLITE_OK. 2583296c7658Sdan */ 25844fccf43aSdan int sqlite3changeset_new( 2585296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2586296c7658Sdan int iVal, /* Index of new.* value to retrieve */ 25874fccf43aSdan sqlite3_value **ppValue /* OUT: New value (or NULL pointer) */ 25884fccf43aSdan ){ 2589d5f0767cSdan if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_INSERT ){ 2590d5f0767cSdan return SQLITE_MISUSE; 2591d5f0767cSdan } 25924fccf43aSdan if( iVal<0 || iVal>=pIter->nCol ){ 25934fccf43aSdan return SQLITE_RANGE; 25944fccf43aSdan } 25954fccf43aSdan *ppValue = pIter->apValue[pIter->nCol+iVal]; 25964fccf43aSdan return SQLITE_OK; 25974fccf43aSdan } 25984fccf43aSdan 2599296c7658Sdan /* 26007aa469cdSdan ** The following two macros are used internally. They are similar to the 26017aa469cdSdan ** sqlite3changeset_new() and sqlite3changeset_old() functions, except that 26027aa469cdSdan ** they omit all error checking and return a pointer to the requested value. 26037aa469cdSdan */ 26047aa469cdSdan #define sessionChangesetNew(pIter, iVal) (pIter)->apValue[(pIter)->nCol+(iVal)] 26057aa469cdSdan #define sessionChangesetOld(pIter, iVal) (pIter)->apValue[(iVal)] 26067aa469cdSdan 26077aa469cdSdan /* 2608296c7658Sdan ** This function may only be called with a changeset iterator that has been 2609296c7658Sdan ** passed to an SQLITE_CHANGESET_DATA or SQLITE_CHANGESET_CONFLICT 2610296c7658Sdan ** conflict-handler function. Otherwise, SQLITE_MISUSE is returned. 2611296c7658Sdan ** 2612296c7658Sdan ** If successful, *ppValue is set to point to an sqlite3_value structure 2613296c7658Sdan ** containing the iVal'th value of the conflicting record. 2614296c7658Sdan ** 2615296c7658Sdan ** If value iVal is out-of-range or some other error occurs, an SQLite error 2616296c7658Sdan ** code is returned. Otherwise, SQLITE_OK. 2617296c7658Sdan */ 2618d5f0767cSdan int sqlite3changeset_conflict( 2619296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2620296c7658Sdan int iVal, /* Index of conflict record value to fetch */ 2621d5f0767cSdan sqlite3_value **ppValue /* OUT: Value from conflicting row */ 2622d5f0767cSdan ){ 2623d5f0767cSdan if( !pIter->pConflict ){ 2624d5f0767cSdan return SQLITE_MISUSE; 2625d5f0767cSdan } 2626d5f0767cSdan if( iVal<0 || iVal>=sqlite3_column_count(pIter->pConflict) ){ 2627d5f0767cSdan return SQLITE_RANGE; 2628d5f0767cSdan } 2629d5f0767cSdan *ppValue = sqlite3_column_value(pIter->pConflict, iVal); 2630d5f0767cSdan return SQLITE_OK; 2631d5f0767cSdan } 2632d5f0767cSdan 26334fccf43aSdan /* 2634cb3e4b79Sdan ** This function may only be called with an iterator passed to an 2635cb3e4b79Sdan ** SQLITE_CHANGESET_FOREIGN_KEY conflict handler callback. In this case 2636cb3e4b79Sdan ** it sets the output variable to the total number of known foreign key 2637cb3e4b79Sdan ** violations in the destination database and returns SQLITE_OK. 2638cb3e4b79Sdan ** 2639cb3e4b79Sdan ** In all other cases this function returns SQLITE_MISUSE. 2640cb3e4b79Sdan */ 2641cb3e4b79Sdan int sqlite3changeset_fk_conflicts( 2642cb3e4b79Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 2643cb3e4b79Sdan int *pnOut /* OUT: Number of FK violations */ 2644cb3e4b79Sdan ){ 2645cb3e4b79Sdan if( pIter->pConflict || pIter->apValue ){ 2646cb3e4b79Sdan return SQLITE_MISUSE; 2647cb3e4b79Sdan } 2648cb3e4b79Sdan *pnOut = pIter->nCol; 2649cb3e4b79Sdan return SQLITE_OK; 2650cb3e4b79Sdan } 2651cb3e4b79Sdan 2652cb3e4b79Sdan 2653cb3e4b79Sdan /* 26544fccf43aSdan ** Finalize an iterator allocated with sqlite3changeset_start(). 26554fccf43aSdan ** 26564fccf43aSdan ** This function may not be called on iterators passed to a conflict handler 26574fccf43aSdan ** callback by changeset_apply(). 26584fccf43aSdan */ 26594fccf43aSdan int sqlite3changeset_finalize(sqlite3_changeset_iter *p){ 2660cbf6d2d2Sdan int rc = SQLITE_OK; 2661cbf6d2d2Sdan if( p ){ 2662296c7658Sdan int i; /* Used to iterate through p->apValue[] */ 2663cbf6d2d2Sdan rc = p->rc; 266412ca0b56Sdan if( p->apValue ){ 26654fccf43aSdan for(i=0; i<p->nCol*2; i++) sqlite3ValueFree(p->apValue[i]); 266612ca0b56Sdan } 2667ef7a6304Sdan sqlite3_free(p->tblhdr.aBuf); 26684757c658Sdan sqlite3_free(p->in.buf.aBuf); 26694fccf43aSdan sqlite3_free(p); 2670cbf6d2d2Sdan } 26714fccf43aSdan return rc; 26724fccf43aSdan } 26734fccf43aSdan 2674fa122adaSdan static int sessionChangesetInvert( 2675fa122adaSdan SessionInput *pInput, /* Input changeset */ 2676fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2677fa122adaSdan void *pOut, 267891ddd559Sdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 267991ddd559Sdan void **ppInverted /* OUT: Inverse of pChangeset */ 268091ddd559Sdan ){ 2681cfec7eeeSdan int rc = SQLITE_OK; /* Return value */ 2682fa122adaSdan SessionBuffer sOut; /* Output buffer */ 2683cfec7eeeSdan int nCol = 0; /* Number of cols in current table */ 2684cfec7eeeSdan u8 *abPK = 0; /* PK array for current table */ 2685cfec7eeeSdan sqlite3_value **apVal = 0; /* Space for values for UPDATE inversion */ 2686ef7a6304Sdan SessionBuffer sPK = {0, 0, 0}; /* PK array for current table */ 268791ddd559Sdan 2688fa122adaSdan /* Initialize the output buffer */ 2689fa122adaSdan memset(&sOut, 0, sizeof(SessionBuffer)); 2690fa122adaSdan 269191ddd559Sdan /* Zero the output variables in case an error occurs. */ 2692fa122adaSdan if( ppInverted ){ 269391ddd559Sdan *ppInverted = 0; 269491ddd559Sdan *pnInverted = 0; 2695fa122adaSdan } 269691ddd559Sdan 2697fa122adaSdan while( 1 ){ 2698ef7a6304Sdan u8 eType; 2699fa122adaSdan 2700fa122adaSdan /* Test for EOF. */ 2701fa122adaSdan if( (rc = sessionInputBuffer(pInput, 2)) ) goto finished_invert; 2702fa122adaSdan if( pInput->iNext>=pInput->nData ) break; 2703fa122adaSdan eType = pInput->aData[pInput->iNext]; 2704fa122adaSdan 270591ddd559Sdan switch( eType ){ 270691ddd559Sdan case 'T': { 2707244593c8Sdan /* A 'table' record consists of: 2708244593c8Sdan ** 2709244593c8Sdan ** * A constant 'T' character, 2710244593c8Sdan ** * Number of columns in said table (a varint), 2711ef7a6304Sdan ** * An array of nCol bytes (sPK), 2712244593c8Sdan ** * A nul-terminated table name. 2713244593c8Sdan */ 2714ef7a6304Sdan int nByte; 2715fa122adaSdan int nVar; 2716fa122adaSdan pInput->iNext++; 2717fa122adaSdan if( (rc = sessionChangesetBufferTblhdr(pInput, &nByte)) ){ 2718ef7a6304Sdan goto finished_invert; 2719ef7a6304Sdan } 2720fa122adaSdan nVar = sessionVarintGet(&pInput->aData[pInput->iNext], &nCol); 2721ef7a6304Sdan sPK.nBuf = 0; 2722fa122adaSdan sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc); 2723fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2724fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2725ef7a6304Sdan if( rc ) goto finished_invert; 2726fa122adaSdan 2727fa122adaSdan pInput->iNext += nByte; 2728cfec7eeeSdan sqlite3_free(apVal); 2729cfec7eeeSdan apVal = 0; 2730ef7a6304Sdan abPK = sPK.aBuf; 273191ddd559Sdan break; 273291ddd559Sdan } 273391ddd559Sdan 273491ddd559Sdan case SQLITE_INSERT: 273591ddd559Sdan case SQLITE_DELETE: { 273691ddd559Sdan int nByte; 2737fa122adaSdan int bIndirect = pInput->aData[pInput->iNext+1]; 2738fa122adaSdan int eType2 = (eType==SQLITE_DELETE ? SQLITE_INSERT : SQLITE_DELETE); 2739fa122adaSdan pInput->iNext += 2; 2740fa122adaSdan assert( rc==SQLITE_OK ); 2741fa122adaSdan rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); 2742fa122adaSdan sessionAppendByte(&sOut, eType2, &rc); 2743fa122adaSdan sessionAppendByte(&sOut, bIndirect, &rc); 2744fa122adaSdan sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); 2745fa122adaSdan pInput->iNext += nByte; 2746fa122adaSdan if( rc ) goto finished_invert; 274791ddd559Sdan break; 274891ddd559Sdan } 274991ddd559Sdan 275091ddd559Sdan case SQLITE_UPDATE: { 2751cfec7eeeSdan int iCol; 275291ddd559Sdan 2753cfec7eeeSdan if( 0==apVal ){ 2754cfec7eeeSdan apVal = (sqlite3_value **)sqlite3_malloc(sizeof(apVal[0])*nCol*2); 2755cfec7eeeSdan if( 0==apVal ){ 2756cfec7eeeSdan rc = SQLITE_NOMEM; 2757cfec7eeeSdan goto finished_invert; 2758cfec7eeeSdan } 2759cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2760cfec7eeeSdan } 276191ddd559Sdan 2762cfec7eeeSdan /* Write the header for the new UPDATE change. Same as the original. */ 2763fa122adaSdan sessionAppendByte(&sOut, eType, &rc); 2764fa122adaSdan sessionAppendByte(&sOut, pInput->aData[pInput->iNext+1], &rc); 276591ddd559Sdan 2766ef7a6304Sdan /* Read the old.* and new.* records for the update change. */ 2767fa122adaSdan pInput->iNext += 2; 2768fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[0]); 2769ef7a6304Sdan if( rc==SQLITE_OK ){ 2770fa122adaSdan rc = sessionReadRecord(pInput, nCol, 0, &apVal[nCol]); 2771ef7a6304Sdan } 2772ef7a6304Sdan 2773cfec7eeeSdan /* Write the new old.* record. Consists of the PK columns from the 2774cfec7eeeSdan ** original old.* record, and the other values from the original 2775cfec7eeeSdan ** new.* record. */ 2776e8fa8c96Sdan for(iCol=0; iCol<nCol; iCol++){ 2777cfec7eeeSdan sqlite3_value *pVal = apVal[iCol + (abPK[iCol] ? 0 : nCol)]; 2778fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2779cfec7eeeSdan } 2780cfec7eeeSdan 2781cfec7eeeSdan /* Write the new new.* record. Consists of a copy of all values 2782cfec7eeeSdan ** from the original old.* record, except for the PK columns, which 2783cfec7eeeSdan ** are set to "undefined". */ 2784e8fa8c96Sdan for(iCol=0; iCol<nCol; iCol++){ 2785cfec7eeeSdan sqlite3_value *pVal = (abPK[iCol] ? 0 : apVal[iCol]); 2786fa122adaSdan sessionAppendValue(&sOut, pVal, &rc); 2787cfec7eeeSdan } 2788cfec7eeeSdan 2789cfec7eeeSdan for(iCol=0; iCol<nCol*2; iCol++){ 2790cfec7eeeSdan sqlite3ValueFree(apVal[iCol]); 2791cfec7eeeSdan } 2792cfec7eeeSdan memset(apVal, 0, sizeof(apVal[0])*nCol*2); 2793cfec7eeeSdan if( rc!=SQLITE_OK ){ 2794cfec7eeeSdan goto finished_invert; 2795cfec7eeeSdan } 2796cfec7eeeSdan 279791ddd559Sdan break; 279891ddd559Sdan } 279991ddd559Sdan 280091ddd559Sdan default: 28014757c658Sdan rc = SQLITE_CORRUPT_BKPT; 2802cfec7eeeSdan goto finished_invert; 280391ddd559Sdan } 2804fa122adaSdan 2805fa122adaSdan assert( rc==SQLITE_OK ); 2806f1a08ad8Sdrh if( xOutput && sOut.nBuf>=SESSIONS_STRM_CHUNK_SIZE ){ 2807fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2808fa122adaSdan sOut.nBuf = 0; 2809fa122adaSdan if( rc!=SQLITE_OK ) goto finished_invert; 2810fa122adaSdan } 281191ddd559Sdan } 281291ddd559Sdan 2813cfec7eeeSdan assert( rc==SQLITE_OK ); 2814fa122adaSdan if( pnInverted ){ 2815fa122adaSdan *pnInverted = sOut.nBuf; 2816fa122adaSdan *ppInverted = sOut.aBuf; 2817fa122adaSdan sOut.aBuf = 0; 2818fa122adaSdan }else if( sOut.nBuf>0 ){ 2819fa122adaSdan rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); 2820fa122adaSdan } 2821cfec7eeeSdan 2822cfec7eeeSdan finished_invert: 2823fa122adaSdan sqlite3_free(sOut.aBuf); 2824cfec7eeeSdan sqlite3_free(apVal); 2825ef7a6304Sdan sqlite3_free(sPK.aBuf); 2826cfec7eeeSdan return rc; 282791ddd559Sdan } 282891ddd559Sdan 2829fa122adaSdan 2830fa122adaSdan /* 2831fa122adaSdan ** Invert a changeset object. 2832fa122adaSdan */ 2833fa122adaSdan int sqlite3changeset_invert( 2834fa122adaSdan int nChangeset, /* Number of bytes in input */ 2835fa122adaSdan const void *pChangeset, /* Input changeset */ 2836fa122adaSdan int *pnInverted, /* OUT: Number of bytes in output changeset */ 2837fa122adaSdan void **ppInverted /* OUT: Inverse of pChangeset */ 2838fa122adaSdan ){ 2839fa122adaSdan SessionInput sInput; 2840fa122adaSdan 2841fa122adaSdan /* Set up the input stream */ 2842fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2843fa122adaSdan sInput.nData = nChangeset; 2844fa122adaSdan sInput.aData = (u8*)pChangeset; 2845fa122adaSdan 2846fa122adaSdan return sessionChangesetInvert(&sInput, 0, 0, pnInverted, ppInverted); 2847fa122adaSdan } 2848fa122adaSdan 2849fa122adaSdan /* 2850fa122adaSdan ** Streaming version of sqlite3changeset_invert(). 2851fa122adaSdan */ 2852f1a08ad8Sdrh int sqlite3changeset_invert_strm( 2853fa122adaSdan int (*xInput)(void *pIn, void *pData, int *pnData), 2854fa122adaSdan void *pIn, 2855fa122adaSdan int (*xOutput)(void *pOut, const void *pData, int nData), 2856fa122adaSdan void *pOut 2857fa122adaSdan ){ 2858fa122adaSdan SessionInput sInput; 2859fa122adaSdan int rc; 2860fa122adaSdan 2861fa122adaSdan /* Set up the input stream */ 2862fa122adaSdan memset(&sInput, 0, sizeof(SessionInput)); 2863fa122adaSdan sInput.xInput = xInput; 2864fa122adaSdan sInput.pIn = pIn; 2865fa122adaSdan 2866fa122adaSdan rc = sessionChangesetInvert(&sInput, xOutput, pOut, 0, 0); 2867fa122adaSdan sqlite3_free(sInput.buf.aBuf); 2868fa122adaSdan return rc; 2869fa122adaSdan } 2870fa122adaSdan 28710c698471Sdan typedef struct SessionApplyCtx SessionApplyCtx; 28720c698471Sdan struct SessionApplyCtx { 28730c698471Sdan sqlite3 *db; 28740c698471Sdan sqlite3_stmt *pDelete; /* DELETE statement */ 2875cfec7eeeSdan sqlite3_stmt *pUpdate; /* UPDATE statement */ 28760c698471Sdan sqlite3_stmt *pInsert; /* INSERT statement */ 28770c698471Sdan sqlite3_stmt *pSelect; /* SELECT statement */ 28780c698471Sdan int nCol; /* Size of azCol[] and abPK[] arrays */ 28790c698471Sdan const char **azCol; /* Array of column names */ 28800c698471Sdan u8 *abPK; /* Boolean array - true if column is in PK */ 28810c698471Sdan }; 28820c698471Sdan 2883d5f0767cSdan /* 2884d5f0767cSdan ** Formulate a statement to DELETE a row from database db. Assuming a table 2885d5f0767cSdan ** structure like this: 2886d5f0767cSdan ** 2887d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2888d5f0767cSdan ** 2889d5f0767cSdan ** The DELETE statement looks like this: 2890d5f0767cSdan ** 2891db04571cSdan ** DELETE FROM x WHERE a = :1 AND c = :3 AND (:5 OR b IS :2 AND d IS :4) 2892d5f0767cSdan ** 2893d5f0767cSdan ** Variable :5 (nCol+1) is a boolean. It should be set to 0 if we require 2894d5f0767cSdan ** matching b and d values, or 1 otherwise. The second case comes up if the 2895d5f0767cSdan ** conflict handler is invoked with NOTFOUND and returns CHANGESET_REPLACE. 2896296c7658Sdan ** 2897296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pDelete is left 2898296c7658Sdan ** pointing to the prepared version of the SQL statement. 2899d5f0767cSdan */ 2900d5f0767cSdan static int sessionDeleteRow( 2901d5f0767cSdan sqlite3 *db, /* Database handle */ 2902d5f0767cSdan const char *zTab, /* Table name */ 29030c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2904d5f0767cSdan ){ 2905296c7658Sdan int i; 2906296c7658Sdan const char *zSep = ""; 2907d5f0767cSdan int rc = SQLITE_OK; 2908d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 29097cf7df7dSdan int nPk = 0; 2910d5f0767cSdan 2911d5f0767cSdan sessionAppendStr(&buf, "DELETE FROM ", &rc); 2912d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2913296c7658Sdan sessionAppendStr(&buf, " WHERE ", &rc); 2914296c7658Sdan 2915296c7658Sdan for(i=0; i<p->nCol; i++){ 2916296c7658Sdan if( p->abPK[i] ){ 29177cf7df7dSdan nPk++; 2918296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2919296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2920296c7658Sdan sessionAppendStr(&buf, " = ?", &rc); 2921296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2922296c7658Sdan zSep = " AND "; 2923296c7658Sdan } 2924296c7658Sdan } 2925296c7658Sdan 29267cf7df7dSdan if( nPk<p->nCol ){ 2927296c7658Sdan sessionAppendStr(&buf, " AND (?", &rc); 2928296c7658Sdan sessionAppendInteger(&buf, p->nCol+1, &rc); 2929296c7658Sdan sessionAppendStr(&buf, " OR ", &rc); 2930296c7658Sdan 2931296c7658Sdan zSep = ""; 2932296c7658Sdan for(i=0; i<p->nCol; i++){ 2933296c7658Sdan if( !p->abPK[i] ){ 2934296c7658Sdan sessionAppendStr(&buf, zSep, &rc); 2935296c7658Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 2936296c7658Sdan sessionAppendStr(&buf, " IS ?", &rc); 2937296c7658Sdan sessionAppendInteger(&buf, i+1, &rc); 2938296c7658Sdan zSep = "AND "; 2939296c7658Sdan } 2940296c7658Sdan } 2941296c7658Sdan sessionAppendStr(&buf, ")", &rc); 29427cf7df7dSdan } 2943d5f0767cSdan 2944d5f0767cSdan if( rc==SQLITE_OK ){ 29450c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); 2946d5f0767cSdan } 2947d5f0767cSdan sqlite3_free(buf.aBuf); 2948d5f0767cSdan 2949d5f0767cSdan return rc; 2950d5f0767cSdan } 2951d5f0767cSdan 2952d5f0767cSdan /* 2953d5f0767cSdan ** Formulate and prepare a statement to UPDATE a row from database db. 2954d5f0767cSdan ** Assuming a table structure like this: 2955d5f0767cSdan ** 2956d5f0767cSdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 2957d5f0767cSdan ** 2958d5f0767cSdan ** The UPDATE statement looks like this: 2959d5f0767cSdan ** 2960d5f0767cSdan ** UPDATE x SET 2961d5f0767cSdan ** a = CASE WHEN ?2 THEN ?3 ELSE a END, 2962964cbd46Sdan ** b = CASE WHEN ?5 THEN ?6 ELSE b END, 2963964cbd46Sdan ** c = CASE WHEN ?8 THEN ?9 ELSE c END, 2964964cbd46Sdan ** d = CASE WHEN ?11 THEN ?12 ELSE d END 2965d5f0767cSdan ** WHERE a = ?1 AND c = ?7 AND (?13 OR 2966964cbd46Sdan ** (?5==0 OR b IS ?4) AND (?11==0 OR d IS ?10) AND 2967d5f0767cSdan ** ) 2968d5f0767cSdan ** 2969d5f0767cSdan ** For each column in the table, there are three variables to bind: 2970d5f0767cSdan ** 2971d5f0767cSdan ** ?(i*3+1) The old.* value of the column, if any. 2972d5f0767cSdan ** ?(i*3+2) A boolean flag indicating that the value is being modified. 2973d5f0767cSdan ** ?(i*3+3) The new.* value of the column, if any. 2974d5f0767cSdan ** 2975d5f0767cSdan ** Also, a boolean flag that, if set to true, causes the statement to update 2976d5f0767cSdan ** a row even if the non-PK values do not match. This is required if the 2977d5f0767cSdan ** conflict-handler is invoked with CHANGESET_DATA and returns 2978d5f0767cSdan ** CHANGESET_REPLACE. This is variable "?(nCol*3+1)". 2979d5f0767cSdan ** 2980296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pUpdate is left 2981296c7658Sdan ** pointing to the prepared version of the SQL statement. 2982d5f0767cSdan */ 2983d5f0767cSdan static int sessionUpdateRow( 2984d5f0767cSdan sqlite3 *db, /* Database handle */ 2985d5f0767cSdan const char *zTab, /* Table name */ 29860c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 2987d5f0767cSdan ){ 2988d5f0767cSdan int rc = SQLITE_OK; 2989d5f0767cSdan int i; 2990d5f0767cSdan const char *zSep = ""; 2991d5f0767cSdan SessionBuffer buf = {0, 0, 0}; 2992d5f0767cSdan 2993d5f0767cSdan /* Append "UPDATE tbl SET " */ 2994d5f0767cSdan sessionAppendStr(&buf, "UPDATE ", &rc); 2995d5f0767cSdan sessionAppendIdent(&buf, zTab, &rc); 2996d5f0767cSdan sessionAppendStr(&buf, " SET ", &rc); 2997d5f0767cSdan 2998d5f0767cSdan /* Append the assignments */ 29990c698471Sdan for(i=0; i<p->nCol; i++){ 3000d5f0767cSdan sessionAppendStr(&buf, zSep, &rc); 30010c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3002d5f0767cSdan sessionAppendStr(&buf, " = CASE WHEN ?", &rc); 3003d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 3004d5f0767cSdan sessionAppendStr(&buf, " THEN ?", &rc); 3005d5f0767cSdan sessionAppendInteger(&buf, i*3+3, &rc); 3006d5f0767cSdan sessionAppendStr(&buf, " ELSE ", &rc); 30070c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3008d5f0767cSdan sessionAppendStr(&buf, " END", &rc); 3009d5f0767cSdan zSep = ", "; 3010d5f0767cSdan } 3011d5f0767cSdan 3012d5f0767cSdan /* Append the PK part of the WHERE clause */ 3013d5f0767cSdan sessionAppendStr(&buf, " WHERE ", &rc); 30140c698471Sdan for(i=0; i<p->nCol; i++){ 30150c698471Sdan if( p->abPK[i] ){ 30160c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3017d5f0767cSdan sessionAppendStr(&buf, " = ?", &rc); 3018d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3019d5f0767cSdan sessionAppendStr(&buf, " AND ", &rc); 3020d5f0767cSdan } 3021d5f0767cSdan } 3022d5f0767cSdan 3023d5f0767cSdan /* Append the non-PK part of the WHERE clause */ 3024d5f0767cSdan sessionAppendStr(&buf, " (?", &rc); 30250c698471Sdan sessionAppendInteger(&buf, p->nCol*3+1, &rc); 3026d5f0767cSdan sessionAppendStr(&buf, " OR 1", &rc); 30270c698471Sdan for(i=0; i<p->nCol; i++){ 30280c698471Sdan if( !p->abPK[i] ){ 3029d5f0767cSdan sessionAppendStr(&buf, " AND (?", &rc); 3030d5f0767cSdan sessionAppendInteger(&buf, i*3+2, &rc); 3031d5f0767cSdan sessionAppendStr(&buf, "=0 OR ", &rc); 30320c698471Sdan sessionAppendIdent(&buf, p->azCol[i], &rc); 3033d5f0767cSdan sessionAppendStr(&buf, " IS ?", &rc); 3034d5f0767cSdan sessionAppendInteger(&buf, i*3+1, &rc); 3035d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3036d5f0767cSdan } 3037d5f0767cSdan } 3038d5f0767cSdan sessionAppendStr(&buf, ")", &rc); 3039d5f0767cSdan 3040d5f0767cSdan if( rc==SQLITE_OK ){ 30410c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pUpdate, 0); 3042d5f0767cSdan } 3043d5f0767cSdan sqlite3_free(buf.aBuf); 3044d5f0767cSdan 3045d5f0767cSdan return rc; 3046d5f0767cSdan } 3047d5f0767cSdan 3048296c7658Sdan /* 3049296c7658Sdan ** Formulate and prepare an SQL statement to query table zTab by primary 3050296c7658Sdan ** key. Assuming the following table structure: 3051296c7658Sdan ** 3052296c7658Sdan ** CREATE TABLE x(a, b, c, d, PRIMARY KEY(a, c)); 3053296c7658Sdan ** 3054296c7658Sdan ** The SELECT statement looks like this: 3055296c7658Sdan ** 3056296c7658Sdan ** SELECT * FROM x WHERE a = ?1 AND c = ?3 3057296c7658Sdan ** 3058296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pSelect is left 3059296c7658Sdan ** pointing to the prepared version of the SQL statement. 3060296c7658Sdan */ 3061d5f0767cSdan static int sessionSelectRow( 3062d5f0767cSdan sqlite3 *db, /* Database handle */ 3063d5f0767cSdan const char *zTab, /* Table name */ 30640c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 3065d5f0767cSdan ){ 3066d7fb7d24Sdan return sessionSelectStmt( 3067d7fb7d24Sdan db, "main", zTab, p->nCol, p->azCol, p->abPK, &p->pSelect); 3068d5f0767cSdan } 3069d5f0767cSdan 3070296c7658Sdan /* 3071296c7658Sdan ** Formulate and prepare an INSERT statement to add a record to table zTab. 3072296c7658Sdan ** For example: 3073296c7658Sdan ** 3074296c7658Sdan ** INSERT INTO main."zTab" VALUES(?1, ?2, ?3 ...); 3075296c7658Sdan ** 3076296c7658Sdan ** If successful, SQLITE_OK is returned and SessionApplyCtx.pInsert is left 3077296c7658Sdan ** pointing to the prepared version of the SQL statement. 3078296c7658Sdan */ 30790c698471Sdan static int sessionInsertRow( 30800c698471Sdan sqlite3 *db, /* Database handle */ 30810c698471Sdan const char *zTab, /* Table name */ 30820c698471Sdan SessionApplyCtx *p /* Session changeset-apply context */ 30830c698471Sdan ){ 30840c698471Sdan int rc = SQLITE_OK; 30850c698471Sdan int i; 30860c698471Sdan SessionBuffer buf = {0, 0, 0}; 30870c698471Sdan 30880c698471Sdan sessionAppendStr(&buf, "INSERT INTO main.", &rc); 30890c698471Sdan sessionAppendIdent(&buf, zTab, &rc); 30900c698471Sdan sessionAppendStr(&buf, " VALUES(?", &rc); 30910c698471Sdan for(i=1; i<p->nCol; i++){ 30920c698471Sdan sessionAppendStr(&buf, ", ?", &rc); 30930c698471Sdan } 30940c698471Sdan sessionAppendStr(&buf, ")", &rc); 30950c698471Sdan 30960c698471Sdan if( rc==SQLITE_OK ){ 30970c698471Sdan rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); 30980c698471Sdan } 30990c698471Sdan sqlite3_free(buf.aBuf); 31000c698471Sdan return rc; 31010c698471Sdan } 31020c698471Sdan 3103296c7658Sdan /* 31047aa469cdSdan ** A wrapper around sqlite3_bind_value() that detects an extra problem. 31057aa469cdSdan ** See comments in the body of this function for details. 31067aa469cdSdan */ 31077aa469cdSdan static int sessionBindValue( 31087aa469cdSdan sqlite3_stmt *pStmt, /* Statement to bind value to */ 31097aa469cdSdan int i, /* Parameter number to bind to */ 31107aa469cdSdan sqlite3_value *pVal /* Value to bind */ 31117aa469cdSdan ){ 31125671ef69Sdrh int eType = sqlite3_value_type(pVal); 3113082c96dfSdan /* COVERAGE: The (pVal->z==0) branch is never true using current versions 3114082c96dfSdan ** of SQLite. If a malloc fails in an sqlite3_value_xxx() function, either 3115082c96dfSdan ** the (pVal->z) variable remains as it was or the type of the value is 3116082c96dfSdan ** set to SQLITE_NULL. */ 31175671ef69Sdrh if( (eType==SQLITE_TEXT || eType==SQLITE_BLOB) && pVal->z==0 ){ 31187aa469cdSdan /* This condition occurs when an earlier OOM in a call to 31197aa469cdSdan ** sqlite3_value_text() or sqlite3_value_blob() (perhaps from within 3120082c96dfSdan ** a conflict-handler) has zeroed the pVal->z pointer. Return NOMEM. */ 31217aa469cdSdan return SQLITE_NOMEM; 31227aa469cdSdan } 31237aa469cdSdan return sqlite3_bind_value(pStmt, i, pVal); 31247aa469cdSdan } 31257aa469cdSdan 31267aa469cdSdan /* 3127db04571cSdan ** Iterator pIter must point to an SQLITE_INSERT entry. This function 3128db04571cSdan ** transfers new.* values from the current iterator entry to statement 3129db04571cSdan ** pStmt. The table being inserted into has nCol columns. 3130db04571cSdan ** 3131db04571cSdan ** New.* value $i 0 from the iterator is bound to variable ($i+1) of 3132db04571cSdan ** statement pStmt. If parameter abPK is NULL, all values from 0 to (nCol-1) 3133db04571cSdan ** are transfered to the statement. Otherwise, if abPK is not NULL, it points 3134db04571cSdan ** to an array nCol elements in size. In this case only those values for 3135db04571cSdan ** which abPK[$i] is true are read from the iterator and bound to the 3136db04571cSdan ** statement. 3137db04571cSdan ** 3138db04571cSdan ** An SQLite error code is returned if an error occurs. Otherwise, SQLITE_OK. 3139db04571cSdan */ 31407aa469cdSdan static int sessionBindRow( 3141db04571cSdan sqlite3_changeset_iter *pIter, /* Iterator to read values from */ 31427aa469cdSdan int(*xValue)(sqlite3_changeset_iter *, int, sqlite3_value **), 3143db04571cSdan int nCol, /* Number of columns */ 3144db04571cSdan u8 *abPK, /* If not NULL, bind only if true */ 3145db04571cSdan sqlite3_stmt *pStmt /* Bind values to this statement */ 3146db04571cSdan ){ 3147db04571cSdan int i; 3148db04571cSdan int rc = SQLITE_OK; 31497aa469cdSdan 31507aa469cdSdan /* Neither sqlite3changeset_old or sqlite3changeset_new can fail if the 31517aa469cdSdan ** argument iterator points to a suitable entry. Make sure that xValue 31527aa469cdSdan ** is one of these to guarantee that it is safe to ignore the return 31537aa469cdSdan ** in the code below. */ 31547aa469cdSdan assert( xValue==sqlite3changeset_old || xValue==sqlite3changeset_new ); 31557aa469cdSdan 3156db04571cSdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 3157db04571cSdan if( !abPK || abPK[i] ){ 3158db04571cSdan sqlite3_value *pVal; 31597aa469cdSdan (void)xValue(pIter, i, &pVal); 31607aa469cdSdan rc = sessionBindValue(pStmt, i+1, pVal); 3161db04571cSdan } 3162db04571cSdan } 3163db04571cSdan return rc; 3164db04571cSdan } 3165db04571cSdan 3166db04571cSdan /* 3167296c7658Sdan ** SQL statement pSelect is as generated by the sessionSelectRow() function. 3168296c7658Sdan ** This function binds the primary key values from the change that changeset 3169296c7658Sdan ** iterator pIter points to to the SELECT and attempts to seek to the table 3170296c7658Sdan ** entry. If a row is found, the SELECT statement left pointing at the row 3171296c7658Sdan ** and SQLITE_ROW is returned. Otherwise, if no row is found and no error 3172296c7658Sdan ** has occured, the statement is reset and SQLITE_OK is returned. If an 31737aa469cdSdan ** error occurs, the statement is reset and an SQLite error code is returned. 31747aa469cdSdan ** 31757aa469cdSdan ** If this function returns SQLITE_ROW, the caller must eventually reset() 31767aa469cdSdan ** statement pSelect. If any other value is returned, the statement does 31777aa469cdSdan ** not require a reset(). 3178296c7658Sdan ** 3179296c7658Sdan ** If the iterator currently points to an INSERT record, bind values from the 3180db04571cSdan ** new.* record to the SELECT statement. Or, if it points to a DELETE or 3181db04571cSdan ** UPDATE, bind values from the old.* record. 3182296c7658Sdan */ 31830c698471Sdan static int sessionSeekToRow( 318437f133ecSdan sqlite3 *db, /* Database handle */ 318537f133ecSdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 318637f133ecSdan u8 *abPK, /* Primary key flags array */ 31870c698471Sdan sqlite3_stmt *pSelect /* SELECT statement from sessionSelectRow() */ 318837f133ecSdan ){ 31897aa469cdSdan int rc; /* Return code */ 3190296c7658Sdan int nCol; /* Number of columns in table */ 3191296c7658Sdan int op; /* Changset operation (SQLITE_UPDATE etc.) */ 3192296c7658Sdan const char *zDummy; /* Unused */ 319337f133ecSdan 3194b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 31957aa469cdSdan rc = sessionBindRow(pIter, 3196db04571cSdan op==SQLITE_INSERT ? sqlite3changeset_new : sqlite3changeset_old, 3197db04571cSdan nCol, abPK, pSelect 3198db04571cSdan ); 31990c698471Sdan 32000c698471Sdan if( rc==SQLITE_OK ){ 32010c698471Sdan rc = sqlite3_step(pSelect); 32020c698471Sdan if( rc!=SQLITE_ROW ) rc = sqlite3_reset(pSelect); 32030c698471Sdan } 32040c698471Sdan 32050c698471Sdan return rc; 32060c698471Sdan } 32070c698471Sdan 3208296c7658Sdan /* 3209296c7658Sdan ** Invoke the conflict handler for the change that the changeset iterator 3210296c7658Sdan ** currently points to. 3211296c7658Sdan ** 3212296c7658Sdan ** Argument eType must be either CHANGESET_DATA or CHANGESET_CONFLICT. 3213296c7658Sdan ** If argument pbReplace is NULL, then the type of conflict handler invoked 3214296c7658Sdan ** depends solely on eType, as follows: 3215296c7658Sdan ** 3216296c7658Sdan ** eType value Value passed to xConflict 3217296c7658Sdan ** ------------------------------------------------- 3218296c7658Sdan ** CHANGESET_DATA CHANGESET_NOTFOUND 3219296c7658Sdan ** CHANGESET_CONFLICT CHANGESET_CONSTRAINT 3220296c7658Sdan ** 3221296c7658Sdan ** Or, if pbReplace is not NULL, then an attempt is made to find an existing 3222296c7658Sdan ** record with the same primary key as the record about to be deleted, updated 3223296c7658Sdan ** or inserted. If such a record can be found, it is available to the conflict 3224296c7658Sdan ** handler as the "conflicting" record. In this case the type of conflict 3225296c7658Sdan ** handler invoked is as follows: 3226296c7658Sdan ** 3227296c7658Sdan ** eType value PK Record found? Value passed to xConflict 3228296c7658Sdan ** ---------------------------------------------------------------- 3229296c7658Sdan ** CHANGESET_DATA Yes CHANGESET_DATA 3230296c7658Sdan ** CHANGESET_DATA No CHANGESET_NOTFOUND 3231296c7658Sdan ** CHANGESET_CONFLICT Yes CHANGESET_CONFLICT 3232296c7658Sdan ** CHANGESET_CONFLICT No CHANGESET_CONSTRAINT 3233296c7658Sdan ** 3234296c7658Sdan ** If pbReplace is not NULL, and a record with a matching PK is found, and 3235296c7658Sdan ** the conflict handler function returns SQLITE_CHANGESET_REPLACE, *pbReplace 3236296c7658Sdan ** is set to non-zero before returning SQLITE_OK. 3237296c7658Sdan ** 3238296c7658Sdan ** If the conflict handler returns SQLITE_CHANGESET_ABORT, SQLITE_ABORT is 3239296c7658Sdan ** returned. Or, if the conflict handler returns an invalid value, 3240296c7658Sdan ** SQLITE_MISUSE. If the conflict handler returns SQLITE_CHANGESET_OMIT, 3241296c7658Sdan ** this function returns SQLITE_OK. 3242296c7658Sdan */ 32430c698471Sdan static int sessionConflictHandler( 3244296c7658Sdan int eType, /* Either CHANGESET_DATA or CONFLICT */ 3245296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 32460c698471Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 32470c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter*), 3248296c7658Sdan void *pCtx, /* First argument for conflict handler */ 3249296c7658Sdan int *pbReplace /* OUT: Set to true if PK row is found */ 32500c698471Sdan ){ 3251296c7658Sdan int res; /* Value returned by conflict handler */ 32520c698471Sdan int rc; 32530c698471Sdan int nCol; 32540c698471Sdan int op; 32550c698471Sdan const char *zDummy; 32560c698471Sdan 3257b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 32580c698471Sdan 32590c698471Sdan assert( eType==SQLITE_CHANGESET_CONFLICT || eType==SQLITE_CHANGESET_DATA ); 32600c698471Sdan assert( SQLITE_CHANGESET_CONFLICT+1==SQLITE_CHANGESET_CONSTRAINT ); 32610c698471Sdan assert( SQLITE_CHANGESET_DATA+1==SQLITE_CHANGESET_NOTFOUND ); 326237f133ecSdan 326337f133ecSdan /* Bind the new.* PRIMARY KEY values to the SELECT statement. */ 32640c698471Sdan if( pbReplace ){ 32650c698471Sdan rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); 32660c698471Sdan }else{ 3267db04571cSdan rc = SQLITE_OK; 32680c698471Sdan } 32690c698471Sdan 32700c698471Sdan if( rc==SQLITE_ROW ){ 32710c698471Sdan /* There exists another row with the new.* primary key. */ 32720c698471Sdan pIter->pConflict = p->pSelect; 32730c698471Sdan res = xConflict(pCtx, eType, pIter); 32740c698471Sdan pIter->pConflict = 0; 32750c698471Sdan rc = sqlite3_reset(p->pSelect); 3276db04571cSdan }else if( rc==SQLITE_OK ){ 32770c698471Sdan /* No other row with the new.* primary key. */ 32780c698471Sdan res = xConflict(pCtx, eType+1, pIter); 32790c698471Sdan if( res==SQLITE_CHANGESET_REPLACE ) rc = SQLITE_MISUSE; 328037f133ecSdan } 328137f133ecSdan 328237f133ecSdan if( rc==SQLITE_OK ){ 32830c698471Sdan switch( res ){ 32840c698471Sdan case SQLITE_CHANGESET_REPLACE: 3285f51e5f6cSdan assert( pbReplace ); 3286f51e5f6cSdan *pbReplace = 1; 32870c698471Sdan break; 32880c698471Sdan 32890c698471Sdan case SQLITE_CHANGESET_OMIT: 32900c698471Sdan break; 32910c698471Sdan 32920c698471Sdan case SQLITE_CHANGESET_ABORT: 32930c698471Sdan rc = SQLITE_ABORT; 32940c698471Sdan break; 32950c698471Sdan 32960c698471Sdan default: 32970c698471Sdan rc = SQLITE_MISUSE; 32980c698471Sdan break; 32990c698471Sdan } 33000c698471Sdan } 33010c698471Sdan 33020c698471Sdan return rc; 33030c698471Sdan } 33040c698471Sdan 3305296c7658Sdan /* 3306296c7658Sdan ** Attempt to apply the change that the iterator passed as the first argument 3307296c7658Sdan ** currently points to to the database. If a conflict is encountered, invoke 3308296c7658Sdan ** the conflict handler callback. 3309296c7658Sdan ** 3310296c7658Sdan ** If argument pbRetry is NULL, then ignore any CHANGESET_DATA conflict. If 3311296c7658Sdan ** one is encountered, update or delete the row with the matching primary key 3312296c7658Sdan ** instead. Or, if pbRetry is not NULL and a CHANGESET_DATA conflict occurs, 3313296c7658Sdan ** invoke the conflict handler. If it returns CHANGESET_REPLACE, set *pbRetry 3314296c7658Sdan ** to true before returning. In this case the caller will invoke this function 3315296c7658Sdan ** again, this time with pbRetry set to NULL. 3316296c7658Sdan ** 3317296c7658Sdan ** If argument pbReplace is NULL and a CHANGESET_CONFLICT conflict is 3318296c7658Sdan ** encountered invoke the conflict handler with CHANGESET_CONSTRAINT instead. 3319296c7658Sdan ** Or, if pbReplace is not NULL, invoke it with CHANGESET_CONFLICT. If such 3320296c7658Sdan ** an invocation returns SQLITE_CHANGESET_REPLACE, set *pbReplace to true 3321296c7658Sdan ** before retrying. In this case the caller attempts to remove the conflicting 3322296c7658Sdan ** row before invoking this function again, this time with pbReplace set 3323296c7658Sdan ** to NULL. 3324296c7658Sdan ** 3325296c7658Sdan ** If any conflict handler returns SQLITE_CHANGESET_ABORT, this function 3326296c7658Sdan ** returns SQLITE_ABORT. Otherwise, if no error occurs, SQLITE_OK is 3327296c7658Sdan ** returned. 3328296c7658Sdan */ 33290c698471Sdan static int sessionApplyOneOp( 3330296c7658Sdan sqlite3_changeset_iter *pIter, /* Changeset iterator */ 3331296c7658Sdan SessionApplyCtx *p, /* changeset_apply() context */ 33320c698471Sdan int(*xConflict)(void *, int, sqlite3_changeset_iter *), 3333296c7658Sdan void *pCtx, /* First argument for the conflict handler */ 3334296c7658Sdan int *pbReplace, /* OUT: True to remove PK row and retry */ 3335296c7658Sdan int *pbRetry /* OUT: True to retry. */ 33360c698471Sdan ){ 33370c698471Sdan const char *zDummy; 33380c698471Sdan int op; 33390c698471Sdan int nCol; 33400c698471Sdan int rc = SQLITE_OK; 33410c698471Sdan 33420c698471Sdan assert( p->pDelete && p->pUpdate && p->pInsert && p->pSelect ); 33430c698471Sdan assert( p->azCol && p->abPK ); 33440c698471Sdan assert( !pbReplace || *pbReplace==0 ); 33450c698471Sdan 3346b4480e94Sdan sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); 33470c698471Sdan 33480c698471Sdan if( op==SQLITE_DELETE ){ 33490c698471Sdan 335073b3c055Sdan /* Bind values to the DELETE statement. If conflict handling is required, 335173b3c055Sdan ** bind values for all columns and set bound variable (nCol+1) to true. 335273b3c055Sdan ** Or, if conflict handling is not required, bind just the PK column 335373b3c055Sdan ** values and, if it exists, set (nCol+1) to false. Conflict handling 335473b3c055Sdan ** is not required if: 335573b3c055Sdan ** 335673b3c055Sdan ** * this is a patchset, or 335773b3c055Sdan ** * (pbRetry==0), or 335873b3c055Sdan ** * all columns of the table are PK columns (in this case there is 335973b3c055Sdan ** no (nCol+1) variable to bind to). 336073b3c055Sdan */ 336173b3c055Sdan u8 *abPK = (pIter->bPatchset ? p->abPK : 0); 336273b3c055Sdan rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); 33637cf7df7dSdan if( rc==SQLITE_OK && sqlite3_bind_parameter_count(p->pDelete)>nCol ){ 336473b3c055Sdan rc = sqlite3_bind_int(p->pDelete, nCol+1, (pbRetry==0 || abPK)); 33657cf7df7dSdan } 33660c698471Sdan if( rc!=SQLITE_OK ) return rc; 33670c698471Sdan 33680c698471Sdan sqlite3_step(p->pDelete); 33690c698471Sdan rc = sqlite3_reset(p->pDelete); 33700c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 33710c698471Sdan rc = sessionConflictHandler( 33720c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 33730c698471Sdan ); 337435e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 33750c698471Sdan rc = sessionConflictHandler( 33760c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 33770c698471Sdan ); 33780c698471Sdan } 33790c698471Sdan 33800c698471Sdan }else if( op==SQLITE_UPDATE ){ 33810c698471Sdan int i; 33820c698471Sdan 33830c698471Sdan /* Bind values to the UPDATE statement. */ 33840c698471Sdan for(i=0; rc==SQLITE_OK && i<nCol; i++){ 33857aa469cdSdan sqlite3_value *pOld = sessionChangesetOld(pIter, i); 33867aa469cdSdan sqlite3_value *pNew = sessionChangesetNew(pIter, i); 33877aa469cdSdan 33880c698471Sdan sqlite3_bind_int(p->pUpdate, i*3+2, !!pNew); 33897aa469cdSdan if( pOld ){ 33907aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+1, pOld); 33917aa469cdSdan } 33927aa469cdSdan if( rc==SQLITE_OK && pNew ){ 33937aa469cdSdan rc = sessionBindValue(p->pUpdate, i*3+3, pNew); 33940c698471Sdan } 33950c698471Sdan } 339673b3c055Sdan if( rc==SQLITE_OK ){ 339773b3c055Sdan sqlite3_bind_int(p->pUpdate, nCol*3+1, pbRetry==0 || pIter->bPatchset); 339873b3c055Sdan } 33990c698471Sdan if( rc!=SQLITE_OK ) return rc; 34000c698471Sdan 34010c698471Sdan /* Attempt the UPDATE. In the case of a NOTFOUND or DATA conflict, 34020c698471Sdan ** the result will be SQLITE_OK with 0 rows modified. */ 34030c698471Sdan sqlite3_step(p->pUpdate); 34040c698471Sdan rc = sqlite3_reset(p->pUpdate); 34050c698471Sdan 34060c698471Sdan if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ 34070c698471Sdan /* A NOTFOUND or DATA error. Search the table to see if it contains 34080c698471Sdan ** a row with a matching primary key. If so, this is a DATA conflict. 34090c698471Sdan ** Otherwise, if there is no primary key match, it is a NOTFOUND. */ 34100c698471Sdan 34110c698471Sdan rc = sessionConflictHandler( 34120c698471Sdan SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry 34130c698471Sdan ); 34140c698471Sdan 341535e2858eSdan }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ 3416db04571cSdan /* This is always a CONSTRAINT conflict. */ 3417db04571cSdan rc = sessionConflictHandler( 3418db04571cSdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 34190c698471Sdan ); 34200c698471Sdan } 34210c698471Sdan 34220c698471Sdan }else{ 34230c698471Sdan assert( op==SQLITE_INSERT ); 34247aa469cdSdan rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); 34250c698471Sdan if( rc!=SQLITE_OK ) return rc; 34260c698471Sdan 34270c698471Sdan sqlite3_step(p->pInsert); 34280c698471Sdan rc = sqlite3_reset(p->pInsert); 342935e2858eSdan if( (rc&0xff)==SQLITE_CONSTRAINT ){ 34300c698471Sdan rc = sessionConflictHandler( 34310c698471Sdan SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, pbReplace 34320c698471Sdan ); 343337f133ecSdan } 343437f133ecSdan } 343537f133ecSdan 343637f133ecSdan return rc; 343737f133ecSdan } 343837f133ecSdan 3439296c7658Sdan /* 34404757c658Sdan ** Argument pIter is a changeset iterator that has been initialized, but 34414757c658Sdan ** not yet passed to sqlite3changeset_next(). This function applies the 34424757c658Sdan ** changeset to the main database attached to handle "db". The supplied 34434757c658Sdan ** conflict handler callback is invoked to resolve any conflicts encountered 34444757c658Sdan ** while applying the change. 3445296c7658Sdan */ 34464757c658Sdan static int sessionChangesetApply( 3447296c7658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 34484757c658Sdan sqlite3_changeset_iter *pIter, /* Changeset to apply */ 344940368988Sdan int(*xFilter)( 345040368988Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 345140368988Sdan const char *zTab /* Table name */ 345240368988Sdan ), 3453d5f0767cSdan int(*xConflict)( 3454d5f0767cSdan void *pCtx, /* Copy of fifth arg to _apply() */ 3455d5f0767cSdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 3456d5f0767cSdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 3457d5f0767cSdan ), 3458296c7658Sdan void *pCtx /* First argument passed to xConflict */ 3459d5f0767cSdan ){ 3460ca62ad57Sdan int schemaMismatch = 0; 3461296c7658Sdan int rc; /* Return code */ 3462d5f0767cSdan const char *zTab = 0; /* Name of current table */ 3463cfdbde21Sdrh int nTab = 0; /* Result of sqlite3Strlen30(zTab) */ 3464296c7658Sdan SessionApplyCtx sApply; /* changeset_apply() context object */ 3465d5f0767cSdan 3466082c96dfSdan assert( xConflict!=0 ); 3467082c96dfSdan 34680c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34694c220252Sdan sqlite3_mutex_enter(sqlite3_db_mutex(db)); 34700c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT changeset_apply", 0, 0, 0); 3471cb3e4b79Sdan if( rc==SQLITE_OK ){ 3472cb3e4b79Sdan rc = sqlite3_exec(db, "PRAGMA defer_foreign_keys = 1", 0, 0, 0); 3473cb3e4b79Sdan } 34740c698471Sdan while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter) ){ 34750c698471Sdan int nCol; 3476d5f0767cSdan int op; 34770c698471Sdan int bReplace = 0; 34780c698471Sdan int bRetry = 0; 34790c698471Sdan const char *zNew; 3480ca62ad57Sdan 3481b4480e94Sdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); 3482d5f0767cSdan 34830c698471Sdan if( zTab==0 || sqlite3_strnicmp(zNew, zTab, nTab+1) ){ 3484ca62ad57Sdan u8 *abPK; 3485ca62ad57Sdan 3486cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 34870c698471Sdan sqlite3_finalize(sApply.pDelete); 34880c698471Sdan sqlite3_finalize(sApply.pUpdate); 34890c698471Sdan sqlite3_finalize(sApply.pInsert); 34900c698471Sdan sqlite3_finalize(sApply.pSelect); 34910c698471Sdan memset(&sApply, 0, sizeof(sApply)); 34920c698471Sdan sApply.db = db; 349337f133ecSdan 349440368988Sdan /* If an xFilter() callback was specified, invoke it now. If the 349540368988Sdan ** xFilter callback returns zero, skip this table. If it returns 349640368988Sdan ** non-zero, proceed. */ 349740368988Sdan schemaMismatch = (xFilter && (0==xFilter(pCtx, zNew))); 349840368988Sdan if( schemaMismatch ){ 349940368988Sdan zTab = sqlite3_mprintf("%s", zNew); 3500f05ac112Sdan if( zTab==0 ){ 3501f05ac112Sdan rc = SQLITE_NOMEM; 3502f05ac112Sdan break; 3503f05ac112Sdan } 35044f528042Sdan nTab = (int)strlen(zTab); 350540368988Sdan sApply.azCol = (const char **)zTab; 350640368988Sdan }else{ 3507ca62ad57Sdan sqlite3changeset_pk(pIter, &abPK, 0); 3508296c7658Sdan rc = sessionTableInfo( 3509ca62ad57Sdan db, "main", zNew, &sApply.nCol, &zTab, &sApply.azCol, &sApply.abPK 3510ca62ad57Sdan ); 3511ca62ad57Sdan if( rc!=SQLITE_OK ) break; 35120c698471Sdan 3513ca62ad57Sdan if( sApply.nCol==0 ){ 3514ca62ad57Sdan schemaMismatch = 1; 3515ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3516ca62ad57Sdan "sqlite3changeset_apply(): no such table: %s", zTab 3517ca62ad57Sdan ); 3518ca62ad57Sdan } 3519ca62ad57Sdan else if( sApply.nCol!=nCol ){ 3520ca62ad57Sdan schemaMismatch = 1; 3521ca62ad57Sdan sqlite3_log(SQLITE_SCHEMA, 3522ca62ad57Sdan "sqlite3changeset_apply(): table %s has %d columns, expected %d", 3523ca62ad57Sdan zTab, sApply.nCol, nCol 3524ca62ad57Sdan ); 3525ca62ad57Sdan } 3526ca62ad57Sdan else if( memcmp(sApply.abPK, abPK, nCol)!=0 ){ 3527ca62ad57Sdan schemaMismatch = 1; 352840368988Sdan sqlite3_log(SQLITE_SCHEMA, "sqlite3changeset_apply(): " 352940368988Sdan "primary key mismatch for table %s", zTab 3530ca62ad57Sdan ); 3531ca62ad57Sdan } 3532ca62ad57Sdan else if( 3533ca62ad57Sdan (rc = sessionSelectRow(db, zTab, &sApply)) 35340c698471Sdan || (rc = sessionUpdateRow(db, zTab, &sApply)) 35350c698471Sdan || (rc = sessionDeleteRow(db, zTab, &sApply)) 35360c698471Sdan || (rc = sessionInsertRow(db, zTab, &sApply)) 353737f133ecSdan ){ 353837f133ecSdan break; 353937f133ecSdan } 3540cfdbde21Sdrh nTab = sqlite3Strlen30(zTab); 3541d5f0767cSdan } 354240368988Sdan } 3543d5f0767cSdan 3544ca62ad57Sdan /* If there is a schema mismatch on the current table, proceed to the 3545ca62ad57Sdan ** next change. A log message has already been issued. */ 3546ca62ad57Sdan if( schemaMismatch ) continue; 3547ca62ad57Sdan 35480c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, &bRetry); 35490c698471Sdan 35500c698471Sdan if( rc==SQLITE_OK && bRetry ){ 35510c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, &bReplace, 0); 35520c698471Sdan } 35530c698471Sdan 35540c698471Sdan if( bReplace ){ 3555db04571cSdan assert( pIter->op==SQLITE_INSERT ); 35560c698471Sdan rc = sqlite3_exec(db, "SAVEPOINT replace_op", 0, 0, 0); 35570c698471Sdan if( rc==SQLITE_OK ){ 35587aa469cdSdan rc = sessionBindRow(pIter, 3559db04571cSdan sqlite3changeset_new, sApply.nCol, sApply.abPK, sApply.pDelete); 35600c698471Sdan sqlite3_bind_int(sApply.pDelete, sApply.nCol+1, 1); 35610c698471Sdan } 35620c698471Sdan if( rc==SQLITE_OK ){ 35630c698471Sdan sqlite3_step(sApply.pDelete); 35640c698471Sdan rc = sqlite3_reset(sApply.pDelete); 35650c698471Sdan } 35660c698471Sdan if( rc==SQLITE_OK ){ 35670c698471Sdan rc = sessionApplyOneOp(pIter, &sApply, xConflict, pCtx, 0, 0); 35680c698471Sdan } 35690c698471Sdan if( rc==SQLITE_OK ){ 35700c698471Sdan rc = sqlite3_exec(db, "RELEASE replace_op", 0, 0, 0); 35710c698471Sdan } 35720c698471Sdan } 35730c698471Sdan } 3574d5f0767cSdan 3575296c7658Sdan if( rc==SQLITE_OK ){ 3576296c7658Sdan rc = sqlite3changeset_finalize(pIter); 3577296c7658Sdan }else{ 3578296c7658Sdan sqlite3changeset_finalize(pIter); 3579296c7658Sdan } 3580d5f0767cSdan 3581d5f0767cSdan if( rc==SQLITE_OK ){ 358207001c45Sdrh int nFk, notUsed; 358307001c45Sdrh sqlite3_db_status(db, SQLITE_DBSTATUS_DEFERRED_FKS, &nFk, ¬Used, 0); 358407001c45Sdrh if( nFk!=0 ){ 3585cb3e4b79Sdan int res = SQLITE_CHANGESET_ABORT; 3586cb3e4b79Sdan sqlite3_changeset_iter sIter; 3587cb3e4b79Sdan memset(&sIter, 0, sizeof(sIter)); 3588cb3e4b79Sdan sIter.nCol = nFk; 3589cb3e4b79Sdan res = xConflict(pCtx, SQLITE_CHANGESET_FOREIGN_KEY, &sIter); 3590cb3e4b79Sdan if( res!=SQLITE_CHANGESET_OMIT ){ 3591cb3e4b79Sdan rc = SQLITE_CONSTRAINT; 3592cb3e4b79Sdan } 3593cb3e4b79Sdan } 3594cb3e4b79Sdan } 3595cb3e4b79Sdan sqlite3_exec(db, "PRAGMA defer_foreign_keys = 0", 0, 0, 0); 3596cb3e4b79Sdan 3597cb3e4b79Sdan if( rc==SQLITE_OK ){ 3598d5f0767cSdan rc = sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3599d5f0767cSdan }else{ 3600d5f0767cSdan sqlite3_exec(db, "ROLLBACK TO changeset_apply", 0, 0, 0); 3601d5f0767cSdan sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); 3602d5f0767cSdan } 3603d5f0767cSdan 36040c698471Sdan sqlite3_finalize(sApply.pInsert); 36050c698471Sdan sqlite3_finalize(sApply.pDelete); 36060c698471Sdan sqlite3_finalize(sApply.pUpdate); 36070c698471Sdan sqlite3_finalize(sApply.pSelect); 3608cfdbde21Sdrh sqlite3_free((char*)sApply.azCol); /* cast works around VC++ bug */ 36094c220252Sdan sqlite3_mutex_leave(sqlite3_db_mutex(db)); 3610d5f0767cSdan return rc; 3611d5f0767cSdan } 361291ddd559Sdan 361377fc1d5bSdan /* 36144757c658Sdan ** Apply the changeset passed via pChangeset/nChangeset to the main database 36154757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 36164757c658Sdan ** to resolve any conflicts encountered while applying the change. 36174757c658Sdan */ 36184757c658Sdan int sqlite3changeset_apply( 36194757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 36204757c658Sdan int nChangeset, /* Size of changeset in bytes */ 36214757c658Sdan void *pChangeset, /* Changeset blob */ 36224757c658Sdan int(*xFilter)( 36234757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36244757c658Sdan const char *zTab /* Table name */ 36254757c658Sdan ), 36264757c658Sdan int(*xConflict)( 36274757c658Sdan void *pCtx, /* Copy of fifth arg to _apply() */ 36284757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36294757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36304757c658Sdan ), 36314757c658Sdan void *pCtx /* First argument passed to xConflict */ 36324757c658Sdan ){ 36334757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 36344757c658Sdan int rc = sqlite3changeset_start(&pIter, nChangeset, pChangeset); 36354757c658Sdan if( rc==SQLITE_OK ){ 36364757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36374757c658Sdan } 36384757c658Sdan return rc; 36394757c658Sdan } 36404757c658Sdan 36414757c658Sdan /* 36424757c658Sdan ** Apply the changeset passed via xInput/pIn to the main database 36434757c658Sdan ** attached to handle "db". Invoke the supplied conflict handler callback 36444757c658Sdan ** to resolve any conflicts encountered while applying the change. 36454757c658Sdan */ 3646f1a08ad8Sdrh int sqlite3changeset_apply_strm( 36474757c658Sdan sqlite3 *db, /* Apply change to "main" db of this handle */ 36484757c658Sdan int (*xInput)(void *pIn, void *pData, int *pnData), /* Input function */ 36494757c658Sdan void *pIn, /* First arg for xInput */ 36504757c658Sdan int(*xFilter)( 36514757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36524757c658Sdan const char *zTab /* Table name */ 36534757c658Sdan ), 36544757c658Sdan int(*xConflict)( 36554757c658Sdan void *pCtx, /* Copy of sixth arg to _apply() */ 36564757c658Sdan int eConflict, /* DATA, MISSING, CONFLICT, CONSTRAINT */ 36574757c658Sdan sqlite3_changeset_iter *p /* Handle describing change and conflict */ 36584757c658Sdan ), 36594757c658Sdan void *pCtx /* First argument passed to xConflict */ 36604757c658Sdan ){ 36614757c658Sdan sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ 3662f1a08ad8Sdrh int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); 36634757c658Sdan if( rc==SQLITE_OK ){ 36644757c658Sdan rc = sessionChangesetApply(db, pIter, xFilter, xConflict, pCtx); 36654757c658Sdan } 36664757c658Sdan return rc; 36674757c658Sdan } 36684757c658Sdan 36694757c658Sdan /* 367077fc1d5bSdan ** This function is called to merge two changes to the same row together as 367177fc1d5bSdan ** part of an sqlite3changeset_concat() operation. A new change object is 367277fc1d5bSdan ** allocated and a pointer to it stored in *ppNew. 367377fc1d5bSdan */ 36745d607a6eSdan static int sessionChangeMerge( 367577fc1d5bSdan SessionTable *pTab, /* Table structure */ 367664277f4aSdan int bPatchset, /* True for patchsets */ 367777fc1d5bSdan SessionChange *pExist, /* Existing change */ 367877fc1d5bSdan int op2, /* Second change operation */ 367977fc1d5bSdan int bIndirect, /* True if second change is indirect */ 368077fc1d5bSdan u8 *aRec, /* Second change record */ 368177fc1d5bSdan int nRec, /* Number of bytes in aRec */ 368277fc1d5bSdan SessionChange **ppNew /* OUT: Merged change */ 36835d607a6eSdan ){ 36845d607a6eSdan SessionChange *pNew = 0; 36855d607a6eSdan 36865d607a6eSdan if( !pExist ){ 3687cbf6d2d2Sdan pNew = (SessionChange *)sqlite3_malloc(sizeof(SessionChange) + nRec); 36885d607a6eSdan if( !pNew ){ 36895d607a6eSdan return SQLITE_NOMEM; 36905d607a6eSdan } 36915d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 3692798693b2Sdan pNew->op = op2; 36935d607a6eSdan pNew->bIndirect = bIndirect; 36945d607a6eSdan pNew->nRecord = nRec; 3695cbf6d2d2Sdan pNew->aRecord = (u8*)&pNew[1]; 3696cbf6d2d2Sdan memcpy(pNew->aRecord, aRec, nRec); 36975d607a6eSdan }else{ 3698798693b2Sdan int op1 = pExist->op; 36995d607a6eSdan 37005d607a6eSdan /* 37015d607a6eSdan ** op1=INSERT, op2=INSERT -> Unsupported. Discard op2. 37025d607a6eSdan ** op1=INSERT, op2=UPDATE -> INSERT. 37035d607a6eSdan ** op1=INSERT, op2=DELETE -> (none) 37045d607a6eSdan ** 37055d607a6eSdan ** op1=UPDATE, op2=INSERT -> Unsupported. Discard op2. 37065d607a6eSdan ** op1=UPDATE, op2=UPDATE -> UPDATE. 37075d607a6eSdan ** op1=UPDATE, op2=DELETE -> DELETE. 37085d607a6eSdan ** 37095d607a6eSdan ** op1=DELETE, op2=INSERT -> UPDATE. 37105d607a6eSdan ** op1=DELETE, op2=UPDATE -> Unsupported. Discard op2. 37115d607a6eSdan ** op1=DELETE, op2=DELETE -> Unsupported. Discard op2. 37125d607a6eSdan */ 37135d607a6eSdan if( (op1==SQLITE_INSERT && op2==SQLITE_INSERT) 37145d607a6eSdan || (op1==SQLITE_UPDATE && op2==SQLITE_INSERT) 37155d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_UPDATE) 37165d607a6eSdan || (op1==SQLITE_DELETE && op2==SQLITE_DELETE) 37175d607a6eSdan ){ 37185d607a6eSdan pNew = pExist; 37195d607a6eSdan }else if( op1==SQLITE_INSERT && op2==SQLITE_DELETE ){ 37205d607a6eSdan sqlite3_free(pExist); 37215d607a6eSdan assert( pNew==0 ); 37225d607a6eSdan }else{ 372364277f4aSdan u8 *aExist = pExist->aRecord; 37245d607a6eSdan int nByte; 37255d607a6eSdan u8 *aCsr; 37265d607a6eSdan 372764277f4aSdan /* Allocate a new SessionChange object. Ensure that the aRecord[] 372864277f4aSdan ** buffer of the new object is large enough to hold any record that 372964277f4aSdan ** may be generated by combining the input records. */ 37305d607a6eSdan nByte = sizeof(SessionChange) + pExist->nRecord + nRec; 37315d607a6eSdan pNew = (SessionChange *)sqlite3_malloc(nByte); 37325d607a6eSdan if( !pNew ){ 37331756ae10Sdan sqlite3_free(pExist); 37345d607a6eSdan return SQLITE_NOMEM; 37355d607a6eSdan } 37365d607a6eSdan memset(pNew, 0, sizeof(SessionChange)); 37375d607a6eSdan pNew->bIndirect = (bIndirect && pExist->bIndirect); 37385d607a6eSdan aCsr = pNew->aRecord = (u8 *)&pNew[1]; 37395d607a6eSdan 3740b08a1efaSdan if( op1==SQLITE_INSERT ){ /* INSERT + UPDATE */ 37415d607a6eSdan u8 *a1 = aRec; 3742b08a1efaSdan assert( op2==SQLITE_UPDATE ); 3743798693b2Sdan pNew->op = SQLITE_INSERT; 3744ef7a6304Sdan if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); 374564277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aExist, a1); 3746b08a1efaSdan }else if( op1==SQLITE_DELETE ){ /* DELETE + INSERT */ 3747b08a1efaSdan assert( op2==SQLITE_INSERT ); 3748798693b2Sdan pNew->op = SQLITE_UPDATE; 3749fa29ecc4Sdan if( bPatchset ){ 3750fa29ecc4Sdan memcpy(aCsr, aRec, nRec); 3751fa29ecc4Sdan aCsr += nRec; 3752fa29ecc4Sdan }else{ 375364277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aExist, 0,aRec,0) ){ 3754b08a1efaSdan sqlite3_free(pNew); 3755b08a1efaSdan pNew = 0; 37565d607a6eSdan } 3757fa29ecc4Sdan } 3758b08a1efaSdan }else if( op2==SQLITE_UPDATE ){ /* UPDATE + UPDATE */ 375964277f4aSdan u8 *a1 = aExist; 37605d607a6eSdan u8 *a2 = aRec; 3761cfec7eeeSdan assert( op1==SQLITE_UPDATE ); 376264277f4aSdan if( bPatchset==0 ){ 3763ef7a6304Sdan sessionSkipRecord(&a1, pTab->nCol); 3764ef7a6304Sdan sessionSkipRecord(&a2, pTab->nCol); 376564277f4aSdan } 3766798693b2Sdan pNew->op = SQLITE_UPDATE; 376764277f4aSdan if( 0==sessionMergeUpdate(&aCsr, pTab, bPatchset, aRec, aExist,a1,a2) ){ 37685d607a6eSdan sqlite3_free(pNew); 37695d607a6eSdan pNew = 0; 37705d607a6eSdan } 3771b08a1efaSdan }else{ /* UPDATE + DELETE */ 3772b08a1efaSdan assert( op1==SQLITE_UPDATE && op2==SQLITE_DELETE ); 3773798693b2Sdan pNew->op = SQLITE_DELETE; 377464277f4aSdan if( bPatchset ){ 377564277f4aSdan memcpy(aCsr, aRec, nRec); 377664277f4aSdan aCsr += nRec; 377764277f4aSdan }else{ 377864277f4aSdan sessionMergeRecord(&aCsr, pTab->nCol, aRec, aExist); 377964277f4aSdan } 37805d607a6eSdan } 37815d607a6eSdan 37825d607a6eSdan if( pNew ){ 37834f528042Sdan pNew->nRecord = (int)(aCsr - pNew->aRecord); 37845d607a6eSdan } 37855d607a6eSdan sqlite3_free(pExist); 37865d607a6eSdan } 37875d607a6eSdan } 37885d607a6eSdan 37895d607a6eSdan *ppNew = pNew; 37905d607a6eSdan return SQLITE_OK; 37915d607a6eSdan } 37925d607a6eSdan 379377fc1d5bSdan /* 379477fc1d5bSdan ** Add all changes in the changeset passed via the first two arguments to 379577fc1d5bSdan ** hash tables. 379677fc1d5bSdan */ 379716228167Sdan static int sessionChangesetToHash( 3798cbf6d2d2Sdan sqlite3_changeset_iter *pIter, /* Iterator to read from */ 379977fc1d5bSdan SessionTable **ppTabList /* IN/OUT: List of table objects */ 38005d607a6eSdan ){ 38015d607a6eSdan u8 *aRec; 38025d607a6eSdan int nRec; 3803cbf6d2d2Sdan int rc = SQLITE_OK; 38045d607a6eSdan SessionTable *pTab = 0; 38055d607a6eSdan 38065d607a6eSdan while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec) ){ 38075d607a6eSdan const char *zNew; 38085d607a6eSdan int nCol; 38095d607a6eSdan int op; 38105d607a6eSdan int iHash; 38115d607a6eSdan int bIndirect; 38125d607a6eSdan SessionChange *pChange; 38135d607a6eSdan SessionChange *pExist = 0; 38145d607a6eSdan SessionChange **pp; 38155d607a6eSdan 38165d607a6eSdan sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); 3817ef7a6304Sdan if( !pTab || sqlite3_stricmp(zNew, pTab->zName) ){ 38185d607a6eSdan /* Search the list for a matching table */ 38194f528042Sdan int nNew = (int)strlen(zNew); 3820f29123b5Sdan u8 *abPK; 3821f29123b5Sdan 3822f29123b5Sdan sqlite3changeset_pk(pIter, &abPK, 0); 38235d607a6eSdan for(pTab = *ppTabList; pTab; pTab=pTab->pNext){ 38245d607a6eSdan if( 0==sqlite3_strnicmp(pTab->zName, zNew, nNew+1) ) break; 38255d607a6eSdan } 38265d607a6eSdan if( !pTab ){ 3827ef7a6304Sdan pTab = sqlite3_malloc(sizeof(SessionTable) + nCol + nNew+1); 3828f29123b5Sdan if( !pTab ){ 3829f29123b5Sdan rc = SQLITE_NOMEM; 3830f29123b5Sdan break; 3831f29123b5Sdan } 38325d607a6eSdan memset(pTab, 0, sizeof(SessionTable)); 38335d607a6eSdan pTab->pNext = *ppTabList; 3834f29123b5Sdan pTab->nCol = nCol; 3835ef7a6304Sdan pTab->abPK = (u8*)&pTab[1]; 3836ef7a6304Sdan memcpy(pTab->abPK, abPK, nCol); 3837ef7a6304Sdan pTab->zName = (char*)&pTab->abPK[nCol]; 3838ef7a6304Sdan memcpy(pTab->zName, zNew, nNew+1); 38395d607a6eSdan *ppTabList = pTab; 3840f29123b5Sdan }else if( pTab->nCol!=nCol || memcmp(pTab->abPK, abPK, nCol) ){ 3841f29123b5Sdan rc = SQLITE_SCHEMA; 3842f29123b5Sdan break; 38435d607a6eSdan } 38445d607a6eSdan } 38455d607a6eSdan 3846cbf6d2d2Sdan if( sessionGrowHash(pIter->bPatchset, pTab) ){ 38471756ae10Sdan rc = SQLITE_NOMEM; 38481756ae10Sdan break; 38491756ae10Sdan } 385064277f4aSdan iHash = sessionChangeHash( 3851cbf6d2d2Sdan pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange 385264277f4aSdan ); 38535d607a6eSdan 38545d607a6eSdan /* Search for existing entry. If found, remove it from the hash table. 38555d607a6eSdan ** Code below may link it back in. 38565d607a6eSdan */ 38575d607a6eSdan for(pp=&pTab->apChange[iHash]; *pp; pp=&(*pp)->pNext){ 385864277f4aSdan int bPkOnly1 = 0; 385964277f4aSdan int bPkOnly2 = 0; 3860cbf6d2d2Sdan if( pIter->bPatchset ){ 386164277f4aSdan bPkOnly1 = (*pp)->op==SQLITE_DELETE; 386264277f4aSdan bPkOnly2 = op==SQLITE_DELETE; 386364277f4aSdan } 386464277f4aSdan if( sessionChangeEqual(pTab, bPkOnly1, (*pp)->aRecord, bPkOnly2, aRec) ){ 38655d607a6eSdan pExist = *pp; 38665d607a6eSdan *pp = (*pp)->pNext; 38675d607a6eSdan pTab->nEntry--; 38685d607a6eSdan break; 38695d607a6eSdan } 38705d607a6eSdan } 38715d607a6eSdan 387264277f4aSdan rc = sessionChangeMerge(pTab, 3873cbf6d2d2Sdan pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange 387464277f4aSdan ); 38755d607a6eSdan if( rc ) break; 38765d607a6eSdan if( pChange ){ 38775d607a6eSdan pChange->pNext = pTab->apChange[iHash]; 38785d607a6eSdan pTab->apChange[iHash] = pChange; 38795d607a6eSdan pTab->nEntry++; 38805d607a6eSdan } 38815d607a6eSdan } 38825d607a6eSdan 3883cbf6d2d2Sdan if( rc==SQLITE_OK ) rc = pIter->rc; 38845d607a6eSdan return rc; 38855d607a6eSdan } 38865d607a6eSdan 38875d607a6eSdan /* 38885d607a6eSdan ** 1. Iterate through the left-hand changeset. Add an entry to a table 38895d607a6eSdan ** specific hash table for each change in the changeset. The hash table 38905d607a6eSdan ** key is the PK of the row affected by the change. 38915d607a6eSdan ** 38925d607a6eSdan ** 2. Then interate through the right-hand changeset. Attempt to add an 38935d607a6eSdan ** entry to a hash table for each component change. If a change already 38945d607a6eSdan ** exists with the same PK values, combine the two into a single change. 38955d607a6eSdan ** 38965d607a6eSdan ** 3. Write an output changeset based on the contents of the hash table. 38975d607a6eSdan */ 3898cbf6d2d2Sdan int sessionChangesetConcat( 3899cbf6d2d2Sdan sqlite3_changeset_iter *pLeft, 3900cbf6d2d2Sdan sqlite3_changeset_iter *pRight, 3901cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 3902cbf6d2d2Sdan void *pOut, 3903cbf6d2d2Sdan int *pnOut, 3904cbf6d2d2Sdan void **ppOut 39055d607a6eSdan ){ 39065d607a6eSdan SessionTable *pList = 0; /* List of SessionTable objects */ 39075d607a6eSdan int rc; /* Return code */ 390864277f4aSdan int bPatch; /* True for a patchset */ 3909e8fa8c96Sdan SessionTable *pTab; 3910e8fa8c96Sdan SessionBuffer buf = {0, 0, 0}; 39115d607a6eSdan 3912cbf6d2d2Sdan assert( xOutput==0 || (ppOut==0 && pnOut==0) ); 39135d607a6eSdan 3914*abae0c4fSdan assert( pLeft->zTab==0 && pRight->zTab==0 ); 391516228167Sdan rc = sessionChangesetToHash(pLeft, &pList); 3916*abae0c4fSdan assert( pLeft->zTab || pList==0 ); 39175d607a6eSdan if( rc==SQLITE_OK ){ 391816228167Sdan rc = sessionChangesetToHash(pRight, &pList); 39195d607a6eSdan } 3920cbf6d2d2Sdan bPatch = pLeft->bPatchset || pRight->bPatchset; 39215d607a6eSdan 3922*abae0c4fSdan if( pLeft->zTab && pRight->zTab && pLeft->bPatchset!=pRight->bPatchset ){ 3923*abae0c4fSdan rc = SQLITE_ERROR; 3924*abae0c4fSdan } 3925*abae0c4fSdan 39265d607a6eSdan /* Create the serialized output changeset based on the contents of the 39275d607a6eSdan ** hash tables attached to the SessionTable objects in list pList. 39285d607a6eSdan */ 3929e8fa8c96Sdan for(pTab=pList; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ 39305d607a6eSdan int i; 39315d607a6eSdan if( pTab->nEntry==0 ) continue; 39325d607a6eSdan 393364277f4aSdan sessionAppendTableHdr(&buf, bPatch, pTab, &rc); 39345d607a6eSdan for(i=0; i<pTab->nChange; i++){ 39355d607a6eSdan SessionChange *p; 39365d607a6eSdan for(p=pTab->apChange[i]; p; p=p->pNext){ 3937798693b2Sdan sessionAppendByte(&buf, p->op, &rc); 39385d607a6eSdan sessionAppendByte(&buf, p->bIndirect, &rc); 39395d607a6eSdan sessionAppendBlob(&buf, p->aRecord, p->nRecord, &rc); 39405d607a6eSdan } 39415d607a6eSdan } 3942cbf6d2d2Sdan 3943f1a08ad8Sdrh if( rc==SQLITE_OK && xOutput && buf.nBuf>=SESSIONS_STRM_CHUNK_SIZE ){ 3944cbf6d2d2Sdan rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3945cbf6d2d2Sdan buf.nBuf = 0; 3946cbf6d2d2Sdan } 39475d607a6eSdan } 39485d607a6eSdan 39495d607a6eSdan if( rc==SQLITE_OK ){ 3950cbf6d2d2Sdan if( xOutput ){ 3951cbf6d2d2Sdan if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); 3952cbf6d2d2Sdan }else{ 39535d607a6eSdan *ppOut = buf.aBuf; 39545d607a6eSdan *pnOut = buf.nBuf; 3955cbf6d2d2Sdan buf.aBuf = 0; 39565d607a6eSdan } 39575d607a6eSdan } 3958cbf6d2d2Sdan sqlite3_free(buf.aBuf); 39595d607a6eSdan 39605d607a6eSdan sessionDeleteTable(pList); 39615d607a6eSdan return rc; 39625d607a6eSdan } 39635d607a6eSdan 3964cbf6d2d2Sdan /* 3965cbf6d2d2Sdan ** Combine two changesets together. 3966cbf6d2d2Sdan */ 3967cbf6d2d2Sdan int sqlite3changeset_concat( 3968cbf6d2d2Sdan int nLeft, /* Number of bytes in lhs input */ 3969cbf6d2d2Sdan void *pLeft, /* Lhs input changeset */ 3970cbf6d2d2Sdan int nRight /* Number of bytes in rhs input */, 3971cbf6d2d2Sdan void *pRight, /* Rhs input changeset */ 3972cbf6d2d2Sdan int *pnOut, /* OUT: Number of bytes in output changeset */ 3973cbf6d2d2Sdan void **ppOut /* OUT: changeset (left <concat> right) */ 3974cbf6d2d2Sdan ){ 3975cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 3976cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 3977cbf6d2d2Sdan int rc; 3978cbf6d2d2Sdan 3979cbf6d2d2Sdan *pnOut = 0; 3980cbf6d2d2Sdan *ppOut = 0; 3981cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter1, nLeft, pLeft); 3982cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3983cbf6d2d2Sdan rc = sqlite3changeset_start(&pIter2, nRight, pRight); 3984cbf6d2d2Sdan } 3985cbf6d2d2Sdan if( rc==SQLITE_OK ){ 3986cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, 0, 0, pnOut, ppOut); 3987cbf6d2d2Sdan } 3988cbf6d2d2Sdan 3989cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 3990cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 3991cbf6d2d2Sdan return rc; 3992cbf6d2d2Sdan } 3993cbf6d2d2Sdan 3994cbf6d2d2Sdan /* 3995cbf6d2d2Sdan ** Streaming version of sqlite3changeset_concat(). 3996cbf6d2d2Sdan */ 3997f1a08ad8Sdrh int sqlite3changeset_concat_strm( 3998cbf6d2d2Sdan int (*xInputA)(void *pIn, void *pData, int *pnData), 3999cbf6d2d2Sdan void *pInA, 4000cbf6d2d2Sdan int (*xInputB)(void *pIn, void *pData, int *pnData), 4001cbf6d2d2Sdan void *pInB, 4002cbf6d2d2Sdan int (*xOutput)(void *pOut, const void *pData, int nData), 4003cbf6d2d2Sdan void *pOut 4004cbf6d2d2Sdan ){ 4005cbf6d2d2Sdan sqlite3_changeset_iter *pIter1 = 0; 4006cbf6d2d2Sdan sqlite3_changeset_iter *pIter2 = 0; 4007cbf6d2d2Sdan int rc; 4008cbf6d2d2Sdan 4009f1a08ad8Sdrh rc = sqlite3changeset_start_strm(&pIter1, xInputA, pInA); 4010cbf6d2d2Sdan if( rc==SQLITE_OK ){ 4011f1a08ad8Sdrh rc = sqlite3changeset_start_strm(&pIter2, xInputB, pInB); 4012cbf6d2d2Sdan } 4013cbf6d2d2Sdan if( rc==SQLITE_OK ){ 4014cbf6d2d2Sdan rc = sessionChangesetConcat(pIter1, pIter2, xOutput, pOut, 0, 0); 4015cbf6d2d2Sdan } 4016cbf6d2d2Sdan 4017cbf6d2d2Sdan sqlite3changeset_finalize(pIter1); 4018cbf6d2d2Sdan sqlite3changeset_finalize(pIter2); 4019cbf6d2d2Sdan return rc; 4020cbf6d2d2Sdan } 4021cbf6d2d2Sdan 40229b1c62d4Sdrh #endif /* SQLITE_ENABLE_SESSION && SQLITE_ENABLE_PREUPDATE_HOOK */ 4023