elasticsearch笔记(3) java操作es的index

一: 准备es插件和elasticsearch-rest-high-level-client插件

 二.

   2.1创建索引连接

@Test
    public void esTest() throws IOException {
    //        PUT /books
//        {
//            "settings": {
//            "number_of_replicas": 1,
//                    "number_of_shards": 5
//        },
//            "mappings": {
//            "noval": {
//                "properties": {
//                    "name": {
//                        "type": "text",
//                                "analyzer": "ik_max_word",
//                                "index": true,
//                                "store": false
//                    },
//                    "author":{
//                        "type": "keyword"
//                    },
    
       String hostname = "192.168.43.30";
       Integer prot = 9200;

        // 设置索引  类型
        String index = "person";
        String type = "man";


        //设置索引的信息:分片 备份
        Settings.Builder settings = Settings.builder()
                .put("number_of_shards", 5)
                .put("number_of_replicas", 1);
        //构建mapping
        XContentBuilder mapping = JsonXContent.contentBuilder()
                .startObject()
                  .startObject("properties")
                    .startObject("name")
                      .field("type","text")
                    .endObject()
                    .startObject("age")
                      .field("type","integer")
                    .endObject()
                  .endObject()
                .endObject();

//        构建索引
        CreateIndexRequest createIndexRequest = new CreateIndexRequest(index)
                .settings(settings) //分盘和备份
                .mapping(type,mapping);


       //链接es
        HttpHost httpHost = new HttpHost(hostname,prot);
        RestClientBuilder restClientBuilder = RestClient.builder(httpHost);
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);
        
        //创建索引连接
        CreateIndexResponse createIndexResponse = restHighLevelClient.indices()
                .create(createIndexRequest, RequestOptions.DEFAULT);
      

    }

2.2 检查索引是否存在

    public void findIndex() throws IOException {
     //  获取连接restHighLevelClient
        HttpHost httpHost = new HttpHost(HOST,PORT);
        RestClientBuilder restClientBuilder = RestClient.builder(httpHost);
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);

        GetIndexRequest getIndexRequest = new GetIndexRequest();
        getIndexRequest.indices("person");

        boolean exists = restHighLevelClient.indices()
                  .exists(getIndexRequest, RequestOptions.DEFAULT);
        System.out.println(exists);

    }

2.3 删除索引

 public void deletIndex() throws IOException {
        //  获取连接restHighLevelClient
        HttpHost httpHost = new HttpHost(HOST,PORT);
        RestClientBuilder restClientBuilder = RestClient.builder(httpHost);
        RestHighLevelClient restHighLevelClient = new RestHighLevelClient(restClientBuilder);

        DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest();
        deleteIndexRequest.indices("person");

        AcknowledgedResponse delete = restHighLevelClient.indices()
                .delete(deleteIndexRequest, RequestOptions.DEFAULT);
        System.out.println(delete.isAcknowledged());

    }