CodeCow/querydsl
1
0
Fork 0
mirror of https://github.com/querydsl/querydsl.git synced 2026-07-06 21:05:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Remove LimitingIterator

Browse Source
This commit is contained in:
Timo Westkämper 2013-03-01 17:19:20 +02:00
parent e7a9c839a4
commit 5e98ac5913
2 changed files with 0 additions and 127 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
querydsl-core/src/main/java/com/mysema/query/util/LimitingIterator.java
View File

@ -1,70 +0,0 @@
/*
* Copyright 2011, Mysema Ltd
*
* Licensed 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.
*/
package com.mysema.query.util;
import java.util.Iterator;
import com.mysema.query.QueryModifiers;
/**
* LimitingIterator is and Iterator adapter which takes limit and offset into account
*
* @author tiwe
*/
public class LimitingIterator<E> implements Iterator<E> {
public static <T> Iterator<T> create(Iterator<T> iterator, QueryModifiers modifiers) {
if (modifiers.isRestricting()) {
if (modifiers.getOffset() != null) {
int counter = 0;
while (iterator.hasNext() && counter < modifiers.getOffset()) {
counter++;
iterator.next();
}
}
if (modifiers.getLimit() != null) {
iterator = new LimitingIterator<T>(iterator, modifiers.getLimit());
}
}
return iterator;
}
private long counter;
private final long limit;
private final Iterator<E> original;
LimitingIterator(Iterator<E> iterator, long limit) {
this.original = iterator;
this.limit = limit;
}
@Override
public boolean hasNext() {
return original.hasNext() && counter < limit;
}
@Override
public E next() {
counter++;
return original.next();
}
@Override
public void remove() {
throw new UnsupportedOperationException();
}
}

57
querydsl-core/src/test/java/com/mysema/query/util/LimitingIteratorTest.java
View File

@ -1,57 +0,0 @@
/*
* Copyright 2011, Mysema Ltd
*
* Licensed 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.
*/
package com.mysema.query.util;
import static org.junit.Assert.assertEquals;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
import javax.annotation.Nullable;
import org.junit.Test;
import com.mysema.commons.lang.IteratorAdapter;
import com.mysema.query.QueryModifiers;
public class LimitingIteratorTest {
@Test
public void test() {
List<Integer> ints = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
assertEquals(Arrays.asList(1, 2), transform(ints, 2l, null));
assertEquals(Arrays.asList(3, 4, 5), transform(ints, 3l, 2l));
assertEquals(Arrays.asList(10), transform(ints, 10l, 9l));
}
private List<Integer> transform(List<Integer> ints, Long limit, @Nullable Long offset) {
QueryModifiers modifiers = new QueryModifiers(limit, offset);
return IteratorAdapter.asList(LimitingIterator.create(ints.iterator(), modifiers));
}
@Test
public void Limit(){
LimitingIterator<String> it = new LimitingIterator<String>(Arrays.asList("1","2","3").iterator(), 2);
assertEquals(Arrays.asList("1","2"), IteratorAdapter.asList(it));
}
@Test
public void Offset(){
Iterator<String> it = LimitingIterator.create(Arrays.asList("1","2","3").iterator(), QueryModifiers.offset(1));
assertEquals(Arrays.asList("2","3"), IteratorAdapter.asList(it));
}
}