SpringBoot整合ElasticSearch-v6.8.1的使用 - 4.索引的创建与删除

---

SpringBoot整合ElasticSearch-v6.8.1的封装 - 1.配置类
SpringBoot整合ElasticSearch-v6.8.1的封装 - 2.接口类
SpringBoot整合ElasticSearch-v6.8.1的封装 - 3.支持类
SpringBoot整合ElasticSearch-v6.8.1的使用 - 5.索引的数据(增删改)
SpringBoot整合ElasticSearch-v6.8.1的使用 - 6.索引的数据(查询)

使用Java创建索引不需要mappings下的_doc节点；以下面结构进行操作

{
    "settings": {
        "number_of_shards": 1,
        "number_of_replicas": 0
    },
    "mappings": {
        "properties": {
            "keyId": {
                "type": "long"
            },
            "account": {
                "type": "keyword"
            },
            "username": {
                "type": "text"
            },
            "age": {
                "type": "short"
            },
            "birthday": {
                "type": "date",
                "format": "yyyy-MM-dd",
                "ignore_malformed": true
            },
            "address": {
                "properties": {
                    "region": {
                        "type": "text",
                        "index": "true"
                    },
                    "location": {
                        "properties": {
                            "province": {
                                "type": "text",
                                "index": "true"
                            },
                            "city": {
                                "type": "text",
                                "index": "true"
                            }
                        }
                    }
                }
            },
            "role": {
                "properties": {
                    "attribute": {
                        "type": "nested"
                    }
                }
            },
            "createdTime": {
                "type": "date",
                "format": "yyyy-MM-dd HH:mm:ss||epoch_millis",
                "ignore_malformed": false
            }
        }
    }
}

判断ES索引是否存在

@Test
void 判断ES索引是否存在() {
    String index = "my_index";
    try {
        System.out.println(elasticSearchService.checkIndexExists(index));
    } catch (Exception e) {
        e.printStackTrace();
    }
}

创建索引

第一种方式创建索引：通过加载整体的mapping字符进行创建

@Test
void 创建ES索引1() {
    String index = "my_index";
    try {
        String source = "索引mapping内容,即上述的json文本";
        System.out.println(elasticSearchService.createIndex(index, source));
    } catch (Exception e) {
        e.printStackTrace();
    }
}

第二种方式创建索引：通过标签代码进行组装mapping内容进行创建

@Test
void 创建ES索引2() {
    String index = "my_index";
    try {
        // 设置settings映射
        Settings settings = Settings.builder().put("number_of_shards", 1).put("number_of_replicas", 0).build();
        // 复合参数
        Map<String, Object> region = new LinkedHashMap<>();
        region.put("type", "text");
        region.put("index", "true");
        Map<String, Object> location = new LinkedHashMap<>();
        Map<String, Object> location_properties = new LinkedHashMap<>();
        Map<String, Object> province = new LinkedHashMap<>();
        province.put("type", "text");
        province.put("index", "true");
        Map<String, Object> city = new LinkedHashMap<>();
        city.put("type", "text");
        city.put("index", "true");
        location_properties.put("province", province);
        location_properties.put("city", city);
        location.put("properties", location_properties);
        // 设置mapping映射
        XContentBuilder mapping = XContentFactory.jsonBuilder()
                .startObject()
                .startObject("properties")
                // keyId
                .startObject("keyId").field("type", "long").endObject()
                // account
                .startObject("account").field("type", "keyword").endObject()
                // username
                .startObject("username").field("type", "text").endObject()
                // age
                .startObject("age").field("type", "short").endObject()
                // birthday
                .startObject("birthday")
                    .field("type", "date")
                    .field("format", "yyyy-MM-dd")
                    .field("ignore_malformed", true).endObject()
                // address
                .startObject("address").startObject("properties")
                    .field("region", region)
                    .field("location", location)
                    .endObject().endObject()
                // role
                .startObject("role").startObject("properties")
                    .startObject("attribute").field("type", "nested").endObject()
                    .endObject().endObject()
                // createdTime
                .startObject("createdTime")
                    .field("type", "date")
                    .field("format", "yyyy-MM-dd HH:mm:ss||epoch_millis")
                    .field("ignore_malformed", true).endObject()
                    .endObject().endObject();
        System.out.println(elasticSearchService.createIndex(index, settings, mapping));
    } catch (Exception e) {
        e.printStackTrace();
    }
}

删除索引

删除索引的同时会删除索引内的全部数据

@Test
void 删除ES索引() {
    String index = "my_index";
    try {
        System.out.println(elasticSearchService.deleteIndex(index));
    } catch (Exception e) {
        e.printStackTrace();
    }
}