Mysql同步

November 23, 2021About 33 min

Mysql同步

SDK类名：/active/Mysql

-------同步规则---

示例接口描述

URL

/mysql同步规则

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql规则管理-新建

SDK 方法名：createMysqlRule

URL

//stream/rule

Method

POST

Request

名称	类型	必选	初始值	简介
mysql_name	Boolean	否	@name
tgt_db_uuid	Array	否	D42BF707-C971-EEA9-521F-BB0F3F7A92FC	备端数据库（分发时为多选）
tgt_type	String	否	oracle	备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum
start_rule_now	Number	否	0
dbmap_topic	String	否		kafka类型，整库映射
map_type	String	否	table	映射方式库映射database 表映射：table 整库映射 all
tab_map	Array	否		表映射
src_table	String	否	src_table
dst_table	String	否	dst_table
src_db	String	否	111
dst_db	String	否	222
full_sync	Number	否	0	全量同步当备端类型不是mysql时全量同步不用选择同步方式默认否
incre_sync	Number	否	1	增量同步
model_type	String	否	1:0	模式汇聚n:1, 分发:1:n，主-主:1:1 主-从:1:0
full_sync_mode	String	否	auto	全同步方式，逻辑:logic 物理 physics 自动 auto（汇聚只有逻辑一种）
db_set	Object	否		高级设置->数据库设置
binlog_row_image	String	否	full	full
default_storage_engine	String	否	innoDB	innoDB
sync_binlog	String	否	1	1
innodb_flush_log	String	否	2
innodb_flush_method	String	否	O_DIRECT	O_DIRECT
binlog_format	String	否	row	row
open_files_limit	String	否	65535	65535
server_id	String	否	123456	随机值
expire_logs_days	String	否	7	7
nat_mode	Number	否	0	否：0 是 1，默认为否，如果选择是，则显示出如下内容
ip	String	否		外网 ip
max_allowed_packet	String	否	52	52m
src_db_uuid	Array	否	1B1153F6-DAD9-BC39-888A-A743FCC208E5	汇聚可一次传多个已逗号隔开
primary_db_one	String	否		(主-主有值其他情况空)主数据库1
primary_map_type_one	String	否		映射方式库，表，整库映射(主主其他为空)
primary_map_one	String	否		主-主有值其他情况空) 映射下传的值 {111:222, 111:333}
primary_db_two	String	否		主-主有值其他情况空)主数据库2
primary_map_type_two	String	否		主-主有值其他情况空)映射方式
primary_map_two	String	否		主-主有值其他情况空)传递值
db_map	Array	否		库映射
dst_table	String	否
src_table	String	否
modify	Boolean	否	false
start_src_db_set	Number	否	0	开启源端配置
start_dst_db_set	Number	否	0
dst_db_set	Object	否		备端数据库设置
binlog_format	String	否
binlog_row_image	String	否
default_storage_engine	String	否
sync_binlog	String	否
innodb_flush_log	String	否
innodb_flush_method	String	否
max_allowed_packet	String	否
open_files_limit	String	否
server_id	String	否
expire_logs_days	String	否
nat_mode	Number	否
ip	String	否
dst_full_sync_set	Object	否
support_ddl	Number	否
change_tf_path	String	否
tf_file_save_time	String	否
nat_mode	String	否
foreign_ip	String	否
extraction	Number	否	0
start_lsn	Number	否
full_sync_set	Object	否		同步程序设置
support_ddl	Number	否	1	否:0 是 1，是否支持ddl 当备端为mysql时，缺省为支持DDL，当备端非mysql时，缺省为不支持DDL
change_tf_path	String	否		更改TF文件路径
tf_file_save_time	Number	否	7	传数字
nat_mode	Number	否	0	默认为否，如果选择是，则显示出如下内容
foreign_ip	String	否		外网ip
extraction	Number	否	0	是否支持远程抽取
start_lsn	Number	否
config	Object
dml_track	Object
delcol	String			删除标记字段名称
drp	Number			删除
enable	Number		1	0不启用 1启用
tmcol	String			操作时间字段名称
urp	Number			更新
src_connect_user	String
dst_connect_user	String
bw_settings	Object
bw_limit	String		"1200:00-13:0040M,300:00-13:0040M"
full_sync_settings	Object			全量设置
clean_user_before_dum	Number		0
concurrent_table	Array
dump_thd	Number
load_thd	Number
existing_table	String		drop_to_recycle
try_split_part_table	Number
etl_settings	Object
etl_table	Array
oprType	String		IRP
table	String
user	String
process	String		SKIP
addInfo	String
inc_sync_ddl_filter	Object
inc_sync_ddl_data	Array		[
"INDEX",
"VIEW",
"FUNCTION"
]
table_change_info	Number			表结构变更通知
message_format	String			protobuf json
json_format	String			json canaljson message_format为json时，可传json ， canaljson，其他值传空串
binary_code	String		hex	取值 hex ， base64
part_load_balance	String
kafka_time_out	String

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	success
uuid	String		@uuid

