注册
达梦DRS部署主备到单机同步
专栏/技术分享/ 文章详情 /

达梦DRS部署主备到单机同步

Ma- 2025/08/22 92 0 0
摘要

一、产品概览

DMDRS是同构/异构数据库数据迁移复制的模块化软件,支持数据迁移、同步、分发、转换四大核心功能,适配多种同步拓扑(一对一、双向、级联、环形、主备等)。
image.png

二、核心架构模块

  1. MANAGER(服务管理)
    • 提供客户端监听、模块加载维护及控制台命令执行。
  2. CPT(数据捕获与投递)
    • 负责源端全量/增量数据抓取、解析及投递。
  3. DSS(数据分流存储)
    • 按Topic分流存储数据,供下游使用。
  4. EXEC(数据应用)
    • 在目标端应用数据,确保一致性。
  5. CVT(数据转换)
    • 通过DRS语言自定义清洗转换规则(支持单操作级处理)。
  6. SCHED(定时调度)
    • 自动化执行CVT脚本、数据校验、同步任务等。
  7. Console工具
    • 基于TCP/IP的远程控制端。

三、核心功能

  1. 数据迁移
    • 静态环境一次性迁移,支持同构/异构库,具备断点续传能力。
  2. 数据同步
    • 全量装载:源库全量数据初始化至目标库。
    • 增量同步:实时同步增量数据,确保动态一致性。
  3. 数据分发
    • 全量/增量数据经流存储后分发给多目标库(一源多目标场景)。
  4. 数据转换
    • 自定义清洗转换规则,适配迁移/同步/分发场景。

四、兼容性支持

  • 硬件平台:龙芯、飞腾、鲲鹏、海光、X86、ARM等。
  • 操作系统:麒麟、UOS、Windows、Red Hat、Ubuntu等。
  • 数据库支持
    • 源端:DM7/8、Oracle 10g+、DB2、MySQL、SQL Server。
    • 目标端:DM7/8、Oracle 10g+、MySQL、PostgreSQL、Kafka、SQL Server。
  • 数据类型:主流数据库类型全覆盖(详见产品手册)。

五、主备–>单机DRS实施

本次部署基于主备–>dm8进行数据增量同步。

1. 环境准备

IP Fils 软件目录 归档目录 备注
192.168.123.10 dbtest1 /home/dmdba/dmdbms /dmdata/arch 主节点 PRIMARY(主备源端)
192.168.123.11 dbtest2 /home/dmdba/dmdbms /dmdata/arch 备节点 standby (主备源端)
192.168.123.12 dbtest3 /home/dmdba/dmdbms /dmdata/arch 监控节点(单机目标端)

2.DRS安装

2.1 开启归档和逻辑附加日志

##归档 主备及目标端均已开启归档 路径为/dmdata/arch ##开启逻辑附加日志 call sp_set_para_value(1,'RLOG_APPEND_LOGIC',1);

2.2 创建用户及测试表

##源端目标端均执行创建用户 CREATE USER DMDRS IDENTIFIED by "Dmdrs123"; grant "RESOURCE","PUBLIC","VTI","SOI","SVI" to "DMDRS"; grant CREATE SESSION to "DMDRS"; ##源端创建测试表 connect dmdrs/Dmdrs123 CREATE table TEST(id int,name varchar2(20)); insert into TEST values(1,'PP'); commit ;

2.3 DRS安装部署

