记录一次es写入操作

ゝ一世哀愁。 2023-06-29 05:41 3阅读 0赞

## 场景： ##

同步商品数据到es

## 注意事项： ##

1，es不能保存BigDecimal类型数据需要先转化为String类型

2，id，在此商品编码作为id

3，es类型怎么处理，es类型相当于数据库表名称，默认类型为：type\_index

IndexRequest(String index, String type, String id)

4，字段格式，es字段名称格式需要把驼峰处理成下划线间隔，如userName 装 user\_name

## 代码 ##

public void doSyncEs(List<BaseProductInfoSap> source) throws IOException {
    	if(CollectionUtils.isEmpty(source)){
    		return;
    	}
    	BulkRequest bulkRequest = new BulkRequest();
    	List<ReqProductInfoEsVo> vos=EsConverter.toEsVO(source);
    	vos.stream().forEach(sap -> {
    		//es不支持对象中包含的bigdecimal类型，将之转为string
    		String obj = BizStringUtils.toUnderlineJSONString(sap);
    		Map<String,Object> objMap = JSONObject.parseObject(obj);
    		//id为product_code，存在则更新，不存在插入
    		String id = sap.getProductCode();
    		IndexRequest request = new IndexRequest(EsOperateTables.BASE_PRODUCT_INFO_SAP.getValue(),
    			EsUtils.TYPE + EsOperateTables.BASE_PRODUCT_INFO_SAP.getValue(), id);
    		request.source(objMap);
    		// 创建更新请求，指定index，type,id,如果indexRequest 有值 （存在该数据）则用doc指定的内容更新indexRequest中指定的source，如果不存在该数据，则插入一条indexRequest指定的source数据
    		UpdateRequest updateRequest = new UpdateRequest(EsOperateTables.BASE_PRODUCT_INFO_SAP.getValue(),EsUtils.TYPE + EsOperateTables.BASE_PRODUCT_INFO_SAP.getValue(),id);
    		updateRequest.doc(objMap);
    		updateRequest.upsert(request);
    		// 将更新请求加入批量操作请求
    		bulkRequest.add(updateRequest);
    	});
    	restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);
    }