// 标准es查询语法,拼音模糊搜索
//创建复杂查询对象---------
SearchRequest searchRequest = new SearchRequest("pinyindata");
//创建一个条件对象用来封装各种条件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

//创建一个对象来封装查询条件query
MatchQueryBuilder queryBuilder = new MatchQueryBuilder("name.pinyin","xw");
//使用条件对象来封装查询条件---条件
sourceBuilder.query(queryBuilder);

//指定查询的列------条件
String[] arr = {"id", "name"};
String[] att = {};
sourceBuilder.fetchSource(arr,att); //指定查询列和不查询列

//分页查询---条件
sourceBuilder.from(0);
sourceBuilder.size(5);
//排序----条件
// SortOrder sortOrder = SortOrder.ASC;------定义排序方式
sourceBuilder.sort("name", SortOrder.DESC);

//创建一个高亮对象，封装高亮条件
HighlightBuilder highlightBuilder = new HighlightBuilder();
//指定高亮列----也可以用fields，全局定义高亮
highlightBuilder.field("name");
highlightBuilder.preTags("<font color='red'>");
highlightBuilder.postTags("</font>");

sourceBuilder.highlighter(highlightBuilder);
//将封装好的条件对象给searchRequest
searchRequest.source(sourceBuilder);
//将封装好所有条件的对象给查询方法
SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
//输出根据条件查出的总条数
System.out.println("命中条数/查询总数:"+search.getHits().getTotalHits().value);

//将查出的数据封住为一个数组
SearchHit[] hits = search.getHits().getHits();
//遍历数组
Arrays.stream(hits).forEach(item->{
    //输出遍历对象
    System.out.println(item.getSourceAsString());
});
Arrays.stream(hits).forEach(item->{
    //遍历输出高亮的字段
    System.out.println(item.getHighlightFields());
});

@Configuration
public class EsConfig {

    @Value("${es.host}")
    private String esHost;
    @Value("${es.port}")
    private Integer esPort;

    @Bean
    public RestHighLevelClient getRestHighLevelClient(){
        HttpHost http1 = new HttpHost(esHost, esPort, "http");
        // 节点2： HttpHost http2 = new HttpHost("127.0.0.1", 9201, "http");
        RestClientBuilder restClientBuilder = RestClient.builder(http1);
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
        return restHighLevelClient;
    }

}

@Autowired
private RestHighLevelClient restHighLevelClient;

Map<String, Object> map = new HashMap<String, Object>() ;
IndexRequest indexRequest = new IndexRequest("pinyindata").type("_doc").id(String.valueOf(map.get("id"))).source(map);
IndexResponse indexResponse = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);

//t_project为表名
List<Entity> projectList = Db.use().findAll("t_project");
List<Map<String, Object>> addList = new ArrayList<>();
for (Entity entity : projectList) {
  Long id = entity.getLong("id");
  String projectName = entity.getStr("project_name");
  Map<String, Object> map = new HashMap<String, Object>() ;
  addList.add(map);
}
BulkRequest bulkRequest = new BulkRequest();
addList.forEach(s -> bulkRequest.add(new IndexRequest().index("pinyindata").type("_doc").id(s.get("id").toString()).source(s)));
bulkRequest.timeout(TimeValue.timeValueSeconds(5));
BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);

@GetMapping("/update")
public void update() throws IOException {
  // 指定id更新
  UpdateRequest updateRequest = new UpdateRequest("pinyindata", "_doc", "5155195438038622213")
    .doc(new HashMap<String, Object>() );
  UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
}

// 根据id获取文档
@GetMapping("/getDocByID")
public Map<String, Object> getDocByID(String id) {
  Map<String, Object> map = new HashMap<>();
  SearchRequest searchRequest = new SearchRequest("pinyindata");
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(QueryBuilders.termQuery("_id", id));
  searchRequest.source(searchSourceBuilder);
  try {
    SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
    if (searchResponse.status() == RestStatus.OK) {
      map = searchResponse.getHits().getAt(0).getSourceAsMap();
    }
  } catch (Exception e) {
    e.printStackTrace();
  }
  return map;
}

{
  "name": "h宾馆",
  "id": 5155195438038622213
}

@GetMapping("/delete")
public void deleteById(String id) throws IOException {
  DeleteRequest deleteByQueryRequest = new DeleteRequest("pinyindata", "_doc", id);
  restHighLevelClient.delete(deleteByQueryRequest, RequestOptions.DEFAULT);
}

//1.创建 SearchRequest搜索请求 指定要查询的索引
SearchRequest searchRequest = new SearchRequest("pinyindata");

//2.创建 SearchSourceBuilder条件构造。builder模式这里就先不简写了
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
/*// 2.1创建一个对象来封装查询条件query，使用拼音分词器->字段名.pinyin进行拼音搜索
        MatchQueryBuilder queryBuilder = new MatchQueryBuilder("name.pinyin","xw");*/
// 2.2查询全部
MatchAllQueryBuilder queryBuilder = QueryBuilders.matchAllQuery();
searchSourceBuilder.query(queryBuilder);

//3.将 SearchSourceBuilder 添加到 SearchRequest中
searchRequest.source(searchSourceBuilder);

//4.执行查询
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);

//5.解析查询结果
System.out.println(searchResponse);
System.out.println("花费的时长：" + searchResponse.getTook());

SearchHits hits = searchResponse.getHits();
System.out.println(hits.getTotalHits());
System.out.println("符合条件的总文档数量：" + hits.getTotalHits().value);
hits.forEach(p -> System.out.println("文档原生信息：" + p.getSourceAsString()));

ArrayList<Map<String, Object>> resultList = new ArrayList<>();
SearchRequest searchRequest = new SearchRequest("pinyindata");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder()
  /*分页参数 es默认最大查询数量10000*/
  .from(0).size(10000)
  /*查询条件*/
  .query(QueryBuilders.matchQuery("name.pinyin", projectName));
searchRequest.source(searchSourceBuilder);
SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
if (searchResponse.status() == RestStatus.OK) {
  SearchHits searchHits = searchResponse.getHits();
  for (SearchHit searchHit: searchHits) {
    resultList.add(searchHit.getSourceAsMap());
    System.out.println(searchHit.getSourceAsMap());
  }
}
return resultList;