thin-client/include/ignite/thin/cache/query/query_cursor.h

Go to the documentation of this file.

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
 
#ifndef _IGNITE_THIN_CACHE_QUERY_QUERY_CURSOR
#define _IGNITE_THIN_CACHE_QUERY_QUERY_CURSOR
 
#include <vector>
 
#include <ignite/common/concurrent.h>
#include <ignite/ignite_error.h>
 
#include <ignite/thin/cache/cache_entry.h>
 
#include <ignite/impl/thin/readable.h>
#include <ignite/impl/thin/cache/query/query_cursor_proxy.h>
 
namespace ignite
{
    namespace thin
    {
        namespace cache
        {
            namespace query
            {
                template<typename K, typename V>
                class QueryCursor
                {
                public:
                    QueryCursor()
                    {
                        // No-op.
                    }
 
                    explicit QueryCursor(const impl::thin::cache::query::QueryCursorProxy& impl) :
                        impl(impl)
                    {
                        // No-op.
                    }
 
                    bool HasNext() const
                    {
                        return impl.HasNext();
                    }
 
                    CacheEntry<K, V> GetNext()
                    {
                        CacheEntry<K, V> entry;
                        impl::thin::ReadableImpl< CacheEntry<K, V> > readable(entry);
 
                        impl.GetNext(readable);
 
                        return entry;
                    }
 
                    void GetAll(std::vector<CacheEntry<K, V> >& res)
                    {
                        res.clear();
                        GetAll(std::inserter(res, res.end()));
                    }
 
                    template<typename OutIter>
                    void GetAll(OutIter iter)
                    {
                        impl::thin::ReadableContainerImpl< CacheEntry<K, V>, OutIter > collection(iter);
 
                        while (HasNext())
                        {
                            *iter = GetNext();
                            ++iter;
                        }
                    }
 
                private:
                    impl::thin::cache::query::QueryCursorProxy impl;
                };
            }
        }
 
 
    }
}
 
#endif //_IGNITE_THIN_CACHE_QUERY_QUERY_CURSOR