标签：cep cut table 注册 nmap pac 表数据 datetime err
项目中因需要保留时区信息, 前后台交互采用时间格式为标准ISO8601格式时间, 例如: 2018-11-11T11:48:23.168+08:00,
数据库使用VARCHAR存储. 某日, 系统写入数据依然正常, 但是系统查询突然全部抛异常:
Caused by: java.time.format.DateTimeParseException: Text ‘2018-11-10 03:11:11.0‘ could not be parsed at index 10
at java.time.format.DateTimeFormatter.parseResolved0(DateTimeFormatter.java:1949)
at java.time.format.DateTimeFormatter.parse(DateTimeFormatter.java:1851)
at java.time.OffsetDateTime.parse(OffsetDateTime.java:402)
at java.time.OffsetDateTime.parse(OffsetDateTime.java:387)
at com.example.demo.mapper.typehandler.OffsetDateTimeTypeHandler.getNullableResult(OffsetDateTimeTypeHandler.java:34)
at com.example.demo.mapper.typehandler.OffsetDateTimeTypeHandler.getNullableResult(OffsetDateTimeTypeHandler.java:13)
at org.apache.ibatis.type.BaseTypeHandler.getResult(BaseTypeHandler.java:66)
... 57 more建表sql
create table task(
task_id varchar(32) primary key ,
create_at varchar(32) not null
);entity
@Data
@EqualsAndHashCode(of = "taskId")
public class Task {
private String taskId;
private OffsetDateTime createAt;
}插入sql xml片段:
<insert id="saveTask" parameterType="com.example.demo.entity.Task">
insert into task(task_id, create_at) values (#{taskId}, #{createAt})
</insert>查询sql xml片段
<select id="getTaskById" resultType="com.example.demo.entity.Task">
select task_id, create_at from task where task_id = #{taskId}
</select>自定义TypeHandler
@MappedTypes(OffsetDateTime.class)
@MappedJdbcTypes(value = JdbcType.VARCHAR)
public class OffsetDateTimeTypeHandler extends BaseTypeHandler<OffsetDateTime> {
private final DateTimeFormatter formatter = DateTimeFormatter.ISO_OFFSET_DATE_TIME;
@Override
public void setNonNullParameter(PreparedStatement ps, int i, OffsetDateTime parameter, JdbcType jdbcType) throws SQLException {
if (parameter == null){
ps.setNull(i, Types.VARCHAR);
}else {
ps.setString(i, formatter.format(parameter));
}
}
@Override
public OffsetDateTime getNullableResult(ResultSet rs, String columnName) throws SQLException {
String text = rs.getString(columnName);
if (text == null){
return null;
}
return OffsetDateTime.parse(text);
}
@Override
public OffsetDateTime getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
String text = rs.getString(columnIndex);
if (text == null){
return null;
}
return OffsetDateTime.parse(text);
}
@Override
public OffsetDateTime getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
String text = cs.getString(columnIndex);
if (text == null){
return null;
}
return OffsetDateTime.parse(text);
}
}从异常信息可知: 是因为 ‘2018-11-10 03:11:11.0‘ 字符串转换为 OffsetDateTime出现了错误.
<insert id="saveTask" parameterType="com.example.demo.entity.Task"> insert into task(task_id, create_at) values(#{taskId}, #{createAt, jdbcType = VARCHAR}) </insert> 或者: <insert id="saveTask" parameterType="com.example.demo.entity.Task"> insert into task(task_id, create_at) values(#{taskId}, #{createAt, typeHandler = com.example.demo.mapper.typehandler.OffsetDateTimeTypeHandler}) </insert>
第三种: 修改自定义TypeHandler的@MappedJdbcTypes(推荐)
由@MappedJdbcTypes(value = JdbcType.VARCHAR) ---> @MappedJdbcTypes(value = JdbcType.VARCHAR, includeNullJdbcType = true)或者将自定义的TypeHandler上的 @MappedJdbcTypes(value = JdbcType.VARCHAR)去掉
查看数据库表数据, 发现task表数据如下:
+-----------+-----------------------+
| task_id | create_at |
+-----------+-----------------------+
| 123456789 | 2018-11-10 03:11:11.0 |
+-----------+-----------------------+毫无疑问, 写入数据库的格式发生了改变, 于是开始怀疑有人改动代码,
接着查询git提交记录, 发现pom.xml文件的依赖发生了改动, 其他源码均无变动, 改动为:
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.0</version>
</dependency>
升级到:
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.1</version>
</dependency>
对应Mybatis版本由3.4.4升级到3.4.5 于是开始怀疑这个问题是由于Mybatis版本升级带来的, 经查看源码发现,mybatis 3.4.5发布的版本里面, 内置了jsr310时间类型的TypeHandler.
在org.apache.ibatis.type.TypeHandlerRegistry新增了这样一段代码:
this.register(Instant.class, InstantTypeHandler.class);
this.register(LocalDateTime.class, LocalDateTimeTypeHandler.class);
this.register(LocalDate.class, LocalDateTypeHandler.class);
this.register(LocalTime.class, LocalTimeTypeHandler.class);
this.register(OffsetDateTime.class, OffsetDateTimeTypeHandler.class);
this.register(OffsetTime.class, OffsetTimeTypeHandler.class);
this.register(ZonedDateTime.class, ZonedDateTimeTypeHandler.class);
this.register(Month.class, MonthTypeHandler.class);
this.register(Year.class, YearTypeHandler.class);
this.register(YearMonth.class, YearMonthTypeHandler.class);
this.register(JapaneseDate.class, JapaneseDateTypeHandler.class);继续debug发现, Mybatis中TypeHandler是使用一个双层Map存储的:
private final Map<Type, Map<JdbcType, TypeHandler<?>>> TYPE_HANDLER_MAP = new ConcurrentHashMap<Type, Map<JdbcType, TypeHandler<?>>>();再查看注册TypeHandler的核心代码如下:
private <T> void register(Type javaType, TypeHandler<? extends T> typeHandler) {
MappedJdbcTypes mappedJdbcTypes = typeHandler.getClass().getAnnotation(MappedJdbcTypes.class);
if (mappedJdbcTypes != null) {
for (JdbcType handledJdbcType : mappedJdbcTypes.value()) {
register(javaType, handledJdbcType, typeHandler);
}
if (mappedJdbcTypes.includeNullJdbcType()) {
register(javaType, null, typeHandler);
}
} else {
register(javaType, null, typeHandler);
}
}先注册的是Mybatis提供的org.apache.ibatis.type.OffsetDateTimeHandler, 后注册的是我们自定义的OffsetDateTimeHandler.
两个Type的注册信息中, javaType都一样, 区别在于, Mybatis提供的TypeHandler注册信息中二级key(JdbcType)为null, 而我们自定义的TypeHandler二级key为
JdbcType.VARCHAR, 而我们的插入sql片段中,对于jdbcType未指定,默认值也就是null.
所以在写入的时候, 使用的是Mybatis提供的TypeHandler.
通过注册TypeHandler源码,我们发现, 无论是去掉自定义TypeHandler上的@MappedJdbcTypes还是设置这个注解的includeNullJdbcType = true, 都可
以在注册我们自定义的TypeHandler的时候, 替换掉Mybatis提供的TypeHandler.
继续debug, 我们现在还剩下一个疑问, 那为什么在查询的时使用的又是我们自定义的OffsetDateTimeHandler呢?
这个我们分两点来看:
5.1. 如何确定jdbcType?
5.2. 如何确定javaType?
先看第一个问题: 如何确定jdbcType?
在PreparedStatementHandler查找到如下代码:
public <E> List<E> query(Statement statement, ResultHandler resultHandler) throws SQLException {
PreparedStatement ps = (PreparedStatement) statement;
ps.execute();
return resultSetHandler.<E> handleResultSets(ps);
}但是这个就是mybatis的边界了,再继续深入可以查看ps.execute具体在MySql的驱动中如何实现,
现在只知道结果就是mysql提供的驱动包会将查询结果集包装成一个ResultSet具体实现是(com.mysql.cj.jdbc.result.ResultSet),
然后通过ResultSet#getMetaData这个接口就可以拿到每一列的sqlType(sqlType和JdbcType是一一对应的).
再看第二个问题: 如何确定javaType?
就以当前我们自己没有定义任何resultMap来分析一下, 核心代码在DefaultResultSetHandler, 如下:
private List<UnMappedColumnAutoMapping> createAutomaticMappings(ResultSetWrapper rsw, ResultMap resultMap, MetaObject metaObject, String columnPrefix) throws SQLException {
final String mapKey = resultMap.getId() + ":" + columnPrefix;
List<UnMappedColumnAutoMapping> autoMapping = autoMappingsCache.get(mapKey);
if (autoMapping == null) {
autoMapping = new ArrayList<UnMappedColumnAutoMapping>();
final List<String> unmappedColumnNames = rsw.getUnmappedColumnNames(resultMap, columnPrefix);
for (String columnName : unmappedColumnNames) {
String propertyName = columnName;
if (columnPrefix != null && !columnPrefix.isEmpty()) {
// When columnPrefix is specified,
// ignore columns without the prefix.
if (columnName.toUpperCase(Locale.ENGLISH).startsWith(columnPrefix)) {
propertyName = columnName.substring(columnPrefix.length());
} else {
continue;
}
}
final String property = metaObject.findProperty(propertyName, configuration.isMapUnderscoreToCamelCase());
if (property != null && metaObject.hasSetter(property)) {
if (resultMap.getMappedProperties().contains(property)) {
continue;
}
final Class<?> propertyType = metaObject.getSetterType(property);
if (typeHandlerRegistry.hasTypeHandler(propertyType, rsw.getJdbcType(columnName))) {
final TypeHandler<?> typeHandler = rsw.getTypeHandler(propertyType, columnName);
autoMapping.add(new UnMappedColumnAutoMapping(columnName, property, typeHandler, propertyType.isPrimitive()));
} else {
configuration.getAutoMappingUnknownColumnBehavior()
.doAction(mappedStatement, columnName, property, propertyType);
}
} else {
configuration.getAutoMappingUnknownColumnBehavior()
.doAction(mappedStatement, columnName, (property != null) ? property : propertyName, null);
}
}
autoMappingsCache.put(mapKey, autoMapping);
}
return autoMapping;
}大概我们可以看出基本流程就是:
column_name -----> property ----> setterMethod ----> propertyType ----> TypeHandler
例如: create_at 通过在mybatis-config.xml中定义的
<setting name="mapUnderscoreToCamelCase" value="true"/>
得到property为 ‘createAt‘, 然后结合ResultType找到createAt的set方法, 找到set方法的参数类型为OffsetDateTime,
也就是 javaType = OffsetDateTime.class, 再结合之前的jdbcType从TypeHandlerRegistry中查找得到TypeHandler为我们自定义的OffsetDateTimeTypeHandler.
Mybatis 3.4.4 升级到3.4.5+版本导致读写操作的时候使用不同的TypeHandler的解决方案
标签：cep cut table 注册 nmap pac 表数据 datetime err
原文地址：https://www.cnblogs.com/index-xyz/p/9942628.html
