devbox
人工智能uu
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

ElasticSearch-学习笔记04【Java客户端操作索引库】_java 创建elasticsearch索引

作者：人工智能uu | 2024-07-25 21:04:22

赞

踩

java 创建elasticsearch索引
  1. ElasticSearch-学习笔记01【ElasticSearch基本介绍】【day01】
  2. ElasticSearch-学习笔记02【ElasticSearch索引库维护】
  3. ElasticSearch-学习笔记03【ElasticSearch集群】
  4. ElasticSearch-学习笔记04【Java客户端操作索引库】【day02】
  5. ElasticSearch-学习笔记05【SpringDataElasticSearch】

目录

01-ES课程介绍

02-使用Java客户端创建索引库

03-使用Java客户端设置mapping步骤

04-使用java客户端设置mapping映射

05-向索引库中添加文档

06-添加文档的第二种方式

07-索引库查询_根据id查询

 08-索引库查询_根据term查询

09-索引库查询_queryString查询

10-查询分页设置

01、插入数据

02、设置分页

11-查询结果高亮显示

01、查看高亮结果

02、高亮显示代码实现

01-ES课程介绍

学习目标：

  1. 能够使用java客户端完成创建、删除索引的操作

  2. 能够使用java客户端完成文档的增删改的操作

  3. 能够使用java客户端完成文档的查询操作

  4. 能够完成文档的分页操作

  5. 能够完成文档的高亮查询操作

  6. 能够搭建Spring Data ElasticSearch的环境

  7. 能够完成Spring Data ElasticSearch的基本增删改查操作

  8. 能够掌握基本条件查询的方法命名规则

管理ES的客户端工具：postman、head插件。

02-使用Java客户端创建索引库

一、使用Java客户端管理ES
1、创建索引库
    步骤：
    1）创建一个Java工程
    2）添加jar包，添加maven的坐标
    3）编写测试方法实现创建索引库
        1、创建一个Settings对象，相当于是一个配置信息，主要用于配置集群的名称。
        2、创建一个客户端Client对象
        3、使用client对象创建一个索引库
        4、关闭client对象

9201、9202、9203：对外提供http服务的端口号；

9301、9302、9303：tcp形式连接ES服务器(InetSocketTransportAddress方法)。

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.client.transport.TransportClient;
  4. import org.elasticsearch.common.settings.Settings;
  5. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  6. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  7. import org.junit.Test;
  8.  
  9. import java.net.InetAddress;
  10.  
  11. public class ElasticSearchClientTest {
  12.     @Test
  13.     public void createIndex() throws Exception {
  14.         //1、创建一个Settings对象，相当于是一个配置信息，主要配置集群的名称。
  15.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  16.         //2、创建一个客户端Client对象
  17.         TransportClient client = new PreBuiltTransportClient(settings);
  18.         //向client中添加三个ip地址的端口号，防止一个服务器不好使然后出现bug
  19.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301));
  20.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302));
  21.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  22.         //3、使用client对象创建一个索引库
  23.         client.admin().indices().prepareCreate("index_hello").get();//.get()执行操作//index_hello索引名称
  24.         //4、关闭client对象
  25.         client.close();
  26.     }
  27. }

ElasticSearch搭建集群时的闪退问题

03-使用Java客户端设置mapping步骤

 

一、使用Java客户端管理ES
1、创建索引库
    步骤：
    1）创建一个Java工程
    2）添加jar包，添加maven的坐标
    3）编写测试方法实现创建索引库
        1、创建一个Settings对象，相当于是一个配置信息，主要配置集群的名称。
        2、创建一个客户端Client对象
        3、使用client对象创建一个索引库
        4、关闭client对象
2、使用Java客户端设置Mappings
    步骤：
    1）创建一个Settings对象
    2）创建一个Client对象
    3）创建一个mapping信息，应该是一个json数据，可以是字符串，也可以是XContextBuilder对象
    4）使用client向es服务器发送mapping信息
    5）关闭client对象