[dmdba@dbtest1 ~]$ ./dmdrs_rev195292_x86_rh6_64_20250801.bin -i Extract install files.......... Please select the installer's language (E/e:English C/c:Chinese)[E/e]:c -----------欢迎使用达梦数据复制软件安装工具----------- 输入[exit]可退出安装。 -----------安装目录----------- 指定安装目录[/home/dmdba/dmdrs5]:^[[D 填写的安装目录无写入权限,请重新输入! 指定安装目录[/home/dmdba/dmdrs5]: -----------安装组件----------- 请选择需要安装的组件 1.安装达梦数据融合管理平台 2.安装代理 请选择安装组件数字序号(使用空格间隔):1 2 选择的组件有: 1.安装达梦数据融合管理平台 2.安装代理 确认?[Y/y(确认选择) or N/n(重新选择)]:y -----------许可证文件----------- 1.免费试用达梦数据复制软件(必须在试用期范围内使用,反复安装无效,使用时 间为3个月) 2.使用许可证文件 指定许可证文件(1,2)[1]:1 免费试用许可证文件限制信息如下: 有效日期:2025-10-16 版本类型:试用版 许可证编号:dm66n367 授权顾客名称:DEVELOP USER 当前选择为免费试用,是否继续安装?[Y/y or N/n]:y -----------配置----------- 数据库驱动路径配置 -数据库驱动路径[/home/dmdba/dmdbms/bin]: 注意:代理配置IP不允许设置成127.0.0.1! 代理配置-代理IP(192.168.1.10,192.168.123.10): 请手动输入代理ip! 注意:代理配置IP不允许设置成127.0.0.1! 代理配置-代理IP(192.168.1.10,192.168.123.10): 请手动输入代理ip! 注意:代理配置IP不允许设置成127.0.0.1! 代理配置-代理IP(192.168.1.10,192.168.123.10):192.168.123.10 代理配置-代理端口[19345]: 达梦数据融合管理平台配置-管理平台端口[8080]: 注意:密码必须至少8个字符,并且满足以下条件中的任意[两项]:数字、大写字 母、小写字母、特殊字符(如!@#$%^&*等)。 达梦数据融合管理平台配置-管理平台密码: 达梦数据融合管理平台配置-管理平台确认密码: 是否使用外置库(0:不使用 1:使用 )[0]: 注意:请输入9至48个字符长度的密码,并且满足以下条件中的任意[三项]:数字 、大写字母、小写字母、特殊字符(如!@#$%^&*等)。 内置数据库配置-密码: 内置数据库配置-确认密码: -----------安装小结----------- 安装目录:[/home/dmdba/dmdrs5] 数据库驱动路径:[/home/dmdba/dmdbms/bin] 代理IP:[192.168.123.10] 代理端口:[19345] 达梦数据融合管理平台IP:[127.0.0.1] 达梦数据融合管理平台端口:[8080] 内置库信息: 数据库IP:[127.0.0.1] 数据库端口:[15236] 用户名:[SYSDBA] 密码:[******] 所需磁盘空间/可用磁盘空间:[2,884 MB/77,222 MB] 确认安装?[Y/y or N/n]:y -----------安装中----------- server start ... server finished. default start ... default finished. agent start ... agent finished. web start ... web finished. doc start ... doc finished. db start ... db finished. 安装成功 -----------系统服务----------- 内置数据库服务设置 1.注册系统服务 2.不注册系统服务 启动方式(1,2)[2]: 正在创建内置数据库服务.... 达梦数据融合管理平台服务设置 1.注册系统服务 2.不注册系统服务 启动方式(1,2)[2]: 正在创建达梦数据融合管理平台服务.... 达梦数据融合管理平台代理服务设置 1.注册系统服务 2.不注册系统服务 启动方式(1,2)[2]: 正在创建达梦数据融合管理平台代理服务.... 正在启动服务[DmServiceDFDB] 正在启动服务[DfmWebService] 正在启动服务[DfmAgentService] -----------安装总结----------- 达梦数据复制软件V5安装完成 地址:http://127.0.0.1:8080 用户名/密码:admin/****** 更多安装信息,请查看安装日志文件:/home/dmdba/dmdrs5/log/install.log

2.4 源端目标端部署辅助表

脚本默认位置在DMDRS执行程序目录下的scripts子目录中 set define off; start ddl_sql_dm8.sql 检查触发器和辅助表是否有效 SQL> select owner, trigger_name from dba_triggers where owner = 'SYSDBA' and trigger_name like 'DRS_$%' and status = 'Y'; select owner, table_name from dba_tables where owner = 'SYSDBA' and table_name like 'DRS_$%' and status = 'VALID'; 行号 OWNER TRIGGER_NAME ---------- ------ ----------------------- 1 SYSDBA DRS_$DDL_TRIGGER_AFTER 2 SYSDBA DRS_$DDL_TRIGGER_BEFORE 3 SYSDBA DRS_$DDL_TRIGGER_GRANT 4 SYSDBA DRS_$DDL_TRIGGER_REVOKE 已用时间: 198.625(毫秒). 执行号:67316. SQL> 行号 OWNER TABLE_NAME ---------- ------ ----------------- 1 SYSDBA DRS_$DDL_COL 2 SYSDBA DRS_$DDL_SQL 3 SYSDBA DRS_$DDL_CONS 4 SYSDBA DRS_$DDL_IDX 5 SYSDBA DRS_$DDL_RENAME 6 SYSDBA DRS_$DDL_SEQ 7 SYSDBA DRS_$DDL_PART 8 SYSDBA DRS_$DDL_COMMMENT 9 SYSDBA DRS_$DDL_LOG 9 rows got 已用时间: 180.636(毫秒). 执行号:67317