mysql规则管理-修改

SDK方法名：modifyMysqlRule

URL

//stream/rule

Method

PUT

Request

名称	类型	必选	初始值	简介
mysql_name	String	否	mysql
src_db_uuid	Array	否	1B1153F6-DAD9-BC39-888A-A743FCC208E5
tgt_db_uuid	Array	否	D42BF707-C971-EEA9-521F-BB0F3F7A92FC
tgt_type	String	否	kafka
start_rule_now	Number	否	0
node_uuid	String	否	6B1153F6-DAD9-BC39-888A-A743FCC208E6
dbmap_topic	String	否
map_type	String	否	table
tab_map	Array	否
src_table	String	否	src_table
topic	String	否	topic
full_sync	Number	否	0
incre_sync	Number	否	1
model_type	String	否	1:0
full_sync_mode	String	否	auto
db_set	Object	否
db_node	String	否	1B1153F6-DAD9-BC39-888A-A743FCC208E5
binlog_format	String	否	row
binlog_row_image	String	否	full
default_storage_engine	String	否	innoDB
sync_binlog	String	否	1
innodb_flush_log	String	否	2
innodb_flush_method	String	否	O_DIRECT
max_allowed_packet	String	否	52
open_files_limit	String	否	65535
server_id	String	否	123456
expire_logs_days	String	否	7
nat_mode	Number	否	0
ip	String	否
full_sync_set	Object	否
support_ddl	Number	否	1
node	String	否	6B1153F6-DAD9-BC39-888A-A743FCC208E6
change_tf_path	String	否
tf_file_save_time	Number	否	7
nat_mode	Number	否	0
foreign_ip	String	否
primary_node_one	String	否
primary_node_two	String	否
primary_db_one	String	否
primary_map_type_one	String	否
primary_map_one	Array	否
primary_db_two	String	否
primary_map_type_two	String	否
primary_map_two	Array	否
db_map	Array	否
src_db	String	否	src_db
dst_db	String	否	dst_db
mysql_uuid	String	否	5349E2CF-7DBO-OAF2-13CB-BB7DFD8A9D86
config	Object
kafka_time_out	String
part_load_balance	String
dml_track	Object			待补，参见修建规则
bw_settings	Object			待补，参见修建规则
full_sync_settings	Object			待补，参见修建规则
etl_settings	Object			待补，参见修建规则
inc_sync_ddl_filter	Object			待补，参见修建规则
table_change_info	String			表结构变更通知
message_format	String			protobuf json
json_format	String			json canaljson message_format为json时，可传json ， canaljson，其他值传空串
binary_code	String			取值 hex ， base64

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	success

mysql规则管理-删除

SDK方法名：deleteMysqlRule

URL

//stream/rule

Method

DELETE

Request

名称	类型	必选	初始值
mysql_uuids	Array	否
0	String		@guid
force	Boolean		true

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object
code	Number		0
message	String		[0] success
success_list	Array
code	Number		0
message	String		[0] success
mysql_uuid	String		16CB63E1-13FA-FB32-EB49-D790682C9648
mysql_name	String		task1
fail_list	Array
code	Number		-1
message	String		[-1] 找不到节点
mysql_uuid	String		16CB63E1-13FA-FB32-EB49-D790682C9647
mysql_name	String		task2

mysql规则管理-获取单个信息

SDK方法名：describeMysqlRule

URL

