目录
一、案例分析
二、Java代码中操作文档
2.1 初始化JavaRestClient
2.2 添加数据到索引库
2.3 根据id查询数据
2.4 根据id修改数据
2.4 删除操作
三、java代码对文档进行操作的基本步骤
一、案例分析
去数据库查询酒店数据,导入到hotel索引库,实现酒店数据的CRUD基本步骤如下
- 初始化JavaRestClient
- 利用JavaRestClient新增酒店数据
- 利用JavaRestClient根据id查询酒店数据
- 利用javaRestClient删除酒店数据5.利用JavaRestClient修改酒店数据
二、Java代码中操作文档
2.1 初始化JavaRestClient
新建一个测试类,实现文档相关操作,并且完成JavaRestClient的初始化
public class ElasticsearchDocumentTest {//客户端private RestHighLevelclient client;@BeforeEachvoid setUp(){client = new RestHighLevelclient(RestClient.builder(HttpHost.create("http://192.168.15.101:9200")));}@AfterEachvoid tearDown() throws IOException {client.close();}
}
2.2 添加数据到索引库
示例代码
@Test
void testIndexDocument() throws IException {// 1.创建request对象IndexRequest request = new IndexRequest("indexName").id("1");// 2.准备JSON文档request.source("{\"namel": "Jack\","agel": 21}",XContentType.JSON);// 3.发送请求client.index(request, RequestOptions.DEFAULT);
}
先查询mysql数据,然后给这条数据创建倒排索引,完成mysql转换为索引库的数据添加:
(1)创建文档对应实体
(2)根据id查询数据库数据,并转换
2.3 根据id查询数据
根据id查询到的文档数据是json,需要反序列化为java对象
@Test
void testGetDocumentById() throws IOException {// 1.创建request对象GetRequest request = new GetRequest("indexName","1");// 2.发送请求,得到结果GetResponse response = client.get(request, RequestOptions.DEFAULT);// 3.解析结果String json = response.getSourceAsString();System.out.println(json);
}
编写代码
2.4 根据id修改数据
修改文档数据有两种方式
方式一(全量更新):再次写入id一样的文档,就会删除旧文档,添加新文档
方式二(局部更新):只更新部分字段
@Test
void testUpdateDocumentById() throws IOException {// 1.创建request对象UpdateRequest request = new UpdateRequest("indexName","1");//2.准备参数,每2个参数为一对 key valuerequest.doc("age",18,"name","Rose");//3更新文档client.update(request, RequestOptions.DEFAULT);
}
编写代码
2.4 删除操作
@Test
void testDeleteDocument() {// 1.准备RequestDeleteRequest request = new DeleteRequest( index: "hotel", id: "61083");// 2.发送请求client.deletelrequest,RequestOptions.DEFAULT);
}
三、java代码对文档进行操作的基本步骤
- 初始化RestHighLevelClient
- 创建XxxRequest。XXX是Index、Get、Update、Delete
- 准备参数 (Index和Update时需要)
- 发送请求。调用RestHighLevelClient#.xxx()方法,xxx是index、get、update、delete
- 解析结果(Get时需要)