query_set.py 文件源码

def _fill_result_cache_to_idx(self, conn, idx):
        """
        Fill the result cache to the given index.

        :param conn: Cassandra connection wrapper used to execute the query.
        :type: cqlengine.ConnectionInterface subclass
        :param idx: Index value to fill the result cache to
        :type: int
        """
        self._execute_query(conn)
        if self._result_idx is None:
            self._result_idx = -1

        qty = idx - self._result_idx
        if qty < 1:
            return
        else:
            for idx in range(qty):
                self._result_idx += 1
                while True:
                    try:
                        result = self._construct_result(
                            self._result_cache[self._result_idx]
                        )
                        self._result_cache[self._result_idx] = result
                        break
                    except IndexError:
                        self._result_cache.append(next(self._result_generator))