Mysql同步
February 26, 2024About 43 min
Mysql同步
SDK类名：/active/Mysql
-------同步规则---
示例接口描述
URL
/mysql同步规则
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
同步规则 - 列表
SDK方法名：listStreamRules
URL
/stream/rule
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| page | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 | |||
| where_args | Object | 否 | |||
| mysql_uuid | String | 否 | 规则uuid | @guid | |
| mysql_name | String | 规则名 | |||
| status | String | 状态 | |||
| src_db_name | String | 数据源 | |||
| tgt_db_name | String | 目标端 | |||
| db_ip | String | 数据库ip | |||
| node_ip | String | 机器节点ip | |||
| username | String | 用户名 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| total | Number | 否 | 12 | ||
| info_list | Array | 否 | |||
| mysql_uuid | Array | 否 | 规则uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554929', '3D7dFcd9-C176-d9ee-4FFB-f22bbd554928'] | +1 |
| src_db_uuid | Array | 否 | 源端uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554926'] | |
| tgt_db_uuid | Array | 否 | 备端uuid | ['3D7dFcd9-C176-d9ee-4FFB-f22bbd554927'] | |
| 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, 1:0 | n:1 | |
| can_op | Number | 否 | 1 | ||
| can_up | Number | 否 | 1 | ||
| can_del | Number | 否 | 1 | ||
| src_db_name | Array | 否 | ['111', 'hello'] | ['hello'] | |
| is_biz_admin | Number | 否 | 1 | ||
| map_type | String | 否 | table, database | 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 | 否 |
同步规则 - 新建
SDK 方法名：createMysqlRule
URL
/stream/rule
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_name | Boolean | 否 | @name | ||
| tgt_db_uuid | Array | 否 | 备端数据库（分发时为多选） | D42BF707-C971-EEA9-521F-BB0F3F7A92FC | |
| tgt_type | String | 否 | 备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum | oracle | |
| start_rule_now | Number | 否 | 0 | ||
| dbmap_topic | String | 否 | kafka类型，整库映射 | ||
| map_type | String | 否 | 映射方式 库映射database 表映射：table 整库映射 all | table | |
| tab_map | Array | 否 | 表映射 | ||
| src_table | String | 否 | src_table | ||
| dst_table | String | 否 | dst_table | ||
| src_db | String | 否 | 111 | ||
| dst_db | String | 否 | 222 | ||
| topic | String | kafka 时库映射存在此参数 | |||
| full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
| incre_sync | Number | 否 | 增量同步 | 1 | |
| model_type | String | 否 | （已废弃）模式 汇聚n:1, 分发:1:n，主-主:1:1 主-从:1:0 | 1:0 | |
| full_sync_mode | String | 否 | 全同步方式，逻辑:logic 物理 physics 自动 auto（汇聚只有逻辑一种） | 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 是 1，默认为否，如果选择是，则显示出如下内容 | 0 | |
| ip | String | 否 | 外网 ip | ||
| max_allowed_packet | String | 否 | 52m | 52 | |
| 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 | 否 | 否:0 是 1，是否支持ddl 当备端为mysql时，缺省为支持DDL，当备端非mysql时，缺省为不支持DDL | 1 | |
| 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 | DML操作追踪设置 | |||
| delcol | String | 删除标记字段名称 | |||
| drp | Number | 删除 | |||
| enable | Number | 0不启用 1启用 | 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 | ||||
| table_msg_uuid | String | 表元信息库 | |||
| end_target_type | String | 最终数据库类型 | |||
| end_target_db | String | 最终目标库 | |||
| end_db_map | String | 最终库映射 | |||
| end_tab_map | String | 最终表映射 | |||
| full_sync_custom_cfg | Array | 全局自定义配置 | |||
| key | String | ||||
| value | String | ||||
| start_lsn | String | 起始lsn | |||
| etl_settings | Object | etl 表设置 | |||
| etl_table | Array | ||||
| deal_Type | String | 处理方式 IRP ：插入 URP:更新 DRP:删除 ALLDML:全部 | IRP | ||
| table | String | 表名 | |||
| user | String | 用户名 | |||
| obj_fix_type | String | 操作类型 SKIP 忽略 DRP 删除 | SKIP | ||
| field_condition | String | 字段或条件 | |||
| inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
| inc_sync_ddl_data | Array | 0: "CREATE TABLE" 1: "DROP TABLE" 2: "ALTER TABLE ADD" 3: "ALTER TABLE DROP" 4: "ALTER TABLE RENAME" 5: "ALTER TABLE MODIFY" 6: "ALTER TABLE CHANGE" 7: "ALTER TABLE ALTER" 8: "TRUNCATE TABLE" | [ CREATE TABLE ] | ||
| table_change_info | Number | 表结构变更通知 | |||
| message_format | String | protobuf json | |||
| json_format | String | json canaljson message_format为json时，可传json ， canaljson， 其他值传空串 | |||
| binary_code | String | 取值 hex ， base64 | hex | ||
| run_time | String | 运行时间 | "1200:00-13:0040M,300:00-13:0040M" | ||
| jointing | Object | 字段拼接 | |||
| table | String | ||||
| op | String | 操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide | append | ||
| content | Array | 目标列+其他两行 | |||
| part_load_balance | String | 分区均衡策略 主键哈希： by_key 表名哈希： by_table | |||
| kafka_time_out | String | producer 超时时间 | |||
| save_json_text | String | 【目标类型：Kafka】另存文本文件 | |||
| exclude_dbs | Array | 排除库列表 | |||
| exclude_dbs_switch | Number | 排除库开关，0：关，1：开 | |||
| other_settings | Object | ||||
| dyn_thread | Number | 增量装载线程数 | |||
| merge_track | Number | 统一解析 | |||
| keep_incre_time | Number | 增量数据导出保留时长 | |||
| incre_full_sync_custom_cfg | Array | 增量自定义配置 | |||
| key | String | ||||
| value | String | ||||
| target_add_columns | Array | 字段添加 | |||
| schema | String | 模式 | |||
| table | String | 表名 | |||
| column | String | 列名 | |||
| function | String | 装载函数 | |||
| dataType | String | 数据类型 | |||
| opType | String | 执行操作：插入：insert，更新：update | |||
| filter_table_settings | Object | 表过滤设置 | |||
| exclude_table | Array | 表过滤 | |||
| exclude_tab_with_column_switch | String | 按列匹配过滤表：0：关，1：开 | |||
| exclude_tab_with_column | Array | 按列匹配过滤表，格式为：列1，列2例： ["NAME", "CARD"] |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| message | String | 否 | success | ||
| uuid | String | @uuid |
同步规则 - 批量新建
SDK 方法名：createBatchMysqlRule
URL
/stream/rule/batch
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| prefix | Boolean | 否 | 批量新建前缀 | @name | |
| db_list | Array | 批量新建同步链路 | |||
| src_db_uuid | String | 源端 | |||
| tgt_db_uuid | String | 备端 | |||
| tgt_db_uuid | Array | 否 | 备端数据库（分发时为多选） | D42BF707-C971-EEA9-521F-BB0F3F7A92FC | |
| tgt_type | String | 否 | 备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum | oracle | |
| start_rule_now | Number | 否 | 0 | ||
| dbmap_topic | String | 否 | kafka类型，整库映射 | ||
| map_type | String | 否 | 映射方式 库映射database 表映射：table 整库映射 all | table | |
| tab_map | Array | 否 | 表映射 | ||
| src_table | String | 否 | src_table | ||
| dst_table | String | 否 | dst_table | ||
| src_db | String | 否 | 111 | ||
| dst_db | String | 否 | 222 | ||
| topic | String | kafka 时库映射存在此参数 | |||
| full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
| incre_sync | Number | 否 | 增量同步 | 1 | |
| model_type | String | 否 | 模式 汇聚n:1, 分发:1:n，主-主:1:1 主-从:1:0 | 1:0 | |
| full_sync_mode | String | 否 | 全同步方式，逻辑:logic 物理 physics 自动 auto（汇聚只有逻辑一种） | 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 是 1，默认为否，如果选择是，则显示出如下内容 | 0 | |
| ip | String | 否 | 外网 ip | ||
| max_allowed_packet | String | 否 | 52m | 52 | |
| 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 | 否 | 否:0 是 1，是否支持ddl 当备端为mysql时，缺省为支持DDL，当备端非mysql时，缺省为不支持DDL | 1 | |
| 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 | DML操作追踪设置 | |||
| delcol | String | 删除标记字段名称 | |||
| drp | Number | 删除 | |||
| enable | Number | 0不启用 1启用 | 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 | ||||
| table_msg_uuid | String | 表元信息库 | |||
| end_target_type | String | 最终数据库类型 | |||
| end_target_db | String | 最终目标库 | |||
| end_db_map | String | 最终库映射 | |||
| end_tab_map | String | 最终表映射 | |||
| full_sync_custom_cfg | Array | 全局自定义配置 | |||
| key | String | ||||
| value | String | ||||
| start_lsn | String | 起始lsn | |||
| etl_settings | Object | etl 表设置 | |||
| etl_table | Array | ||||
| deal_Type | String | 处理方式 IRP ：插入 URP:更新 DRP:删除 ALLDML:全部 | IRP | ||
| table | String | 表名 | |||
| user | String | 用户名 | |||
| obj_fix_type | String | 操作类型 SKIP 忽略 DRP 删除 | SKIP | ||
| field_condition | String | 字段或条件 | |||
| inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
| inc_sync_ddl_data | Array | 0: "CREATE TABLE" 1: "DROP TABLE" 2: "ALTER TABLE ADD" 3: "ALTER TABLE DROP" 4: "ALTER TABLE RENAME" 5: "ALTER TABLE MODIFY" 6: "ALTER TABLE CHANGE" 7: "ALTER TABLE ALTER" 8: "TRUNCATE TABLE" | [ CREATE TABLE ] | ||
| table_change_info | Number | 表结构变更通知 | |||
| message_format | String | protobuf json | |||
| json_format | String | json canaljson message_format为json时，可传json ， canaljson， 其他值传空串 | |||
| binary_code | String | 取值 hex ， base64 | hex | ||
| run_time | String | 运行时间 | "1200:00-13:0040M,300:00-13:0040M" | ||
| jointing | Object | 字段拼接 | |||
| table | String | ||||
| op | String | 操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide | append | ||
| content | Array | 目标列+其他两行 | |||
| part_load_balance | String | 分区均衡策略 主键哈希： by_key 表名哈希： by_table | |||
| kafka_time_out | String | producer 超时时间 | |||
| save_json_text | String | 【目标类型：Kafka】另存文本文件 | |||
| exclude_dbs | Array | 排除库列表 | |||
| exclude_dbs_switch | Number | 排除库开关，0：关，1：开 | |||
| other_settings | Object | ||||
| dyn_thread | Number | 增量装载线程数 | |||
| merge_track | Number | 统一解析 | |||
| keep_incre_time | Number | 增量数据导出保留时长 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| message | String | 否 | success | ||
| uuid | String | @uuid |
同步规则 - 修改
SDK方法名：modifyMysqlRule
URL
/stream/rule
Method
PUT
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_name | String | 否 | mysql | ||
| src_db_uuid | String | 否 | 1B1153F6-DAD9-BC39-888A-A743FCC208E5 | ||
| tgt_db_uuid | String | 否 | 备端数据库（分发时为多选） | D42BF707-C971-EEA9-521F-BB0F3F7A92FC | |
| tgt_type | String | 否 | 备库类型 mysql , oracle,kfaka,postgres,vertica,greenplum | kafka | |
| start_rule_now | Number | 否 | 0 | ||
| node_uuid | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
| dbmap_topic | String | 否 | kafka类型，整库映射 | ||
| map_type | String | 否 | 映射方式 库映射database 表映射：table 整库映射 all | table | |
| tab_map | Array | 否 | 表映射 | ||
| src_table | String | 否 | src_table | ||
| topic | String | 否 | kafka 时库映射存在此参数 | topic | |
| dst_table | String | ||||
| src_db | String | ||||
| dst_db | String | ||||
| full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
| incre_sync | Number | 否 | 增量同步 | 1 | |
| model_type | String | 否 | 模式 汇聚n:1, 分发:1:n，主-主:1:1 主-从:1:0 | 1:0 | |
| full_sync_mode | String | 否 | 全同步方式，逻辑:logic 物理 physics 自动 auto（汇聚只有逻辑一种） | 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 | ||||
| dml_track | Object | DML操作追踪设置 | |||
| urp | String | ||||
| drp | String | ||||
| tmcol | String | ||||
| delcol | String | ||||
| bw_settings | Object | 带宽设置 | |||
| full_sync_settings | Object | 全量设置 | |||
| etl_settings | Object | etl 表设置 | |||
| inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
| table_change_info | String | 表结构变更通知 | |||
| message_format | String | protobuf json | |||
| json_format | String | json canaljson message_format为json时，可传json ， canaljson， 其他值传空串 | |||
| binary_code | String | 取值 hex ， base64 | |||
| run_time | String | 运行时间 | 1200:00-13:0040M,300:00-13:0040M | ||
| part_load_balance | String | 分区均衡策略 主键哈希： by_key 表名哈希： by_table | by_table | ||
| kafka_time_out | String | producer 超时时间 | |||
| save_json_text | Boolean | 【目标类型：Kafka】另存文本文件 | false |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| message | String | 否 | success |
同步规则 - 批量修改
SDK方法名：batchModifyMysqlRule
URL
/stream/rule/batch
Method
PUT
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_rule_uuids | String | 否 | 规则uuids | mysql | |
| start_rule_now | Number | 否 | 0 | ||
| node_uuid | String | 否 | 6B1153F6-DAD9-BC39-888A-A743FCC208E6 | ||
| dbmap_topic | String | 否 | kafka类型，整库映射 | ||
| map_type | String | 否 | 映射方式 库映射database 表映射：table 整库映射 all | table | |
| tab_map | Array | 否 | 表映射 | ||
| src_table | String | 否 | src_table | ||
| topic | String | 否 | kafka 时库映射存在此参数 | topic | |
| dst_table | String | ||||
| src_db | String | ||||
| dst_db | String | ||||
| full_sync | Number | 否 | 全量同步 当备端类型不是mysql时 全量同步不用选择同步方式 默认 否 | 0 | |
| incre_sync | Number | 否 | 增量同步 | 1 | |
| model_type | String | 否 | 模式 汇聚n:1, 分发:1:n，主-主:1:1 主-从:1:0 | 1:0 | |
| full_sync_mode | String | 否 | 全同步方式，逻辑:logic 物理 physics 自动 auto（汇聚只有逻辑一种） | 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 | ||||
| dml_track | Object | DML操作追踪设置 | |||
| urp | String | ||||
| drp | String | ||||
| tmcol | String | ||||
| delcol | String | ||||
| bw_settings | Object | 带宽设置 | |||
| full_sync_settings | Object | 全量设置 | |||
| etl_settings | Object | etl 表设置 | |||
| inc_sync_ddl_filter | Object | 增量ddl 过滤设置 | |||
| table_change_info | String | 表结构变更通知 | |||
| message_format | String | protobuf json | |||
| json_format | String | json canaljson message_format为json时，可传json ， canaljson， 其他值传空串 | |||
| binary_code | String | 取值 hex ， base64 | |||
| run_time | String | 运行时间 | 1200:00-13:0040M,300:00-13:0040M | ||
| part_load_balance | String | 分区均衡策略 主键哈希： by_key 表名哈希： by_table | by_table | ||
| kafka_time_out | String | producer 超时时间 | |||
| save_json_text | Boolean | 【目标类型：Kafka】另存文本文件 | false | ||
| batch_basic_settings | String | 基本设置 批量更新开关 0：关闭， 1：开启 | |||
| batch_full_sync_settings | String | 全量设置 批量更新开关 0：关闭， 1：开启 | |||
| batch_incre_sync_settings | String | 增量设置 批量更新开关 0：关闭， 1：开启 | |||
| batch_advanced_settings | String | 高级设置 批量更新开关 0：关闭， 1：开启 | |||
| batch_full_sync_obj_filter | String | 全量对象设置 批量更新开关 0：关闭， 1：开启 | |||
| batch_encrypt_compress | String | 加密压缩设置 批量更新开关 0：关闭， 1：开启 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| message | String | 否 | success |
同步规则 - 删除
SDK方法名：deleteMysqlRule
URL
/stream/rule
Method
DELETE
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_uuids | Array | 否 | |||
| force | Boolean | true |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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 |
同步规则 - 获取单个信息
SDK方法名：describeMysqlRule
URL
/stream/rule/:uuid([A-F0-9-]+)
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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 | 否 | database | table | |
| 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 |
同步规则 - 操作
SDK方法名：
继续：resumeMysqlRule;
停止：stopMysqlRule;
修改：modifyMysqlRule;
重启：restartMysqlRule;
开始解析：startParsingMysqlRule;
停止解析：stopParsingMysqlRule;
重新解析：resetParsingMysqlRule;
开始加载：startLoadMysqlRule;
停止加载：stopLoadMysqlRule;
重新加载：resetLoadMysqlRule;
复制：duplicateMysqlRule;
URL
/stream/rule/operate
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| operate | String | 否 | resume 继续 stop 停止 restart 重启 （下面的暂时都弃用） start_parsing(暂时隐藏) stop_parsing（暂时隐藏） reset_parsing（暂时隐藏） start_load stop_load reset_load remove stop_schedule 停止调度 start_schedule 启动调度 stop_analysis:停止解析 start_analysis：开始解析 reset_analysis： 重置解析 | restart | |
| mysql_uuid | String | 否 | @guid | ||
| scn | String | 否 | |||
| all | Number | 否 | 只有在重置装载时才有此值 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
同步规则 - 状态（详细返回参考Oracle同步规则状态接口）
SDK方法名：listStreamStatus
URL
/stream/rule/status
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | 3333 | ||
| data | Object | 否 | |||
| code | Number | 否 | 0 | ||
| message | String | 否 | 44444 | ||
| info_list | Array | 否 | 参考Oracle同步状态接口 | 2 |
同步规则 - 日志
SDK方法名：listStreamLog;mysql日志管理
URL
/stream/rule/log
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| node_uuid | String | 否 | 节点 uuid | @guid | |
| mysql_uuid | String | 否 | 规则 uuid | @guid |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| mysql_uuid | String | 否 | @guid | ||
| start_time | String | 否 | 开始时间 | 2019-10-11 14:23:13 | |
| end_time | String | 否 | 2019-10-11 15:23:13 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| set_time | Number | 否 | 1 | ||
| type | String | 否 | |||
| interval | String | 否 | 时间间隔 | 1 | |
| set_time_init | String | 否 | |||
| rule_uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
mysql-表比较-获取单个
SDK方法名：describeStreamCmp
URL
/stream/tb_cmp/:uuid([A-F0-9-]+)
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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, database | table | |
| 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 | |
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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 | 否 | 规则uuid | @guid | |
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 | @guid | 1 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
mysql-表比较-获取规则列表
SDK方法名：listStreamCmps
URL
/stream/tb_cmp
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| page | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| tb_cmp_uuids | String | 否 | @guid | ||
| operate | String | 否 | cmp_stop | cmp_restart |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| time_list | String | 否 | @guid | ||
| uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | |||
| limit | String | 否 | |||
| offset | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| page | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 | |||
| uuid | String | 否 | @guid | ||
| start_time | 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 | 否 | Anna Martin | ||
| src | String | 否 | Cynthia Gonzalez | ||
| dst | String | 否 | Robert Johnson | ||
| diif_msg | String | 差异描述 | |||
| total | Number | 否 | 30 |
mysql-表比较-查看单条
SDK方法名：describeStreamCmp
URL
/stream/result_fix_list
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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 | 否 | done:已修复，not_repaired：未修复 | 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| offset | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 | |||
| uuid | String | 否 | @guid | ||
| start_time | String | 否 | |||
| name | String | 否 | |||
| owner | String | 否 | admin |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
比较结果列表的导出
SDK方法名：exportCmpResult
URL
/stream/export
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
历史结果中的修复
SDK方法名：listCmpDiffMap
URL
/stream/tb_cmp/diff_map
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | |||
| time | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 | ||
| result_info | Array | 否 | ['LIU.YI','LIU.ER'] |
======分割线=========
分割下所有的接口都暂时弃用
URL
/分割下所有的接口都暂时弃用
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
备机接管-新建
SDK方法名：createBkTakeover
URL
/stream/bk_takeover
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 1 |
备机接管-接管结果
SDK方法名：listTakeoverResult
URL
/stream/bk_takeover/result
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| bk_takeover_uuid | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| bk_takeover_uuids | String | 否 | @guid | ||
| operate | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 1 |
备机接管-获取状态
SDK方法名：listTakeoverStatus
URL
/stream/bk_takeover/status
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
mysql-对象修复-新建
SDK方法名：createObjFix
URL
/stream/obj_fix
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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对应类型值如下：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 用逗号连接并且 均加密 | [{"type":"owner.name"}] | 2 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | 规则uuid | @guid |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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 | 否 | json 字符串 | [{"INDEX":"owner.name"}] |
mysql-对象修复 -删除
SDK方法名：deleteObjFix
URL
/stream/obj_fix
Method
DELETE
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 | 数组 | @guid |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| page | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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; one_time;periodic | immediate | ||
| message | String | 否 |
mysql对象修复-操作
SDK方法名：{operate}ObjFix;重新修复
URL
/stream/obj_fix/operate
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| obj_fix_uuids | Array | 否 | 规则uuid | @guid | |
| operate | String | 否 | restart | stop |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
对象修复 - 修复结果
SDK方法名：describeObjFixResult
URL
/stream/obj_fix/result
Method
GET
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | @guid |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
mysql对象比较 - 新建
SDK方法名：createObjCmp
URL
/stream/obj_cmp
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| obj_cmp_name | String | 否 | 对象比较名称 | test | |
| src_db_uuid | String | 否 | 源端数据库uuid | 4CA773F4-36E3-A091-122C-ACDFB2112C21 | |
| tgt_db_uuid | String | 否 | 备端数据库uuid | 40405FD3-DB86-DC8A-81C9-C137B6FDECE5 | |
| cal_table_recoders | Number | 否 | 是否对比表的记录数 | 1 | |
| rule_uuid | String | 否 | 同步规则uuid | 751A03F5-C97D-645B-82B2-316A5D198528 | |
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| page | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_field | String | 否 | |||
| search_value | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | @guid | ||
| time_list | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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 | |
| 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | @guid |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | 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初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 | ["11111111-1111-1111-1111-111111111111"] |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |
mysql对象比较 - 操作
SDK方法名：停止：stopTbCmp; 重启：restartTbCmp;
URL
/stream/obj_cmp/operate
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
mysql获取对象比较状态
SDK方法名：listObjCmpStatus
URL
/stream/obj_cmp/status
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuids | Array | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| offset | Number | 否 | 1 | ||
| limit | Number | 否 | 10 | ||
| search_value | String | 否 | |||
| usr | String | 否 | I2 | ||
| filed | String | 否 | |||
| uuid | String | 否 | |||
| start_time | String | 否 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| uuid | String | 否 | @guid | ||
| start_time | String | 否 | |||
| limit | Number | 否 | |||
| offset | String | 否 | |||
| search_value | String | 否 | |||
| BackLackOnly | Number | 否 | 0 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| 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初始值 | Mock规则 |
|---|
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|
mysql-表修复-新建
SDK方法名：createStreamTableFix
URL
/stream/tb_cmp/table_fix
Method
POST
Request
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| rule_uuid | String | 否 | @guid | ||
| tab | Array | 否 | |||
| fix_relation | Number | 否 | 0 |
Response
| 名称 | 类型 | 必选 | 简介 | Mock初始值 | Mock规则 |
|---|---|---|---|---|---|
| ret | Number | 否 | 200 | ||
| msg | String | 否 | |||
| data | Object | 否 | |||
| message | String | 否 | |||
| code | Number | 否 | 0 |