org.apache.oodt.cas.filemgr.structs.Query.getCriteria()方法的使用及代码示例

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

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

Query.getCriteria介绍

暂无

代码示例

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. public static Map<String, Object> getXmlRpcQuery(Query query) {
  2.  Map<String, Object> queryHash = new Hashtable<String, Object>();
  3.  Vector<Map<String, Object>> criteriaVector = getXmlRpcQueryCriteriaList(query.getCriteria());
  4.  queryHash.put("criteria", criteriaVector);
  5.  return queryHash;
  6. }

代码示例来源：origin: apache/oodt

  1. public static Map<String, Object> getXmlRpcQuery(Query query) {
  2.  Map<String, Object> queryHash = new Hashtable<String, Object>();
  3.  Vector<Map<String, Object>> criteriaVector = getXmlRpcQueryCriteriaList(query.getCriteria());
  4.  queryHash.put("criteria", criteriaVector);
  5.  return queryHash;
  6. }

代码示例来源：origin: apache/oodt

  1. public static AvroQuery getAvroQuery(Query query){
  2.   List<AvroQueryCriteria> avroQueryCriterias = new ArrayList<AvroQueryCriteria>();
  3.   for (QueryCriteria qc : query.getCriteria()){
  4.     avroQueryCriterias.add(getAvroQueryCriteria(qc));
  5.   }
  6.   return new AvroQuery(avroQueryCriterias);
  7. }

代码示例来源：origin: apache/oodt

  1. /**
  2.  * Converts this TypeHandler's element in the given Query into a Query
  3.  * with the necessary elements and values so the Catalog can be queried.
  4.  *    
  5.  *    NOTE: Original Query is modified . . . the argument query becomes
  6.  *    equal to the returned query (return of query is a convenience).
  7.  *    
  8.  * @param query Query for which the Catalog Query will be returned
  9.  * @return A Query with Catalog element values
  10.  * @throws QueryFormulationException
  11.  * @throws IllegalAccessException 
  12.  * @throws InstantiationException 
  13.  */
  14. public Query preQueryHandle(Query query) throws QueryFormulationException {
  15.   LinkedList<QueryCriteria> qcList = new LinkedList<QueryCriteria>();
  16.   for (QueryCriteria qc : query.getCriteria()) {
  17.     qcList.add(this.handleQueryCriteria(qc));
  18.   }
  19.   query.setCriteria(qcList);
  20.   return query;
  21. }

代码示例来源：origin: apache/oodt

  1. /**
  2.  * Common utility to retrieve a range of products matching the specified {@link Query} and {@link ProductType}.
  3.  * This method transforms the given constraints in a map of HTTP (name, value) pairs and delegates to the following method.
  4.  *
  5.  * @param query
  6.  * @param type
  7.  * @param offset
  8.  * @param limit
  9.  * @return
  10.  * @throws CatalogException
  11.  */
  12. private QueryResponse getProducts(Query query, ProductType type, int offset, int limit) throws CatalogException {
  13.   // build HTTP request
  14.   ConcurrentHashMap<String, String[]> params = new ConcurrentHashMap<String, String[]>();
  15.   // product type constraint
  16.   params.put("q", new String[]{Parameters.PRODUCT_TYPE_NAME+":"+type.getName()} );
  17.   // convert filemgr query into a Solr query
  18.   List<String> qc = new ArrayList<String>();
  19.   for (QueryCriteria queryCriteria : query.getCriteria()) {
  20.     LOG.info("Query criteria="+queryCriteria.toString());
  21.     qc.add(queryCriteria.toString());
  22.   }
  23.   params.put("fq", qc.toArray( new String[ qc.size() ] ));
  24.   // sort
  25.   params.put("sort", new String[]{ Parameters.PRODUCT_RECEIVED_TIME+" desc"} );
  26.   return this.getProducts(params, offset, limit);
  27. }

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. /**
  2.  * Converts this TypeHandler's element in the given Query into a Query
  3.  * with the necessary elements and values so the Catalog can be queried.
  4.  *    
  5.  *    NOTE: Original Query is modified . . . the argument query becomes
  6.  *    equal to the returned query (return of query is a convenience).
  7.  *    
  8.  * @param query Query for which the Catalog Query will be returned
  9.  * @return A Query with Catalog element values
  10.  * @throws QueryFormulationException
  11.  * @throws IllegalAccessException 
  12.  * @throws InstantiationException 
  13.  */
  14. public Query preQueryHandle(Query query) throws QueryFormulationException {
  15.   LinkedList<QueryCriteria> qcList = new LinkedList<QueryCriteria>();
  16.   for (QueryCriteria qc : query.getCriteria()) {
  17.     qcList.add(this.handleQueryCriteria(qc));
  18.   }
  19.   query.setCriteria(qcList);
  20.   return query;
  21. }

