Lines Matching refs:nCol
100 int nCol; /* Number of columns in zTab */ member
123 int nCol; /* Number of columns in table zName */ member
526 assert( pTab->nCol==pSession->hook.xCount(pSession->hook.pCtx) ); in sessionPreupdateHash()
527 for(i=0; i<pTab->nCol; i++){ in sessionPreupdateHash()
608 for(i=0; i<pTab->nCol; i++){ in sessionChangeHash()
658 for(iCol=0; iCol<pTab->nCol; iCol++){ in sessionChangeEqual()
692 int nCol, in sessionMergeRecord() argument
701 for(iCol=0; iCol<nCol; iCol++){ in sessionMergeRecord()
793 for(i=0; i<pTab->nCol; i++){ in sessionMergeUpdate()
818 for(i=0; i<pTab->nCol; i++){ in sessionMergeUpdate()
857 for(iCol=0; iCol<pTab->nCol; iCol++){ in sessionPreupdateEqual()
1126 if( pTab->nCol==0 ){ in sessionInitTable()
1130 pTab->zName, &pTab->nCol, 0, &pTab->azCol, &abPK in sessionInitTable()
1134 for(i=0; i<pTab->nCol; i++){ in sessionInitTable()
1146 1 + sessionVarintLen(pTab->nCol) + pTab->nCol + strlen(pTab->zName)+1 in sessionInitTable()
1204 for(ii=0; ii<pTab->nCol; ii++){ in sessionUpdateMaxSize()
1218 for(ii=0; ii<pTab->nCol; ii++){ in sessionUpdateMaxSize()
1317 if( pTab->nCol!=pSession->hook.xCount(pSession->hook.pCtx) ){ in sessionPreupdateOneChange()
1372 for(i=0; i<pTab->nCol; i++){ in sessionPreupdateOneChange()
1403 for(i=0; i<pTab->nCol; i++){ in sessionPreupdateOneChange()
1597 int nCol, in sessionExprComparePK() argument
1606 for(i=0; i<nCol; i++){ in sessionExprComparePK()
1620 int nCol, in sessionExprCompareOther() argument
1630 for(i=0; i<nCol; i++){ in sessionExprCompareOther()
1651 int nCol, in sessionSelectFindNew() argument
1675 char *zStmt = sessionSelectFindNew(pTab->nCol, zDb1, zDb2, pTab->zName,zExpr); in sessionDiffFindNew()
1705 char *zExpr2 = sessionExprCompareOther(pTab->nCol, in sessionDiffFindModified()
1724 pDiffCtx->nOldOff = pTab->nCol; in sessionDiffFindModified()
1769 int nCol; /* Columns in zFrom.zTbl */ in sqlite3session_diff() local
1772 rc = sessionTableInfo(0, db, zFrom, zTbl, &nCol, 0, &azCol, &abPK); in sqlite3session_diff()
1774 if( pTo->nCol!=nCol ){ in sqlite3session_diff()
1778 for(i=0; i<nCol; i++){ in sqlite3session_diff()
1799 zExpr = sessionExprComparePK(pTo->nCol, in sqlite3session_diff()
2338 int nCol, /* Number of columns in table */ in sessionAppendDelete() argument
2351 for(i=0; i<nCol; i++){ in sessionAppendDelete()
2393 int nCol, /* Number of columns in table */ in sessionSelectStmt() argument
2418 for(i=0; i<nCol; i++){ in sessionSelectStmt()
2448 int nCol, /* Number of columns in table */ in sessionSelectBind() argument
2456 for(i=0; i<nCol && rc==SQLITE_OK; i++){ in sessionSelectBind()
2525 sessionAppendVarint(pBuf, pTab->nCol, pRc); in sessionAppendTableHdr()
2526 sessionAppendBlob(pBuf, pTab->abPK, pTab->nCol, pRc); in sessionAppendTableHdr()
2574 int nCol = 0; /* Number of columns in table */ 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()
2609 for(iCol=0; iCol<nCol; iCol++){ in sessionGenerateChangeset()
2617 rc = sessionAppendDelete(&buf, bPatchset, p, nCol, abPK); in sessionGenerateChangeset()
2941 int nCol /* Number of values in record */ in sessionSkipRecord() argument
2945 for(i=0; i<nCol; i++){ in sessionSkipRecord()
3008 int nCol, /* Number of values in record */ in sessionReadRecord() argument
3018 for(i=0; i<nCol && rc==SQLITE_OK; i++){ in sessionReadRecord()
3084 int nCol = 0; in sessionChangesetBufferTblhdr() local
3089 nRead += sessionVarintGet(&pIn->aData[pIn->iNext + nRead], &nCol); in sessionChangesetBufferTblhdr()
3097 if( nCol<0 || nCol>65536 ){ in sessionChangesetBufferTblhdr()
3100 rc = sessionInputBuffer(pIn, nRead+nCol+100); in sessionChangesetBufferTblhdr()
3101 nRead += nCol; in sessionChangesetBufferTblhdr()
3127 int nCol, /* Number of columns in record */ in sessionChangesetBufferRecord() argument
3133 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionChangesetBufferRecord()
3178 nVarint = sessionVarintGet(&p->in.aData[p->in.iNext], &p->nCol); in sessionChangesetReadTblhdr()
3179 if( p->nCol>0 ){ in sessionChangesetReadTblhdr()
3182 nByte = p->nCol * sizeof(sqlite3_value*) * 2 + nCopy; in sessionChangesetReadTblhdr()
3191 size_t iPK = sizeof(sqlite3_value*)*p->nCol*2; 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()
3236 for(i=0; i<p->nCol*2; i++){ in sessionChangesetNextOne()
3239 memset(p->apValue, 0, sizeof(sqlite3_value*)*p->nCol*2); in sessionChangesetNextOne()
3284 nVal = p->nCol * 2; in sessionChangesetNextOne()
3287 for(i=0; i<p->nCol; i++) if( p->abPK[i] ) nVal++; in sessionChangesetNextOne()
3289 nVal = p->nCol; in sessionChangesetNextOne()
3296 sqlite3_value **apOld = (p->bInvert ? &p->apValue[p->nCol] : p->apValue); in sessionChangesetNextOne()
3297 sqlite3_value **apNew = (p->bInvert ? p->apValue : &p->apValue[p->nCol]); in sessionChangesetNextOne()
3302 p->rc = sessionReadRecord(&p->in, p->nCol, abPK, apOld, 0); in sessionChangesetNextOne()
3308 p->rc = sessionReadRecord(&p->in, p->nCol, 0, apNew, pbEmpty); in sessionChangesetNextOne()
3317 for(i=0; i<p->nCol; i++){ in sessionChangesetNextOne()
3321 p->apValue[i] = p->apValue[i+p->nCol]; in sessionChangesetNextOne()
3323 p->apValue[i+p->nCol] = 0; in sessionChangesetNextOne()
3391 *pnCol = pIter->nCol; in sqlite3changeset_op()
3409 if( pnCol ) *pnCol = pIter->nCol; in sqlite3changeset_pk()
3434 if( iVal<0 || iVal>=pIter->nCol ){ in sqlite3changeset_old()
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)]
3496 if( iVal<0 || iVal>=pIter->nCol ){ in sqlite3changeset_conflict()
3518 *pnOut = pIter->nCol; in sqlite3changeset_fk_conflicts()
3535 for(i=0; i<p->nCol*2; i++) sqlite3ValueFree(p->apValue[i]); in sqlite3changeset_finalize()
3553 int nCol = 0; /* Number of cols in current table */ in sessionChangesetInvert() local
3590 nVar = sessionVarintGet(&pInput->aData[pInput->iNext], &nCol); in sessionChangesetInvert()
3592 sessionAppendBlob(&sPK, &pInput->aData[pInput->iNext+nVar], nCol, &rc); in sessionChangesetInvert()
3611 rc = sessionChangesetBufferRecord(pInput, nCol, &nByte); in sessionChangesetInvert()
3624 apVal = (sqlite3_value **)sqlite3_malloc64(sizeof(apVal[0])*nCol*2); in sessionChangesetInvert()
3629 memset(apVal, 0, sizeof(apVal[0])*nCol*2); in sessionChangesetInvert()
3638 rc = sessionReadRecord(pInput, nCol, 0, &apVal[0], 0); in sessionChangesetInvert()
3640 rc = sessionReadRecord(pInput, nCol, 0, &apVal[nCol], 0); in sessionChangesetInvert()
3646 for(iCol=0; iCol<nCol; iCol++){ in sessionChangesetInvert()
3647 sqlite3_value *pVal = apVal[iCol + (abPK[iCol] ? 0 : nCol)]; in sessionChangesetInvert()
3654 for(iCol=0; iCol<nCol; iCol++){ in sessionChangesetInvert()
3659 for(iCol=0; iCol<nCol*2; iCol++){ in sessionChangesetInvert()
3662 memset(apVal, 0, sizeof(apVal[0])*nCol*2); in sessionChangesetInvert()
3755 int nCol; /* Size of azCol[] and abPK[] arrays */ member
3786 int nCol = pIter->nCol; in sessionUpdateFind() local
3787 int nU32 = (pIter->nCol+33)/32; in sessionUpdateFind()
3800 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3809 if( bPatchset ) p->aUpdateMask[nCol/32] |= (1<<(nCol%32)); in sessionUpdateFind()
3856 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3869 for(ii=0; ii<pIter->nCol; ii++){ in sessionUpdateFind()
3962 for(i=0; i<p->nCol; i++){ in sessionDeleteRow()
3973 if( nPk<p->nCol ){ in sessionDeleteRow()
3975 sessionAppendInteger(&buf, p->nCol+1, &rc); in sessionDeleteRow()
3979 for(i=0; i<p->nCol; i++){ in sessionDeleteRow()
4018 db, "main", zTab, p->nCol, p->azCol, p->abPK, &p->pSelect); in sessionSelectRow()
4042 for(i=0; i<p->nCol; i++){ in sessionInsertRow()
4048 for(i=1; i<p->nCol; i++){ in sessionInsertRow()
4129 int nCol, /* Number of columns */ in sessionBindRow() argument
4142 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionBindRow()
4182 int nCol; /* Number of columns in table */ in sessionSeekToRow() local
4186 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionSeekToRow()
4189 nCol, abPK, pSelect in sessionSeekToRow()
4223 sessionAppendVarint(&p->rebase, p->nCol, &rc); in sessionRebaseAdd()
4224 sessionAppendBlob(&p->rebase, p->abPK, p->nCol, &rc); in sessionRebaseAdd()
4236 for(i=0; i<p->nCol; i++){ in sessionRebaseAdd()
4294 int nCol; in sessionConflictHandler() local
4298 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionConflictHandler()
4392 int nCol; in sessionApplyOneOp() local
4399 sqlite3changeset_op(pIter, &zDummy, &nCol, &op, 0); in sessionApplyOneOp()
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()
4441 for(i=0; rc==SQLITE_OK && i<nCol; i++){ in sessionApplyOneOp()
4488 rc = sessionBindRow(pIter, sqlite3changeset_new, nCol, 0, p->pInsert); in sessionApplyOneOp()
4550 sqlite3changeset_new, pApply->nCol, pApply->abPK, pApply->pDelete); in sessionApplyOneWithRetry()
4551 sqlite3_bind_int(pApply->pDelete, pApply->nCol+1, 1); in sessionApplyOneWithRetry()
4591 size_t nByte = 2*pApply->nCol*sizeof(sqlite3_value*); in sessionRetryConstraints()
4595 pIter2->nCol = pApply->nCol; in sessionRetryConstraints()
4665 int nCol; in sessionChangesetApply() local
4669 sqlite3changeset_op(pIter, &zNew, &nCol, &op, 0); in sessionChangesetApply()
4688 sApply.nCol = 0; in sessionChangesetApply()
4714 db, "main", zNew, &sApply.nCol, &zTab, &sApply.azCol, &sApply.abPK in sessionChangesetApply()
4717 for(i=0; i<sApply.nCol; i++){ in sessionChangesetApply()
4721 if( sApply.nCol==0 ){ in sessionChangesetApply()
4727 else if( sApply.nCol<nCol ){ in sessionChangesetApply()
4732 zTab, sApply.nCol, nCol in sessionChangesetApply()
4735 else if( nCol<nMinCol || memcmp(sApply.abPK, abPK, nCol)!=0 ){ in sessionChangesetApply()
4742 sApply.nCol = nCol; in sessionChangesetApply()
4787 sIter.nCol = nFk; in sessionChangesetApply()
4975 for(i=0; i<pTab->nCol; i++){ in sessionChangeMerge()
5008 for(i=0; i<pTab->nCol; i++){ in sessionChangeMerge()
5074 if( bPatchset==0 ) sessionSkipRecord(&a1, pTab->nCol); in sessionChangeMerge()
5075 sessionMergeRecord(&aCsr, pTab->nCol, aExist, a1); in sessionChangeMerge()
5093 sessionSkipRecord(&a1, pTab->nCol); in sessionChangeMerge()
5094 sessionSkipRecord(&a2, pTab->nCol); in sessionChangeMerge()
5108 sessionMergeRecord(&aCsr, pTab->nCol, aRec, aExist); in sessionChangeMerge()
5139 int nCol; in sessionChangesetToHash() local
5154 sqlite3changeset_op(pIter, &zNew, &nCol, &op, &bIndirect); in sessionChangesetToHash()
5167 pTab = sqlite3_malloc64(sizeof(SessionTable) + nCol + nNew+1); in sessionChangesetToHash()
5173 pTab->nCol = nCol; 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()
5455 int nCol, /* Number of columns in each record */ in sessionAppendRecordMerge() argument
5464 for(i=0; i<nCol; i++){ in sessionAppendRecordMerge()
5519 for(i=0; i<pIter->nCol; i++){ in sessionAppendPartialUpdate()
5538 for(i=0; i<pIter->nCol; i++){ in sessionAppendPartialUpdate()
5603 sessionAppendVarint(&sOut, pIter->nCol, &rc); in sessionRebase()
5604 sessionAppendBlob(&sOut, pIter->abPK, pIter->nCol, &rc); in sessionRebase()
5638 sessionSkipRecord(&pCsr, pIter->nCol); in sessionRebase()
5641 sessionAppendRecordMerge(&sOut, pIter->nCol, in sessionRebase()
5659 sessionAppendRecordMerge(&sOut, pIter->nCol, in sessionRebase()