信创迁移适配实战-MySQL到达梦数据库DM8的数据迁移

简介: 信创迁移适配实战-MySQL到达梦数据库DM8的数据迁移

背景


虽然最终会被部署到国产数据库环境,但是实际项目开发时大概率是一开始在 MySQL 上开发,直到最后部署时再做迁移适配。


之前是我们在项目真正开发之前进行的预研与测试。今天开始真实场景下的数据迁移,操作系统与数据库已经由专业的运维人员安装完毕,操作系统:统信UOS;数据库:达梦8


虽然可以在IDEA中建立与DM8服务端连接,并且提供了不少功能,但是不能直接修改字段类型。还是通过DM自带的管理工具比较方便。到达梦官方注册账号,下载 Windows 下的开发版,可仅安装客户端工具。

image.png

这次我们用到的主要是DM管理工具DM数据迁移工具


由于本系列文章仅用于记录当时项目的国产化迁移过程,不涉及太多的理论内容,基本都是一系列的操作过程,所以行文上就直接上操作了。如果您有任何疑问,欢迎留言评论。


从前车马很慢,书信很远,一生只够爱一个人。

如今生活太快,时间太少,不要绕圈子,给我来个痛快的。


数据迁移


包括配中心置数据库迁移与业务后台数据迁移。这里以 Nacos 官方的配置数据库迁移为例进行示例,迁移过程很顺利。


创建用户/模式


create user STANDARD_CONFIG identified by STANDARD_CONFIG123 limit failed_login_attemps 5, password_lock_time 5;


新建的 STANDARD_CONFIG 用户默认为 PUBLIC 角色,没有建表权限,先赋予建表权限,再迁移数据。

image.png


开始迁移


  • Nacos 官方的配置数据库迁移

image.png

  • Nacos 官方的配置数据库迁移成功

image.png


错误处理


字段长度错误


实际迁移业务数据库时可能遇到一些报错问题,我们逐一解决。迁移过程中的报错一般都是字段长度超限, MySQL 和达梦字段长度定义不同, MySQL 中长度是达梦的3倍,所以只要将达梦的字段长度改为 MySQL 的3倍即可,可通过以下语句修改。


ALTER TABLE SYSDBA.SYS_USER MODIFY NICK_NAME varchar(90) NOT NULL;


自增列赋值错误


当手动导入数据时,报错:仅当指定列列表,且 SET IDENTITY_INSERTON 时,才能对自增列赋值;这是由于我们的数据对自增列进行了赋值操作,需要先开启对自增列的更新才能进行插入操作,注意不能有反引号。

set IDENTITY_INSERT sys_user ON;
INSERT INTO sys_user (user_id, dept_id, unit_id, user_name, nick_name, user_type, email, phonenumber, sex, avatar, password, status, del_flag, login_ip, login_date, create_by, create_time, update_by, update_time, remark) VALUES (1, 101, NULL, 'admin', 'administrator', '00', '123@163.com', '15888888888', '1', '', '$2a$10$7JB720yubVSZvUI0rEqK/.VqGOZPH.ulu33dHOiBE8ByOhJIrdAu2', '0', '0', '127.0.0.1', '2021-11-22 11:15:51', 'admin', '2021-11-22 11:15:51', '', NULL, '管理员');
set IDENTITY_INSERT sys_user OFF;

另外,通过程序执行时,可能遇到同样的错误,我们使用 MyBatisPlus ,进行 save 操作时(采用默认的策略,即生成的雪花算法),因为默认的 SQL 语句包含了 ID 列的赋值导致报错,解决办法是将 ID 主键字段设置为非自增。


UPDATE不生效


UPDATE 语句要带 commit

UPDATE SYS_NOTICE SET notice_content = '<p>你懂的,for search.</p>';
commit;


JSON支持


DM 支持 JSON 数据的存储和查询,在 DM 库中 JSON 以字符串形式存储。

CREATE TABLE std_standard_option (
  name VARCHAR(50) NOT NULL COMMENT '名称',
  content VARCHAR CONSTRAINT JSON_CHECK CHECK(CONTENT IS JSON) COMMENT '内容'
)


达梦字符串截断


虽然 DM 支持 JSON 数据的存储和查询,但是我们的 JSON 长度过长,超出了 JSON 类型能够存储的最大长度,后来就干脆使用 TEXT 类型来存储 JSON 数据。

CREATE TABLE "SYSDBA"."STD_STANDARD_TITLE"
(
"name" VARCHAR(50) NOT NULL,
"content" TEXT NOT NULL);
COMMENT ON TABLE "SYSDBA"."STD_STANDARD_TITLE" IS '标准题录表';
COMMENT ON COLUMN "SYSDBA"."STD_STANDARD_TITLE"."content" IS '内容';
COMMENT ON COLUMN "SYSDBA"."STD_STANDARD_TITLE"."name" IS '名称';

