总共配置了四个etl同步规则用例用来进行数据比对测试(比对数据内容与条数)
测试环境:MySQL–>Oracle
1.添加where过滤条件 2.重命名列名 3.修改非主键列数据内容 4.修改主键列数据内容

配置四张表的etl同步规则

##account_rel_menu_api
添加where过滤条件( id > 11120475 and url like '%index%' )
PASS(SQLTYPE=(ON=INSERT,IGNORE=UPDATE,ON=UPDATE),CONDITION=( id > 11120475 and url like '%index%' ))

##account_api
将列url重命名成mobile_url
COLMAP(column_name=url,optype=rename,data_type=string,after_column_name=mobile_url)

##bus_parameter_module_image
用replace函数修改moduletype列内容
COLMAP(column_name=moduletype,optype=modify,data_type=string,function=(@REPLACE(moduletype,'KAFKA','zcbus_kafka')))

##bus_parameter_modulenumbin函数修改主键id列内容
COLMAP(column_name=id,optype=modify,data_type=number,function=(@NUMBIN(id)))

比对规则配置

1.表account_rel_menu_api(where过滤条件)

将where条件添加到源端条件中
比对数据记录条数:

比对结果:

比对数据内容:

比对结果:

2.表account_api(重命名列)

比对数据条数时默认配置即可,比对数据内容配置比队列时去掉修改列url
比对数据记录条数:

比对结果:

比对数据内容:

比对结果:

3.表bus_parameter_module_image(修改非主键列)

比对数据条数时默认配置即可,比对数据内容配置比队列时去掉修改列moduletype
比对数据记录条数:

比对结果:

比对数据记录条数:

比对结果:

4.表bus_parameter_module(修改主键列)

比对数据条数时默认配置即可,由于比对数据内容是基于主键或唯一索引,id列为主键列,比对数据内容配置比队列时去掉id列,会报错
比对数据记录条数:

比对结果:

比对数据记录条数:

比对结果:

文档更新时间: 2022-10-24 22:02   作者:liyue