話不多說，環境是ElasticSearch 安裝教程 可以看這個。我的環境是5.3 + 分詞 。

一、Index的建立

      5.x的預設是不會在你插入資料的時候主動建立index的，所以網上其他地方的介紹程式碼，都有問題。你是沒法直接用的。
建立index：

     // 設定叢集名稱
    Settings settings = Settings.builder().put("cluster.name", clusterName).build();
    // 建立client
    client = new PreBuiltTransportClient(settings);
    Map<String, Integer> nodeMap = parseNodeIpInfo();
    for
 
 (Map.Entry<String, Integer> entry : nodeMap.entrySet()) {
        client.addTransportAddress(
                new InetSocketTransportAddress(InetAddress.getByName(entry.getKey()), entry.getValue()));
    }
    //建立client後，獲取index的配置引數
    XContentBuilder mapping = getIndexMapping();
    client.admin().indices().prepareCreate(userIndexName).setSettings(mapping).get();




   /**
     * 解析節點IP資訊,多個節點用逗號隔開,IP和埠用冒號隔開
     * @return
 

     */
    private Map<String, Integer> parseNodeIpInfo() {
        String[] nodeIpInfoArr = esNodes.split(","); //esNodes為外部注入的es的ip
        Map<String, Integer> map = new HashMap<String, Integer>(nodeIpInfoArr.length);
        for (String ipInfo : nodeIpInfoArr) {
            String[] ipInfoArr = ipInfo.split(":"
 
);
            map.put(ipInfoArr[0], Integer.parseInt(ipInfoArr[1]));
        }
        return map;
    }

    /**
     * 建立所需的index配置
     * @return
     * @throws IOException
     */
    private XContentBuilder getIndexMapping() throws IOException {
        XContentBuilder mapping = XContentFactory.jsonBuilder();
        mapping.startObject()
               .startObject("index")
                    .startObject("analyzer")
                        .startObject("pinyin_analyzer")
                            .field("tokenizer", "my_pinyin")
                        .endObject()
                        .startObject("default")
                            .field("tokenizer", "ik_max_word")
                        .endObject()
                    .endObject()
                    .startObject("tokenizer")
                        .startObject("my_pinyin")
                            .field("type", "pinyin")
                            // 拼音首字母單獨開一個
                            .field("keep_separate_first_letter", true)
                            .field("keep_full_pinyin", true)
                            .field("keep_original", true)
                            .field("limit_first_letter_length", 16)
                            .field("lowercase", true)
                            .field("remove_duplicated_term", true)
                .endObject().endObject().endObject().endObject().endObject();
        return mapping;
    }
// 判斷index建立是否成功
IndicesExistsResponse userResponse = client.admin().indices().exists(new IndicesExistsRequest(userIndexName)).actionGet();
 return userResponse.isExists();  //true  存在

二、建立type

      在ElasticSearch裡面，上面的index就相當於建立一個了一個數據庫，而type則是建立一張表。

    //es裡面設定引數的話用這個比較形象的去構建json格式
    XContentBuilder mapping = XContentFactory.jsonBuilder()
                .startObject()
                .startObject(userTypeName) //該type 名
                    .startObject("properties")  
                        .startObject("userId")  //相當於資料庫欄位名 型別
                            .field("type", "text")  //欄位型別
                        .endObject()
                        .startObject("loginName") // 巢狀物件欄位
                            .field("type", "keyword") //特殊設定，該欄位是拼音分詞的
                            .startObject("fields")
                                .startObject("pinyin")
                                    .field("type", "text")
                                    .field("store", false)
                                    .field("term_vector", "with_offsets")
                                    .field("analyzer", "pinyin_analyzer") 
                                    .field("boost", 10)
                                .endObject()
                            .endObject()
                        .endObject() //刪去了部分欄位
                        .startObject("orgId")
                            .field("type", "text")
                        .endObject()
                        .startObject("orgPath")
                            .field("type", "text")
                        .endObject()
                        .endObject().endObject().endObject();
        PutMappingRequest mappingRequest = Requests.putMappingRequest(userIndexName).type(userTypeName).source(mapping);
        client.admin().indices().putMapping(mappingRequest).actionGet();

//判斷type是否存在
TypesExistsRequest type = new TypesExistsRequest(new String[] { userIndexName }, userTypeName);
return client.admin().indices().typesExists(type).actionGet().isExists();

