flink cdc笔记（二）：flink cdc的两种开发方式

MySQL type

Flink SQL type

TINYINT

TINYINT

SMALLINT
TINYINT UNSIGNED

SMALLINT

INT
MEDIUMINT
SMALLINT UNSIGNED

INT

BIGINT
INT UNSIGNED

BIGINT

BIGINT UNSIGNED

DECIMAL(20, 0)

REAL
FLOAT

FLOAT

DOUBLE

DOUBLE

NUMERIC(p, s)
DECIMAL(p, s)
where p <= 38

DECIMAL(p, s)

NUMERIC(p, s)
DECIMAL(p, s)
where 38 < p <= 65

STRING

BOOLEAN
TINYINT(1)
BIT(1)

BOOLEAN

DATE

DATE

TIME [(p)]

TIME [(p)]

TIMESTAMP [(p)]
DATETIME [(p)]

TIMESTAMP [(p)]

CHAR(n)

CHAR(n)

VARCHAR(n)

VARCHAR(n)

BIT(n)

BINARY(⌈n/8⌉)

Oracle type

Flink SQL type

NUMBER(p, s <= 0), p - s < 3

TINYINT

NUMBER(p, s <= 0), p - s < 5

SMALLINT

NUMBER(p, s <= 0), p - s < 10

INT

NUMBER(p, s <= 0), p - s < 19

BIGINT

NUMBER(p, s <= 0), 19 <= p - s <= 38

DECIMAL(p - s, 0)

NUMBER(p, s > 0)

DECIMAL(p, s)

NUMBER(p, s <= 0), p - s > 38

STRING

FLOAT
BINARY_FLOAT

FLOAT

DOUBLE PRECISION
BINARY_DOUBLE

DOUBLE

NUMBER(1)

BOOLEAN

DATE
TIMESTAMP [(p)]

TIMESTAMP [(p)] [WITHOUT TIMEZONE]

TIMESTAMP [(p)] WITH TIME ZONE

TIMESTAMP [(p)] WITH TIME ZONE

TIMESTAMP [(p)] WITH LOCAL TIME ZONE

TIMESTAMP_LTZ [(p)]

CHAR(n)
NCHAR(n)
NVARCHAR2(n)
VARCHAR(n)
VARCHAR2(n)
CLOB
NCLOB
XMLType

STRING

BLOB
ROWID

BYTES