2.5 源端目标端环境变量配置

##添加DRS及DPI export LD_LIBRARY_PATH="$LD_LIBRARY_PATH:/home/dmdba/dmdbms/bin:/home/dmdba/dmdbms/drivers/dpi:/home/dmdba/dmdrs5/bin" export DM_HOME="/home/dmdba/dmdbms" PATH=$PATH:$HOME/.local/bin:$HOME/bin:$DM_HOME/bin:/home/dmdba/dmdbms/drivers/dpi:/home/dmdba/dmdrs5/bin

2.6 源端目标端配置启动脚本

##源端配置启动脚本 #set execute environment #REPLACE INSTALL_HOME path INSTALL_HOME=/home/dmdba/dmdrs5 #REPLACE program dir PROG_DIR=/home/dmdba/dmdrs5/bin #REPLACE program config path #If drs server is BP node and wants to startup without drs.xml,please specify the running port in CONF_PATH,for example,CONF_PATH="-port 5345" CONF_PATH=/home/dmdba/dmdrs5/bin/cpt.xml #REPLACE need library path, LD_LIBRARY_PATH/LIBPATH NEED_LIB_PATH=/home/dmdba/dmdbms/bin #REPLACE program name, drsvr/dssvr/dvsvr EXEC_PROG_NAME=drsvr #REPLACE service type, drs server/dss server/dvs server SERVICE_TYPE_NAME="drs server" ##目标端配置启动脚本 #set execute environment #REPLACE INSTALL_HOME path INSTALL_HOME=/home/dmdba/dmdrs5 #REPLACE program dir PROG_DIR=/home/dmdba/dmdrs5/bin #REPLACE program config path #If drs server is BP node and wants to startup without drs.xml,please specify the running port in CONF_PATH,for example,CONF_PATH="-port 5345" CONF_PATH=/home/dmdba/dmdrs5/bin/exec.xml #REPLACE need library path, LD_LIBRARY_PATH/LIBPATH NEED_LIB_PATH=/home/dmdba/dmdbms/bin #REPLACE program name, drsvr/dssvr/dvsvr EXEC_PROG_NAME=drsvr #REPLACE service type, drs server/dss server/dvs server SERVICE_TYPE_NAME="drs server"

2.7 cpt模块和exec模块配置

###主 <?xml version="1.0" encoding="GB18030"?> <drs> <base> <mgr_port>5345</mgr_port> <siteid>1</siteid> <lang>ch-utf8</lang> </base> <cpt> <name>cpt_dm8</name> <char_code>UTF-8</char_code> <ddl_mask>obj:op:ddl_rec</ddl_mask> <login> <dbtype>dm8</dbtype> <server>dm</server> <user>SYSDB</user> <pwd>!QAZ2wsx</pwd> <port>5236</port> </login> <send> <ip>192.168.123.12</ip> <port>5345</port> <target_name>exec_dm8</target_name> <map> <item>DMDRS.TEST==DMDRS.TEST</item> </map> </send> <cluster> <mode>master</mode> <standby> <ip>192.168.123.11</ip> <port>5345</port> <target_name>tpt_dm8</target_name> </standby> <local>192.168.123.10</local> </cluster> </cpt> </drs> ###备 <?xml version="1.0" encoding="GB18030"?> <drs> <base> <mgr_port>5345</mgr_port> <siteid>1</siteid> <lang>ch-utf8</lang> </base> <cpt> <name>cpt_dm8</name> <char_code>UTF-8</char_code> <ddl_mask>obj:op:ddl_rec</ddl_mask> <login> <dbtype>dm8</dbtype> <server>dm</server> <user>SYSDB</user> <pwd>!QAZ2wsx</pwd> <port>5236</port> </login> <send> <ip>192.168.123.12</ip> <port>5345</port> <target_name>exec_dm8</target_name> <map> <item>DMDRS.TEST==DMDRS.TEST</item> </map> </send> <cluster> <mode>slave</mode> <local>192.168.123.11</local> </cluster> </cpt> </drs> ###目标库 <?xml version="1.0" encoding="GB18030"?> <drs> <base> <mgr_port>5345</mgr_port> <siteid>2</siteid> <lang>ch-utf8</lang> </base> <exec> <name>exec_dm8</name> <char_code>UTF-8</char_code> <login> <dbtype>dm8</dbtype> <server>192.168.123.12</server> <user>SYSDB</user> <pwd>!QAZ2wsx</pwd> <port>5236</port> </login> <group> <item> <id>35</id> <exec_policy>0</exec_policy> <desc> <table>DMDRS.TEST</table> </desc> </item> </group> </exec> </drs>

