ElasticSearch添加mapping

1.创建索引

/**
 * 创建索引
 *
 * @param indexName
 */
public static void createIndex(String indexName) {
//插入前删除,以免报错
 boolean flag = client.admin().indices().exists(new IndicesExistsRequest().indices(new String[]{indexName})).actionGet().isExists();
 if (flag){
client.admin().indices().prepareDelete(indexName).execute().actionGet();
 }
client.admin().indices().prepareCreate(indexName).get();
 //client.admin().indices().prepareCreate(indexName)
 // .setSettings(Settings.builder()
 // .put("index.number_of_shards", 3)
 // .put("index.number_of_replicas", 2)
 // )
 // .get();
}

 

2.创建mapping

    /**
     * 创建mapping,根据需求修改
     *
     * @param indexName
     * @param typeName
     */
    public static void createMapping(String indexName, String typeName) {
        XContentBuilder mappingType = null;
        try {
            mappingType = jsonBuilder()
                    .startObject()
                    .startObject(typeName)
                    .startObject("properties")
                    .startObject("id").field("type", "integer").field("store", "yes").endObject()
                    .startObject("Name").field("type", "string").field("store", "yes").field("analyzer", "ik_smart").field("search_analyzer", "ik_smart").endObject()
                    .startObject("updatedate").field("type", "date").field("store", "yes").endObject()
                    .endObject()
                    .endObject()
                    .endObject();
        } catch (IOException e) {
            logger.error("build company mapping failed", e);
        }
        PutMappingRequest mapping = Requests.putMappingRequest(indexName).type(typeName).source(mappingType);
        client.admin().indices().putMapping(mapping).actionGet();
        client.admin().indices().prepareRefresh().get();
        //client.close();
    }