contrib/sqlite3/sqlite3.c

15731 #define OP_IfNotOpen      26 /* jump, synopsis: if( !csr[P1] ) goto P2     */
33504     /*  26 */ "IfNotOpen"        OpHelp("if( !csr[P1] ) goto P2"),
90533 ** Synopsis: if( !csr[P1] ) goto P2
109853     **   Rewind csr
109854     **   if eof(csr) goto end_of_scan;
109876     **   Next csr
109877     **   if !eof(csr) goto next_row;
109923     **   Rewind csr
109924     **   if eof(csr) goto end_of_scan;
109992     **   Next csr
109993     **   if !eof(csr) goto next_row;
155437   int csr;                        /* Cursor number */
155488 **   (WindowCsrAndReg.csr) and an array of registers (starting at
155493 **   be required. In this case both WindowCodeArg.csr and reg are set to
155511 ** Generate VM code to read the window frames peer values from cursor csr into
155516   int csr,
155527       sqlite3VdbeAddOp3(v, OP_Column, csr, iColOff+i, reg+i);
155539 ** If argument csr is greater than or equal to 0, then argument reg is
155542 ** the arguments are extracted from the current row of csr into the
155545 ** Or, if csr is less than zero, then the array of registers at reg is
155554   int csr,                        /* Read arguments from this cursor */
155575         sqlite3VdbeAddOp3(v, OP_Column, csr, pWin->iArgCol+i, reg+i);
155613         sqlite3VdbeAddOp3(v, OP_Column, csr, pWin->iArgCol+nArg,regTmp);
155630             pOp->p1 = csr;
155719   int csr;
155724   csr = pMWin->csrApp;
155744   sqlite3VdbeAddOp3(v, OP_SeekGE, csr, lblBrk, pMWin->regStartRowid);
155747   sqlite3VdbeAddOp2(v, OP_Rowid, csr, regRowid);
155767       windowReadPeerValues(p, csr, regPeer);
155779   windowAggStep(p, pMWin, csr, 0, p->regArg);
155782   sqlite3VdbeAddOp2(v, OP_Next, csr, addrNext);
155825         int csr = pWin->csrApp;
155839         sqlite3VdbeAddOp3(v, OP_SeekRowid, csr, 0, tmpReg);
155841         sqlite3VdbeAddOp3(v, OP_Column, csr, pWin->iArgCol, pWin->regResult);
155847         int csr = pWin->csrApp;
155869         sqlite3VdbeAddOp3(v, OP_SeekRowid, csr, lbl, tmpReg);
155871         sqlite3VdbeAddOp3(v, OP_Column, csr, pWin->iArgCol, pWin->regResult);
156124   int csr, reg;
156149               p, OP_Le, p->current.csr, regCountdown, p->start.csr, lblDone
156153               p, OP_Ge, p->start.csr, regCountdown, p->current.csr, lblDone
156158             p, OP_Gt, p->end.csr, regCountdown, p->current.csr, lblDone
156181     sqlite3VdbeAddOp2(v, OP_Rowid, p->start.csr, regRowid1);
156182     sqlite3VdbeAddOp2(v, OP_Rowid, p->end.csr, regRowid2);
156192       csr = p->current.csr;
156198       csr = p->start.csr;
156204         windowAggStep(p, pMWin, csr, 1, p->regArg);
156210       csr = p->end.csr;
156216         windowAggStep(p, pMWin, csr, 0, p->regArg);
156222     sqlite3VdbeAddOp1(v, OP_Delete, csr);
156227     sqlite3VdbeAddOp2(v, OP_Next, csr, sqlite3VdbeCurrentAddr(v)+2);
156231     sqlite3VdbeAddOp2(v, OP_Next, csr, sqlite3VdbeCurrentAddr(v)+1+bPeer);
156241     windowReadPeerValues(p, csr, regTmp);
156590 ** In the above notation, "csr.key" means the current value of the ORDER BY
156592 ** or <expr PRECEDING) read from cursor csr.
156710   s.current.csr = pMWin->iEphCsr;
156711   csrWrite = s.current.csr+1;
156712   s.start.csr = s.current.csr+2;
156713   s.end.csr = s.current.csr+3;
156832     sqlite3VdbeAddOp2(v, OP_Rewind, s.current.csr, 1);
156835     sqlite3VdbeAddOp1(v, OP_ResetSorter, s.current.csr);
156845     sqlite3VdbeAddOp2(v, OP_Rewind, s.start.csr, 1);
156848   sqlite3VdbeAddOp2(v, OP_Rewind, s.current.csr, 1);
156850   sqlite3VdbeAddOp2(v, OP_Rewind, s.end.csr, 1);
156873         windowCodeRangeTest(&s, OP_Ge, s.current.csr, regEnd, s.end.csr, lbl);
156899           windowCodeRangeTest(&s, OP_Ge, s.current.csr, regEnd, s.end.csr, lbl);
156976   sqlite3VdbeAddOp1(v, OP_ResetSorter, s.current.csr);
176135   Fts3MultiSegReader csr;        /* Must be right after "base" */
176146     sqlite3_int64 nDoc;           /* 'documents' values for current csr row */
176147     sqlite3_int64 nOcc;           /* 'occurrences' values for current csr row */
176345   sqlite3Fts3SegReaderFinish(&pCsr->csr);
176384   rc = sqlite3Fts3SegReaderStep(pFts3, &pCsr->csr);
176387     int nDoclist = pCsr->csr.nDoclist;
176388     char *aDoclist = pCsr->csr.aDoclist;
176394       int n = (pCsr->nStop<pCsr->csr.nTerm) ? pCsr->nStop : pCsr->csr.nTerm;
176395       int mc = memcmp(pCsr->zStop, pCsr->csr.zTerm, n);
176396       if( mc<0 || (mc==0 && pCsr->csr.nTerm>pCsr->nStop) ){
176511   sqlite3Fts3SegReaderFinish(&pCsr->csr);
176514   memset(&pCsr->csr, 0, ((u8*)&pCsr[1]) - (u8*)&pCsr->csr);
176548       pCsr->filter.zTerm, pCsr->filter.nTerm, 0, isScan, &pCsr->csr
176551     rc = sqlite3Fts3SegReaderStart(pFts3, &pCsr->csr, &pCsr->filter);
176579       sqlite3_result_text(pCtx, p->csr.zTerm, p->csr.nTerm, SQLITE_TRANSIENT);
183445   Fts3MultiSegReader csr;         /* Cursor to iterate through level(s) */
183456   rc = sqlite3Fts3SegReaderCursor(p, iLangid, iIndex, iLevel, 0, 0, 1, 0, &csr);
183457   if( rc!=SQLITE_OK || csr.nSegment==0 ) goto finished;
183469     if( csr.nSegment==1 && 0==fts3SegReaderIsPending(csr.apSegment[0]) ){
183488   assert( csr.nSegment>0 );
183498   rc = sqlite3Fts3SegReaderStart(p, &csr, &filter);
183500     rc = sqlite3Fts3SegReaderStep(p, &csr);
183503         csr.zTerm, csr.nTerm, csr.aDoclist, csr.nDoclist);
183510         p, iLangid, iIndex, iLevel, csr.apSegment, csr.nSegment
183525   sqlite3Fts3SegReaderFinish(&csr);
185422   Fts3MultiSegReader csr;
185429   memset(&csr, 0, sizeof(csr));
185434       p, iLangid, iIndex, FTS3_SEGCURSOR_ALL, 0, 0, 0, 1,&csr
185437     rc = sqlite3Fts3SegReaderStart(p, &csr, &filter);
185441     while( SQLITE_ROW==(rc = sqlite3Fts3SegReaderStep(p, &csr)) ){
185442       char *pCsr = csr.aDoclist;
185443       char *pEnd = &pCsr[csr.nDoclist];
185470                 csr.zTerm, csr.nTerm, iLangid, iIndex, iDocid,
185478   sqlite3Fts3SegReaderFinish(&csr);