7.4. Debezium PostgreSQL 连接器如何映射数据类型

布尔值

布尔值

不适用

BIT(1)

布尔值

不适用

BIT( > 1)

BYTES

io.debezium.data.Bits

。length 模式参数包含一个代表位数的整数。生成的 byte[] 包含 little-endian 格式的位，并的大小包含指定的位数。例如，numBytes = n/8 +（n % 8 == 0 ?0 : 1） 其中 n 是位数。

位不同[(M)]

BYTES

io.debezium.data.Bits

。length 模式参数包含一个整数，代表位数(2^31 - 1，如果没有为列提供长度)。生成的 byte[] 包含 little-endian 表单中的位，并根据内容的大小。指定的大小 (M) 存储在 io.debezium.data.Bits 类型的 length 参数中。

SMALLINT,SMALLSERIAL

INT16

不适用

整数， 串行

INT32

不适用

BIGINT,BIGSERIAL OID

INT64

不适用

REAL

FLOAT32

不适用

双精度

FLOAT64

不适用

CHAR[(M)]

字符串

不适用

VARCHAR[(M)]

字符串

不适用

CHARACTER[(M)]

字符串

不适用

CHARACTER VARYING[(M)]

字符串

不适用

TIMESTAMPTZ ，带有时区的时间戳

字符串

io.debezium.time.ZonedTimestamp

是带有时区信息的时间戳的字符串，其中时区为 GMT。

TIMETZ ，带有时区的时间

字符串

io.debezium.time.ZonedTime

是时区信息的字符串，其中时区为 GMT。

间隔 [P]

INT64

io.debezium.time.MicroDuration
（默认）

使用每月平均值的 365.25 / 12.0 公式的间隔的大约微秒数。

间隔 [P]

字符串

io.debezium.time.Interval
（当 interval.handling.mode 设置为 字符串）

遵循特征 P<years>Y<months>Y<months>M<days>DT<hours>H<minutes>M<seconds>S 的间隔值的字符串表示，例如 P1Y2M3DT4H5M6.78S。

BYTEA

BYTES 或 STRING

N/a

遵循原始字节（默认）、base64 编码的字符串或 base64-url-safe-encoded 字符串或十六进制编码的字符串，具体取决于连接器 的二进制处理模式 设置。

Debezium 只支持 Postgres bytea_output 配置值 hex。有关 PostgreSQL 二进制文件数据类型的更多信息，请参阅 PostgreSQL 文档。

JSON, JSONB

字符串

io.debezium.data.Json

包含 JSON 文档、数组或 scalar 的字符串表示。

XML

字符串

io.debezium.data.Xml

包含 XML 文档的字符串表示。

UUID

字符串

io.debezium.data.Uuid

包含 PostgreSQL UUID 值的字符串表示。

点

STRUCT

io.debezium.data.geometry.Point

包含有两个 FLOAT64 字段的结构，(x,y)。每个字段代表 geometric 点的协调。

LTREE

字符串

io.debezium.data.Ltree

包含 PostgreSQL LTREE 值的字符串表示。

CITEXT

字符串

不适用

INET

字符串

不适用

INT4RANGE

字符串

N/a

整数范围。

INT8RANGE

字符串

N/A

range of bigint.

NUMRANGE

字符串

N/A

范围 数字.

TSRANGE

字符串

n/a

包含时间戳范围的字符串表示，没有时区。

TSTZRANGE

字符串

n/a

包含带有本地系统时区的时间戳范围的字符串表示。

DATERANGE

字符串

n/a

包括代表一个日期范围的字符串。它始终具有专用的上限。

ENUM

字符串

io.debezium.data.Enum

包含 PostgreSQL ENUM 值的字符串表示。允许的值集合在 允许的 schema 参数中维护。

DATE

INT32

io.debezium.time.Date

代表自时期起的天数。

TIME (1 )、TIME (2), TIME (3)

INT32

