Oracle同步

SDK类名：/active/OracleRule

同步规则 - 列表

SDK方法名：listSyncRules

URL

/active/rule

Method

GET

Request

名称	类型	必选	简介	Mock初始值	Mock规则
page	Number	否	页数	1
limit	Number	否	单页数量	10
search_field	String	否	模糊搜索域	rule_name
search_value	String	否	模糊搜索值
group_uuid	String	否	查询业务组
where_args	Object	否	复合条件搜索
status	String		状态
src_db_name	String		数据源
tgt_db_name	String		目标端
db_ip	String		源备数据库ip
node_ip	String		源备机器节点ip
username	String		用户名
rule_name	String		（同步规则）规则名
start_before	Number		启动时间戳范围右值
start_after	Number		启动时间戳范围左值

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
code	Number		接口状态码	0
message	String		接口请求结果	[0] 操作成功。
total	Number		记录总数	25
info_list	Array		列表		10
src_db_name	String		数据源（源数据库节点名）	db103
tgt_db_name	String		目标端（备数据库节点名）	db105
username	String		所有者	admin
user_uuid	String		创建用户uuid	1BCFCAA3-E3C8-3E28-BDC5-BE36FDC2B5DC
rule_uuid	String		规则uuid	AF16E01E-6988-D0FA-3A7F-DEE04C4D3B4A
src_db_uuid	String		源数据库节点uuid	AF16E01E-6988-D0FA-3A7F-DEE04C4D3B4A
tgt_db_uuid	String		备数据库节点uuid	72855161-CD57-6FB5-C195-B19F466AB2C0
rule_type	Number		规则类型，依照不同源端： 0：oracle, 1：脱敏规则 6：db2, 7：oceanbase, 8：informix, 9：dm	0
rule_name	String		规则名	123123
node_uuid	String		源端机器节点uuid
tgt_type	String		目标端数据库类型	oracle
db_user_map	String		用户映射信息	{"u1":"u2","u3":"u4"}
row_map_mode	String		行映射方式， rowid：rowid， where：主键， auto：自动	rowid
map_type	String		映射方式，对应页面勾选映射方式	["user", "table", "column"]
table_map	Array		表映射信息	[ { "src_user": "a", "src_table": "b", "dst_user": "c", "dst_table": "d", "column": [] }, { "src_user": "e", "src_table": "f", "dst_user": "g", "dst_table": "h", "column": [] } ]
dbmap_topic	String		备端为kafka并且为整库映射时 整库映射topic
sync_mode	String		是否全量同步：0：关，1：开	1
start_scn	String		起始scn	0
storage_settings	Object		存储设置
table_space_map	Object		表空间映射
other_settings	Object		高级设置
error_handling	Object		错误处理
bw_settings	Object	否	带宽设置
full_sync_settings	Object		全量设置
full_sync_obj_filter	Object		全量对象过滤设置
inc_sync_ddl_filter	Object		增量DDL过滤设置
filter_table_settings	Object		表过滤设置
etl_settings	Object		ETL设置
create_time	Number	否	创建时间戳	1593511163
start_rule_now	String		规则提交后立即启动： 0：关，1：开	1
dml_track	Object		DML操作追踪设置
kafka_time_out	Number		Producer超时时间（毫秒）	1000
part_load_balance	String		分区均衡策略： by_table：表名哈希， by_key：主键哈希	by_table
is_biz_admin	Number		当前访问用户是否有admin权限	1
can_del	Number		显示删除按钮	1
can_op	Number		显示操作按钮	1
can_up	Number		显示修改按钮	1
comment	String		备注
compress	Number		（除dm源端类型外）压缩等级
compress_algo	String		压缩算法
compress_level	Number		压缩等级
compress_switch	Number		压缩开关： 0：关，1：开
encrypt_switch	Number		加密开关： 0：关，1：开
encrypt	Number		加密类型

同步规则 - 新建

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

URL