2.8 启动服务

[dmdba@dbtest1 bin]$ DrsService_Slave start Starting DrsService_Slave: [ OK ] [dmdba@dmtest2 bin]$ DrsService_Slave start Starting DrsService_Slave: [ OK ] [dmdba@dbtest3 bin]$ DrsService_Slave start Starting DrsService_Slave: [ OK ]

2.8 添加同步表

[dmdba@dbtest1 bin]$ drcsl cpt.xml CSL[INFO]: CONSOLE TOOL DRS5: V5.2.4.1-Build(2025.07.30-195292_trunc_sp2)_64 CSL> connect CSL[INFO]: [INPUT CMD: connect] CSL> alter cpt_dm8 set lsn CSL[INFO]: [INPUT CMD: alter cpt_dm8 set lsn] MGR[INFO]: 成功获取模块的起始SCN cpt name: cpt_dm8, LSN: 106815 命令执行成功 CSL> alter cpt_dm8 add table "sch.name='DMDRS' and tab.name='TEST'" DROP|CREATE| INSERT|GROUP|100000|INDEX|FAST; CSL[INFO]: [INPUT CMD: alter cpt_dm8 add table "sch.name='DMDRS' and tab.name='T EST'" DROP|CREATE|INSERT|GROUP|100000|INDEX|FAST;] MGR[INFO]: 获取到装载掩码组合 mask: |CREATE|DROP|INSERT|INDEX|TABLE|FAST|GROUP MGR[WARN]: 使用掩码FAST当目的端为DM8或EXCHANGE、DELAY、WHEREPARTITION装载功能 的表故障时无法续传!请确认是否继续?(Y/N) y MGR[WARN]: 检测到TRUNCATE/DROP/CLEAR掩码,会对执行端目标表进行相应操作,再进行装 载!请确认是否继续?(Y/N) y 命令执行成功 CSL> CSL> CSL> start cpt_dm8 CSL[INFO]: [INPUT CMD: start cpt_dm8] MGR[INFO]: 模块正在启动 module: cpt_dm8 MGR[INFO]: CPT准备就绪 type: dm8 cpt MGR[INFO]: 模块已经处于运行状态 module: cpt_dm8 命令执行成功 CSL> quit; CSL[INFO]: [INPUT CMD: quit;] 命令执行成功

2.9 数据同步测试

###主库添加数据 [dmdba@dbtest1 bin]$ dm 服务器[localhost:5236]:处于主库打开状态 登录使用时间 : 9.689(ms) disql V8 SQL> connect dmdrs/Dmdrs123 服务器[LOCALHOST:5236]:处于主库打开状态 登录使用时间 : 5.755(ms) SQL> SQL> select * from test; 行号 ID NAME ---------- ----------- ---- 1 1 PP 已用时间: 3.746(毫秒). 执行号:7401. SQL> insert into test values(2,'tt'); 影响行数 1 已用时间: 24.125(毫秒). 执行号:7402. SQL> commit; 操作已执行 已用时间: 6.376(毫秒). 执行号:7403. SQL> ###备库查看数据是否同步 [dmdba@dbtest3 bin]$ dm 服务器[localhost:5236]:处于普通打开状态 登录使用时间 : 5.038(ms) disql V8 SQL> select * from dmdrs.test; 行号 ID NAME ---------- ----------- ---- 1 1 PP 已用时间: 2.411(毫秒). 执行号:15401. SQL> select * from dmdrs.test; 行号 ID NAME ---------- ----------- ---- 1 1 PP 已用时间: 0.508(毫秒). 执行号:15402. SQL> select * from dmdrs.test; 行号 ID NAME ---------- ----------- ---- 1 1 PP 2 2 tt 已用时间: 0.419(毫秒). 执行号:15403.

