本文整理了Java中io.yawp.repository.query.QueryBuilder.limit
方法的一些代码示例,展示了QueryBuilder.limit
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryBuilder.limit
方法的具体详情如下:
包路径:io.yawp.repository.query.QueryBuilder
类名称:QueryBuilder
方法名:limit
暂无
代码示例来源:origin: feroult/yawp
public QueryTransformer<F, T> limit(int limit) {
query.limit(limit);
return this;
}
代码示例来源:origin: feroult/yawp
private T executeQueryFirst() {
limit(1);
List<T> list = executeQuery();
if (list.size() == 0) {
return null;
}
return list.get(0);
}
代码示例来源:origin: feroult/yawp
private void configureQuery(int batchSize, QueryBuilder<?> q) {
if (cursor != null) {
q.cursor(cursor);
}
q.limit(batchSize);
}
代码示例来源:origin: feroult/yawp
private QueryBuilder<Work> worksQuery() {
long timestamp = System.currentTimeMillis() - ELAPSED_TIME_MILLES;
QueryBuilder<Work> q = yawp(Work.class).where("timestamp", "<=", timestamp);
if (cursor != null) {
q.setCursor(cursor);
}
q.limit(BATCH_SIZE);
return q;
}
代码示例来源:origin: feroult/yawp
private QueryBuilder<SinkMarker> prepareQuery() {
QueryBuilder<SinkMarker> q = r.query(SinkMarker.class).from(sinkId).order("id").limit(BATCH_SIZE);
if (cursor != null) {
q.cursor(cursor);
}
return q;
}
代码示例来源:origin: feroult/yawp
private List<? extends IdRef<?>> sinkIds() {
QueryBuilder<?> q = r.query(sinkClazz).order("id").limit(BATCH_SIZE);
if (cursor != null) {
q.cursor(cursor);
}
List<? extends IdRef<?>> ids = q.ids();
if (ids.size() < BATCH_SIZE) {
cursor = null;
} else {
cursor = q.getCursor();
}
return ids;
}
}
代码示例来源:origin: feroult/yawp
private List<? extends IdRef<?>> sourceIds() {
QueryBuilder<?> q = r.query(sourceClazz).order("id").limit(BATCH_SIZE);
if (cursor != null) {
q.cursor(cursor);
}
List<? extends IdRef<?>> ids = q.ids();
if (ids.size() < BATCH_SIZE) {
cursor = null;
} else {
cursor = q.getCursor();
}
return ids;
}
}
代码示例来源:origin: feroult/yawp
private List<? extends IdRef<?>> sinkMarkerIds() {
QueryBuilder<?> q = r.query(SinkMarker.class).from(sinkId).order("id").limit(BATCH_SIZE);
if (cursor != null) {
q.cursor(cursor);
}
List<? extends IdRef<?>> ids = q.ids();
if (ids.size() < BATCH_SIZE) {
cursor = null;
} else {
cursor = q.getCursor();
}
return ids;
}
}
代码示例来源:origin: feroult/yawp
public QueryBuilder<T> options(QueryOptions options) {
if (options.getCondition() != null) {
where(options.getCondition());
}
if (options.getPreOrders() != null) {
preOrders.addAll(options.getPreOrders());
}
if (options.getPostOrders() != null) {
postOrders.addAll(options.getPostOrders());
}
if (options.getLimit() != null) {
limit(options.getLimit());
}
if (options.getCursor() != null) {
cursor(options.getCursor());
}
return this;
}
代码示例来源:origin: feroult/yawp
@Test
public void testLimit() {
saveManyBasicObjects(3);
List<BasicObject> objects = yawp(BasicObject.class).order("intValue", "desc").limit(1).list();
assertEquals(1, objects.size());
assertEquals(3, objects.get(0).getIntValue());
}
代码示例来源:origin: feroult/yawp
@Test
public void testCursor() {
saveManyBasicObjects(3);
QueryBuilder<BasicObject> q = yawp(BasicObject.class).order("intValue", "desc").limit(1);
List<BasicObject> objects1 = q.list();
assertEquals(3, objects1.get(0).getIntValue());
List<BasicObject> objects2 = q.list();
assertEquals(2, objects2.get(0).getIntValue());
List<BasicObject> objects3 = yawp(BasicObject.class).cursor(q.getCursor()).order("intValue", "desc").limit(1).list();
assertEquals(1, objects3.get(0).getIntValue());
}
内容来源于网络,如有侵权,请联系作者删除!