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

Go to the documentation of this file.

/*
 * Copyright 2022 GridGain Systems, Inc. and Contributors.
 *
 * Licensed under the GridGain Community Edition License (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     https://www.gridgain.com/products/software/community-edition/gridgain-community-edition-license
 *
 * 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