学习 Elasticsearch 的相关使用(二）

GET_analyze{
"analyzer": "ik_smart",
"text": "蜘蛛侠"}
GET_analyze{
"analyzer": "ik_max_word",
"text": "蜘蛛侠"}

//创建索引@TestvoidcreateIndex() throwsIOException {
CreateIndexRequestrequest=newCreateIndexRequest("spring_test");
CreateIndexResponsecreateIndexResponse=client.indices().create(request, RequestOptions.DEFAULT);
System.out.println(createIndexResponse);
}

//判断索引是否存在，存在返回 true,不存在 false@TestvoidisExistIndex() throwsIOException {
GetIndexRequestrequest=newGetIndexRequest("spring_test");
booleanexists=client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}

//删除索引，删除成功，response.isAcknowledged()=true,否则为 false@TestvoiddeleteIndex() throwsIOException {
DeleteIndexRequestrequest=newDeleteIndexRequest("spring_test");
AcknowledgedResponseresponse=client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(response.isAcknowledged());
}

//测试添加文档（User 对象）@TestvoidaddDoc() throwsIOException {
//创建对象Useruser=newUser("Jie", 20);
//创建请求IndexRequestrequest=newIndexRequest("spring_test");
//创建规则request.id("1");
request.timeout(TimeValue.timeValueSeconds(1));
//将数据 json 格式放入请求request.source(JSON.toJSONString(user), XContentType.JSON);
//客户端发送请求，获取响应的结果IndexResponseresponse=client.index(request, RequestOptions.DEFAULT);
System.out.println(response);
System.out.println(response.status());
}

//判断文档是否存在 get /index/doc/1@TestvoidisExistsDoc() throwsIOException {
//获取 GetRequest 请求，构造重载 index,type,idGetRequestrequest=newGetRequest("spring_test","1");
//不获取返回的 _source 的上下文request.fetchSourceContext(newFetchSourceContext(false));
request.storedFields("_none_");
booleanexists=client.exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}

@TestvoidgetDoc() throwsIOException {
//获取 GetRequest 请求，构造重载 index,type,idGetRequestrequest=newGetRequest("spring_test","1");
GetResponseresponse=client.get(request, RequestOptions.DEFAULT);
//将文档内容作为字符串输出System.out.println(response.getSourceAsString());
//响应信息是与命令是一样的System.out.println(response);
}

//更新文档信息@TestvoidupdateDoc() throwsIOException {
//获取 GetRequest 请求，构造重载 index,type,idUpdateRequestrequest=newUpdateRequest("spring_test","1");
request.timeout("1s");
//创建对象Useruser=newUser("I'm Jie", 22);
//将对象封装为 JSON 类型request.doc(JSON.toJSONString(user),XContentType.JSON);
UpdateResponseresponse=client.update(request, RequestOptions.DEFAULT);
System.out.println(response);
System.out.println(response.status());
}

//删除文档信息@TestvoiddelDoc() throwsIOException {
//获取 GetRequest 请求，构造重载 index,type,idDeleteRequestrequest=newDeleteRequest("spring_test","1");
request.timeout("1s");
DeleteResponseresponse=client.delete(request, RequestOptions.DEFAULT);
System.out.println(response);
System.out.println(response.status());
}

//批量添加文档信息@TestvoidbulkRequest() throwsIOException {
BulkRequestrequest=newBulkRequest();
request.timeout("10s");
//准备数据ArrayList<User>users=newArrayList<>();
users.add(newUser("test1",2));
users.add(newUser("test2",3));
users.add(newUser("test3",2));
users.add(newUser("test4",5));
users.add(newUser("test5",2));
//批处理请求for (inti=0; i<users.size(); i++) {
request.add(
newIndexRequest("spring_test")
            .id((i+1)+"")   //不设置 id，默认随机 id            .source(JSON.toJSONString(users.get(i)),XContentType.JSON));
    }
//提交请求BulkResponseresponse=client.bulk(request, RequestOptions.DEFAULT);
System.out.println(response);
System.out.println(response.status());
}

//查询//SearchRequest 搜索请求//SearchSourceBuilder 条件构造//使用 QueryBuilders 创造条件//HighlightBuilder 构建高亮//TermQueryBuilder 精确查询//MatchAllQueryBuilder 匹配所有@Testvoidsearch() throwsIOException {
//请求SearchRequestsearch=newSearchRequest("spring_test");
//构建搜索条件SearchSourceBuildersourceBuilder=newSearchSourceBuilder();
/*查询条件，可以使用 QueryBuilders 工具类实现*/TermQueryBuildertermQueryBuilder=QueryBuilders.termQuery("age", 2);
sourceBuilder.query(termQueryBuilder);
//设置时间sourceBuilder.timeout(newTimeValue(60, TimeUnit.SECONDS));
search.source(sourceBuilder);
SearchResponseresponse=client.search(search, RequestOptions.DEFAULT);
System.out.println(response);
System.out.println(JSON.toJSONString(response.getHits()));
System.out.println("===============================");
for (SearchHithit : response.getHits().getHits()) {
System.out.println(hit.getSourceAsMap());
    }
}

//高亮字段@TestvoidhighLight() throwsIOException {
//请求SearchRequestsearch=newSearchRequest("spring_test");
//构建搜索条件SearchSourceBuildersourceBuilder=newSearchSourceBuilder();
TermQueryBuildertermQueryBuilder=QueryBuilders.termQuery("name", "test1");
sourceBuilder.query(termQueryBuilder);
sourceBuilder.timeout(newTimeValue(60, TimeUnit.SECONDS));
//高亮HighlightBuilderhighlightBuilder=newHighlightBuilder();
highlightBuilder.field("name");                     //设置高亮字段highlightBuilder.requireFieldMatch(false);          //取消多个高亮highlightBuilder.preTags("<font color='red'>");     //前缀highlightBuilder.postTags("</font>");               //后缀sourceBuilder.highlighter(highlightBuilder);
//执行搜索search.source(sourceBuilder);
SearchResponseresponse=client.search(search, RequestOptions.DEFAULT);
//解析结果ArrayList<Map<String,Object>>list=newArrayList<>();
for (SearchHithit : response.getHits().getHits()) {
Map<String, HighlightField>highlightFields=hit.getHighlightFields();
HighlightFieldname=highlightFields.get("name");
//获取原理的结果Map<String, Object>sourceAsMap=hit.getSourceAsMap();
// 将高亮字段替换掉原来的字段if(name!=null){
Text[] texts=name.getFragments();
Stringn_name="";
for (Texttext : texts) {
n_name+=text;
            }
sourceAsMap.put("name",n_name);
        }
list.add(sourceAsMap);
    }
}