performs the next index set.

@param bool $bIndexUsingTicker - if set to true, each call to this method will only index as many rows as defined by INDEX_SET_SIZE
16729
public function ProcessNextIndexStep($bIndexUsingTicker = true)
    {
        TCacheManager::SetDisableCaching(true);
        // if no index is running, prepare the indexer
        $iTickerSize = self::INDEX_SET_SIZE;
        if (!$bIndexUsingTicker) {
            $iTickerSize = -1;
        }
        if (!$this->IsRunning()) {
            $this->InitializeIndexer();
        }

        if ($this->IndexerHasFinished()) {
            // indexing is done...
            $this->IndexCompletedHook();
        } elseif ($this->IsRunning()) {
            // now process the next tick...
            $iRecordsProcessed = 0;
            do {
                $iWorkId = $this->aTablesToProcess[0];
                $oIndexQuery = TdbShopSearchQuery::GetNewInstance();
                /** @var $oIndexQuery TdbShopSearchQuery */
                if ($oIndexQuery->Load($iWorkId)) {
                    $iRecordsProcessedByIndexer = $oIndexQuery->CreateIndexTick($iTickerSize);
                    $iRecordsProcessed += $iRecordsProcessedByIndexer;
                    if (($iRecordsProcessedByIndexer < $iTickerSize) || ($iTickerSize < 0)) {
                        // if we processed less than we requested, we must be done with this query
                        // so we drop it from the list of queries we need to process
                        array_shift($this->aTablesToProcess);
                    }
                } else {
                    // unalbe to load query object... so drop it from the list
                    array_shift($this->aTablesToProcess);
                }
            } while (!$this->IndexerHasFinished() && (($iRecordsProcessed < self::INDEX_SET_SIZE) || ($iTickerSize < 0)));
        }
        $this->CommitProcessData();
        TCacheManager::SetDisableCaching(false);
    }
1049512
public function setSessionIndex(string $sessionIndex = null) : void
    {
        if (is_null($sessionIndex)) {
            $this->sessionIndexes = [];
        } else {
            $this->sessionIndexes = [$sessionIndex];
        }
    }
370663
function NextRecordSet()
	{
		if (!sqlsrv_next_result($this->_queryID)) return false;
		$this->_inited = false;
		$this->bind = false;
		$this->_currentRow = -1;
		$this->Init();
		return true;
	}
488393
@Override
	public void nextPage() {
		if (!paged) {			
			this.firstPage();
			paged = true;
		} else if (!isLast()) {
			offset = (getPageNumber() + 1) * pageSize;

			execute();
		}
	}
536828
public function execute(Zend_Search_Lucene_Interface $reader, $docsFilter = null)
    {
        if ($this->_signs === null) {
            $this->_calculateConjunctionResult($reader);
        } else {
            $this->_calculateNonConjunctionResult($reader);
        }

        // Initialize weight if it's not done yet
        $this->_initWeight($reader);
    }
1336744
public function prepareRawStatement(string $statement, array $bindings): void
    {
        $this->statement = $statement;
        if (empty($bindings)) {
            return;
        }

        foreach ($bindings as $key => $value) {
            $this->addBindingValue($key, $value);
        }
    }
613341
public function callProcedure($procedureName = '', $bindParams = [], $isSelect = true)
    {
        $this->bindParams = $bindParams;
        $this->currentQueryIsMaster = true;
        $stmt = $this->prepare("exec {$procedureName}", $this->wlink);
        $this->execute($stmt);
        if ($isSelect) {
            return $stmt->fetchAll(\PDO::FETCH_ASSOC);
        } else {
            return $stmt->rowCount();
        }
    }
675001
public function andWhere($conditions, array $bindParams = null, array $bindTypes = null) {
        if(!is_null($bindParams)) {
            $tmpBindParams = array();
            foreach($bindParams as $key => $value) {
                if(is_int($key)) {
                    $param = 'criteriaHelper' . $this->incrementLocalParamCount();
                    $tmpBindParams[$param] = $value;
                    $conditions = str_replace('?' . $key, ':' . $param . ':', $conditions);
                } else {
                    $tmpBindParams[$key] = $value;
                }
            }
            $bindParams = $tmpBindParams;
        }
        $this->getCriteria()->andWhere($conditions, $bindParams, $bindTypes);
        return $this;
    }
1331431
@Override
	public boolean next() {
		if (isLhsEmpty)
			return false;
		if (idx.next()) {
			ts.moveToRecordId(idx.getDataRecordId());
			return true;
		} else if (!(isLhsEmpty = !s.next())) {
			resetIndex();
			return next();
		} else
			return false;
	}
563297
protected function bindIndex()
    {
        $this->app->bind('iverberk.larasearch.index', function ($app, $params)
        {
            $name = isset($params['name']) ? $params['name'] : '';

            return new Index($params['proxy'], $name);
        });
    }
933166
private function limitOffset($limit, $offset)
    {
        if (!$this->withoutTotalResultCount && !$this->count()) {
            return false;
        }

        $this->queryBuilder
            ->setFirstResult($offset)
            ->setMaxResults($limit);

        return true;
    }
898304
public function selectOne( $query, $bindings = [] )
	{
		$query = $this->bind_params( $query, $bindings );

		$result = $this->db->get_row( $query );

		if ( $result === false || $this->db->last_error ) {
			throw new QueryException( $query, $bindings, new \Exception( $this->db->last_error ) );
		}

		return $result;
	}
193577
public function affectingStatement($query, $bindings = [])
    {
        $statement = $this->execute($query, $bindings);
        return $statement->rowCount();
    }
729831
public function prepareIndexMapping(IndexEvent $event)
    {
        $code = $event->getIndexCode();
        $mapping = $event->getMapping();

        $parameters = array("index" => $event->getIndexName());
        $driver = $this->getDriver();

        $shards = $driver->getExtraConfiguration("number_of_shards")->getValue();
        if (null !== $shards) {
            $parameters["body"]["settings"]["number_of_shards"] = $shards;
        }

        $replicas = $driver->getExtraConfiguration("number_of_replicas")->getValue();
        if (null !== $replicas) {
            $parameters["body"]["settings"]["number_of_replicas"] = $replicas;
        }

        $esMapping = &$parameters["body"]["mappings"][$code];

        $esMapping["_source"] = ["enabled" => $driver->getExtraConfiguration("save_source")];

        foreach ($mapping->getMapping() as $column => $type) {
            $resolvedType = $this->resolveType($type);

            $esMapping["properties"][$column] = $resolvedType;
        }

        $event->setExtraData($parameters);
    }
1238230
public boolean next() throws OdaException
	{
        int maxRows = getMaxRows();
        if( m_currentRowId < maxRows )
        {
            m_currentRowId++;
            currentRow = sqlResult.get(m_currentRowId-1);
            return true;
        }
        
        return false;        
	}
1194396
public function getBindingId($orderIndex = 0)
    {
        $bindingInfo = $this->getBindingInfo($orderIndex);
        return array_key_exists('bindingId', $bindingInfo) ? $bindingInfo['bindingId'] : null;
    }
784723
function insert($table, array $bind)
    {
        $sql = $this->insertSql($table, $bind);
        // execute the statement and return the number of affected rows
        $stmt = $this->wrappedAdapter->query($sql, array_values($bind));
        $result = $stmt->rowCount();
        return $result;
    }