elasticsearch插入数据

1、单条插入（推荐设定主键id防止重复）

      public static String addIndex(String index,String type,HashMap<String, Object> hashMap){  

                  hashMap.put("id", "3");  //这里如果不指定id的话elasticsearch会自动创建主键id，

                  hashMap.put("title","双宿双飞从");

                  hashMap.put("describe", "测试123");  

                  hashMap.put("author", "测试doc");  

                TransportClient client=EsClientPool.getInstance().getClient();

                try {  

                    IndexResponse response = client.prepareIndex(index, type,hashMap.get("id").toString())

                            .setSource(hashMap).execute().actionGet();

                    System.out.println(response.getId());

                    return response.getId();  //返回主键

                } catch (Exception e) {

                    // TODO: handle exception

                    return null;

                }finally{

                    client.close();//关闭连接

                }

            }

2、批量插入

      public static void addAllIndex(String index,String type,HashMap<String, Object> hashMap){

                      hashMap.put("title","双宿双飞从");

                      hashMap.put("describe", "测试123");  

                      hashMap.put("author", "测试doc");  

                    TransportClient client=EsClientPool.getInstance().getClient();

                    try {

                        BulkRequestBuilder bulkRequest = client.prepareBulk();

                        for (int i = 0; i < 10000; i++) {

                            bulkRequest.add(client.prepareIndex(index, type).setSource(hashMap));

                            // 每1000条提交一次

                            if (i % 10000 == 0) {

                                bulkRequest.execute().actionGet();

                            }

                        }

                    } catch (Exception e) {

                    }finally{

                        client.close();

                    }

            }