需求背景

项目上线前，收集的同步表配置后业务反馈有部分表未同步，校对同步列表发现未同步表名称不在收集的列表中，收集未同步表名称、用户和模式。

操作步骤

收集未同步表信息

收集未同步表名称、用户和模式。需要将源端topicis用户下的topicis模式下的 ICIS_CREDITORPUBINFO 实时同步到目标端topicis用户下的topicis模式里。

表存量数据迁移

打开KDTS工具，将源端topicis用户下的topicis模式下的 ICIS_CREDITORPUBINFO表存量数据迁移至目标端topicis用户下的topicis模式下。

新增源端和目标端数据源步骤省略。

新建迁移任务

迁移任务中选择源端和目标端时需要特别注意，避免选错。

选择模式和迁移内容

模式和属主选择时要注意，比如业务通常都是在public模式下存储，但是该套环境时在模式topicis下。

迁移内容仅包含和表相关的类型，如：表结构、表数据、主键、索引、唯一性约束、外键、检查约束、注释。

选择迁移对象

要迁移的对象少的话直接从列表中选择即可，相反下载导入模板选择从文件导入。

设置迁移参数

自动转换对象名一定要取消对勾，因为源端和目标端属于同构KES V8，不需要进行对象名转换。

保持并开始迁移任务

迁移任务状态显示绿色的完成则说明迁移完成。

KFS同步配置文件中增加要同步的表

多个表直接需要用逗号分割。

su - kfs
vi flysync.ini
在property=replicator.filter.replicate.do= 最后增加,topicis.ICIS_CREDITORPUBINFO

配置DDL过滤配置文件

/home/kfs/replicator/filters-config/ddl_support_5114.json 来源于flysync.ini中property=replicator.filter.ddlSupport.definitionsFile的值。

su - kfs
cp /home/kfs/replicator/filters-config/ddl_support_5114.json /home/kfs/replicator/filters-config/ddl_support_5114.json_bak
vi /home/kfs/replicator/filters-config/ddl_support_5114.json

强烈建议弄nodepad++打开，因为可以将对象组进行折叠。分别在table和index模块中增加该表，大小写各一组，table组增加参数：

      "topicis.ICIS_CREDITORPUBINFO": {
      "CREATE": "Y",
      "ALTER": "Y",
      "DROP": "Y",
      "TRUNCATE": "Y"
    },
          "topicis.icis_creditorpubinfo": {
      "CREATE": "Y",
      "ALTER": "Y",
      "DROP": "Y",
      "TRUNCATE": "Y"
    }

index组增加参数：

    "topicis.ICIS_CREDITORPUBINFO": {
      "CREATE": "Y",
      "ALTER": "Y",
      "DROP": "Y"
    },
        "topicis.icis_creditorpubinfo": {
      "CREATE": "Y",
      "ALTER": "Y",
      "DROP": "Y"
    }

停止同步服务

replicator 命令是用来对同步服务的开关,系统注册和查看状态等

replicator stop

--参数说明
stop：运行时停止同步服务

更新KFS同步服务配置

fspm 全称为 flysync包管理器 ，用来安装和配置 Kingbase FlySync 的同步服务组件，主要功能包括

• 校验配置文件的正确性
• 部署同步服务组件
• 修改同步服务组件的参数
• 升级同步服务组件
• 删除同步服务
• 重置同步服务断点信息
• 收集同步表服务的诊断信息

fspm update

--参数说明：
update：使用flysync.ini配置文件信息更新已经安装的FlySync

启动同步服务

replicator 命令是用来对同步服务的开关,系统注册和查看状态等

replicator start

--参数说明
start：作为守护进程在后台启动

创新新数据校验任务

创新新数据校验任务

登录管控平台，创新新数据校验任务.

选择源端要校验的对象

选择源端要校验的对象，一定要选对数据库和模式名。

选择目标端要校对的对象

选择目标端要校对的对象，一定要选对数据库和模式名。

最后停止并删除原数据校验任务。

创新新数据校验调度

停止原来的调度

最后停止并删除原数据校验调度。

创新新数据修复任务

停止原来的数据修复任务

创建新数据修复任务，如下：

最后停止并删除原数据修复任务。

手动执行新数据校验调度

注意：每次手动执行数据校验调度时，目标端节点的同步服务会离线，等校验结束数据一致才会上线目标端节点的同步服务。

查看数据校验进度，如下：

如果目标端和源端有数据不一致，会自动进行修复，修复完成后操作列会显示已修复。