oracle同步

November 23, 2021About 62 min

oracle同步

SDK类名:/active/OracleRule

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

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

URL

/active/rule/db_check_mult

Method

POST

Request

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

Response

名称类型必选初始值简介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_logString1最小附加日志
成功:1
失败:0
    force_loggingString1正确 1
失败:0

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

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

SDK方法名:describeSyncRulesDML

URL

/active/rule/incre_dml_summary

Method

POST

Request

名称类型必选初始值简介Mock规则
offsetNumber1偏移位置
limitString10搜索行数
usrString用户
rule_uuidString@guid规则uuid
sort_orderStringasc排序方式
searchString搜索
sortString

Response

名称类型必选初始值简介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规则
offsetNumber0
limitNumber10
rule_uuidString@guid
usrString
sortString
sort_orderString
searchString

Response

名称类型必选初始值简介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规则

Response

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

同步规则 - 新建

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

URL

/active/rule

Method

POST

Request

名称类型必选初始值简介Mock规则
rule_nameStringctt->ctt规则名称
src_db_uuidString6C4AEF37-6496-6DCD-E085-DD640001E4EC源端数据库uuid
tgt_db_uuidString1C5F3C4B-7333-9518-7349-9712BC9ED664备端数据库uuid
start_rule_nowNumber0开始规则
row_map_modeStringrowid行映射方式
tgt_typeStringoracle备库类型
db_user_mapObject{"CTT":"CTT"}用户映射模式
map_typeStringuser映射方式
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_cvNumber0备端对删除的表进行备份
  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, 其他值传空串
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
kafkaArray
  binary_codeString取值 hex , base64hex
dml_trackArray
  enableNumber
  urpNumber
  drpNumber
  tmcolString
  delcolString
error_handlingObject高级->错误处理
  load_err_setStringcontinue装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
  drpStringignore删除时未找到记录
ignore :忽略
err:报错
  irpStringirpafterdel插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
  urpStringtoirp更新时为找到记录
toirp: 转换为插入
err:报错
  report_failed_dmlNumber上传dml 错误
0:没选中
1:选中

Response

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

同步规则 - 修改

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

URL

/active/rule

Method

PUT

Request

名称类型必选初始值简介Mock规则
rule_nameStringctt->ctt表名
src_db_uuidString6C4AEF37-6496-6DCD-E085-DD640001E4EC源库uuid
tgt_db_uuidString1C5F3C4B-7333-9518-7349-9712BC9ED664备库uuid
start_rule_nowNumber0开始同步规则
row_map_modeStringrowid行映射方式
tgt_typeStringoracle备库类型
db_user_mapObject{"CTT":"CTT"}用户映射
map_typeStringuser映射类型
table_mapArray[{}]表映射
dbmap_topicStringtest1kfk 整库映射
sync_modeNumber1
start_scnString1起始scn
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_cvNumber0备端对删除的表进行备份
  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_infoNumber1表结构变更通知
  message_formatStringprotobuf
json
  json_formatStringjson
canaljson
message_format为json时,可传json , canaljson, 其他值传空串
error_handlingObject高级->错误处理
  load_err_setStringcontinue装载错误处理方式
continue 继续装载
stopld:停止装载
stoptabld:停止此表装载
  drpStringignore删除时未找到记录
ignore :忽略
err:报错
  irpStringirpafterdel插入时记录冲突
irp: 删除后插入
tourp:转换为更新
err:报错
  urpStringtoirp更新时为找到记录
toirp: 转换为插入
err:报错
  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_outString12000producer 超时时间
part_load_balanceString12分区均衡策略
rule_uuidStringF530FB0E-0208-9071-66D3-E595AE7D5A4C
kafkaArray
  binary_codeStringbase64取值 hex , base64
dml_trackArray
  enableBoolean1
  urpNumber1
  drpNumber1
  tmcolString1
  delcolString1

Response

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

同步规则-删除

SDK方法名:deleteOracleRule

URL

/active/rule

Method

DELETE

Request

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

Response

名称类型必选初始值简介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规则
pageNumber1页数
limitNumber10单页数量
search_fieldStringrule_name搜索字段
search_valueString模糊搜索值
group_uuidString查询业务组
where_argsObject
  rule_uuidString@guid

Response

