DTS_BINLOG_PARSER用于SELECT语句中,表示对数据传输服务(Data Transmission Service,简称DTS)传输的数据库binlog数据进行解析。
背景信息
注意 当前只支持解析DTS同步的RDS binlog数据。
DTS_BINLOG_PARSER解析结果是一个STRUCT类型,包含字段如下:
struct
: recordID long, -- binlog的record ID
| source string, -- 数据源信息,包括数据库类型,版本等等
| dbTable string, -- 数据表名
| recordType string, -- 操作类型,包括INSERT,DELETE,UPDATE和INIT
| recordTimestamp timestamp, -- 记录的时间戳
| extraTags string, -- 记录的属性信息,例如pk,uk等
| fields string, -- 数据表的schema信息
| beforeImages string, -- 本记录生成前的记录数据
| afterImages string -- 本记录生成后的记录数据
语法
SELECT DTS_BINLOG_PARSER(column)
FROM table
示例
SELECT
recordID,
source,
dbTable,
recordType,
recordTimestamp,
extraTags,
fields,
beforeImages,
afterImages
FROM(
SELECT DTS_BINLOG_PARSER(value) as (recordID, source, dbTable, recordType, recordTimestamp, extraTags, fields, beforeImages, afterImages)
FROM dts_binlog_table
)