//stream/rule/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
mysql_uuid	String	否

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
info_list	Object	否
mysql_name	String	否	mysql
src_db_uuid	String	否	['1111','2222']
tgt_db_uuid	Array	否	2222
tgt_type	String	否	kafka
start_rule_now	Number	否	0
node_uuid	String	否	6B1153F6-DAD9-BC39-888A-A743FCC208E6
dbmap_topic	String	否	db_topic
map_type	String	否	table	database
tab_map	Array	否			2
src_table	String	否	@name
dst_table	String	否	@name
src_db	String	否	111
dst_db	String	否	222
full_sync	Number	否	0
incre_sync	Number	否	1
model_type	String	否	n:1
full_sync_mode	String	否	auto
db_set	Object	否
db_node	String	否	1B1153F6-DAD9-BC39-888A-A743FCC208E5
binlog_format	String	否	row
binlog_row_image	String	否	full
default_storage_engine	String	否	innoDB
sync_binlog	String	否	777
innodb_flush_log	String	否	777
innodb_flush_method	String	否	O_DIRECT
max_allowed_packet	String	否	777
open_files_limit	String	否	777
server_id	String	否	777
expire_logs_days	String	否	777
nat_mode	Number	否	0
ip	String	否	192.168.1.1
full_sync_set	Object	否
support_ddl	Number	否	1
node	String	否	6B1153F6-DAD9-BC39-888A-A743FCC208E6
change_tf_path	String	否
tf_file_save_time	Number	否	777
nat_mode	Number	否	0
foreign_ip	String	否	192.168.1.1
start_lsn	String	否	9
primary_node_one	String	否	1111
primary_node_two	String	否	2222
primary_db_one	String	否	EC9D7dcC-55BC-849b-ABd1-F7AbADC7f936
primary_map_type_one	String	否	table
primary_map_one	String	否	{"123":"123"}
primary_db_two	String	否	b254e0c8-f91d-b4Ac-4ab3-C8A2bCbdB86c
primary_map_type_two	String	否	database
primary_map_two	String	否	{"44":"44","555":"555"}
db_map	Array	否			2
src_table	String	否	555
dst_table	String	否	666
dst_full_sync_set	Object	否
support_ddl	Number	否	1
change_tf_path	String	否
tf_file_save_time	Number	否	7
nat_mode	Number	否	0
foreign_ip	Number	否
extraction	Number	否	0
start_lsn	String	否	0
config	Object
dml_track	Object
enable	Number		0
urp	Number		0
drp	Number		0
tmcol	String
delcol	String

mysql规则管理-操作

SDK方法名：

继续：resumeMysqlRule;

停止：stopMysqlRule;

修改：modifyMysqlRule;

重启：restartMysqlRule;

开始解析：startParsingMysqlRule;

停止解析：stopParsingMysqlRule;

重新解析：resetParsingMysqlRule;

开始加载：startLoadMysqlRule;

停止加载：stopLoadMysqlRule;

重新加载：resetLoadMysqlRule;

移除：removeMysqlRule;

URL

//stream/rule/operate

Method

POST

Request

名称	类型	必选	初始值	简介
operate	String	否	restart	resume 继续 stop 停止 restart 重启 modify start_parsing stop_parsing reset_parsing start_load stop_load reset_load remove
mysql_uuid	String	否	@guid
scn	String	否
tf	String	否		只有在重置装载时才有此值

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql规则管理-规则列表

SDK方法名：listStreamRules

URL

//stream/rule

Method

GET

Request

名称	类型	必选	初始值
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否
where_args	Object	否
mysql_uuid	String	否	@guid

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
total	Number	否	12
info_list	Array	否
mysql_uuid	Array	否	['3D7dFcd9-C176-d9ee-4FFB-f22bbd554929', '3D7dFcd9-C176-d9ee-4FFB-f22bbd554928']	规则uuid	+1
src_db_uuid	Array	否	['3D7dFcd9-C176-d9ee-4FFB-f22bbd554926']	源端uuid
tgt_db_uuid	Array	否	['3D7dFcd9-C176-d9ee-4FFB-f22bbd554927']	备端uuid
tgt_type	Array	否	[
"kafka",
"sqlserver",
"hbase",
"postgres",
"oracle"
]	备端类型	+1
user_uuid	String	否	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
mysql_name	String	否	@name	规则名称
tgt_db_name	Array	否	['bei']	备端数据库名称
model_type	String	否	n:1	n:1, 1:0
can_op	Number	否	1
can_up	Number	否	1
can_del	Number	否	1
src_db_name	Array	否	['hello']	['111', 'hello']
is_biz_admin	Number	否	1
map_type	String	否	database	table, database
tab_map	Array	否		表映射
src_table	String	否	@name
dst_table	String	否	@name
src_db	String	否	111
dst_db	String	否	222
db_map	Array	否		库映射
src_table	String	否	@name
dst_table	String	否	@name
message	String	否

mysql规则管理-状态

SDK方法名：listStreamStatus

URL

//stream/rule/status

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否	3333
data	Object	否
code	Number	否	0
message	String	否	44444
info_list	Array	否			2
wSt	Array	否		2 导出
status	String	否	ACTIVE_RULE_DUMP	ACTIVE_RULE_TRACK
progress	Number	否	55
bSt	Array	否		2 装载
status	String	否	ACTIVE_RULE_TRACK	ACTIVE_RULE_DUMP
progress	String	否	66
mysql_uuid	Array	否	['3D7dFcd9-C176-d9ee-4FFB-f22bbd554929', '3D7dFcd9-C176-d9ee-4FFB-f22bbd554928']		+1
stage	String		done	pause: 停止 dump: 全量 track:增量 done:完成 offline:离线
state	String		0	0：正常非0：错误
progress	String		100	进度