达梦数据库中一行记录的所有字段的实际长度的和不能超过页大小的一半。在达梦数据库中,一行记录所有字段长度累加不能超过下表:

image.png


项目适配


信创迁移适配预研-SpringBoot连接达梦数据库DM8服务并在IDEA中连接,我们使用自己安装到虚拟机环境的数据库服务,并且通过添加外部依赖的方式加载依赖,这里我们要将数据库依赖打包至部署包中。


项目依赖


  • 安装依赖至本地仓库
mvn install:install-file -Dfile=D:\Java\IdeaProjects\dmtest\drivers\jdbc\DmJdbcDriver18.jar -DgroupId=com.dm -DartifactId=DmJdbcDriver18 -Dversion=1.8 -Dpackaging=jar
  • pom.xml
<dependency>
            <groupId>com.dm</groupId>
            <artifactId>DmJdbcDriver18</artifactId>
            <version>1.8</version>
        </dependency>
  • yml
driver-class-name: dm.jdbc.driver.DmDriver
            url: jdbc:dm://192.168.21.64:5236
            username: SYSDBA
            password: SYSDBA


函数报错


项目打包部署后,在实际国产化环境下进行测试,发现一些函数报错了。


  • MySQL 中使用的函数 find_in_set 迁移到DM8后报错。

###Error querying database. Cause: dm.jdbc.driver. DMException: 第1 行附近出现错误: 无法解析的成员访问表达式[find_in_set] ###The error may exist in class path resource [mapper/system/SysUserMapper.xml] ###The error may involve com.yfcx.system.mapper. SysUserMapper.selectUserList_COUNT ###The error occurred while executing a query ###SQL: SELECT count(0) FROM sys_user u LEFT JOIN sys_dept d ON u.dept_id = d.dept_id WHERE u.del_flag = '0' AND (u.dept_id = ? OR u.dept_id IN (SELECT t.dept_id FROM sys_dept t WHERE find_in_set(?, ancestors))) ###Cause: dm.jdbc.driver. DMException: 第1 行附近出现错误: 无法解析的成员访问表达式[find_in_set] ; 第1 行附近出现错误: 无法解析的成员访问表达式[find_in_set]; nested exception is dm.jdbc.driver. DMException: 第1 行附近出现错误: 无法解析的成员访问表达式[find_in_set]

解决:在达梦数据库中执行

CREATE OR REPLACE FUNCTION FIND_IN_SET
                (
                        piv_str1 varchar2,
                        piv_str2 varchar2,
                        p_sep    varchar2 := ',')
                RETURN NUMBER
                            IS
                l_idx     number:=0;                 -- 用于计算piv_str2中分隔符的位置
                str       varchar2(500);             -- 根据分隔符截取的子字符串
                piv_str   varchar2(500) := piv_str2; -- 将piv_str2赋值给piv_str
                res       number        :=0;         -- 返回结果
                loopIndex number        :=0;
        BEGIN
                -- 如果piv_str中没有分割符,直接判断piv_str1和piv_str是否相等,相等 res=1
                IF instr(piv_str, p_sep, 1) = 0 THEN
                        IF piv_str          = piv_str1 THEN
                                res        := 1;
                        END IF;
                ELSE
                        -- 循环按分隔符截取piv_str
                        LOOP
                                l_idx    := instr(piv_str, p_sep);
                                loopIndex:=loopIndex+1;
                                -- 当piv_str中还有分隔符时
                                IF l_idx > 0 THEN
                                        -- 截取第一个分隔符前的字段str
                                        str:= substr(piv_str, 1, l_idx-1);
                                        -- 判断 str 和piv_str1 是否相等,相等 res=1 并结束循环判断
                                        IF str      = piv_str1 THEN
                                                res:= loopIndex;
                                                EXIT;
                                        END IF;
                                        piv_str := substr(piv_str, l_idx+length(p_sep));
                                ELSE
                                        -- 当截取后的piv_str 中不存在分割符时,判断piv_str和piv_str1是否相等,相等 res=1
                                        IF piv_str  = piv_str1 THEN
                                                res:= loopIndex;
                                        END IF;
                                        -- 无论最后是否相等,都跳出循环
                                        EXIT;
                                END IF;
                        END LOOP;
                        -- 结束循环
                END IF;
                -- 返回res
                RETURN res;
        END FIND_IN_SET;
commit;
  • MySQL 中使用的函数 cast(field as char) 迁移到DM8后报错。