/active/rule

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_name	String	否	规则名称	ctt->ctt
src_db_uuid	String	否	源端数据库uuid	6C4AEF37-6496-6DCD-E085-DD640001E4EC
src_db_auth_uuid	String		源端用户认证uuid
tgt_db_uuid	String	否	备端数据库uuid	1C5F3C4B-7333-9518-7349-9712BC9ED664
tgt_db_auth_uuid	String		备端用户认证uuid
start_rule_now	Number	否	开始规则	0
row_map_mode	String	否	行映射方式	rowid
tgt_type	String	否	备库类型	oracle
db_user_map	Object	否	用户映射模式	{"CTT":"CTT"}
full_map_switch	Number		0：非整库映射，1：整库映射
map_type_list	Array		映射方式
map_type	String	否	（旧版本参数）映射方式	user
include_tab_with_column	Array		格式为：用户,列1，列2，列3。（用户支持星号）例： ["U1, ID, NAME", ", CARD"]
user	String		原用户
target	String		目标用户或目标topic（kafka）
column	String		列名
include_tab_with_column_switch	Number		0：关闭，1：开启
table_map	Array	否	表映射模式
dst_table	String		备端表名	a
dst_user	String		备端用户	b
src_table	String		源端表名	c
src_user	String		源端用户	d
column	Array
dst_column	String		备端字段	e
src_column	String		源端字段	f
key	Array		自定义主键key列	@last	3
split_dst_table	Array
condition	String		拆分条件
dst_table	String		备端表名
dst_user	String		备端用户
sync_mode	Number	否		1
dbmap_topic	String	否	kfk 整库映射
start_scn	String	否	起始scn
storage_settings	Object	否	高级->存储设置
src_max_mem	Number	否	源端内存缓存上限	512
src_max_disk	Number	否	源端磁盘缓存上限	5000
txn_max_mem	Number	否	事务最大内存占用	10000
tf_max_size	Number	否	最大跟踪文件大小	100
tgt_extern_table	String	否
max_ld_mem	String
keep_incre_time	String		备端保留增量导出数据时长
table_space_map	Object	否	高级->表空间映射
tgt_table_space	String	否
table_mapping_way	String	否		ptop
table_path_map	Object	否		{"ddd":"sss","ddd1":"sss1"}
table_space_name	Object	否		{"qq":"ss"}
other_settings	Object	否	高级->其他设置
keep_dyn_data	Number	否		0
dyn_thread	Number	否		1
dly_constraint_load	Number	否		0
zip_level	Number	否		0
ddl_cv	Number	否	备端对删除的表进行备份	0
keep_bad_act	Number	否		0
keep_usr_pwd	Number	否		1
convert_urp_of_key	Number	否		0
merge_track	String		统一解析
ignore_foreign_key	Number	否		0
table_delay_load	Array		["hh.ww"]
fill_lob_column	String
keep_seq_sync	String
gen_txn	String
encrypt_switch	Number
encrypt_type	Number
table_change_info	Number		表结构变更通知
encrypt_key	String
message_format	String		protobuf json
json_format	String		json canaljson message_format为json时，可传json ， canaljson， 其他值传空串
run_time	String		运行时间	"1200:00-13:0040M,300:00-13:0040M"
jointing	Object		字段拼接
table	String		表
op	String		操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide	append
content	Array		目标列+其他两行
enable_truncate_frequence	Number		truncate频率限制 0：关 1：开
target_add_columns	Array		字段添加
schema	String		模式
table	String		表名
column	String		列名
function	String		装载函数
dataType	String		数据类型
opType	String		执行操作：插入：insert，更新：update
initrans	Number		表和索引的initrans，0关1开
redo_read_thread	Number		读取日志线程数
bw_settings	Object	否	高级->宽带设置
bw_limit	String	否		"1200:00-13:0040M,300:00-13:0040M"
full_sync_settings	Object	否	全同步设置
load_thd	Number	否		1
keep_exist_table	Number	否		0
keep_table	Number	否		0
ld_dir_opt	Number	否		0
his_thread	Number	否		1
try_split_part_table	Number	否		0
concurrent_table	Array	否		["hello.world"]
dump_thd	Number			1
clean_user_before_dump	Number			0
existing_table	String			drop_to_recycle
sync_mode	Number			0
start_scn	String
full_sync_custom_cfg	Array		全局自定义配置
key	String
value	String
full_sync_obj_filter	Object	否	全同步对象过滤
full_sync_obj_data	Array	否		["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filter	Object	否	增量同步对象ddl过滤
inc_sync_ddl_data	Array	否		["INDEX","VIEW","FUNCTION"]
filter_table_settings	Object	否	过滤表
exclude_table	Array	否	表过滤设置
user	String		用户名
table	String		表名
exclude_tab_with_column	Array		格式为：用户,列1，列2，列3。（用户支持星号）例： ["U1, ID, NAME", ", CARD"]
exclude_tab_with_column_switch	Number		0：关闭，1：开启
etl_settings	Object	否	etl
etl_table	Array	否
oprType	String	否		IRP
table	String	否
user	String	否
process	String	否		SKIP
addInfo	String	否
biz_grp_list	Array	否	分组业务
kafka_time_out	String	否			12000
part_load_balance	String	否			by_table
kafka_message_encoding	String				UTF-8
save_json_text	Boolean		【目标为Kafka】“另存文本文件”开关	false
kafka	Array
binary_code	String		取值 hex ， base64		hex
dml_track	Array
enable	Boolean		是否启用 true
keep_deleted_row	Boolean		是否保留删除列 true
change_table_structure	Boolean		变更同步表结构
date_time_column_unique	Boolean		操作产生时间字段值主键
load_date_time_column_unique	Boolean		操作装载时间字段值主键
date_column	String		操作日期字段名
time_column	String		操作时间字段名
date_time_column	String		操作日期+时间字段名
op_column	String		操作标记字段名
opv_insert	String		操作标记字段：插入操作标记值
opv_update	String		操作标记字段：更新操作标记值
opv_update_key	String		操作标记字段：更新主键、唯一键操作标记值
opv_delete	String		操作标记字段：删除操作标记值
audit	Boolean		是否启用审计表
audit_prefix	String		审计表前辍
audit_appendix	String		审计表后辍
identity_column	String		自增列字段	AUTO_INCR
load_date_column	String		装载仅日期
load_time_column	String		装载仅时间
load_date_time_column	String		时间和日期
error_handling	Object		高级->错误处理
load_err_set	String		装载错误处理方式 continue 继续装载 stopld:停止装载 stoptabld:停止此表装载	continue
drp	String		删除时未找到记录 ignore :忽略 err:报错	ignore
irp	String		插入时记录冲突 "irpafterdel" （删除后插入，默认值） "tourp"（转换为更新） "err"（报错） 以上为原有值不变，新增以下三个值： "choose_bigger" （按指定字段更大值插入） "choose_smaller" （按指定字段更小值插入） "sp" （执行指定存储过程）	irpafterdel
urp	String		更新时为找到记录 toirp: 转换为插入 err:报错	toirp
report_failed_dml	Number		上传dml 错误 0：没选中 1：选中
info	String		任意字符串，表示用户指定的字段名或者存储过程名称。
encrypt_switch	String		加密开关 0：关，1：开
encrypt	String		加密格式 0：aes，1：sm4
secret_key	String		密钥内容
compress_switch	String		压缩开关 0：关，1：开
compress	String		压缩等级
comment	String		备注
incre_sync	Number		增量同步

Response

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

同步规则 - 批量新建

SDK方法名：createBatchOracleRule;

URL

/active/rule/batch

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
prefix	String	否	规则名称前缀	temp
db_list	Array	否	数据库列表
src_db_uuid	String		源端数据库uuid	6C4AEF37-6496-6DCD-E085-DD640001E4EC
tgt_db_uuid	String		备端数据库uuid
tgt_type	String		备端数据库类型
start_rule_now	Number	否	开始规则	0
row_map_mode	String	否	行映射方式	rowid
db_user_map	Object	否	用户映射模式	{"CTT":"CTT"}
map_type	String	否	映射方式	user
table_map	Array	否	表映射模式
sync_mode	Number	否		1
dbmap_topic	String	否	kfk 整库映射
start_scn	String	否	起始scn
storage_settings	Object	否	高级->存储设置
src_max_mem	Number	否		512
src_max_disk	Number	否		5000
txn_max_mem	Number	否		10000
tf_max_size	Number	否		100
tgt_extern_table	String	否
max_ld_mem	String
table_space_map	Object	否	高级->表空间映射
tgt_table_space	String	否
table_mapping_way	String	否		ptop
table_path_map	Object	否		{"ddd":"sss","ddd1":"sss1"}
table_space_name	Object	否		{"qq":"ss"}
other_settings	Object	否	高级->其他设置
keep_dyn_data	Number	否		0
dyn_thread	Number	否		1
dly_constraint_load	Number	否		0
zip_level	Number	否		0
ddl_cv	Number	否	备端对删除的表进行备份	0
keep_bad_act	Number	否		0
keep_usr_pwd	Number	否		1
convert_urp_of_key	Number	否		0
merge_track	String		统一解析
ignore_foreign_key	Number	否		0
table_delay_load	Array		["hh.ww"]
fill_lob_column	String
keep_seq_sync	String
gen_txn	String
encrypt_switch	Number
encrypt_type	Number
table_change_info	Number		表结构变更通知
encrypt_key	String
message_format	String		protobuf json
json_format	String		json canaljson message_format为json时，可传json ， canaljson， 其他值传空串
run_time	String		运行时间	"1200:00-13:0040M,300:00-13:0040M"
jointing	Object		字段拼接
table	String		表
op	String		操作 op类型定义 前辍 prefix 后辍 append 常量 const 拼接 join 加 add 减 sub 乘 multiply 除 divide	append
content	Array		目标列+其他两行
enable_truncate_frequence	Number		truncate频率限制 0：关 1：开
bw_settings	Object	否	高级->宽带设置
bw_limit	String	否		"1200:00-13:0040M,300:00-13:0040M"
full_sync_settings	Object	否	全同步设置
load_thd	Number	否		1
keep_exist_table	Number	否		0
keep_table	Number	否		0
ld_dir_opt	Number	否		0
his_thread	Number	否		1
try_split_part_table	Number	否		0
concurrent_table	Array	否		["hello.world"]
dump_thd	Number			1
clean_user_before_dump	Number			0
existing_table	String			drop_to_recycle
sync_mode	Number			0
start_scn	String
full_sync_obj_filter	Object	否	全同步对象过滤
full_sync_obj_data	Array	否		["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filter	Object	否	增量同步对象ddl过滤
inc_sync_ddl_data	Array	否		["INDEX","VIEW","FUNCTION"]
filter_table_settings	Object	否	过滤表
exclude_table	Array	否		["hh.ww"]
etl_settings	Object	否	etl
etl_table	Array	否
oprType	String	否		IRP
table	String	否
user	String	否
process	String	否		SKIP
addInfo	String	否
biz_grp_list	Array	否	分组业务
kafka_time_out	String	否			12000
part_load_balance	String	否			by_table
kafka_message_encoding	String				UTF-8
save_json_text	Boolean		【目标为Kafka】“另存文本文件”开关	false
kafka	Array
binary_code	String		取值 hex ， base64		hex
dml_track	Array
enable	Boolean		是否启用 true
keep_deleted_row	Boolean		是否保留删除列 true
date_column	String		操作日期字段名
time_column	String		操作时间字段名
date_time_column	String		操作日期+时间字段名
op_column	String		操作标记字段名
opv_insert	String		操作标记字段：插入操作标记值
opv_update	String		操作标记字段：更新操作标记值
opv_update_key	String		操作标记字段：更新主键、唯一键操作标记值
opv_delete	String		操作标记字段：删除操作标记值
audit	Boolean		是否启用审计表
audit_prefix	String		审计表前辍
audit_appendix	String		审计表后辍
identity_column	String		自增列字段	AUTO_INCR
load_date_column	String		装载仅日期
load_time_column	String		装载仅时间
load_date_time_column	String		时间和日期
error_handling	Object		高级->错误处理
load_err_set	String		装载错误处理方式 continue 继续装载 stopld:停止装载 stoptabld:停止此表装载	continue
drp	String		删除时未找到记录 ignore :忽略 err:报错	ignore
irp	String		插入时记录冲突 irp: 删除后插入 tourp:转换为更新 err:报错	irpafterdel
urp	String		更新时为找到记录 toirp: 转换为插入 err:报错	toirp
report_failed_dml	Number		上传dml 错误 0：没选中 1：选中
maintenance	Number		维护模式

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否		success
uuid	String			@uuid
info_list	Array
code	String
message	String
rule_uuid	String
rule_name	String

同步规则 - 修改

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

URL

/active/rule

Method

PUT

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_name	String	否	表名	ctt->ctt
src_db_uuid	String	否	源库uuid	6C4AEF37-6496-6DCD-E085-DD640001E4EC
tgt_db_uuid	String	否	备库uuid	1C5F3C4B-7333-9518-7349-9712BC9ED664
start_rule_now	Number	否	开始同步规则	0
row_map_mode	String	否	行映射方式	rowid
tgt_type	String	否	备库类型	oracle
db_user_map	Object	否	用户映射	{"CTT":"CTT"}
map_type	String	否	映射类型	user
table_map	Array	否	表映射	[{}]
dbmap_topic	String	否	kfk 整库映射	test1
sync_mode	Number	否		1
start_scn	String	否	起始scn	1
storage_settings	Object	否	高级->存储设置
src_max_mem	Number	否		512
src_max_disk	Number	否		5000
txn_max_mem	Number	否		10000
tf_max_size	Number	否		100
tgt_extern_table	String	否		1
max_ld_mem	String			1
table_space_map	Object	否	高级->表空间映射
tgt_table_space	String	否		1
table_mapping_way	String	否		ptop
table_path_map	Object	否		{"ddd":"sss","ddd1":"sss1"}
table_space_name	Object	否		{"qq":"ss"}
other_settings	Object	否	高级->其他设置
keep_dyn_data	Number	否		0
dyn_thread	Number	否		1
dly_constraint_load	Number	否		0
zip_level	Number	否		0
ddl_cv	Number	否	备端对删除的表进行备份	0
keep_bad_act	Number	否		0
keep_usr_pwd	Number	否		1
convert_urp_of_key	Number	否		0
ignore_foreign_key	Number	否		0
table_delay_load	Array
table	String
user	String
keep_seq_sync	String			1
fill_lob_colum	String
gen_txn	String			1
merge_track	String
sync_lob	Number		是否同步lob 数据
table_change_info	Number		表结构变更通知	1
message_format	String		protobuf json
json_format	String		json canaljson message_format为json时，可传json ， canaljson， 其他值传空串
run_time	String		运行时间
enable_truncate_frequence	Number		truncate频率限制 0：关 1：开
error_handling	Object	否	高级->错误处理
load_err_set	String	否	装载错误处理方式 continue 继续装载 stopld:停止装载 stoptabld:停止此表装载	continue
drp	String	否	删除时未找到记录 ignore :忽略 err:报错	ignore
irp	String	否	插入时记录冲突 irp: 删除后插入 tourp:转换为更新 err:报错	irpafterdel
urp	String	否	更新时为找到记录 toirp: 转换为插入 err:报错	toirp
report_failed_dml	Number		上传dml 错误 0：没选中 1：选中
bw_settings	Object	否	高级->宽带设置
bw_limit	String	否		"1200:00-13:0040M,300:00-13:0040M"
full_sync_settings	Object	否	全同步设置
keep_exist_table	Number	否		0
keep_table	Number	否		0
load_mode	String	否		direct
ld_dir_opt	Number	否		0
his_thread	Number	否		1
try_split_part_table	Number	否		0
concurrent_table	Array	否		["hello.world"]
dump_thd	Number			1
clean_user_before_dump	Number			1
existing_table	String			s
sync_mode	Number			1
start_scn	String			1
load_thd	Number
full_sync_obj_filter	Object	否	全同步对象过滤
full_sync_obj_data	Array	否		["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filter	Object	否	增量同步对象ddl过滤
inc_sync_ddl_data	Array	否		["INDEX","VIEW","FUNCTION"]
filter_table_settings	Object	否	过滤表
exclude_table	Array	否		["hh.ww"]
etl_settings	Object	否	etl
etl_table	Array	否
oprType	String	否		IRP
table	String	否		1
user	String	否		user
process	String	否		SKIP
addInfo	String	否		1
biz_grp_list	Array	否	分组业务
kafka_time_out	String	否	producer 超时时间	12000
part_load_balance	String	否	分区均衡策略	12
rule_uuid	String			F530FB0E-0208-9071-66D3-E595AE7D5A4C
kafka	Array
binary_code	String		取值 hex ， base64	base64
dml_track	Array
enable	Boolean			1
urp	Number			1
drp	Number			1
tmcol	String			1
delcol	String			1
save_json_text	Boolean		【目标类型：Kafka】另存文本文件	false

Response

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

同步规则 - 批量修改

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

URL

/active/rule/batch

Method

PUT

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_uuids	Array		需要被修改的规则
start_rule_now	Number	否	开始同步规则	0
row_map_mode	String	否	行映射方式	rowid
tgt_type	String	否	备库类型	oracle
db_user_map	Object	否	用户映射	{"CTT":"CTT"}
map_type	String	否	映射类型	user
table_map	Array	否	表映射	[{}]
dbmap_topic	String	否	kfk 整库映射	test1
sync_mode	Number	否		1
start_scn	String	否	起始scn	1
storage_settings	Object	否	高级->存储设置
src_max_mem	Number	否		512
src_max_disk	Number	否		5000
txn_max_mem	Number	否		10000
tf_max_size	Number	否		100
tgt_extern_table	String	否		1
max_ld_mem	String			1
table_space_map	Object	否	高级->表空间映射
tgt_table_space	String	否		1
table_mapping_way	String	否		ptop
table_path_map	Object	否		{"ddd":"sss","ddd1":"sss1"}
table_space_name	Object	否		{"qq":"ss"}
other_settings	Object	否	高级->其他设置
keep_dyn_data	Number	否		0
dyn_thread	Number	否		1
dly_constraint_load	Number	否		0
zip_level	Number	否		0
ddl_cv	Number	否	备端对删除的表进行备份	0
keep_bad_act	Number	否		0
keep_usr_pwd	Number	否		1
convert_urp_of_key	Number	否		0
ignore_foreign_key	Number	否		0
table_delay_load	Array
table	String
user	String
keep_seq_sync	String			1
fill_lob_colum	String
gen_txn	String			1
merge_track	String
sync_lob	Number		是否同步lob 数据
table_change_info	Number		表结构变更通知	1
message_format	String		protobuf json
json_format	String		json canaljson message_format为json时，可传json ， canaljson， 其他值传空串
run_time	String		运行时间
enable_truncate_frequence	String		truncate频率限制 0：关 1：开
error_handling	Object	否	高级->错误处理
load_err_set	String	否	装载错误处理方式 continue 继续装载 stopld:停止装载 stoptabld:停止此表装载	continue
drp	String	否	删除时未找到记录 ignore :忽略 err:报错	ignore
irp	String	否	插入时记录冲突 irp: 删除后插入 tourp:转换为更新 err:报错	irpafterdel
urp	String	否	更新时为找到记录 toirp: 转换为插入 err:报错	toirp
report_failed_dml	Number		上传dml 错误 0：没选中 1：选中
bw_settings	Object	否	高级->宽带设置
bw_limit	String	否		"1200:00-13:0040M,300:00-13:0040M"
full_sync_settings	Object	否	全同步设置
keep_exist_table	Number	否		0
keep_table	Number	否		0
load_mode	String	否		direct
ld_dir_opt	Number	否		0
his_thread	Number	否		1
try_split_part_table	Number	否		0
concurrent_table	Array	否		["hello.world"]
dump_thd	Number			1
clean_user_before_dump	Number			1
existing_table	String			s
sync_mode	Number			1
start_scn	String			1
load_thd	Number
full_sync_obj_filter	Object	否	全同步对象过滤
full_sync_obj_data	Array	否		["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]
inc_sync_ddl_filter	Object	否	增量同步对象ddl过滤
inc_sync_ddl_data	Array	否		["INDEX","VIEW","FUNCTION"]
filter_table_settings	Object	否	过滤表
exclude_table	Array	否		["hh.ww"]
etl_settings	Object	否	etl
etl_table	Array	否
oprType	String	否		IRP
table	String	否		1
user	String	否		user
process	String	否		SKIP
addInfo	String	否		1
biz_grp_list	Array	否	分组业务
kafka_time_out	String	否	producer 超时时间	12000
part_load_balance	String	否	分区均衡策略	12
rule_uuid	String			F530FB0E-0208-9071-66D3-E595AE7D5A4C
kafka	Array
binary_code	String		取值 hex ， base64	base64
dml_track	Array
enable	Boolean			1
urp	Number			1
drp	Number			1
tmcol	String			1
delcol	String			1
save_json_text	Boolean		【目标类型：Kafka】另存文本文件	false
batch_basic_settings	Number		基本设置 批量更新开关 0：关闭， 1：开启	0
batch_full_sync_settings	Number		全量设置 批量更新开关 0：关闭， 1：开启	0
batch_incre_sync_settings	Number		增量设置 批量更新开关 0：关闭， 1：开启	0
batch_advanced_settings	Number		高级设置 批量更新开关 0：关闭， 1：开启	0
batch_full_sync_obj_filter	Number		全量对象设置 批量更新开关 0：关闭， 1：开启	0
batch_inc_sync_ddl_filter	Number		增量DDL设置 批量更新开关 0：关闭， 1：开启	0
batch_encrypt_compress	Number		加密压缩设置 批量更新开关 0：关闭， 1：开启	0

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
code	Number	否		0
message	String	否		success
result	Array
rule_uuid	String
code	String
message	String

同步规则 - 删除

SDK方法名：deleteOracleRule

URL

/active/rule

Method

DELETE

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_uuids	Array	否	规则数组	["DBED8CDE-435D-7865-76FE-149AA54AC7F7"]
type	String	否	false_rule
force	Boolean		true

Response

名称	类型	必选	简介	Mock初始值	Mock规则
msg	String	否
data	Object	否
code	Number	否		1
message	String	否		Delete success
success_list	Array
code	String			0
rule_uuid	String			sfasf
rule_name	String			dddddd
message	String			dddd
fail_list	Array
code	Number			-1
message	String			dfrrr
rule_uuid	String			yrtrshgf
rule_name	String			gfhfdhfsh
ret	Number	否		200

同步规则-数据库预检（已废弃）

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

URL

/active/rule/db_check_single

Method

POST

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
message	String
code	Number			0
info_list	Object
ver	String		版本号
lang	String		字符集的信息
nlang	String		国家字符集
max_processes	String		process 最大连接数
db_block_size	String
all_redo_size	String		redo log 总大小
db_file	String		db_files 数
open_cursor	String
partition_large_extents	String		成功：1 失败：0
components	Object		组件列表
min_supple_log	String		最小附加日志 成功:1 失败：0	1
force_logging	String		正确 1 失败：0 成功:1 失败：0	1
index_partition_large_extents	String		成功 1 失败 0
open_arch	String		开启归档 成功：1 失败：0
db_connect	String		成功:1 失败：0	1
notice	String		注意事项
uuid	String

同步规则-获取单个

SDK方法名：describeSyncRules

URL

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

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否		success
code	Number	否		0
info_list	Object	否
rule_uuid	String	否		751A03F5-C97D-645B-82B2-316A5D198528
src_db_uuid	String	否		4CA773F4-36E3-A091-122C-ACDFB2112C21
tgt_db_uuid	String	否		40405FD3-DB86-DC8A-81C9-C137B6FDECE5
tgt_type	String	否		kafka
db_user_map	String	否		{"11":"1122"}
row_map_mode	String	否		rowid
map_type	String	否		user
table_map	Array	否		[{src_user: "111", src_table: "222", dst_user: "3", dst_table: "4"}]
dbmap_topic	String	否
node_uuid	String	否
sync_mode	Number	否		0
start_scn	String	否		0
full_sync_settings	Object	否
keep_exist_table	Number	否		0
keep_table	Number	否		0
load_mode	String	否		direct
ld_dir_opt	Number	否		0
his_thread	Number	否		1
try_split_part_table	Number	否		0
concurrent_table	Array	否		["hello.world"]
rule_name	String	否		ctt->ctt
inc_sync_ddl_filter	Object	否
inc_sync_ddl_data	Array	否		["CREATE TABLE","DROP TABLE","ALTER TABLE"]
filter_table_settings	Object	否
exclude_table	Array	否		["hh.ww"]
etl_settings	Object	否
etl_table	Array	否		[{obj_fix_type: "URP", user: "123", table: "123", deal_type: "SKIP", field_condition: "44"}]
start_rule_now	Number	否		0
storage_settings	Object	否
src_max_mem	Number	否		512
src_max_disk	Number	否		5000
txn_max_mem	Number	否		10000
tf_max_size	Number	否		100
tgt_extern_table	String	否
error_handling	Object	否
load_err_set	String	否		continue
drp	String	否		ignore
irp	String	否		irpafterdel
urp	String	否		toirp
table_space_map	Object	否
tgt_table_space	String	否
table_mapping_way	String	否		ptop
table_path_map	String	否		{"ddd":"sss"}
table_space_name	String	否		{"qq":"ss"}
other_settings	Object	否
keep_dyn_data	Number	否		0
dyn_thread	Number	否		1
dly_constraint_load	Number	否		0
zip_level	Number	否		0
ddl_cv	Number	否		0
keep_bad_act	Number	否		0
keep_usr_pwd	Number	否		1
convert_urp_of_key	Number	否		0
ignore_foreign_key	Number	否		0
bw_settings	Object	否
bw_limit	String	否		1200:00-13:0040k,300:00-13:0040m
biz_grp_list	Array	否	业务组
dml_track	Object	否
enable	Number	否		1
urp	Number	否		0
drp	Number	否		1
tmcol	String	否
delcol	String	否
producer_send_time	String	否		66666
part_load_balance	String	否		by_table
kafka_time_out	String	否		132000
full_sync_obj_filter	Object	否
full_sync_obj_data	Array	否		["PROCEDURE","PACKAGE","PACKAGE BODY","DATABASE LINK","OLD JOB","JOB","PRIVS","CONSTRAINT","JAVA RESOURCE","JAVA SOURCE"]

同步规则 - 操作

SDK方法名：

继续：resumeOracleRule;

停止：stopOracleRule;

重启：restartOracleRule

开始日志解析：startAnalysisOracleRule;

停止日志解析：stopAnalysisOracleRule;

重新日志解析：resetAnalysisOracleRule;

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

复制：duplicateOracleRule

URL

/active/rule/operate

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
operate	String	否	resume 继续 stop 停止 restart 重启 start_analysis stop_analysis reset_analysis stop_and_stopanalysis stop_schedule 停止调度(暂弃) start_chedule 启动调度（暂弃） duplicate	restart
rule_uuid	String	否	规则uuid	@guid
scn	String	否	（重置解析）SCN	1
all	Number		（重置解析）重置源库所有规则
rule_name	String		（复制）复制的规则新名称

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
data	Object
success_list	Array				5
code	Number			,0
message	String
fail_list	Array				5
code	Number			-1
message	String
all_list	Array				10
code	Number			@pick(0,-1)
message	String

同步规则 - 状态

SDK方法名：listSyncRulesStatus

URL

/active/rule/status

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
code	Number			0
message	String			[0] 操作成功。
has_false_rule	Boolean		是否有残留规则	false
info_list	Array				2
rule_uuid	String		同步规则 uuid	['6ECF19A1-3754-1490-C6A3-52AFB4D7F497', '6ECF19A1-3754-1490-C6A3-52AFB4D7F496']	+1
work_state	Object		导出状态信息
status	String		ACTIVE_RULE_NORMAL : 正常 ACTIVE_RULE_ABNORMAL : 异常 ACTIVE_RULE_TRACK : 增量 ACTIVE_RULE_TRACK_WARNING : 增量 ACTIVE_RULE_PAUSE : 停止 ACTIVE_RULE_STOP : 停止 ACTIVE_RULE_DUMPDICT : 准备 ACTIVE_RULE_DUMP : 全量 ACTIVE_RULE_DONE : 完成 ACTIVE_RULE_FINISH : 完成 ACTIVE_RULE_ERROR : 错误 ACTIVE_RULE_INIT : 未启动 ACTIVE_RULE_FIX : 修复中 ACTIVE_RULE_UNKNOWN : 未知 ACTIVE_RULE_ONLINE : 在线 ACTIVE_RULE_WARN : 警告 ACTIVE_RULE_DOING : 在线 ACTIVE_RULE_ : 未知 ACTIVE_RULE_OFFLINE : 停止 ACTIVE_RULE_RUN : 运行 ACTIVE_RULE_WAIT : 准备 ACTIVE_REVERSE_FINISH : 完成 ACTIVE_REVERSE_ABNORMAL : 异常 ACTIVE_REVERSE_WARN : 警告 ACTIVE_REVERSE_UNKNOWN : 未知 ACTIVE_REVERSE_ : 未知 ACTIVE_REVERSE_FINISH : 完成 ACTIVE_REVERSE_ABNORMAL : 异常 ACTIVE_REVERSE_WARN : 警告 ACTIVE_REVERSE_UNKNOWN : 未知 ACTIVE_REVERSE_ : 未知 REVERSE_DOING : 在线 REVERSE_DONE : 完成 REVERSE_STOP : 停止 REVERSE_PAUSE : 暂停 ACTIVE_RULE_SCHEDULING : [调度中] ACTIVE_RULE_STOP_SCHEDUL : [停止调度] OBJ_FIX_DOING : 正在修复 OBJ_FIX_DONE : 修复完成 OBJ_FIX_ERROR : 修复错误 OBJ_FIX_UNKNOWN : 未知 OBJ_FIX_STOP : 停止修复 OBJ_FIX_ABNORMAL : 修复异常 OBJ_FIX_PAUSE : 停止 OBJ_FIX_OFFLINE : 离线 CMP_ABNORMAL : 比较异常 CMP_DOING : 正在比较 CMP_DONE : 比较完成 CMP_ERROR : 比较错误 CMP_UNKNOWN : 未知 CMP_PAUSE : 停止 CMP_STOP : 停止 CMP_WAIT : 等待中 CMP_OFFLINE : 离线 TAKEOVER_UNKNOWN : 未知 TAKEOVER_DOING : 正在接管 TAKEOVER_DONE : 接管完成 TAKEOVER_ERROR : 接管错误 TAKEOVER_STOP : 接管停止 TAKEOVER_ABNORMAL : 接管异常 TAKEOVER_OFFLINE : 离线	ACTIVE_RULE_TRACK
error_code	Number			-4018
progress	String			[98, 66]	+1
back_state	Object		装载信息
status	String		同上work_state	ACTIVE_RULE_PAUSE
relay_state	Object		中继节点的信息
status	String		同上work_state
error_code	String
track_state	Object		解析状态信息
status	String		同上work_state	['ACTIVE_RULE_PAUSE', 'OFFLINE']	+1
src_state	Object		此功能对应数据源的状态，领导要求暂时屏蔽此功能，可不看
status	String			ACTIVE_RULE_UNKNOWN
dst_state	Object		同src_state
status	String			ACTIVE_RULE_UNKNOWN
extract	String		解析时间	-
load	String		装载时间	-
delay	Number		延迟	0
peak	Number		峰值	0
has_new_err	Number		对应日志报警 1：显示有新的日志 0：没有新日志产生	1
data_info	Object		对应的悬浮框内的信息
dst	Object		目标端
db_ip	Array		目标端ip	["192.168.12.199"]
node_ip	String		节点ip	192.168.12.199
node_name	String		名称	test_c199
log_read_type	String	是	日志读取方式	file
orcl	String		服务名	orcl
src	Object		数据源
db_ip	Array		数据库ip	["192.168.12.200"]
node_ip	String		节点ip	192.168.12.200
node_name	String		节点名	test_c200
log_read_type	String		读取方式	file
orcl	String		服务名	orcl
stage	String		对应原先功能总览->同步规则的功能，暂时弃用	PAUSE
state	Number		对应原先功能总览->同步规则的功能，暂时弃用	-4018
progress	Null		对应原先功能总览->同步规则的功能，暂时弃用
scheduleState	String		ACTIVE_RULE_SCHEDULING：调度中 ACTIVE_RULE_STOP_SCHEDUL:停止调度	ACTIVE_RULE_STOP_SCHEDUL

同步规则-表修复

SDK方法名：describeRuleTableFix;表修复

URL

/active/rule/table_fix

Method

POST

Request

名称	类型	必选	简介	Mock初始值	Mock规则
rule_uuid	String	否	规则uuid	F530FB0E-0208-9071-66D3-E595AE7D5A4C
tab	Array	否	表信息，为用户.表的形式	["I2.table"]
fix_relation	Number	否	0 无关联 1 有关联	0

Response

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

同步规则-获取scn号

SDK方法名：describeRuleGetScn;

URL

/active/rule/get_scn

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number	否		200
msg	String	否
data	Object	否
message	String	否
code	Number	否		0
scn	String	否

同步规则 - 从底层获取SCN

getSCN获取SCN

URL

/active/rule/get_rpc_scn

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	String
msg	String
data	Object
message	String
code	Number
scn	String

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

getRevertSCN获取SCN

URL

/active/rule/get_revert_rpc_scn

Method

GET

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	String
msg	String
data	Object
message	String
code	Number
scn	String

同步规则-偏移量信息

SDK方法名：listKafkaOffsetInfo;

URL

/active/rule/kafka_offset

Method

POST

Request

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

Response

名称	类型	必选	简介	Mock初始值	Mock规则
ret	Number			200
msg	String
data	Object
message	String
code	Number			0
info_list	Object
update_time	String			2020-12-02 18:07:59
kafka_latest_offset	Array				2
topic	String			test1
partition	String			0
offset	String			1
timestamp	String			2020-12-02 16:45:27