mysql规则管理-日志

SDK方法名：listStreamLog;mysql日志管理

URL

//stream/rule/log

Method

POST

Request

名称	类型	必选	初始值
offset	Number	否	1
limit	Number	否	10
date_start	String	否	1624876176
date_end	String	否	1624876118
type	Number	否	1
module_type	Number	否	-1
query_type	Number	否	1
mysql_uuid	String	否	@guid
rule_uuid	String		@guid

Response

名称	类型	必选	初始值
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	Delete success
info_list	Array	否
create_time	String	否	2019-08-09 17:29:43
detail	String	否	Full Sync done, elapsed time: 24 sec'
flag	Number	否	1
log_level	String	否	2
log_type	String	否	装载
uuid	String	否	@uuid
ret	Number	否	200

mysql规则管理-同步状态(暂时废弃)

SDK方法名：listStreamSyncStatus

URL

//stream/rule/sync_status

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
node_uuid	String	否	@guid	节点 uuid
mysql_uuid	String	否	@guid	规则 uuid

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	success
info_list	Array	否
host_name	String	否	@name	主机名称
work	String	否	111	事务
after_work	String	否	222	前事务
load_number	String	否	333
load_time	String	否	444	装载延时
load	String	否	555
status	String	否	666

mysql规则管理-历史信息(暂时废弃)

SDK方法名：describeHistory

URL

//stream/rule/history

Method

POST

Request

名称	类型	必选	初始值	简介
mysql_uuid	String	否	@guid
start_time	String	否	2019-10-11 14:23:13	开始时间
end_time	String	否	2019-10-11 15:23:13

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	success
info_list	Array	否
host_name	String	否	@name
work	String	否	111
serial_num	String	否	222	序号
delay	String	否	333	延时
extract_delay	String	否	444	抽取延时

mysql规则管理-资源占用(暂时废弃)

SDK方法名：describeResource

URL

//stream/rule/resouce

Method

POST

Request

名称	类型	必选	初始值	简介
set_time	Number	否	1
type	String	否
interval	String	否	1	时间间隔
set_time_init	String	否
rule_uuid	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
info_list	Array	否
start_time	String	否	2018/11/08 10:40:06
traffic	Number	否	1
info_list_max	Array	否
start_time	String	否	2018/11/08 10:40:06
traffic	Number	否	1
interval	Number	否	5
uuid	String	否
max	String	否
min	String	否
lastdate	String	否

-----mysql表比较-----

URL

//stream/mysql

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql-表比较-获取单个

SDK方法名：describeStreamCmp

URL

//stream/tb_cmp/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
stream_tb_cmp	Object	否
table_cmp_name	String	否	ctt->ctt
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
cmp_type	String	否	table	table, database
filter_table_settings	String	否	["333.444"]
tdb_tb_map	Array	否
src_table	String	否	@name
dst_table	String	否	@name
src_db	String	否	@name
dst_db	String	否	@name
dump_thd	Number	否	1
rule_uuid	String	否	3D7dFcd9-C176-d9ee-4FFB-f22bbd554929
policies	String	否	1\|00:09	1,2,3*1	00:02
policy_type	String	否	periodic
one_time	String	否	2019-05-27 16:07:08
db_user_map	Array	否
src_table	String	否	@name
dst_table	String	否	@name
concurrentTab	Array
try_split_part_table	Number

mysql-表比较-新建

SDK 方法名：createStreamCmp

URL

//stream/tb_cmp

Method

POST

Request

名称	类型	必选	初始值	简介
tb_cmp_name	String	否	ctt->ctt	表比较的名称
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
cmp_type	String	否	table, database, user	映射类型
db_user_map	Array	否	{"CTT":"CTT"}	用户映射
src_table	String	否
dst_table	String	否
filter_table	String	否	["用户.表名"]
db_tb_map	Array	否	表映射	表映射
src_table	String	否
dst_table	String	否
src_db	String	否
dst_db	String	否
dump_thd	Number	否	1	抽取线程数
rule_uuid	String	否	@guid	规则uuid
polices	String	否	"0\|00:00	运行策略
policy_type	String	否	one_time	策略类型
try_split_part_table	Number	否	0
concurrent_table	Array			并发表
one_time	String
repair	Number
fix_related	Number

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
uuid	String		@uuid

mysql-表比较-删除

SDK方法名：deleteStreamRules

URL

//stream/tb_cmp

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否	@guid

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql-表比较-获取规则列表

SDK方法名：listStreamCmps

URL

//stream/tb_cmp

Method

GET

Request

