Lines Matching refs:op
101 int op; /* Current operation */ member
296 u8 op; /* One of UPDATE, DELETE, INSERT */ member
851 int op /* Current pre-update operation */ in sessionPreupdateEqual() argument
856 assert( op==SQLITE_INSERT || op==SQLITE_UPDATE || op==SQLITE_DELETE ); in sessionPreupdateEqual()
870 if( op==SQLITE_INSERT ){ in sessionPreupdateEqual()
951 int bPkOnly = (p->op==SQLITE_DELETE && bPatchset); in sessionGrowHash()
1195 int op, in sessionUpdateMaxSize() argument
1201 if( pC->op==SQLITE_INSERT ){ in sessionUpdateMaxSize()
1202 if( op!=SQLITE_DELETE ){ in sessionUpdateMaxSize()
1210 }else if( op==SQLITE_DELETE ){ in sessionUpdateMaxSize()
1301 int op, /* One of SQLITE_UPDATE, INSERT, DELETE */ in sessionPreupdateOneChange() argument
1350 rc = sessionPreupdateHash(pSession, pTab, op==SQLITE_INSERT, &iHash, &bNull); in sessionPreupdateOneChange()
1357 if( sessionPreupdateEqual(pSession, pTab, pC, op) ) break; in sessionPreupdateOneChange()
1374 if( op!=SQLITE_INSERT ){ in sessionPreupdateOneChange()
1405 if( op!=SQLITE_INSERT ){ in sessionPreupdateOneChange()
1418 pC->op = op; in sessionPreupdateOneChange()
1434 rc = sessionUpdateMaxSize(op, pSession, pTab, pC); in sessionPreupdateOneChange()
1492 int op, /* SQLITE_UPDATE, DELETE or INSERT */ in xPreUpdate() argument
1516 sessionPreupdateOneChange(op, pSession, pTab); in xPreUpdate()
1517 if( op==SQLITE_UPDATE ){ in xPreUpdate()
1667 int op, in sessionDiffFindNew() argument
1687 sessionPreupdateOneChange(op, pSession, pTab); in sessionDiffFindNew()
2605 if( p->op==SQLITE_INSERT ){ in sessionGenerateChangeset()
2616 }else if( p->op!=SQLITE_INSERT ){ in sessionGenerateChangeset()
2779 int sqlite3session_object_config(sqlite3_session *pSession, int op, void *pArg){ in sqlite3session_object_config() argument
2781 switch( op ){ in sqlite3session_object_config()
3226 u8 op; in sessionChangesetNextOne() local
3257 op = p->in.aData[p->in.iNext++]; in sessionChangesetNextOne()
3258 while( op=='T' || op=='P' ){ in sessionChangesetNextOne()
3260 p->bPatchset = (op=='P'); in sessionChangesetNextOne()
3265 op = p->in.aData[p->in.iNext++]; in sessionChangesetNextOne()
3275 p->op = op; in sessionChangesetNextOne()
3277 if( p->op!=SQLITE_UPDATE && p->op!=SQLITE_DELETE && p->op!=SQLITE_INSERT ){ in sessionChangesetNextOne()
3283 if( p->bPatchset==0 && op==SQLITE_UPDATE ){ in sessionChangesetNextOne()
3285 }else if( p->bPatchset && op==SQLITE_DELETE ){ in sessionChangesetNextOne()
3300 if( p->op!=SQLITE_INSERT && (p->bPatchset==0 || p->op==SQLITE_DELETE) ){ in sessionChangesetNextOne()
3307 if( p->op!=SQLITE_DELETE ){ in sessionChangesetNextOne()
3312 if( (p->bPatchset || p->bInvert) && p->op==SQLITE_UPDATE ){ in sessionChangesetNextOne()
3327 if( p->op==SQLITE_INSERT ) p->op = SQLITE_DELETE; in sessionChangesetNextOne()
3328 else if( p->op==SQLITE_DELETE ) p->op = SQLITE_INSERT; in sessionChangesetNextOne()
3390 *pOp = pIter->op; in sqlite3changeset_op()
3431 if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_DELETE ){ in sqlite3changeset_old()
3459 if( pIter->op!=SQLITE_UPDATE && pIter->op!=SQLITE_INSERT ){ in sqlite3changeset_new()
4183 int op; /* Changset operation (SQLITE_UPDATE etc.) */ in sessionSeekToRow() local
4186 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionSeekToRow()
4188 op==SQLITE_INSERT ? sqlite3changeset_new : sqlite3changeset_old, in sessionSeekToRow()
4218 int eOp = pIter->op; in sessionRebaseAdd()
4295 int op; in sessionConflictHandler() local
4298 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionConflictHandler()
4391 int op; in sessionApplyOneOp() local
4399 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionApplyOneOp()
4401 if( op==SQLITE_DELETE ){ in sessionApplyOneOp()
4433 }else if( op==SQLITE_UPDATE ){ in sessionApplyOneOp()
4475 assert( op==SQLITE_INSERT ); in sessionApplyOneOp()
4536 assert( pIter->op==SQLITE_UPDATE || pIter->op==SQLITE_DELETE ); in sessionApplyOneWithRetry()
4546 assert( pIter->op==SQLITE_INSERT ); in sessionApplyOneWithRetry()
4666 int op; in sessionChangesetApply() local
4669 sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); in sessionChangesetApply()
4965 pNew->op = op2; in sessionChangeMerge()
4990 if( pExist->op==SQLITE_DELETE && pExist->bIndirect ){ in sessionChangeMerge()
5005 pNew->op = op2; in sessionChangeMerge()
5028 int op1 = pExist->op; in sessionChangeMerge()
5073 pNew->op = SQLITE_INSERT; in sessionChangeMerge()
5078 pNew->op = SQLITE_UPDATE; in sessionChangeMerge()
5096 pNew->op = SQLITE_UPDATE; in sessionChangeMerge()
5103 pNew->op = SQLITE_DELETE; in sessionChangeMerge()
5140 int op; in sessionChangesetToHash() local
5154 sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); in sessionChangesetToHash()
5196 pTab, (pIter->bPatchset && op==SQLITE_DELETE), aRec, pTab->nChange in sessionChangesetToHash()
5206 bPkOnly1 = (*pp)->op==SQLITE_DELETE; in sessionChangesetToHash()
5207 bPkOnly2 = op==SQLITE_DELETE; in sessionChangesetToHash()
5218 pIter->bPatchset, pExist, op, bIndirect, aRec, nRec, &pChange in sessionChangesetToHash()
5273 sessionAppendByte(&buf, p->op, &rc); in sessionChangegroupOutput()
5619 assert( pChange->op==SQLITE_DELETE || pChange->op==SQLITE_INSERT ); in sessionRebase()
5620 switch( pIter->op ){ in sessionRebase()
5622 if( pChange->op==SQLITE_INSERT ){ in sessionRebase()
5635 if( pChange->op==SQLITE_DELETE ){ in sessionRebase()
5654 assert( pIter->op==SQLITE_DELETE ); in sessionRebase()
5656 if( pChange->op==SQLITE_INSERT ){ in sessionRebase()
5668 sessionAppendByte(&sOut, pIter->op, &rc); in sessionRebase()
5786 int sqlite3session_config(int op, void *pArg){ in sqlite3session_config() argument
5788 switch( op ){ in sqlite3session_config()