本文整理了Java中org.infinispan.query.dsl.QueryBuilder.maxResults
方法的一些代码示例,展示了QueryBuilder.maxResults
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryBuilder.maxResults
方法的具体详情如下:
包路径:org.infinispan.query.dsl.QueryBuilder
类名称:QueryBuilder
方法名:maxResults
暂无
代码示例来源:origin: org.infinispan/infinispan-query-dsl
@Override
public QueryBuilder maxResults(int maxResults) {
return getQueryBuilder().maxResults(maxResults);
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public QueryBuilder maxResults(int maxResults) {
return getQueryBuilder().maxResults(maxResults);
}
代码示例来源:origin: org.commonjava.indy/indy-core
@Override
public Map<Location, Set<String>> getAllMissing()
{
logger.debug( "[NFC] getAllMissing start" );
Map<Location, Set<String>> result = new HashMap<>();
Query query = queryFactory.from( NfcConcreteResourceWrapper.class )
.maxResults( maxResultSetSize )
.build();
List<NfcConcreteResourceWrapper> all = query.list();
for ( NfcConcreteResourceWrapper entry : all )
{
String loc = entry.getLocation();
StoreKey storeKey = fromString( loc );
Set<String> paths = result.computeIfAbsent( new NfcKeyedLocation( storeKey ), k -> new HashSet<>() );
paths.add( entry.getPath() );
}
logger.debug( "[NFC] getAllMissing complete, size: {}", all.size() );
return result;
}
代码示例来源:origin: org.commonjava.indy/indy-core
@Override
public Set<String> getMissing( final Location location )
{
logger.debug( "[NFC] getMissing for {} start", location );
Set<String> paths = new HashSet<>();
Query query = queryFactory.from( NfcConcreteResourceWrapper.class )
.maxResults( maxResultSetSize )
.having( "location" )
.eq( ( (KeyedLocation) location ).getKey().toString() )
.toBuilder()
.build();
List<NfcConcreteResourceWrapper> matches = query.list();
matches.forEach( resource -> paths.add( resource.getPath() ));
logger.debug( "[NFC] getMissing complete, count: {}", matches.size() );
return paths;
}
代码示例来源:origin: org.commonjava.indy/indy-core
@Override
public Map<Location, Set<String>> getAllMissing( int pageIndex, int pageSize )
{
logger.debug( "[NFC] getAllMissing start, pageIndex: {}, pageSize: {}", pageIndex, pageSize );
Map<Location, Set<String>> result = new HashMap<>();
pageSize = getProperPageSize(pageSize);
long offset = pageIndex * pageSize;
Query query = queryFactory.from( NfcConcreteResourceWrapper.class )
.startOffset( offset )
.maxResults( pageSize )
.orderBy( "location" )
.orderBy( "path" )
.build();
List<NfcConcreteResourceWrapper> all = query.list();
for ( NfcConcreteResourceWrapper entry : all )
{
String loc = entry.getLocation();
StoreKey storeKey = fromString( loc );
Set<String> paths = result.computeIfAbsent( new NfcKeyedLocation( storeKey ), k -> new HashSet<>() );
paths.add( entry.getPath() );
}
logger.debug( "[NFC] getAllMissing complete, size: {}", all.size() );
return result;
}
代码示例来源:origin: org.commonjava.indy/indy-core
/**
* Get missing entries via pagination.
* @param location
* @param pageIndex starts from 0
* @param pageSize how many entries in each page
* @return
*/
@Override
public Set<String> getMissing( Location location, int pageIndex, int pageSize )
{
logger.debug( "[NFC] getMissing for {} start, pageIndex: {}, pageSize: {}", location, pageIndex, pageSize );
Set<String> paths = new HashSet<>();
pageSize = getProperPageSize(pageSize);
long offset = pageIndex * pageSize;
Query query = queryFactory.from( NfcConcreteResourceWrapper.class )
.startOffset( offset )
.maxResults( pageSize )
.orderBy( "path" )
.having( "location" )
.eq( ( (KeyedLocation) location ).getKey().toString() )
.toBuilder()
.build();
List<NfcConcreteResourceWrapper> matches = query.list();
matches.forEach( resource -> paths.add( resource.getPath() ) );
logger.debug( "[NFC] getMissing complete, count: {}", matches.size() );
return paths;
}
代码示例来源:origin: org.infinispan/infinispan-query
@Test(expectedExceptions = IllegalArgumentException.class, expectedExceptionsMessageRegExp = "ISPN014823: maxResults must be greater than 0")
public void testPagination1() {
QueryFactory qf = getQueryFactory();
qf.from(getModelFactory().getUserImplClass())
.maxResults(0);
}
代码示例来源:origin: org.infinispan/infinispan-query
@Test(expectedExceptions = IllegalArgumentException.class, expectedExceptionsMessageRegExp = "ISPN014823: maxResults must be greater than 0")
public void testPagination2() {
QueryFactory qf = getQueryFactory();
qf.from(getModelFactory().getUserImplClass())
.maxResults(-4);
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testUnorderedPagination4() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.maxResults(5)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(3, list.size());
}
代码示例来源:origin: org.commonjava.indy/indy-content-index
@Override
@Measure
public void clearAllIndexedPathWithOriginalStore( ArtifactStore originalStore )
{
StoreKey osk = originalStore.getKey();
long total = iterateRemove( () -> queryFactory.from( IndexedStorePath.class )
.maxResults( ITERATE_RESULT_SIZE )
.having( "packageType" )
.eq( osk.getPackageType() )
.and()
.having( "originStoreType" )
.eq( osk.getType().name() )
.and()
.having( "originStoreName" )
.eq( osk.getName() )
.toBuilder()
.build() );
logger.trace( "Cleared all indices with origin: {}, size: {}", osk, total );
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testUnorderedPagination7() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.startOffset(1).maxResults(10)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(2, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testOrderedPagination4() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.orderBy("id", SortOrder.ASC)
.maxResults(5)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(3, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testUnorderedPagination8() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.startOffset(0).maxResults(2)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(2, list.size());
}
代码示例来源:origin: org.commonjava.indy/indy-content-index
@Override
@Measure
public void clearAllIndexedPathInStore( ArtifactStore store )
{
StoreKey sk = store.getKey();
long total = iterateRemove( () -> queryFactory.from( IndexedStorePath.class )
.maxResults( ITERATE_RESULT_SIZE )
.having( "packageType" )
.eq( sk.getPackageType() )
.and()
.having( "storeType" )
.eq( sk.getType().name() )
.and()
.having( "storeName" )
.eq( sk.getName() )
.toBuilder()
.build() );
logger.trace( "Cleared all indices with group: {}, size: {}", sk, total );
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testUnorderedPagination6() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.startOffset(20).maxResults(10)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(0, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testOrderedPagination6() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.orderBy("id", SortOrder.ASC)
.startOffset(20).maxResults(10)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(0, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testOrderedPagination7() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.orderBy("id", SortOrder.ASC)
.startOffset(1).maxResults(10)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(2, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testOrderedPagination8() {
QueryFactory qf = getQueryFactory();
Query q = qf.from(getModelFactory().getUserImplClass())
.orderBy("id", SortOrder.ASC)
.startOffset(0).maxResults(2)
.build();
List<User> list = q.list();
assertEquals(3, q.getResultSize());
assertEquals(2, list.size());
}
代码示例来源:origin: org.infinispan/infinispan-query
public void testSampleDomainQuery16() {
QueryFactory qf = getQueryFactory();
// third batch of 10 transactions for a given account
Query q = qf.from(getModelFactory().getTransactionImplClass())
.startOffset(20).maxResults(10)
.orderBy("id", SortOrder.ASC)
.having("accountId").eq(2).and().having("description").like("Expensive%")
.build();
List<Transaction> list = q.list();
assertEquals(50, q.getResultSize());
assertEquals(10, list.size());
for (int i = 0; i < 10; i++) {
assertEquals("Expensive shoes " + (20 + i), list.get(i).getDescription());
}
}
代码示例来源:origin: org.commonjava.indy/indy-content-index
@Override
@Measure
public void clearAllIndexedPathInStoreWithOriginal( ArtifactStore store, ArtifactStore originalStore )
{
StoreKey sk = store.getKey();
StoreKey osk = originalStore.getKey();
long total = iterateRemove( () -> queryFactory.from( IndexedStorePath.class )
.maxResults( ITERATE_RESULT_SIZE )
.having( "packageType" )
.eq( osk.getPackageType() )
.and()
.having( "storeType" )
.eq( sk.getType().name() )
.and()
.having( "storeName" )
.eq( sk.getName() )
.and()
.having( "originStoreType" )
.eq( osk.getType().name() )
.and()
.having( "originStoreName" )
.eq( osk.getName() )
.toBuilder()
.build() );
logger.trace( "Cleared all indices with origin: {} and group: {}, size: {}", osk, sk, total );
}
内容来源于网络,如有侵权,请联系作者删除!