插入 csv 文件

本篇文档将指导你在 MySQL 客户端启动 MatrixOne 时如何完成 csv 格式数据导入。

语法结构

  • 场景一：数据文件与 MatrixOne 服务器在同一台机器上：
1. LOAD DATA
2. INFILE 'file_name'
3. INTO TABLE tbl_name
4. [{FIELDS | COLUMNS}
5. [TERMINATED BY 'string']
6. [[OPTIONALLY] ENCLOSED BY 'char']
7. ]
8. [LINES
9. [STARTING BY 'string']
10. [TERMINATED BY 'string']
11. ]
12. [IGNORE number {LINES | ROWS}]
13. [PARALLEL {'TRUE' | 'FALSE'}]
  • 场景二：数据文件与 MatrixOne 服务器在不同的机器上：
1. LOAD DATA LOCAL
2. INFILE 'file_name'
3. INTO TABLE tbl_name
4. [{FIELDS | COLUMNS}
5. [TERMINATED BY 'string']
6. [[OPTIONALLY] ENCLOSED BY 'char']
7. ]
8. [LINES
9. [STARTING BY 'string']
10. [TERMINATED BY 'string']
11. ]
12. [IGNORE number {LINES | ROWS}]
13. [PARALLEL {'TRUE' | 'FALSE'}]

开始前准备

已完成单机部署 MatrixOne。

MySQL Client 中使用 Load data 命令导入数据

你可以使用 Load Data 从大数据文件中导入数据，本章将介绍如何导入 csv 格式文件。

Note: csv（逗号分隔值）文件是一种特殊的文件类型，可在 Excel 中创建或编辑，csv 文件不是采用多列的形式存储信息，而是使用逗号分隔的形式存储信息。

步骤

数据文件与 MatrixOne 服务器在同一台机器上

  1. 在 MatrixOne 中执行 Load Data 之前，需要提前在 MatrixOne 中创建完成数据表。
  2. 启动 MySQL 客户端，连接 MatrixOne：

1. mysql -h 127.0.0.1 -P 6001 -uroot -p111

Note

上述代码段中的登录账号为初始账号，请在登录 MatrixOne 后及时修改初始密码，参见密码管理。 3. 在 MySQL 客户端对对应的文件路径执行 LOAD DATA：

1. mysql> LOAD DATA INFILE '/tmp/xxx.csv' 2. INTO TABLE table_name 3. FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY "\r\n";

数据文件与 MatrixOne 服务器在不同的机器上

  1. 在 MatrixOne 中执行 LOAD DATA LOCAL 之前，需要提前在 MatrixOne 中创建完成数据表。
  2. 启动 MySQL 客户端，连接 MatrixOne：

1. mysql -h <mo-host-ip> -P 6001 -udump -p111 --local-infile 3. 在 MySQL 客户端对对应的文件路径执行 LOAD DATA LOCAL：

1. mysql> LOAD DATA LOCAL INFILE '/tmp/xxx.csv' 2. INTO TABLE table_name 3. FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY "\r\n";

示例：使用 docker 启动 MatrixOne 执行 Load data

如果你通过 Docker 安装 MatrixOne，那么文件默认存储在 Docker 镜像中。如果你需要将文件存储在本地目录，你需要先将本地目录挂载到容器。

在以下示例中，本地文件系统路径 ~/tmp/docker_loaddata_demo/ 挂载到 MatrixOne Docker 镜像，并映射到 Docker 容器内的 /ssb-dbgen-path 目录。本篇示例将指导你使用 Docker 加载数据。

  1. 下载数据集，并且将数据集存储到本地 ~/tmp/docker_loaddata_demo/ 路径下：

1. cd ~/tmp/docker_loaddata_demo/ 2. wget https://community-shared-data-1308875761.cos.ap-beijing.myqcloud.com/lineorder_flat.tar.bz2 2. 解压数据集：

1. tar -jxvf lineorder_flat.tar.bz2 3. 使用 Docker 启动 MatrixOne，启动时将存放了数据文件的目录 ~/tmp/docker_loaddata_demo/ 挂载到容器的某个目录下，这里容器目录以 /ssb-dbgen-path 为例：

1. sudo docker run --name matrixone --privileged -d -p 6001:6001 -v ~/tmp/docker_loaddata_demo/:/ssb-dbgen-path:rw matrixorigin/matrixone:0.6.0 4. 连接 MatrixOne 服务：

1. mysql -h 127.0.0.1 -P 6001 -uroot -p111

Note: 如果你的数据文件与 MatrixOne 服务器在不同的机器上，即数据文件在你所使用的客户端机器上时，那么你连接 MatrixOne 服务主机需要使用命令行：mysql -h <mo-host-ip> -P 6001 -udump -p111 --local-infile；并且导入的命令行需要使用 LOAD DATA LOCAL INFILE 语法。 5. 在 MatrixOne 中新建表 lineorder_flat，并且将数据集导入至 MatriOne：

1. mysql> create database if not exists ssb; 2. mysql> use ssb; 3. mysql> drop table if exists lineorder_flat; 4. mysql> CREATE TABLE lineorder_flat( 5. LO_ORDERKEY bigint key, 6. LO_LINENUMBER int, 7. LO_CUSTKEY int, 8. LO_PARTKEY int, 9. LO_SUPPKEY int, 10. LO_ORDERDATE date, 11. LO_ORDERPRIORITY char(15), 12. LO_SHIPPRIORITY tinyint, 13. LO_QUANTITY double, 14. LO_EXTENDEDPRICE double, 15. LO_ORDTOTALPRICE double, 16. LO_DISCOUNT double, 17. LO_REVENUE int unsigned, 18. LO_SUPPLYCOST int unsigned, 19. LO_TAX double, 20. LO_COMMITDATE date, 21. LO_SHIPMODE char(10), 22. C_NAME varchar(25), 23. C_ADDRESS varchar(25), 24. C_CITY char(10), 25. C_NATION char(15), 26. C_REGION char(12), 27. C_PHONE char(15), 28. C_MKTSEGMENT char(10), 29. S_NAME char(25), 30. S_ADDRESS varchar(25), 31. S_CITY char(10), 32. S_NATION char(15), 33. S_REGION char(12), 34. S_PHONE char(15), 35. P_NAME varchar(22), 36. P_MFGR char(6), 37. P_CATEGORY char(7), 38. P_BRAND char(9), 39. P_COLOR varchar(11), 40. P_TYPE varchar(25), 41. P_SIZE int, 42. P_CONTAINER char(10) 43. ); 44. mysql> load data infile '/ssb-dbgen-path/lineorder_flat.tbl' into table lineorder_flat FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n'; 6. 导入成功后，可以使用 SQL 语句查看导入数据的行数：

1. select count(*) from lineorder_flat; 2. /* 3. expected results: 4. */ 5. +----------+ 6. | count(*) | 7. +----------+ 8. | 10272594 | 9. +----------+

限制

加载 csv 格式支持 JSON 类型，但是需要确保 JSON 内不含有字段终止符号，如果 JSON 内含有字段终止符号，那么 JSON 需要用双引号包裹起来。例如：

  • 正确示例："{"a":1, "b":2}", 2
  • 错误示例：{"a":1, "b":2}, 2