名称	类型	必选	初始值
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
total	Number	否	5
info_list	Array	否
create_time	String	否	2019-06-21 14:33:24
tb_cmp_name	String	否	@name
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
user_uuid	String	否	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
tb_cmp_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
tgt_db_name	String	否	bei
tgt_type	String	否	目标类型123
is_biz_admin	Number	否	1
can_op	Number	否	1
can_up	Number	否	1
can_del	Number	否	1
src_db_name	String	否	yuan
policy_type	String
message	String	否

mysql-表比较-状态接口

SDK方法名：listStreamCmpStatus

URL

//stream/tb_cmp/status

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
info_list	Array	否
cmp_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
wSt	Object	否
status	String	否	ABNORMAL
error_code	String	否	4017
bSt	Object	否
status	String	否	DUMP
progress	String	否	80

mysql-表比较-操作

SDK方法名：

停止：cmpStopStreamCmp;

重启：cmpRestartStreamCmp;

URL

//stream/tb_cmp/operate

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
tb_cmp_uuids	String	否	@guid
operate	String	否		cmp_stop \| cmp_restart

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql-表比较-比较结果的删除

SDK方法名：deleteCmpResult

URL

//stream/tb_cmp/result_time_list

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
time_list	String	否	@guid
uuid	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql-表比较-比较结果的查看

SDK方法名：listCmpResult

URL

//stream/tb_cmp/result_time_list

Method

GET

Request

名称	类型	必选
uuid	String	否
limit	String	否
offset	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
time_list	Array	否
show_time	String	否	2019-07-05 17:35:13
summary	Object	否
total	Number	否	999
use_time	Number	否	777
diff	Number	否	444
time	String	否	2019-07-05_17-35-13

mysql表比较-比较任务结果

SDK方法名：describeTbCmpResult

URL

//stream/tb_cmp/result

Method

GET

Request

名称	类型	必选	初始值	简介
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否
uuid	String	否	@guid
start_time	String	否		对应的时间

Response

名称	类型	必选	初始值	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	否	Anna Martin
src	String	否	Cynthia Gonzalez
dst	String	否	Robert Johnson
total	Number	否	30

mysql-表比较-查看单条

SDK方法名：describeStreamCmp

URL

//stream/result_fix_list

Method

GET

Request

名称	类型	必选	初始值
time_list	String	否	@guid
uuid	String	否
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否
uuid	String	否	@guid
start_time	String	否

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
time_list	Array	否
db_name	String	否	@name	数据库名称
table_name	String	否	@name
col_cmp	String	否	111	列比较
line_num	Number	否	222	行数
content	String	否	333	内容
status	String	否	not_repaired	done:已修复，not_repaired：未修复
total	Number	否	15
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	否
db_name	String	否	Donald Miller
table_name	String	否	Joseph Walker
col_cmp	String	否	111
line_num	Number	否	222
content	String	否	333
status	String	否	not_repaired
total	Number	否	10

mysql-表比较-单条错误信息

SDK方法名：describeCmpErrorMsg

URL

//stream/tb_cmp/error_msg

Method

GET

Request

名称	类型	必选	初始值
offset	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否
uuid	String	否	@guid
start_time	String	否
name	String	否
owner	String	否	admin

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
result_info	Object	否
rows	Array	否
src_row	String	否	@name
dst_row	String	否	@name
total	Number	否	10

比较结果列表的修复

SDK方法名：listFixResult

URL

//stream/result_fix_list

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

比较结果列表的导出

SDK方法名：exportCmpResult

URL

//stream/export

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

历史结果中的修复

SDK方法名：listCmpDiffMap

URL

//stream/tb_cmp/diff_map

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否
time	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
result_info	Array	否	['LIU.YI','LIU.ER']

===============分割线==================

URL

/===============分割线==================

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

备机接管-新建

SDK方法名：createBkTakeover

URL

//stream/bk_takeover

Method

POST

Request

名称	类型	必选	初始值
mysql_uuid	String	否	@guid
start_val	Number	否	1000
scan_ip	Array	否	["c01D7F86-A631-b79f-E2AA-7ccb7f2bE851","c01D7F86-A631-b79f-E2AA-7ccb7f2bE851","c01D7F86-A631-b79f-E2AA-7ccb7f2bE851"]
hosts	Array	否
ip	String	否	192.168.12.200
password	String	否
use_ip_sw	Number	否	1

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

备机接管-查看

SDK方法名：describeBkTakeover

URL