2.10 主备switchover 同步测试

###主备切换操作
login
用户名:sysdba
密码:
[monitor]         2025-08-18 21:56:42: 登录监视器成功!

switchover
此操作需谨慎, 将会导致主库发生切换, 是否继续使用GRP1.DMTEST执行SWITCHOVER操作(YES/NO/Y/N)?
y
[monitor]         2025-08-18 21:58:21: 开始切换实例DMTEST
[monitor]         2025-08-18 21:58:21: 通知守护进程DMSERVER切换SWITCHOVER状态
[monitor]         2025-08-18 21:58:21: 守护进程(DMSERVER)状态切换 [OPEN-->SWITCHOVER]
[monitor]         2025-08-18 21:58:21: 切换守护进程DMSERVER为SWITCHOVER状态成功
[monitor]         2025-08-18 21:58:21: 通知守护进程DMTEST切换SWITCHOVER状态
[monitor]         2025-08-18 21:58:21: 守护进程(DMTEST)状态切换 [OPEN-->SWITCHOVER]
[monitor]         2025-08-18 21:58:21: 切换守护进程DMTEST为SWITCHOVER状态成功
[monitor]         2025-08-18 21:58:21: 实例DMSERVER开始执行SP_SET_GLOBAL_DW_STATUS(0, 6)语句
[monitor]         2025-08-18 21:58:21: 实例DMSERVER执行SP_SET_GLOBAL_DW_STATUS(0, 6)语句成功
[monitor]         2025-08-18 21:58:21: 实例DMTEST开始执行SP_SET_GLOBAL_DW_STATUS(0, 6)语句
[monitor]         2025-08-18 21:58:21: 实例DMTEST执行SP_SET_GLOBAL_DW_STATUS(0, 6)语句成功
[monitor]         2025-08-18 21:58:21: 实例DMSERVER开始执行ALTER DATABASE MOUNT语句
[monitor]         2025-08-18 21:58:21: 实例DMSERVER执行ALTER DATABASE MOUNT语句成功
[monitor]         2025-08-18 21:58:21: 实例DMTEST开始执行SP_APPLY_KEEP_PKG()语句
[monitor]         2025-08-18 21:58:21: 实例DMTEST执行SP_APPLY_KEEP_PKG()语句成功
[monitor]         2025-08-18 21:58:21: 实例DMTEST开始执行ALTER DATABASE MOUNT语句
[monitor]         2025-08-18 21:58:22: 实例DMTEST执行ALTER DATABASE MOUNT语句成功
[monitor]         2025-08-18 21:58:22: 实例DMSERVER开始执行ALTER DATABASE STANDBY语句
[monitor]         2025-08-18 21:58:22: 实例DMSERVER执行ALTER DATABASE STANDBY语句成功
[monitor]         2025-08-18 21:58:22: 实例DMTEST开始执行ALTER DATABASE PRIMARY语句
[monitor]         2025-08-18 21:58:22: 实例DMTEST执行ALTER DATABASE PRIMARY语句成功
[monitor]         2025-08-18 21:58:22: 通知实例DMTEST修改所有归档状态无效
[monitor]         2025-08-18 21:58:22: 修改所有实例归档为无效状态成功
[monitor]         2025-08-18 21:58:22: 实例DMSERVER开始执行ALTER DATABASE OPEN FORCE语句
[monitor]         2025-08-18 21:58:22: 实例DMSERVER执行ALTER DATABASE OPEN FORCE语句成功
[monitor]         2025-08-18 21:58:22: 实例DMTEST开始执行ALTER DATABASE OPEN FORCE语句
[monitor]         2025-08-18 21:58:22: 实例DMTEST执行ALTER DATABASE OPEN FORCE语句成功
[monitor]         2025-08-18 21:58:22: 实例DMSERVER开始执行SP_SET_GLOBAL_DW_STATUS(6, 0)语句
[monitor]         2025-08-18 21:58:22: 实例DMSERVER执行SP_SET_GLOBAL_DW_STATUS(6, 0)语句成功
[monitor]         2025-08-18 21:58:22: 实例DMTEST开始执行SP_SET_GLOBAL_DW_STATUS(6, 0)语句
[monitor]         2025-08-18 21:58:22: 实例DMTEST执行SP_SET_GLOBAL_DW_STATUS(6, 0)语句成功
[monitor]         2025-08-18 21:58:22: 通知守护进程DMSERVER切换OPEN状态
[monitor]         2025-08-18 21:58:22: 守护进程(DMSERVER)状态切换 [SWITCHOVER-->OPEN]
[monitor]         2025-08-18 21:58:22: 切换守护进程DMSERVER为OPEN状态成功
[monitor]         2025-08-18 21:58:22: 通知守护进程DMTEST切换OPEN状态
[monitor]         2025-08-18 21:58:22: 守护进程(DMTEST)状态切换 [SWITCHOVER-->OPEN]
[monitor]         2025-08-18 21:58:22: 切换守护进程DMTEST为OPEN状态成功
[monitor]         2025-08-18 21:58:22: 通知组(GRP1)的守护进程执行清理操作
[monitor]         2025-08-18 21:58:22: 清理守护进程(DMSERVER)请求成功
[monitor]         2025-08-18 21:58:22: 清理守护进程(DMTEST)请求成功
[monitor]         2025-08-18 21:58:22: 实例DMTEST切换成功

