normangyllenhaal / canal-client Goto Github PK

View Code? Open in Web Editor NEW

246.0 6.0 113.0 62 KB

spring boot canal starter 易用的canal 客户端 canal client

Java 100.00%

java canal canal-client springboot spring

canal-client's People

Contributors

Stargazers

Watchers

Forkers

just-do-it-for-everything pologood hanchuntian xue2lang weng1016 cjl1001 51392010 hailiangyuan yxs19910622 jiyulongxu huangchengkang yyc0994 junneyang chenzhaoplus tonyluo findczk wubbing0314 ruslitandrian qingo00o kotlef roamdy lyc88 lf-325 recentprogress joyyin0824 ewsq zhaomeng0113 itjinkui sunhuadong0601 sea-monster leejachin devfox88 jerry1237 coolroad psh686868 yangsumeng ryangwj tartary applenele apl0219 yujiehou lishutaoqq l5butterfly kejiaweiren chengernest mu-l yuxicun mrjxl epiphyllum cgb-redis-mysql-mongodb tracis lyx990593218 dizhaung huangdx0726 zdd10010806 sunny086 andaren mkerj ky2009888 renaultphoto gloryfromca dengjiajunjohn shone5499 wang7839186 wgldwj mosslwj cccssppp bigtian99 xzg2022 zaitanzaibao jackychan moxiaoyutop morning-reading feijiwjgq sucrewu augustyou pengbiaobeyond iikspiral foreverzang lovepli hezhaoming my-toolkit yuan-hy winkeylucky chenxxxxxxxx coderlaoliu jiangqs3 joekay777 xyxbc-git awei0916 xiaochenge666 mnilhx suplu youfl nikohxx 249241489 bankly waitforamiracle ywl-0525 lyy2002

canal-client's Issues

老师 ,maven仓库还没更新到最新呢,升级版本后,提示找不到

canal-server环境的相关搭建，建议是可以在readme中去说明下的，canal-server的ip:port启动可以附加一些截图，肯能更方便其他人理解

sun.reflect.generics.reflectiveObjects.ParameterizedTypeImpl cannot be cast to java.lang.Class

INFO 5324 --- [l-client-thread] t.j.c.client.client.AbstractCanalClient : 获取消息 Message[id=9732,entries=[header {
version: 1
logfileName: "mysql-bin.000092"
logfileOffset: 40795484
serverId: 12345
serverenCode: "UTF-8"
executeTime: 1565505699000
sourceType: MYSQL
schemaName: "changgou_goods"
tableName: "tb_sku"
eventLength: 6592
eventType: UPDATE
props {
key: "rowsCount"
value: "4"
}
}
entryType: ROWDATA

可否把canal.client升级为1.1.4

mysql枚举字段报错

mysql使用枚举字段，在Java实体类加注解 @Enumerated(EnumType.STRING)，canal报错

StringConvertUtil

没有“”判断

现在不支持配置多个example吧

事务问题

当mysql 开启事务的时候。写入多表多数据。这边能相应到但是是循环返回的，能不能一次性返回。不做多次返回

一点建议

1.字段日期类型不全面，YYYY-MM-dd hh:mm:ss.SSS 等格式无法转换，目前只能使用string类型接收
2.canal.asyncs设置为false不生效，启动会报错，原因：同一个类中2个MessageHandler用同样的methodname，@bean注解应该只会按照方法名注入第一个bean. 换用不同方法名即可
3.版本1.2.6目前无法下载

demo 跑起来 user 的属性获取不到值

开发环境 win7
canal 环境 1.3
服务器 windows12
mysql 5.7

映射相关的问题

1、对非纯字母的字段值实体映射时，属性值为空。如包含"_"的字段，属性名为驼峰；
2、ORM实体属性不支持LocalDateTime；

数字类型的字段，如果值为Null，会报错 For input string ""

比如Java中使用Integer、Long、BigDecimal等类型的字段，数据表中字段的值为null，canal就会报错：For input string ""
因为源码里面，值为Null的数字类型字段直接变成了空字符串，所以报这个错误

Column中isNull取到的是true时，Java实体属性为Number类型时会转换异常

   @Override
    <R> R newInstance(Class<R> c, List<CanalEntry.Column> columns) throws Exception {
        R object = c.newInstance();
        Map<String, String> columnNames = EntryUtil.getFieldName(object.getClass());
        for (CanalEntry.Column column : columns) {
            String fieldName = columnNames.get(column.getName());
            if (StringUtils.isNotEmpty(fieldName)) {
                FieldUtil.setFieldValue(object, fieldName, column.getValue());
            }
        }
        return object;
    }

    static Object convertType(Class<?> type, String columnValue) {
        if(columnValue==null){
            return null;
        }else if (type.equals(Integer.class)) {
            return Integer.parseInt(columnValue);
        } else if (type.equals(Long.class)) {
            return Long.parseLong(columnValue);
        } else if (type.equals(Boolean.class)) {
            return convertToBoolean(columnValue);
        } else if (type.equals(BigDecimal.class)) {
            return new BigDecimal(columnValue);
        } else if (type.equals(Double.class)) {
            return Double.parseDouble(columnValue);
        } else if (type.equals(Float.class)) {
            return Float.parseFloat(columnValue);
        } else if (type.equals(Date.class)) {
            return parseDate(columnValue);
        } else if (type.equals(java.sql.Date.class)) {
            return parseDate(columnValue);
        } else {
            return columnValue;
        }
    }