前言

之前在Vertx项目中使用Tdengine，但Vertx没有Tdengine的异步JDBC驱动。所以只能使用Tdengine提供的同步JDBC驱动配合vertx.executeBlocking实现异步数据库查询。
原生的JDBC在SQL参数绑定和返回数据映射时很不方便。但当时第一印象是Mybatis和Spring结合太紧密了（实际是可以的哈），所以自己写了一个简单的SQL解析和返回数据映射的简单JDBC工具。但不能像Mybaits那样支持复杂的嵌套的类参数绑定和映射，但已经够用了。

首先要实现的功能：

• 实现SQL参数绑定，支持实体类和MAP绑定到SQL
• 实现返回值映射到实体类

实现效果：

public class PropertyMapper extends BaseMapper {


    public PropertyMapper(DataSource dataSource) {
        super(dataSource);
    }
    
    public Integer add(PropertyEntity propertyEntity) {
        // 实体类参数绑定到SQL
        return update("INSERT INTO property VALUES (#{ts}, #{value});", propertyEntity);
    }


    public List page(Long startTime, Long endTime, Long start, Long size) {
        Map params = new MapBuilder().put("startTime", startTime)
                .put("endTime", endTime)
                .put("start", start)
                .put("size", size)
                .build();
         // MAP参数绑定到SQL
        return selectList("SELECT ts, value, property_code FROM property WHERE ts >= #{startTime} AND ts <= #{endTime} ORDER BY ts DESC LIMIT #{size} OFFSET #{start}", params, PropertyEntity.class);
    }
    

public class  PropertyEntity {

    /**
     * 时间戳, 精确到ms
     */
    @TableField(typeHandler = OffsetDateTimeToLongHandler.class, value = "ts")
    private Long ts;


    /**
     * 值, 不同产品属性定义的超级表值类型不同
     */
    private Object value;
    
     /**
     * 属性编码
     */
    private String propertyCode;
}

对比下原生实现，原生的很多重复代码，同时预编译SQL中参数占位符号都是?区分度差了，每次写的时候还要将参数和?的序列对应起来（JDBC中?index从1开始）可能导致绑定参数错误，

PreparedStatementpsmt = null; 
ResultSetrs = null;
try {
    Connectionconn = null;
    conn =JdbcUtils.getConnection(); 
    Stringsql = "SELECT ts, value, property_code FROM property WHERE ts >= ? AND ts <= ? ORDER BY ts DESC LIMIT ? OFFSET ?";
    psmt =conn.prepareStatement(sql);
    //绑定参数到预编译SQL
    psmt.setLong(1,startTime);
    psmt.setLong(1,endTime);
    psmt.setLong(1,start);
    psmt.setLong(1,size);
    rs =psmt.executeQuery();
    List result = new ArrayList<>();
    while(rs.next()){
        //解析返回值
        Long ts = rs.getLong("ts"); 
        Object value = rs.getObject("value"); 
        String propertyCode = rs.getObject("property_code"); 
        PropertyEntity property = new PropertyEntity();
        property.setTs(ts);
        property.setValue(value);
        property.setPropertyCode(propertyCode);
        result.add(property);
    } 
    return result;
} catch(Exception e) { 
    throw new RuntimeException(e);
} finally{
    JdbcUtils.closeResource(conn,psmt, rs); 
}

实现SQL参数绑定，支持实体类和MAP绑定到SQL

INSERT INTO property VALUES (#{ts}, #{value});
SELECT ts, value, property_code FROM property WHERE ts >= #{startTime} AND ts <= #{endTime} ORDER BY ts DESC LIMIT #{size} OFFSET #{start}

1. 第一步将SQL中类似#{ts}替换成?，同时获取到参数占位标识符ts
2. 解析传进来的参数，如果是实体类就转换成Map，Key是属性名称，Value是属性值。如果是Map就进行第三步
3. 第1步获取的参数占位符ts，从第二步解析到的参数Map中获取到参数值存储到顺序List中
4. 填充预编译SQL参数值

/**
 * obj根据属性名映射到sql 占位符 #{ts}
 */
public static SqlAndParamDTO objMapToSqlParam(String sql, Object po) {
    return toSqlParam(sql, poToMap(po, false));
}


/**
 * map参数更加key映射到sql
 */
public static SqlAndParamDTO toSqlParam(String sql, Map paramMap) {
    if (paramMap == null || paramMap.isEmpty()) {
        return SqlAndParamDTO.builder().paramList(Collections.emptyList()).sql(sql).build();
    }
    List