mirror of
https://gitee.com/dromara/RuoYi-Vue-Plus.git
synced 2026-09-13 15:43:43 +08:00
360 lines
37 KiB
SQL
360 lines
37 KiB
SQL
-- ----------------------------
|
||
-- 数据同步模块（MySQL）
|
||
-- 依赖 ry_vue.sql 中的 sys_menu、sys_dict_type、sys_dict_data 表
|
||
-- ----------------------------
|
||
|
||
-- ----------------------------
|
||
-- 1、连接配置表
|
||
-- ----------------------------
|
||
create table sync_connection
|
||
(
|
||
connection_id bigint(20) not null comment '连接ID',
|
||
connection_name varchar(100) not null comment '连接名称',
|
||
connection_role varchar(16) not null comment '连接角色（SOURCE源端 TARGET目标端）',
|
||
connection_type varchar(32) not null comment '连接类型（DINGTALK钉钉 S3标准S3 ALIYUN_OSS阿里云OSS）',
|
||
endpoint varchar(512) default null comment '服务端点',
|
||
region varchar(64) default null comment '区域',
|
||
bucket_name varchar(255) default null comment '存储桶名称',
|
||
base_path varchar(1024) default '' comment '连接默认根路径',
|
||
config_json text comment '非敏感扩展配置JSON',
|
||
secret_json text comment '加密后的敏感配置JSON（禁止明文存储）',
|
||
status char(1) default '0' comment '状态（0正常 1停用）',
|
||
del_flag char(1) default '0' comment '删除标志（0代表存在 1代表删除）',
|
||
active_name varchar(100) generated always as
|
||
(case when del_flag = '0' then connection_name else null end) stored
|
||
comment '有效连接名称（用于唯一约束）',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
remark varchar(500) default null comment '备注',
|
||
primary key (connection_id),
|
||
unique key uk_sync_connection_active_name (active_name),
|
||
key idx_sync_connection_name_del (connection_name, del_flag),
|
||
key idx_sync_connection_role_type (connection_role, connection_type),
|
||
key idx_sync_connection_status_del (status, del_flag)
|
||
) engine = innodb comment = '数据同步连接配置表';
|
||
|
||
-- ----------------------------
|
||
-- 2、同步计划表
|
||
-- ----------------------------
|
||
create table sync_plan
|
||
(
|
||
plan_id bigint(20) not null comment '同步计划ID',
|
||
plan_name varchar(100) not null comment '计划名称',
|
||
source_connection_id bigint(20) not null comment '源端连接ID',
|
||
target_connection_id bigint(20) not null comment '目标端连接ID',
|
||
source_root varchar(1024) default '/' comment '源端同步根路径或空间标识',
|
||
target_prefix varchar(1024) default '' comment '目标端对象键前缀',
|
||
sync_mode varchar(16) default 'INCREMENTAL' comment '同步模式（FULL全量 INCREMENTAL增量）',
|
||
schedule_type varchar(16) default 'MANUAL' comment '调度类型（MANUAL手动 CRON定时）',
|
||
cron_expression varchar(128) default null comment 'Cron表达式',
|
||
conflict_strategy varchar(16) default 'OVERWRITE' comment '冲突策略（OVERWRITE覆盖 SKIP跳过 KEEP_BOTH两者保留）',
|
||
delete_strategy varchar(16) default 'KEEP' comment '删除策略（KEEP保留 MARK标记 DELETE删除目标）',
|
||
delete_guard_percent int(11) default 50 comment '单次目标删除比例保护阈值（0-100，100表示允许全删）',
|
||
verify_mode varchar(16) default 'SIZE' comment '校验方式（SIZE大小 ETAG标识 SHA256摘要）',
|
||
max_concurrency int(11) default 4 comment '最大并发传输数',
|
||
bandwidth_limit_kbps bigint(20) default 0 comment '带宽上限KB/s（0表示不限速）',
|
||
status char(1) default '0' comment '状态（0正常 1停用）',
|
||
last_run_time datetime default null comment '最近运行时间',
|
||
next_run_time datetime default null comment '下次运行时间',
|
||
del_flag char(1) default '0' comment '删除标志（0代表存在 1代表删除）',
|
||
active_name varchar(100) generated always as
|
||
(case when del_flag = '0' then plan_name else null end) stored
|
||
comment '有效计划名称（用于唯一约束）',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
remark varchar(500) default null comment '备注',
|
||
primary key (plan_id),
|
||
unique key uk_sync_plan_active_name (active_name),
|
||
key idx_sync_plan_name_del (plan_name, del_flag),
|
||
key idx_sync_plan_source_connection (source_connection_id),
|
||
key idx_sync_plan_target_connection (target_connection_id),
|
||
key idx_sync_plan_schedule (status, del_flag, schedule_type, next_run_time)
|
||
) engine = innodb comment = '数据同步计划表';
|
||
|
||
-- ----------------------------
|
||
-- 3、同步任务表
|
||
-- ----------------------------
|
||
create table sync_job
|
||
(
|
||
job_id bigint(20) not null comment '同步任务ID',
|
||
plan_id bigint(20) not null comment '同步计划ID',
|
||
trigger_type varchar(16) not null comment '触发类型（MANUAL手动 SCHEDULE调度 RETRY重试）',
|
||
run_type varchar(16) not null comment '运行类型（FULL全量 INCREMENTAL增量）',
|
||
status varchar(20) default 'PENDING' comment '任务状态（PENDING待执行 RUNNING执行中 CANCELING取消中 SUCCESS成功 PARTIAL_FAILED部分失败 FAILED失败 CANCELED已取消）',
|
||
active_plan_id bigint(20) generated always as
|
||
(case when status in ('PENDING', 'RUNNING', 'CANCELING') then plan_id else null end) stored
|
||
comment '活动任务计划ID（用于保证单计划仅一个运行任务）',
|
||
checkpoint_before text comment '运行前检查点快照',
|
||
checkpoint_after text comment '运行后检查点快照',
|
||
total_count bigint(20) default 0 comment '待处理对象总数',
|
||
processed_count bigint(20) default 0 comment '已处理对象数',
|
||
success_count bigint(20) default 0 comment '成功对象数',
|
||
failed_count bigint(20) default 0 comment '失败对象数',
|
||
skipped_count bigint(20) default 0 comment '跳过对象数',
|
||
deleted_count bigint(20) default 0 comment '删除或标记对象数',
|
||
total_bytes bigint(20) default 0 comment '待传输总字节数',
|
||
transferred_bytes bigint(20) default 0 comment '已传输字节数',
|
||
start_time datetime default null comment '开始时间',
|
||
finish_time datetime default null comment '结束时间',
|
||
error_message text comment '任务错误信息',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
primary key (job_id),
|
||
unique key uk_sync_job_active_plan (active_plan_id),
|
||
key idx_sync_job_plan_time (plan_id, create_time),
|
||
key idx_sync_job_status_time (status, create_time)
|
||
) engine = innodb comment = '数据同步任务表';
|
||
|
||
-- ----------------------------
|
||
-- 4、同步任务明细表
|
||
-- ----------------------------
|
||
create table sync_job_item
|
||
(
|
||
item_id bigint(20) not null comment '任务明细ID',
|
||
job_id bigint(20) not null comment '同步任务ID',
|
||
source_object_id varchar(255) not null comment '源端对象唯一标识',
|
||
parent_object_id varchar(255) default null comment '源端父对象标识',
|
||
source_path varchar(2048) not null comment '源端相对路径',
|
||
target_key varchar(2048) default null comment '目标端对象键',
|
||
object_type varchar(16) not null comment '对象类型（FILE文件 FOLDER目录 ONLINE_DOCUMENT在线文档）',
|
||
action_type varchar(16) not null comment '动作类型（CREATE新增上传 UPDATE更新上传 SKIP跳过 DELETE删除）',
|
||
status varchar(20) default 'PENDING' comment '明细状态（PENDING待执行 RUNNING执行中 SUCCESS成功 SKIPPED已跳过 FAILED失败）',
|
||
size bigint(20) default 0 comment '源对象字节数',
|
||
transferred_bytes bigint(20) default 0 comment '已传输字节数',
|
||
version_token varchar(512) default null comment '源端版本标识',
|
||
source_etag varchar(255) default null comment '源端ETag',
|
||
source_sha256 char(64) default null comment '源端SHA-256摘要',
|
||
target_etag varchar(255) default null comment '目标端ETag',
|
||
target_version_id varchar(512) default null comment '目标端版本ID',
|
||
retry_count int(11) default 0 comment '已重试次数',
|
||
start_time datetime default null comment '开始时间',
|
||
finish_time datetime default null comment '结束时间',
|
||
error_code varchar(64) default null comment '错误码',
|
||
error_message text comment '错误信息',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
primary key (item_id),
|
||
unique key uk_sync_job_item_job_object (job_id, source_object_id),
|
||
key idx_sync_job_item_job_status (job_id, status),
|
||
key idx_sync_job_item_retry (status, retry_count),
|
||
key idx_sync_job_item_parent (job_id, parent_object_id)
|
||
) engine = innodb comment = '数据同步任务明细表';
|
||
|
||
-- ----------------------------
|
||
-- 5、源对象状态表
|
||
-- ----------------------------
|
||
create table sync_object
|
||
(
|
||
object_id bigint(20) not null comment '对象记录ID',
|
||
plan_id bigint(20) not null comment '同步计划ID',
|
||
source_object_id varchar(255) not null comment '源端对象唯一标识',
|
||
parent_object_id varchar(255) default null comment '源端父对象标识',
|
||
object_name varchar(1024) not null comment '对象名称',
|
||
source_path varchar(2048) not null comment '相对同步根目录的源端路径',
|
||
object_type varchar(16) not null comment '对象类型（FILE文件 FOLDER目录 ONLINE_DOCUMENT在线文档）',
|
||
size bigint(20) default 0 comment '对象字节数',
|
||
modified_time datetime default null comment '源端最后修改时间',
|
||
version_token varchar(512) default null comment '源端版本标识',
|
||
source_etag varchar(255) default null comment '源端ETag',
|
||
source_sha256 char(64) default null comment '源端SHA-256摘要',
|
||
content_type varchar(255) default null comment '内容类型',
|
||
metadata_json text comment '源端扩展元数据JSON',
|
||
target_key varchar(2048) default null comment '最近成功同步的目标对象键',
|
||
target_version_id varchar(512) default null comment '最近成功同步的目标版本ID',
|
||
target_etag varchar(255) default null comment '最近成功同步的目标端ETag',
|
||
sync_status varchar(20) default 'DISCOVERED' comment '同步状态（DISCOVERED已发现 PENDING待同步 SYNCED已同步 SKIPPED已跳过 FAILED失败 DELETED源端已删除）',
|
||
source_deleted char(1) default '0' comment '源端删除标志（0未删除 1已删除）',
|
||
first_seen_job_id bigint(20) default null comment '首次发现任务ID',
|
||
last_seen_job_id bigint(20) default null comment '最近扫描发现任务ID',
|
||
last_sync_job_id bigint(20) default null comment '最近成功同步任务ID',
|
||
last_sync_time datetime default null comment '最近成功同步时间',
|
||
last_error_message text comment '最近同步错误信息',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
primary key (object_id),
|
||
unique key uk_sync_object_plan_source (plan_id, source_object_id),
|
||
key idx_sync_object_plan_status (plan_id, sync_status, source_deleted),
|
||
key idx_sync_object_last_seen (plan_id, last_seen_job_id),
|
||
key idx_sync_object_target_key (plan_id, target_key(191))
|
||
) engine = innodb comment = '数据同步源对象状态表';
|
||
|
||
-- ----------------------------
|
||
-- 6、增量检查点表
|
||
-- ----------------------------
|
||
create table sync_checkpoint
|
||
(
|
||
checkpoint_id bigint(20) not null comment '检查点ID',
|
||
plan_id bigint(20) not null comment '同步计划ID',
|
||
checkpoint_type varchar(32) not null comment '检查点类型（PAGE_CURSOR分页游标 INCREMENTAL_WATERMARK增量水位 RUN_WATERMARK运行水位）',
|
||
checkpoint_key varchar(255) not null comment '检查点作用域键（空间、目录或分区标识）',
|
||
checkpoint_value longtext comment '检查点值或JSON快照',
|
||
watermark_time datetime default null comment '增量水位时间',
|
||
last_job_id bigint(20) default null comment '最近提交检查点的任务ID',
|
||
version bigint(20) default 0 comment '乐观锁版本号',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
primary key (checkpoint_id),
|
||
unique key uk_sync_checkpoint_plan_type_key (plan_id, checkpoint_type, checkpoint_key),
|
||
key idx_sync_checkpoint_last_job (last_job_id)
|
||
) engine = innodb comment = '数据同步增量检查点表';
|
||
|
||
-- ----------------------------
|
||
-- 7、分片传输记录表
|
||
-- ----------------------------
|
||
create table sync_transfer_part
|
||
(
|
||
part_id bigint(20) not null comment '分片记录ID',
|
||
job_item_id bigint(20) not null comment '任务明细ID',
|
||
upload_id varchar(512) not null comment '目标端分片上传会话ID',
|
||
part_number int(11) not null comment '分片序号（从1开始）',
|
||
part_offset bigint(20) default 0 comment '分片起始字节偏移',
|
||
part_size bigint(20) default 0 comment '分片字节数',
|
||
transferred_bytes bigint(20) default 0 comment '分片已传输字节数',
|
||
part_etag varchar(255) default null comment '目标端分片ETag',
|
||
checksum_sha256 char(64) default null comment '分片SHA-256摘要',
|
||
status varchar(20) default 'PENDING' comment '分片状态（PENDING待上传 UPLOADING上传中 SUCCESS成功 FAILED失败）',
|
||
retry_count int(11) default 0 comment '已重试次数',
|
||
start_time datetime default null comment '开始时间',
|
||
finish_time datetime default null comment '结束时间',
|
||
error_message text comment '错误信息',
|
||
create_dept bigint(20) default null comment '创建部门',
|
||
create_by bigint(20) default null comment '创建者',
|
||
create_time datetime default null comment '创建时间',
|
||
update_by bigint(20) default null comment '更新者',
|
||
update_time datetime default null comment '更新时间',
|
||
primary key (part_id),
|
||
unique key uk_sync_transfer_part_item_number (job_item_id, part_number),
|
||
key idx_sync_transfer_part_upload_status (upload_id(191), status),
|
||
key idx_sync_transfer_part_status_retry (status, retry_count)
|
||
) engine = innodb comment = '数据同步分片传输记录表';
|
||
|
||
-- ----------------------------
|
||
-- 8、数据同步菜单
|
||
-- ----------------------------
|
||
insert into sys_menu
|
||
(menu_id, menu_name, parent_id, order_num, path, component, query_param, is_frame, is_cache, menu_type,
|
||
visible, status, perms, icon, active_menu, ext, create_dept, create_by, create_time, update_by, update_time, remark)
|
||
values
|
||
(1901400000000000001, '数据同步', 0, 2, 'sync', null, null, 'N', 'Y', 'M', '0', '0', null, 'sync', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步目录'),
|
||
(1901400000000000100, '连接管理', 1901400000000000001, 1, 'connection', 'sync/connection/index', null, 'N', 'Y', 'C', '0', '0', 'sync:connection:list', 'link', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步连接管理菜单'),
|
||
(1901400000000000101, '同步计划', 1901400000000000001, 2, 'plan', 'sync/plan/index', null, 'N', 'Y', 'C', '0', '0', 'sync:plan:list', 'calendar', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步计划菜单'),
|
||
(1901400000000000102, '同步任务', 1901400000000000001, 3, 'job', 'sync/job/index', null, 'N', 'Y', 'C', '0', '0', 'sync:job:list', 'job', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步任务菜单'),
|
||
(1901400000000000103, '对象清单', 1901400000000000001, 4, 'object', 'sync/object/index', null, 'N', 'Y', 'C', '0', '0', 'sync:object:list', 'list', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步对象清单菜单'),
|
||
(1901400000000001001, '连接查询', 1901400000000000100, 1, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:query', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001002, '连接新增', 1901400000000000100, 2, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:add', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001003, '连接修改', 1901400000000000100, 3, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:edit', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001004, '连接删除', 1901400000000000100, 4, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:remove', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001006, '连接测试', 1901400000000000100, 5, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:test', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001007, '钉钉 Web 登录', 1901400000000000100, 6, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:connection:auth', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001011, '计划查询', 1901400000000000101, 1, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:plan:query', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001012, '计划新增', 1901400000000000101, 2, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:plan:add', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001013, '计划修改', 1901400000000000101, 3, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:plan:edit', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001014, '计划删除', 1901400000000000101, 4, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:plan:remove', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001016, '立即运行', 1901400000000000101, 5, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:job:run', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001021, '任务查询', 1901400000000000102, 1, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:job:query', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001022, '任务删除', 1901400000000000102, 2, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:job:remove', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001024, '取消任务', 1901400000000000102, 3, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:job:cancel', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001025, '重试任务', 1901400000000000102, 4, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:job:retry', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, ''),
|
||
(1901400000000001031, '对象查询', 1901400000000000103, 1, '#', '', null, 'N', 'Y', 'F', '0', '0', 'sync:object:query', '#', '', '', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '');
|
||
|
||
-- ----------------------------
|
||
-- 9、数据同步字典类型
|
||
-- ----------------------------
|
||
insert into sys_dict_type
|
||
(dict_id, dict_name, dict_type, create_dept, create_by, create_time, update_by, update_time, remark)
|
||
values
|
||
(1901500000000000001, '同步连接角色', 'sync_connection_role', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步连接角色'),
|
||
(1901500000000000002, '同步连接类型', 'sync_connection_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据同步连接类型'),
|
||
(1901500000000000003, '同步模式', 'sync_mode', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '全量或增量同步模式'),
|
||
(1901500000000000004, '同步调度类型', 'sync_schedule_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '手动或Cron调度'),
|
||
(1901500000000000005, '同步冲突策略', 'sync_conflict_strategy', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '目标对象冲突处理策略'),
|
||
(1901500000000000006, '同步删除策略', 'sync_delete_strategy', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源端删除处理策略'),
|
||
(1901500000000000007, '同步校验方式', 'sync_verify_mode', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '传输完整性校验方式'),
|
||
(1901500000000000008, '同步触发类型', 'sync_trigger_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步任务触发类型'),
|
||
(1901500000000000009, '同步任务状态', 'sync_job_status', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步任务运行状态'),
|
||
(1901500000000000010, '同步明细状态', 'sync_job_item_status', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步任务明细状态'),
|
||
(1901500000000000011, '同步对象类型', 'sync_object_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步对象类型'),
|
||
(1901500000000000012, '同步动作类型', 'sync_action_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步任务明细动作类型'),
|
||
(1901500000000000013, '同步对象状态', 'sync_object_status', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源对象同步状态'),
|
||
(1901500000000000014, '同步分片状态', 'sync_transfer_part_status', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '分片上传状态'),
|
||
(1901500000000000015, '同步检查点类型', 'sync_checkpoint_type', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '增量检查点类型');
|
||
|
||
-- ----------------------------
|
||
-- 10、数据同步字典数据
|
||
-- ----------------------------
|
||
insert into sys_dict_data
|
||
(dict_code, dict_sort, dict_label, dict_value, dict_type, css_class, list_class, is_default,
|
||
create_dept, create_by, create_time, update_by, update_time, remark)
|
||
values
|
||
(1901600000000000001, 1, '源端', 'SOURCE', 'sync_connection_role', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据来源连接'),
|
||
(1901600000000000002, 2, '目标端', 'TARGET', 'sync_connection_role', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '数据目标连接'),
|
||
(1901600000000000003, 1, '钉钉', 'DINGTALK', 'sync_connection_type', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '钉钉企业网盘'),
|
||
(1901600000000000004, 2, '标准S3', 'S3', 'sync_connection_type', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, 'S3标准兼容存储'),
|
||
(1901600000000000005, 3, '阿里云OSS', 'ALIYUN_OSS', 'sync_connection_type', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '阿里云对象存储OSS'),
|
||
(1901600000000000006, 1, '全量同步', 'FULL', 'sync_mode', '', 'primary', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '每次扫描全部对象'),
|
||
(1901600000000000007, 2, '增量同步', 'INCREMENTAL', 'sync_mode', '', 'success', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '完整枚举后按持久清单差异传输'),
|
||
(1901600000000000008, 1, '手动执行', 'MANUAL', 'sync_schedule_type', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '仅手动触发'),
|
||
(1901600000000000009, 2, 'Cron调度', 'CRON', 'sync_schedule_type', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '按Cron表达式触发'),
|
||
(1901600000000000010, 1, '覆盖', 'OVERWRITE', 'sync_conflict_strategy', '', 'warning', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '覆盖目标对象'),
|
||
(1901600000000000011, 2, '跳过', 'SKIP', 'sync_conflict_strategy', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '保留目标对象并跳过'),
|
||
(1901600000000000012, 3, '两者保留', 'KEEP_BOTH', 'sync_conflict_strategy', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '重命名后保留两个对象'),
|
||
(1901600000000000013, 1, '保留目标', 'KEEP', 'sync_delete_strategy', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源端删除时保留目标对象'),
|
||
(1901600000000000014, 2, '仅标记', 'MARK', 'sync_delete_strategy', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '仅记录源端删除状态'),
|
||
(1901600000000000015, 3, '删除目标', 'DELETE', 'sync_delete_strategy', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '同步删除目标对象'),
|
||
(1901600000000000016, 1, '文件大小', 'SIZE', 'sync_verify_mode', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '按对象大小校验'),
|
||
(1901600000000000017, 2, 'ETag', 'ETAG', 'sync_verify_mode', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '按ETag校验'),
|
||
(1901600000000000018, 3, 'SHA-256', 'SHA256', 'sync_verify_mode', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '按SHA-256摘要校验'),
|
||
(1901600000000000019, 1, '手动触发', 'MANUAL', 'sync_trigger_type', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '用户手动触发任务'),
|
||
(1901600000000000020, 2, '调度触发', 'SCHEDULE', 'sync_trigger_type', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '计划调度触发任务'),
|
||
(1901600000000000021, 3, '重试触发', 'RETRY', 'sync_trigger_type', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '失败任务重试触发'),
|
||
(1901600000000000022, 1, '待执行', 'PENDING', 'sync_job_status', '', 'info', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '等待执行'),
|
||
(1901600000000000023, 2, '执行中', 'RUNNING', 'sync_job_status', '', 'primary', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '正在执行'),
|
||
(1901600000000000024, 3, '成功', 'SUCCESS', 'sync_job_status', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '全部成功'),
|
||
(1901600000000000025, 4, '部分失败', 'PARTIAL_FAILED', 'sync_job_status', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '部分对象失败'),
|
||
(1901600000000000026, 5, '失败', 'FAILED', 'sync_job_status', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '任务失败'),
|
||
(1901600000000000027, 6, '已取消', 'CANCELED', 'sync_job_status', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '任务已取消'),
|
||
(1901600000000000053, 7, '取消中', 'CANCELING', 'sync_job_status', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '正在终止本节点传输'),
|
||
(1901600000000000028, 1, '待执行', 'PENDING', 'sync_job_item_status', '', 'info', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '等待执行'),
|
||
(1901600000000000029, 2, '执行中', 'RUNNING', 'sync_job_item_status', '', 'primary', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '正在执行'),
|
||
(1901600000000000030, 3, '成功', 'SUCCESS', 'sync_job_item_status', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '对象同步成功'),
|
||
(1901600000000000031, 4, '已跳过', 'SKIPPED', 'sync_job_item_status', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '对象已跳过'),
|
||
(1901600000000000032, 5, '失败', 'FAILED', 'sync_job_item_status', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '对象同步失败'),
|
||
(1901600000000000033, 1, '文件', 'FILE', 'sync_object_type', '', 'primary', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '普通文件'),
|
||
(1901600000000000034, 2, '目录', 'FOLDER', 'sync_object_type', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '目录对象'),
|
||
(1901600000000000035, 3, '在线文档', 'ONLINE_DOCUMENT', 'sync_object_type', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '需导出的在线文档'),
|
||
(1901600000000000036, 1, '新增上传', 'CREATE', 'sync_action_type', '', 'success', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '首次上传目标对象'),
|
||
(1901600000000000037, 2, '更新上传', 'UPDATE', 'sync_action_type', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '更新或覆盖目标对象'),
|
||
(1901600000000000038, 3, '跳过', 'SKIP', 'sync_action_type', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '跳过目标操作'),
|
||
(1901600000000000051, 4, '删除', 'DELETE', 'sync_action_type', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '删除目标对象'),
|
||
(1901600000000000039, 1, '已发现', 'DISCOVERED', 'sync_object_status', '', 'info', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '扫描已发现'),
|
||
(1901600000000000040, 2, '待同步', 'PENDING', 'sync_object_status', '', 'warning', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '等待同步'),
|
||
(1901600000000000041, 3, '已同步', 'SYNCED', 'sync_object_status', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '最近同步成功'),
|
||
(1901600000000000042, 4, '已跳过', 'SKIPPED', 'sync_object_status', '', 'info', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '按策略跳过'),
|
||
(1901600000000000043, 5, '失败', 'FAILED', 'sync_object_status', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '最近同步失败'),
|
||
(1901600000000000044, 6, '源端已删除', 'DELETED', 'sync_object_status', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源端对象已删除'),
|
||
(1901600000000000045, 1, '待上传', 'PENDING', 'sync_transfer_part_status', '', 'info', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '分片等待上传'),
|
||
(1901600000000000046, 2, '上传中', 'UPLOADING', 'sync_transfer_part_status', '', 'primary', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '分片正在上传'),
|
||
(1901600000000000047, 3, '成功', 'SUCCESS', 'sync_transfer_part_status', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '分片上传成功'),
|
||
(1901600000000000048, 4, '失败', 'FAILED', 'sync_transfer_part_status', '', 'danger', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '分片上传失败'),
|
||
(1901600000000000049, 1, '分页游标', 'PAGE_CURSOR', 'sync_checkpoint_type', '', 'primary', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源端分页扫描游标'),
|
||
(1901600000000000050, 2, '增量水位', 'INCREMENTAL_WATERMARK', 'sync_checkpoint_type', '', 'success', 'N', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '源端增量同步水位'),
|
||
(1901600000000000052, 3, '运行水位', 'RUN_WATERMARK', 'sync_checkpoint_type', '', 'warning', 'Y', 1761000000000000103, 1761100000000000001, sysdate(), null, null, '当前版本任务运行水位');
|