04-使用java客户端设置mapping映射

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.client.transport.TransportClient;
  4. import org.elasticsearch.common.settings.Settings;
  5. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  6. import org.elasticsearch.common.xcontent.XContentBuilder;
  7. import org.elasticsearch.common.xcontent.XContentFactory;
  8. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  9. import org.junit.Test;
  10.  
  11. import java.net.InetAddress;
  12.  
  13. public class ElasticSearchClientTest {
  14.     @Test
  15.     public void createIndex() throws Exception {
  16.         //1、创建一个Settings对象，相当于是一个配置信息，主要配置集群的名称。
  17.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  18.         //2、创建一个客户端Client对象
  19.         TransportClient client = new PreBuiltTransportClient(settings);
  20.         //向client中添加三个ip地址的端口号，防止一个服务器不好使然后出现bug
  21.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301));
  22.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302));
  23.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  24.         //3、使用client对象创建一个索引库
  25.         client.admin().indices().prepareCreate("index_hello").get();//index_hello索引名称、get()执行操作
  26.         //4、关闭client对象
  27.         client.close();
  28.     }
  29.  
  30.     @Test
  31.     public void setMappings() throws Exception {
  32.         //1、创建一个Settings对象
  33.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  34.         //2、创建一个Client对象，创建一个TransportClient对象
  35.         TransportClient client = new PreBuiltTransportClient(settings)
  36.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301))
  37.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302))
  38.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  39.  
  40.         //3、创建一个mapping信息，应该是一个json数据，可以是字符串，也可以是XContextBuilder对象
  41.         /*
  42.             {
  43.                 "article": {type名称，表名：文章
  44.                     "properties": {
  45.                         "id": {//字段
  46.                             "type": "long",
  47.                             "store": true
  48.                             // "index": "not_analyzed"
  49.                         },
  50.                         "title": {
  51.                             "type": "text",
  52.                             "store": true,
  53.                             "index": true,
  54.                             "analyzer": "ik_smart"//ik_max_word、standard
  55.                         },
  56.                         "content": {
  57.                             "type": "text",
  58.                             "store": true,
  59.                             "index": true,//analyzed
  60.                             "analyzer": "ik_smart"//ik_max_word、standard
  61.                         }
  62.                     }
  63.                 }
  64.             }
  65.         */
  66.         XContentBuilder builder = XContentFactory.jsonBuilder()
  67.                 .startObject()
  68.                     .startObject("article")//type名称
  69.                         .startObject("properties")
  70.                             .startObject("id")
  71.                                 .field("type", "long")
  72.                                 .field("store", true)
  73.                             .endObject()
  74.                             .startObject("title")
  75.                                 .field("type", "text")
  76.                                 .field("store", true)
  77.                                 .field("analyzer", "ik_smart")
  78.                             .endObject()
  79.                             .startObject("content")
  80.                                 .field("type", "text")
  81.                                 .field("store", true)
  82.                                 .field("analyzer", "ik_smart")
  83.                             .endObject()
  84.                         .endObject()
  85.                     .endObject()
  86.                 .endObject();
  87.         //4、使用client向es服务器发送mapping信息，使用client把mapping信息设置到索引库中
  88.         client.admin().indices()
  89.                 .preparePutMapping("index_hello")//设置要做映射的索引，设置索引库名称
  90.                 .setType("article")//设置要做映射的type，设置type名称
  91.                 .setSource(builder)//mapping信息，可以是XContentBuilder对象也可以是json格式的字符串
  92.                 .get();
  93.         //5、关闭client对象，关闭链接
  94.         client.close();
  95.     }
  96. }

05-向索引库中添加文档

es集群可以包含多个索引（indices）（数据库），每一个索引可以包含多个类型（types）（表），每一个类型包含多个文档（documents）（行），然后每个文档（数据）包含多个字段（Fields）（列）。

一、使用Java客户端管理ES
1、创建索引库
    步骤：
    1）创建一个Java工程
    2）添加jar包，添加maven的坐标
    3）编写测试方法实现创建索引库
        1、创建一个Settings对象，相当于是一个配置信息，主要用于配置集群的名称。
        2、创建一个客户端Client对象
        3、使用client对象创建一个索引库
        4、关闭client对象
2、使用Java客户端设置Mappings
    步骤：
    1）创建一个Settings对象
    2）创建一个Client对象
    3）创建一个mapping信息，应该是一个json数据，可以是字符串，也可以是XContextBuilder对象
    4）使用client向es服务器发送mapping信息
    5）关闭client对象
3、添加文档(一行数据)
    步骤：
    1）创建一个Settings对象
    2）创建一个Client对象
    3）创建一个文档对象，创建一个json格式的字符串或者使用XContentBuilder
    4）使用Client对象吧文档添加到索引库中
    5）关闭client

