Clob转String报错SQLRecoverableException: 关闭的连接

背景

接到任务需要做一个数据上传的功能，主要是从20多个视图中查询数据，然后调用接口上传数据。

经过

我把这个功能分成两部分：数据查询、数据上传。

上传数据的接口只有一个，通过指定一个参数来区分不同类型的数据，而查询数据的视图中的数据不需要我们处理，因此决定查询数据时使用map来接收参数。

这么做的原因有几个：

1. 视图字段与接口参数不完全匹配，有的少了几个字段
2. 接口参数名是驼峰命名，视图也是驼峰命名但因为是Oracle数据库不区分大小写所以实际是大写
3. 不能通过SQL写下划线别名，因为添加下划线后别名长度会超过30

因此，我决定直接使用SELECT *查询数据，使用List<Map<String,Object>>来接收数据。

但是还有个问题，接口中有部分数据是存在对象嵌套的，部分字段是List类型。

List类型的数据不是通过关联查询得到的，而是需要另外写一个查询去查。

考虑到以上，我决定mapper层查询数据使用map来接收，然后在service层先查询数据再转换成对象。

数据查询编写了一个DataQueryMapper和DataQueryService:

public interface DataQueryMapper {
    List<Map<String, Object>> getPage(@Param("req") PatientReq req);
}

@Service
@RequiredArgsConstructor
public class DataQueryService implements IDataQueryService {
    
    private final DataQueryMapper baseMapper;
    
    @Override
    public List<PageData> getPage(PatientReq req) {
        return NcBeanUtil.mapToBean(baseMapper.getPage(req), PageData.class);
    }
}

BeanUtil用于转换对象：

public class NcBeanUtil {

    private static final Map<Class<?>, Map<String, Field>> CACHE = new HashMap<>();

    private NcBeanUtil() {

    }

    public static <T> T mapToBean(Map<String, Object> map, Class<T> clazz) {
        if (CollUtil.isEmpty(map)) {
            return null;
        }
        Map<String, Field> fieldMap = getFieldMap(clazz);
        T instance = ReflectUtil.newInstance(clazz);
        for (Map.Entry<String, Object> entry : map.entrySet()) {
            String key = entry.getKey();
            Object value = entry.getValue();
            Field field = fieldMap.get(key);
            if (field == null) {
                continue;
            }
            Class<?> fieldType = field.getType();
            Object fieldValue = Convert.convert(fieldType, value);
            ReflectUtil.setFieldValue(instance, field, fieldValue);
        }
        return instance;
    }

    public static <T> List<T> mapToBean(List<Map<String, Object>> mapList, Class<T> clazz) {
        if (CollUtil.isEmpty(mapList)) {
            return Collections.emptyList();
        }
        return mapList.stream().map(map -> NcBeanUtil.mapToBean(map, clazz)).collect(Collectors.toList());
    }

    private static <T> Map<String, Field> getFieldMap(Class<T> clazz) {
        if (CACHE.containsKey(clazz)) {
            return CACHE.get(clazz);
        }
        Map<String, Field> fieldMap = new HashMap<>();
        Field[] fields = ReflectUtil.getFields(clazz);
        for (Field field : fields) {
            String name = field.getName();
            String key = name.toUpperCase(Locale.ROOT);
            fieldMap.put(key, field);
        }
        CACHE.put(clazz, fieldMap);
        return fieldMap;
    }

}

很巧妙的先使用Bean的field定义转换成大写，与原先的field映射存入map，转换时使用map获取到实际的field并填充转换后的值。

报错

运行以后，效果很好，只是在查询其中几个视图时出现了报错：

SQLRecoverableException: 关闭的连接
cn.hutool.core.convert.ConvertException: SQLRecoverableException: 关闭的连接
	at cn.hutool.core.convert.impl.StringConverter.clobToStr(StringConverter.java:56)
	at cn.hutool.core.convert.impl.StringConverter.convertInternal(StringConverter.java:32)
	at cn.hutool.core.convert.impl.StringConverter.convertInternal(StringConverter.java:22)
	at cn.hutool.core.convert.AbstractConverter.convert(AbstractConverter.java:58)
	at cn.hutool.core.convert.ConverterRegistry.convert(ConverterRegistry.java:207)
	at cn.hutool.core.convert.ConverterRegistry.convert(ConverterRegistry.java:247)
	at cn.hutool.core.convert.Convert.convertWithCheck(Convert.java:753)
	at cn.hutool.core.convert.Convert.convert(Convert.java:706)
	at cn.hutool.core.convert.Convert.convert(Convert.java:677)
	at cn.hutool.core.convert.Convert.convert(Convert.java:651)
	at ...mapToBean(NcBeanUtil.java:36)
	...
	at java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197)
	at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1625)
	at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509)
	at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499)
	at java.base/java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921)
	at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.base/java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682)
	at ...NcBeanUtil.mapToBean(NcBeanUtil.java:50)
	...

奇怪的现象发生了，为什么在mapToBean的时候会发生SQL相关的异常？

顺着堆栈，发现是NcBeanUtil在使用hutool转换时发生异常

public static <T> T mapToBean(Map<String, Object> map, Class<T> clazz) {
    ...
    Object fieldValue = Convert.convert(fieldType, value);
    ...
}

解决

百思不得其解，这种报错也是第一次见，为什么连接会关闭？

上网查询一番，发现都是说数据库连接断开之类的，但是重复实验很多次，只有特定几个查询会发生这种异常。

于是在转换时添加了日志，查看是什么原因导致的

public static <T> T mapToBean(Map<String, Object> map, Class<T> clazz) {
   ...
        try {
            Object fieldValue = Convert.convert(fieldType, value);
            ReflectUtil.setFieldValue(instance, field, fieldValue);
        } catch (Exception e) {
            log.error("Convert异常: {}:{} valueType = {}, fieldType = {}", key, value, value == null ? null : value.getClass(), fieldType);
            throw e;
        }
    ...
}

结果出来了

Convert异常: NCMARITALHISTORY:oracle.sql.CLOB@6bc2903b valueType = class oracle.sql.CLOB, fieldType = class java.lang.String

valueType是Clob，fieldType是String，异常是在Clob转String时发生的。

private static String clobToStr(Clob clob) {
    Reader reader = null;
    try {
        reader = clob.getCharacterStream();
        return IoUtil.read(reader);
    } catch (SQLException e) {
        throw new ConvertException(e);
    } finally {
        IoUtil.close(reader);
    }
}

继续在网络上检索，看到有这样一个说法

oracle-解析CLOB格式字段转String

SQL CLOB是 内置类型，它将字符大对象(Character Large Object) 存储为数据库表某一行中的一个列值。默认情况下，驱动程序使用 SQL locator(CLOB)实现 Clob 对象，这意味着 CLOB 对象包含一个指向 SQL CLOB 数据的逻辑指针而不是数据本身。Clob 对象在它被创建的事务处理期间有效。

Clob 对象在它被创建的事务处理期间有效

莫非是查询后连接关闭或者没有开启事务，连接先关闭了再把Clob转String导致报错？

尝试添加了@Transaction注解

@Override
@Transactional(rollbackFor = Exception.class)
public List<PageData> get=Page(PatientReq req) {
    return NcBeanUtil.mapToBean(baseMapper.getPage(req), PageData.class);
}

没想到轻松解决了。