org.molgenis.data.support.QueryImpl.pageSize()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(12.6k)|赞(0)|评价(0)|浏览(72)

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

QueryImpl.pageSize介绍

暂无

代码示例

代码示例来源：origin: org.molgenis/molgenis-omx-protocolviewer

@RequestMapping(value = "/search", method = RequestMethod.POST)
@ResponseBody
public SearchResult searchItems(@RequestBody Map<String, Object> request)
{
  Object catalogId = request.get("catalogId");
  Object queryString = request.get("queryString");
  if (catalogId == null) return new SearchResult("The catalogID cannot be null");
  if (queryString == null) return new SearchResult("The queryString items cannot be null");
  List<QueryRule> rules = new ArrayList<QueryRule>();
  for (String term : queryString.toString().split("\\s*"))
  {
    if (rules.size() > 0) rules.add(new QueryRule(Operator.AND));
    rules.add(new QueryRule(Operator.SEARCH, term));
  }
  return searchService.search(new SearchRequest("protocolTree-" + catalogId.toString(), new QueryImpl(rules)
      .pageSize(Integer.MAX_VALUE), null));
}

代码示例来源：origin: org.molgenis/molgenis-omx-protocolviewer

@RequestMapping(value = "/items", method = RequestMethod.POST)
@ResponseBody
public SearchResult getItemsFromIndex(@RequestBody Map<String, Object> request)
{
  Object catalogId = request.get("catalogId");
  Object draftItems = request.get("items");
  if (catalogId == null) return new SearchResult("The catalogID cannot be null");
  if (draftItems == null) return new SearchResult("The selected items cannot be null");
  List<QueryRule> rules = new ArrayList<QueryRule>();
  if (draftItems instanceof List<?>)
  {
    for (Object item : (List<?>) draftItems)
    {
      if (rules.size() > 0) rules.add(new QueryRule(Operator.OR));
      rules.add(new QueryRule("id", Operator.EQUALS, item.toString()));
    }
  }
  return searchService.search(new SearchRequest("protocolTree-" + catalogId.toString(), new QueryImpl(rules)
      .pageSize(Integer.MAX_VALUE), null));
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public Set<String> findOntologyTermSynonyms(Hit ontologyTermHit)
{
  String ontologyTermIRI = ontologyTermHit.getColumnValueMap().get(ONTOLOGY_TERM_IRI).toString();
  Set<String> synonyms = new HashSet<String>();
  QueryImpl query = new QueryImpl();
  query.addRule(new QueryRule(ONTOLOGY_TERM_IRI, Operator.EQUALS, ontologyTermIRI));
  query.pageSize(100000);
  SearchRequest searchRequest = new SearchRequest(null, query, null);
  SearchResult searchResult = searchService.search(searchRequest);
  for (Hit hit : searchResult.getSearchHits())
  {
    synonyms.add(hit.getColumnValueMap().get(ONTOLOGYTERM_SYNONYM).toString().toLowerCase());
  }
  return synonyms;
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public List<Hit> getRootOntologyTerms(String ontologyIri)
{
  SearchRequest searchRequest = new SearchRequest(
      AsyncOntologyIndexer.createOntologyTermDocumentType(ontologyIri), new QueryImpl().pageSize(
          Integer.MAX_VALUE).eq(OntologyTermIndexRepository.ROOT, true), null);
  List<Hit> listOfHits = new ArrayList<Hit>();
  Set<String> processedOntologyTerms = new HashSet<String>();
  for (Hit hit : searchService.search(searchRequest))
  {
    String ontologyTermIri = hit.getColumnValueMap().get(OntologyTermIndexRepository.ONTOLOGY_TERM_IRI)
        .toString();
    if (!processedOntologyTerms.contains(ontologyTermIri))
    {
      listOfHits.add(hit);
      processedOntologyTerms.add(ontologyTermIri);
    }
  }
  return listOfHits;
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public List<String> searchAllOntologies()
{
  List<String> ontologyUris = new ArrayList<String>();
  SearchResult result = searchService.search(new SearchRequest(null, new QueryImpl().pageSize(Integer.MAX_VALUE)
      .eq(OntologyTermIndexRepository.ENTITY_TYPE, OntologyIndexRepository.TYPE_ONTOLOGY), null));
  for (Hit hit : result.getSearchHits())
  {
    Map<String, Object> columnValueMap = hit.getColumnValueMap();
    if (columnValueMap.containsKey("url")) ontologyUris.add(AsyncOntologyIndexer
        .createOntologyTermDocumentType(columnValueMap.get("url").toString()));
  }
  return ontologyUris;
}

代码示例来源：origin: org.molgenis/molgenis-ontology

.findAll(
   ONTOLOGY_TERM_DYNAMIC_ANNOTATION,
   new QueryImpl<>(rulesForOtherFields).pageSize(Integer.MAX_VALUE))
 .collect(Collectors.toList());
dataService.findAll(ONTOLOGY_TERM, new QueryImpl<>(rules).pageSize(Integer.MAX_VALUE));

代码示例来源：origin: org.molgenis/molgenis-data-rest

public Query<Entity> parseQueryString(Map<String, String[]> parameterMap) {
  QueryImpl<Entity> q = new QueryImpl<>();

  for (Map.Entry<String, String[]> entry : parameterMap.entrySet()) {
   String paramName = entry.getKey();
   String[] paramValues = entry.getValue();

   if ((paramValues != null) && (paramValues.length > 0) && (paramValues[0] != null)) {
    if (paramName.equalsIgnoreCase("num")) {
     q.pageSize(DataConverter.toInt(paramValues[0]));
    } else if (paramName.equalsIgnoreCase("start")) {
     q.offset(DataConverter.toInt(paramValues[0]));
    } else if (paramName.equalsIgnoreCase("q")) {
     Query<Entity> query = molgenisRSQL.createQuery(paramValues[0], entityType);
     for (QueryRule rule : query.getRules()) {
      q.addRule(rule);
     }
    }
   }
  }

  return q;
 }
}

代码示例来源：origin: org.molgenis/molgenis-ontology-core

() ->
  dataService
    .findAll(ONTOLOGY_TERM, new QueryImpl<>(finalRules).pageSize(pageSize))
    .iterator();

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

Query query = new QueryImpl().pageSize(Integer.MAX_VALUE);
for (String ontologyTermUri : ontologyTermUris)

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

finalQuery.setOperator(Operator.SHOULD);
SearchRequest request = new SearchRequest(AsyncOntologyIndexer.createOntologyTermDocumentType(ontologyIri),
    new QueryImpl(finalQuery).pageSize(MAX_NUMBER_MATCHES), null);
Iterator<Hit> iterator = searchService.search(request).getSearchHits().iterator();

代码示例来源：origin: org.molgenis/molgenis-ontology

private void lexicalMatchOntologyTerms(
  String ontologyIri,
  Entity inputEntity,
  Entity ontologyEntity,
  int pageSize,
  List<QueryRule> rulesForOntologyTermFields,
  List<Entity> relevantEntities) {
 QueryRule disMaxQueryRule = new QueryRule(rulesForOntologyTermFields);
 disMaxQueryRule.setOperator(DIS_MAX);
 List<QueryRule> finalQueryRules =
   Arrays.asList(
     new QueryRule(OntologyTermMetaData.ONTOLOGY, EQUALS, ontologyEntity),
     new QueryRule(AND),
     disMaxQueryRule);
 Stream<Entity> lexicalMatchedOntologyTermEntities =
   dataService
     .findAll(ONTOLOGY_TERM, new QueryImpl<>(finalQueryRules).pageSize(pageSize))
     .map(
       ontologyTerm ->
         addLexicalScoreToMatchedEntity(
           inputEntity,
           ontologyTerm,
           ontologyIri)); // TODO use findAll(ONTOLOGY_TERM, ..., OntologyTerm.class)
 lexicalMatchedOntologyTermEntities.forEach(
   matchedEntity -> {
    if (!relevantEntities.contains(matchedEntity)) {
     relevantEntities.add(matchedEntity);
    }
   });
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

private SearchResult findAllFeatures(Integer targetDataSetId)
{
  QueryImpl query = new QueryImpl();
  query.addRule(new QueryRule(ENTITY_TYPE, Operator.EQUALS, ObservableFeature.class.getSimpleName().toLowerCase()));
  query.pageSize(1000000);
  DataSet dataSet = dataService.findOne(DataSet.ENTITY_NAME, targetDataSetId, DataSet.class);
  return searchService
      .search(new SearchRequest(CATALOGUE_PREFIX + dataSet.getProtocolUsed().getId(), query, null));
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public List<Ontology> getAllOntologies()
{
  List<Ontology> ontologies = new ArrayList<Ontology>();
  QueryImpl q = new QueryImpl();
  q.pageSize(Integer.MAX_VALUE);
  q.addRule(new QueryRule(OntologyIndexRepository.ENTITY_TYPE, Operator.EQUALS,
      OntologyIndexRepository.TYPE_ONTOLOGY));
  SearchRequest searchRequest = new SearchRequest(null, q, null);
  for (Hit hit : searchService.search(searchRequest).getSearchHits())
  {
    Ontology ontology = new Ontology();
    ontology.setIdentifier(hit.getColumnValueMap().get(OntologyIndexRepository.ONTOLOGY_IRI).toString());
    ontology.setOntologyURI(hit.getColumnValueMap().get(OntologyIndexRepository.ONTOLOGY_IRI).toString());
    ontology.setName(hit.getColumnValueMap().get(OntologyIndexRepository.ONTOLOGY_NAME).toString());
    ontologies.add(ontology);
  }
  return ontologies;
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

private Set<String> retrieveUnits(OntologyTerm ot)
{
  Set<String> extractedUnitObjects = new HashSet<String>();
  QueryImpl query = new QueryImpl();
  query.pageSize(10000);
  query.addRule(new QueryRule(ONTOLOGY_TERM_IRI, Operator.EQUALS, ot.getTermAccession()));
  SearchRequest searchRequest = new SearchRequest(UNIT_DOCUMENT_TYPE, query, null);
  SearchResult result = searchService.search(searchRequest);
  for (Hit hit : result.getSearchHits())
  {
    Map<String, Object> columnValueMap = hit.getColumnValueMap();
    extractedUnitObjects
        .add(processUnitName(columnValueMap.get(ONTOLOGYTERM_SYNONYM).toString().toLowerCase()));
  }
  if (!extractedUnitObjects.contains(ot.getName()))
  {
    extractedUnitObjects.add(processUnitName(ot.getName()));
  }
  return extractedUnitObjects;
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

q.pageSize(Integer.MAX_VALUE);
q.addRule(new QueryRule(PROTOCOLTREE_TYPE_FIELD, Operator.EQUALS, ObservableFeature.ENTITY_NAME.toLowerCase()));

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public Hit getOntologyByIri(String ontologyIri)
{
  QueryImpl q = new QueryImpl();
  q.pageSize(Integer.MAX_VALUE);
  q.addRule(new QueryRule(OntologyIndexRepository.ENTITY_TYPE, Operator.EQUALS,
      OntologyIndexRepository.TYPE_ONTOLOGY));
  q.addRule(new QueryRule(Operator.AND));
  q.addRule(new QueryRule(OntologyIndexRepository.ONTOLOGY_IRI, Operator.EQUALS, ontologyIri));
  SearchRequest searchRequest = new SearchRequest(AsyncOntologyIndexer.createOntologyDocumentType(ontologyIri),
      q, null);
  List<Hit> searchHits = searchService.search(searchRequest).getSearchHits();
  if (searchHits.size() > 0) return searchHits.get(0);
  return new Hit(null, AsyncOntologyIndexer.createOntologyDocumentType(ontologyIri),
      Collections.<String, Object> emptyMap());
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

/**
 * Retrieve feature information from Index based on given featureIds list.
 * If featureIds is empty, all of features are retrieved for particular
 * dataset
 * 
 * @param protocolId
 * @param featureIds
 * @return
 */
private SearchResult retrieveFeatureFromIndex(Integer protocolId, Iterable<Integer> featureIds)
{
  QueryImpl query = new QueryImpl();
  query.pageSize(Integer.MAX_VALUE);
  if (featureIds != null && Iterables.size(featureIds) > 0)
  {
    for (Integer featureId : featureIds)
    {
      if (query.getRules().size() > 0) query.addRule(new QueryRule(Operator.OR));
      query.addRule(new QueryRule(ENTITY_ID, Operator.EQUALS, featureId));
    }
  }
  else
  {
    query.addRule(new QueryRule(ENTITY_TYPE, Operator.EQUALS, ObservableFeature.class.getSimpleName()
        .toLowerCase()));
  }
  return searchService.search(new SearchRequest(CATALOGUE_PREFIX + protocolId, query, null));
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

public SearchResult findOntologyTerm(List<String> queryStrings)
{
  QueryImpl query = new QueryImpl();
  if (queryStrings.size() > 0)
  {
    for (String queryString : queryStrings)
    {
      if (query.getRules().size() > 0) query.addRule(new QueryRule(Operator.OR));
      query.addRule(new QueryRule(ONTOLOGYTERM_SYNONYM, Operator.EQUALS, queryString));
    }
    query.addRule(new QueryRule(Operator.AND));
    query.addRule(new QueryRule(ENTITY_TYPE, Operator.EQUALS, "ontologyTerm"));
    query.pageSize(100);
  }
  return searchService.search(new SearchRequest(null, query, null));
}

代码示例来源：origin: org.molgenis/molgenis-omx-biobankconnect

@Async
@RunAsSystem
@Transactional
public void applyAlgorithm(String userName, Integer targetDataSetId, List<Integer> sourceDataSetIds)
{
  currentUserStatus.setUserCurrentStage(userName, STAGE.DeleteMapping);
  removeExistingDerivedDataSets(userName, targetDataSetId, sourceDataSetIds);
  currentUserStatus.setUserCurrentStage(userName, STAGE.CreateMapping);
  createDerivedDataSets(userName, targetDataSetId, sourceDataSetIds);
  SearchResult allFeaturesResult = findAllFeatures(targetDataSetId);
  currentUserStatus.setUserTotalNumberOfQueries(userName,
      allFeaturesResult.getTotalHitCount() * sourceDataSetIds.size());
  QueryImpl query = new QueryImpl();
  query.pageSize(Integer.MAX_VALUE);
  for (Hit hit : allFeaturesResult.getSearchHits())
  {
    if (query.getRules().size() > 0) query.addRule(new QueryRule(Operator.OR));
    query.addRule(new QueryRule(STORE_MAPPING_FEATURE, Operator.EQUALS, hit.getColumnValueMap().get(ENTITY_ID)));
  }
  generateValues(userName, query, targetDataSetId, sourceDataSetIds);
  currentUserStatus.setUserCurrentStage(userName, STAGE.StoreMapping);
  searchService.indexRepository(new DataSetMatrixRepository(dataService, createDerivedDataSetIdentifier(userName,
      targetDataSetId.toString(), StringUtils.join(sourceDataSetIds, '-'))));
  currentUserStatus.setUserIsRunning(userName, false);
}

代码示例来源：origin: org.molgenis/molgenis-data-rest

Query<Entity> q =
  new QueryImpl<>(queryRules)
    .pageSize(request.getNum())
    .offset(request.getStart())
    .sort(sort);

内容来源于网络，如有侵权，请联系作者删除！

QueryImpl

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com