2025-08-18 21:58:22
#================================================================================#
GROUP            OGUID       MON_CONFIRM     MODE            MPP_FLAG
GRP1             453331      FALSE           AUTO            FALSE


<<DATABASE GLOBAL INFO:>>
DW_IP         MAL_DW_PORT  WTIME                WTYPE     WCTLSTAT  WSTATUS        INAME            INST_OK   N_EP  N_OK  ISTATUS     IMODE     DSC_STATUS     RTYPE     RSTAT       DETACHED
192.168.1.11  52142        2025-08-18 21:58:22  GLOBAL    VALID     OPEN           DMTEST           OK        1     1     OPEN        PRIMARY   DSC_OPEN       REALTIME  VALID       FALSE

EP INFO:
INST_IP         INST_PORT  INST_OK   INAME            ISTATUS     IMODE     DSC_SEQNO  DSC_CTL_NODE RTYPE     RSTAT       FSEQ            FLSN            CSEQ            CLSN            DW_STAT_FLAG
192.168.123.11  5237       OK        DMTEST           OPEN        PRIMARY   0          0            REALTIME  VALID       6810            107215          6810            107216          NONE

<<DATABASE GLOBAL INFO:>>
DW_IP         MAL_DW_PORT  WTIME                WTYPE     WCTLSTAT  WSTATUS        INAME            INST_OK   N_EP  N_OK  ISTATUS     IMODE     DSC_STATUS     RTYPE     RSTAT       DETACHED
192.168.1.10  52141        2025-08-18 21:58:22  GLOBAL    VALID     OPEN           DMSERVER         OK        1     1     OPEN        STANDBY   DSC_OPEN       REALTIME  INVALID     FALSE

EP INFO:
INST_IP         INST_PORT  INST_OK   INAME            ISTATUS     IMODE     DSC_SEQNO  DSC_CTL_NODE RTYPE     RSTAT       FSEQ            FLSN            CSEQ            CLSN            DW_STAT_FLAG
192.168.123.10  5236       OK        DMSERVER         OPEN        STANDBY   0          0            REALTIME  INVALID     6808            107122          6808            107122          NONE

DATABASE(DMSERVER) APPLY INFO FROM (DMTEST), REDOS_PARALLEL_NUM (1), WAIT_APPLY[FALSE]:
DSC_SEQNO[0], (RSEQ, SSEQ, KSEQ)[6808, 6808, 6808], (RLSN, SLSN, KLSN)[107122, 107122, 107122], N_TSK[0], TSK_MEM_USE[0]


#================================================================================#


####备库转换为主库
[dmdba@dmtest2 bin]$ disql dmdrs/Dmdrs123:5237

服务器[LOCALHOST:5237]:处于备库打开状态
登录使用时间 : 3.495(ms)
disql V8
SQL> quit;
[dmdba@dmtest2 bin]$ disql dmdrs/Dmdrs123:5237

服务器[LOCALHOST:5237]:处于主库打开状态
登录使用时间 : 3.868(ms)
disql V8
SQL> insert into test values(3,'ww');
影响行数 1

已用时间: 10.152(毫秒). 执行号:1001.
SQL> commit;
操作已执行
已用时间: 3.710(毫秒). 执行号:1002.
SQL>



