将数据从 SQL Server 迁移至 MatrixOne

本篇文档将指导你如何将数据从 SQL Server 迁移至 MatrixOne。

SQLServer 作为一款成熟的商业数据库,在各个行业内均有着广泛地使用,并且其功能与性能都非常出众。作为一款关系型数据库,MatrixOne 同样支持多种从 SQLServer 而来的数据库迁移模式。

数据类型差异

MatrixOne 与 SQL Server 存在着诸多类型上的差异,这些差异有些可以通过其他类型来替换,有些则暂时无法支持,具体列表如下:

SQLServerMatrixOne
real使用 double 替换
money, smallmoney使用 decimal 替换
datetimeoffset使用 timestmap 与时区替换
nchar/nvarchar/ntext使用 char/varchar/text 替换
image使用 blob 替换
uniqueidentifier使用 uuid 替换
bit暂不支持
rowversion暂不支持
hierarchyid暂不支持
sql_variant暂不支持
xml暂不支持
geometry暂不支持
geography暂不支持

在线迁移

本章节将指导你使用第三方工具,将数据从 SQL Server 迁移至 MatrixOne。

  • 适用场景:数据量较小(建议小于 1GB),对迁移的速度不敏感的场景。

准备工作

  • 带图形界面的跳板机:可连接 SQL Server 源端,也可连接 MatrixOne 目标端。
  • 数据迁移工具:在跳板机上下载 DBeaver

第一步:迁移表结构和表数据

在这里以 TPCH 数据集为例,将 TPCH 数据集的 8 张表从 SQL Server 迁移至 MatrixOne。

  1. 打开 DBeaver,从 SQL Server 中选择待迁移的表,鼠标右键点击导出数据

    将数据从 SQL Server 迁移至 MatrixOne - 图1

  2. 转化目标 > 导出目标窗口选择数据库,点击下一步;在表映射窗口选择目标容器,目标容器选择 MatrixOne 的数据库 tpch

    将数据从 SQL Server 迁移至 MatrixOne - 图2

    将数据从 SQL Server 迁移至 MatrixOne - 图3

  3. 抽取设置数据加载设置窗口,设置选择抽取和插入的数量,为了触发 MatrixOne 的直接写 S3 策略,建议填写 5000:

    将数据从 SQL Server 迁移至 MatrixOne - 图4

    将数据从 SQL Server 迁移至 MatrixOne - 图5

  4. 完成设置后,DBeaver 开始对数据进行迁移,在完成后 DBeaver 将会提示迁移成功。

第二步:检查数据

完成迁移之后,可以采用如下方式检查数据:

  • 通过 select count(*) from <table_name> 来确认源库与目标库的数据量是否一致。

  • 通过相关的查询对比结果,你也可以参见完成 TPCH 测试查询示例,进行结果对比。

离线迁移

本章节将指导你通过离线文件导入到 MatrixOne。

  • 适用场景:数据量较大(大于 1GB),对迁移的速度较为敏感的场景。

准备工作

  • 带图形界面的跳板机:可连接 SQL Server 源端,也可连接 MatrixOne 目标端的。
  • 数据迁移工具:在跳板机上下载 DBeaver

第一步:迁移表结构

在这里以 TPCH 数据集为例,将 TPCH 数据集的 8 张表从 SQL Server 迁移至 MatrixOne。

  1. 打开 DBeaver,从 SQL Server 中选择待迁移的表,鼠标右键点击后选择生成 SQL > DDL > 复制,先将这段 SQL 复制到一个文本编辑器内,给文本编辑器命名为 sqlserver_ddl.sql,保存到跳板机本地。

    将数据从 SQL Server 迁移至 MatrixOne - 图6

  2. 连接到 MatrixOne,在 MatrixOne 中创建新的数据库和表:

    1. create database tpch;
    2. use tpch;
    3. source '/YOUR_PATH/sqlserver_ddl.sql'

第二步:迁移数据

在 MatrixOne 中,有两种数据迁移方式可供选择:INSERTLOAD DATA。当数据量大于 1GB 时,首先推荐使用 LOAD DATA,其次可以选择使用 INSERT

LOAD DATA

使用 LOAD DATA 先将 SQL Server 的数据表导出为 CSV 格式,并使用 MatrixOne 的并行 LOAD 功能将数据迁移至 MatrixOne:

  1. 打开 DBeaver,中选择待迁移的表,鼠标右键点击后选择导出数据,将 SQL Server 数据表导出为 CSV 格式文件:

    将数据从 SQL Server 迁移至 MatrixOne - 图7

  2. 转化目标 > 导出目标窗口选择 CSV,点击下一步

    将数据从 SQL Server 迁移至 MatrixOne - 图8

    将数据从 SQL Server 迁移至 MatrixOne - 图9

    将数据从 SQL Server 迁移至 MatrixOne - 图10

  3. 连接到 MatrixOne,将导出的 CSV 数据导入至 MatrixOne:

    1. mysql> load data infile '/{filepath}/lineitem.txt' INTO TABLE lineitem FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    2. mysql> load data infile '/{filepath}/nation.txt' INTO TABLE nation FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    3. mysql> load data infile '/{filepath}/part.txt' INTO TABLE part FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    4. mysql> load data infile '/{filepath}/customer.txt' INTO TABLE customer FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    5. mysql> load data infile '/{filepath}/orders.txt' INTO TABLE orders FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    6. mysql> load data infile '/{filepath}/supplier.txt' INTO TABLE supplier FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    7. mysql> load data infile '/{filepath}/region.txt' INTO TABLE region FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
    8. mysql> load data infile '/{filepath}/partsupp.txt' INTO TABLE partsupp FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';

更多关于 LOAD DATA 的操作示例,参见批量导入

INSERT

INSERT 语句需要使用 DBeaver 先将逻辑语句导出,再导入到 MatrixOne:

  1. 使用 DBeaver 导出数据:打开 DBeaver,从 SQL Server 中选择待迁移的表,鼠标右键点击后选择导出数据 > SQL,为了确保插入时触发 MatrixOne 的直接写 S3,建议批量插入参数每条语句的数据行数设置为 5000:

    将数据从 SQL Server 迁移至 MatrixOne - 图11

    将数据从 SQL Server 迁移至 MatrixOne - 图12

    将数据从 SQL Server 迁移至 MatrixOne - 图13

  2. 使用下面的命令替换 sqlserver_ddl.sql 文件内 MatrixOne 不支持的关键字:

    1. # Linux系统执行的命令如下:
    2. sed -i 's/,N/,/g' mssql_data.sql
    3. #MacOS 系统则使用的命令如下:
    4. sed -i '' 's/,N/,/g' mssql_data.sql
  3. 在 MatrixOne 端,执行该 SQL 文件:

    1. ues tpch;
    2. source '/YOUR_PATH/sqlserver_ddl.sql'

更多关于 INSERT 的操作示例,参见插入数据

第三步:检查数据

完成迁移之后,可以采用如下方式检查数据:

  • 通过 select count(*) from <table_name> 来确认源库与目标库的数据量是否一致。

  • 通过相关的查询对比结果,你也可以参见完成 TPCH 测试查询示例,进行结果对比。