网站怎么做自然优化,川畅科技联系 网站设计,wordpress侧边导航主题,国开网站怎么做目录 12.5 RestClient操作索引库
12.5.1创建库
12.5.2 删除索引库
12.5.3 判断是否存在
12.6 RestClient操作文档
12.6.1 新增文档
12.6.2 查询文档
12.6.3 修改文档
12.6.4 删除文档
12.6.5 批量导入文档 12.5 RestClient操作索引库
酒店mapping映射 PUT /hotel{mappings: {properties: {id: {type: keyword,copy_to: all},name: {type: text,analyzer: ik_max_word},address: {type: keyword,index: false},price: {type: integer},score: {type: integer},brand: {type: keyword,copy_to: all},city: {type: keyword},starName: {type: keyword},business: {type: keyword},location: {type: geo_point},pic: {type: keyword,index: false},all: {type: text,analyzer: ik_max_word}}}}
导入依赖 !--elasticSearch依赖--dependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion7.12.1/version/dependency propertiesjava.version1.8/java.versionelasticsearch.version7.12.1/elasticsearch.version/properties 创建对象 SpringBootTestclass HotelIndexTest {private RestHighLevelClient client;// 客户端初始化BeforeEachvoid setUp(){this.client new RestHighLevelClient(RestClient.builder(HttpHost.create(http://192.168.142.129:9200)));}Testvoid tetsInit(){System.out.println(client);}// 客户端销毁AfterEachvoid tearDown() throws IOException {this.client.close();}}
client.indices()包含了操作索引库的所有方法
12.5.1创建库 Testvoid testCreateHotelIndex() throws IOException {// 1. 创建Request对象CreateIndexRequest request new CreateIndexRequest(hotel);// 2. 准备请求的参数request.source(MAPPING_TEMPLATE,XContentType.JSON);// 3. 发送请求 client.indices()的返回值包含了索引库额所有操作client.indices().create(request,RequestOptions.DEFAULT);}
MAPPING_TEMPLATE是自定义的常量也就是上面创建索引库的语句 12.5.2 删除索引库 Testvoid testDeleteIndex() throws IOException {// 1. 创建request对象DeleteIndexRequest request new DeleteIndexRequest(hotel);// 2. 发送请求client.indices().delete(request,RequestOptions.DEFAULT);}
12.5.3 判断是否存在 Testvoid testExistIndex() throws IOException {// 1. 创建request对象GetIndexRequest request new GetIndexRequest(hotel);// 2. 发送请求boolean exists client.indices().exists(request, RequestOptions.DEFAULT);// 3. 输出System.out.println(exists ? 索引库存在 : 索引库不存在);}
12.6 RestClient操作文档
12.6.1 新增文档 Testvoid testIndexDocument() throws IOException {// 在数据库查到数据Hotel hotel iHotelService.getById(61083L);HotelDoc hotelDoc new HotelDoc(hotel); // 经度 纬度 拼接之后的对象 ,即索引库需要的类型// 1. 创建请求对象IndexRequest request new IndexRequest(hotel).id(hotel.getId().toString());// 2. 准备json文档 把查到的对象转换成json对象request.source(JSON.toJSONString(hotelDoc),XContentType.JSON);// 3. 发送请求client.index(request,RequestOptions.DEFAULT);}
12.6.2 查询文档 Testvoid testGetDocumentById() throws IOException {// 1. 准备requestGetRequest request new GetRequest(hotel, 61083);// 2. 发送请求GetResponse response client.get(request, RequestOptions.DEFAULT);// 3. 从响应中解析对象String json response.getSourceAsString();// 4. 把json转成HotelDoc对象HotelDoc hotelDoc JSON.parseObject(json, HotelDoc.class);System.out.println(hotelDoc);}
12.6.3 修改文档
第二种更新方式即局部更新的代码 : Testvoid testUpdateDocumentById() throws IOException {// 1. 准备RequestUpdateRequest request new UpdateRequest(hotel, 61083);// 2. 准备请求参数request.doc(age, 18,name,Rose);// 3. 发送请求client.update(request,RequestOptions.DEFAULT);}
12.6.4 删除文档 Testvoid testDeleteDocumentById() throws IOException {// 1. 准备requestDeleteRequest request new DeleteRequest(hotel,61083);// 2. 发送请求client.delete(request,RequestOptions.DEFAULT);}
12.6.5 批量导入文档 Testvoid testBulk() throws IOException {// 批量查询酒店数据ListHotel hotels iHotelService.list();// 1. 创建Bulk请求BulkRequest request new BulkRequest();// 2. 准备参数 添加多个新增的requestfor (Hotel hotel : hotels) {// 把hotel转成hotelDoc对象HotelDoc hotelDoc new HotelDoc(hotel);request.add(new IndexRequest(hotel).id(hotelDoc.getId().toString()).source(JSON.toJSONString(hotelDoc),XContentType.JSON));}// 3. 发送请求client.bulk(request,RequestOptions.DEFAULT);}
