0


【开发问题】flink-cdc不用数据库之间的,不同类型的转化

不同的数据库之期间数据类型转化

问题来源与原因

我一开始是flink-cdc,oracle2Mysql,sql
我一开始直接用的oracle【date】类型,mysql【date】类型,sql的校验通过了,但是真正操作数据的时候报错,告诉我oracle的数据格式的日期数据,不可以直接插入到mysql格式的日期数据,说白了就是数据格式不一致导致的

解决过程,思路错误,导致各种错误

错误思路是什么

我想的是既然格式不对,就自己手动把格式转一下,然后变成mysql认可的格式就好了,这之间,报了很多错误,又是方法不对,又是,方法参数类型不对。反正这个路其实是错误的
错误方式1:
在这里插入图片描述
错误方式2:
在这里插入图片描述
错误方式3:
在这里插入图片描述
各种转化错误

正确解决方式,找官网对应的链接器,数据转化

连接器jdbc的地址
在这里插入图片描述
在这里插入图片描述
MySQL typeOracle typePostgreSQL typeSQL Server typeFlink SQL typeTINYINTTINYINTTINYINTSMALLINT TINYINT UNSIGNEDSMALLINT INT2 SMALLSERIAL SERIAL2SMALLINTSMALLINTINT MEDIUMINT SMALLINT UNSIGNEDINTEGER SERIALINTINTBIGINT INT UNSIGNEDBIGINT INT UNSIGNEDBIGINTBIGINTBIGINT UNSIGNEDDECIMAL(20, 0)BIGINTBIGINTBIGINTFLOATBINARY_FLOATREAL FLOAT4REALFLOATDOUBLE DOUBLE PRECISIONBINARY_DOUBLEFLOAT8 DOUBLE PRECISIONFLOATDOUBLENUMERIC(p, s) DECIMAL(p, s)SMALLINT FLOAT(s) DOUBLE PRECISION REAL NUMBER(p, s)NUMERIC(p, s) DECIMAL(p, s)NUMERIC(p, s) DECIMAL(p, s)DECIMAL(p, s)BOOLEAN TINYINT(1)BOOLEANBITBOOLEANDATEDATEDATEDATEDATETIME [§]DATETIME [§] [WITHOUT TIMEZONE]TIME(0)TIME [§] [WITHOUT TIMEZONE]DATETIME [§]TIMESTAMP [§] [WITHOUT TIMEZONE]TIMESTAMP [§] [WITHOUT TIMEZONE]DATETIME DATETIME2TIMESTAMP [§] [WITHOUT TIMEZONE]CHAR(n) VARCHAR(n) TEXTCHAR(n) VARCHAR(n) CLOBCHAR(n) CHARACTER(n) VARCHAR(n) CHARACTER VARYING(n) TEXTCHAR(n) NCHAR(n) VARCHAR(n) NVARCHAR(n) TEXT NTEXTSTRINGBINARY VARBINARY BLOBRAW(s) BLOBBYTEABINARY(n) VARBINARY(n)BYTESARRAYARRAY


本文转载自: https://blog.csdn.net/u010978399/article/details/131914289
版权归原作者 吃素的哈士奇 所有, 如有侵权,请联系我们删除。

“【开发问题】flink-cdc不用数据库之间的,不同类型的转化”的评论:

还没有评论