名称类型必选简介初始值Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray
    src_db_nameString数据源(源数据库节点名)db103
    tgt_db_nameString目标端(备数据库节点名)db105
    usernameString所有者admin
    user_uuidString创建用户uuid1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    rule_uuidArray规则uuid['6ECF19A1-3754-1490-C6A3-52AFB4D7F497', '6ECF19A1-3754-1490-C6A3-52AFB4D7F496']+1
    src_db_uuidString源数据库节点uuidAF16E01E-6988-D0FA-3A7F-DEE04C4D3B4A
    tgt_db_uuidString备数据库节点uuid72855161-CD57-6FB5-C195-B19F466AB2C0
    rule_typeNumber规则类型,依照不同源端:
0:oracle,
1:脱敏规则
6:db2,
7:oceanbase,
8:informix,
9:dm
0
    rule_nameString规则名123123
    node_uuidString源端机器节点uuid
    tgt_typeString目标端数据库类型oracle
    db_user_mapString用户映射信息
    row_map_modeString行映射方式,
rowid:rowid,
where:主键,
auto:自动
rowid
    map_typeString映射方式,对应页面勾选映射方式db
    table_mapString表映射信息
    dbmap_topicString备端为kafka并且为整库映射时
整库映射topic
    sync_modeString是否全量同步:0:关,1:开1
    start_scnString起始scn0
    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":""}
    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增量DDL过滤设置{"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_settingsStringETL设置{"etl_table":[]}
    create_timeNumber创建时间戳1593511163
    start_rule_nowString规则提交后立即启动:
0:关,1:开
1
    db_map_uuidString
    dml_trackStringDML操作追踪设置{"enable":0,"urp":0,"drp":0,"tmcol":"","delcol":""}
    kafka_time_outStringProducer超时时间(毫秒)
    part_load_balanceString分区均衡策略:
by_table:表名哈希,
by_key:主键哈希
by_table
    is_biz_adminNumber1
    can_delNumber1显示删除按钮
    can_opNumber1显示操作按钮
    can_upNumber1显示修改按钮
  totalNumber11

同步规则-获取单个

SDK方法名:describeSyncRules

URL

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

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
operateStringrestartresume 继续
stop 停止
restart 重启
start_analysis
stop_analysis
reset_analysis
stop_and_stopanalysis
rule_uuidString@guid
scnString1

Response

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

同步规则-日志

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

URL

/active/rule/log

Method

POST

Request

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

Response

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

同步规则-状态

SDK方法名:listSyncRulesStatus

URL

/active/rule/status

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray2
    rule_uuidString'6ECF19A1-3754-1490-C6A3-52AFB4D7F497',
    loadString2019-06-23 20:23:18
    extractString2019-06-25 11:26:19
    peakString100
    delayString10
    work_stateObject导出
      statusStringACTIVE_RULE_STOPACTIVE_RULE_TRACK:增量
ACTIVE_RULE_PAUSE:停止
ACTIVE_RULE_ABNORMAL:异常
ACTIVE_RULE_UNKNOWN 未知
      error_codeStringACTIVE_RULE_DUMP 全量
ACTIVE_RULE_STOP(出错返回的停止)
    back_stateObject装载
      progressString0ACTIVE_RULE_TRACK:增量
ACTIVE_RULE_PAUSE:停止(手动停止)
ACTIVE_RULE_STOP(出错返回的停止)
ACTIVE_RULE_ABNORMAL:异常
ACTIVE_RULE_UNKNOWN 未知
      statusStringACTIVE_RULE_DUMPACTIVE_RULE_DUMP
    relay_stateObject中继
      statusStringACTIVE_RULE_UNKNOWNACTIVE_RULE_TRACK:增量
ACTIVE_RULE_PAUSE:停止
ACTIVE_RULE_ABNORMAL:异常
ACTIVE_RULE_UNKNOWN 未知
    track_stateObject解析
      statusStringACTIVE_RULE_UNKNOWNACTIVE_RULE_TRACK:增量
ACTIVE_RULE_STOP:停止
ACTIVE_RULE_ABNORMAL:异常
ACTIVE_RULE_UNKNOWN 未知
    has_new_errNumber10:没有新日志产生 1:产生错误日志
    data_infoObject数据库提示信息
      srcObject源端信息
        db_ipArray['172.20.42.102']数据库 ip
        log_read_typeStringfile日志读取方式
        orclStringorcl
        node_nameStringsrcnode节点名
        node_ipString172.20.42.102节点ip
      dstObject备端信息
        db_ipArray['172.20.42.102']数据库ip
        log_read_typeStringfile日志读取方式
        orclStringorcl
        node_nameStringsrcnode2
        node_ipString172.20.42.102
    stageStringstopstop(出错返回的停止)
pause: 停止(手动返回的停止)
dump: 全量
track:增量
done:完成
offline:离线
    stateNumber-40170:正常
非0:错误
    progressString进度
  has_false_ruleBooleantrue

同步规则 - 通用状态

SDK方法名:listSyncRulesGeneralStatus

URL

/active/rule/general_status

Method

GET

Request

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

Response

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

同步规则-已同步的对象

SDK方法名:describeSyncRulesHasSync

URL

/active/rule/sync_obj

Method

POST

Request

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

Response

名称类型必选初始值简介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/
  totalNumber1总共多少条数据

同步规则-失败的对象

SDK方法名:describeSyncRulesFailObj

URL

/active/rule/fail_obj

Method

POST

Request

名称类型必选初始值简介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规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  info_listArray
    usrString222
    nameStringdd
    typeStringTABLE
    stageNumber10 全量 1增量
  totalNumber1

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

SDK方法名:describeSyncRulesLoadInfo;装载信息

URL

/active/rule/load_info

Method

POST

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listObject
    backObject备端信息
      full_backupArray2
        lineString18699647344450
        nameStringLILY.BMSQL_ORDER_LINE12333333I2.COMDATA
        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规则
offsetNumber0
limitString10
rule_uuidString@guid

Response

名称类型必选初始值简介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规则
row_uuidString@guid
limitNumber15
offsetNumber1

Response

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

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

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

URL

/active/rule/z_structure

Method

POST

Request

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

Response

名称类型必选初始值简介Mock规则
msgString
dataObject
  codeNumber0
  messageStringDelete success
  info_listArray2
    isParentBooleantrue没有子集 false,有 true
    nameString@nametest
retNumber200

同步规则-流量图

SDK方法名:describeSyncRulesMrtg;流量图

URL

/active/rule/mrtg

Method

POST

Request

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

页面自动刷新时 返回值最后一个
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规则
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规则
typeStringsec
start_timeString
end_timeString
limitNumber10
offsetNumber0
uuidString1d2F6Fed-DAC6-FE94-A6cB-5Ab55415E9fd

Response

名称类型必选初始值简介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规则
offsetNumber0
limitString10
rule_uuidString@guid

Response

名称类型必选初始值简介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规则
src_db_uuidString
dst_db_uuidString

Response

名称类型必选初始值简介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
      msgStringdbFailRuleNotRun数据库连接失败,规则无法正常运行
    noticeObject
      srcStringa\nb\n\c\n
      dstStringa
b
c
      flagStringwarning
      msgString

同步规则-获取残留规则

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

URL

/active/rule/get_false_rule

Method

GET

Request

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

Response

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

同步规则-选择用户

SDK方法名:describeRuleSelectUser;选择用户

URL

/active/rule/select_user

Method

POST

Request

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

Response

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

同步规则-表修复

SDK方法名:describeRuleTableFix;表修复

URL

/active/rule/table_fix

Method

POST

Request

名称类型必选初始值简介Mock规则
rule_uuidStringF530FB0E-0208-9071-66D3-E595AE7D5A4C规则uuid
tabArray["I2.table"]I2.table
fix_relationNumber00 无关联 1 有关联

Response

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

同步规则-获取scn号

SDK方法名:describeRuleGetScn;

URL

/active/rule/get_scn

Method

GET

Request

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

Response

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

同步规则-装载统计报表

SDK方法名:listRuleLoadReport;

URL

/active/rule/load_report

Method

POST

Request

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

Response

名称类型必选初始值简介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规则

Response

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

对象比较 - 列表

SDK方法名:listObjCmp

URL

//active/obj_cmp

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
obj_cmp_nameStringtest对象比较名称
src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21源端数据库uuid
tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5备端数据库uuid
cal_table_recodersNumber1是否对比表的记录数
rule_uuidString751A03F5-C97D-645B-82B2-316A5D198528同步规则uuid
cmp_typeStringuser类型
db_user_mapString{'src_user':'dst_user'}用户映射
policiesString策略
policy_typeStringperiodic策略类型
one_timeString2019-05-27 16:07:08
repairNumber1
configObject
  one_taskStringimmediate立即比较:immediate
选择时间:select_time

Response

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

对象比较 - 删除

SDK方法名:deleteObjCmp

URL

//active/obj_cmp

Method

DELETE

Request

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

Response

名称类型必选初始值简介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规则

Response

名称类型必选初始值简介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*100:02
    policy_typeStringperiodic
    one_timeString2019-05-27 16:07:08
    repairNumber1
  messageString
  codeNumber0

对象比较 - 操作

SDK方法名:{operate}ObjCmp

URL

//active/obj_cmp/operate

Method

POST

Request

名称类型必选初始值简介Mock规则
operateStringcmp_stop| cmp_restartcmp_stop_oracle
obj_cmp_uuidsArray

Response

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

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

SDK方法名:listObjCmpResultTimeList

URL

//active/obj_cmp/result_time_list

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
uuidString@guid
start_timeString开始时间
limitNumber
offsetString
search_valueString搜索值
BackLackOnlyNumber0显示备端差异

Response

名称类型必选初始值简介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规则
uuidsArray

Response

名称类型必选初始值简介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规则
uuidString@guid
time_listArray

Response

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

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

SDK方法名:listObjCmpCmpInfo

URL

//active/obj_cmp/cmp_info

Method

GET

Request

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

Response

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

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

URL

/对象修复

Method

GET

Request

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

Response

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

对象修复 - 新建

SDK方法名:createObjFix

URL

//active/obj_fix

Method

POST

Request

名称类型必选初始值简介Mock规则
obj_fix_nameStringtest
src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
obj_mapString[{"type":"owner.name"}]type对应类型值如下:INDEX->索引,VIEW->视图,FUNCTION->函数,PROCEDURE->存储过程,PACKAGE->包头
PACKAGE BODY->包体,SYNONYM->同义词,TRIGGER->触发器,
SEQUENCE->序列,JAVA SOURCE->JAVA源,JAVA CLASS->JAVA类,JAVA RESOURCE->JAVA资源,TYPE->类型,TYPE BODY->类型体,QUEUE->队列,MATERIALIZED VIEW->物化视图,DATABASE LINK->DBLINK,OLD JOB->JOB,JOB->SCH JOB,PRIVS->权限,CONSTRAINT->约束.
owner和name 用逗号连接并且 均加密
2
obj_fix_uuidString@guid

Response

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

对象修复 - 获取单个

SDK方法名:describeObjFix

URL

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

Method

GET

Request

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

Response

名称类型必选初始值简介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_mapString[{"INDEX":"owner.name"}]json 字符串

对象修复 - 删除

SDK方法名:deleteObjFix

URL

//active/obj_fix

Method

DELETE

Request

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

Response

名称类型必选初始值简介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规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选初始值简介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_typeStringimmediate
immediate; one_time;periodic
  messageString

对象修复-操作

SDK方法名:

重新修复:restartObjFix;

停止:stopObjFix;

URL

//active/obj_fix/operate

Method

POST

Request

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

Response

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

对象修复 - 修复结果

SDK方法名:describeObjFixResult

URL

//active/obj_fix/result

Method

GET

Request

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

Response

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

对象修复--获取状态

SDK方法名:listObjFixStatus

URL

//active/obj_fix/status

Method

POST

Request

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

Response

名称类型必选初始值简介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规则

Response

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

表比较 - 新建

SDK方法名:createTbCmp

URL

//active/tb_cmp

Method

POST

Request

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

Response

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

表比较 - 获取单个

SDK方法名:describeTbCmp

URL

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

Method

GET

Request

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

Response

名称类型必选初始值简介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*100:02
    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规则
uuidsArray@guid
forceBooleanfalse

Response

名称类型必选初始值简介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规则
pageNumber1
limitNumber10
search_fieldString
search_valueString

Response

名称类型必选初始值简介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_typeStringimmediateimmediate; one_time;periodic
    configObject
      one_taskString'immediate'
  messageString

状态接口

SDK方法名:listTbCmpStatus;状态接口

URL

//active/tb_cmp/status

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  info_listArray2
    extractString2019-06-25 11:26:19解析时间
    cmp_uuidString@guid
    peakString100峰值
    dst_stateObject目标端
      statusStringOFFLINE目标端状态
    delayString10延迟
    loadString2019-06-23 20:23:18装载时间
    work_stateObject同步规则对应导出,其他规则对应源机
      statusStringABNORMAL状态
      error_codeString4017错误码
    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规则
tb_cmp_uuidsArray@guid
operateStringcmp_stop | cmp_restartcmp_stop_oracle

Response

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

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

SDK方法名:listTbCmpResultTimeList

URL

//active/tb_cmp/result_time_list

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
uuidString
time_listArray@guid

Response

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

表比较-比较任务结果

SDK方法名:describeTbCmpResult

URL

//active/tb_cmp/result

Method

GET

Request

名称类型必选初始值简介Mock规则
offsetNumber1
limitNumber10
search_fieldString
search_valueString
uuidString@guid
start_timeString对应的时间

Response

名称类型必选初始值简介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
    totalNumber30
    rule_relatedNumber1

表比较-错误信息

SDK方法名:describeTbCmpErrorMsg;错误信息

URL

//active/tb_cmp/error_msg

Method

GET

Request

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

Response

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

表比较-比较结果

SDK方法名:describeTbCmpCmpResult

URL

//active/tb_cmp/cmp_result

Method

GET

Request

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

Response

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

备端接管-获取网卡列表

SDK方法名:listBkTakeoveNetworkCard;

URL

//active/bk_takeover/bk_network_card

Method

GET

Request

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

Response

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

备端接管-新建

SDK方法名:createBkTakeover

URL

//active/bk_takeover

Method

POST

Request

名称类型必选初始值简介Mock规则
rule_uuidString@guid
typeNumber1操作类型: 0 = 备端接管 1 = 备端解除接管 2 = 源端接管准备
enable_trgjobNumber1是否执行启用触发器Job
enable_alter_seqNumber1是否执行调整序列
enable_attachipNumber0是否要附加IP
start_valNumber10序列增加值比例
net_adapterString要附加IP的网卡名
ipString附加的ip
disable_trgjobNumber1禁用源端触发器
dettach_ipNumber备端解除附加ip

Response

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

备端接管-查看

SDK方法名:describeBkTakeover

URL

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

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
uuidsArray@guid
forceBooleanfalse

Response

名称类型必选初始值简介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规则
bk_takeover_uuidString@guid

Response

名称类型必选初始值简介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规则
bk_takeover_uuidsArray@guid
operateStringrestart | stop

Response

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

备端接管-获取状态

SDK方法名:listBkTakeoverStatus

URL

//active/bk_takeover/status

Method

POST

Request

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

Response

名称类型必选初始值简介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规则

Response

名称类型必选初始值简介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规则

Response

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

反向规则-新建

SDK方法名:createReverse

URL

//active/reverse

Method

POST

Request

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

Response

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

反向规则-删除

SDK方法名:deleteReverse

URL

//active/reverse

Method

DELETE

Request

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

Response

名称类型必选初始值简介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规则
rule_uuidString@guid规则uuid

Response

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

反向规则-获取列表

SDK方法名:listReverse

URL

//active/reverse

Method

GET

Request

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

Response

名称类型必选初始值简介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规则
uuidsArray@guid

Response

名称类型必选初始值简介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规则
uuidString@guid

Response

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

反向规则-重启反向任务

SDK方法名:restartReverse

URL

//active/reverse/restart

Method

POST

Request

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

Response

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

反向规则-查看

SDK方法名:describeSingleReverse

URL

//active/reverse

Method

PUT

Request

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

Response

名称类型必选初始值简介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_scnNumber1其实scn
  row_map_modeStringrowid
  rowid_thdNumber

日志下载

SDK方法名:downloadLog

URL

/active/rule/log_download

Method

GET

Request

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

Response

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

偏移量信息

SDK方法名:listKafkaOffsetInfo;

URL

/active/rule/kafka_offset

Method

POST

Request

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

Response

名称类型必选初始值简介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规则
startString
uuidString
tabArray['srcuser.srctable']

Response

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

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

URL

/active/rule/incre_dml_summary

Method

DELETE

Request

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

Response

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

清除增量失败(ddl,dml)

URL

/active/rule/incre_dml

Method

DELETE

Request

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

Response

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

对象比较-删除(oracle)

URL

//active/obj_cmp/obj_cmp_oracle

Method

DELETE

Request

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

Response

名称类型必选初始值简介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规则
uuidsString@guid
forceBooleanfalse

Response

名称类型必选初始值简介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
Last update: 11/23/2023, 10:43:57 AM
Contributors: ganl