青岛公司建设网站,建站合同模板,手机怎么安装网站程序,小型的电商网站有哪些文章目录 三、RestClient操作索引库与文档3.1 操作索引库3.2 操作文档结束语 三、RestClient操作索引库与文档
ES官方提供了各种不同语言的客户端#xff0c;用来操作ES。这些客户端的本质就是组装DSL语句#xff0c;通过http请求发送给ES。
官方文档地址: https://www.ela… 文章目录 三、RestClient操作索引库与文档3.1 操作索引库3.2 操作文档结束语 三、RestClient操作索引库与文档
ES官方提供了各种不同语言的客户端用来操作ES。这些客户端的本质就是组装DSL语句通过http请求发送给ES。
官方文档地址: https://www.elastic.co/guide/en/elasticsearch/client/index.html
数据库文件视频里展示的数据库表可以使用自己有的其他数据替代不一定非要一致。
自己手敲了个工程项目包含SQL文件测试RestClient项目文件
3.1 操作索引库
设计数据表对应的mappings
PUT /movie
{mappings: {properties: {all:{type: text,analyzer: ik_max_word},movieId:{type: keyword},movieTitle:{type: text,analyzer: ik_max_word, copy_to: all},movieIntroduction:{type: text,analyzer: ik_max_word, copy_to: all},movieRating:{type: float},movieReleaseDate:{type: keyword, copy_to: all}}}
}引入依赖
propertiesjava.version1.8/java.versionelasticsearch.version7.12.1/elasticsearch.versionmybatis-plus-boot.version3.4.2/mybatis-plus-boot.version
/propertiesdependencygroupIdorg.elasticsearch.client/groupIdartifactIdelasticsearch-rest-high-level-client/artifactIdversion7.12.1/version
/dependency初始化
public class MovieIndexTest {private RestHighLevelClient client;Testvoid testInit(){System.out.println(client);}BeforeEachvoid setUp(){this.client new RestHighLevelClient(RestClient.builder(HttpHost.create(http://10.120.54.174:9200)));}AfterEachvoid close() throws IOException {this.client.close();}
}创建movie索引CREATE_MOVIE 为上面的 mappings
public class MovieIndexTest {// ...........Testvoid testCreateMovieIndex() throws IOException {// 创建RequestCreateIndexRequest request new CreateIndexRequest(movie);// 准备请求数据request.source(CREATE_MOVIE, XContentType.JSON);// 发送请求client.indices().create(request, RequestOptions.DEFAULT);}// ...........
}删除、获取判断是否存在
public class MovieIndexTest {Testvoid testDelete() throws IOException {DeleteIndexRequest deleteIndexRequest new DeleteIndexRequest(movie);client.indices().delete(deleteIndexRequest,RequestOptions.DEFAULT);}Testvoid testExists() throws IOException {GetIndexRequest getIndexRequest new GetIndexRequest(movie);boolean exists client.indices().exists(getIndexRequest, RequestOptions.DEFAULT);System.out.println(exists);}Testvoid testGet() throws IOException {GetIndexRequest getIndexRequest new GetIndexRequest(movie);GetIndexResponse getIndexResponse client.indices().get(getIndexRequest, RequestOptions.DEFAULT);System.out.println(getIndexResponse);}
}3.2 操作文档
【TODO】
结束语
上一篇二、ElasticSearch中索引库与文档操作
