ElasticSearch 數據的批量索引

　　ElasticSearch 通常用於檢索百萬級別以上的數據，所以創建索引都是批量創建的，固然也支持單量索引。

　　ElasticSearch 以json數據格式做爲數據插入格式，而Solr是以文檔形式做爲基本格式，所以在創建索引以前，首先得把數據封裝成咱們須要的格式：

　　能夠用字符串，而後轉成json：

String json = "{" +
         "\"poi_index\":\"1\"," +
         "\"poi_title\":\"XXXX大學\"," +
         "\"poi_address\":\"XX省XX市XX區XX號\"," +
         "\"poi_lng\":\"126.545454\"," +
         "\"poi_lat\":\"23.121212\"," +
         "\"poi_phone\":\"15988888888\"," +
         "\"poi_tags\":\"學校，教育\"" +
    "}";

JSONObject json2 = JSONObject.fromObject(json);

　　能夠用JsonObject：

                jsonObject = new JSONObject();
                jsonObject.put("poi_index","23");
                jsonObject.put("poi_title", "xx大學");
                jsonObject.put("poi_address","xx路xx號");
                jsonObject.put("poi_lng", "123.321");
                jsonObject.put("poi_lat", ".23.32");
                jsonObject.put("poi_phone", "123456768");
                jsonObject.put("poi_tags", "學校");

　　也能夠使用ElasicSearch附帶的幫助類：

import static org.elasticsearch.common.xcontent.XContentFactory.*;

XContentBuilder builder = jsonBuilder()
    .startObject()
        .field("user", "kimchy")
        .field("postDate", new Date())
        .field("message", "trying out Elasticsearch")
    .endObject()

 String json = builder.string();

 

　　經過BulkRequestBuilder,將批量數據添加到request協議棧緩衝區：

BulkRequestBuilder bulkRequest = client.prepareBulk();
bulkRequest.add(client.prepareIndex("pois", "cxyword")
                        .setSource(jsonObject));

　　執行 get() 就能將數據插入建立的索引庫，最後用BulkResponse判斷是否插入失敗：

            BulkResponse bulkResponse = bulkRequest.get();
            if (bulkResponse.hasFailures())
            {
                       System.out.println("failed")
            }