框架背景
springboot 3.3.1+elasticseach8.13.4+spring-data-elasticsearch5.3.1(其实只要用了springboot3.3.1 上下两个的版本都在里面绑死了)
问题描述
使用spring-data-elasticsearch操作es，当字段增加映射注解,其实如果是日期类型，你不加默认也给你映射成date了
@Field(type = FieldType.Date)
可以正常保存成功，但查询时会报错
org.springframework.data.elasticsearch.core.convert.ConversionException: Unable to convert value ‘2024-08-30’ to java.time.LocalDateTime for property ‘createTime’
通过kibana查看数据
发现保存的数据格式是 “2024-08-30”，导致读取时解析失败
解决方案使用自定义的转换器，我这里是将LocalDateTime保存为时间戳，读取的时候再转为LocalDateTime
以下是配置类（我是自定义了一个starer，所以用了@AutoConfiguration）
package cn.iocoder.centralstore.framework.es.config;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.data.elasticsearch.core.mapping.PropertyValueConverter;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
/***
* @Description: 处理 Elasticsearch 中 LocalDateTime 与时间戳之间的转换
* 将 LocalDateTime 写入为时间戳，读取时将时间戳转换为 LocalDateTime。
* @Author: TaoYuan
* @Date: 2024/8/29
*/
@AutoConfiguration
@Slf4j
public class CentralstoreLocalDateTimeConverter implements PropertyValueConverter {
// 使用系统默认时区
private static final ZoneId ZONE_ID = ZoneId.systemDefault();
@Override
public Object write(Object value) {
if (value instanceof LocalDateTime localDateTime) {
Instant instant = localDateTime.atZone(ZONE_ID).toInstant();
long timestamp = instant.toEpochMilli();
log.info("将 LocalDateTime [{}] 转换为时间戳 [{}]", localDateTime, timestamp);
return timestamp;
} else {
String errorMessage = String.format("写入操作接收到非 LocalDateTime 值: [%s], 类型: [%s]", value, value.getClass().getName());
log.error(errorMessage);
throw new IllegalStateException(errorMessage);
}
}
@Override
public Object read(Object value) {
if (value instanceof Long timestamp) {
LocalDateTime localDateTime = LocalDateTime.ofInstant(Instant.ofEpochMilli(timestamp), ZONE_ID);
log.info("将时间戳 [{}] 转换为 LocalDateTime [{}]", timestamp, localDateTime);
return localDateTime;
} else {
String errorMessage = String.format("无法将值 '值: [%s], 类型: [%s] 解析为 LocalDateTime", value,value.getClass().getName());
log.error(errorMessage);
throw new IllegalStateException(errorMessage);
}
}
}
字段增加注解
@Field(type = FieldType.Date)
@ValueConverter(CentralstoreLocalDateTimeConverter.class)
private LocalDateTime createTime;```
至此，插入数据和查询数据LocalDateTime类型就搞定了。其实里面还有很多细节，但是大部分估计跟我一样，只想着找到解决方案，不去想为什么会这样。所以就懒得继续深讲了。
还有很多坑，比如使用雪花算法生成的Id是19位，存入es后后两位精度丢失，这个处理起来最简单的办法就是使用String类型的作为id。或者跟上面一样 增加一个Long类型的转换器，转为String ，读取的时候再转换为Long。这个我还没有尝试，只是目前改了一下id的数据类型。
到现在为止仍然没有整合完，还有一堆坑等着我，次奥！！！次奥！！！次奥！！！
