ElactisSearch7

	@Test
	void addData() throws IOException {
		//创建对象
		User user = new User("小也", 20);

		//获取索引对象
		IndexRequest request = new IndexRequest("xiaoye");

		//设置记录唯一标识已经超时时间
		request.id("1");
		request.timeout("1s");

	      //把我们的对象记录以JSON格式放入请求中，es是以json格式存储记录的
	      request.source(JSON.toJSONString(user), XContentType.JSON);

		//发送请求，获得返回值
		IndexResponse response = client.index(request, RequestOptions.DEFAULT);

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

	@Test
	void batchDate() throws IOException {
		//批量操作整合对象
		BulkRequest request = new BulkRequest();
		for (int i = 0; i < 10; i++) {
			User user = new User("贾维斯" + i + "号", i);
			request.add(new IndexRequest("xiaoye").id(String.valueOf(i)).source(JSON.toJSONString(user),XContentType.JSON));
		}
		BulkResponse response = client.bulk(request, RequestOptions.DEFAULT);
		//返回操作是否失败，返回false代表操作成功
		System.out.println(response.hasFailures());
	}

	@Test
	void getDate() throws IOException {
		GetRequest request = new GetRequest("xiaoye", "1");
		GetResponse response = client.get(request,RequestOptions.DEFAULT);
		System.out.println(response.getSource().toString());
	}

	@Test
	void complexSearch() throws IOException {
		SearchRequest index = new SearchRequest("xiaoye");

		//构造整合者
		SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

		//条件查询构造
		MatchQueryBuilder matchAllQueryBuilder = QueryBuilders.matchQuery("name", "贾维斯");
		searchSourceBuilder.query(matchAllQueryBuilder);
//		TermQueryBuilder termQuery = QueryBuilders.termQuery("name", "贾维斯1号");
//		searchSourceBuilder.query(termQuery);

		//构造高亮，字段为name
		HighlightBuilder highlightBuilder = new HighlightBuilder();
		highlightBuilder.field("name");
		searchSourceBuilder.highlighter(highlightBuilder);

		//构造整合者放入请求中
		index.source(searchSourceBuilder);

		SearchResponse response = client.search(index, RequestOptions.DEFAULT);

		System.out.println(JSON.toJSONString(response.getHits()));

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

		for (SearchHit hit : response.getHits().getHits()) {
			System.out.println(hit.getSourceAsString());

			// 打印出高亮片段
			HighlightField highlightField = hit.getHighlightFields().get("name");
			for (Text fragment : highlightField.getFragments()) {
				System.out.println(fragment.toString());
			}
		}
	}