ElasticSearch简单使用总结

java配置文件

@Bean("restHighLevelClient")
	public RestHighLevelClient restHighLevelClient() {
		RestHighLevelClient restHighLevelClient = new RestHighLevelClient(RestClient.builder(new HttpHost("127.0.0.1",9200,"http")));
		return restHighLevelClient;
	}

	@GetMapping("/createIndexES")
	@ApiOperation("创建索引")
	public Object createIndexES(@RequestParam("index") String index) {
		CreateIndexRequest createIndexRequest = new CreateIndexRequest(index);
		CreateIndexResponse response =  null;
		try {
			response = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return response;
	}



	
	@GetMapping("/dropIndexES")
	@ApiOperation("删除索引")
	public Object dropIndexES(@RequestParam("index") String ...index) {
		DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(index);
		AcknowledgedResponse response =  null;
		try {
			response = restHighLevelClient.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return response;
	}
	
	
	@GetMapping("/deleteIndex/{index}/{id}")
	@ApiOperation("根据索引以及id删除内容")
	public Object deleteIndex(@PathVariable("index") String index,@PathVariable("id") String id) {
		DeleteRequest deleteRequest = new DeleteRequest(index, id);
		DeleteResponse response =  null;
		try {
			response = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return response;
	}
	
	
	
	@PostMapping("/insertIndex")
	@ApiOperation("创建索引内容")
	public Object insertIndex(@RequestParam("index") String index,@RequestBody Map map) {
		IndexRequest indexRequest = new IndexRequest(index.toLowerCase());//创建索引
		indexRequest.timeout(Timevalue.timevalueSeconds(10));//设置超时时间
		indexRequest.source(map,XContentType.JSON);
		IndexResponse response =  null;
		try {
			response = restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return response;
	}
	
	
	@GetMapping("/searchES")
    @ApiOperation("查询es内容--分页")
	public Object searchES(@RequestParam("index") String index,
			               @RequestParam("text") String text,
			               @RequestParam(name = "pageNum",defaultValue = "1") Integer pageNum,
			               @RequestParam(name = "pageSize",defaultValue = "10") Integer pageSize) {
		SearchRequest searchRequest = new SearchRequest(index);
		SearchResponse response = null;
		MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("like", text);
		SearchSourceBuilder builder = new SearchSourceBuilder();
		builder.query(matchQuery);//查询条件
		HighlightBuilder highlightBuilder = new HighlightBuilder();
		highlightBuilder.preTags("").postTags("").field("like");
		builder.highlighter(highlightBuilder);
		builder.from(pageNum);//页数
		builder.size(pageSize);//每页条数
		searchRequest.source(builder);
		try {
			response = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		SearchHits searchHits = response.getHits();
		return searchHits;
	}
	
	
	@PostMapping("/updateES/{index}/{id}")
	@ApiOperation("根据索引以及id修改es内容")
	public Object updateES(@RequestBody Map map,
							@PathVariable("index")String index,
							@PathVariable("id")String id) {
		UpdateRequest request = new UpdateRequest(index, id);
		request.doc(map,XContentType.JSON);
		UpdateResponse response = null;
		try {
			response = restHighLevelClient.update(request, RequestOptions.DEFAULT);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return response;
	}
	
	@PostMapping("/bulkSavaES/{index}")
	@ApiOperation("批量添加es内容")
	public Object bulkSavaES(@PathVariable("index") String index,@RequestBody List