ES7.9基本操作

@Autowired

@Qualifier("restHighLevelClient")

private RestHighLevelClientclient;

@Test

public void addIndex() throws IOException{

    System.out.println(ESutils.INDEX);

    System.out.println(ESutils.ID);

  Brand brand =new Brand(1,"a","b");

  String s = JSON.toJSONString(brand);

    XContentBuilder builder =jsonBuilder()

            .startObject()

            .field("user", "kimchy")

            .field("postDate", new Date())

            .field("message", "trying out Elasticsearch")

            .endObject();

    XContentBuilder builder =jsonBuilder().field(s);

    String s1 = Strings.toString(builder);

    System.out.println("s1 = " + s1);

}

/**

• 索引操作

• @throws IOException

*/

@Test

public void test0014Creat() throws IOException{

    // put testIndex  默认doc

    CreateIndexRequest request =new CreateIndexRequest("test_index");

    //执行请求                                        实现上面请求    默认参数

    CreateIndexResponse resp =client.indices().create(request, RequestOptions.DEFAULT);

    //

    System.out.println(resp);

  /* boolean test_index2 = elasticsearchTemplate.createIndex("test_index2");

        该版本好像还没有更新新的es

System.out.println("test_index2 = " + test_index2);*/

}

//exit + delete

@Test

public void test002Exit() throws IOException{

    // put testIndex  默认doc

    GetIndexRequest request =new GetIndexRequest("test_index3");

    boolean exists =client.indices().exists(request, RequestOptions.DEFAULT);

    System.out.println("exists = " + exists);

    DeleteIndexRequest deleteIndexRequest =new DeleteIndexRequest("test_index3");

    AcknowledgedResponse delete =client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);

    System.out.println("delete = " + delete.isAcknowledged());

}

/***

*文档操作

*/

//添加文档

@Test

public void test001Insert() throws IOException{

    User user =new User("a",12);

    //导向库

    IndexRequest request =new IndexRequest("test_index");

    //put test_index/_doc/1

//id

    request.id("1");

    //过期时间

    request.timeout("3s");

    //放入数据  设置数据格式

    request.source(JSON.toJSONString(user), XContentType.JSON);

    //用index 放入请求

    IndexResponse response =client.index(request, RequestOptions.DEFAULT);

    System.out.println("response = " + response);

    System.out.println(response.status());

    System.out.println(response.toString());

}

//获取信息

@Test

public void test002Get() throws IOException{

    //获取索引数据get test_index

    GetRequest request =new GetRequest("test_index", "1");

    // 不获取返回的_source 上下文

  /* request.fetchSourceContext(new FetchSourceContext(false));

request.storedFields("_none_");*/

    GetResponse documentFields =client.get(request, RequestOptions.DEFAULT);

    System.out.println(documentFields.toString());

    System.out.println(documentFields.getSourceAsMap());

}

//更新文档

@Test

public void test003Update() throws IOException{

    UpdateRequest updateRequest =new UpdateRequest("test_index", "1");

    User user =new User("B",2);

    updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);

    UpdateResponse update =client.update(updateRequest, RequestOptions.DEFAULT);

    System.out.println(update.getResult());

    System.out.println(update);

}

/**

• 批量操作数据

• @throws IOException

*/

//批量操作数据

@Test

public void test004bluk() throws IOException{

    BulkRequest bulkRequest =new BulkRequest();

    bulkRequest.timeout("10s");

    ArrayList<User> list =new ArrayList<>();

    list.add(new User("1a",2));

    list.add(new User("7a",3));

    list.add(new User("7a",6));

    list.add(new User("8a",9));

    list.add(new User("9a",12));

    list.add(new User("6a",22));

    list.add(new User("3a",32));

    list.add(new User("2a",42));

    list.add(new User("1a",52));

    for (int i =0; i

        bulkRequest.add(new IndexRequest(ESutils.INDEX)

                    .id((i+10)+"")

                    .source(JSON.toJSONString(list.get(i)),XContentType.JSON));

    }

    BulkResponse bulk =client.bulk(bulkRequest, RequestOptions.DEFAULT);

    System.out.println(bulk.hasFailures());

    System.out.println(bulk.buildFailureMessage());

    System.out.println(bulk.getItems());

    System.out.println(bulk.status());

    System.out.println(bulk.getTook());

    System.out.println(bulk.getIngestTook());

}

/**

• 搜索查询

*/

@Test

public void test001Search() throws IOException{

    //发起搜索请求

    SearchRequest searchRequest =new SearchRequest(ESutils.INDEX_GOODS);

    //搜索构建器

    SearchSourceBuilder searchSourceBuilder =new SearchSourceBuilder();

    //查询条件

    MatchQueryBuilder query1 = QueryBuilders.matchQuery("brandName", "三");

    RangeQueryBuilder query2 = QueryBuilders.rangeQuery("price").gte(1000).lte(2000);

    BoolQueryBuilder query = QueryBuilders.boolQuery().must(query2).must(query1);

    //设置搜索构造器参数

    searchSourceBuilder.from(0);

    searchSourceBuilder.size(5);

    searchSourceBuilder.sort(new FieldSortBuilder("id").order(SortOrder.DESC));

    //添加高亮进入条件  使用高亮构造器

    searchSourceBuilder.highlighter(new HighlightBuilder().field("brandName").preTags("<p color = red >").postTags("<p>"));

    searchSourceBuilder.query(query).query(query);

    //搜索构造器参数加入搜索

    SearchRequest request = searchRequest.source(searchSourceBuilder);

    //老操作了 调用客户端search

    SearchResponse search =client.search(request, RequestOptions.DEFAULT);

    System.out.println(search.getHits());

    System.out.println("------------");

    search.getHits().forEach(s-> System.out.println(s));

    System.out.println("------------");

    System.out.println(search.getHits().getTotalHits());

    System.out.println("------------");

    //处理高亮之后

    for (SearchHit hit : search.getHits().getHits()) {

        Map<String, Object> sourceAsMap = hit.getSourceAsMap();

        //处理高亮字段

        Map<String, HighlightField> highlightFields = hit.getHighlightFields();

        HighlightField field = highlightFields.get("brandName");

        Text[] fragments = field.fragments();

        String a ="";

        for (Text fragment : fragments) {

            a+=fragment;

        }

        //高亮字段覆盖原字段

        sourceAsMap.put("brandName",a);

        System.out.println(sourceAsMap);

    }