最近在做业务监控日志的展示， 公司用的es存储日志 ，所以也顺道学习了一波用java 的 RestHighLevelClient 查询es

    （1）普通查询   

           sql : where  id = xxx  ->  es : termQuery("id" , "xxxx")

                    where  id =XXXX and  name = xxxx   -> es : 这里要用到  BoolQueryBuilder , 也就是要用连接多个查询条件 ， 

                    boolQueryBuilder.must(QueryBuilders.boolQuery().must(QueryBuilders.termsQuery("id ", xxx)).must(QueryBuilders.boolQuery().must(QueryBuilders.termsQuery("name ", xxx)))

       (2) 聚合查询 es中用桶的概念去做聚合查询， 首先将一堆数据根据什么条件分成一个一个的桶 ， 也就是sql中的 group By 。每个桶中又有什么操作 ， 比如  count , sum ,等。

      sql : group  by  id ->  es  : AggregationBuilders.terms("idCount").field("id") , 先给你的桶起一个叫 idCount 的名字，以便于在后边获取数据的时候根据这个桶id 拿到自己的桶分组结果 ，filed(id") 就是按照id分组了。

     分享一个聚合查询最常用的操作： topHits ,比方说 ，我现在 sql 想这样查  ，  select  count(id) , name , age  from person  group by  age , 按照 age 分组之后 ， 我还想知道 name等其他字段 ， 这个时候你就可以用tophits , 

     桶内查询：TermsAggregationBuilder aggregationBuilder = AggregationBuilders.terms("active_user_count").field(field).size(10000) .subAggregation(AggregationBuilders.topHits("time").fetchSource({“age” , "name"}, null).size(1) );

    最后的size(1) 就是最后分组里面 ，我就要一条数据， 当然你还可以根据其他条件进行桶内排序， 比方 ，找出 18岁的人中， 最小的前三位 ， 这个时候 ，tophits 可以这个样写， 

TermsAggregationBuilder aggregationBuilder = // 桶名字叫 max_age , 按照age 分组 , 每个桶里面又按照出生日期倒序排列， 并且每个桶只取前三个值
AggregationBuilders.terms("max_age").field("age").size(10000).subAggregation(AggregationBuilders.topHits("time").fetchSource(new String[]{"age", "name" , "id" }, null).size(3).sort("borb_date", SortOrder.DESC));// 在 桶外， 我又想根据 年龄倒序排列 ， 
MaxAggregationBuilder serverTime = AggregationBuilders.max("maxAge111111").field("age");
BucketOrder absTimeOrder = BucketOrder.aggregation("maxAge111111", true);
aggregationBuilder.order(absTimeOrder);
aggregationBuilder.subAggregation(serverTime);
sourceBuilder.aggregation(aggregationBuilder);

注意  maxAge111111 这个名字哦 ，大家在调试代码的时候 ， 如果没有出结果 ，一定要把  SearchRequest 对象中的  source 拷贝出来运行一下哦，本质上java 代码还是在构建 查询语句的过程 ，所以你也可以先用kibana写es 查询，成功后再跟根据语句去写java代码。

还有一个需要注意的地方 ，分桶查询结果默认只返回十条， 所以如果你图省事儿， 直接设置10000 ，sourceBuilder.size(10000) ， 但是当查询结果超过一万就没办法了 ，安全做法是用es 游标去循环取值。