io.yawp.repository.query.QueryBuilder.limit()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.5k)|赞(0)|评价(0)|浏览(121)

本文整理了Java中io.yawp.repository.query.QueryBuilder.limit方法的一些代码示例,展示了QueryBuilder.limit的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryBuilder.limit方法的具体详情如下:
包路径:io.yawp.repository.query.QueryBuilder
类名称:QueryBuilder
方法名:limit

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());
}

相关文章