Lines Matching refs:pIter
3384 sqlite3_changeset_iter *pIter, /* Iterator handle */ in sqlite3changeset_op() argument
3390 *pOp = pIter->op; in sqlite3changeset_op()
3391 *pnCol = pIter->nCol; in sqlite3changeset_op()
3392 *pzTab = pIter->zTab; in sqlite3changeset_op()
3393 if( pbIndirect ) *pbIndirect = pIter->bIndirect; in sqlite3changeset_op()
3404 sqlite3_changeset_iter *pIter, /* Iterator object */ in sqlite3changeset_pk() argument
3408 *pabPK = pIter->abPK; in sqlite3changeset_pk()
3409 if( pnCol ) *pnCol = pIter->nCol; in sqlite3changeset_pk()
3427 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sqlite3changeset_old() argument
3431 if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_DELETE ){ in sqlite3changeset_old()
3434 if( iVal<0 || iVal>=pIter->nCol ){ in sqlite3changeset_old()
3437 *ppValue = pIter->apValue[iVal]; in sqlite3changeset_old()
3455 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sqlite3changeset_new() argument
3459 if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_INSERT ){ in sqlite3changeset_new()
3462 if( iVal<0 || iVal>=pIter->nCol ){ in sqlite3changeset_new()
3465 *ppValue = pIter->apValue[pIter->nCol+iVal]; in sqlite3changeset_new()
3474 #define sessionChangesetNew(pIter, iVal) (pIter)->apValue[(pIter)->nCol+(iVal)] argument
3475 #define sessionChangesetOld(pIter, iVal) (pIter)->apValue[(iVal)] argument
3489 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sqlite3changeset_conflict() argument
3493 if( !pIter->pConflict ){ in sqlite3changeset_conflict()
3496 if( iVal<0 || iVal>=pIter->nCol ){ in sqlite3changeset_conflict()
3499 *ppValue = sqlite3_column_value(pIter->pConflict, iVal); in sqlite3changeset_conflict()
3512 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sqlite3changeset_fk_conflicts() argument
3515 if( pIter->pConflict || pIter->apValue ){ in sqlite3changeset_fk_conflicts()
3518 *pnOut = pIter->nCol; in sqlite3changeset_fk_conflicts()
3779 sqlite3_changeset_iter *pIter, in sessionUpdateFind() argument
3786 int nCol = pIter->nCol; in sessionUpdateFind()
3787 int nU32 = (pIter->nCol+33)/32; in sessionUpdateFind()
3800 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3801 if( sessionChangesetNew(pIter, ii) ){ in sessionUpdateFind()
3839 int bStat1 = (sqlite3_stricmp(pIter->zTab, "sqlite_stat1")==0); in sessionUpdateFind()
3852 sessionAppendIdent(&buf, pIter->zTab, &rc); in sessionUpdateFind()
3856 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3857 if( p->abPK[ii]==0 && sessionChangesetNew(pIter, ii) ){ in sessionUpdateFind()
3869 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3870 if( p->abPK[ii] || (bPatchset==0 && sessionChangesetOld(pIter, ii)) ){ in sessionUpdateFind()
4127 sqlite3_changeset_iter *pIter, /* Iterator to read values from */ in sessionBindRow() argument
4145 (void)xValue(pIter, i, &pVal); in sessionBindRow()
4177 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sessionSeekToRow() argument
4186 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionSeekToRow()
4187 rc = sessionBindRow(pIter, in sessionSeekToRow()
4213 sqlite3_changeset_iter *pIter /* Iterator pointing at current change */ in sessionRebaseAdd() argument
4218 int eOp = pIter->op; in sessionRebaseAdd()
4221 const char *zTab = pIter->zTab; in sessionRebaseAdd()
4239 sqlite3changeset_old(pIter, i, &pVal); in sessionRebaseAdd()
4241 sqlite3changeset_new(pIter, i, &pVal); in sessionRebaseAdd()
4287 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sessionConflictHandler() argument
4298 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionConflictHandler()
4306 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionConflictHandler()
4313 pIter->pConflict = p->pSelect; in sessionConflictHandler()
4314 res = xConflict(pCtx, eType, pIter); in sessionConflictHandler()
4315 pIter->pConflict = 0; in sessionConflictHandler()
4321 u8 *aBlob = &pIter->in.aData[pIter->in.iCurrent]; in sessionConflictHandler()
4322 int nBlob = pIter->in.iNext - pIter->in.iCurrent; in sessionConflictHandler()
4327 res = xConflict(pCtx, eType+1, pIter); in sessionConflictHandler()
4351 rc = sessionRebaseAdd(p, res, pIter); in sessionConflictHandler()
4383 sqlite3_changeset_iter *pIter, /* Changeset iterator */ in sessionApplyOneOp() argument
4399 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionApplyOneOp()
4414 u8 *abPK = (pIter->bPatchset ? p->abPK : 0); in sessionApplyOneOp()
4415 rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); in sessionApplyOneOp()
4425 SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry in sessionApplyOneOp()
4429 SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 in sessionApplyOneOp()
4436 int bPatchset = (pbRetry==0 || pIter->bPatchset); in sessionApplyOneOp()
4438 rc = sessionUpdateFind(pIter, p, bPatchset, &pUp); in sessionApplyOneOp()
4442 sqlite3_value *pOld = sessionChangesetOld(pIter, i); in sessionApplyOneOp()
4443 sqlite3_value *pNew = sessionChangesetNew(pIter, i); in sessionApplyOneOp()
4464 SQLITE_CHANGESET_DATA, p, pIter, xConflict, pCtx, pbRetry in sessionApplyOneOp()
4470 SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, 0 in sessionApplyOneOp()
4480 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionApplyOneOp()
4488 rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); in sessionApplyOneOp()
4497 SQLITE_CHANGESET_CONFLICT, p, pIter, xConflict, pCtx, pbReplace in sessionApplyOneOp()
4517 sqlite3_changeset_iter *pIter, /* Changeset iterator to read change from */ in sessionApplyOneWithRetry() argument
4526 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, &bReplace, &bRetry); in sessionApplyOneWithRetry()
4536 assert( pIter->op==SQLITE_UPDATE || pIter->op==SQLITE_DELETE ); in sessionApplyOneWithRetry()
4537 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4546 assert( pIter->op==SQLITE_INSERT ); in sessionApplyOneWithRetry()
4549 rc = sessionBindRow(pIter, in sessionApplyOneWithRetry()
4558 rc = sessionApplyOneOp(pIter, pApply, xConflict, pCtx, 0, 0); in sessionApplyOneWithRetry()
4630 sqlite3_changeset_iter *pIter, /* Changeset to apply */ in sessionChangesetApply() argument
4653 pIter->in.bNoDiscard = 1; in sessionChangesetApply()
4664 while( rc==SQLITE_OK && SQLITE_ROW==sqlite3changeset_next(pIter) ){ in sessionChangesetApply()
4669 sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); in sessionChangesetApply()
4675 db, pIter->bPatchset, zTab, &sApply, xConflict, pCtx in sessionChangesetApply()
4712 sqlite3changeset_pk(pIter, &abPK, 0); in sessionChangesetApply()
4766 rc = sessionApplyOneWithRetry(db, pIter, &sApply, xConflict, pCtx); in sessionChangesetApply()
4769 bPatchset = pIter->bPatchset; in sessionChangesetApply()
4771 rc = sqlite3changeset_finalize(pIter); in sessionChangesetApply()
4773 sqlite3changeset_finalize(pIter); in sessionChangesetApply()
4843 sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ in sqlite3changeset_apply_v2() local
4845 int rc = sessionChangesetStart(&pIter, 0, 0, nChangeset, pChangeset, bInv, 1); in sqlite3changeset_apply_v2()
4848 db, pIter, xFilter, xConflict, pCtx, ppRebase, pnRebase, flags in sqlite3changeset_apply_v2()
4901 sqlite3_changeset_iter *pIter; /* Iterator to skip through changeset */ in sqlite3changeset_apply_v2_strm() local
4903 int rc = sessionChangesetStart(&pIter, xInput, pIn, 0, 0, bInverse, 1); in sqlite3changeset_apply_v2_strm()
4906 db, pIter, xFilter, xConflict, pCtx, ppRebase, pnRebase, flags in sqlite3changeset_apply_v2_strm()
5128 sqlite3_changeset_iter *pIter, /* Iterator to read from */ in sessionChangesetToHash() argument
5137 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, 0) ){ in sessionChangesetToHash()
5148 pGrp->bPatch = pIter->bPatchset; in sessionChangesetToHash()
5149 }else if( pIter->bPatchset!=pGrp->bPatch ){ in sessionChangesetToHash()
5154 sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); in sessionChangesetToHash()
5160 sqlite3changeset_pk(pIter, &abPK, 0); in sessionChangesetToHash()
5191 if( sessionGrowHash(0, pIter->bPatchset, pTab) ){ in sessionChangesetToHash()
5196 pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange in sessionChangesetToHash()
5205 if( pIter->bPatchset ){ in sessionChangesetToHash()
5218 pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange in sessionChangesetToHash()
5228 if( rc==SQLITE_OK ) rc = pIter->rc; in sessionChangesetToHash()
5319 sqlite3_changeset_iter *pIter; /* Iterator opened on pData/nData */ in sqlite3changegroup_add() local
5322 rc = sqlite3changeset_start(&pIter, nData, pData); in sqlite3changegroup_add()
5324 rc = sessionChangesetToHash(pIter, pGrp, 0); in sqlite3changegroup_add()
5326 sqlite3changeset_finalize(pIter); in sqlite3changegroup_add()
5350 sqlite3_changeset_iter *pIter; /* Iterator opened on pData/nData */ in sqlite3changegroup_add_strm() local
5353 rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3changegroup_add_strm()
5355 rc = sessionChangesetToHash(pIter, pGrp, 0); in sqlite3changegroup_add_strm()
5357 sqlite3changeset_finalize(pIter); in sqlite3changegroup_add_strm()
5504 sqlite3_changeset_iter *pIter, /* Iterator pointed at local change */ in sessionAppendPartialUpdate() argument
5518 *pOut++ = pIter->bIndirect; in sessionAppendPartialUpdate()
5519 for(i=0; i<pIter->nCol; i++){ in sessionAppendPartialUpdate()
5522 if( pIter->abPK[i] || a2[0]==0 ){ in sessionAppendPartialUpdate()
5523 if( !pIter->abPK[i] && a1[0] ) bData = 1; in sessionAppendPartialUpdate()
5538 for(i=0; i<pIter->nCol; i++){ in sessionAppendPartialUpdate()
5541 if( pIter->abPK[i] || a2[0]!=0xFF ){ in sessionAppendPartialUpdate()
5572 sqlite3_changeset_iter *pIter, /* Input data */ in sessionRebase() argument
5585 while( SQLITE_ROW==sessionChangesetNext(pIter, &aRec, &nRec, &bNew) ){ in sessionRebase()
5590 const char *zTab = pIter->zTab; in sessionRebase()
5597 if( pIter->bPatchset ){ 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()
5620 switch( pIter->op ){ in sessionRebase()
5626 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5638 sessionSkipRecord(&pCsr, pIter->nCol); in sessionRebase()
5640 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5641 sessionAppendRecordMerge(&sOut, pIter->nCol, in sessionRebase()
5647 sessionAppendPartialUpdate(&sOut, pIter, in sessionRebase()
5654 assert( pIter->op==SQLITE_DELETE ); in sessionRebase()
5658 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5659 sessionAppendRecordMerge(&sOut, pIter->nCol, in sessionRebase()
5668 sessionAppendByte(&sOut, pIter->op, &rc); in sessionRebase()
5669 sessionAppendByte(&sOut, pIter->bIndirect, &rc); in sessionRebase()
5723 sqlite3_changeset_iter *pIter = 0; /* Iterator opened on pData/nData */ in sqlite3rebaser_configure() local
5725 rc = sqlite3changeset_start(&pIter, nRebase, (void*)pRebase); in sqlite3rebaser_configure()
5727 rc = sessionChangesetToHash(pIter, &p->grp, 1); in sqlite3rebaser_configure()
5729 sqlite3changeset_finalize(pIter); in sqlite3rebaser_configure()
5741 sqlite3_changeset_iter *pIter = 0; /* Iterator to skip through input */ in sqlite3rebaser_rebase() local
5742 int rc = sqlite3changeset_start(&pIter, nIn, (void*)pIn); in sqlite3rebaser_rebase()
5745 rc = sessionRebase(p, pIter, 0, 0, pnOut, ppOut); in sqlite3rebaser_rebase()
5746 sqlite3changeset_finalize(pIter); in sqlite3rebaser_rebase()
5762 sqlite3_changeset_iter *pIter = 0; /* Iterator to skip through input */ in sqlite3rebaser_rebase_strm() local
5763 int rc = sqlite3changeset_start_strm(&pIter, xInput, pIn); in sqlite3rebaser_rebase_strm()
5766 rc = sessionRebase(p, pIter, xOutput, pOut, 0, 0); in sqlite3rebaser_rebase_strm()
5767 sqlite3changeset_finalize(pIter); in sqlite3rebaser_rebase_strm()