oracle同步

November 18, 2022About 75 min

oracle同步

SDK类名:/active/OracleRule

同步规则-数据库预检(支持单个或者多个)

SDK方法名:describeRuleDbCheckMult;数据库预检

URL

/active/rule/db_check_mult

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listObject
    verString版本号
    langString字符集的信息
    nlangString国家字符集
    max_processesStringprocess 最大连接数
    db_block_sizeString
    all_redo_sizeStringredo log 总大小
    db_fileStringdb_files 数
    open_cursorString
    partition_large_extentsString成功:1
失败:0
    componentsObject组件列表
    min_supple_logString最小附加日志
成功:1
失败:0
1
    force_loggingString正确 1
失败:0

成功:1
失败:0
1
    index_partition_large_extentsString成功 1
失败 0
    open_archString开启归档
成功:1
失败:0
    db_connectString成功:1
失败:0
1
    noticeString注意事项
    uuidString

同步规则-增量失败DML统计

SDK方法名:describeSyncRulesDML

URL

/active/rule/incre_dml_summary

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber偏移位置1
limitString搜索行数10
usrString用户
rule_uuidString规则uuid@guid
sort_orderString排序方式asc
searchString搜索
sortString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    usrStringusr
    table_nameStringtable200
    irp_error_numberNumber30
    urp_error_numberNumber60
    drp_error_numberNumber90
  totalNumber1

同步规则-已同步的对象具体信息

SDK方法名:describeSyncRulesObjInfo

URL

/active/rule/sync_obj_info

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitNumber10
rule_uuidString@guid
usrString
sortString
sort_orderString
searchString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray2
    nAllNumber
    eAllNumber
    nameStringI2_1
    nRowString112003
    eIRPString0
    eURPString0
    eDRPString1
    nIRPString1
    nURPString1
    nDRPString1
    stateString-
  totalNumber2000

同步|对象比较|对象修复|表比较 - 新建-准备-获取代理状态

SDK方法名:describeSyncRulesProxyStatus

URL

/active/rule/proxy_status

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] success
  proxyStringonline

同步规则 - 新建

SDK方法名:createOracleRule; 创建同步规则

URL

