zoukankan      html  css  js  c++  java
  • ES查询操作

    /**
    *
    * method_name:simpleSearch
    * date:2016年11月4日上午11:10:53
    * author:terry
    * return_type:List<Map<String,Object>>
    * description:简单查询
    */
    public static List<Map<String,Object>> simpleSearch(String alias,String[] indexNames,String[] types, HashMap<String, Object[]> mustSearchContentMap, int from, int offset, String sortField, String sortType,String exisiFiled){
    long sTime = System.currentTimeMillis();
    if (offset <= 0) {
    return null;
    }
    try {
    SearchRequestBuilder searchRequestBuilder = searchClient.prepareSearch(alias).setSearchType(SearchType.DEFAULT)//SearchType.DEFAULT
    .setFrom(from).setSize(offset).setExplain(true);
    if(types != null){
    searchRequestBuilder.setTypes(types);
    }
    if (sortField == null || sortField.isEmpty() || sortType == null || sortType.isEmpty()) {
    /*如果不需要排序*/
    }
    else {
    /*如果需要排序*/
    org.elasticsearch.search.sort.SortOrder sortOrder = sortType.equals("desc") ? org.elasticsearch.search.sort.SortOrder.DESC : org.elasticsearch.search.sort.SortOrder.ASC;
    searchRequestBuilder = searchRequestBuilder.addSort(sortField, sortOrder);
    }

    if(mustSearchContentMap == null){//查询条件为空 则查询所有数据
    searchRequestBuilder = searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
    }else{
    BoolQueryBuilder bool = EsTools.createQueryBuilder(mustSearchContentMap, SearchLogic.must);
    bool.filter(QueryBuilders.existsQuery(exisiFiled));
    searchRequestBuilder = searchRequestBuilder.setQuery(bool);
    }
    //
    SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
    long eTime = System.currentTimeMillis();
    long time = eTime - sTime;
    logger.info("====================simpleSearch查询耗时:"+time+"毫秒===============================");
    return getSearchResult(searchResponse);
    }
    catch (Exception e) {
    logger.error(e.getMessage());
    e.printStackTrace();
    }
    return null;
    }

  • 相关阅读:
    多线程自动化运维linux的尝试 优化二
    多线程自动化运维linux的尝试 优化一
    多线程自动化运维linux的尝试
    mysql root 没有任何权限
    oracle hint 知多少
    pandas 实战笔记
    ICM issue IcmPlAllocBuf: MpiGetOutbuf failed (rc = 14 (MPI_ESTALE: outdated MPI handle))
    利用python在Oracle数据库中生成密码字典库
    nginx 配置的一些参数
    nginx四层代理
  • 原文地址:https://www.cnblogs.com/fuqiang-terry/p/6836289.html
Copyright © 2011-2022 走看看