代码示例来源：origin: org.apache.oodt/oodt-webapp-components

  1. private void refreshProductPage() {
  2.  Query query = new Query();
  3.  System.out.println("CALLING REFRESH PRODUCT PAGE, CRITERIA:");
  4.  for (TermQueryCriteria crit : this.criteria) {
  5.   System.out.println(crit);
  6.  }
  7.  query.getCriteria().addAll(this.criteria);
  8.  try {
  9.   this.productPage = fm.getFm().pagedQuery(query, type, this.pageNum);
  10.  } catch (CatalogException e) {
  11.   LOG.log(Level.SEVERE, "Unable to obtain page products: type: ["
  12.     + type.getName() + "]: Reason: " + e.getMessage());
  13.  }
  14. }

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. /**
  2.  * Common utility to retrieve a range of products matching the specified {@link Query} and {@link ProductType}.
  3.  * This method transforms the given constraints in a map of HTTP (name, value) pairs and delegates to the following method.
  4.  * 
  5.  * @param query
  6.  * @param type
  7.  * @param offset
  8.  * @param limit
  9.  * @return
  10.  * @throws CatalogException
  11.  */
  12. private QueryResponse getProducts(Query query, ProductType type, int offset, int limit) throws CatalogException {
  13.   
  14.   // build HTTP request
  15.   ConcurrentHashMap<String, String[]> params = new ConcurrentHashMap<String, String[]>();
  16.   // product type constraint
  17.   params.put("q", new String[]{Parameters.PRODUCT_TYPE_NAME+":"+type.getName()} );
  18. // convert filemgr query into a Solr query
  19.   List<String> qc = new ArrayList<String>();
  20. for (QueryCriteria queryCriteria : query.getCriteria()) {
  21.     LOG.info("Query criteria="+queryCriteria.toString());
  22.     qc.add(queryCriteria.toString());
  23. }
  24. params.put("fq", qc.toArray( new String[ qc.size() ] ));
  25. // sort
  26. params.put("sort", new String[]{ Parameters.PRODUCT_RECEIVED_TIME+" desc"} );
  27. return this.getProducts(params, offset, limit);
  28.   
  29. }

