Elasticsearch简单学习

光之使者  金牌会员 | 昨天 13:21 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 871|帖子 871|积分 2613

1、依赖的导入

  1. <!--ES依赖-->
  2. <dependency>
  3.     <groupId>org.elasticsearch.client</groupId>
  4.     <artifactId>elasticsearch-rest-high-level-client</artifactId>
  5. </dependency>
复制代码
2、客户端链接

  1. RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(HttpHost.create("http://localhost:9200")));
复制代码
3、索引库的相关操作

1、索引库的创建

  1. @Test
  2. void createTestIndex() throws IOException {
  3.     /*创建索引库*/
  4.     //1.创建Request对象，索引库名称必须为小写字母
  5.     CreateIndexRequest request = new CreateIndexRequest("test_index");
  7.     String source = "{\n" +
  8.         "        "mappings":{\n" +
  9.         "        "properties":{\n" +
  10.         "            "id":{\n" +
  11.         "                "type":"integer"\n" +
  12.         "            },\n" +
  13.         "            "name":{\n" +
  14.         "                "type":"text",\n" +
  15.         "                "analyzer":"ik_max_word"\n" +
  16.         "            },\n" +
  17.         "            "age":{\n" +
  18.         "                "type":"integer"\n" +
  19.         "            },\n" +
  20.         "            "sex":{\n" +
  21.         "                "type":"keyword"\n" +
  22.         "            },\n" +
  23.         "            "bossId":{\n" +
  24.         "                "type":"integer"\n" +
  25.         "            },\n" +
  26.         "            "departmentId":{\n" +
  27.         "                "type":"integer"\n" +
  28.         "            }\n" +
  29.         "        }\n" +
  30.         "    }\n" +
  31.         "}";
  33.     //2.准备请求的参数：DSL语句
  34.     request.source(source, XContentType.JSON);
  36.     //3.发请求
  37.     client.indices().create(request, RequestOptions.DEFAULT);
  38. }
复制代码
2、判定索引库是否存在

  1. @Test
  2. void existsTestIndex() throws IOException {
  3.     /*判断索引库是否存在*/
  4.     //1.创建Request对象，名称必须为小写字母
  5.     GetIndexRequest request = new GetIndexRequest("test_index");
  7.     //2.发请求
  8.     boolean is = client.indices().exists(request, RequestOptions.DEFAULT);
  9.     System.out.println(is);
  10. }
复制代码
3、删除索引库

  1. @Test
  2. void deleteTestIndex() throws IOException {
  3.     /*删除索引库*/
  4.     //1.创建Request对象，名称必须为小写字母
  5.     DeleteIndexRequest request = new DeleteIndexRequest("test_index");
  7.     //2.发请求
  8.     client.indices().delete(request, RequestOptions.DEFAULT);
  9. }
复制代码
4、文档的操作

1、创建文档

  1. @Test
  2. void createDocTest() throws IOException {
  3.     //从数据库中获取数据对象
  4.     Employee employee = employeeMapper.selectAllById(1);
  6.     //1. 创建Request对象
  7.     IndexRequest request = new IndexRequest("test_index").id(employee.getId().toString());
  9.     //2.准备json文档
  10.     String source = JSON.toJSONString(employee);
  11.     //2.1准备json文档
  12.     request.source(source, XContentType.JSON);
  14.     //3.发请求
  15.     client.index(request, RequestOptions.DEFAULT);
  16. }
复制代码
2、获取指定的文档

  1. @Test
  2. void getDocTest() throws IOException {
  3.     //1.创建Request对象
  4.     GetRequest request = new GetRequest("test_index","1");
  5.     //2.发请求，得到结果
  6.     GetResponse response = client.get(request, RequestOptions.DEFAULT);
  7.     //3.解析结果
  8.     String json = response.getSourceAsString();
  9.     System.out.println(json);
  10.     Employee employee = JSON.parseObject(json, Employee.class);
  11.     System.out.println(employee);
  12. }
复制代码
3、更新文档

  1. @Test
  2. void updateDocTest() throws IOException {
  3.     //1.创建Request对象
  4.     UpdateRequest request = new UpdateRequest("test_index","1");
  6.     //2.准备DSL语句
  7.     request.doc(
  8.         "age",18
  9.     );
  11.     //3.发请求
  12.     client.update(request,RequestOptions.DEFAULT);
  13. }
