java写⼊es数据库_Elasticarch教程(七)elasticarchIn。
。。
⾸先我不赞成再采⽤⼀些中间件(jar包)来解决和 之间的交互,⽐如 Spring-data-elasticarch.jar 系列⼀样,⽤就得依赖它。⽽Elasticarch 本⾝的⽤法就是很简洁的,也很容易,只要稍微加⼀下封装,即可解决。下⾯上我的简单封装的批量处理。
清朝皇后package lasticarch.manager;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
盈亏平衡点分析
import net.sf.json.JSONObject;
import org.elasticarch.action.bulk.BulkRequestBuilder;
import org.elasticarch.action.bulk.BulkRespon;
import org.elasticarch.action.index.IndexRequestBuilder;
import utils.StringUtils;
import lasticarch.utils.ESTools;
public class InrtManager {undefined
/**
* 添加数据到Elasticarch
* @param index
* @param type 类型
* @param idName Id字段名称
* @param json 存储的JSON,可以接受Map母乳性黄疸症状
好雪片片* @return
*/
题西林壁刻在哪里
public static Map save(String index, String type, String idName,JSONObject json) {undefined
List list = new ArrayList();
list.add(json);
return save(index, type, idName, list);
}
/**
* 添加数据到Elasticarch
* @param index 索引
季后赛规则* @param type 类型
* @param idName Id字段名称
* @param listData ⼀个对象集合
* @return
*/
@SuppressWarnings("unchecked")
public static Map save(String index, String type, String idName,List listData) {undefined BulkRequestBuilder bulkRequest = ESTools.client.prepareBulk().tRefresh(true);
Map resultMap = new HashMap();
for (Object object : listData) {undefined
JSONObject json = JSONObject.fromObject(object);
//没有指定idName 那就让Elasticarch⾃动⽣成
if(StringUtils.isBlank(idName)){undefined
IndexRequestBuilder lrb = ESTools.client.prepareIndex(index, type).tSource(json); bulkRequest.add(lrb);
}
el{undefined安塞腰鼓教案
String idValue = json.optString(idName);
IndexRequestBuilder lrb = ESTools.client.prepareIndex(index, type,idValue).tSource(json); bulkRequest.add(lrb);
}
}
BulkRespon bulkRespon = ute().actionGet();
if (bulkRespon.hasFailures()) {undefined
// process failures by iterating through each bulk respon item
System.out.Items().toString());
resultMap.put("500", "保存ES失败!");
return resultMap;
}
bulkRequest = ESTools.client.prepareBulk();
resultMap.put("200", "保存ES成功!");
return resultMap;
}
}
>烤鱼的热量