3.4. Debezium Db2 连接器如何映射数据类型

布尔值

布尔值

只有快照可以从带有 BOOLEAN 类型列的表中获取。目前，Db2 上的 SQL 复制不支持 BOOLEAN，因此 Debezium 无法在这些表上执行 CDC。考虑使用其他类型的类型。

BIGINT

INT64

不适用

二进制

BYTES

不适用

BLOB

BYTES

不适用

CHAR[(N)]

字符串

不适用

CLOB

字符串

不适用

DATE

INT32

io.debezium.time.Date

代表没有时区信息的时间戳

DECFLOAT

BYTES

org.apache.kafka.connect.data.Decimal

十进制

BYTES

org.apache.kafka.connect.data.Decimal

DBCLOB

字符串

不适用

DOUBLE

FLOAT64

不适用

整数

INT32

不适用

REAL

FLOAT32

不适用

SMALLINT

INT16

不适用

时间

INT32

io.debezium.time.Time

字符串表示没有时区信息

TIMESTAMP

INT64

io.debezium.time.MicroTimestamp

字符串表示没有时区信息的时间戳

VARBINARY

BYTES

不适用

VARCHAR[(N)]

字符串

不适用

VARGRAPHIC

字符串

不适用

XML

字符串

io.debezium.data.Xml

字符串表示 XML 文档

DATE

INT32

io.debezium.time.Date

代表自时期起的天数。

TIME (0), TIME (1), TIME (2), TIME (3)

INT32

io.debezium.time.Time

代表过去的毫秒数，不包括时区信息。

TIME (4), TIME (5), TIME (6)

INT64

io.debezium.time.MicroTime

代表过去的微秒数，不包括时区信息。

TIME (7)

INT64

io.debezium.time.NanoTime

代表过去午夜的纳秒数量，不包括时区信息。

DATETIME

INT64

io.debezium.time.Timestamp

代表自 epoch 后的毫秒数，不包括时区信息。

DATE

INT32

org.apache.kafka.connect.data.Date

代表自 epoch 后的天数。

TIME([P])

INT64

org.apache.kafka.connect.data.Time

代表自午夜起的毫秒数，不包括时区信息。Db2 允许 P 在 0-7 范围内存储最多 10 个微秒的精度，但当 P 大于 3 时，这个模式会导致精度丢失。

DATETIME

INT64

org.apache.kafka.connect.data.Timestamp

代表自 epoch 起的毫秒数，不包括时区信息。

NUMERIC[(P[,S])]

BYTES

org.apache.kafka.connect.data.Decimal

scale schema 参数包含一个整数，代表十进制点被转换了多少位。connect.decimal.precision schema 参数包含一个整数，代表给定十进制值的精度。

DECIMAL[(P[,S])]

BYTES

org.apache.kafka.connect.data.Decimal

scale schema 参数包含一个整数，代表十进制点被转换了多少位。connect.decimal.precision schema 参数包含一个整数，代表给定十进制值的精度。