io.debezium.time.Time

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

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

INT64

io.debezium.time.MicroTime

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

TIMESTAMP (1), TIMESTAMP (2), TIMESTAMP (3)

INT64

io.debezium.time.Timestamp

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

TIMESTAMP (4), TIMESTAMP (5), TIMESTAMP (6), TIMESTAMP

INT64

io.debezium.time.MicroTimestamp

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

DATE

INT32

io.debezium.time.Date

代表自时期起的天数。

TIME([P])

INT64

io.debezium.time.MicroTime

以微秒为单位代表时间值，不包括时区信息。PostgreSQL 允许精度 P 在范围 0-6 中存储最多 microsecond 精度。

TIMESTAMP (1) , TIMESTAMP (2), TIMESTAMP (3)

INT64

io.debezium.time.Timestamp

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

TIMESTAMP (4) , TIMESTAMP (5), TIMESTAMP (6), TIMESTAMP

INT64

io.debezium.time.MicroTimestamp

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

DATE

INT32

org.apache.kafka.connect.data.Date

代表自 epoch 后的天数。

TIME([P])

INT64

org.apache.kafka.connect.data.Time

代表自午夜起的毫秒数，不包括时区信息。PostgreSQL 允许 P 在范围 0-6 中存储到 microsecond 精度，但当 P 大于 3 时，这个模式会导致精度丢失。

TIMESTAMP([P])

INT64

org.apache.kafka.connect.data.Timestamp

代表自 epoch 起的毫秒数，不包括时区信息。PostgreSQL 允许 P 在范围 0-6 中存储到 microsecond 精度，但当 P 大于 3 时，这个模式会导致精度丢失。

NUMERIC[(M[,D])]

BYTES

org.apache.kafka.connect.data.Decimal

scale schema 参数包含一个整数，代表十进制点被转换了多少位。

DECIMAL[(M[,D])]

BYTES

org.apache.kafka.connect.data.Decimal

scale schema 参数包含一个整数，代表十进制点被转换了多少位。

MONEY[(M[,D])]

BYTES

org.apache.kafka.connect.data.Decimal

scale schema 参数包含一个整数，代表十进制点被转换了多少位。scale 模式参数由 money.fraction.digits 连接器配置属性决定。

数字

STRUCT

io.debezium.data.VariableScaleDecimal

Contains 一个结构，它有两个字段：类型为 INT32 的扩展，其中包含未 扩展 格式的传输 值 和值 BYTES。

十进制

STRUCT

io.debezium.data.VariableScaleDecimal

Contains 一个结构，它有两个字段：类型为 INT32 的扩展，其中包含未 扩展 格式的传输 值 和值 BYTES。

NUMERIC[(M[,D])]

FLOAT64

DECIMAL[(M[,D])]

FLOAT64

MONEY[(M[,D])]

FLOAT64

NUMERIC[(M[,D])]

字符串

DECIMAL[(M[,D])]

字符串

MONEY[(M[,D])]

字符串

HSTORE

字符串

io.debezium.data.Json

示例：使用 JSON 转换的输出表示为 {"key" : "val"}

HSTORE

MAP

n/a

示例：使用 JSON 转换程序的输出表示为 {"key" : "val"}

INET

字符串

N/a

IPv4 和 IPv6 网络

CIDR

字符串

N/a

IPv4 和 IPv6 主机和网络

MACADDR

字符串

N/A

MAC 地址

MACADDR8

字符串

N/a

MAC 地址( EUI-64 格式)

GEOMETRY
（计划）

STRUCT

io.debezium.data.geometry.Geometry

包含有两个字段的结构：

有关格式详情，请参阅 Open Geospatial Consortium Simple Features Access specification。

GEOGRAPHY
（设备）

STRUCT

io.debezium.data.geometry.Geography

包含有两个字段的结构：

有关格式详情，请参阅 Open Geospatial Consortium Simple Features Access specification。