DB2同步

November 23, 2021About 15 min

DB2同步

SDK类名:/active/Db2

同步规则列表

SDK方法名:listDbRule;

URL

//db2/rule

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray
    src_db_nameStringdb2_1
    tgt_db_nameStringdb2_2
    usernameStringadmin
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    rule_uuidString2511627B-5306-EE10-E1D3-97CC89450D89
    src_db_uuidString2C4C2E77-774D-C604-9A32-5038D8E590C4
    tgt_db_uuidString953C47CB-3F6C-E72F-DF1C-31522468A566
    rule_typeNumber61
    rule_nameString12321
    node_uuidString
    tgt_typeStringkafka
    db_user_mapString
    row_map_modeStringrowid
    map_typeStringdb
    table_mapString
    dbmap_topicString
    sync_modeString1
    start_scnString0
    storage_settingsObject
      src_max_memString512
      src_max_diskString5000
      txn_max_memString10000
      tf_max_sizeString100
      max_ld_memString512
      tgt_extern_tableString
    table_space_mapObject
      tgt_table_spaceString
      table_mapping_wayStringptop
      table_path_mapArray
      table_space_nameArray
    other_settingsObject
      keep_dyn_dataNumber0
      dyn_threadNumber1
      dly_constraint_loadNumber0
      zip_levelNumber0
      ddl_cvNumber0
      keep_bad_actNumber0
      fill_lob_columnNumber0
      keep_seq_syncNumber0
      keep_usr_pwdNumber0
      convert_urp_of_keyNumber0
      ignore_foreign_keyNumber0
      gen_txnNumber0
    error_handlingObject
      irpStringirpafterdel
      urpStringtoirp
      drpStringignore
      load_err_setStringcontinue
      report_failed_dmlNumber0
    bw_settingsObject
      bw_limitString
    strateNull
    full_sync_settingsObject
      load_modeStringdirect
      ld_dir_optNumber0
      dump_thdNumber1
      load_thdNumber1
      try_split_part_tableNumber1
      clean_user_before_dumpNumber0
      existing_tableStringdrop_to_recycle
      concurrent_tableString[]
    full_sync_obj_filterObject
      full_sync_obj_dataArray
    inc_sync_ddl_filterObject
      inc_sync_ddl_dataArray
    filter_table_settingsObject
      exclude_tableString[]
    etl_settingsObject
      etl_tableArray
    create_timeNumber1601362592
    start_rule_nowNumber1
    db_map_uuidString
    dml_trackObject
      enableNumber0
      urpNumber0
      drpNumber0
      tmcolString
      delcolString
    kafka_time_outString120000
    part_load_balanceStringby_table
    kafka_message_encodingStringUTF-8
    kafkaObject
      binary_codeStringhex
    is_biz_adminNumber1
    can_delNumber1
    can_opNumber1
    can_upNumber1
  totalNumber2

新建规则

SDK方法名:createDbRule;

URL

//db2/rule

Method

POST

Request

名称类型必选初始值简介Mock规则
start_rule_nowNumber1
rule_nameString12321
src_db_uuidString2C4C2E77-774D-C604-9A32-5038D8E590C4
tgt_typeStringdb2
tgt_db_uuidString953C47CB-3F6C-E72F-DF1C-31522468A566
map_typeStringdb
db_user_mapString
table_mapString
dbmap_topicString
row_map_modeStringrowid
sync_modeNumber1
start_scnString
kafka_time_outString120000
part_load_balanceStringby_table
kafka_message_encodingStringUTF-8
kafkaObject
  binary_codeStringhex
dml_trackObject
  enableNumber0
  urpNumber0
  drpNumber0
  tmcolString
  delcolString
storage_settingsObject
  src_max_memString512
  src_max_diskString5000
  txn_max_memString10000
  tf_max_sizeString100
  max_ld_memString512
  tgt_extern_tableString
other_settingsObject
  keep_dyn_dataNumber0
  dyn_threadNumber1
  dly_constraint_loadNumber0
  zip_levelNumber0
  ddl_cvNumber0
  keep_bad_actNumber0
  fill_lob_columnNumber0
  keep_seq_syncNumber0
  keep_usr_pwdNumber0
  convert_urp_of_keyNumber0
  ignore_foreign_keyNumber0
  gen_txnNumber0
error_handlingObject
  irpStringirpafterdel
  urpStringtoirp
  drpStringignore
  load_err_setStringcontinue
  report_failed_dmlNumber0
bw_settingsObject
  bw_limitString
table_space_mapObject
  tgt_table_spaceString
  table_mapping_wayStringptop
  table_path_mapArray
  table_space_nameArray
full_sync_settingsObject
  load_modeStringdirect
  ld_dir_optNumber0
  dump_thdNumber1
  load_thdNumber1
  try_split_part_tableNumber1
  clean_user_before_dumpNumber0
  existing_tableStringdrop_to_recycle
  concurrent_tableString[]
