JavaRestClient操作Elasticsearch中的排序(sort)

不念不忘少年蓝@ 2022-12-24 00:39 214阅读 0赞

# 导包 #

导包可以根据 [文档][Link 1] 里导入依赖  
这里就不写依赖了

# 代码 #

import com.google.gson.Gson;
    import com.leyou.pojo.Item;
    import org.apache.http.HttpHost;
    import org.elasticsearch.action.search.SearchRequest;
    import org.elasticsearch.action.search.SearchResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.elasticsearch.index.query.QueryBuilders;
    import org.elasticsearch.search.SearchHit;
    import org.elasticsearch.search.SearchHits;
    import org.elasticsearch.search.builder.SearchSourceBuilder;
    import org.elasticsearch.search.sort.SortOrder;
    import org.junit.After;
    import org.junit.Before;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringRunner;
    
    import java.io.IOException;
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    public class EsdemoFindSource { 
    
        private RestHighLevelClient client;
    
        private Gson gson = new Gson();
        /** * 先执行 */
        @Before
        public void init (){ 
            // 初始化HighLevel客户端
            client = new RestHighLevelClient(
                    RestClient.builder(
                            HttpHost.create("http://127.0.0.1:9201"),
                            HttpHost.create("http://127.0.0.1:9202"),
                            HttpHost.create("http://127.0.0.1:9203")
                    )
            );
        }
    
        /** * source过滤 */
        @Test
        public void findSource() throws IOException { 
           //创建搜索对象
            SearchRequest searchRequest = new SearchRequest();
            //构建查询工具
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            //查询条件
            searchSourceBuilder.query(QueryBuilders.matchAllQuery());
            //排序条件,SortOrder.ASC:升序,SortOrder.DESC:降序
            searchSourceBuilder.sort("字段名", SortOrder.DESC);
            searchRequest.source(searchSourceBuilder);
            //搜索
            SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
            //解析
            SearchHit[] hits = search.getHits().getHits();
            for (SearchHit hit : hits) { 
                //获取数据
                String sourceString = hit.getSourceAsString();
                //反序列化
                Item item = gson.fromJson(sourceString, Item.class);
                //打印
                System.out.println("结果:"+item);
            }
    
        }
    
        /** * 后执行 */
        @After
        public void close(){ 
            try { 
                client.close();
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    }

[Link 1]: https://blog.csdn.net/weixin_44257023/article/details/110130718