Lines Matching refs:rc
49 int rc; /* Non-zero if an error has occurred */ member
97 int rc; /* Iterator error code */ member
529 int rc; in sessionPreupdateHash() local
534 rc = pSession->hook.xNew(pSession->hook.pCtx, i, &pVal); in sessionPreupdateHash()
536 rc = pSession->hook.xOld(pSession->hook.pCtx, i, &pVal); in sessionPreupdateHash()
538 if( rc!=SQLITE_OK ) return rc; in sessionPreupdateHash()
862 int rc; /* Error code from preupdate_new/old */ in sessionPreupdateEqual() local
872 rc = pSession->hook.xNew(pSession->hook.pCtx, iCol, &pVal); in sessionPreupdateEqual()
875 rc = pSession->hook.xOld(pSession->hook.pCtx, iCol, &pVal); in sessionPreupdateEqual()
877 assert( rc==SQLITE_OK ); in sessionPreupdateEqual()
1004 int rc; in sessionTableInfo() local
1017 rc = sqlite3_table_column_metadata(db, zDb, zThis, 0, 0, 0, 0, 0, 0); in sessionTableInfo()
1018 if( rc==SQLITE_OK ){ in sessionTableInfo()
1025 }else if( rc==SQLITE_ERROR ){ in sessionTableInfo()
1032 return rc; in sessionTableInfo()
1045 rc = sqlite3_prepare_v2(db, zPragma, -1, &pStmt, 0); in sessionTableInfo()
1047 if( rc!=SQLITE_OK ){ in sessionTableInfo()
1052 return rc; in sessionTableInfo()
1060 rc = sqlite3_reset(pStmt); in sessionTableInfo()
1062 if( rc==SQLITE_OK ){ in sessionTableInfo()
1066 rc = SQLITE_NOMEM; in sessionTableInfo()
1069 if( rc==SQLITE_OK ){ in sessionTableInfo()
1091 rc = sqlite3_reset(pStmt); in sessionTableInfo()
1098 if( rc==SQLITE_OK ){ in sessionTableInfo()
1110 return rc; in sessionTableInfo()
1129 pSession->rc = sessionTableInfo(pSession, pSession->db, pSession->zDb, in sessionInitTable()
1132 if( pSession->rc==SQLITE_OK ){ in sessionInitTable()
1151 return (pSession->rc || pTab->abPK==0); in sessionInitTable()
1168 int rc = p->hook.xOld(p->hook.pCtx, iCol, &pVal); in sessionStat1Old() local
1169 if( rc==SQLITE_OK && iCol==1 && sqlite3_value_type(pVal)==SQLITE_NULL ){ in sessionStat1Old()
1173 return rc; in sessionStat1Old()
1178 int rc = p->hook.xNew(p->hook.pCtx, iCol, &pVal); in sessionStat1New() local
1179 if( rc==SQLITE_OK && iCol==1 && sqlite3_value_type(pVal)==SQLITE_NULL ){ in sessionStat1New()
1183 return rc; in sessionStat1New()
1307 int rc = SQLITE_OK; in sessionPreupdateOneChange() local
1310 if( pSession->rc ) return; in sessionPreupdateOneChange()
1318 pSession->rc = SQLITE_SCHEMA; in sessionPreupdateOneChange()
1324 pSession->rc = SQLITE_NOMEM; in sessionPreupdateOneChange()
1339 rc = SQLITE_NOMEM; in sessionPreupdateOneChange()
1350 rc = sessionPreupdateHash(pSession, pTab, op==SQLITE_INSERT, &iHash, &bNull); in sessionPreupdateOneChange()
1351 if( rc!=SQLITE_OK ) goto error_out; in sessionPreupdateOneChange()
1367 assert( rc==SQLITE_OK ); in sessionPreupdateOneChange()
1384 rc = sessionSerializeValue(0, p, &nByte); in sessionPreupdateOneChange()
1385 if( rc!=SQLITE_OK ) goto error_out; in sessionPreupdateOneChange()
1391 rc = SQLITE_NOMEM; in sessionPreupdateOneChange()
1432 assert( rc==SQLITE_OK ); in sessionPreupdateOneChange()
1434 rc = sessionUpdateMaxSize(op, pSession, pTab, pC); in sessionPreupdateOneChange()
1444 if( rc!=SQLITE_OK ){ in sessionPreupdateOneChange()
1445 pSession->rc = rc; in sessionPreupdateOneChange()
1454 int rc = SQLITE_OK; in sessionFindTable() local
1469 rc = sqlite3session_attach(pSession, zName); in sessionFindTable()
1470 if( rc==SQLITE_OK ){ in sessionFindTable()
1481 assert( rc==SQLITE_OK || pRet==0 ); in sessionFindTable()
1483 return rc; in sessionFindTable()
1510 if( pSession->rc ) continue; in xPreUpdate()
1513 pSession->rc = sessionFindTable(pSession, zName, &pTab); in xPreUpdate()
1515 assert( pSession->rc==SQLITE_OK ); in xPreUpdate()
1674 int rc = SQLITE_OK; in sessionDiffFindNew() local
1678 rc = SQLITE_NOMEM; in sessionDiffFindNew()
1681 rc = sqlite3_prepare(pSession->db, zStmt, -1, &pStmt, 0); in sessionDiffFindNew()
1682 if( rc==SQLITE_OK ){ in sessionDiffFindNew()
1689 rc = sqlite3_finalize(pStmt); in sessionDiffFindNew()
1694 return rc; in sessionDiffFindNew()
1703 int rc = SQLITE_OK; in sessionDiffFindModified() local
1709 rc = SQLITE_NOMEM; in sessionDiffFindModified()
1716 rc = SQLITE_NOMEM; in sessionDiffFindModified()
1719 rc = sqlite3_prepare(pSession->db, zStmt, -1, &pStmt, 0); in sessionDiffFindModified()
1721 if( rc==SQLITE_OK ){ in sessionDiffFindModified()
1728 rc = sqlite3_finalize(pStmt); in sessionDiffFindModified()
1734 return rc; in sessionDiffFindModified()
1744 int rc = pSession->rc; in sqlite3session_diff() local
1752 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1758 rc = sessionFindTable(pSession, zTbl, &pTo); in sqlite3session_diff()
1761 rc = pSession->rc; in sqlite3session_diff()
1766 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1772 rc = sessionTableInfo(0, db, zFrom, zTbl, &nCol, 0, &azCol, &abPK); in sqlite3session_diff()
1773 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1790 rc = SQLITE_SCHEMA; in sqlite3session_diff()
1798 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1805 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1806 rc = sessionDiffFindNew(SQLITE_INSERT, pSession, pTo, zDb, zFrom, zExpr); in sqlite3session_diff()
1810 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1811 rc = sessionDiffFindNew(SQLITE_DELETE, pSession, pTo, zFrom, zDb, zExpr); in sqlite3session_diff()
1815 if( rc==SQLITE_OK ){ in sqlite3session_diff()
1816 rc = sessionDiffFindModified(pSession, pTo, zFrom, zExpr); in sqlite3session_diff()
1825 return rc; in sqlite3session_diff()
1948 int rc = SQLITE_OK; in sqlite3session_attach() local
1969 rc = SQLITE_NOMEM; in sqlite3session_attach()
1987 return rc; in sqlite3session_attach()
2041 int rc = *pRc; in sessionAppendValue() local
2042 if( rc==SQLITE_OK ){ in sessionAppendValue()
2044 rc = sessionSerializeValue(0, pVal, &nByte); in sessionAppendValue()
2045 sessionBufferGrow(p, nByte, &rc); in sessionAppendValue()
2046 if( rc==SQLITE_OK ){ in sessionAppendValue()
2047 rc = sessionSerializeValue(&p->aBuf[p->nBuf], pVal, 0); in sessionAppendValue()
2050 *pRc = rc; in sessionAppendValue()
2241 int rc = SQLITE_OK; in sessionAppendUpdate() local
2249 sessionAppendByte(pBuf, SQLITE_UPDATE, &rc); in sessionAppendUpdate()
2250 sessionAppendByte(pBuf, p->bIndirect, &rc); in sessionAppendUpdate()
2302 sessionAppendBlob(pBuf, pCsr, nAdvance, &rc); in sessionAppendUpdate()
2304 sessionAppendByte(pBuf, 0, &rc); in sessionAppendUpdate()
2311 sessionAppendCol(&buf2, pStmt, i, &rc); in sessionAppendUpdate()
2313 sessionAppendByte(&buf2, 0, &rc); in sessionAppendUpdate()
2322 sessionAppendBlob(pBuf, buf2.aBuf, buf2.nBuf, &rc); in sessionAppendUpdate()
2326 return rc; in sessionAppendUpdate()
2341 int rc = SQLITE_OK; in sessionAppendDelete() local
2343 sessionAppendByte(pBuf, SQLITE_DELETE, &rc); in sessionAppendDelete()
2344 sessionAppendByte(pBuf, p->bIndirect, &rc); in sessionAppendDelete()
2347 sessionAppendBlob(pBuf, p->aRecord, p->nRecord, &rc); in sessionAppendDelete()
2374 sessionAppendBlob(pBuf, pStart, (int)(a-pStart), &rc); in sessionAppendDelete()
2380 return rc; in sessionAppendDelete()
2398 int rc = SQLITE_OK; in sessionSelectStmt() local
2407 if( zSql==0 ) rc = SQLITE_NOMEM; in sessionSelectStmt()
2413 sessionAppendStr(&buf, "SELECT * FROM ", &rc); in sessionSelectStmt()
2414 sessionAppendIdent(&buf, zDb, &rc); in sessionSelectStmt()
2415 sessionAppendStr(&buf, ".", &rc); in sessionSelectStmt()
2416 sessionAppendIdent(&buf, zTab, &rc); in sessionSelectStmt()
2417 sessionAppendStr(&buf, " WHERE ", &rc); in sessionSelectStmt()
2420 sessionAppendStr(&buf, zSep, &rc); in sessionSelectStmt()
2421 sessionAppendIdent(&buf, azCol[i], &rc); in sessionSelectStmt()
2422 sessionAppendStr(&buf, " IS ?", &rc); in sessionSelectStmt()
2423 sessionAppendInteger(&buf, i+1, &rc); in sessionSelectStmt()
2431 if( rc==SQLITE_OK ){ in sessionSelectStmt()
2432 rc = sqlite3_prepare_v2(db, zSql, nSql, ppStmt, 0); in sessionSelectStmt()
2435 return rc; in sessionSelectStmt()
2453 int rc = SQLITE_OK; in sessionSelectBind() local
2456 for(i=0; i<nCol && rc==SQLITE_OK; i++){ in sessionSelectBind()
2468 rc = sqlite3_bind_int64(pSelect, i+1, iVal); in sessionSelectBind()
2479 rc = sqlite3_bind_double(pSelect, i+1, rVal); in sessionSelectBind()
2489 rc = sqlite3_bind_text(pSelect, i+1, (char *)a, n, SQLITE_TRANSIENT); in sessionSelectBind()
2500 rc = sqlite3_bind_blob(pSelect, i+1, a, n, SQLITE_TRANSIENT); in sessionSelectBind()
2508 return rc; in sessionSelectBind()
2551 int rc; /* Return code */ in sessionGenerateChangeset() local
2565 if( pSession->rc ) return pSession->rc; in sessionGenerateChangeset()
2566 rc = sqlite3_exec(pSession->db, "SAVEPOINT changeset", 0, 0, 0); in sessionGenerateChangeset()
2567 if( rc!=SQLITE_OK ) return rc; in sessionGenerateChangeset()
2571 for(pTab=pSession->pTable; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ in sessionGenerateChangeset()
2583 rc = sessionTableInfo(0, db, pSession->zDb, zName, &nCol, 0,&azCol,&abPK); in sessionGenerateChangeset()
2584 if( !rc && (pTab->nCol!=nCol || memcmp(abPK, pTab->abPK, nCol)) ){ in sessionGenerateChangeset()
2585 rc = SQLITE_SCHEMA; in sessionGenerateChangeset()
2589 sessionAppendTableHdr(&buf, bPatchset, pTab, &rc); in sessionGenerateChangeset()
2592 if( rc==SQLITE_OK ){ in sessionGenerateChangeset()
2593 rc = sessionSelectStmt( in sessionGenerateChangeset()
2598 for(i=0; i<pTab->nChange && rc==SQLITE_OK; i++){ in sessionGenerateChangeset()
2601 for(p=pTab->apChange[i]; rc==SQLITE_OK && p; p=p->pNext){ in sessionGenerateChangeset()
2602 rc = sessionSelectBind(pSel, nCol, abPK, p); in sessionGenerateChangeset()
2603 if( rc!=SQLITE_OK ) continue; in sessionGenerateChangeset()
2607 sessionAppendByte(&buf, SQLITE_INSERT, &rc); in sessionGenerateChangeset()
2608 sessionAppendByte(&buf, p->bIndirect, &rc); in sessionGenerateChangeset()
2610 sessionAppendCol(&buf, pSel, iCol, &rc); in sessionGenerateChangeset()
2614 rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); in sessionGenerateChangeset()
2617 rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); in sessionGenerateChangeset()
2619 if( rc==SQLITE_OK ){ in sessionGenerateChangeset()
2620 rc = sqlite3_reset(pSel); in sessionGenerateChangeset()
2626 && rc==SQLITE_OK in sessionGenerateChangeset()
2630 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2646 if( rc==SQLITE_OK ){ in sessionGenerateChangeset()
2652 rc = xOutput(pOut, (void*)buf.aBuf, buf.nBuf); in sessionGenerateChangeset()
2659 return rc; in sessionGenerateChangeset()
2674 int rc; in sqlite3session_changeset() local
2677 rc = sessionGenerateChangeset(pSession, 0, 0, 0, pnChangeset,ppChangeset); in sqlite3session_changeset()
2678 assert( rc || pnChangeset==0 in sqlite3session_changeset()
2681 return rc; in sqlite3session_changeset()
2780 int rc = SQLITE_OK; in sqlite3session_object_config() local
2786 rc = SQLITE_MISUSE; in sqlite3session_object_config()
2796 rc = SQLITE_MISUSE; in sqlite3session_object_config()
2799 return rc; in sqlite3session_object_config()
2912 int rc = SQLITE_OK; in sessionInputBuffer() local
2914 while( !pIn->bEof && (pIn->iNext+nByte)>=pIn->nData && rc==SQLITE_OK ){ in sessionInputBuffer()
2918 if( SQLITE_OK==sessionBufferGrow(&pIn->buf, nNew, &rc) ){ in sessionInputBuffer()
2919 rc = pIn->xInput(pIn->pIn, &pIn->buf.aBuf[pIn->buf.nBuf], &nNew); in sessionInputBuffer()
2931 return rc; in sessionInputBuffer()
3014 int rc = SQLITE_OK; in sessionReadRecord() local
3018 for(i=0; i<nCol && rc==SQLITE_OK; i++){ in sessionReadRecord()
3021 rc = sessionInputBuffer(pIn, 9); in sessionReadRecord()
3022 if( rc==SQLITE_OK ){ in sessionReadRecord()
3024 rc = SQLITE_CORRUPT_BKPT; in sessionReadRecord()
3031 if( !apOut[i] ) rc = SQLITE_NOMEM; in sessionReadRecord()
3036 if( rc==SQLITE_OK ){ in sessionReadRecord()
3041 rc = sessionInputBuffer(pIn, nByte); in sessionReadRecord()
3042 if( rc==SQLITE_OK ){ in sessionReadRecord()
3044 rc = SQLITE_CORRUPT_BKPT; in sessionReadRecord()
3047 rc = sessionValueSetStr(apOut[i],&pIn->aData[pIn->iNext],nByte,enc); in sessionReadRecord()
3066 return rc; in sessionReadRecord()
3083 int rc = SQLITE_OK; in sessionChangesetBufferTblhdr() local
3087 rc = sessionInputBuffer(pIn, 9); in sessionChangesetBufferTblhdr()
3088 if( rc==SQLITE_OK ){ in sessionChangesetBufferTblhdr()
3098 rc = SQLITE_CORRUPT_BKPT; in sessionChangesetBufferTblhdr()
3100 rc = sessionInputBuffer(pIn, nRead+nCol+100); in sessionChangesetBufferTblhdr()
3105 while( rc==SQLITE_OK ){ in sessionChangesetBufferTblhdr()
3110 rc = sessionInputBuffer(pIn, nRead + 100); in sessionChangesetBufferTblhdr()
3113 return rc; in sessionChangesetBufferTblhdr()
3130 int rc = SQLITE_OK; in sessionChangesetBufferRecord() local
3133 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionChangesetBufferRecord()
3135 rc = sessionInputBuffer(pIn, nByte + 10); in sessionChangesetBufferRecord()
3136 if( rc==SQLITE_OK ){ in sessionChangesetBufferRecord()
3142 rc = sessionInputBuffer(pIn, nByte); in sessionChangesetBufferRecord()
3149 return rc; in sessionChangesetBufferRecord()
3170 int rc; in sessionChangesetReadTblhdr() local
3172 assert( p->rc==SQLITE_OK ); in sessionChangesetReadTblhdr()
3174 rc = sessionChangesetBufferTblhdr(&p->in, &nCopy); in sessionChangesetReadTblhdr()
3175 if( rc==SQLITE_OK ){ in sessionChangesetReadTblhdr()
3184 sessionBufferGrow(&p->tblhdr, nByte, &rc); in sessionChangesetReadTblhdr()
3186 rc = SQLITE_CORRUPT_BKPT; in sessionChangesetReadTblhdr()
3190 if( rc==SQLITE_OK ){ in sessionChangesetReadTblhdr()
3205 return (p->rc = rc); in sessionChangesetReadTblhdr()
3232 if( p->rc!=SQLITE_OK ) return p->rc; in sessionChangesetNextOne()
3246 p->rc = sessionInputBuffer(&p->in, 2); in sessionChangesetNextOne()
3247 if( p->rc!=SQLITE_OK ) return p->rc; in sessionChangesetNextOne()
3261 if( sessionChangesetReadTblhdr(p) ) return p->rc; in sessionChangesetNextOne()
3262 if( (p->rc = sessionInputBuffer(&p->in, 2)) ) return p->rc; in sessionChangesetNextOne()
3272 return (p->rc = SQLITE_CORRUPT_BKPT); in sessionChangesetNextOne()
3278 return (p->rc = SQLITE_CORRUPT_BKPT); in sessionChangesetNextOne()
3291 p->rc = sessionChangesetBufferRecord(&p->in, nVal, pnRec); in sessionChangesetNextOne()
3292 if( p->rc!=SQLITE_OK ) return p->rc; in sessionChangesetNextOne()
3302 p->rc = sessionReadRecord(&p->in, p->nCol, abPK, apOld, 0); in sessionChangesetNextOne()
3303 if( p->rc!=SQLITE_OK ) return p->rc; in sessionChangesetNextOne()
3308 p->rc = sessionReadRecord(&p->in, p->nCol, 0, apNew, pbEmpty); in sessionChangesetNextOne()
3309 if( p->rc!=SQLITE_OK ) return p->rc; in sessionChangesetNextOne()
3322 if( p->apValue[i]==0 ) return (p->rc = SQLITE_CORRUPT_BKPT); in sessionChangesetNextOne()
3358 int rc; in sessionChangesetNext() local
3361 rc = sessionChangesetNextOne(p, paRec, pnRec, pbNew, &bEmpty); in sessionChangesetNext()
3362 }while( rc==SQLITE_ROW && p->bSkipEmpty && bEmpty); in sessionChangesetNext()
3363 return rc; in sessionChangesetNext()
3530 int rc = SQLITE_OK; in sqlite3changeset_finalize() local
3533 rc = p->rc; in sqlite3changeset_finalize()
3541 return rc; in sqlite3changeset_finalize()
3551 int rc = SQLITE_OK; /* Return value */ in sessionChangesetInvert() local
3571 if( (rc = sessionInputBuffer(pInput, 2)) ) goto finished_invert; in sessionChangesetInvert()
3587 if( (rc = sessionChangesetBufferTblhdr(pInput, &nByte)) ){ in sessionChangesetInvert()
3592 sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc); in sessionChangesetInvert()
3593 sessionAppendByte(&sOut, eType, &rc); in sessionChangesetInvert()
3594 sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); in sessionChangesetInvert()
3595 if( rc ) goto finished_invert; in sessionChangesetInvert()
3610 assert( rc==SQLITE_OK ); in sessionChangesetInvert()
3611 rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); in sessionChangesetInvert()
3612 sessionAppendByte(&sOut, eType2, &rc); in sessionChangesetInvert()
3613 sessionAppendByte(&sOut, bIndirect, &rc); in sessionChangesetInvert()
3614 sessionAppendBlob(&sOut, &pInput->aData[pInput->iNext], nByte, &rc); in sessionChangesetInvert()
3616 if( rc ) goto finished_invert; in sessionChangesetInvert()
3626 rc = SQLITE_NOMEM; in sessionChangesetInvert()
3633 sessionAppendByte(&sOut, eType, &rc); in sessionChangesetInvert()
3634 sessionAppendByte(&sOut, pInput->aData[pInput->iNext+1], &rc); in sessionChangesetInvert()
3638 rc = sessionReadRecord(pInput, nCol, 0, &apVal[0], 0); in sessionChangesetInvert()
3639 if( rc==SQLITE_OK ){ in sessionChangesetInvert()
3640 rc = sessionReadRecord(pInput, nCol, 0, &apVal[nCol], 0); in sessionChangesetInvert()
3648 sessionAppendValue(&sOut, pVal, &rc); in sessionChangesetInvert()
3656 sessionAppendValue(&sOut, pVal, &rc); in sessionChangesetInvert()
3663 if( rc!=SQLITE_OK ){ in sessionChangesetInvert()
3671 rc = SQLITE_CORRUPT_BKPT; in sessionChangesetInvert()
3675 assert( rc==SQLITE_OK ); in sessionChangesetInvert()
3677 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3679 if( rc!=SQLITE_OK ) goto finished_invert; in sessionChangesetInvert()
3683 assert( rc==SQLITE_OK ); in sessionChangesetInvert()
3689 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionChangesetInvert()
3696 return rc; in sessionChangesetInvert()
3729 int rc; in sqlite3changeset_invert_strm() local
3736 rc = sessionChangesetInvert(&sInput, xOutput, pOut, 0, 0); in sqlite3changeset_invert_strm()
3738 return rc; in sqlite3changeset_invert_strm()
3784 int rc = SQLITE_OK; in sessionUpdateFind() local
3793 rc = SQLITE_NOMEM; in sessionUpdateFind()
3797 if( rc==SQLITE_OK ){ in sessionUpdateFind()
3799 rc = SQLITE_CORRUPT; in sessionUpdateFind()
3803 rc = SQLITE_OK; in sessionUpdateFind()
3808 if( rc==SQLITE_OK ){ in sessionUpdateFind()
3842 rc = SQLITE_NOMEM; in sessionUpdateFind()
3851 sessionAppendStr(&buf, "UPDATE main.", &rc); in sessionUpdateFind()
3852 sessionAppendIdent(&buf, pIter->zTab, &rc); in sessionUpdateFind()
3853 sessionAppendStr(&buf, " SET ", &rc); in sessionUpdateFind()
3858 sessionAppendStr(&buf, zSep, &rc); in sessionUpdateFind()
3859 sessionAppendIdent(&buf, p->azCol[ii], &rc); in sessionUpdateFind()
3860 sessionAppendStr(&buf, " = ?", &rc); in sessionUpdateFind()
3861 sessionAppendInteger(&buf, ii*2+1, &rc); in sessionUpdateFind()
3868 sessionAppendStr(&buf, " WHERE ", &rc); in sessionUpdateFind()
3871 sessionAppendStr(&buf, zSep, &rc); in sessionUpdateFind()
3877 "ELSE ?4 END ", &rc in sessionUpdateFind()
3880 sessionAppendIdent(&buf, p->azCol[ii], &rc); in sessionUpdateFind()
3881 sessionAppendStr(&buf, " IS ?", &rc); in sessionUpdateFind()
3882 sessionAppendInteger(&buf, ii*2+2, &rc); in sessionUpdateFind()
3888 if( rc==SQLITE_OK ){ in sessionUpdateFind()
3890 rc = sqlite3_prepare_v2(p->db, zSql, buf.nBuf, &pUp->pStmt, 0); in sessionUpdateFind()
3893 if( rc!=SQLITE_OK ){ in sessionUpdateFind()
3905 assert( (rc==SQLITE_OK)==(pUp!=0) ); in sessionUpdateFind()
3911 return rc; in sessionUpdateFind()
3954 int rc = SQLITE_OK; in sessionDeleteRow() local
3958 sessionAppendStr(&buf, "DELETE FROM main.", &rc); in sessionDeleteRow()
3959 sessionAppendIdent(&buf, zTab, &rc); in sessionDeleteRow()
3960 sessionAppendStr(&buf, " WHERE ", &rc); in sessionDeleteRow()
3965 sessionAppendStr(&buf, zSep, &rc); in sessionDeleteRow()
3966 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionDeleteRow()
3967 sessionAppendStr(&buf, " = ?", &rc); in sessionDeleteRow()
3968 sessionAppendInteger(&buf, i+1, &rc); in sessionDeleteRow()
3974 sessionAppendStr(&buf, " AND (?", &rc); in sessionDeleteRow()
3975 sessionAppendInteger(&buf, p->nCol+1, &rc); in sessionDeleteRow()
3976 sessionAppendStr(&buf, " OR ", &rc); in sessionDeleteRow()
3981 sessionAppendStr(&buf, zSep, &rc); in sessionDeleteRow()
3982 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionDeleteRow()
3983 sessionAppendStr(&buf, " IS ?", &rc); in sessionDeleteRow()
3984 sessionAppendInteger(&buf, i+1, &rc); in sessionDeleteRow()
3988 sessionAppendStr(&buf, ")", &rc); in sessionDeleteRow()
3991 if( rc==SQLITE_OK ){ in sessionDeleteRow()
3992 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pDelete, 0); in sessionDeleteRow()
3996 return rc; in sessionDeleteRow()
4035 int rc = SQLITE_OK; in sessionInsertRow() local
4039 sessionAppendStr(&buf, "INSERT INTO main.", &rc); in sessionInsertRow()
4040 sessionAppendIdent(&buf, zTab, &rc); in sessionInsertRow()
4041 sessionAppendStr(&buf, "(", &rc); in sessionInsertRow()
4043 if( i!=0 ) sessionAppendStr(&buf, ", ", &rc); in sessionInsertRow()
4044 sessionAppendIdent(&buf, p->azCol[i], &rc); in sessionInsertRow()
4047 sessionAppendStr(&buf, ") VALUES(?", &rc); in sessionInsertRow()
4049 sessionAppendStr(&buf, ", ?", &rc); in sessionInsertRow()
4051 sessionAppendStr(&buf, ")", &rc); in sessionInsertRow()
4053 if( rc==SQLITE_OK ){ in sessionInsertRow()
4054 rc = sqlite3_prepare_v2(db, (char *)buf.aBuf, buf.nBuf, &p->pInsert, 0); in sessionInsertRow()
4057 return rc; in sessionInsertRow()
4071 int rc = sessionSelectRow(db, "sqlite_stat1", p); in sessionStat1Sql() local
4072 if( rc==SQLITE_OK ){ in sessionStat1Sql()
4073 rc = sessionPrepare(db, &p->pInsert, in sessionStat1Sql()
4079 if( rc==SQLITE_OK ){ in sessionStat1Sql()
4080 rc = sessionPrepare(db, &p->pDelete, in sessionStat1Sql()
4086 return rc; in sessionStat1Sql()
4134 int rc = SQLITE_OK; in sessionBindRow() local
4142 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionBindRow()
4149 rc = SQLITE_CORRUPT_BKPT; in sessionBindRow()
4151 rc = sessionBindValue(pStmt, i+1, pVal); in sessionBindRow()
4155 return rc; in sessionBindRow()
4181 int rc; /* Return code */ in sessionSeekToRow() local
4187 rc = sessionBindRow(pIter, in sessionSeekToRow()
4192 if( rc==SQLITE_OK ){ in sessionSeekToRow()
4193 rc = sqlite3_step(pSelect); in sessionSeekToRow()
4194 if( rc!=SQLITE_ROW ) rc = sqlite3_reset(pSelect); in sessionSeekToRow()
4197 return rc; in sessionSeekToRow()
4215 int rc = SQLITE_OK; in sessionRebaseAdd() local
4222 sessionAppendByte(&p->rebase, 'T', &rc); in sessionRebaseAdd()
4223 sessionAppendVarint(&p->rebase, p->nCol, &rc); in sessionRebaseAdd()
4224 sessionAppendBlob(&p->rebase, p->abPK, p->nCol, &rc); in sessionRebaseAdd()
4225 sessionAppendBlob(&p->rebase, (u8*)zTab, (int)strlen(zTab)+1, &rc); in sessionRebaseAdd()
4233 (eOp==SQLITE_DELETE ? SQLITE_DELETE : SQLITE_INSERT), &rc in sessionRebaseAdd()
4235 sessionAppendByte(&p->rebase, (eType==SQLITE_CHANGESET_REPLACE), &rc); in sessionRebaseAdd()
4243 sessionAppendValue(&p->rebase, pVal, &rc); in sessionRebaseAdd()
4246 return rc; in sessionRebaseAdd()
4293 int rc; in sessionConflictHandler() local
4306 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionConflictHandler()
4308 rc = SQLITE_OK; in sessionConflictHandler()
4311 if( rc==SQLITE_ROW ){ in sessionConflictHandler()
4316 rc = sqlite3_reset(p->pSelect); in sessionConflictHandler()
4317 }else if( rc==SQLITE_OK ){ in sessionConflictHandler()
4323 sessionAppendBlob(&p->constraints, aBlob, nBlob, &rc); in sessionConflictHandler()
4328 if( res==SQLITE_CHANGESET_REPLACE ) rc = SQLITE_MISUSE; in sessionConflictHandler()
4332 if( rc==SQLITE_OK ){ in sessionConflictHandler()
4343 rc = SQLITE_ABORT; in sessionConflictHandler()
4347 rc = SQLITE_MISUSE; in sessionConflictHandler()
4350 if( rc==SQLITE_OK ){ in sessionConflictHandler()
4351 rc = sessionRebaseAdd(p, res, pIter); in sessionConflictHandler()
4355 return rc; in sessionConflictHandler()
4393 int rc = SQLITE_OK; in sessionApplyOneOp() local
4415 rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); in sessionApplyOneOp()
4416 if( rc==SQLITE_OK && sqlite3_bind_parameter_count(p->pDelete)>nCol ){ in sessionApplyOneOp()
4417 rc = sqlite3_bind_int(p->pDelete, nCol+1, (pbRetry==0 || abPK)); in sessionApplyOneOp()
4419 if( rc!=SQLITE_OK ) return rc; in sessionApplyOneOp()
4422 rc = sqlite3_reset(p->pDelete); in sessionApplyOneOp()
4423 if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ in sessionApplyOneOp()
4424 rc = sessionConflictHandler( in sessionApplyOneOp()
4427 }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ in sessionApplyOneOp()
4428 rc = sessionConflictHandler( in sessionApplyOneOp()
4438 rc = sessionUpdateFind(pIter, p, bPatchset, &pUp); in sessionApplyOneOp()
4441 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionApplyOneOp()
4445 rc = sessionBindValue(pUp, i*2+2, pOld); in sessionApplyOneOp()
4447 if( rc==SQLITE_OK && pNew ){ in sessionApplyOneOp()
4448 rc = sessionBindValue(pUp, i*2+1, pNew); in sessionApplyOneOp()
4451 if( rc!=SQLITE_OK ) return rc; in sessionApplyOneOp()
4456 rc = sqlite3_reset(pUp); in sessionApplyOneOp()
4458 if( rc==SQLITE_OK && sqlite3_changes(p->db)==0 ){ in sessionApplyOneOp()
4463 rc = sessionConflictHandler( in sessionApplyOneOp()
4467 }else if( (rc&0xff)==SQLITE_CONSTRAINT ){ in sessionApplyOneOp()
4469 rc = sessionConflictHandler( in sessionApplyOneOp()
4480 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionApplyOneOp()
4481 if( rc==SQLITE_ROW ){ in sessionApplyOneOp()
4482 rc = SQLITE_CONSTRAINT; in sessionApplyOneOp()
4487 if( rc==SQLITE_OK ){ in sessionApplyOneOp()
4488 rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); in sessionApplyOneOp()
4489 if( rc!=SQLITE_OK ) return rc; in sessionApplyOneOp()
4492 rc = sqlite3_reset(p->pInsert); in sessionApplyOneOp()
4495 if( (rc&0xff)==SQLITE_CONSTRAINT ){ in sessionApplyOneOp()
4496 rc = sessionConflictHandler( in sessionApplyOneOp()
4502 return rc; in sessionApplyOneOp()
4524 int rc; in sessionApplyOneWithRetry() local
4526 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, &bReplace, &bRetry); in sessionApplyOneWithRetry()
4527 if( rc==SQLITE_OK ){ in sessionApplyOneWithRetry()
4537 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4547 rc = sqlite3_exec(db, "SAVEPOINT replace_op", 0, 0, 0); in sessionApplyOneWithRetry()
4548 if( rc==SQLITE_OK ){ in sessionApplyOneWithRetry()
4549 rc = sessionBindRow(pIter, in sessionApplyOneWithRetry()
4553 if( rc==SQLITE_OK ){ in sessionApplyOneWithRetry()
4555 rc = sqlite3_reset(pApply->pDelete); in sessionApplyOneWithRetry()
4557 if( rc==SQLITE_OK ){ in sessionApplyOneWithRetry()
4558 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4560 if( rc==SQLITE_OK ){ in sessionApplyOneWithRetry()
4561 rc = sqlite3_exec(db, "RELEASE replace_op", 0, 0, 0); in sessionApplyOneWithRetry()
4566 return rc; in sessionApplyOneWithRetry()
4580 int rc = SQLITE_OK; in sessionRetryConstraints() local
4587 rc = sessionChangesetStart( in sessionRetryConstraints()
4590 if( rc==SQLITE_OK ){ in sessionRetryConstraints()
4597 sessionBufferGrow(&pIter2->tblhdr, nByte, &rc); in sessionRetryConstraints()
4599 if( rc==SQLITE_OK ) memset(pIter2->apValue, 0, nByte); in sessionRetryConstraints()
4601 while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter2) ){ in sessionRetryConstraints()
4602 rc = sessionApplyOneWithRetry(db, pIter2, pApply, xConflict, pCtx); in sessionRetryConstraints()
4606 if( rc==SQLITE_OK ) rc = rc2; in sessionRetryConstraints()
4611 if( rc!=SQLITE_OK ) break; in sessionRetryConstraints()
4618 return rc; in sessionRetryConstraints()
4645 int rc = SQLITE_OK; /* Return code */ in sessionChangesetApply() local
4659 rc = sqlite3_exec(db, "SAVEPOINT changeset_apply", 0, 0, 0); in sessionChangesetApply()
4661 if( rc==SQLITE_OK ){ in sessionChangesetApply()
4662 rc = sqlite3_exec(db, "PRAGMA defer_foreign_keys = 1", 0, 0, 0); in sessionChangesetApply()
4664 while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter) ){ in sessionChangesetApply()
4674 rc = sessionRetryConstraints( in sessionChangesetApply()
4677 if( rc!=SQLITE_OK ) break; in sessionChangesetApply()
4703 rc = SQLITE_NOMEM; in sessionChangesetApply()
4713 rc = sessionTableInfo(0, in sessionChangesetApply()
4716 if( rc!=SQLITE_OK ) break; in sessionChangesetApply()
4744 if( (rc = sessionStat1Sql(db, &sApply) ) ){ in sessionChangesetApply()
4749 if( (rc = sessionSelectRow(db, zTab, &sApply)) in sessionChangesetApply()
4750 || (rc = sessionDeleteRow(db, zTab, &sApply)) in sessionChangesetApply()
4751 || (rc = sessionInsertRow(db, zTab, &sApply)) in sessionChangesetApply()
4766 rc = sessionApplyOneWithRetry(db, pIter, &sApply, xConflict, pCtx); in sessionChangesetApply()
4770 if( rc==SQLITE_OK ){ in sessionChangesetApply()
4771 rc = sqlite3changeset_finalize(pIter); in sessionChangesetApply()
4776 if( rc==SQLITE_OK ){ in sessionChangesetApply()
4777 rc = sessionRetryConstraints(db, bPatchset, zTab, &sApply, xConflict, pCtx); in sessionChangesetApply()
4780 if( rc==SQLITE_OK ){ in sessionChangesetApply()
4790 rc = SQLITE_CONSTRAINT; in sessionChangesetApply()
4797 if( rc==SQLITE_OK ){ in sessionChangesetApply()
4798 rc = sqlite3_exec(db, "RELEASE changeset_apply", 0, 0, 0); in sessionChangesetApply()
4806 if( rc==SQLITE_OK && bPatchset==0 && sApply.bRebase ){ in sessionChangesetApply()
4819 return rc; in sessionChangesetApply()
4845 int rc = sessionChangesetStart(&pIter, 0, 0, nChangeset, pChangeset, bInv, 1); in sqlite3changeset_apply_v2() local
4846 if( rc==SQLITE_OK ){ in sqlite3changeset_apply_v2()
4847 rc = sessionChangesetApply( in sqlite3changeset_apply_v2()
4851 return rc; in sqlite3changeset_apply_v2()
4903 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse, 1); in sqlite3changeset_apply_v2_strm() local
4904 if( rc==SQLITE_OK ){ in sqlite3changeset_apply_v2_strm()
4905 rc = sessionChangesetApply( in sqlite3changeset_apply_v2_strm()
4909 return rc; in sqlite3changeset_apply_v2_strm()
4935 int rc; /* Error code */ member
4957 int rc = SQLITE_OK; in sessionChangeMerge() local
4996 rc = SQLITE_NOMEM; in sessionChangeMerge()
5120 return rc; in sessionChangeMerge()
5134 int rc = SQLITE_OK; in sessionChangesetToHash() local
5150 rc = SQLITE_ERROR; in sessionChangesetToHash()
5169 rc = SQLITE_NOMEM; in sessionChangesetToHash()
5186 rc = SQLITE_SCHEMA; in sessionChangesetToHash()
5192 rc = SQLITE_NOMEM; in sessionChangesetToHash()
5217 rc = sessionChangeMerge(pTab, bRebase, in sessionChangesetToHash()
5220 if( rc ) break; in sessionChangesetToHash()
5228 if( rc==SQLITE_OK ) rc = pIter->rc; in sessionChangesetToHash()
5229 return rc; in sessionChangesetToHash()
5257 int rc = SQLITE_OK; in sessionChangegroupOutput() local
5265 for(pTab=pGrp->pList; rc==SQLITE_OK && pTab; pTab=pTab->pNext){ in sessionChangegroupOutput()
5269 sessionAppendTableHdr(&buf, pGrp->bPatch, pTab, &rc); in sessionChangegroupOutput()
5273 sessionAppendByte(&buf, p->op, &rc); in sessionChangegroupOutput()
5274 sessionAppendByte(&buf, p->bIndirect, &rc); in sessionChangegroupOutput()
5275 sessionAppendBlob(&buf, p->aRecord, p->nRecord, &rc); in sessionChangegroupOutput()
5276 if( rc==SQLITE_OK && xOutput && buf.nBuf>=sessions_strm_chunk_size ){ in sessionChangegroupOutput()
5277 rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5284 if( rc==SQLITE_OK ){ in sessionChangegroupOutput()
5286 if( buf.nBuf>0 ) rc = xOutput(pOut, buf.aBuf, buf.nBuf); in sessionChangegroupOutput()
5295 return rc; in sessionChangegroupOutput()
5302 int rc = SQLITE_OK; /* Return code */ in sqlite3changegroup_new() local
5306 rc = SQLITE_NOMEM; in sqlite3changegroup_new()
5311 return rc; in sqlite3changegroup_new()
5320 int rc; /* Return code */ in sqlite3changegroup_add() local
5322 rc = sqlite3changeset_start(&pIter, nData, pData); in sqlite3changegroup_add()
5323 if( rc==SQLITE_OK ){ in sqlite3changegroup_add()
5324 rc = sessionChangesetToHash(pIter, pGrp, 0); in sqlite3changegroup_add()
5327 return rc; in sqlite3changegroup_add()
5351 int rc; /* Return code */ in sqlite3changegroup_add_strm() local
5353 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3changegroup_add_strm()
5354 if( rc==SQLITE_OK ){ in sqlite3changegroup_add_strm()
5355 rc = sessionChangesetToHash(pIter, pGrp, 0); in sqlite3changegroup_add_strm()
5358 return rc; in sqlite3changegroup_add_strm()
5394 int rc; in sqlite3changeset_concat() local
5396 rc = sqlite3changegroup_new(&pGrp); in sqlite3changeset_concat()
5397 if( rc==SQLITE_OK ){ in sqlite3changeset_concat()
5398 rc = sqlite3changegroup_add(pGrp, nLeft, pLeft); in sqlite3changeset_concat()
5400 if( rc==SQLITE_OK ){ in sqlite3changeset_concat()
5401 rc = sqlite3changegroup_add(pGrp, nRight, pRight); in sqlite3changeset_concat()
5403 if( rc==SQLITE_OK ){ in sqlite3changeset_concat()
5404 rc = sqlite3changegroup_output(pGrp, pnOut, ppOut); in sqlite3changeset_concat()
5408 return rc; in sqlite3changeset_concat()
5423 int rc; in sqlite3changeset_concat_strm() local
5425 rc = sqlite3changegroup_new(&pGrp); in sqlite3changeset_concat_strm()
5426 if( rc==SQLITE_OK ){ in sqlite3changeset_concat_strm()
5427 rc = sqlite3changegroup_add_strm(pGrp, xInputA, pInA); in sqlite3changeset_concat_strm()
5429 if( rc==SQLITE_OK ){ in sqlite3changeset_concat_strm()
5430 rc = sqlite3changegroup_add_strm(pGrp, xInputB, pInB); in sqlite3changeset_concat_strm()
5432 if( rc==SQLITE_OK ){ in sqlite3changeset_concat_strm()
5433 rc = sqlite3changegroup_output_strm(pGrp, xOutput, pOut); in sqlite3changeset_concat_strm()
5437 return rc; in sqlite3changeset_concat_strm()
5578 int rc = SQLITE_OK; in sessionRebase() local
5598 rc = SQLITE_ERROR; in sessionRebase()
5602 sessionAppendByte(&sOut, pIter->bPatchset ? 'P' : 'T', &rc); in sessionRebase()
5603 sessionAppendVarint(&sOut, pIter->nCol, &rc); in sessionRebase()
5604 sessionAppendBlob(&sOut, pIter->abPK, pIter->nCol, &rc); in sessionRebase()
5605 sessionAppendBlob(&sOut,(u8*)pIter->zTab,(int)strlen(pIter->zTab)+1,&rc); in sessionRebase()
5608 if( pTab && rc==SQLITE_OK ){ in sessionRebase()
5625 sessionAppendByte(&sOut, SQLITE_UPDATE, &rc); in sessionRebase()
5626 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5627 sessionAppendBlob(&sOut, pChange->aRecord, pChange->nRecord, &rc); in sessionRebase()
5628 sessionAppendBlob(&sOut, aRec, nRec, &rc); in sessionRebase()
5639 sessionAppendByte(&sOut, SQLITE_INSERT, &rc); in sessionRebase()
5640 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5643 pChange->aRecord, pChange->nRecord, &rc in sessionRebase()
5648 aRec, nRec, pChange->aRecord, pChange->nRecord, &rc in sessionRebase()
5657 sessionAppendByte(&sOut, SQLITE_DELETE, &rc); in sessionRebase()
5658 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5660 pChange->aRecord, pChange->nRecord, aRec, nRec, &rc in sessionRebase()
5668 sessionAppendByte(&sOut, pIter->op, &rc); in sessionRebase()
5669 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5670 sessionAppendBlob(&sOut, aRec, nRec, &rc); in sessionRebase()
5672 if( rc==SQLITE_OK && xOutput && sOut.nBuf>sessions_strm_chunk_size ){ in sessionRebase()
5673 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5676 if( rc ) break; in sessionRebase()
5679 if( rc!=SQLITE_OK ){ in sessionRebase()
5684 if( rc==SQLITE_OK ){ in sessionRebase()
5687 rc = xOutput(pOut, sOut.aBuf, sOut.nBuf); in sessionRebase()
5696 return rc; in sessionRebase()
5703 int rc = SQLITE_OK; in sqlite3rebaser_create() local
5708 rc = SQLITE_NOMEM; in sqlite3rebaser_create()
5713 return rc; in sqlite3rebaser_create()
5724 int rc; /* Return code */ in sqlite3rebaser_configure() local
5725 rc = sqlite3changeset_start(&pIter, nRebase, (void*)pRebase); in sqlite3rebaser_configure()
5726 if( rc==SQLITE_OK ){ in sqlite3rebaser_configure()
5727 rc = sessionChangesetToHash(pIter, &p->grp, 1); in sqlite3rebaser_configure()
5730 return rc; in sqlite3rebaser_configure()
5742 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn); in sqlite3rebaser_rebase() local
5744 if( rc==SQLITE_OK ){ in sqlite3rebaser_rebase()
5745 rc = sessionRebase(p, pIter, 0, 0, pnOut, ppOut); in sqlite3rebaser_rebase()
5749 return rc; in sqlite3rebaser_rebase()
5763 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3rebaser_rebase_strm() local
5765 if( rc==SQLITE_OK ){ in sqlite3rebaser_rebase_strm()
5766 rc = sessionRebase(p, pIter, xOutput, pOut, 0, 0); in sqlite3rebaser_rebase_strm()
5770 return rc; in sqlite3rebaser_rebase_strm()
5787 int rc = SQLITE_OK; in sqlite3session_config() local
5798 rc = SQLITE_MISUSE; in sqlite3session_config()
5801 return rc; in sqlite3session_config()