//stream/bk_takeover/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	[0] success
active_bk_takeover	Object	否
id	String	否	2
user_uuid	String	否	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
random_str	String	否	CDA58D92-C0F9-32C8-3BFA-065F0BA17CB4
create_time	String	否	1564385400
bk_takeover_uuid	String	否	0A20B300-8B41-2573-E5CA-A1CB57C0CADF
mysql_uuid	String	否	E2Dd563c-cD1e-2dd2-8B8B-68beFFEc49cC
start_val	String	否	1000
scan_ip	Array	否
hosts	Array	否
use_ip_sw	String	否	0

备机接管-删除

SDK方法名：deleteBkTakeover

URL

//stream/bk_takeover

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	1

备机接管-接管结果

SDK方法名：listTakeoverResult

URL

//stream/bk_takeover/result

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
bk_takeover_uuid	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
result_info	Object	否
seq_err	Array	否
username	String	否	@name
seq_name	String	否	@name
tri_err	Array	否
username	String	否	@name
tri_name	String	否	@name
takeover_obj	Array	否
username	String	否	@name
seq_num	Number	否	10
seq_err_num	Number	否	11
tri_num	String	否	@name
tri_err_num	Number	否	10

备机接管-操作

SDK方法名：{operate}Takeover

URL

//stream/bk_takeover/operate

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
bk_takeover_uuids	String	否	@guid
operate	String	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	1

备机接管-获取状态

SDK方法名：listTakeoverStatus

URL

//stream/bk_takeover/status

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否	[0] success
info_list	Array	否
bk_takeover_uuid	String	否	3211BF7E-D9B2-1259-5C2A-264DAC3E26DC
wSt	Object	否
progress	String	否	ABNORMAL
status	String	否	ABNORMAL
bSt	Object	否
progress	String	否	DONE
status	String	否	DONE

备机接管列表

SDK方法名：listTakeoverList

URL

//stream/bk_takeover

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
total	Number	否	20
info_list	Array	否
create_time	String	否	2019-10-10 10:10:10
rule_name	String	否	@name
bk_takeover_uuid	String	否	3211BF7E-D9B2-1259-5C2A-264DAC3E26DC
can_op	Number	否	1
can_up	Number	否	1
can_del	Number	否	1
is_biz_admin	Number	否	1

--------对象修复------

URL

/mysql对象修复

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql-对象修复-新建

SDK方法名：createObjFix

URL

//stream/obj_fix

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
obj_fix_name	String	否	test
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
rule_uuid	String	否	751A03F5-C97D-645B-82B2-316A5D198528
obj_map	String	否	[{"type":"owner.name"}]	type对应类型值如下：INDEX->索引,VIEW->视图,FUNCTION->函数,PROCEDURE->存储过程,PACKAGE->包头 PACKAGE BODY->包体,SYNONYM->同义词,TRIGGER->触发器, SEQUENCE->序列,JAVA SOURCE->JAVA源,JAVA CLASS->JAVA类,JAVA RESOURCE->JAVA资源,TYPE->类型,TYPE BODY->类型体,QUEUE->队列,MATERIALIZED VIEW->物化视图,DATABASE LINK->DBLINK,OLD JOB->JOB,JOB->SCH JOB,PRIVS->权限,CONSTRAINT->约束. owner和name 用逗号连接并且均加密	2

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

对象修复 - 获取单个

SDK方法名：describeObjFix

URL

//stream/obj_fix/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否	@guid	规则uuid

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
active_obj_fix	Object	否
obj_fix_name	String	否	test
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
obj_fix_uuid	String	否	751A03F5-C97D-645B-82B2-316A5D198528
obj_map	String	否	[{"INDEX":"owner.name"}]	json 字符串

mysql-对象修复 -删除

SDK方法名：deleteObjFix

URL

//stream/obj_fix

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否	@guid	数组

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
obj_fix_uuid	String		@uuid

mysql-对象修复 - 列表

SDK方法名：listObjFix

URL

//stream/obj_fix

Method

GET

Request

名称	类型	必选	初始值
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
total	Number	否	20
info_list	Array	否			6
create_time	String	否	1593511163
obj_fix_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
obj_fix_name	String	否	test
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
user_uuid	String	否	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
src_db_name	String	否	yuan
tgt_db_name	String	否	bei
username	String	否	admin
policy_type	String		immediate	immediate; one_time;periodic
message	String	否

mysql对象修复-操作

SDK方法名：{operate}ObjFix;重新修复

URL

//stream/obj_fix/operate

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
obj_fix_uuids	Array	否	@guid	规则uuid
operate	String	否		restart \| stop

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

对象修复 - 修复结果

SDK方法名：describeObjFixResult

URL

//stream/obj_fix/result

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否	@guid

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
info_list	Array	否
obj_fix_type	String	否	索引
status	String	否	on	修复状态
owner	String	否	@name	所有者
name	String	否	@name	名称
head_info	Object	否
obj_fix_name	String	否	@name