复制代码
4、删除文档

  1. @Test
  2. void deleteDocTest() throws IOException {
  3.     //1.创建Request对象
  4.     DeleteRequest request = new DeleteRequest("test_index","1");
  5.     //2.发请求
  6.     client.delete(request,RequestOptions.DEFAULT);
  7. }
复制代码
5、批量操作（创建）

  1. @Test
  2. void batchCreateDocTest() throws IOException {
  3.     //1.创建Request对象
  4.     BulkRequest request = new BulkRequest();
  6.     //2.准备DSL语句，批量增加文档
  7.     List<Employee> employees = employeeMapper.selectAll();
  8.     for(Employee e : employees){
  9.         request.add(new IndexRequest("test_index")
  10.                     .id(e.getId().toString())
  11.                     .source(JSON.toJSONString(e),XContentType.JSON));
  12.     }
  14.     //3.发请求
  15.     client.bulk(request,RequestOptions.DEFAULT);
  16. }
复制代码
5、搜索文档

1、分词查询-查询全部

  1. @Test
  2. void matchAllTest() throws IOException {  //分词查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2.组织DSL参数
  7.     request.source() // 查询全部
  8.         .query(QueryBuilders.matchAllQuery());
  10.     //3.发送请求
  11.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  13.     //4.解析结果
  14.     SearchHits searchHits = response.getHits();
  16.     //4.1获取总条数
  17.     long total = searchHits.getTotalHits().value;
  18.     System.out.println("总共有：" + total + "条数据");
  20.     //4.2获取文档数组
  21.     SearchHit[] hits = searchHits.getHits();
  23.     //4.3遍历数组
  24.     for(SearchHit h : hits){
  25.         String json = h.getSourceAsString();
  26.         Employee employee = JSON.parseObject(json, Employee.class);
  27.         System.out.println(employee);
  28.     }
  29. }
复制代码
2、分词查询-指定字段

  1. @Test
  2. void matchQueryTest() throws IOException { //分词查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2.组织DSL参数
  7.     request.source() //查询指定字段的值，也可以指定多个字段 .multiMatchQuery()
  8.         .query(QueryBuilders.matchQuery("name","晨"));
  10.     //3.发送请求
  11.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  13.     //4.解析结果
  14.     SearchHits searchHits = response.getHits();
  16.     //4.1获取总条数
  17.     long total = searchHits.getTotalHits().value;
  18.     System.out.println("总共有：" + total + "条数据");
  20.     //4.2获取文档数组
  21.     SearchHit[] hits = searchHits.getHits();
  23.     //4.3遍历数组
  24.     for(SearchHit h : hits){
  25.         String json = h.getSourceAsString();
  26.         Employee employee = JSON.parseObject(json, Employee.class);
  27.         System.out.println(employee);
  28.     }
  29. }
复制代码
3、精确查询

  1. @Test
  2. void termQueryTest() throws IOException {  //精确查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2.组织DSL参数
  7.     request.source() //精确查询只能查询 非text（分词字段），如果查询分词字段，则自动采用模糊分词查询
  8.         .query(QueryBuilders.termQuery("age","33"));
  10.     //3.发送请求
  11.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  13.     //4.解析结果
  14.     SearchHits searchHits = response.getHits();
  16.     //4.1获取总条数
  17.     long total = searchHits.getTotalHits().value;
  18.     System.out.println("总共有：" + total + "条数据");
  20.     //4.2获取文档数组
  21.     SearchHit[] hits = searchHits.getHits();
  23.     //4.3遍历数组
  24.     for(SearchHit h : hits){
  25.         String json = h.getSourceAsString();
  26.         Employee employee = JSON.parseObject(json, Employee.class);
  27.         System.out.println(employee);
  28.     }
  29. }
复制代码
4、范围查询

  1. @Test
  2. void rangeQueryTest() throws IOException {  //范围查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2.组织DSL参数
  7.     request.source() //范围查询，gte：大于等于，lte：小于等于，gt：大于，lt：小于
  8.         .query(QueryBuilders.rangeQuery("age").gte(30).lte(35));
  10.     //3.发送请求
  11.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  13.     //4.解析结果
  14.     SearchHits searchHits = response.getHits();
  16.     //4.1获取总条数
  17.     long total = searchHits.getTotalHits().value;
  18.     System.out.println("总共有：" + total + "条数据");
  20.     //4.2获取文档数组
  21.     SearchHit[] hits = searchHits.getHits();
  23.     //4.3遍历数组
  24.     for(SearchHit h : hits){
  25.         String json = h.getSourceAsString();
  26.         Employee employee = JSON.parseObject(json, Employee.class);
  27.         System.out.println(employee);
  28.     }
  29. }