/active/rule

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
rule_nameString规则名称ctt->ctt
src_db_uuidString源端数据库uuid6C4AEF37-6496-6DCD-E085-DD640001E4EC
src_db_auth_uuidString源端用户认证uuid
tgt_db_uuidString备端数据库uuid1C5F3C4B-7333-9518-7349-9712BC9ED664
tgt_db_auth_uuidString备端用户认证uuid
start_rule_nowNumber开始规则0
row_map_modeString行映射方式rowid
tgt_typeString备库类型oracle
db_user_mapObject用户映射模式{"CTT":"CTT"}
full_map_switchNumber0:非整库映射,1:整库映射
map_type_listArray映射方式
map_typeString(旧版本参数)映射方式user
include_tab_with_columnArray格式为:用户,列1,列2,列3。(用户支持星号)例:
["U1, ID, NAME", "
, CARD"]
  userString原用户
  targetString目标用户或目标topic(kafka)
  columnString列名
include_tab_with_column_switchNumber0:关闭,1:开启
table_mapArray表映射模式
  dst_tableString备端表名a
  dst_userString备端用户b
  src_tableString源端表名c
  src_userString源端用户d
  columnArray
    dst_columnString备端字段e
    src_columnString源端字段f
sync_modeNumber1
dbmap_topicStringkfk 整库映射
start_scnString起始scn
storage_settingsObject高级->存储设置
  src_max_memNumber512
  src_max_diskNumber5000
  txn_max_memNumber10000
  tf_max_sizeNumber100
  tgt_extern_tableString
  max_ld_memString
table_space_mapObject高级->表空间映射
  tgt_table_spaceString
  table_mapping_wayStringptop
  table_path_mapObject{"ddd":"sss","ddd1":"sss1"}
  table_space_nameObject{"qq":"ss"}
other_settingsObject高级->其他设置
  keep_dyn_dataNumber0
  dyn_threadNumber1
  dly_constraint_loadNumber0
  zip_levelNumber0
  ddl_cvNumber备端对删除的表进行备份0
  keep_bad_actNumber0
  keep_usr_pwdNumber1
  convert_urp_of_keyNumber0
  merge_trackString统一解析
  ignore_foreign_keyNumber0
  table_delay_loadArray["hh.ww"]
  fill_lob_columnString
  keep_seq_syncString
  gen_txnString
  encrypt_switchNumber
  encrypt_typeNumber
  table_change_infoNumber表结构变更通知
  encrypt_keyString
  message_formatStringprotobuf
json
  json_formatStringjson
canaljson
message_format为json时,可传json , canaljson, 其他值传空串
  run_timeString运行时间"1200:00-13:0040M,300:00-13:0040M"
  jointingObject字段拼接
    tableString
    opString操作
op类型定义
前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide
append
    contentArray目标列+其他两行
bw_settingsObject高级->宽带设置
  bw_limitString"1200:00-13:0040M,300:00-13:0040M"
full_sync_settingsObject全同步设置
  load_thdNumber1
  keep_exist_tableNumber0
  keep_tableNumber0
  ld_dir_optNumber0
  his_threadNumber1
  try_split_part_tableNumber0
  concurrent_tableArray["hello.world"]
  dump_thdNumber1
  clean_user_before_dumpNumber0
  existing_tableStringdrop_to_recycle
  sync_modeNumber0
  start_scnString
full_sync_obj_filterObject全同步对象过滤
  full_sync_obj_dataArray["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filterObject增量同步对象ddl过滤
  inc_sync_ddl_dataArray["INDEX","VIEW","FUNCTION"]
filter_table_settingsObject过滤表
  exclude_tableArray["hh.ww"]
  exclude_tab_with_columnArray格式为:用户,列1,列2,列3。(用户支持星号)例:
["U1, ID, NAME", "
, CARD"]
  exclude_tab_with_column_switchNumber0:关闭,1:开启
etl_settingsObjectetl
  etl_tableArray
    oprTypeStringIRP
    tableString
    userString
    processStringSKIP
    addInfoString
biz_grp_listArray分组业务
kafka_time_outString12000
part_load_balanceStringby_table
kafka_message_encodingStringUTF-8
save_json_textBoolean【目标为Kafka】“另存文本文件”开关false
kafkaArray
  binary_codeString取值 hex , base64hex
dml_trackArray
  enableBoolean是否启用 true
  keep_deleted_rowBoolean是否保留删除列 true
  date_columnString操作日期字段名
  time_columnString操作时间字段名
  date_time_columnString操作日期+时间字段名
  op_columnString操作标记字段名
  opv_insertString操作标记字段:插入操作标记值
  opv_updateString操作标记字段:更新操作标记值
  opv_update_keyString操作标记字段:更新主键、唯一键操作标记值
  opv_deleteString操作标记字段:删除操作标记值
  auditBoolean是否启用审计表
  audit_prefixString审计表前辍
  audit_appendixString审计表后辍
  identity_columnString自增列字段AUTO_INCR
  load_date_columnString装载仅日期
  load_time_columnString装载仅时间
  load_date_time_columnString时间和日期
error_handlingObject高级->错误处理
  load_err_setString装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
continue
  drpString删除时未找到记录
ignore :忽略
err:报错
ignore
  irpString插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
irpafterdel
  urpString更新时为找到记录
toirp: 转换为插入
err:报错
toirp
  report_failed_dmlNumber上传dml 错误
0:没选中
1:选中
encrypt_switchString加密开关 0:关,1:开
encryptString加密格式 0:aes,1:sm4
secret_keyString密钥内容
compress_switchString压缩开关 0:关,1:开
compressString压缩等级

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess
  uuidString@uuid

同步规则 - 批量新建

SDK方法名:createBatchOracleRule;

URL

/active/rule/batch

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
prefixString规则名称前缀temp
db_listArray数据库列表
  src_db_uuidString源端数据库uuid6C4AEF37-6496-6DCD-E085-DD640001E4EC
  tgt_db_uuidString备端数据库uuid
tgt_typeString备端数据库类型
start_rule_nowNumber开始规则0
row_map_modeString行映射方式rowid
db_user_mapObject用户映射模式{"CTT":"CTT"}
map_typeString映射方式user
table_mapArray表映射模式[{}]
sync_modeNumber1
dbmap_topicStringkfk 整库映射
start_scnString起始scn
storage_settingsObject高级->存储设置
  src_max_memNumber512
  src_max_diskNumber5000
  txn_max_memNumber10000
  tf_max_sizeNumber100
  tgt_extern_tableString
  max_ld_memString
table_space_mapObject高级->表空间映射
  tgt_table_spaceString
  table_mapping_wayStringptop
  table_path_mapObject{"ddd":"sss","ddd1":"sss1"}
  table_space_nameObject{"qq":"ss"}
other_settingsObject高级->其他设置
  keep_dyn_dataNumber0
  dyn_threadNumber1
  dly_constraint_loadNumber0
  zip_levelNumber0
  ddl_cvNumber备端对删除的表进行备份0
  keep_bad_actNumber0
  keep_usr_pwdNumber1
  convert_urp_of_keyNumber0
  merge_trackString统一解析
  ignore_foreign_keyNumber0
  table_delay_loadArray["hh.ww"]
  fill_lob_columnString
  keep_seq_syncString
  gen_txnString
  encrypt_switchNumber
  encrypt_typeNumber
  table_change_infoNumber表结构变更通知
  encrypt_keyString
  message_formatStringprotobuf
json
  json_formatStringjson
canaljson
message_format为json时,可传json , canaljson, 其他值传空串
  run_timeString运行时间"1200:00-13:0040M,300:00-13:0040M"
  jointingObject字段拼接
    tableString
    opString操作
op类型定义
前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide
append
    contentArray目标列+其他两行
bw_settingsObject高级->宽带设置
  bw_limitString"1200:00-13:0040M,300:00-13:0040M"
full_sync_settingsObject全同步设置
  load_thdNumber1
  keep_exist_tableNumber0
  keep_tableNumber0
  ld_dir_optNumber0
  his_threadNumber1
  try_split_part_tableNumber0
  concurrent_tableArray["hello.world"]
  dump_thdNumber1
  clean_user_before_dumpNumber0
  existing_tableStringdrop_to_recycle
  sync_modeNumber0
  start_scnString
full_sync_obj_filterObject全同步对象过滤
  full_sync_obj_dataArray["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filterObject增量同步对象ddl过滤
  inc_sync_ddl_dataArray["INDEX","VIEW","FUNCTION"]
filter_table_settingsObject过滤表
  exclude_tableArray["hh.ww"]
etl_settingsObjectetl
  etl_tableArray
    oprTypeStringIRP
    tableString
    userString
    processStringSKIP
    addInfoString
biz_grp_listArray分组业务
kafka_time_outString12000
part_load_balanceStringby_table
kafka_message_encodingStringUTF-8
save_json_textBoolean【目标为Kafka】“另存文本文件”开关false
kafkaArray
  binary_codeString取值 hex , base64hex
dml_trackArray
  enableBoolean是否启用 true
  keep_deleted_rowBoolean是否保留删除列 true
  date_columnString操作日期字段名
  time_columnString操作时间字段名
  date_time_columnString操作日期+时间字段名
  op_columnString操作标记字段名
  opv_insertString操作标记字段:插入操作标记值
  opv_updateString操作标记字段:更新操作标记值
  opv_update_keyString操作标记字段:更新主键、唯一键操作标记值
  opv_deleteString操作标记字段:删除操作标记值
  auditBoolean是否启用审计表
  audit_prefixString审计表前辍
  audit_appendixString审计表后辍
  identity_columnString自增列字段AUTO_INCR
  load_date_columnString装载仅日期
  load_time_columnString装载仅时间
  load_date_time_columnString时间和日期
error_handlingObject高级->错误处理
  load_err_setString装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
continue
  drpString删除时未找到记录
ignore :忽略
err:报错
ignore
  irpString插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
irpafterdel
  urpString更新时为找到记录
toirp: 转换为插入
err:报错
toirp
  report_failed_dmlNumber上传dml 错误
0:没选中
1:选中

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess
  uuidString@uuid

同步规则 - 修改

SDK方法名:modifyOracleRule;修改同步规则

URL

/active/rule

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
rule_nameString表名ctt->ctt
src_db_uuidString源库uuid6C4AEF37-6496-6DCD-E085-DD640001E4EC
tgt_db_uuidString备库uuid1C5F3C4B-7333-9518-7349-9712BC9ED664
start_rule_nowNumber开始同步规则0
row_map_modeString行映射方式rowid
tgt_typeString备库类型oracle
db_user_mapObject用户映射{"CTT":"CTT"}
map_typeString映射类型user
table_mapArray表映射[{}]
dbmap_topicStringkfk 整库映射test1
sync_modeNumber1
start_scnString起始scn1
storage_settingsObject高级->存储设置
  src_max_memNumber512
  src_max_diskNumber5000
  txn_max_memNumber10000
  tf_max_sizeNumber100
  tgt_extern_tableString1
  max_ld_memString1
table_space_mapObject高级->表空间映射
  tgt_table_spaceString1
  table_mapping_wayStringptop
  table_path_mapObject{"ddd":"sss","ddd1":"sss1"}
  table_space_nameObject{"qq":"ss"}
other_settingsObject高级->其他设置
  keep_dyn_dataNumber0
  dyn_threadNumber1
  dly_constraint_loadNumber0
  zip_levelNumber0
  ddl_cvNumber备端对删除的表进行备份0
  keep_bad_actNumber0
  keep_usr_pwdNumber1
  convert_urp_of_keyNumber0
  ignore_foreign_keyNumber0
  table_delay_loadArray
    tableString
    userString
  keep_seq_syncString1
  fill_lob_columString
  gen_txnString1
  merge_trackString
  sync_lobNumber是否同步lob 数据
  table_change_infoNumber表结构变更通知1
  message_formatStringprotobuf
json
  json_formatStringjson
canaljson
message_format为json时,可传json , canaljson, 其他值传空串
  run_timeString运行时间
error_handlingObject高级->错误处理
  load_err_setString装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
continue
  drpString删除时未找到记录
ignore :忽略
err:报错
ignore
  irpString插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
irpafterdel
  urpString更新时为找到记录
toirp: 转换为插入
err:报错
toirp
  report_failed_dmlNumber上传dml 错误
0:没选中
1:选中
bw_settingsObject高级->宽带设置
  bw_limitString"1200:00-13:0040M,300:00-13:0040M"
full_sync_settingsObject全同步设置
  keep_exist_tableNumber0
  keep_tableNumber0
  load_modeStringdirect
  ld_dir_optNumber0
  his_threadNumber1
  try_split_part_tableNumber0
  concurrent_tableArray["hello.world"]
  dump_thdNumber1
  clean_user_before_dumpNumber1
  existing_tableStrings
  sync_modeNumber1
  start_scnString1
  load_thdNumber
full_sync_obj_filterObject全同步对象过滤
  full_sync_obj_dataArray["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filterObject增量同步对象ddl过滤
  inc_sync_ddl_dataArray["INDEX","VIEW","FUNCTION"]
filter_table_settingsObject过滤表
  exclude_tableArray["hh.ww"]
etl_settingsObjectetl
  etl_tableArray
    oprTypeStringIRP
    tableString1
    userStringuser
    processStringSKIP
    addInfoString1
biz_grp_listArray分组业务
kafka_time_outStringproducer 超时时间12000
part_load_balanceString分区均衡策略12
rule_uuidStringF530FB0E-0208-9071-66D3-E595AE7D5A4C
kafkaArray
  binary_codeString取值 hex , base64base64
dml_trackArray
  enableBoolean1
  urpNumber1
  drpNumber1
  tmcolString1
  delcolString1
save_json_textBoolean【目标类型:Kafka】另存文本文件false

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess
  uuidString@uuid

同步规则 - 批量修改

SDK方法名:modifyOracleRuleBatch;批量修改同步规则

URL

/active/rule/batch

Method

PUT

Request

名称类型必选简介Mock初始值Mock规则
rule_uuidsArray需要被修改的规则
start_rule_nowNumber开始同步规则0
row_map_modeString行映射方式rowid
tgt_typeString备库类型oracle
db_user_mapObject用户映射{"CTT":"CTT"}
map_typeString映射类型user
table_mapArray表映射[{}]
dbmap_topicStringkfk 整库映射test1
sync_modeNumber1
start_scnString起始scn1
storage_settingsObject高级->存储设置
  src_max_memNumber512
  src_max_diskNumber5000
  txn_max_memNumber10000
  tf_max_sizeNumber100
  tgt_extern_tableString1
  max_ld_memString1
table_space_mapObject高级->表空间映射
  tgt_table_spaceString1
  table_mapping_wayStringptop
  table_path_mapObject{"ddd":"sss","ddd1":"sss1"}
  table_space_nameObject{"qq":"ss"}
other_settingsObject高级->其他设置
  keep_dyn_dataNumber0
  dyn_threadNumber1
  dly_constraint_loadNumber0
  zip_levelNumber0
  ddl_cvNumber备端对删除的表进行备份0
  keep_bad_actNumber0
  keep_usr_pwdNumber1
  convert_urp_of_keyNumber0
  ignore_foreign_keyNumber0
  table_delay_loadArray
    tableString
    userString
  keep_seq_syncString1
  fill_lob_columString
  gen_txnString1
  merge_trackString
  sync_lobNumber是否同步lob 数据
  table_change_infoNumber表结构变更通知1
  message_formatStringprotobuf
json
  json_formatStringjson
canaljson
message_format为json时,可传json , canaljson, 其他值传空串
  run_timeString运行时间
error_handlingObject高级->错误处理
  load_err_setString装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
continue
  drpString删除时未找到记录
ignore :忽略
err:报错
ignore
  irpString插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
irpafterdel
  urpString更新时为找到记录
toirp: 转换为插入
err:报错
toirp
  report_failed_dmlNumber上传dml 错误
0:没选中
1:选中
bw_settingsObject高级->宽带设置
  bw_limitString"1200:00-13:0040M,300:00-13:0040M"
full_sync_settingsObject全同步设置
  keep_exist_tableNumber0
  keep_tableNumber0
  load_modeStringdirect
  ld_dir_optNumber0
  his_threadNumber1
  try_split_part_tableNumber0
  concurrent_tableArray["hello.world"]
  dump_thdNumber1
  clean_user_before_dumpNumber1
  existing_tableStrings
  sync_modeNumber1
  start_scnString1
  load_thdNumber
full_sync_obj_filterObject全同步对象过滤
  full_sync_obj_dataArray["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filterObject增量同步对象ddl过滤
  inc_sync_ddl_dataArray["INDEX","VIEW","FUNCTION"]
filter_table_settingsObject过滤表
  exclude_tableArray["hh.ww"]
etl_settingsObjectetl
  etl_tableArray
    oprTypeStringIRP
    tableString1
    userStringuser
    processStringSKIP
    addInfoString1
biz_grp_listArray分组业务
kafka_time_outStringproducer 超时时间12000
part_load_balanceString分区均衡策略12
rule_uuidStringF530FB0E-0208-9071-66D3-E595AE7D5A4C
kafkaArray
  binary_codeString取值 hex , base64base64
dml_trackArray
  enableBoolean1
  urpNumber1
  drpNumber1
  tmcolString1
  delcolString1
save_json_textBoolean【目标类型:Kafka】另存文本文件false
batch_basic_settingsNumber基本设置 批量更新开关 0:关闭, 1:开启0
batch_full_sync_settingsNumber全量设置 批量更新开关 0:关闭, 1:开启0
batch_incre_sync_settingsNumber增量设置 批量更新开关 0:关闭, 1:开启0
batch_advanced_settingsNumber高级设置 批量更新开关 0:关闭, 1:开启0
batch_full_sync_obj_filterNumber全量对象设置 批量更新开关 0:关闭, 1:开启0
batch_inc_sync_ddl_filterNumber增量DDL设置 批量更新开关 0:关闭, 1:开启0
batch_encrypt_compressNumber加密压缩设置 批量更新开关 0:关闭, 1:开启0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess
  resultArray
    rule_uuidString
    codeString
    messageString

同步规则-删除

SDK方法名:deleteOracleRule

URL

/active/rule

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
rule_uuidsArray规则数组["DBED8CDE-435D-7865-76FE-149AA54AC7F7"]
typeStringfalse_rule
forceBooleantrue

Response

名称类型必选简介Mock初始值Mock规则
msgString
dataObject
  codeNumber1
  messageStringDelete success
  success_listArray
    codeString0
    rule_uuidStringsfasf
    rule_nameStringdddddd
    messageStringdddd
  fail_listArray
    codeNumber-1
    messageStringdfrrr
    rule_uuidStringyrtrshgf
    rule_nameStringgfhfdhfsh
retNumber200

同步规则-列表

SDK方法名:listSyncRules

URL

/active/rule

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber偏移数1
limitNumber最多多少行10
search_fieldString搜索域rule_name
search_valueString搜索值
group_uuidString查询业务组
where_argsObject
  rule_uuidString@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray2
    src_db_nameStringdb103
    tgt_db_nameStringdb105
    usernameStringadmin
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    rule_uuidArray['6ECF19A1-3754-1490-C6A3-52AFB4D7F497', '6ECF19A1-3754-1490-C6A3-52AFB4D7F496']+1
    src_db_uuidStringAF16E01E-6988-D0FA-3A7F-DEE04C4D3B4A
    tgt_db_uuidString72855161-CD57-6FB5-C195-B19F466AB2C0
    rule_typeNumber0
    rule_nameString123123
    node_uuidString
    tgt_typeStringoracle
    db_user_mapString
    row_map_modeStringrowid
    map_typeStringdb
    table_mapString
    dbmap_topicString
    sync_modeString1
    start_scnString0
    storage_settingsString{"src_max_mem":"512","src_max_disk":"5000","txn_max_mem":"10000","tf_max_size":"100","max_ld_mem":"512","tgt_extern_table":""}
    table_space_mapString{"tgt_table_space":"","table_mapping_way":"ptop","table_path_map":[],"table_space_name":[]}
    other_settingsString{"keep_dyn_data":0,"dyn_thread":1,"dly_constraint_load":0,"zip_level":0,"ddl_cv":0,"keep_bad_act":0,"keep_usr_pwd":0,"convert_urp_of_key":0,"ignore_foreign_key":0,"gen_txn":0,
"merge_track":1}
    error_handlingString{"irp":"irpafterdel","urp":"toirp","drp":"ignore","load_err_set":"continue","report_failed_dml":0}
    bw_settingsString{"bw_limit":""}
    strateNull
    full_sync_settingsString{"existing_table":"drop_to_recycle","load_mode":"direct","ld_dir_opt":0,"his_thread":1,"try_split_part_table":1,"concurrent_table":"[]","clean_user_before_dump":0}
    full_sync_obj_filterString{"full_sync_obj_data":["INDEX","VIEW","FUNCTION","PROCEDURE","PACKAGE","PACKAGE BODY","SYNONYM","TRIGGER","SEQUENCE","JAVA CLASS","TYPE","TYPE BODY","MATERIALIZED VIEW","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]}
    inc_sync_ddl_filterString{"inc_sync_ddl_data":["CREATE TABLE","DROP TABLE","ALTER TABLE","TABLE ADD","TABLE DROP","TABLE MODIFY","TABLE RENAME","TRUNCATE TABLE","MOVE TABLE","CREATE COMMENT","ADD PARTITION","DROP PARTITION","ADD SUBPARTITION","DROP SUBPARTITION","SPLIT PARTITION","SPLIT SUBPARTITION","MERGE SUBPARTITION","MERGE PARTITION","SWAP","ALTER LVAL","SET TEMPLATE","CREATE INDEX","DROP INDEX","ALTER INDEX","RENAME INDEX","CREATE TYPE","DROP TYPE","CREATE VIEW","DROP VIEW","CREATE SYN","DROP SYN","ADD CONSTRAINT","DROP CONSTRAINT","ALTER CONSTRAINT","CREATE SEQUENCE","DROP SEQUENCE","ALTER SEQUENCE","CREATE ROLE","DROP ROLE","ALTER ROLE","GRANT SYS","GRANT OBJ","REVOKE SYS","REVOKE OBJ","CREATE MVIEW LOG","DROP MVIEW LOG","CREATE MVIEW","DROP MVIEW","CREATE JAVA","DROP JAVA","CREATE CLASS","DROP CLASS","CREATE RESOURCE","DROP RESOURCE","CREATE PROFILE","DROP PROFILE","ALTER PROFILE","CREATE PROC","DROP PROC","ALTER PROC","CREATE DROP DBLINK","CREATE QUEUE","DROP QUEUE","ALTER QUEUE","CREATE TABLESPACE","DROP TABLESPACE","ALTER TABLESPACE","RENAME TABLESPACE","ADD HASH PARTITION","SWAPS","ADD CONSTRAINTS"]}
    filter_table_settingsString{"exclude_table":"[]"}
    etl_settingsString{"etl_table":[]}
    create_timeNumber1593511163
    start_rule_nowString1
    db_map_uuidString
    dml_trackString{"enable":0,"urp":0,"drp":0,"tmcol":"","delcol":""}
    kafka_time_outString
    part_load_balanceStringby_table
    kafkaTimeoutString12000
    partLoadBalanceStringby_key
    is_biz_adminNumber1
    can_delNumber1
    can_opNumber1
    can_upNumber1
  totalNumber11

同步规则-获取单个

SDK方法名:describeSyncRules

URL

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

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
uuidStringF530FB0E-0208-9071-66D3-E595AE7D5A4C

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageStringsuccess
  codeNumber0
  info_listObject
    rule_uuidString751A03F5-C97D-645B-82B2-316A5D198528
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    tgt_typeStringkafka
    db_user_mapString{"11":"1122"}
    row_map_modeStringrowid
    map_typeStringuser
    table_mapArray[{src_user: "111", src_table: "222", dst_user: "3", dst_table: "4"}]
    dbmap_topicString
    node_uuidString
    sync_modeNumber0
    start_scnString0
    full_sync_settingsObject
      keep_exist_tableNumber0
      keep_tableNumber0
      load_modeStringdirect
      ld_dir_optNumber0
      his_threadNumber1
      try_split_part_tableNumber0
      concurrent_tableArray["hello.world"]
    rule_nameStringctt->ctt
    inc_sync_ddl_filterObject
      inc_sync_ddl_dataArray["CREATE TABLE","DROP TABLE","ALTER TABLE"]
    filter_table_settingsObject
      exclude_tableArray["hh.ww"]
    etl_settingsObject
      etl_tableArray[{obj_fix_type: "URP", user: "123", table: "123", deal_type: "SKIP", field_condition: "44"}]
    start_rule_nowNumber0
    storage_settingsObject
      src_max_memNumber512
      src_max_diskNumber5000
      txn_max_memNumber10000
      tf_max_sizeNumber100
      tgt_extern_tableString
    error_handlingObject
      load_err_setStringcontinue
      drpStringignore
      irpStringirpafterdel
      urpStringtoirp
    table_space_mapObject
      tgt_table_spaceString
      table_mapping_wayStringptop
      table_path_mapString{"ddd":"sss"}
      table_space_nameString{"qq":"ss"}
    other_settingsObject
      keep_dyn_dataNumber0
      dyn_threadNumber1
      dly_constraint_loadNumber0
      zip_levelNumber0
      ddl_cvNumber0
      keep_bad_actNumber0
      keep_usr_pwdNumber1
      convert_urp_of_keyNumber0
      ignore_foreign_keyNumber0
    bw_settingsObject
      bw_limitString1200:00-13:0040k,300:00-13:0040m
    biz_grp_listArray业务组
    dml_trackObject
      enableNumber1
      urpNumber0
      drpNumber1
      tmcolString
      delcolString
    producer_send_timeString66666
    part_load_balanceStringby_table
    kafka_time_outString132000
    full_sync_obj_filterObject
      full_sync_obj_dataArray["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]

同步规则 - 操作

SDK方法名:

继续:resumeOracleRule;

停止:stopOracleRule;

重启:restartOracleRule

开始日志解析:startAnalysisOracleRule;

停止日志解析:stopAnalysisOracleRule;

重新日志解析:resetAnalysisOracleRule;

停止规则并停止日志解析:stopAndStopanalysisOracleRule;

URL

/active/rule/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
operateStringresume 继续
stop 停止
restart 重启
start_analysis
stop_analysis
reset_analysis
stop_and_stopanalysis
stop_schedule 停止调度(暂弃)
start_chedule 启动调度(暂弃)
restart
rule_uuidString@guid
scnString1
allNumber

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

同步规则-日志

SDK方法名:listRuleLog;同规则的日志管理

URL

/active/rule/log

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitNumber10
date_startString开始时间@date
date_endString开始时间的结束时间@date
typeNumber0:错误 2:消息 -1:全部-1
module_typeNumber0:导出 1:装载 2:解析 3:中继 4:脱敏 -1 全部-1
query_typeNumber最新查询:1 最早查询:2 查询 :01
rule_uuidString规则uuidF530FB0E-0208-9071-66D3-E595AE7D5A4C

Response

名称类型必选简介Mock初始值Mock规则
msgString
dataObject
  codeNumber0
  messageStringDelete success
  info_listArray5
    create_timeString2019-08-09 17:29:43
    detailStringFull Sync done, elapsed time: 24 sec'
    log_levelString日志级别 0:serious 2
2
    flagNumber0:正常, 1新信息 标红1
    log_typeString模块: 导出,装载,解析装载
    uuidString@uuid
  totalNumber666
retNumber200

同步规则-状态

SDK方法名:listSyncRulesStatus

URL

/active/rule/status

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  has_false_ruleBoolean是否有残留规则false
  info_listArray2
    rule_uuidString同步规则 uuid['6ECF19A1-3754-1490-C6A3-52AFB4D7F497', '6ECF19A1-3754-1490-C6A3-52AFB4D7F496']+1
    work_stateObject导出状态信息
      statusStringACTIVE_RULE_PAUSE: 停止
ACTIVE_RULE_DUMP: 全量
ACTIVE_RULE_TRACK:增量
ACTIVE_RULE_DONE:完成
ACTIVE_RULE_OFFLINE:离线
ACTIVE_RULE_TRACK
      error_codeNumber-4018
      progressString[98, 66]+1
    back_stateObject装载信息
      statusString同上work_stateACTIVE_RULE_PAUSE
    relay_stateObject中继节点的信息
      statusString同上work_state
      error_codeString
    track_stateObject解析状态信息
      statusString同上work_state['ACTIVE_RULE_PAUSE', 'OFFLINE']+1
    src_stateObject此功能对应数据源的状态,领导要求暂时屏蔽此功能,可不看
      statusStringACTIVE_RULE_UNKNOWN
    dst_stateObject同src_state
      statusStringACTIVE_RULE_UNKNOWN
    extractString解析时间-
    loadString装载时间-
    delayNumber延迟0
    peakNumber峰值0
    has_new_errNumber对应日志报警 1:显示有新的日志
0:没有新日志产生
1
    data_infoObject对应的悬浮框内的信息
      dstObject目标端
        db_ipArray目标端ip["192.168.12.199"]
        node_ipString节点ip192.168.12.199
        node_nameString名称test_c199
        log_read_typeString日志读取方式file
        orclString服务名orcl
      srcObject数据源
        db_ipArray数据库ip["192.168.12.200"]
        node_ipString节点ip192.168.12.200
        node_nameString节点名test_c200
        log_read_typeString读取方式file
        orclString服务名orcl
    stageString对应原先功能总览->同步规则的功能,暂时弃用PAUSE
    stateNumber对应原先功能总览->同步规则的功能,暂时弃用-4018
    progressNull对应原先功能总览->同步规则的功能,暂时弃用
    scheduleStateStringACTIVE_RULE_SCHEDULING:调度中
ACTIVE_RULE_STOP_SCHEDUL:停止调度
ACTIVE_RULE_STOP_SCHEDUL

同步规则 - 通用状态

SDK方法名:listSyncRulesGeneralStatus

URL

/active/rule/general_status

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray["@guid","@guid"]

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray2
    uuidString'6ECF19A1-3754-1490-C6A3-52AFB4D7F497',
    stageStringpause: 停止
dump: 全量
track:增量
done:完成
offline:离线
stop
    stateNumber0:正常
非0:错误
-4017
    progressNumber进度0

同步规则-已同步的对象

SDK方法名:describeSyncRulesHasSync

URL

/active/rule/sync_obj

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetString0
limitNumber10
row_uuidString@guid
searchString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject3
  messageString
  codeNumber0
  info_listArray2
    usrStringI2
    numString18/0
    indexString4/0
    viewString/
    functionString/
    procedureString/
    packageString/
    package_bodyString/
    synonymString/
    triggerString/
    sequenceString/
    java_sourceString/
    java_classString/
    java_resourceString/
    typeString/
    type_bobyString/
    queueString/
    materialized_viewString/
    dblinkString/
  totalNumber总共多少条数据1

同步规则-失败的对象

SDK方法名:describeSyncRulesFailObj

URL

/active/rule/fail_obj

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitNumber10
rule_uuidString@guid
searchString
typeNumber全部:-1; 按对象类型收集错误对象,支持 0="TABLE", 1="TABLE PARTITION", 2="CONSTRAINT", 3="INDEX", 4="VIEW", 5="FUNCTION", 6="PROCEDURE", 7="PACKAGE", 8="PACKAGE BODY", 9="SYNONYM", 10="TRIGGER", 11="SEQUENCE", 12="JAVA SOURCE", 13="JAVA CLASS", 14="JAVA RESOURCE", 15="TYPE", 16="TYPE BODY", 17="QUEUE", 18="MATERIALIZED VIEW", 19="DATABASE LINK", 20="MATERIALIZED VIEW LOG", 21="JOB", 22="OLD JOB", 23="PRIVS", 24="LIBRARY", 25="INDEXTYPE", 26="USER", 27="TABLESPACE", 28="UDT",
stageNumber所有:-1 全量阶段:0 增量阶段:1

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray
    usrString222
    nameStringdd
    typeStringTABLE
    stageNumber0 全量 1增量1
  totalNumber1

同步规则-装载信息流量图

SDK方法名:describeSyncRulesLoadInfo;装载信息

URL

/active/rule/load_info

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listObject
    backObject备端信息
      full_backupArray2
        lineString01869964734445
        nameStringI2.COMDATALILY.BMSQL_ORDER_LINE12333333
        tunnelString76.7 MB76.7 MB
      load_threadArray2
        numString0
        sizeString0
      loader_infoObject
        actfailString0
        actloadString0
        compress_rateNumber0
        maxdelayString0ms
        scnTimeString1969-12-31 16:00:00
        txndelayString0ms
        scnString
      nameString200-db
      processNumber94.44
      stateStringdump
      uuidString4CFE1f68-B29e-E1b3-EE1c-7E51ebFcDf61
      preprocessObject
        splitString111
        irpString222
        urpString333
        drpString444
        ddlString555
      ldTypeStringkafka
      extLdStObject
        dml_cntObject
          urpString111
          drpString222
          failedString333
          irpString444
        update_timeString2020-03-24 15:24:57
        ddl_cntString666
    workObject工作机信息
      full_backupArray2
        lineString186996473
        nameStringLILY.BMSQL_ORDER_LINE
        tunnelString0 Bytes
      nameString199-db
      processNumber72.22
      stateStringdump
      threadsArray2
        numString0
        timeString2019-07-18 10:47:45
        breakpointString1285.16940
        lwnString1285.16940
        stateNumber0
      txnObject
        drpString19128
        irpString19138
        memString0 Bytes
        mempeakString828 Bytes
        qmiString0
        stateString0
        txnString20222
        urpString0
      uuidString9Dbed7fd-1EEF-eA25-2611-eDBaCeC940FC
    relayObject中继信息
      stateNumber10
      outString111
      speedString5555
      cacheString56666
      memStringmem
      dskStringdsk
      wSeqString111
      rSeqString222

同步规则-增量失败dml

SDK方法名:listRuleIncreDml;增量失败

URL

/active/rule/incre_dml

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitString10
rule_uuidString@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    create_timeString2019-07-23 12:10:57
    exe_sqlStringALTER TABLE "I2"."LIU" ADD ( "GENGYANQI" VARCHAR2 (100))
    messageStringORA-00942: table or view does not exist
    src_sqlString失败rowid :alter table liu add gengyanqi varchar(100)
    obj_nameStringTEST_DML
    opr_typeStringTABLE ADD
    user_nameStringI2
  totalNumber1

同步规则-已同步表

SDK方法名:listRuleSyncTable;已同步的表

URL

/active/rule/sync_table

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
row_uuidString@guid
limitNumber15
offsetNumber1

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray20
    doneNumber已同步的表
    dDrpNumber删除
    dIrpNumber插入
    dUrpNumber更新
    eDrpNumber错误删除
    eIrpNumber错误插入0
    eUrpNumber错误更新0
    errNumber出错表
    userNumber用户名0
  totalString5

同步规则-获取数据库表字段

SDK方法名:describeRuleZStructure;获取数据库表字段

URL

/active/rule/z_structure

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
db_uuidString@guid
levelStringroot,user,col(0,1,2)
typeStringtab,user,db
tab_nameString搜索用到其他传空
type_valueStringtype 类型对应的值

Response

名称类型必选简介Mock初始值Mock规则
msgString
dataObject
  codeNumber0
  messageStringDelete success
  info_listArray2
    isParentBoolean没有子集 false,有 truetrue
    nameStringtest@name
retNumber200

同步规则-流量图

SDK方法名:describeSyncRulesMrtg;流量图

URL

/active/rule/mrtg

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
set_timeNumber开始时默认set_time等于 1, 默认值有改动 set_time_ranger*(分,小时,天)

页面自动刷新时 返回值最后一个
1
typeStringtype:traffic,memusg,delay,load_txn,load_action
intervalNumber计算方式: var interval = set_time_range > 15 ? Math.ceil(set_time_range / 3) : 5;

页面根据实际情况返回
时间间隔
set_time_initString上次时间的最后一个值
rule_uuidString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  maxString
  minString
  lastdateString
  messageString
  info_listArray返回的数据7
    start_timeString2018/11/08 10:40:06
    trafficNumber时间间隔1-100
  info_list_maxArray只有在事务延迟的情况才有值7
    start_timeString2018/11/08 10:40:06
    trafficNumber1-100
  intervalNumber5
  uuidString

同步规则-装载延迟统计报表

SDK方法名:listRuleLoadDelayReport;

URL

/active/rule/load_delay_report

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
typeStringsec
start_timeString
end_timeString
limitNumber10
offsetNumber0
uuidString1d2F6Fed-DAC6-FE94-A6cB-5Ab55415E9fd

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] success
  totalNumber2161
  info_listObject
    2020-02-05 22:28Array3
      0Number9999
      1Number82
      2Number125
      3Number52
      4Number0
      5Number0
      6Number6
      7Number7
      8Number8
      9Number9
      10Number10
      11Number11
      12String12
    2020-02-05 22:29Array
      0Number0
      1Number0
      2Number0
      3Number12
      4Number70
      5Number150
      6Number6
      7Number7
      8Number8
      9Number9
      10Number10
      11Number11
      12Number668
    2020-02-05 22:30Array
      0Number87
      1Number8
      2Number0
      3Number0
      4Number0
      5Number0
      6Number6
      7Number7
      8Number8
      9Number9
      10Number10
      11Number11
      12Number12
    2020-02-05 22:31Array
      0Number0
      1Number12
      2Number78
      3Number89.0
      4Number16.5
      5Number19.0
      6Number10.8
      7Number9.03
      8Number3.09
      9Number1.09
      10Number188
      11Number1.5
      12Number1.2

同步规则-增量失败ddl

SDK方法名:describeSyncRulesIncreDdl;增量失败ddl

URL

/active/rule/incre_ddl

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber0
limitString10
rule_uuidString@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    create_timeString2019-07-23 12:10:57
    exe_sqlStringALTER TABLE "I2"."LIU" ADD ( "GENGYANQI" VARCHAR2 (100))
    messageStringORA-00942: table or view does not exist
    obj_nameNumberLIU
    opr_typeNumberTABLE ADD
    src_sqlStringalter table liu add gengyanqi varchar(100)
    user_nameStringI2
  totalNumber1

同步规则-数据库预检

SDK方法名:describeRuleDbCheck;数据库预检

URL

/active/rule/db_check

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listObject
    verObject
      srcString11.1.0
      dstString11.0.0
      flagStringwarning
      msgStringbackVerNumLow
    langObject
      srcStringAMERICAN_AMERICA.AL32UTF8
      dstStringAMERICAN_AMERICA.AL32UTF8
      flagStringnormal
      msgString
    nlangObject
      srcStringAL32UTF16
      dstString
      flagStringwarning
      msgStringcharOnBothCountryIncon
    db_block_sizeObject
      srcString1
      dstString2
      flagStringwarning
      msgStringblockSizesTwoNotSame
    all_redo_sizeObject
      srcNumber1000
      dstNumber999
      flagStringnormal
      msgStringsmallCausePerTakeoverSlow
    max_processesObject
      srcNumber100
      dstNumber99
      flagStringwarning
      msgStringsmallCausePerTakeover
    db_fileObject
      src_db_fileNumber100
      dst_db_fileNumber999
      flagStringwarning
      msgStringsmallCauseCreateTableFileFail
    open_cursorObject
      srcNumber100
      dstNumber99
      flagStringwarning
      msgStringsmallCausePerTakeover
    partition_large_extentsObject
      srcBoolean
      dstNumberYES
      flagStringwarning
      msgStringcanLeadShortageTableSpace
    componentsObject
      srcArray[11,22]
      dstArray[11,22]
      flagStringnormal
      msgString
    not_support_objObject
      srcArray[11,22]
      dstArray[11,22]
      flagStringnormal
      msgString
    min_supple_logObject
      srcStringYES
      dstString
      flagStringwarning
      msgStringsourceMustMinAddLog
    force_loggingObject
      srcStringYES
      dstString
      flagStringwarning
      msgStringsourceMustLog
    index_partition_large_extentsObject
      srcBooleanYES
      dstBoolean
      flagStringwarning
      msgStringcanLeadShortageTableSpace
    open_archObject
      srcBooleanYES
      dstBooleanNO
      flagStringwarning
      msgStringcanLeadFullSlow
    db_connectObject
      srcBooleanYES
      dstBooleanYES
      flagStringerror
      msgString数据库连接失败,规则无法正常运行dbFailRuleNotRun
    noticeObject
      srcStringa\nb\n\c\n
      dstStringa
b
c
      flagStringwarning
      msgString

同步规则-获取残留规则

SDK方法名:describeRuleGetFalseRule;获取残留规则

URL

/active/rule/get_false_rule

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray2
    uuidString@guid
    nameString@name

同步规则-选择用户

SDK方法名:describeRuleSelectUser;选择用户

URL

/active/rule/select_user

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
db_uuidString数据uuid@guid

Response

名称类型必选简介Mock初始值Mock规则
msgString
dataObject
  codeNumber0
  messageStringDelete success
  info_listArray6
    idString
    pidString
    db_uuidStringdb_uuid@guid
    nameString@name
retNumber200

同步规则-表修复

SDK方法名:describeRuleTableFix;表修复

URL

/active/rule/table_fix

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
rule_uuidString规则uuidF530FB0E-0208-9071-66D3-E595AE7D5A4C
tabArrayI2.table["I2.table"]
fix_relationNumber0 无关联 1 有关联0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

同步规则-获取scn号

SDK方法名:describeRuleGetScn;

URL

/active/rule/get_scn

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  scnString

同步规则-装载统计报表

SDK方法名:listRuleLoadReport;

URL

/active/rule/load_report

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
typeStringsec
start_timeString
end_timeString
limitNumber10
offsetNumber0
uuidString1d2F6Fed-DAC6-FE94-A6cB-5Ab55415E9fd

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] success
  totalNumber2161
  info_listObject
    2020-02-05 22:28Array3
      0Number56
      1Number82
      2Number125
      3Number52
      4Number0
      5Number0
      6Number6
      7Number7
      8Number8
      9Number9
      10Number10
      11Number11
      12String12
    2020-02-05 22:29Array
      0Number0
      1Number0
      2Number0
      3Number12
      4Number70
      5Number150
      6Number6
      7Number7
      8Number8
      9Number9
      11Number11
      10Number10
      12Number668
    2020-02-05 22:30Array
      0Number87
      1Number8
      2Number0
      3Number0
      4Number0
      5Number0
      6Number6
      7Number7
      8Number8
      9Number9
      10Number10
      11Number11
      12Number12
    2020-02-05 22:31Array
      0Number0
      1Number12
      2Number78
      3Number84
      4Number145
      5Number8
      6Number999
      7Number7777
      8Number888
      9Number9999
      10Number1000
      11Number1188
      12Number12576

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

URL

/对象比较

Method

GET

Request

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

Response

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

对象比较 - 列表

SDK方法名:listObjCmp

URL

/active/obj_cmp

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  totalNumber20
  info_listArray16
    create_timeString1593511163
    obj_cmp_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    obj_cmp_nameStringtest
    src_db_uuidString3D7dFcd9-C176-d9ee-4FFB-f22bbd554926
    tgt_db_uuidString3D7dFcd9-C176-d9ee-4FFB-f22bbd554925
    cmp_typeStringuser
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    src_db_nameStringyuan
    tgt_db_nameStringbei
    usernameStringadmin
    can_opNumber1
    can_upNumber1
    can_delNumber1
    configObject
      one_taskString'immediate'
  messageString

对象比较 - 新建

SDK方法名:createObjCmp

URL

/active/obj_cmp

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
obj_cmp_nameString对象比较名称test
src_db_uuidString源端数据库uuid4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuidString备端数据库uuid40405FD3-DB86-DC8A-81C9-C137B6FDECE5
cal_table_recodersNumber是否对比表的记录数1
rule_uuidString同步规则uuid751A03F5-C97D-645B-82B2-316A5D198528
cmp_typeString类型user
db_user_mapString用户映射{'src_user':'dst_user'}
policiesString策略
policy_typeString策略类型periodic
one_timeString2019-05-27 16:07:08
repairNumber1
configObject
  one_taskString立即比较:immediate
选择时间:select_time
immediate

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  uuidString@uuid

对象比较 - 删除

SDK方法名:deleteObjCmp

URL

/active/obj_cmp

Method

DELETE

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber1
  success_listArray
    codeString
    messageStringfff
    obj_cmp_nameStringff
    obj_cmp_uuidStringgfsg
  fail_listArray
    codeString-1
    messageStringsgsdf
    obj_cmp_nameStringdsg
    obj_cmp_uuidStringsdfgdsg

对象比较 - 获取单个

SDK方法名:describeObjCmp

URL

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

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  active_obj_cmpObject
    obj_cmp_uuidString
    obj_cmp_nameStringtest
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    rule_uuidString751A03F5-C97D-645B-82B2-316A5D198528
    cmp_typeStringuser
    cal_table_recodersNumber1
    db_user_mapString{"user1":"user1"}
    policiesString1|00:091,2,3*1
    policy_typeStringperiodic
    one_timeString2019-05-27 16:07:08
    repairNumber1
  messageString
  codeNumber0

对象比较 - 操作

SDK方法名:{operate}ObjCmp

URL

/active/obj_cmp/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
operateStringcmp_stop (停止)
| cmp_restart (重启)
cmp_immediate(立即比较)
cmp_stop_time (停止定时)
obj_cmp_uuidsArray

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

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

SDK方法名:listObjCmpResultTimeList

URL

/active/obj_cmp/result_time_list

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  time_listArray16
    show_timeString2019-07-05 17:35:13
    summaryObject
      diffNumber1-100
    timeString2019-07-05_17-35-13
  totalNumber20

对象比较-比较任务结果

SDK方法名:describeObjCmpResult

URL

/active/obj_cmp/result

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
uuidString@guid
start_timeString开始时间
limitNumber
offsetString
search_valueString搜索值
BackLackOnlyNumber显示备端差异0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  result_infoObject
    totalNumber20
    rowsArray
      CONSTRAINTString1/1__1
      DATABASE LINKString0/0__1
      FUNCTIONString0/0__1
      INDEXString4/5__0
      JAVA CLASSString0/0__1
      JAVA RESOURCEString0/0__1
      JAVA SOURCEString0/0__1
      JOBString0/0__1
      MATERIALIZED VIEWString0/0__1
      OLD JOBString0/0__1
      PACKAGEString0/0__1
      PACKAGE BODYString0/0__1
      PRIVSString9/8__0
      PROCEDUREString0/0__1
      QUEUEString0/0__1
      SEQUENCEString0/0__1
      SYNONYMString0/0__1
      TABLEString18/19__0
      TABLE PARTITIONString0/0__1
      TRIGGERString0/0__1
      TYPEString0/0__1
      TYPE BODYString0/0__1
      VIEWString2/2__1
      usrStringI2/I2
  head_infoObject
    obj_cmp_nameStringMichelle Lewis

获取对象比较状态

SDK方法名:listObjCmpStatus

URL

/active/obj_cmp/status

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    cmp_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    wStObject
      statusStringERROR
      progressNumber
      error_codeNumber-4022
    bStObject
      statusStringDUMP
      progressString80
      error_codeString-22
    diff_numberNumber10

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

SDK方法名:describeObjCmpResultTimeList

URL

/active/obj_cmp/result_time_list

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidString@guid
time_listArray

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

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

SDK方法名:listObjCmpCmpInfo

URL

/active/obj_cmp/cmp_info

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber1
limitNumber10
search_valueString
usrStringI2
filedString
uuidString
start_timeString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listObject
    totalNumber2000
    rowsArray
      srcString1111
      dstString2222
    cal_table_recodersBoolean是否比较表的记录false

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

URL

/对象修复

Method

GET

Request

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

Response

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

对象修复 - 新建

SDK方法名:createObjFix

URL

/active/obj_fix

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
obj_fix_nameStringtest
src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
obj_mapStringtype对应类型值如下: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
obj_fix_uuidString@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  uuidString@uuid

对象修复 - 获取单个

SDK方法名:describeObjFix

URL

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

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  active_obj_fixObject
    obj_fix_nameStringtest
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    obj_fix_uuidString751A03F5-C97D-645B-82B2-316A5D198528
    obj_mapStringjson 字符串[{"INDEX":"owner.name"}]

对象修复 - 删除

SDK方法名:deleteObjFix

URL

/active/obj_fix

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray数组@guid
forceBooleanfalse

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  success_listArray
    codeString
    messageString
    obj_fix_nameString
    obj_fix_uuidString
  fail_listArray
    codeString
    messageString
    obj_fix_nameString
    obj_fix_uuidString

对象修复 - 列表

SDK方法名:listObjFix

URL

/active/obj_fix

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  totalNumber20
  info_listArray6
    create_timeString1593511163
    obj_fix_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    obj_fix_nameStringtest
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    src_db_nameStringyuan
    tgt_db_nameStringbei
    usernameStringadmin
    policy_typeString
immediate; one_time;periodic
immediate
  messageString

对象修复-操作

SDK方法名:

重新修复:restartObjFix;

停止:stopObjFix;

URL

/active/obj_fix/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
obj_fix_uuidsArray规则uuid
operateStringrestart | stop

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

对象修复 - 修复结果

SDK方法名:describeObjFixResult

URL

/active/obj_fix/result

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray
    obj_fix_typeString索引
    statusString修复状态on
    ownerString所有者@name
    nameString名称@name
  head_infoObject
    obj_fix_nameString@name

对象修复--获取状态

SDK方法名:listObjFixStatus

URL

/active/obj_fix/status

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    wStObject
      statusStringTRACK
      progressNumber1
    bStObject
      statusStringDUMP
      progressString80
    obj_fix_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87

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

URL

/表比较

Method

GET

Request

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

Response

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

表比较 - 新建

SDK方法名:createTbCmp

URL

/active/tb_cmp

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
tb_cmp_nameStringctt->ctt
src_db_uuidsArray["4CA773F4-36E3-A091-122C-ACDFB2112C21"]
tgt_db_uuidsArray["4CA773F4-36E3-A091-122C-ACDFB2112C22"]
cmp_typeStringuser,table,duser
db_user_mapString{"CTT":"CTT"}
filter_tableArray["i2.test"]
db_tb_mapString{"ctt:ctt"}
dump_thdNumber抽取线程数1
rule_uuidString@guid
policesString策略"0|00:00
policy_typeString策略类型;periodic(周期) ,one_time 一次性任务 immediate 立刻执行one_time
concurrent_tableArray并发表["hh.ww"]
try_split_part_tableNumber尝试并发设置 0:否 1:是0
one_timeString策略的开始时间,如果不是一次性任务为空值2019-05-27 16:07:08
repairNumber0
fix_relatedNumber0
configObject
  one_taskStringimmediate select_time
  tab_cmp_fiterArray
    userString
    tableString
    conditionString
  start_rule_nowNumber
report_msgNumber0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber
  uuidString@uuid

表比较 - 获取单个

SDK方法名:describeTbCmp

URL

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

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
uuidString表比较规则的uuid@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  active_tb_cmpObject
    table_cmp_nameStringctt->ctt
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    cmp_typeStringuser
    db_user_mapString{"CTT":"CTT"}
    filter_table_settingsString[用户.表名]
    db_tb_mapString表映射
    dump_thdNumber1
    rule_uuidString5DA7469c-b5d5-Bd53-5ADB-7Eee6D31e60B
    policiesString1|00:091,2,3*1
    policy_typeStringperiodic
    concurrentTabArray["hh.ww"]
    try_split_part_tableNumber0
    one_timeString2019-05-27 16:07:08

表比较 - 删除

SDK方法名:deleteTbCmp

URL

/active/tb_cmp

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray@guid
forceBooleanfalse

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  success_listArray
    codeStringsadgffdsg
    messageStringsdfg
    tb_cmp_nameStringsfdg
    tb_cmp_uuidStringsdgfs
  fail_listArray
    codeString-2
    messageStringfff
    tb_cmp_nameStringfff
    tb_cmp_uuidStringfff

表比较 - 列表

SDK方法名:listTbCmp

URL

/active/tb_cmp

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  totalNumber20
  info_listArray
    create_timeString1593511163
    tb_cmp_nameStringname321
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    tb_cmp_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    tgt_db_nameStringbei
    usernameStringadmin
    can_opNumber1
    can_upNumber1
    can_delNumber1
    is_biz_adminNumber1
    src_db_nameStringyuan
    policy_typeStringimmediate; one_time;periodicimmediate
    configObject
      one_taskString'immediate'
  messageString

状态接口

SDK方法名:listTbCmpStatus;状态接口

URL

/active/tb_cmp/status

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray2
    extractString解析时间2019-06-25 11:26:19
    cmp_uuidString@guid
    peakString峰值100
    dst_stateObject目标端
      statusString目标端状态OFFLINE
    delayString延迟10
    loadString装载时间2019-06-23 20:23:18
    work_stateObject同步规则对应导出,其他规则对应源机
      statusString状态ABNORMAL
      error_codeString错误码4017
    src_stateObject源端
      statusStringONLINE
    back_stateObject
      statusStringDUMP
      progressString80
    relay_stateObject装载
      statusStringTRACK
    track_stateObject解析
      statusStringUNKNOWN

表比较-操作

SDK方法名:

停止:stopTbCmp;

重启:restartTbCmp;

URL

/active/tb_cmp/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
tb_cmp_uuidsArray@guid
operateStringcmp_stop (停止)
| cmp_restart (启动)
cmp_immediate(立即比较)
cmp_stop_time (停止定时)

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

表比较 - 历史结果(查看表比较时间结果集)

SDK方法名:listTbCmpResultTimeList

URL

/active/tb_cmp/result_time_list

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  time_listArray16
    show_timeString2019-07-05 17:35:13
    rule_relatedNumber
    summaryObject
      totalNumber1192
      use_timeNumber844
      diffNumber130
    timeString2019-07-05_17-35-13
  totalNumber20

表比较-比较结果的删除

SDK方法名:describeTbCmpResuluTimeList;查看结果删除

URL

/active/tb_cmp/result_time_list

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidString
time_listArray@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

表比较-比较任务结果

SDK方法名:describeTbCmpResult

URL

/active/tb_cmp/result

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber1
limitNumber10
search_fieldString
search_valueString
uuidString@guid
start_timeString对应的时间
flagNumber0:仅显示差异表
1:显示所有比对表
0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  head_infoObject头比较信息
    totalNumber100
    errNumber10
    endString2019-10-10 12:00:00
    startString2019-10-10 10:00:00
    use_timeString3600
    all_errNumber20
  result_infoObject
    rowsArray10
      src_userStringuser
      src_table_nameStringAnna Martin
      srcStringCynthia Gonzalez
      dstStringRobert Johnson
      src_diff_msgString
      dst_diff_msgString
    totalNumber30
    rule_relatedNumber1

表比较-错误信息

SDK方法名:describeTbCmpErrorMsg;错误信息

URL

/active/tb_cmp/error_msg

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber1
limitNumber10
search_fieldString
search_valueString
uuidString@guid
start_timeString
nameString
ownerString所属者admin

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  result_infoObject
    rowsArray10
      src_rowString@name
      dst_rowString@name
    totalNumber2000

表比较-表比对的详细信息

SDK方法名:describeTbCmpCmpDesc;表比对的详细信息

URL

/active/tb_cmp/cmp_describe

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
offsetNumber1
limitNumber10
search_fieldString
search_valueString
uuidString@guid
start_timeString
nameString
ownerString所属者admin

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  result_infoObject
    diffObject10
      srcSchemaArray
        nameString源端表名srcTableName
        dstSchemaString备端schema名称dstSchema
        dstNameString备端表名dstTableName
        maxStepsNumber该表最大执行步数2
        plansArray
          planString计划名称plan15
          recursionsArray一个执行计划可以有多个执行步(递归比对
            srowNumber3
            drowNumber3
            srcSqlArray[
"select id,c1,c2,c3 from srcSchema.srcTableName where id<10000"
],
            dstSqlArray[
"select id,c1,c2,c3 from dstSchema.dstTableName where id<10000"
]

表比较-比较结果

SDK方法名:describeTbCmpCmpResult

URL

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

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  summaryObject
    totalNumber1192
    use_timeNumber844
    diffNumber130

表比较-api 启动比较

SDK方法名:describeTbCmpStart

URL

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

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString

备端接管-获取网卡列表

SDK方法名:listBkTakeoveNetworkCard;

URL

/active/bk_takeover/bk_network_card

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray

备端接管-新建

SDK方法名:createBkTakeover

URL

/active/bk_takeover

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
rule_uuidString@guid
typeNumber操作类型: 0 = 备端接管 1 = 备端解除接管 2 = 源端接管准备1
enable_trgjobNumber是否执行启用触发器Job1
enable_alter_seqNumber是否执行调整序列1
enable_attachipNumber是否要附加IP0
start_valNumber序列增加值比例10
net_adapterString要附加IP的网卡名
ipString附加的ip
disable_trgjobNumber禁用源端触发器1
dettach_ipNumber备端解除附加ip

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  uuidString@uuid

备端接管-查看

SDK方法名:describeBkTakeover

URL

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

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] success
  active_bk_takeoverObject
    idString2
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    random_strStringCDA58D92-C0F9-32C8-3BFA-065F0BA17CB4
    create_timeString1564385400
    bk_takeover_uuidString0A20B300-8B41-2573-E5CA-A1CB57C0CADF
    rule_uuidStringE2Dd563c-cD1e-2dd2-8B8B-68beFFEc49cC
    start_valString1000
    scan_ipArray
    hostsArray
    use_ip_swString0

备机接管-删除

SDK方法名:deleteBkTakeover

URL

/active/bk_takeover

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray@guid
forceBooleanfalse

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  success_listArray
    codeString
    messageString
    rule_nameString
    bk_takeover_uuidString
  fail_listArray
    codeString
    messageString
    rule_nameString
    bk_takeover_uuidString

备机接管-接管结果

SDK方法名:describeBkTakeoverResult

URL

/active/bk_takeover/result

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  attath_ipresString
  result_infoObject全部表全部显示出来
    seq_errArray失败的序列
      usernameString@name
      seq_nameString@name
    tri_errArray失败的触发器
      usernameString@name
      tri_nameString@name
    takeover_objArray已接管的对象
      usernameString@name
      seq_numNumber10
      seq_err_numNumber11
      tri_numString@name
      tri_err_numNumber10
    attath_ip_resNumber附加IP执行结果: 0未执行; 1成功;-1失败
    dettach_ip_resNumber解除IP执行结果: 0未执行; 1成功;-1失败

备机接管-操作

SDK方法名:

停止:stopBkTakeover;

重启:restartBkTakeover;

URL

/active/bk_takeover/operate

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
bk_takeover_uuidsArray@guid
operateStringrestart | stop

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString11111
dataObject
  messageString22222
  codeNumber1

备端接管-获取状态

SDK方法名:listBkTakeoverStatus

URL

/active/bk_takeover/status

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] success
  info_listArray
    bk_takeover_uuidString3211BF7E-D9B2-1259-5C2A-264DAC3E26DC
    wStObject
      progressStringABNORMAL
      statusStringABNORMAL
    bStObject
      progressStringDONE
      statusStringDONE

备端接管列表

SDK方法名:listBkTakeover

URL

/active/bk_takeover

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  totalNumber11
  info_listArray
    create_timeString1593511163
    rule_nameString@name
    bk_takeover_uuidString3211BF7E-D9B2-1259-5C2A-264DAC3E26DC
    can_opNumber1
    can_upNumber1
    can_delNumber1
    is_biz_adminNumber1
    typeNumber操作类型: 0 = 备端接管 1 = 备端解除接管 2 = 源端接管准备

--------反向规则--------

URL

/反向规则

Method

GET

Request

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

Response

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

反向规则-新建

SDK方法名:createReverse

URL

/active/reverse

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
reverse_nameString规则名称
rule_uuidString规则uuidF530FB0E-0208-9071-66D3-E595AE7D5A4C
start_scnNumber其实scn,非 0 的整数123
rowid_thdNumber55
row_map_modeString"rowid"

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageStringsuccess
  codeNumber0
  uuidString@uuid

反向规则-删除

SDK方法名:deleteReverse

URL

/active/reverse

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsArray数组
forceBooleanfalse

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  success_listArray
    codeString
    messageString
    reverse_nameString
    reverse_uuidString
  fail_listArray
    codeString
    messageString
    reverse_nameString
    reverse_uuidString

反向规则-获取单个规则信息

SDK方法名:describeReverse

URL

/active/reverse/rule_single

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  rule_listArray同步规则列表2
    rule_nameString同步规则的名称@name
    rule_uuidString@guid
  node_listArray节点的列表
    node_nameString节点名称@name
    node_uuidString节点uuid@guid
  row_map_modeString行映射方式rowid

反向规则-获取列表

SDK方法名:listReverse

URL

/active/reverse

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString123455566
dataObject
  codeNumber0
  totalNumber20
  info_listArray5
    create_timeString1593511163
    user_uuidString@guid
    usernameStringadmin
    reverse_nameString反向规则的名称@name
    src_db_nameStringdb-199
    tgt_db_nameStringdb-200
    reverse_uuidString2309d76d-61Bf-EC40-9Cc2-D4737CBb9254
    can_opNumber1
    can_delNumber1
    can_upNumber1
    is_biz_adminNumber1
  messageString6666666666666

反向规则-状态

SDK方法名:listReverseStatus

URL

/active/reverse/status

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    reverse_uuidString2309d76d-61Bf-EC40-9Cc2-D4737CBb9254
    wStObject
      statusStringREVERSE_FINISH
      error_codeString
    bStObject
      statusStringREVERSE_PAUSE
      progressString80
    src_db_nameString
    dst_db_nameString

反向规则-停止

SDK方法名:stopReverse

URL

/active/reverse/stop

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

反向规则-重启反向任务

SDK方法名:restartReverse

URL

/active/reverse/restart

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
uuidString反向规则的uuid@guid

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

反向规则-查看

SDK方法名:describeSingleReverse

URL

/active/reverse

Method

PUT

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  create_timeString2019-06-21 14:33:24
  user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
  usernameStringadmin
  reverse_nameString@name
  rule_nameString@name
  node_nameString@name
  start_scnNumber其实scn1
  row_map_modeStringrowid
  rowid_thdNumber

日志下载

SDK方法名:downloadLog

URL

/active/rule/log_download

Method

GET

Request

名称类型必选简介Mock初始值Mock规则
rule_uuidString
typeNumber日志级别
module_typeNumber模块
date_startNumber
date_endNumber

Response

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

偏移量信息

SDK方法名:listKafkaOffsetInfo;

URL

/active/rule/kafka_offset

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listObject
    update_timeString2020-12-02 18:07:59
    kafka_latest_offsetArray2
      topicStringtest1
      partitionString0
      offsetString1
      timestampString2020-12-02 16:45:27

表比较-比较结果-差异修复

URL

/active/tb_cmp/diff_fix

Method

POST

Request

名称类型必选简介Mock初始值Mock规则
startString
uuidString
tabArray['srcuser.srctable']

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0

同步规则-增量失败统计删除(失败对象)

URL

/active/rule/incre_dml_summary

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidString
typeNumber0:同步失败对象
1:增量失败dml 统计信息
0

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess

清除增量失败(ddl,dml)

URL

/active/rule/incre_dml

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidString
opr_typeStringddl 失败:ddl
dml 失败:dml
ddl

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageStringsuccess

对象比较-删除(oracle)

URL

/active/obj_cmp/obj_cmp_oracle

Method

DELETE

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber1
  success_listArray
    codeString
    messageString
    obj_cmp_nameString
    obj_cmp_uuidString
  fail_listArray
    codeString-1
    messageString
    obj_cmp_nameString
    obj_cmp_uuidString

表比较-删除(oracle)

URL

/active/tb_cmp/tb_cmp_oracle

Method

DELETE

Request

名称类型必选简介Mock初始值Mock规则
uuidsString@guid
forceBooleanfalse

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  success_listArray
    codeString
    messageString
    tb_cmp_nameString
    tb_cmp_uuidString
  fail_listArray
    codeString
    messageString
    tb_cmp_nameString
    tb_cmp_uuidString

表比较状态

URL

/active/tb_cmp/status

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    wStObject
      statusStringERROR
      progressNumber1
      error_codeNumber-4022
    bStObject
      statusStringDUMP
      progressString80
      error_codeString-22
    cmp_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    diff_numberNumber10

dml-一键修复

dml 修复所有坏表

URL

/active/rule/table_fix_all

Method

POST

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray
    userString
    tableString

同步规则 - 从底层获取SCN

getSCN获取SCN

URL

/active/rule/get_rpc_scn

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retString
msgString
dataObject
  messageString
  codeNumber
  scnString

同步规则 - 从底层获取接管SCN

getRevertSCN获取SCN

URL

/active/rule/get_revert_rpc_scn

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retString
msgString
dataObject
  messageString
  codeNumber
  scnString

测试接口(无用接口测试)

URL

/offline/test

Method

GET

Request

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

Response

名称类型必选简介Mock初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  totalNumber20
  info_listArray
    create_timeString1593511163
    tb_cmp_uuidStringC038DE5A-CDB2-F26D-FA5F-93E3FF266A87
    tb_cmp_nameStringname321
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    src_db_nameStringyuan
    tgt_db_nameStringbei
    usernameStringadmin
    can_opNumber1
    can_upNumber1
    can_delNumber1
    is_biz_adminNumber1
    policy_typeStringimmediate
    configObject
      one_taskString'immediate'
  messageString
Last update: 11/18/2022, 3:56:21 PM
Contributors: ganl