三、增

        向ElasticSearch裡面新增資料的話可以一個個插入也可以批量新增：

public void bulkSaveUserToES(List<UserESData> users) throws Exception {

    BulkRequestBuilder bulk = client.prepareBulk();
       //迴圈新增資料
        for (UserESData u : users) { 
            //這裡是用我資料庫裡面的id作為ElasticSearch的文件id
            bulk.add(client.prepareIndex(userIndexName, userTypeName, u.getUserId()).setSource(JSON.toJSONString(u),XContentType.JSON));
        }
        //執行
        bulk.execute().actionGet();
    }

單個數據儲存
public void saveUserESData(final UserESData user) throws Exception {
    client.prepareIndex(userIndexName, userTypeName, user.getUserId())
                    .setSource(JSON.toJSONString(user), XContentType.JSON).get();
}

四、改

        在這裡ElasticSearch提供多種方式用於定位要修改的資料：

//根據id修改
XContentBuilder builder = null;
    try {
        builder = XContentFactory.jsonBuilder()
                .startObject()
                    .field("userName", user.getUserName())
                    .field("orgId", user.getOrgId())
                    .field("orgPath", user.getOrgPath())
                .endObject();
    } catch (IOException e) {
        log.error("方法updateUserESData 再構造儲存物件時出錯！", e);
    }
                                                        //根據這個id
    client.prepareUpdate(userIndexName, userTypeName, user.getUserId()).setDoc(builder)
                    .get();

    //批量根據id更新
    BulkRequestBuilder bulk = client.prepareBulk();
        for (Entry<String, Object[]> info : userInfo.entrySet()) {
            bulk.add(client.prepareUpdate(userIndexName, userTypeName, info.getKey())
                    .setDoc(XContentFactory.jsonBuilder()
                            .startObject()
                                .field("orgId", info.getValue()[0])
                                .field("orgPath", info.getValue()[1])
                                .field("teamId", info.getValue()[2])
                            .endObject()));
                }
    //執行
    bulk.execute().get();    

若是根據某些條件更新，可以使用ElasticSearch的指令碼 Painless
對於我們在ElasticSearch裡面的每一行資料（文件）都相當於 “ctx“ 資料的屬性是可以訪問的

如上邊的圖，我點選一行資料可以看到很多屬性。我使用ctx._source.userId 就可以獲取該userId
在程式裡：

//使用ElasticSearch的script來存放指令碼 ， 讓userName修改為newName
Script script = new Script("ctx._source.userName=" + newName);
//建立更新的條件，假如是orgPath要能滿足orgInfo[0]這個條件的，就修改userName
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
boolQuery.should(QueryBuilders.matchPhraseQuery("orgPath", orgInfo[0]));
//執行
UpdateByQueryAction.INSTANCE.newRequestBuilder(client).script(script).filter(boolQuery)
                        .source(orgIndexName).get();

//該段程式碼相當於sql

UPDATE table SET userName = ? WHERE orgPath LIKE ? 

如果條件有多個比如：UPDATE table SET userName = ? WHERE orgPath LIKE ? AND userName LIKE ? 
script 不用變，
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
boolQuery.should(QueryBuilders.matchPhraseQuery("orgPath", orgInfo[0]));
boolQuery.must(QueryBuilders.matchPhraseQuery("userName", "陳"));

//如果希望修改路徑（字串）的部分值，那麼參照Painless 的白名單API 可以這樣編寫指令碼
StringBuilder sb = new StringBuilder(); 
sb.append("if(ctx._source.orgPath.startsWith(\"").append(oldOrgPath)
    .append("\")){ctx._source.orgPath=ctx._source.orgPath.replace(\"")
    .append(oldOrgPath).append("\",\"").append(newOrgPath)
    .append("\")}");
Script script = new Script(sb.toString());
/**  如果是以oldOrgPath開頭的路徑，則替換為newOrgPath  
if(ctx._source.orgPath.startsWith(oldOrgPath)){
    ctx._source.orgPath = ctx._source.orgPath.replace(oldOrgPath,newOrgPath)
}
*/

五、刪除

        ElasticSearch的刪除

//根據id刪除
client.prepareDelete(userIndexName, userTypeName, userId).execute().actionGet();

//根據條件來刪除  返回刪除條數   queryBuilder  構建的查詢條件

long delete = DeleteByQueryAction.INSTANCE.newRequestBuilder(client).filter(queryBuilder).source(userIndexName).get().getDeleted();