复制代码
5、复合查询

  1. @Test
  2. void boolQueryTest() throws IOException {  //复合查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2.1创建复合查询对象
  7.     BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
  9.     //2.2添加查询条件
  10.     boolQuery.must(QueryBuilders.matchQuery("name","雨"));
  11.     boolQuery.filter(QueryBuilders.rangeQuery("age").gte(20).lte(35));
  13.     //2.3组织DSL参数
  14.     request.source()
  15.         .query(boolQuery);
  17.     //3.发送请求
  18.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  20.     //4.解析结果
  21.     SearchHits searchHits = response.getHits();
  23.     //4.1获取总条数
  24.     long total = searchHits.getTotalHits().value;
  25.     System.out.println("总共有：" + total + "条数据");
  27.     //4.2获取文档数组
  28.     SearchHit[] hits = searchHits.getHits();
  30.     //4.3遍历数组
  31.     for(SearchHit h : hits){
  32.         String json = h.getSourceAsString();
  33.         Employee employee = JSON.parseObject(json, Employee.class);
  34.         System.out.println(employee);
  35.     }
  36. }
复制代码
6、分页排序查询

  1. @Test
  2. void pageSortQueryTest() throws IOException {  //分页、排序查询
  3.     // 页码，每页大小
  4.     int page = 3,size = 10;
  6.     //1.准备Request
  7.     SearchRequest request = new SearchRequest("test_index");
  9.     //2组织DSL参数
  10.     request.source()
  11.         .from((page-1)*size) // 包含form，(page-1)*size，是前端传过来的页码和每页条数
  12.         .size(size)
  13.         .sort("id", SortOrder.ASC)
  14.         .query(QueryBuilders.matchAllQuery());
  16.     //3.发送请求
  17.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  19.     //4.解析结果
  20.     SearchHits searchHits = response.getHits();
  22.     //4.1获取总条数
  23.     long total = searchHits.getTotalHits().value;
  24.     System.out.println("总共有：" + total + "条数据");
  26.     //4.2获取文档数组
  27.     SearchHit[] hits = searchHits.getHits();
  29.     //4.3遍历数组
  30.     for(SearchHit h : hits){
  31.         String json = h.getSourceAsString();
  32.         Employee employee = JSON.parseObject(json, Employee.class);
  33.         System.out.println(employee);
  34.     }
  35. }
复制代码
6、高亮查询

  1. @Test
  2. void highLightQueryTest() throws IOException {  //高亮查询
  3.     //1.准备Request
  4.     SearchRequest request = new SearchRequest("test_index");
  6.     //2组织DSL参数
  7.     request.source()
  8.         .highlighter(new HighlightBuilder() //高亮显示
  9.                      .field("name") //字段名
  10.                      .requireFieldMatch(false) // 是否与查询字段匹配
  11.                     ) // 用的默认标签 <em></em>
  12.         .query(QueryBuilders.matchQuery("name","晨"));
  14.     //3.发送请求
  15.     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
  17.     //4.解析结果
  18.     SearchHits searchHits = response.getHits();
  20.     //4.1获取总条数
  21.     long total = searchHits.getTotalHits().value;
  22.     System.out.println("总共有：" + total + "条数据");
  24.     //4.2获取文档数组
  25.     SearchHit[] hits = searchHits.getHits();
  27.     //4.3遍历数组
  28.     for(SearchHit h : hits){
  29.         String json = h.getSourceAsString();
  30.         Employee employee = JSON.parseObject(json, Employee.class);
  32.         // 高亮显示，因为每条数据都是带有 晨 的，所以每条数据都有一个HighlightField用于替换
  33.         HighlightField name = h.getHighlightFields().get("name");
  35.         //替换
  36.         employee.setName(name.getFragments()[0].toString());
  38.         System.out.println(employee);
  39.     }
  40. }
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

光之使者

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

存储 挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表