每一步都要创建一个client对象，所以将client单独提取出来。

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.client.transport.TransportClient;
  4. import org.elasticsearch.common.settings.Settings;
  5. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  6. import org.elasticsearch.common.xcontent.XContentBuilder;
  7. import org.elasticsearch.common.xcontent.XContentFactory;
  8. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  9. import org.junit.Before;
  10. import org.junit.Test;
  11.  
  12. import java.net.InetAddress;
  13.  
  14. public class ElasticSearchClientTest {
  15.     private TransportClient client;
  16.  
  17.     @Before
  18.     public void init() throws Exception {
  19.         //1、创建一个Settings对象
  20.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  21.         //2、创建一个Client对象，创建一个TransportClient对象
  22.         client = new PreBuiltTransportClient(settings)
  23.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301))
  24.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302))
  25.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  26.     }
  27.  
  28.     @Test
  29.     public void createIndex() throws Exception {
  30.         //1、创建一个Settings对象，相当于是一个配置信息，主要配置集群的名称。
  31.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  32.         //2、创建一个客户端Client对象
  33.         TransportClient client = new PreBuiltTransportClient(settings);
  34.         //向client中添加三个ip地址的端口号，防止一个服务器不好使然后出现bug
  35.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301));
  36.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302));
  37.         client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  38.         //3、使用client对象创建一个索引库
  39.         client.admin().indices().prepareCreate("index_hello").get();//index_hello索引名称、get()执行操作
  40.         //4、关闭client对象
  41.         client.close();
  42.     }
  43.  
  44.     @Test
  45.     public void setMappings() throws Exception {
  46.         //3、创建一个mapping信息，应该是一个json数据，可以是字符串，也可以是XContextBuilder对象
  47.         /*
  48.             {
  49.                 "article": {type名称，表名：文章
  50.                     "properties": {
  51.                         "id": {//字段
  52.                             "type": "long",
  53.                             "store": true
  54.                             // "index": "not_analyzed"
  55.                         },
  56.                         "title": {
  57.                             "type": "text",
  58.                             "store": true,
  59.                             "index": true,
  60.                             "analyzer": "ik_smart"//ik_max_word、standard
  61.                         },
  62.                         "content": {
  63.                             "type": "text",
  64.                             "store": true,
  65.                             "index": true,//analyzed
  66.                             "analyzer": "ik_smart"//ik_max_word、standard
  67.                         }
  68.                     }
  69.                 }
  70.             }
  71.         */
  72.         XContentBuilder builder = XContentFactory.jsonBuilder()
  73.                 .startObject()
  74.                     .startObject("article")//type名称
  75.                         .startObject("properties")
  76.                             .startObject("id")
  77.                                 .field("type", "long")
  78.                                 .field("store", true)
  79.                             .endObject()
  80.                             .startObject("title")
  81.                                 .field("type", "text")
  82.                                 .field("store", true)
  83.                                 .field("analyzer", "ik_smart")
  84.                             .endObject()
  85.                             .startObject("content")
  86.                                 .field("type", "text")
  87.                                 .field("store", true)
  88.                                 .field("analyzer", "ik_smart")
  89.                             .endObject()
  90.                         .endObject()
  91.                     .endObject()
  92.                 .endObject();
  93.         //4、使用client向es服务器发送mapping信息，使用client把mapping信息设置到索引库中
  94.         client.admin().indices()
  95.                 .preparePutMapping("index_hello")//设置要做映射的索引，设置索引库名称
  96.                 .setType("article")//设置要做映射的type，设置type名称
  97.                 .setSource(builder)//mapping信息，可以是XContentBuilder对象也可以是json格式的字符串
  98.                 .get();
  99.         //5、关闭client对象，关闭链接
  100.         client.close();
  101.     }
  102.  
  103.     @Test
  104.     public void testAddDocument() throws Exception {
  105.         //1）创建一个Settings对象
  106.         //2）创建一个Client对象
  107.         //public void init() throws Exception {...}
  108.         //3）创建一个文档对象，创建一个json格式的字符串或者使用XContentBuilder
  109.         XContentBuilder builder = XContentFactory.jsonBuilder()
  110.                 .startObject()
  111.                     .field("id", 2l)//long型数据 2l
  112.                     .field("title", "Cause I got a crush on you who you~")
  113.                     .field("content", "你是我的我是你的谁~")
  114.                 .endObject();
  115.         //4）使用Client对象把文档对象添加到索引库中
  116.         client.prepareIndex()
  117.                 .setIndex("index_hello")//设置索引名称
  118.                 .setType("article")//设置typr
  119.                 .setId("2")//设置文档的id，如果不设置id的话es会自动生成一个id
  120.                 .setSource(builder)//设置文档信息，builder对象或json串
  121.                 .get();//执行操作
  122.         //5）关闭client客户端
  123.         client.close();
  124.     }
  125. }

