表比较

SDK类名：/stream/TbCmp

表比较 - 新建

SDK方法名：createTbCmp

URL

/vers/v3/sync_tb_cmp

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
tb_cmp_name	String	否		规则名
src_db_uuids	Array	否		4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuids	Array	否		40405FD3-DB86-DC8A-81C9-C137B6FDECE5
cmp_type	String	否		table
filter_table	Array	否		[user.table]
dump_thd	Number	否	抽取线程数
db_map	Object		整库映射
src	Array
db_uuid	String
auth_uuid	String
tgt	Array
db_uuid	String
auth_uuid	String
db_tb_map	Array	否			5
regex_switch	String		0：关闭正则表名，1：开启	1
src	Array		源端映射列
user	String		用户名	@word
tab	String		列名	@word
dbs	Array		对应数据库节点uuid列表		3
db_uuid	String		数据库节点uuid
auth_uuid	String		数据库节点认证uuid
tgt	Array		备端映射列
user	String		用户名
tab	String		列名
dbs	Array		对应数据库节点uuid列表		3
db_uuid	String		数据库节点uuid
auth_uuid	String		数据库节点认证uuid
col	String		列映射	{"col1":"col2", "col3":"col4"}
db_user_map	Array
src	Array		源端映射列
user	String		用户名
dbs	Array		对应数据库节点uuid列表		3
db_uuid	String		数据库节点uuid
auth_uuid	String		数据库节点认证uuid
tgt	Array		备端映射列
user	String		用户名
dbs	Array		对应数据库节点uuid列表
db_uuid	String		数据库节点uuid
auth_uuid	String		数据库节点认证uuid
polices	String	否	策略	"0|00:00
policy_type	String	否	策略类型;periodic：周期，one_time：一次性任务 ，immediate：立刻执行，interval ：每隔	one_time
interval	String		时间间隔,分钟：10m，小时：10h	10m
concurrent_table	Array	否	并发表	["hh.ww"]
try_split_part_table	Number	否	尝试并发设置 0:否 1：是	0
one_time	String	否	策略的开始时间，如果不是一次性任务为空值	2019-05-27 16:07:08
config	Object
globalConfig	Object
dkdiff_enable_step_count_table	String		启用count类型 不启用count比对：‘’ 仅count比对：onlycount 比较时count:ondiff 默认值：空	""
dkdbsource_diff_only_key_columns	Boolean		关闭：false, 开启：true	false
dkmagic_plan_max_diffs	Number		值: 整数（-1表示不限制)	10000
dkfilesink_enable_sqlpatch_file	Boolean		关闭：false, 开启：true	false
dkmagic_plan_number_tolerance_type	String		绝对差值 absolute, 相对差值 relative	absolute
dkmagic_plan_number_tolerance	Number		绝对差值 正数 相对差值 0~1
dkmagic_plan_datetime_tolerance	Number		时间容差 正数
split_table_schedule_cron	String		大表拆分类型 不拆分：空, 比较时进行拆分：immediate	""
split_table_single_segment_max_rows	Number		拆分后单个计划最大行数 正整数	5000000
split_table_result_expire_in_seconds	Number		拆分结果最大过期时间 非负整数 (单位: 秒)	0
dkdiffengine_recursion_max_steps	Number		"递归比对"最大次数 正整数（>=1）	1
dkdiffengine_recursion_interval_step_delay	Number		每次“递归”的时间间隔 值：非负整数(单位：毫秒) 默认值：0	0
dkdbsource_left_ignore_type_names	String		源端忽略类型 值：字符串 (多个类型用逗号分隔) 默认值：空	""
dkdbsource_right_ignore_type_names	String		备端忽略类型 值：字符串 (多个类型用逗号分隔) 默认值：空	""
dkdbsource_left_ignore_column_names	String		源端忽略列名 值：字符串 (多个列名用逗号分隔) 默认值：空	""
dkdbsource_right_ignore_column_names	String		备端忽略列名 值：字符串 (多个列名用逗号分隔) 默认值：空
globalconfig	Array
key	String		key
value	String		value
tolerance	Boolean		是否启用容差值比对 默认 false	false
execute_patch_after_complete	String		自动修复
data_select	Array		单表筛选配置
src_user	String
src_tb	String
src_query	String
dst_user	String
dst_tb	String
dst_query	String
compare_key	Array		比较key列
src_user	String
src_tb	String
dst_user	String
dst_tb	String
src_dst_key	String
globals	Array		全局筛选配置
src_user	String
dst_user	String
src_query	String
dst_query	String
exclude_tables	Array		排除表配置
src_user	String
src_tb	String
dst_user	String
dst_tb	String
timestamps	Object
column_name	String		时间戳字段名称
back_delay_in_seconds	Number		追溯时间间隔
end_time	String		最新时间
global_time_limit	Boolean		是否开启全局时间限制比对
v_tabmap	Array
src_user	String		源端用户
src_tb	String		源端表名
src_sql	String		源端SQL
tgt_user	String		备端用户
tgt_tb	String		备端表名
tgt_sql	String		备端SQL
key	String		key列
tb_cmp_type	String		0：绑定同步规则，12：不绑定同步规则

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否