mysql对象修复--获取状态

SDK方法名：listObjFixStatus

URL

//stream/obj_fix/status

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
info_list	Array	否
wSt	Object	否
status	String	否	TRACK
progress	Number	否	1
bSt	Object	否
status	String	否	DUMP
progress	String	否	80
obj_fix_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87

-----对象比较-----

URL

/mysql对象比较

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql对象比较 - 新建

SDK方法名：createObjCmp

URL

//stream/obj_cmp

Method

POST

Request

名称	类型	必选	初始值	简介
obj_cmp_name	String	否	test	对象比较名称
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21	源端数据库uuid
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5	备端数据库uuid
cal_table_recoders	Number	否	1	是否对比表的记录数
rule_uuid	String	否	751A03F5-C97D-645B-82B2-316A5D198528	同步规则uuid
cmp_type	String	否	user	类型
db_user_map	String	否	{'src_user':'dst_user'}	用户映射
policies	String	否
policy_type	String	否	periodic
one_time	String	否	2019-05-27 16:07:08
repair	Number	否	1

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
obj_cmp_uuid	String		@uuid

mysql对象比较 - 列表

SDK方法名：listObjCmp

URL

//stream/obj_cmp

Method

GET

Request

名称	类型	必选	初始值
page	Number	否	1
limit	Number	否	10
search_field	String	否
search_value	String	否

Response

名称	类型	必选	初始值	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
total	Number	否	20
info_list	Array	否		16
create_time	String	否	1593511163
obj_cmp_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
obj_cmp_name	String	否	test
src_db_uuid	String	否	3D7dFcd9-C176-d9ee-4FFB-f22bbd554926
tgt_db_uuid	String	否	3D7dFcd9-C176-d9ee-4FFB-f22bbd554925
cmp_type	String	否	user
user_uuid	String	否	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
src_db_name	String	否	yuan
tgt_db_name	String	否	bei
username	String	否	admin
can_op	Number	否	1
can_up	Number	否	1
can_del	Number	否	1
message	String	否

mysql对象比较-比较结果的删除

SDK方法名：describeObjCmpResultTimeList

URL

//stream/obj_cmp/result_time_list

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否	@guid
time_list	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql对象比较 - 获取单个

SDK方法名：describeObjCmp

URL

//stream/obj_cmp/:uuid([A-F0-9-]+)

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
active_obj_cmp	Object	否
obj_cmp_uuid	String	否
obj_cmp_name	String	否	test
src_db_uuid	String	否	4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否	40405FD3-DB86-DC8A-81C9-C137B6FDECE5
rule_uuid	String	否	751A03F5-C97D-645B-82B2-316A5D198528
cmp_type	String	否	user
cal_table_recoders	Number	否	1
db_user_map	String	否	{"user1":"user1"}
policies	String	否	1\|00:09	1,2,3*1	00:02
policy_type	String	否	periodic
one_time	String	否	2019-05-27 16:07:08
repair	Number	否	1
message	String	否
code	Number	否	0

mysql对象比较-比较结果时间列表

SDK方法名：listObjCmpResultTimeList

URL

//stream/obj_cmp/result_time_list

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则
uuid	String	否	@guid

Response

名称	类型	必选	初始值	Mock规则
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
time_list	Array	否		16
show_time	String	否	2019-07-05 17:35:13
summary	Object	否
diff	Number	否		1-100
time	String	否	2019-07-05_17-35-13
total	Number	否	20

mysql对象比较 - 删除

SDK方法名：deleteObjCmp

URL

//stream/obj_cmp

Method

DELETE

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否	["11111111-1111-1111-1111-111111111111"]

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

mysql对象比较 - 操作

SDK方法名：{operate}ObjCmp

URL

//stream/obj_cmp/operate

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql获取对象比较状态

SDK方法名：listObjCmpStatus

URL

//stream/obj_cmp/status

Method

POST

Request

名称	类型	必选	初始值	简介	Mock规则
uuids	Array	否

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
code	Number	否	0
message	String	否
info_list	Array	否
cmp_uuid	String	否	C038DE5A-CDB2-F26D-FA5F-93E3FF266A87
wSt	Object	否
status	String	否	TRACK
progress	Number	否
bSt	Object	否
status	String	否	DUMP
progress	String	否	80

mysql对象比较-比较结果详细信息

SDK方法名：listObjCmpCmpInfo

URL

//stream/obj_cmp/cmp_info

Method

GET

Request

名称	类型	必选	初始值
offset	Number	否	1
limit	Number	否	10
search_value	String	否
usr	String	否	I2
filed	String	否
uuid	String	否
start_time	String	否

