![ElasticSearch[02]ElasticSearchJavaAPI](http://www.mshxw.com/aiimages/31/650174.png "ElasticSearch[02]ElasticSearchJavaAPI")
参考视频
【狂神说Java】ElasticSearch7.6.x最新完整教程通俗易懂 P13.
【狂神说Java】ElasticSearch7.6.x最新完整教程通俗易懂 P14.
环境准备| 软件 | 版本 |
|---|---|
| ElasticSearch | 7.8.1 |
| IDEA | 2021.2 |
| ElasticSearch Head | 0.1.5 |
创建普通maven项目
pom.xml添加依赖
log4j2.xmlorg.projectlombok lombok 1.18.22 com.alibaba fastjson 1.2.75 junit junit 4.13.1 compile org.elasticsearch.client elasticsearch-rest-high-level-client 7.8.1 org.apache.logging.log4j log4j-core 2.13.3 org.apache.logging.log4j log4j-api 2.13.3
resources配置log4j2.xml
ElasticSearchClientConfig.java
编写ElasticSearchClient配置类
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
public class ElasticSearchClientConfig {
public static RestHighLevelClient getRestHighLevelClient(){
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("127.0.0.1", 9200, "http"))
);
return client;
}
}
user.java
编写pojo实体类
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
private String name;
private int age;
}
APITest.java
创建测试类编写测试方法
import com.alibaba.fastjson.JSON;
import com.elasticsearch.api.config.ElasticSearchClientConfig;
import com.elasticsearch.api.pojo.User;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteRequest;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.support.master.AcknowledgedResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.client.indices.GetIndexRequest;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.common.unit.Timevalue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Map;
import java.util.concurrent.TimeUnit;
public class APITest {
RestHighLevelClient client;
@Before
public void before() {
client=ElasticSearchClientConfig.getRestHighLevelClient();
}
}
ElasticSearch Java API测试
创建索引
//创建索引
@Test
public void testCreateIndex() throws IOException {
//创建索引请求
CreateIndexRequest request = new CreateIndexRequest("user_index");
//执行创建请求
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
//打印运行结果
System.out.println(createIndexResponse.isAcknowledged());
}
true获取索引
//获取索引
@Test
public void testExistIndex() throws IOException {
GetIndexRequest request = new GetIndexRequest("user_index");
boolean exists = client.indices().exists(request, RequestOptions.DEFAULT);
System.out.println(exists);
}
true删除索引
//删除索引
@Test
public void testDeleteIndex() throws IOException {
DeleteIndexRequest request = new DeleteIndexRequest("user_index");
AcknowledgedResponse delete = client.indices().delete(request, RequestOptions.DEFAULT);
System.out.println(delete.isAcknowledged());
}
true添加数据到测试文档
//添加数据到测试文档
@Test
public void testAdddocument() throws IOException {
//创建对象
User user = new User("aa", 12);
//创建请求
IndexRequest request = new IndexRequest("user_index");
//规则 put /user_index/_doc/1
request.id("1");//若不设置id则生成随机id
//响应时间
//request.timeout(Timevalue.timevalueSeconds(1));
request.timeout("1s");
//将数据放入请求
request.source(JSON.toJSONString(user), XContentType.JSON);
//客户端发送请求，获取响应结果
IndexResponse indexResponse = client.index(request, RequestOptions.DEFAULT);
System.out.println(indexResponse.toString());
System.out.println(indexResponse.status());//对应命令返回状态
}
IndexResponse[index=user_index,type=_doc,id=1,version=1,result=created,seqNo=0,primaryTerm=1,shards={"total":2,"successful":1,"failed":0}]
CREATED
文档主键查询
//文档主键查询
//获取测试文档，判断是否存在 get /index/doc/1
@Test
public void testExists() throws Exception {
GetRequest user_index = new GetRequest("user_index", "1");
//不获取返回的_source 的上下文
user_index.fetchSourceContext(new FetchSourceContext(false));
user_index.storedFields("_none_");
boolean exists = client.exists(user_index, RequestOptions.DEFAULT);
System.out.println(exists);
}
true获得文档信息
//获得文档信息
@Test
public void testGetdocuments() throws Exception {
GetRequest user_index = new GetRequest("user_index", "1");
GetResponse getResponse = client.get(user_index, RequestOptions.DEFAULT);
System.out.println(getResponse.getSourceAsString());//打印文档的内容
System.out.println(getResponse);
}
{"age":12,"name":"aa"}
{"_index":"user_index","_type":"_doc","_id":"1","_version":1,"_seq_no":0,"_primary_term":1,"found":true,"_source":{"age":12,"name":"aa"}}
更新文档信息
//更新文档信息
@Test
public void testUpdatedocuments() throws Exception {
UpdateRequest updateRequest = new UpdateRequest("user_index", "1");
updateRequest.timeout("1s");
User bb = new User("bb", 18);
updateRequest.doc(JSON.toJSONString(bb), XContentType.JSON);
UpdateResponse updateResponse = client.update(updateRequest, RequestOptions.DEFAULT);
System.out.println(updateResponse);
System.out.println(updateResponse.status());
}
UpdateResponse[index=user_index,type=_doc,id=1,version=2,seqNo=1,primaryTerm=1,result=updated,shards=ShardInfo{total=2, successful=1, failures=[]}]
OK
删除文档记录
//删除文档记录
@Test
public void testDeletedocuments() throws Exception {
DeleteRequest deleteRequest = new DeleteRequest("user_index", "1");
deleteRequest.timeout("1s");
DeleteResponse deleteResponse = client.delete(deleteRequest, RequestOptions.DEFAULT);
System.out.println(deleteResponse);
System.out.println(deleteResponse.status());
}
DeleteResponse[index=user_index,type=_doc,id=1,version=3,result=deleted,shards=ShardInfo{total=2, successful=1, failures=[]}]
OK
批量添加数据到测试文档
//批量添加数据到测试文档
@Test
public void testBulkRequest() throws Exception {
BulkRequest bulkRequest = new BulkRequest();
bulkRequest.timeout("1s");
ArrayList userList = new ArrayList<>();
userList.add(new User("aa", 11));
userList.add(new User("bb", 12));
userList.add(new User("cc", 13));
userList.add(new User("dd", 14));
userList.add(new User("ee", 15));
int i = 1;
for (User user : userList) {
//批量更新和批量删除 处理请求
bulkRequest.add(
new IndexRequest("user_index")
.id(i + "")
.source(JSON.toJSONString(user), XContentType.JSON)
);
i++;
}
BulkResponse bulkResponse = client.bulk(bulkRequest, RequestOptions.DEFAULT);
System.out.println(bulkResponse.hasFailures());//是否失败 false代表成功
}
false文档条件查询（高亮、分页）
多添加几条name=aa的数据用于测试
//文档条件查询
@Test
public void testSearch() throws Exception {
//文档条件查询
@Test
public void testSearch() throws Exception {
SearchRequest searchRequest = new SearchRequest("user_index");
//构建搜索条件
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
// MatchAllQueryBuilder termQueryBuilder = QueryBuilders.matchAllQuery();//matchAll匹配所有
//查询条件可以使用QueryBuilders工具类实现
TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "aa");//term精确匹配
sourceBuilder.query(termQueryBuilder);
//设置高亮
HighlightBuilder highlightBuilder = new HighlightBuilder();
highlightBuilder
.field("name")//高亮字段
.requireFieldMatch(false)//是否每个字都高亮
.preTags("")//高亮前缀
.postTags("");//高亮后缀
sourceBuilder.highlighter(highlightBuilder);
sourceBuilder.from();//页码
sourceBuilder.size();//每页条数
sourceBuilder.timeout(new Timevalue(60, TimeUnit.SECONDS));
searchRequest.source(sourceBuilder);
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
System.out.println(JSON.toJSONString(searchResponse.getHits()));
System.out.println("*******打印文档内容*********");
for (SearchHit documentFields : searchResponse.getHits().getHits()) {
System.out.println(documentFields.getSourceAsMap());
}
System.out.println("********内容高亮显示********");
for (SearchHit documentFields : searchResponse.getHits().getHits()) {
Map highlightFields = documentFields.getHighlightFields();
HighlightField name = highlightFields.get("name");
Map sourceAsMap = documentFields.getSourceAsMap();
if (name != null) {
Text[] fragments = name.fragments();
String newTitle = "";
for (Text text : fragments) {
newTitle += text;
}
sourceAsMap.put("name", newTitle);
}
System.out.println(sourceAsMap);
}
}
{"fragment":true,"hits":[{"fields":{},"fragment":false,"highlightFields":{"name":{"fragment":true,"fragments":[{"fragment":true}],"name":"name"}},"id":"1","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.7985077,"seqNo":-2,"sortValues":[],"sourceAsMap":{"name":"aa","age":11},"sourceAsString":"{"age":11,"name":"aa"}","sourceRef":{"fragment":true},"type":"_doc","version":-1},{"fields":{},"fragment":false,"highlightFields":{"name":{"fragment":true,"fragments":[{"fragment":true}],"name":"name"}},"id":"GI1_mH0BKTXNK4J9Fszy","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.7985077,"seqNo":-2,"sortValues":[],"sourceAsMap":{"name":"aa","age":13},"sourceAsString":"{"age":13,"name":"aa"}","sourceRef":{"fragment":true},"type":"_doc","version":-1},{"fields":{},"fragment":false,"highlightFields":{"name":{"fragment":true,"fragments":[{"fragment":true}],"name":"name"}},"id":"GY1_mH0BKTXNK4J9Qsxb","matchedQueries":[],"primaryTerm":0,"rawSortValues":[],"score":0.7985077,"seqNo":-2,"sortValues":[],"sourceAsMap":{"name":"aa","age":15},"sourceAsString":"{"age":15,"name":"aa"}","sourceRef":{"fragment":true},"type":"_doc","version":-1}],"maxScore":0.7985077,"totalHits":{"relation":"EQUAL_TO","value":3}}
*******打印文档内容*********
{name=aa, age=11}
{name=aa, age=13}
{name=aa, age=15}
********内容高亮显示********
{name=aa, age=11}
{name=aa, age=13}
{name=aa, age=15}