06-添加文档的第二种方式

一、使用Java客户端管理ES
1、创建索引库
2、使用Java客户端设置Mappings
3、添加文档(一行数据)

4、添加文档第二种方式
    创建一个pojo类
    使用工具类把pojo转换成json字符串
    把文档写入索引库

  1. @Test
  2. public void testAddDocument2() throws Exception {
  3.     //创建一个Article对象
  4.     Article article = new Article();
  5.     //设置对象的属性
  6.     article.setId(3l);
  7.     article.setTitle("再多一眼看一眼就会爆炸~");
  8.     article.setContent("再近一点靠近点快被融化~");
  9.     //把article对象转换成json格式的字符串
  10.     ObjectMapper objectMapper = new ObjectMapper();
  11.     String jsonDocument = objectMapper.writeValueAsString(article);
  12.     System.out.println(jsonDocument);
  13.     //使用client对象把文档写入索引库
  14.     client.prepareIndex("index_hello", "article", "3")
  15.             .setSource(jsonDocument, XContentType.JSON)
  16.             .get();
  17.     //关闭客户端
  18.     client.close();
  19. }

07-索引库查询_根据id查询

一、使用Java客户端管理ES
1、创建索引库
2、使用Java客户端设置Mappings
3、添加文档(一行数据)
4、添加文档的第二种方式

二、使用ES客户端实现搜索
1、根据id搜索
    QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1", "2");
2、根据Term查询（关键词）
    QueryBuilder queryBuilder = QueryBuilders.termQuery("title", "北方");