###Error querying database.  Cause: dm.jdbc.driver.DMException: 第10 行附近出现错误: 无法转换的数据类型
###The error may exist in class path resource [mapper/system/SysNoticeMapper.xml]
###The error may involve com.yfcx.system.mapper.SysNoticeMapper.selectNoticeList
###The error occurred while executing a query
###SQL: SELECT * FROM (  SELECT TMP_PAGE.*, ROWNUM PAGEHELPER_ROW_ID FROM (  select notice_id, notice_title, notice_type, cast(notice_content as char) as notice_content, status, create_by, create_time, update_by, update_time, remark from sys_notice WHERE  notice_type = ? order by create_time desc  ) TMP_PAGE) WHERE PAGEHELPER_ROW_ID <= ? AND PAGEHELPER_ROW_ID > ?

这个错误主要是由于富文本编辑器内容使用了 BLOB 类型存储,在 DM8 中类型转换失败。


解决:不过前端的富文本编辑器不支持图片上传,由于字段内容不包含图片等二进制内容,在达梦数据库中直接换成了 TEXTCLOB 类型就可以了。记得在代码中去掉 cast 转换函数。


关于字符串与二进制类型的各类转换,达梦的文档中有以下说明:CAST(value AS type)

image.png


相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
目录
相关文章
|
缓存 关系型数据库 BI
使用MYSQL Report分析数据库性能(下)
使用MYSQL Report分析数据库性能
674 158
|
12月前
|
关系型数据库 MySQL 数据库
阿里云数据库RDS费用价格:MySQL、SQL Server、PostgreSQL和MariaDB引擎收费标准
阿里云RDS数据库支持MySQL、SQL Server、PostgreSQL、MariaDB,多种引擎优惠上线!MySQL倚天版88元/年,SQL Server 2核4G仅299元/年,PostgreSQL 227元/年起。高可用、可弹性伸缩,安全稳定。详情见官网活动页。
1785 152
|
关系型数据库 MySQL 数据库
阿里云数据库RDS支持MySQL、SQL Server、PostgreSQL和MariaDB引擎
阿里云数据库RDS支持MySQL、SQL Server、PostgreSQL和MariaDB引擎,提供高性价比、稳定安全的云数据库服务,适用于多种行业与业务场景。
1222 156
|
缓存 监控 关系型数据库
使用MYSQL Report分析数据库性能(中)
使用MYSQL Report分析数据库性能
797 156
|
12月前
|
关系型数据库 MySQL 分布式数据库
阿里云PolarDB云原生数据库收费价格:MySQL和PostgreSQL详细介绍
阿里云PolarDB兼容MySQL、PostgreSQL及Oracle语法,支持集中式与分布式架构。标准版2核4G年费1116元起,企业版最高性能达4核16G,支持HTAP与多级高可用,广泛应用于金融、政务、互联网等领域,TCO成本降低50%。
|
12月前
|
关系型数据库 分布式数据库 数据库
阿里云数据库收费价格:MySQL、PostgreSQL、SQL Server和MariaDB引擎费用整理
阿里云数据库提供多种类型,包括关系型与NoSQL,主流如PolarDB、RDS MySQL/PostgreSQL、Redis等。价格低至21元/月起,支持按需付费与优惠套餐,适用于各类应用场景。
|
12月前
|
SQL 关系型数据库 MySQL
Mysql数据恢复—Mysql数据库delete删除后数据恢复案例
本地服务器,操作系统为windows server。服务器上部署mysql单实例,innodb引擎,独立表空间。未进行数据库备份,未开启binlog。 人为误操作使用Delete命令删除数据时未添加where子句,导致全表数据被删除。删除后未对该表进行任何操作。需要恢复误删除的数据。 在本案例中的mysql数据库未进行备份,也未开启binlog日志,无法直接还原数据库。
|
关系型数据库 MySQL 数据库
自建数据库如何迁移至RDS MySQL实例
数据库迁移是一项复杂且耗时的工程,需考虑数据安全、完整性及业务中断影响。使用阿里云数据传输服务DTS,可快速、平滑完成迁移任务,将应用停机时间降至分钟级。您还可通过全量备份自建数据库并恢复至RDS MySQL实例,实现间接迁移上云。
|
缓存 监控 关系型数据库
使用MYSQL Report分析数据库性能(上)
最终建议:当前系统是完美的读密集型负载模型,优化重点应放在减少行读取量和提高数据定位效率。通过索引优化、分区策略和内存缓存,预期可降低30%的CPU负载,同时保持100%的缓冲池命中率。建议每百万次查询后刷新统计信息以持续优化
837 161
|
存储 运维 关系型数据库
从MySQL到云数据库,数据库迁移真的有必要吗?
本文探讨了企业在业务增长背景下,是否应从 MySQL 迁移至云数据库的决策问题。分析了 MySQL 的优势与瓶颈,对比了云数据库在存储计算分离、自动化运维、多负载支持等方面的优势,并提出判断迁移必要性的五个关键问题及实施路径,帮助企业理性决策并落地迁移方案。