Lines Matching refs:abPK
103 u8 *abPK; /* Primary key array */ member
126 u8 *abPK; /* Array of primary key flags */ member
528 if( pTab->abPK[i] ){ in sessionPreupdateHash()
610 int isPK = pTab->abPK[i]; in sessionChangeHash()
659 if( pTab->abPK[iCol] ){ in sessionChangeEqual()
801 if( pTab->abPK[i] || nOld!=nNew || memcmp(aOld, aNew, nNew) ){ in sessionMergeUpdate()
802 if( pTab->abPK[i]==0 ) bRequired = 1; in sessionMergeUpdate()
827 && (pTab->abPK[i] || (nOld==nNew && 0==memcmp(aOld, aNew, nNew))) in sessionMergeUpdate()
858 if( !pTab->abPK[iCol] ){ in sessionPreupdateEqual()
1011 u8 *abPK = 0; in sessionTableInfo() local
1072 abPK = (u8 *)pAlloc; in sessionTableInfo()
1073 pAlloc = &abPK[nDbCol]; in sessionTableInfo()
1088 abPK[i] = sqlite3_column_int(pStmt, 5); in sessionTableInfo()
1100 *pabPK = abPK; in sessionTableInfo()
1127 u8 *abPK; in sessionInitTable() local
1128 assert( pTab->azCol==0 || pTab->abPK==0 ); in sessionInitTable()
1130 pTab->zName, &pTab->nCol, 0, &pTab->azCol, &abPK in sessionInitTable()
1135 if( abPK[i] ){ in sessionInitTable()
1136 pTab->abPK = abPK; in sessionInitTable()
1151 return (pSession->rc || pTab->abPK==0); in sessionInitTable()
1268 if( bChanged && pTab->abPK[ii] ){ in sessionUpdateMaxSize()
1276 }else if( pTab->abPK[ii] ){ in sessionUpdateMaxSize()
1377 }else if( pTab->abPK[i] ){ in sessionPreupdateOneChange()
1407 }else if( pTab->abPK[i] ){ in sessionPreupdateOneChange()
1600 const char **azCol, u8 *abPK in sessionExprComparePK() argument
1607 if( abPK[i] ){ in sessionExprComparePK()
1623 const char **azCol, u8 *abPK in sessionExprCompareOther() argument
1631 if( abPK[i]==0 ){ in sessionExprCompareOther()
1706 pSession->zDb, zFrom, pTab->zName, pTab->azCol, pTab->abPK in sessionDiffFindModified()
1770 u8 *abPK; in sqlite3session_diff() local
1772 rc = sessionTableInfo(0, db, zFrom, zTbl, &nCol, 0, &azCol, &abPK); in sqlite3session_diff()
1779 if( pTo->abPK[i]!=abPK[i] ) bMismatch = 1; in sqlite3session_diff()
1781 if( abPK[i] ) bHasPk = 1; in sqlite3session_diff()
1800 zDb, zFrom, pTo->zName, pTo->azCol, pTo->abPK in sqlite3session_diff()
2239 u8 *abPK /* Boolean array - true for PK columns */ in sessionAppendUpdate() argument
2248 assert( abPK!=0 ); in sessionAppendUpdate()
2301 if( bChanged || abPK[i] ){ in sessionAppendUpdate()
2310 if( bChanged || (bPatchset && abPK[i]) ){ in sessionAppendUpdate()
2339 u8 *abPK /* Boolean array - true for PK columns */ in sessionAppendDelete() argument
2358 assert( abPK[i]==0 ); in sessionAppendDelete()
2373 if( abPK[i] ){ in sessionAppendDelete()
2395 u8 *abPK, /* PRIMARY KEY array */ in sessionSelectStmt() argument
2419 if( abPK[i] ){ in sessionSelectStmt()
2449 u8 *abPK, /* PRIMARY KEY array */ in sessionSelectBind() argument
2462 assert( abPK[i]==0 ); in sessionSelectBind()
2466 if( abPK[i] ){ in sessionSelectBind()
2475 if( abPK[i] ){ in sessionSelectBind()
2488 if( abPK[i] ){ in sessionSelectBind()
2499 if( abPK[i] ){ in sessionSelectBind()
2526 sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc); in sessionAppendTableHdr()
2575 u8 *abPK = 0; /* Primary key array */ in sessionGenerateChangeset() local
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()
2594 db, pSession->zDb, zName, nCol, azCol, abPK, &pSel); in sessionGenerateChangeset()
2602 rc = sessionSelectBind(pSel, nCol, abPK, p); in sessionGenerateChangeset()
2613 assert( abPK!=0 ); /* Because sessionSelectStmt() returned ok */ in sessionGenerateChangeset()
2614 rc = sessionAppendUpdate(&buf, bPatchset, pSel, p, abPK); in sessionGenerateChangeset()
2617 rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); in sessionGenerateChangeset()
3009 u8 *abPK, /* Array of primary key flags, or NULL */ in sessionReadRecord() argument
3020 if( abPK && abPK[i]==0 ) continue; in sessionReadRecord()
3199 p->abPK = 0; in sessionChangesetReadTblhdr()
3202 p->abPK = (u8*)&p->apValue[p->nCol*2]; in sessionChangesetReadTblhdr()
3203 p->zTab = p->abPK ? (char*)&p->abPK[p->nCol] : 0; in sessionChangesetReadTblhdr()
3287 for(i=0; i<p->nCol; i++) if( p->abPK[i] ) nVal++; in sessionChangesetNextOne()
3301 u8 *abPK = p->bPatchset ? p->abPK : 0; in sessionChangesetNextOne() local
3302 p->rc = sessionReadRecord(&p->in, p->nCol, abPK, apOld, 0); in sessionChangesetNextOne()
3319 if( p->abPK[i] ){ in sessionChangesetNextOne()
3408 *pabPK = pIter->abPK; in sqlite3changeset_pk()
3554 u8 *abPK = 0; /* PK array for current table */ in sessionChangesetInvert() local
3600 abPK = sPK.aBuf; in sessionChangesetInvert()
3647 sqlite3_value *pVal = apVal[iCol + (abPK[iCol] ? 0 : nCol)]; in sessionChangesetInvert()
3655 sqlite3_value *pVal = (abPK[iCol] ? 0 : apVal[iCol]); in sessionChangesetInvert()
3757 u8 *abPK; /* Boolean array - true if column is in PK */ member
3857 if( p->abPK[ii]==0 && sessionChangesetNew(pIter, ii) ){ in sessionUpdateFind()
3870 if( p->abPK[ii] || (bPatchset==0 && sessionChangesetOld(pIter, ii)) ){ in sessionUpdateFind()
3963 if( p->abPK[i] ){ in sessionDeleteRow()
3980 if( !p->abPK[i] ){ in sessionDeleteRow()
4018 db, "main", zTab, p->nCol, p->azCol, p->abPK, &p->pSelect); in sessionSelectRow()
4130 u8 *abPK, /* If not NULL, bind only if true */ in sessionBindRow() argument
4143 if( !abPK || abPK[i] ){ in sessionBindRow()
4178 u8 *abPK, /* Primary key flags array */ in sessionSeekToRow() argument
4189 nCol, abPK, pSelect in sessionSeekToRow()
4224 sessionAppendBlob(&p->rebase, p->abPK, p->nCol, &rc); in sessionRebaseAdd()
4238 if( eOp==SQLITE_DELETE || (eOp==SQLITE_UPDATE && p->abPK[i]) ){ in sessionRebaseAdd()
4306 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionConflictHandler()
4396 assert( p->azCol && p->abPK ); in sessionApplyOneOp()
4414 u8 *abPK = (pIter->bPatchset ? p->abPK : 0); in sessionApplyOneOp() local
4415 rc = sessionBindRow(pIter, sqlite3changeset_old, nCol, abPK, p->pDelete); in sessionApplyOneOp()
4417 rc = sqlite3_bind_int(p->pDelete, nCol+1, (pbRetry==0 || abPK)); in sessionApplyOneOp()
4444 if( p->abPK[i] || (bPatchset==0 && pOld) ){ in sessionApplyOneOp()
4480 rc = sessionSeekToRow(p->db, pIter, p->abPK, p->pSelect); in sessionApplyOneOp()
4550 sqlite3changeset_new, pApply->nCol, pApply->abPK, pApply->pDelete); in sessionApplyOneWithRetry()
4596 pIter2->abPK = pApply->abPK; in sessionRetryConstraints()
4672 u8 *abPK; in sessionChangesetApply() local
4690 sApply.abPK = 0; in sessionChangesetApply()
4712 sqlite3changeset_pk(pIter, &abPK, 0); in sessionChangesetApply()
4714 db, "main", zNew, &sApply.nCol, &zTab, &sApply.azCol, &sApply.abPK in sessionChangesetApply()
4718 if( sApply.abPK[i] ) nMinCol = i+1; in sessionChangesetApply()
4735 else if( nCol<nMinCol || memcmp(sApply.abPK, abPK, nCol)!=0 ){ in sessionChangesetApply()
4979 }else if( pTab->abPK[i]==0 ){ in sessionChangeMerge()
5011 if( *a1==0xFF || (pTab->abPK[i]==0 && bIndirect) ){ in sessionChangeMerge()
5158 u8 *abPK; in sessionChangesetToHash() local
5160 sqlite3changeset_pk(pIter, &abPK, 0); in sessionChangesetToHash()
5174 pTab->abPK = (u8*)&pTab[1]; in sessionChangesetToHash()
5175 memcpy(pTab->abPK, abPK, nCol); in sessionChangesetToHash()
5176 pTab->zName = (char*)&pTab->abPK[nCol]; in sessionChangesetToHash()
5185 }else if( pTab->nCol!=nCol || memcmp(pTab->abPK, abPK, nCol) ){ in sessionChangesetToHash()
5522 if( pIter->abPK[i] || a2[0]==0 ){ in sessionAppendPartialUpdate()
5523 if( !pIter->abPK[i] && a1[0] ) bData = 1; in sessionAppendPartialUpdate()
5541 if( pIter->abPK[i] || a2[0]!=0xFF ){ in sessionAppendPartialUpdate()
5604 sessionAppendBlob(&sOut, pIter->abPK, pIter->nCol, &rc); in sessionRebase()