3、QueryString查询方式（带分析的查询）
    QueryBuilder queryBuilder = QueryBuilders.queryStringQuery("速度与激情").defaultField("title");
    查询步骤：
    1）创建一个Client对象
    2）创建一个查询对象，可以使用QueryBuilders工具类创建QueryBuilder对象
    3）使用client执行查询
    4）得到查询的结果
    5）取查询结果的总记录数
    6）取查询结果列表
    7）关闭client

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.action.search.SearchResponse;
  4. import org.elasticsearch.client.transport.TransportClient;
  5. import org.elasticsearch.common.settings.Settings;
  6. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  7. import org.elasticsearch.index.query.QueryBuilder;
  8. import org.elasticsearch.index.query.QueryBuilders;
  9. import org.elasticsearch.search.SearchHit;
  10. import org.elasticsearch.search.SearchHits;
  11. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  12. import org.junit.Before;
  13. import org.junit.Test;
  14.  
  15. import java.net.InetAddress;
  16. import java.util.Iterator;
  17. import java.util.Map;
  18.  
  19. public class SearchIndex {
  20.     private TransportClient client;
  21.  
  22.     @Before
  23.     public void init() throws Exception {
  24.         //1、创建一个Settings对象
  25.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  26.         //2、创建一个Client对象，创建一个TransportClient对象
  27.         client = new PreBuiltTransportClient(settings)
  28.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301))
  29.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302))
  30.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  31.     }
  32.  
  33.     @Test
  34.     public void testSearchById() throws Exception {
  35.         //1）创建一个client对象
  36.         //public void init() throws Exception {}
  37.         //2）创建一个查询对象，可以使用QueryBuilders工具类创建QueryBuilder对象
  38.         QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1", "2");
  39.         //3）使用client执行查询
  40.         SearchResponse searchResponse = client.prepareSearch("index_hello")
  41.                 .setTypes("article")
  42.                 .setQuery(queryBuilder)
  43.                 .get();
  44.         //4）得到查询的结果
  45.         SearchHits searchHits = searchResponse.getHits();
  46.         //5）取查询结果的总记录数
  47.         System.out.println("查询结果总记录数：" + searchHits.getTotalHits());
  48.         //6）取查询结果列表
  49.         Iterator<SearchHit> iterator = searchHits.iterator();
  50.         while (iterator.hasNext()) {
  51.             SearchHit searchHit = iterator.next();
  52.             //打印文档对象，以json格式输出
  53.             System.out.println(searchHit.getSourceAsString());
  54.             //取文档的属性
  55.             System.out.println("---------------文档的属性");
  56.             Map<String, Object> document = searchHit.getSource();
  57.             System.out.println(document.get("id"));
  58.             System.out.println(document.get("title"));
  59.             System.out.println(document.get("content"));
  60.         }
  61.         //7）关闭client
  62.         client.close();
  63.     }
  64. }

 08-索引库查询_根据term查询

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.action.search.SearchResponse;
  4. import org.elasticsearch.client.transport.TransportClient;
  5. import org.elasticsearch.common.settings.Settings;
  6. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  7. import org.elasticsearch.index.query.QueryBuilder;
  8. import org.elasticsearch.index.query.QueryBuilders;
  9. import org.elasticsearch.index.query.TermQueryBuilder;
  10. import org.elasticsearch.search.SearchHit;
  11. import org.elasticsearch.search.SearchHits;
  12. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  13. import org.junit.Before;
  14. import org.junit.Test;
  15.  
  16. import java.net.InetAddress;
  17. import java.util.Iterator;
  18. import java.util.Map;
  19.  
  20. public class SearchIndex {
  21.     private TransportClient client;
  22.  
  23.     @Before
  24.     public void init() throws Exception {
  25.         //1、创建一个Settings对象
  26.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  27.         //2、创建一个Client对象，创建一个TransportClient对象
  28.         client = new PreBuiltTransportClient(settings)
  29.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301))
  30.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302))
  31.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  32.     }
  33.  
  34.     private void search(QueryBuilder queryBuilder) throws Exception {
  35.         //3）使用client执行查询
  36.         SearchResponse searchResponse = client.prepareSearch("index_hello")
  37.                 .setTypes("article")
  38.                 .setQuery(queryBuilder)
  39.                 .get();
  40.         //4）得到查询的结果
  41.         SearchHits searchHits = searchResponse.getHits();
  42.         //5）取查询结果的总记录数
  43.         System.out.println("查询结果总记录数：" + searchHits.getTotalHits());
  44.         //6）取查询结果列表
  45.         Iterator<SearchHit> iterator = searchHits.iterator();
  46.         while (iterator.hasNext()) {
  47.             SearchHit searchHit = iterator.next();
  48.             //打印文档对象，以json格式输出
  49.             System.out.println(searchHit.getSourceAsString());
  50.             //取文档的属性
  51.             System.out.println("---------------文档的属性");
  52.             Map<String, Object> document = searchHit.getSource();
  53.             System.out.println(document.get("id"));
  54.             System.out.println(document.get("title"));
  55.             System.out.println(document.get("content"));
  56.         }
  57.         //7）关闭client
  58.         client.close();
  59.     }
  60.  
  61.     @Test
  62.     public void testSearchById() throws Exception {
  63.         //1）创建一个client对象
  64.         //public void init() throws Exception {}
  65.         //2）创建一个查询对象，可以使用QueryBuilders工具类创建QueryBuilder对象
  66.         QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1", "2");
  67.         search(queryBuilder);
  68.     }
  69.  
  70.     @Test
  71.     public void testQueryByTerm() throws Exception {
  72.         //创建一个QueryBuilder对象
  73.         //参数1：要搜索的字段
  74.         //参数2：要搜索的关键词
  75.         TermQueryBuilder queryBuilder = QueryBuilders.termQuery("title", "爆炸");
  76.         //执行查询
  77.         search(queryBuilder);
  78.     }
  79. }

09-索引库查询_queryString查询

10-查询分页设置

01、插入数据

  1. @Test
  2. public void testAddDocument3() throws Exception {//批量添加数据
  3.     for (int i = 4; i < 100; i++) {
  4.         //创建一个Article对象
  5.         Article article = new Article();
  6.         //设置对象的属性
  7.         article.setId(i);
  8.         article.setTitle("再多一眼看一眼就会爆炸~" + i);
  9.         article.setContent("再近一点靠近点快被融化~" + i);
  10.         //把article对象转换成json格式的字符串
  11.         ObjectMapper objectMapper = new ObjectMapper();
  12.         String jsonDocument = objectMapper.writeValueAsString(article);
  13.         System.out.println(jsonDocument);
  14.         //使用client对象把文档写入索引库
  15.         client.prepareIndex("index_hello", "article", i + "")
  16.                 .setSource(jsonDocument, XContentType.JSON)
  17.                 .get();
  18.     }
  19.     //关闭客户端
  20.     client.close();
  21. }

