public static int[] buildSqlTypes(List<Class> fieldTypeArray) {

        int[] tmpFieldsType = new int[fieldTypeArray.size()];
        for (int i = 0; i < fieldTypeArray.size(); i++) {
            String fieldType = fieldTypeArray.get(i).getName();
            if (fieldType.equals(Integer.class.getName())) {
                tmpFieldsType[i] = Types.INTEGER;
            } else if (fieldType.equals(Boolean.class.getName())) {
                tmpFieldsType[i] = Types.BOOLEAN;
            } else if (fieldType.equals(Long.class.getName())) {
                tmpFieldsType[i] = Types.BIGINT;
            } else if (fieldType.equals(Byte.class.getName())) {
                tmpFieldsType[i] = Types.TINYINT;
            } else if (fieldType.equals(Short.class.getName())) {
                tmpFieldsType[i] = Types.SMALLINT;
            } else if (fieldType.equals(String.class.getName())) {
                tmpFieldsType[i] = Types.CHAR;
            } else if (fieldType.equals(Float.class.getName())) {
                tmpFieldsType[i] = Types.FLOAT;
            } else if (fieldType.equals(Double.class.getName())) {
                tmpFieldsType[i] = Types.DOUBLE;
            } else if (fieldType.equals(Timestamp.class.getName())) {
                tmpFieldsType[i] = Types.TIMESTAMP;
            } else if (fieldType.equals(BigDecimal.class.getName())) {
                tmpFieldsType[i] = Types.DECIMAL;
            } else if (fieldType.equals(Date.class.getName())) {
                tmpFieldsType[i] = Types.DATE;
            } else if (fieldType.equals(Time.class.getName())) {
                tmpFieldsType[i] = Types.TIME;
            }else if (fieldType.equals(Clob.class.getName())){
                tmpFieldsType[i] = Types.CLOB;
            } else if (fieldType.equals(NClob.class.getName())) {
                tmpFieldsType[i] = Types.NCLOB;
            } else {
                throw new RuntimeException("no support field type for sql. the input type:" + fieldType);
            }
        }

        return tmpFieldsType;
    }
By now specified class type conversion.
FIXME Follow-up has added a new type of time needs to be modified

@param fieldTypeArray
rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/JDBCTypeConvertUtils.java