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();
}
}