02、设置分页

一、使用Java客户端管理ES
1、创建索引库
2、使用Java客户端设置Mappings
3、添加文档(一行数据)
4、添加文档的第二种方式

二、使用ES客户端实现搜索
1、根据id搜索
2、根据Term查询（关键词）
3、QueryString查询方式（带分析的查询）
4、分页的处理
    在client对象执行查询之前，设置分页信息。
    然后再执行查询
     //执行查询
        SearchResponse searchResponse = client.prepareSearch("index_hello")
                .setTypes("article")
                .setQuery(queryBuilder)
                //设置分页信息
                .setFrom(0)
                //每页显示的行数
                .setSize(5)
                .get();
    分页需要设置两个值，一个from、size
    from：起始的行号，从0开始。
    size：每页显示的记录数

11-查询结果高亮显示

一、使用Java客户端管理ES
1、创建索引库
2、使用Java客户端设置Mappings
3、添加文档(一行数据)
4、添加文档的第二种方式

二、使用ES客户端实现搜索
1、根据id搜索
2、根据Term查询（关键词）
3、QueryString查询方式（带分析的查询）
4、分页的处理
5、查询结果高亮显示
（1）高亮的配置
        1）设置高亮显示的字段
        2）设置高亮显示的前缀
        3）设置高亮显示的后缀
（2）在client对象执行查询之前，设置高亮显示的信息
（3）遍历结果列表时可以从结果中取高亮结果

01、查看高亮结果

给关键词的前后加上HTML标签作为前后缀。

