DbUtils无法处理H2数据库Blob到bean的byte[]的映射

问题背景

使用apache.commons.dbutils做的数据库操作，当使用的库为h2时，并且定义的java bean中存在byte[]，建表字段存在blob。当查询出java bean时，会报错:

java.sql.SQLException: Cannot set eventContent: incompatible types, cannot convert org.h2.jdbc.JdbcBlob to [B Query: SELECT * FROM

解决方案

先给解决方案，下面的排查过程爱看不看 [滑稽]

public class Blob2BytesBeanProcessor extends GenerousBeanProcessor {
    @Override
    protected Object processColumn(ResultSet rs, int index, Class<?> propType) throws SQLException {
        if (byte[].class.isAssignableFrom(propType)) {
            return rs.getBytes(index);
        }
        return super.processColumn(rs, index, propType);
    }
}


psvm() {
    QueryRunner qr = new QueryRunner();
    qr.query(sql, new BeanListHandler<>(clz, new BasicRowProcessor(new Blob2BytesBeanProcessor())), params);
}

排查过程

DbUtils在注入bean的参数时，调用的ResultSet.getObject()。但是为什么h2会报错，mysql不会呢？需要看源码

h2的ResultSet实现为JdbcResultSet，观察getObject代码。这段代码返回的Value类型为ValueLobDb

image.png

接着调用convertToDefaultObject返回了JdbcBlob类型，使用此类型注入给byte[]，所以就报错了

image.png

再来看看mysql为什么不报错，mysql的ResultSet实现类为JDBC42ResultSet，观察其getObject，一路跟踪到父类ResultSetImpl中，可以看到这么一行红色框的代码。mysql自己做了blob到byte[]的转换

image.png

解决的过程

我们知道，对象被反射创建后被参数注入，这个过程一般是调用无参构造+setter完成的，那么可以从这方面入手，重载set函数。

public void setContent(byte[] bytes) {

}

// 注：JdbcBlob是Blob的子类
public void setContent(Blob blob) {

}

但是实验下来依旧报错。那就离谱起来，理论上来说如果源码中的参数注入是用的setter，那么应当不会有问题，下面只能通过看原来找答案了。

oh my god，它竟然用的java的内省玩的。内省会得到field的writer与reader函数，并且只会得到一个，所以set重载方案失效！。

image.png

那h2不支持Blob到byte[]的转换，我构造函数只保留setContent(Blob blob)，让mysql自己识别转换成blob，测试下来是不行的，MySQL只会转成byte[]，然后会报byte[]转Blob的错。

这里是有兜底方案的，就是将content改成Blob类型。但是这样就在get函数中做Blob到byte[]的转换，不够优雅。

百度与谷歌无果，只能继续跟一下源码，看能不能找到可扩展的地方。

省略掉跟踪源码的过程，直接说结果。

在BeanProcessor(用于对响应bean的创建与参数注入)的polulateBean方法中进行的参数注入

image.png

对每个参数的注入是调用processColumn()方法。并且processColumn是个protected修饰的，也就是说，我们可以重写该方法，判断propType是否为byte[]类型，如果是，则直接调用ResultSet.getBytes()。

DbUtils直接给我们开了个口子，让我可以自己实现参数类型的转换！看来大佬的代码考虑了非常充分的扩展..

public class Blob2BytesBeanProcessor extends GenerousBeanProcessor {
    @Override
    protected Object processColumn(ResultSet rs, int index, Class<?> propType) throws SQLException {
        // 如果需求中有Byte[]包装类型，那这里再多一行判断即可
        if (byte[].class.isAssignableFrom(propType)) {
            return rs.getBytes(index);
        }
        return super.processColumn(rs, index, propType);
    }
}

问题总结

DbUtils使用java内省获得到字段的writer与reader，然后使用ResultSet.getObject得到数据库结果，通过writer进行参数注入。

留好扩展的口子，对于后面来找问题的人来说是多么幸福的事情。

最后编辑于：2021.04.13 15:29:11