paging-predicate-test

paging-predicate-test

    static void testPagingPredicate() {
        HazelcastInstance instance = Hazelcast.newHazelcastInstance();
        IMap<Object, Object> map = instance.getMap("map");
        for (int i = 0; i < 20; i++) {
            map.put(i, i);
        }

        PagingPredicate pagingPredicate = getPagingPredicate(0, 10, null);

        Collection<Object> values = map.values(pagingPredicate);
        for (Object value : values) {
            System.err.println("value: " + value);
        }

        System.err.println("nextPage");
        pagingPredicate.nextPage();
        values = map.values(pagingPredicate);
        for (Object value : values) {
            System.err.println("value: " + value);
        }

    }


    public static PagingPredicate getPagingPredicate(int offset, int limit, SqlPredicate sqlPredicate) {
        final int pageSize = limit - offset;
        final PagingPredicate pagingPredicate;
        if (sqlPredicate == null) {
            pagingPredicate = new PagingPredicate(pageSize);
        } else {
            pagingPredicate = new PagingPredicate(sqlPredicate, pageSize);
        }
        if (pagingPredicate.getPageSize() >= 0) {
            for (int index = 0; index < offset; index = index + pageSize) {
                pagingPredicate.nextPage();
            }
        }
        return pagingPredicate;
    }