Response

名称	类型	必选	初始值	简介
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
info_list	Object	否
total	Number	否	2000
rows	Array	否
src	String	否	1111
dst	String	否	2222
cal_table_recoders	Boolean	否	false	是否比较表的记录

mysql对象比较-比较任务结果

SDK方法名：describeObjCmpResult

URL

//stream/obj_cmp/result

Method

GET

Request

名称	类型	必选	初始值
uuid	String	否	@guid
start_time	String	否
limit	Number	否
offset	String	否
search_value	String	否
BackLackOnly	Number	否	0

Response

名称	类型	必选	初始值
code	Number	否	0
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0
result_info	Object	否
total	Number	否	20
rows	Array	否
CONSTRAINT	String	否	1/1__1
DATABASE LINK	String	否	0/0__1
FUNCTION	String	否	0/0__1
INDEX	String	否	4/5__0
JAVA CLASS	String	否	0/0__1
JAVA RESOURCE	String	否	0/0__1
JAVA SOURCE	String	否	0/0__1
JOB	String	否	0/0__1
MATERIALIZED VIEW	String	否	0/0__1
OLD JOB	String	否	0/0__1
PACKAGE	String	否	0/0__1
PACKAGE BODY	String	否	0/0__1
PRIVS	String	否	9/8__0
PROCEDURE	String	否	0/0__1
QUEUE	String	否	0/0__1
SEQUENCE	String	否	0/0__1
SYNONYM	String	否	0/0__1
TABLE	String	否	18/19__0
TABLE PARTITION	String	否	0/0__1
TRIGGER	String	否	0/0__1
TYPE	String	否	0/0__1
TYPE BODY	String	否	0/0__1
VIEW	String	否	2/2__1
usr	String	否	I2/I2
head_info	Object	否
obj_cmp_name	String	否	Michelle Lewis

-----mysql 表修复------

URL

/mysql 表修复

Method

GET

Request

名称	类型	必选	初始值	简介	Mock规则

Response

名称	类型	必选	初始值	简介	Mock规则

mysql-表修复-新建

SDK方法名：createStreamTableFix

URL

//stream/tb_cmp/table_fix

Method

POST

Request

名称	类型	必选	初始值
rule_uuid	String	否	@guid
tab	Array	否
fix_relation	Number	否	0

Response

名称	类型	必选	初始值
ret	Number	否	200
msg	String	否
data	Object	否
message	String	否
code	Number	否	0

Mysql同步

# Mysql同步

# -------同步规则---

# URL

# Method

# Request

# Response

# mysql规则管理-新建

# URL

# Method

# Request

# Response

# mysql规则管理-修改

# URL

# Method

# Request

# Response

# mysql规则管理-删除

# URL

# Method

# Request

# Response

# mysql规则管理-获取单个信息

# URL

# Method

# Request

# Response

# mysql规则管理-操作

# URL

# Method

# Request

# Response

# mysql规则管理-规则列表

# URL

# Method

# Request

# Response

# mysql规则管理-状态

# URL

# Method

# Request

# Response

# mysql规则管理-日志

# URL

# Method

# Request

# Response

# mysql规则管理-同步状态(暂时废弃)

# URL

# Method

# Request

# Response

# mysql规则管理-历史信息(暂时废弃)

# URL

# Method

# Request

# Response

# mysql规则管理-资源占用(暂时废弃)

# URL

# Method

# Request

# Response

# -----mysql表比较-----

# URL

# Method

# Request

# Response

# mysql-表比较-获取单个

# URL

# Method

# Request

# Response

# mysql-表比较-新建

# URL

# Method

# Request

# Response

# mysql-表比较-删除

# URL

# Method

Mysql同步

-------同步规则---

URL

Method

Request

Response

mysql规则管理-新建

URL

Method

Request

Response

mysql规则管理-修改

URL

Method

Request

Response

mysql规则管理-删除

URL

Method

Request

Response

mysql规则管理-获取单个信息

URL

Method

Request

Response

mysql规则管理-操作

URL

Method

Request

Response

mysql规则管理-规则列表

URL

Method

Request

Response

mysql规则管理-状态

URL

Method

Request

Response

mysql规则管理-日志

URL

Method

Request

Response

mysql规则管理-同步状态(暂时废弃)

URL

Method

Request

Response

mysql规则管理-历史信息(暂时废弃)

URL

Method

Request

Response

mysql规则管理-资源占用(暂时废弃)

URL

Method

Request

Response

-----mysql表比较-----

URL

Method

Request

Response

mysql-表比较-获取单个

URL

Method

Request

Response

mysql-表比较-新建

URL

Method

Request

Response

mysql-表比较-删除

URL

Method

Request