投稿
  1. 首页
  2. 随笔

java *** 作es之rest风格基本 *** 作

城市画报•2022-12-17•随笔•阅读20

java *** 作es之rest风格基本 *** 作,第1张

java *** 作es之rest风格基本 *** 作

ES基本 *** 作

文章目录
  • 1、注入RestHighLevelClient
  • 2、 *** 作索引
    • 2.1、创建索引
    • 2.2、测试索引是否存在 GET index
    • 2.3、删除索引 DELETe index
  • 3、文档 *** 作
    • 3.1、添加文档
    • 3.2、获取文档，查看是否存在
    • 3.3、获取文档信息
    • 3.4、更新文档
    • 3.5、删除1号文档
    • 3.6、批量插入数据
    • 3.7、查询，分页，高亮
  • 4、查询
    • 4.1、整体结构
    • 4.2、常用条件查询
      • 4.2.1、精度匹配查询 termQuery
      • 4.2.2、匹配查询（分词）matchQuery
      • 4.2.3、精确查询 queryString
      • 4.2.4、模糊查询 wildcardQuery
      • 4.2.5、范围查询 rangeQuery
      • 4.2.6、多条件合并查询

1、注入RestHighLevelClient 
@Configuration
public class ElasticSearchClientConfig {
    @Bean
    public RestHighLevelClient restHighLevelClient(){
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(new HttpHost("39.105.145.159",9200,"http"))
        );
        return client;
    }
}
2、 *** 作索引

注入RestHighLevelClient

@Autowired
@Qualifier("restHighLevelClient")
RestHighLevelClient client;
2.1、创建索引

​ PUT index

void testIndex() {
        //1.创建索引的请求
        CreateIndexRequest request = new CreateIndexRequest("test_index");
        //2客户端执行请求，请求后获得响应
        CreateIndexResponse response = null;
        try {
            response = client.indices().create(request, RequestOptions.DEFAULT);
        } catch (IOException e) {
            e.printStackTrace();
        }
        System.out.println(response);
    }
