ElasticSearch 学习 二 （spring boot整合）

ElasticSearch  学习 

1、SpringBoot整合

1. 引入ElasticSearch相关坐标

<!--引入es的坐标-->
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.4.0</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.4.0</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>7.4.0</version>
        </dependency>

　　2.ElasticSearchConfig配置

@Configuration
@ConfigurationProperties(prefix="elasticsearch")
public class ElasticSearchConfig {
    private String host;
    private int port;
    public String getHost() {
        return host;
    }
    public void setHost(String host) {
        this.host = host;
    }
    public int getPort() {
        return port;
    }
    public void setPort(int port) {
        this.port = port;
    }
    @Bean
    public RestHighLevelClient client(){
        return new RestHighLevelClient(RestClient.builder(
                new HttpHost(host,port,"http")
        ));
    }
}

　　3.配置yml文件

 elasticsearch: 2 host: localhost 3 port: 9200 

测试

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringElasticSearchApplication.class)
public class SpringElasticSearchApplicationTests {

    @Autowired
    private RestHighLevelClient restClient;


    @Test
    public void contextLoads() {
        System.out.println(restClient);
    }

    /**
     * 添加索引
     *
     * @throws IOException
     */
    @Test
    public void addIndex() throws IOException {
        //1.使用client获取操作索引对象
        IndicesClient indices = restClient.indices();
        //2.具体操作获取返回值
        //2.1 设置索引名称
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("itheima");

        CreateIndexResponse createIndexResponse = indices.create(createIndexRequest, RequestOptions.DEFAULT);
        //3.根据返回值判断结果
        System.out.println(createIndexResponse.isAcknowledged());
    }

    /**
     * 添加索引与映射
     */
    @Test
    public void addIndexAndMapping() throws IOException {
        //1.获取操作索引对象
        IndicesClient indices = restClient.indices();
        //2.具体操作
        //创建索引
        CreateIndexRequest createIndexRequest = new CreateIndexRequest("itcast");
        //设置mapping
        String mapping = "{
" +
                "      "properties" : {
" +
                "        "address" : {
" +
                "          "type" : "text",
" +
                "          "analyzer" : "ik_max_word"
" +
                "        },
" +
                "        "age" : {
" +
                "          "type" : "long"
" +
                "        },
" +
                "        "name" : {
" +
                "          "type" : "keyword"
" +
                "        }
" +
                "      }
" +
                "    }";

        createIndexRequest.mapping(mapping, XContentType.JSON);

        CreateIndexResponse createIndexResponse = indices.create(createIndexRequest, RequestOptions.DEFAULT);

        System.out.println("createIndexResponse = " + createIndexResponse.isAcknowledged());
    }

    /**
     *  C查询索引
     * @throws IOException
     */
    @Test
    public void queryIndex() throws IOException {
        IndicesClient indices = restClient.indices();

        GetIndexRequest getReqeust = new GetIndexRequest("itcast");
        GetIndexResponse response = indices.get(getReqeust, RequestOptions.DEFAULT);


        //获取结果
        Map<String, MappingMetaData> mappings = response.getMappings();
        for (String key : mappings.keySet()) {
            System.out.println(key+":" + mappings.get(key).getSourceAsMap());

        }
    }


    /**
     * 删除索引
     * @throws IOException
     */
    @Test
    public void deleteInsex() throws IOException {
        //获取索引操作对象
        IndicesClient indices = restClient.indices();
        //获取删除的请求对象
        DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest("itcast");
        //执行删除
        AcknowledgedResponse delete = indices.delete(deleteIndexRequest, RequestOptions.DEFAULT);

        System.out.println("delete = " + delete.isAcknowledged());

    }


    /**
     * 文档操作，添加数据
     */
    @Test
    public void addMappings() throws IOException {
        Map map = new HashMap();

        map.put("name","张三");
        map.put("age",18);
        map.put("address","南京高淳");

        Person p = new Person();
        p.setId("2");
        p.setName("小胖2222");
        p.setAge(30);
        p.setAddress("陕西西安");

        //将对象转为json
        String data = JSON.toJSONString(p);

        //1.获取操作文档的对象 ,为对象的时候source后面要制定文档类型
        IndexRequest indexRequest = new IndexRequest("itcast").id("2").source(data,XContentType.JSON);
        //添加数据，获取结果
        IndexResponse response = restClient.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println("response = " + response.getId());
    }

    /**
     * 修改文档：添加文档时，如果id存在则修改，id不存在则添加
     */
    @Test
    public void updateDoc() throws IOException {
        Person p = new Person();
        p.setId("2");
        p.setName("小胖");
        p.setAge(20);
        p.setAddress("陕西宝鸡");
        //将对象转为json
        String data = JSON.toJSONString(p);

        //1.获取操作文档的对象 ,为对象的时候source后面要制定文档类型
        IndexRequest indexRequest = new IndexRequest("itcast").id("2").source(data,XContentType.JSON);
        //添加数据，获取结果
        IndexResponse response = restClient.index(indexRequest, RequestOptions.DEFAULT);
        System.out.println("response = " + response.getId());
    }


    /**
     * 通过id查询文档
     * @throws IOException
     */
    @Test
    public void getDoc() throws IOException {
        GetRequest request = new GetRequest("itcast", "2");
        GetResponse r = restClient.get(request, RequestOptions.DEFAULT);
        System.out.println("r.getSourceAsString() = " + r.getSourceAsString());
    }


    /**
     * 根据id删除文档
     * @throws IOException
     */
    @Test
    public void deleteDoc() throws IOException {
        DeleteRequest request = new DeleteRequest("itcast", "2");
        DeleteResponse delete = restClient.delete(request, RequestOptions.DEFAULT);
        System.out.println("delete = " + delete.getId());
    }
}