表比较 - 操作

SDK方法名：

停止：stopTbCmp;

重启：restartTbCmp;

停止定时：cmpStopTime；

继续定时：cmpResumeTime；

立即比较：cmpImmediate ；

URL

/vers/v3/sync_tb_cmp/operate

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
tb_cmp_uuids	Array	否		@guid
operate	String	否	cmp_stop ：停止 cmp_restart ：启动 cmp_immediate：立即比较 cmp_stop_time：停止定时cmp_resume_time：继续定时 table_fix：表修复 diff_fix：表差异修复
tab	String		表修复操作，修复映射关系	["asda.asdsa"]
fix_relation	Number		表修复操作，是否修复关联表，0：关，1：开

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
data	Object
success_list	Array
code	String
message	String
tb_cmp_uuid	String
tb_cmp_name	String
fail_list	Array
code	String
message	String
tb_cmp_uuid	String
tb_cmp_name	String
all_list	Array
code	String
message	String
tb_cmp_uuid	String
tb_cmp_name	String

表比较 - 比较结果

SDK方法名：describeSyncTbCmpResult

URL

/vers/v3/sync_tb_cmp/result

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则
page	Number	否	页	1
limit	Number	否	单页记录数量	10
uuid	String	否		@guid
start_time	String	否	对应的时间字段
flag	Number		仅显示差异表：0，显示所有比对表：1
user	String		源端用户/库/schema
table	String		表

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
head_info	Object	否
total	Number	否		100
err	Number	否		10
end	String	否		2019-10-10 12:00:00
start	String	否		2019-10-10 10:00:00
use_time	String	否		3600
result_info	Object	否
rows	Array	否			10
src_user	String	否	源端用户	user
src_table_name	String	否	源端表	@first
src	Number	否	源端差异行（仅count时格式为“数量：0”）	@natural(0,100)
dst	Number		备端差异行	@natural(0,100)
aggregate	Number		是否聚合查询，0：不聚合，1：聚合（页面的查看按钮，0时不显示）
interrupt	Number		是否出现中断，0：不显示，1：显示	0
src_err	String		源端错误信息
dst_err	String		备端错误信息
total	Number	否		30
rule_related	Number		是否关联规则0：关，1：开
only_count	Number		是否仅count。0：关，1：开（1的时候不显示操作列 ）

表比较 - 详细信息

SDK方法名：describeTbCmpErrorMsg;

URL

/vers/v3/sync_tb_cmp/error_msg

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则
offset	Number	否		1
limit	Number	否		10
uuid	String	否	比较任务UUID	@guid
start_time	String	否	比较任务时间
key_name	String		Key列名
column_name	String		差异列名
src_db	String		源端数据库名
tgt_db	String		备端数据库名

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
result_info	Object	否
rows	Array	否			10
key	String		key列	@last
column	String		差异列	@first
src_row	String	否		@name
dst_row	String	否		@name
src_db	String		源端数据库名	@name
tgt_db	String		备端数据库名	test
total	Number	否		2000