|
|
|
|
长按识别二维码 即可免费体验学习
文章整理于网络 如有侵权請联系删除
SERVER等数据库没有一个很好的开源JAR來处理, 公司也开发了相关的数据库的JAR有些还在开发当中,有些操作非常复杂我也没有去尝试。confluent公司有一个JDBC source connector可以用来处理INSERT+UPDATE的数据对於DELETE默认拿不到,可以通过触发器来做一个数据中转再获取
之所以单独来讲这个东西,是因为JDBC SOURCE CONNECTOR有一些很重要的东西尤其是字段的转换,否者输出的数据可能是byte类型或者是base64类型,看起来就像一堆乱码这个东西官网并没有介绍的非常详细。
在SYS.TEST表新增数据查看同步的数据:
数据的ID是number类型,但是显示的数据为:"ID":"CQ==" 很明显,这个数据我们根本看不懂这个是因为CONNECTOR JAR在转换数据出现的问题。
有人把上面链接翻译成Φ文版:
那个参数对decimal并没有意义因此需要我们自己使用query,自己添加SQL来解决
通过query,自己添加了CAST语句至于number(?,?)中的?,你根据实际情况写就可鉯
5. 重新提交TASK并查看数据
这个数据才是我们真正想看到的,另外date类型默认使用的是UNIX_TIMESTAMP,这个可以使用代码转换也可以使用CAST。
总而言之JDBC模式可以抓取ISNERT+UPDATE数据,整体没有问题需要注意的就是这个字段数据转换问题。