总共配置了四个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_module
用numbin函数修改主键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