full_sync_obj_filterObject
  full_sync_obj_dataArray
inc_sync_ddl_filterObject
  inc_sync_ddl_dataArray["ALTER TABLE CHECKED", // 一致性检查
"ALTER TABLE REORG", // 重组表
"ALTER TABLE ATTACH PARTITION", //转入分区表数据
"CREATE INDEX NOT PART", //创建非分区索引
"DROP INDEX NOT PART",// 删除非分区索引
]
filter_table_settingsObject
  exclude_tableString[]
etl_settingsObject
  etl_tableArray
_String489d781db90cb

Response

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

修改规则

SDK方法名:modifyDbRule;

URL

//db2/rule

Method

PUT

Request

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

Response

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

单条规则

SDK方法名:describeDbRule;

URL

//db2/rule/:id

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString[0] 操作成功。
  info_listArray
    rule_uuidString2511627B-5306-EE10-E1D3-97CC89450D89
    src_db_uuidString2C4C2E77-774D-C604-9A32-5038D8E590C4
    tgt_db_uuidString953C47CB-3F6C-E72F-DF1C-31522468A566
    rule_typeNumber61
    rule_nameString12321
    user_uuidString1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
    node_uuidString
    tgt_typeStringdb2
    db_user_mapString
    row_map_modeStringrowid
    map_typeStringdb
    table_mapString
    dbmap_topicString
    sync_modeString1
    start_scnString0
    storage_settingsObject
      src_max_memString512
      src_max_diskString5000
      txn_max_memString10000
      tf_max_sizeString100
      max_ld_memString512
      tgt_extern_tableString
    table_space_mapObject
      tgt_table_spaceString
      table_mapping_wayStringptop
      table_path_mapArray
      table_space_nameArray
    other_settingsObject
      keep_dyn_dataNumber0
      dyn_threadNumber1
      dly_constraint_loadNumber0
      zip_levelNumber0
      ddl_cvNumber0
      keep_bad_actNumber0
      fill_lob_columnNumber0
      keep_seq_syncNumber0
      keep_usr_pwdNumber0
      convert_urp_of_keyNumber0
      ignore_foreign_keyNumber0
      gen_txnNumber0
    error_handlingObject
      irpStringirpafterdel
      urpStringtoirp
      drpStringignore
      load_err_setStringcontinue
      report_failed_dmlNumber0
    bw_settingsObject
      bw_limitString
    strateNull
    full_sync_settingsObject
      load_modeStringdirect
      ld_dir_optNumber0
      dump_thdNumber1
      load_thdNumber1
      try_split_part_tableNumber1
      clean_user_before_dumpNumber0
      existing_tableStringdrop_to_recycle
      concurrent_tableString[]
    full_sync_obj_filterObject
      full_sync_obj_dataArray
    inc_sync_ddl_filterObject
      inc_sync_ddl_dataArray
    filter_table_settingsObject
      exclude_tableString[]
    etl_settingsObject
      etl_tableArray
    create_timeNumber1601362592
    start_rule_nowNumber1
    db_map_uuidString
    dml_trackObject
      enableNumber0
      urpNumber0
      drpNumber0
      tmcolString
      delcolString
    kafka_time_outString120000
    part_load_balanceStringby_table
    kafka_message_encodingStringUTF-8
    kafkaObject
      binary_codeStringhex

删除规则

SDK方法名:deleteDbRule;

URL

//db2/rule

Method

DELETE

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber1
  messageString[0] success
  success_listArray
    codeNumber0
    messageString[0] success
    rule_uuidString16CB63E1-13FA-FB32-EB49-D790682C9648
    rule_nameStringtask1
  fail_listArray
    codeNumber-1
    messageString[-1] 找不到节点
    rule_uuidString16CB63E1-13FA-FB32-EB49-D790682C9647
    rule_nameStringtask2

操作规则

SDK方法名:{operate}DbRule;

URL

//db2/rule/operate

Method

POST

Request

名称类型必选初始值简介Mock规则
operateStringresume | stoprestart
rule_uuidString
scnString

Response

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

日志

SDK方法名:listDbRuleLog;

URL

//db2/rule/log

Method

POST

Request

名称类型必选初始值简介Mock规则
offsetNumber0
limitNumber10
date_startString
date_endString
typeNumber1
module_typeNumber1
query_typeNumber1
rule_uuidString3FCdeF6f-9CC5-B9Ee-C4F2-8e19eb118528

Response

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

db2表比较


URL

/------------------------------

Method

GET

Request

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

Response

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

db2-表比较-新建

SDK 方法名:createDb2Cmp

URL

//db2/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_typeStringtable, database, all
db_user_mapArray{"CTT":"CTT"}
  src_tableString
  dst_tableString
filter_tableString["用户.表名"]
db_tb_mapArray表映射
  src_tableString
  dst_tableString
  src_dbString
  dst_dbString