02、高亮显示代码实现

  1. package com.itheima.es;
  2.  
  3. import org.elasticsearch.action.search.SearchResponse;
  4. import org.elasticsearch.client.transport.TransportClient;
  5. import org.elasticsearch.common.settings.Settings;
  6. import org.elasticsearch.common.text.Text;
  7. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  8. import org.elasticsearch.index.query.QueryBuilder;
  9. import org.elasticsearch.index.query.QueryBuilders;
  10. import org.elasticsearch.index.query.TermQueryBuilder;
  11. import org.elasticsearch.search.SearchHit;
  12. import org.elasticsearch.search.SearchHits;
  13. import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
  14. import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
  15. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  16. import org.junit.Before;
  17. import org.junit.Test;
  18.  
  19. import java.net.InetAddress;
  20. import java.util.Iterator;
  21. import java.util.Map;
  22.  
  23. public class SearchIndex {
  24.     private TransportClient client;
  25.  
  26.     @Before
  27.     public void init() throws Exception {
  28.         //1、创建一个Settings对象
  29.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  30.         //2、创建一个Client对象，创建一个TransportClient对象
  31.         client = new PreBuiltTransportClient(settings)
  32.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9301))
  33.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9302))
  34.                 .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9303));
  35.     }
  36.  
  37.     private void search(QueryBuilder queryBuilder) throws Exception {
  38.         //3）使用client执行查询
  39.         SearchResponse searchResponse = client.prepareSearch("index_hello")
  40.                 .setTypes("article")
  41.                 .setQuery(queryBuilder)
  42.                 .get();
  43.         //4）得到查询的结果
  44.         SearchHits searchHits = searchResponse.getHits();
  45.         //5）取查询结果的总记录数
  46.         System.out.println("查询结果总记录数：" + searchHits.getTotalHits());
  47.         //6）取查询结果列表
  48.         Iterator<SearchHit> iterator = searchHits.iterator();
  49.         while (iterator.hasNext()) {
  50.             SearchHit searchHit = iterator.next();
  51.             //打印文档对象，以json格式输出
  52.             System.out.println(searchHit.getSourceAsString());
  53.             //取文档的属性
  54.             System.out.println("---------------文档的属性");
  55.             Map<String, Object> document = searchHit.getSource();
  56.             System.out.println(document.get("id"));
  57.             System.out.println(document.get("title"));
  58.             System.out.println(document.get("content"));
  59.         }
  60.         //7）关闭client
  61.         client.close();
  62.     }
  63.  
  64.     @Test
  65.     public void testSearchById() throws Exception {
  66.         //1）创建一个client对象
  67.         //public void init() throws Exception {}
  68.         //2）创建一个查询对象，可以使用QueryBuilders工具类创建QueryBuilder对象
  69.         QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1", "2");
  70.         search(queryBuilder);
  71.         /*
  72.         //3）使用client执行查询
  73.         SearchResponse searchResponse = client.prepareSearch("index_hello")
  74.                 .setTypes("article")
  75.                 .setQuery(queryBuilder)
  76.                 .get();
  77.         //4）得到查询的结果
  78.         SearchHits searchHits = searchResponse.getHits();
  79.         //5）取查询结果的总记录数
  80.         System.out.println("查询结果总记录数：" + searchHits.getTotalHits());
  81.         //6）取查询结果列表
  82.         Iterator<SearchHit> iterator = searchHits.iterator();
  83.         while (iterator.hasNext()) {
  84.             SearchHit searchHit = iterator.next();
  85.             //打印文档对象，以json格式输出
  86.             System.out.println(searchHit.getSourceAsString());
  87.             //取文档的属性
  88.             System.out.println("---------------文档的属性");
  89.             Map<String, Object> document = searchHit.getSource();
  90.             System.out.println(document.get("id"));
  91.             System.out.println(document.get("title"));
  92.             System.out.println(document.get("content"));
  93.         }
  94.         //7）关闭client
  95.         client.close();*/
  96.     }
  97.  
  98.     @Test
  99.     public void testQueryByTerm() throws Exception {
  100.         //创建一个QueryBuilder对象
  101.         //参数1：要搜索的字段
  102.         //参数2：要搜索的关键词
  103.         TermQueryBuilder queryBuilder = QueryBuilders.termQuery("title", "爆炸");
  104.         //执行查询
  105.         search(queryBuilder);
  106.     }
  107.  
  108.     @Test
  109.     public void testQueryStringQuery() throws Exception {
  110.         //创建一个QueryBuilder对象
  111.         QueryBuilder queryBuilder = QueryBuilders.queryStringQuery("爆炸").defaultField("title");
  112.         //执行查询
  113.         search(queryBuilder, "title");
  114.     }
  115.  
  116.     private void search(QueryBuilder queryBuilder, String highLightField) throws Exception {
  117.         HighlightBuilder highlightBuilder = new HighlightBuilder();
  118.         highlightBuilder.field(highLightField);//高亮显示的字段
  119.         highlightBuilder.preTags("<em>");//前缀
  120.         highlightBuilder.postTags("</em>");//后缀
  121.         //3）使用client执行查询
  122.         SearchResponse searchResponse = client.prepareSearch("index_hello")
  123.                 .setTypes("article")
  124.                 .setQuery(queryBuilder)
  125.                 //设置分页信息
  126.                 .setFrom(0)//起始行号从0开始
  127.                 .setSize(5)//每一页显示的行数
  128.                 //设置高亮信息
  129.                 .highlighter(highlightBuilder)
  130.                 .get();
  131.         //4）得到查询的结果
  132.         SearchHits searchHits = searchResponse.getHits();
  133.         //5）取查询结果的总记录数
  134.         System.out.println("查询结果总记录数：" + searchHits.getTotalHits());
  135.         //6）取查询结果列表
  136.         Iterator<SearchHit> iterator = searchHits.iterator();
  137.         while (iterator.hasNext()) {
  138.             SearchHit searchHit = iterator.next();
  139.             //打印文档对象，以json格式输出
  140.             System.out.println(searchHit.getSourceAsString());
  141.             //取文档的属性
  142.             System.out.println("---------------文档的属性");
  143.             Map<String, Object> document = searchHit.getSource();
  144.             System.out.println(document.get("id"));
  145.             System.out.println(document.get("title"));
  146.             System.out.println(document.get("content"));
  147.             System.out.println("****************************高亮结果");
  148.             Map<String, HighlightField> highlightFields = searchHit.getHighlightFields();
  149.             System.out.println(highlightFields);
  150.             //取title高亮显示的结果
  151.             HighlightField field = highlightFields.get(highLightField);//取key
  152.             Text[] fragments = field.getFragments();
  153.             if (fragments != null) {
  154.                 String title = fragments[0].toString();
  155.                 System.out.println(title);
  156.             }
  157.         }
  158.         //7）关闭client
  159.         client.close();
  160.     }
  161. }

高亮显示：

xxx.xxx.var——快速生成变量。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/人工智能uu/article/detail/881977
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号