java写入es数据库_Elasticarch教程(七)elasticarchIn。。。

更新时间:2023-06-26 16:13:08 阅读: 评论:0

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;
}
}
>烤鱼的热量

本文发布于:2023-06-26 16:13:08,感谢您对本站的认可!

本文链接:https://www.wtabcd.cn/fanwen/fan/82/1044896.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:封装   指定   盈亏   黄疸   数据库   添加
相关文章
留言与评论(共有 0 条评论)
   
验证码:
推荐文章
排行榜
Copyright ©2019-2022 Comsenz Inc.Powered by © 专利检索| 网站地图