辽阳网站开发,ui设计师工作流程,现在哪个网站还做白拿,wordpress能建论坛吗目录
一、案例分析
二、Java代码中操作文档 2.1 初始化JavaRestClient 2.2 添加数据到索引库 2.3 根据id查询数据 2.4 根据id修改数据 2.4 删除操作
三、java代码对文档进行操作的基本步骤 一、案例分析
去数据库查询酒店数据#xff0c;导入到hotel索引库#xff0…目录
一、案例分析
二、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(indexName1);// 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(indexName1);//2.准备参数每2个参数为一对 key valuerequest.doc(age18,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时需要)