####查看数据同步情况
[dmdba@dbtest3 bin]$ dm

服务器[localhost:5236]:处于普通打开状态
登录使用时间 : 4.532(ms)
disql V8
SQL>  select *  from dmdrs.test;

行号     ID          NAME
---------- ----------- ----
1          1           PP
2          2           tt

已用时间: 3.374(毫秒). 执行号:16501.
SQL> select *  from dmdrs.test;

行号     ID          NAME
---------- ----------- ----
1          1           PP
2          2           tt
3          3           ww

已用时间: 0.414(毫秒). 执行号:16502.

2.11 相关命令演示

查看DRS版本

CSL> SHOW VERSION CSL[INFO]: [INPUT CMD: SHOW VERSION] +------------------------------------------------+ | 【版本信息】 | +------------------------------------------------+ | V5.2.4.1-Build(2025.07.30-195292_trunc_sp2)_64 | +------------------------------------------------+ 命令执行成功

查看DRS授权

CSL> SHOW LIC CSL[INFO]: [INPUT CMD: SHOW LIC] +-------------------------------------------------------------------------------------------------------------------------+ | 【许可证信息】 | +-------------------------------------------------------------------------------------------------------------------------+ | 有效日期 | 授权顾客名称 | 项目名称 | 许可证编号 | 版本类型 | 授权数据库类型 | +------------+--------------+----------+------------+----------+----------------------------------------------------------+ | 2025-10-30 | DEVELOP USER | | dm66n367 | 试用版 | DM6,DM7,DM8,Oracle,SQL Server,MySQL,DB2,PostgreSQL,Kafka | +------------+--------------+----------+------------+----------+----------------------------------------------------------+ 命令执行成功

动态添加同步表

ALTER [<CPT_NAME>] ADD|DELETE TABLE "<FILTER>"|ALL [<LOAD_MASK>]

断点续传

ALTER [<CPT_NAME>] CONTINUE LOAD

查看装载状态

CSL> show cpt_dm8 load status
CSL[INFO]: [INPUT CMD: show cpt_dm8 load status]
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
|                                                                                                          【装载状态】                                                                                                          |
+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+
| 序号 | 需装载对象 | 装载字典 | 已装载对象 | 未装载对象 | 正装载对象 | 装载错误对象 |       开始时间      |       结束时间      |               装载条件               |                   装载掩码                  | 对象类型 |
+------+------------+----------+------------+------------+------------+--------------+---------------------+---------------------+--------------------------------------+---------------------------------------------+----------+
|    1 |          1 |        1 |          1 |          0 |          0 |            0 | 2025-08-18 21:49:59 | 2025-08-18 21:50:15 | sch.name='DMDRS' and tab.name='TEST' | DROP|CREATE|INSERT|GROUP|100000|INDEX|FAST; | TABLE    |
+------+------------+----------+------------+------------+------------+--------------+---------------------+---------------------+--------------------------------------+---------------------------------------------+----------+
命令执行成功

查看正在装载的表信息

CSL> ld
CSL[INFO]: [INPUT CMD: ld]
+------------------------------------------------------------------------------------+
|                                   【全部装载表】                                   |
+------------------------------------------------------------------------------------+
| 序号 | 模式名 | 表名 | 已装载行数 |   状态   |       开始时间      | 耗时 | 分组数 |
+------+--------+------+------------+----------+---------------------+------+--------+
|    1 | DMDRS  | TEST |          1 | COMPLETE | 2025-08-18 21:50:14 |  0 s |      1 |
+------+--------+------+------------+----------+---------------------+------+--------+
命令执行成功

SHOW [<CPT_NAME>] LOAD TABLE RUNNING

查看装载失败的表信息

SHOW [<CPT_NAME] LOAD TABLE ERROR

清理装载记录

ALTER [<CPT_NAME>] DELETE LOAD_RECORD

查看线程信息

SHOW [<EXEC_NAME>] THR [LOAD] [<THRID>] [TRX|CURTRX]

查看分组信息

SHOW [<EXEC_NAME>] [<SITE_ID>] GROUP [<GROUPID>]

rowid_map方式查看rowid是否成功映射方法

执行端执行show cache table
 
看有没有ROWID_源端站点号_0000000源端表名字典
然后执行show get 这个表名 就会打印出来。
评论
后发表回复

作者

文章

阅读量

获赞

扫一扫
联系客服