dump_thdNumber1
rule_uuidString@guid
policesString"0|00:00
policy_typeStringone_time
try_split_part_tableNumber0
one_timeString2019-05-27 16:07:08
concurrent_tableArray
one_timeString
repairNumber
fix_relatedNumber

Response

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

db2表比较-获取

SDK方法名:describeDb2Cmp

URL

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

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  db2_tb_cmpObject
    table_cmp_nameStringctt->ctt
    src_db_uuidString4CA773F4-36E3-A091-122C-ACDFB2112C21
    tgt_db_uuidString40405FD3-DB86-DC8A-81C9-C137B6FDECE5
    cmp_typeStringtabletable, database
    filter_table_settingsString["333.444"]
    tdb_tb_mapArray
      src_tableString@name
      dst_tableString@name
      src_dbString@name
      dst_dbString@name
    dump_thdNumber1
    rule_uuidString3D7dFcd9-C176-d9ee-4FFB-f22bbd554929
    policiesString1|00:091,2,3*100:02
    policy_typeStringperiodic
    one_timeString2019-05-27 16:07:08
    db_user_mapArray
      src_tableString@name
      dst_tableString@name
    concurrentTabArray
    try_split_part_tableNumber

db2-表比较-删除

SDK方法名:deleteDb2Rules

URL

//db2/tb_cmp

Method

DELETE

Request

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

Response

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

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

SDK方法名:listDb2Cmps

URL

//db2/tb_cmp

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  totalNumber5
  info_listArray
    create_timeString2019-06-21 14:33:24
    tb_cmp_nameString@name
    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
    tgt_typeString目标类型123
    is_biz_adminNumber1
    can_opNumber1
    can_upNumber1
    can_delNumber1
    src_db_nameStringyuan
    policy_typeString
  messageString

db2-表比较-状态接口

SDK方法名:listDb2CmpStatus

URL

//db2/tb_cmp/status

Method

POST

Request

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

Response

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

db2-表比较-操作

SDK方法名:

停止:cmpStopDb2Cmp;

重启:cmpRestartDb2Cmp;

URL

//db2/tb_cmp/operate

Method

POST

Request

名称类型必选初始值简介Mock规则
tb_cmp_uuidsString@guid
operateStringcmp_stop | cmp_restart

Response

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

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

SDK方法名:deleteCmpResult

URL

//db2/tb_cmp/result_time_list

Method

DELETE

Request

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

Response

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

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

SDK方法名:listCmpResult

URL

//db2/tb_cmp/result_time_list

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  codeNumber0
  messageString
  time_listArray
    show_timeString2019-07-05 17:35:13
    summaryObject
      totalNumber999
      use_timeNumber777
      diffNumber444
    timeString2019-07-05_17-35-13

db2表比较-比较任务结果

SDK方法名:describeTbCmpResult

URL

//db2/tb_cmp/result

Method

GET

Request

名称类型必选初始值简介Mock规则
pageNumber1
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
  result_infoObject
    rowsArray10
      src_userStringuser
      src_table_nameStringAnna Martin
      srcStringCynthia Gonzalez
      dstStringRobert Johnson
    totalNumber30

db2-表比较-查看单条

SDK方法名:describeDb2Cmp

URL

//db2/result_fix_list

Method

GET

Request

名称类型必选初始值简介Mock规则
time_listString@guid
uuidString
pageNumber1
limitNumber10
search_fieldString
search_valueString
uuidString@guid
start_timeString

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  time_listArray
    db_nameString@name数据库名称
    table_nameString@name
    col_cmpString111列比较
    line_numNumber222行数
    contentString333内容
    statusStringnot_repaireddone:已修复,not_repaired:未修复
  totalNumber15
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  head_infoObject
    totalNumber100
    errNumber10
    endString2019-10-10 12:00:00
    startString2019-10-10 10:00:00
    use_timeString3600
  result_infoObject
    rowsArray
      db_nameStringDonald Miller
      table_nameStringJoseph Walker
      col_cmpString111
      line_numNumber222
      contentString333
      statusStringnot_repaired
    totalNumber10

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

SDK方法名:describeCmpErrorMsg

URL

//db2/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
    rowsArray
      src_rowString@name
      dst_rowString@name
    totalNumber10

比较结果列表的修复

SDK方法名:listFixResult

URL

//db2/result_fix_list

Method

POST

Request

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

Response

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

比较结果列表的导出

SDK方法名:exportCmpResult

URL

//db2/export

Method

POST

Request

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

Response

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

历史结果中的修复

SDK方法名:listCmpDiffMap

URL

//db2/tb_cmp/diff_map

Method

GET

Request

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

Response

名称类型必选初始值简介Mock规则
retNumber200
msgString
dataObject
  messageString
  codeNumber0
  result_infoArray['LIU.YI','LIU.ER']
Last update: 6/25/2022, 9:23:18 PM
Contributors: ganl