代码示例来源：origin: apache/oodt

  1. private void refreshProductPage() {
  2.  Query query = new Query();
  3.  System.out.println("CALLING REFRESH PRODUCT PAGE, CRITERIA:");
  4.  for (TermQueryCriteria crit : this.criteria) {
  5.   System.out.println(crit);
  6.  }
  7.  query.getCriteria().addAll(this.criteria);
  8.  try {
  9.   this.productPage = fm.getFm().pagedQuery(query, type, this.pageNum);
  10.  } catch (CatalogException e) {
  11.   LOG.log(Level.SEVERE, "Unable to obtain page products: type: ["
  12.     + type.getName() + "]: Reason: " + e.getMessage());
  13.  }
  14. }

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. @SuppressWarnings("unchecked")
  2. public static ComplexQuery getComplexQueryFromXmlRpc(Map<String, Object> complexQueryHash) {
  3.  ComplexQuery complexQuery = new ComplexQuery();
  4.  complexQuery.setCriteria(getQueryFromXmlRpc(complexQueryHash).getCriteria());
  5.  if (((Vector<String>) complexQueryHash.get("reducedProductTypeNames")).size() > 0) {
  6.   complexQuery.setReducedProductTypeNames((Vector<String>) complexQueryHash.get("reducedProductTypeNames"));
  7.  }
  8.  if (((Vector<String>) complexQueryHash.get("reducedMetadata")).size() > 0) {
  9.   complexQuery.setReducedMetadata((Vector<String>) complexQueryHash.get("reducedMetadata"));
  10.  }
  11.  complexQuery.setSortByMetKey((String) complexQueryHash.get("sortByMetKey"));
  12.  complexQuery.setToStringResultFormat((String) complexQueryHash.get("toStringResultFormat"));
  13.  if (complexQueryHash.get("queryFilter") != null) {
  14.   complexQuery.setQueryFilter(
  15.     getQueryFilterFromXmlRpc((Map<String, Object>) complexQueryHash.get("queryFilter")));
  16.  }
  17.  return complexQuery;
  18. }

