将数据从 SQL Server 迁移至 MatrixOne

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

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

数据类型差异

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

在线迁移

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

• 适用场景：数据量较小（建议小于 1GB），对迁移的速度不敏感的场景。

准备工作

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

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

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

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

   

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

   

   

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

   

   

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，保存到跳板机本地。

   

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

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

第二步：迁移数据

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

LOAD DATA

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

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

   

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

   

   

   

3. 连接到 MatrixOne，将导出的 CSV 数据导入至 MatrixOne：

   mysql> load data infile '/{filepath}/lineitem.txt' INTO TABLE lineitem FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/nation.txt' INTO TABLE nation FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/part.txt' INTO TABLE part FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/customer.txt' INTO TABLE customer FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/orders.txt' INTO TABLE orders FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/supplier.txt' INTO TABLE supplier FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   mysql> load data infile '/{filepath}/region.txt' INTO TABLE region FIELDS TERMINATED BY '|' lines TERMINATED BY '\n' parallel 'true';
   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：

   

   

   

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

   # Linux系统执行的命令如下：
   sed -i 's/,N/,/g' mssql_data.sql
   #MacOS 系统则使用的命令如下：
   sed -i '' 's/,N/,/g' mssql_data.sql

3. 在 MatrixOne 端，执行该 SQL 文件：

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

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

第三步：检查数据

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

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

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