2.2、测试索引是否存在 GET index 
void testExistIndex() throws IOException {
    //1.创建索引的请求
    GetIndexRequest request = new GetIndexRequest("test_index");
    //2客户端执行请求，请求后获得响应
    boolean exist =  client.indices().exists(request, RequestOptions.DEFAULT);
    System.out.println("测试索引是否存在-----"+exist);
}
2.3、删除索引 DELETE index 
void testDeleteIndex() throws IOException {
    DeleteIndexRequest request = new DeleteIndexRequest("test_index");
    AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
    System.out.println("删除索引--------" + delete.isAcknowledged());
}
3、文档 *** 作 3.1、添加文档 
void testAdddocument() throws IOException {
    //创建对象
    User user = new User("小明",18);
    //创建请求
    IndexRequest request = new IndexRequest("test_index");
    //制定规则
    request.id("1");//id
    request.timeout(Timevalue.timevalueSeconds(1));//过期时间
    //request.timeout("1s");

    //将数据放入请求
    request.source(JSON.toJSONString(user), XContentType.JSON);
    //客户端发送请求
    IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);

}
3.2、获取文档，查看是否存在 
void testIsExists() throws IOException {
    GetRequest getRequest = new GetRequest("test_index", "1");
    getRequest.fetchSourceContext(new FetchSourceContext(false));//不获取_source的上下文，效率更高
    getRequest.storedFields("_none_");

    boolean exists = client.exists(getRequest,RequestOptions.DEFAULT);
    System.out.println(exists);

}
3.3、获取文档信息 
void testGetdocument() throws IOException{
    GetRequest getRequest = new GetRequest("test_index", "1");
    GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
    System.out.println(getResponse.getSourceAsString());//打印文档内容
    System.out.println(getResponse);//返回的全部内容和命令获取的是一样的
}
3.4、更新文档 
void testUpdatedocument() throws IOException{
    UpdateRequest updateRequest = new UpdateRequest("test_index", "1");
    updateRequest.timeout("1s");
    User user = new User("小明", 10);
    updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);
    UpdateResponse update = client.update(updateRequest, RequestOptions.DEFAULT);
    System.out.println(update.status());
    System.out.println(update);
}
3.5、删除1号文档 
void testDeletedocument() throws IOException{
    DeleteRequest deleteRequest = new DeleteRequest("test_index", "1");
    deleteRequest.timeout("1s");
    DeleteResponse delete = client.delete(deleteRequest, RequestOptions.DEFAULT);
    System.out.println(delete);
    System.out.println(delete.status());
}
3.6、批量插入数据 
void testBulkdocument() throws IOException {
    BulkRequest bulkRequest = new BulkRequest();
    bulkRequest.timeout("10s");//数据越大时间越多

    ArrayList arrayList = new ArrayList<>();
    arrayList.add(new User("小明",10));
    arrayList.add(new User("小红",11));
    arrayList.add(new User("小1",12));
    arrayList.add(new User("小2",13));
    arrayList.add(new User("小3",14));
    arrayList.add(new User("小4",15));

    //批处理请求
    for(int i = 0;i 
3.7、查询，分页，高亮 

void testSearch() throws IOException {
    ArrayList> list = new ArrayList<>();
    SearchRequest searchRequest = new SearchRequest("test_index");
    //构建搜索条件
    SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

    //查询条件，可以使用QueryBuilders  因为中文愿意查不出中文，所以将name改为name.keyword,也可以安装ik分词器
    TermQueryBuilder termQuery = QueryBuilders.termQuery("name.keyword", "小红");//精确查询
    sourceBuilder.query(termQuery);


    //匹配所有
    


    //在60s内查询出来
    sourceBuilder.timeout(new Timevalue(60, TimeUnit.SECONDS));

    //分页
    sourceBuilder.from(0);
    sourceBuilder.size(4);

    //高亮显示
    HighlightBuilder highlightBuilder = new HighlightBuilder();
    highlightBuilder.field("name.keyword");
    highlightBuilder.requireFieldMatch(false);  //多个单词高亮的话，要把这个设置为trues
    highlightBuilder.preTags("");
    highlightBuilder.postTags("");
    sourceBuilder.highlighter(highlightBuilder);

    //执行搜索
    searchRequest.source(sourceBuilder);
    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);//执行请求

    for (SearchHit hit : searchResponse.getHits().getHits()) {
        //解析高亮，用高亮替换原来的
        Map highlightFields = hit.getHighlightFields();
        HighlightField name = highlightFields.get("name.keyword");
        Map sourceAsMap = hit.getSourceAsMap();//原来的结果
        if(name!=null){
            Text[] fragments = name.fragments();
            StringBuilder newName = new StringBuilder();
            for (Text text : fragments) {
                newName.append(text);
            }
            sourceAsMap.put("name", newName.toString());
            list.add(sourceAsMap);
        }
    }
    System.out.println(list.toString());
}

 
4、查询 
4.1、整体结构 

  •  
    注入RestHighLevelClient
     
    @Autowired
@Qualifier("restHighLevelClient")
RestHighLevelClient client;

     
  •  
    搜索框架
     
    void findByName() throws IOException {
  SearchRequest searchRequest = new SearchRequest("test_index");
  //构建搜索条件
  SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
  //存储多个条件
  BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
  //构建条件
  TermQueryBuilder query1 = QueryBuilders.termQuery("name.keyword","小明");
  //条件放入
  queryBuilder.should(query1);
  //多条件引入
  sourceBuilder.query(queryBuilder);
  //进行分页
  sourceBuilder.from(0);
  sourceBuilder.size(6);
  //条件进入请求
  searchRequest.source(sourceBuilder);
  //执行查询
  SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
  //解析查询结果
  for (SearchHit hit : search.getHits().getHits()) {
      System.out.println(hit.getSourceAsMap().toString());
  }
}

     
 
4.2、常用条件查询 
4.2.1、精度匹配查询 termQuery 

TermQueryBuilder query1 = QueryBuilders.termQuery("name.keyword","小明");

 

根据名字查询，查询name，加上keyword是由于中文匹配，keyword不会进行分词，才能够进行查询，不加keyword默认是text，会进行分词
 
4.2.2、匹配查询（分词）matchQuery 

MatchQueryBuilder name = QueryBuilders.matchQuery("name", "小明");

 

查询结果:
 

它会将“小明”分为“小”与“明”进行查询，所以将“小兰”也查出来了
 
4.2.3、精确查询 queryString 

//构建条件QueryStringQueryBuilder name = new QueryStringQueryBuilder("小兰").field("name").defaultOperator(Operator.AND);

 

使用QueryStringQueryBuilder构造查询条件，不用keyword也可以精确查询。
 
4.2.4、模糊查询 wildcardQuery 

WildcardQueryBuilder wildcardQuery = QueryBuilders.wildcardQuery("name.keyword", String.format("*%s*", "小"));

 

查询结果：
 

小字进行模糊查询。
 
4.2.5、范围查询 rangeQuery 

RangeQueryBuilder age = QueryBuilders.rangeQuery("age").from(12, true).to(15, true);

 

后面的true表示包含当前值即：[12,15],若为false则为(12,15)。
 
4.2.6、多条件合并查询 

//搜索条件WildcardQueryBuilder wildcardQuery1 = QueryBuilders.wildcardQuery("name.keyword", String.format("*%s*", "小"));WildcardQueryBuilder wildcardQuery2 = QueryBuilders.wildcardQuery("name.keyword", String.format("*%s*", "兰"));queryBuilder.must(wildcardQuery1).must(wildcardQuery2);

 

查询结果：
 

这里使用的是must进行合并查询，代表and，使用should即代表or，可以分开写也可以合在一条语句。
 

保存笔记，以后总能用得着。
欢迎分享，转载请注明来源：内存溢出
原文地址:https://54852.com/zaji/5669255.html
赞 (0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
城市画报城市画报一级用户组
00
上一篇 2022-12-16
下一篇2022-12-16

发表评论

登录后才能评论

评论列表（0条）

    保存