代码示例来源：origin: apache/oodt

  1. @SuppressWarnings("unchecked")
  2. public static ComplexQuery getComplexQueryFromXmlRpc(Map<String, Object> complexQueryHash) {
  3.  ComplexQuery complexQuery = new ComplexQuery();
  4.  complexQuery.setCriteria(getQueryFromXmlRpc(complexQueryHash).getCriteria());
  5.  if (((Vector<String>) complexQueryHash.get("reducedProductTypeNames")).size() > 0) {
  6.   complexQuery.setReducedProductTypeNames((Vector<String>) complexQueryHash.get("reducedProductTypeNames"));
  7.  }
  8.  if (((Vector<String>) complexQueryHash.get("reducedMetadata")).size() > 0) {
  9.   complexQuery.setReducedMetadata((Vector<String>) complexQueryHash.get("reducedMetadata"));
  10.  }
  11.  complexQuery.setSortByMetKey((String) complexQueryHash.get("sortByMetKey"));
  12.  complexQuery.setToStringResultFormat((String) complexQueryHash.get("toStringResultFormat"));
  13.  if (complexQueryHash.get("queryFilter") != null) {
  14.   complexQuery.setQueryFilter(
  15.     getQueryFilterFromXmlRpc((Map<String, Object>) complexQueryHash.get("queryFilter")));
  16.  }
  17.  return complexQuery;
  18. }

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. if (query.getCriteria().size() == 0) {
  2.    getProductSql.append("SELECT DISTINCT product_id FROM ").append(type.getName()).append("_metadata");
  3.  }else if (query.getCriteria().size() == 1) {
  4.    getProductSql.append(this.getSqlQuery(query.getCriteria().get(0), type));
  5.  }else {
  6.    getProductSql.append(this.getSqlQuery(new BooleanQueryCriteria(query.getCriteria(), BooleanQueryCriteria
  7.      .AND), type));
  8. if (query.getCriteria().size() == 0) {
  9.  getProductSql.append("SELECT DISTINCT products.product_id FROM products, ").append(type.getName())
  10.         .append("_metadata").append(" WHERE products.product_id=").append(type.getName())
  11.         .append("_metadata.product_id");
  12. }    else if (query.getCriteria().size() == 1) {
  13.  getProductSql.append(this.getSqlQuery(query.getCriteria().get(0), type));
  14. }    else {
  15.  getProductSql.append(this.getSqlQuery(new BooleanQueryCriteria(query.getCriteria(), BooleanQueryCriteria
  16.    .AND), type));

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. int clauseNum = 0;
  2. if (query.getCriteria() != null && query.getCriteria().size() > 0) {
  3.  for (QueryCriteria criteria : query.getCriteria()) {
  4.   clauseNum++;

代码示例来源：origin: apache/oodt

  1. int clauseNum = 0;
  2. if (query.getCriteria() != null && query.getCriteria().size() > 0) {
  3.  for (QueryCriteria criteria : query.getCriteria()) {
  4.   clauseNum++;

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. for (QueryCriteria queryCriteria : query.getCriteria()) {
  2.   booleanQuery.add(this.getQuery(queryCriteria), BooleanClause.Occur.MUST);

代码示例来源：origin: apache/oodt

  1. for (QueryCriteria queryCriteria : query.getCriteria()) {
  2.   booleanQuery.add(this.getQuery(queryCriteria), BooleanClause.Occur.MUST);

代码示例来源：origin: org.apache.oodt/oodt-webapp-components

  1. private void computeStartEndIdx() {
  2.  if (this.productPage.getTotalPages() == 1) {
  3.   this.totalProducts = this.productPage.getPageProducts().size();
  4.   this.pageNum = 1;
  5.  } else if (productPage.getTotalPages() == 0) {
  6.   this.totalProducts = 0;
  7.   this.pageNum = 1;
  8.  } else {
  9.   this.totalProducts = (productPage.getTotalPages() - 1) * PAGE_SIZE;
  10.   this.pageNum = this.productPage.getPageNum();
  11.   // get the last page
  12.   ProductPage lastPage;
  13.   Query query = new Query();
  14.   query.getCriteria().addAll(this.criteria);
  15.   try {
  16.    lastPage = fm.getFm().pagedQuery(query, this.type,
  17.      this.productPage.getTotalPages());
  18.    this.totalProducts += lastPage.getPageProducts().size();
  19.   } catch (Exception ignore) {
  20.   }
  21.  }
  22.  this.endIdx = this.totalProducts != 0 ? Math.min(this.totalProducts,
  23.    (PAGE_SIZE) * (this.pageNum)) : 0;
  24.  this.startIdx = this.totalProducts != 0 ? ((this.pageNum - 1) * PAGE_SIZE) + 1
  25.    : 0;
  26. }

代码示例来源：origin: apache/oodt

  1. for (QueryCriteria queryCriteria : query.getCriteria()) {
  2.   booleanQuery.add(this.getQuery(queryCriteria), BooleanClause.Occur.MUST);

代码示例来源：origin: org.apache.oodt/cas-filemgr

  1. for (QueryCriteria queryCriteria : query.getCriteria()) {
  2.   booleanQuery.add(this.getQuery(queryCriteria), BooleanClause.Occur.MUST);

代码示例来源：origin: apache/oodt

  1. private void computeStartEndIdx() {
  2.  if (this.productPage.getTotalPages() == 1) {
  3.   this.totalProducts = this.productPage.getPageProducts().size();
  4.   this.pageNum = 1;
  5.  } else if (productPage.getTotalPages() == 0) {
  6.   this.totalProducts = 0;
  7.   this.pageNum = 1;
  8.  } else {
  9.   this.totalProducts = (productPage.getTotalPages() - 1) * PAGE_SIZE;
  10.   this.pageNum = this.productPage.getPageNum();
  11.   // get the last page
  12.   ProductPage lastPage;
  13.   Query query = new Query();
  14.   query.getCriteria().addAll(this.criteria);
  15.   try {
  16.    lastPage = fm.getFm().pagedQuery(query, this.type,
  17.      this.productPage.getTotalPages());
  18.    this.totalProducts += lastPage.getPageProducts().size();
  19.   } catch (Exception ignore) {
  20.   }
  21.  }
  22.  this.endIdx = this.totalProducts != 0 ? Math.min(this.totalProducts,
  23.    (PAGE_SIZE) * (this.pageNum)) : 0;
  24.  this.startIdx = this.totalProducts != 0 ? ((this.pageNum - 1) * PAGE_SIZE) + 1
  25.    : 0;
  26. }

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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