插入 csv 文件

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

语法结构

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

LOAD DATA
INFILE 'file_name'
INTO TABLE tbl_name
[{FIELDS | COLUMNS}
[TERMINATED BY 'string']
[[OPTIONALLY] ENCLOSED BY 'char']
]
[LINES
[STARTING BY 'string']
[TERMINATED BY 'string']
]
[IGNORE number {LINES | ROWS}]
[PARALLEL {'TRUE' | 'FALSE'}]

场景二：数据文件与 MatrixOne 服务器在不同的机器上：

LOAD DATA LOCAL
INFILE 'file_name'
INTO TABLE tbl_name
[{FIELDS | COLUMNS}
[TERMINATED BY 'string']
[[OPTIONALLY] ENCLOSED BY 'char']
]
[LINES
[STARTING BY 'string']
[TERMINATED BY 'string']
]
[IGNORE number {LINES | ROWS}]
[PARALLEL {'TRUE' | 'FALSE'}]

开始前准备

已完成单机部署 MatrixOne。

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

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

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

步骤

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

在 MatrixOne 中执行 Load Data 之前，需要提前在 MatrixOne 中创建完成数据表。
启动 MySQL 客户端，连接 MatrixOne：
```
mysql -h 127.0.0.1 -P 6001 -uroot -p111
```
Note

上述代码段中的登录账号为初始账号，请在登录 MatrixOne 后及时修改初始密码，参见密码管理。

在 MySQL 客户端对对应的文件路径执行 LOAD DATA：

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

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

在 MatrixOne 中执行 LOAD DATA LOCAL 之前，需要提前在 MatrixOne 中创建完成数据表。

启动 MySQL 客户端，连接 MatrixOne：

mysql -h <mo-host-ip> -P 6001 -uroot -p111 --local-infile

在 MySQL 客户端对对应的文件路径执行 LOAD DATA LOCAL：

mysql> LOAD DATA LOCAL INFILE '/tmp/xxx.csv'
INTO TABLE table_name
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 加载数据。

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

cd ~/tmp/docker_loaddata_demo/
wget https://community-shared-data-1308875761.cos.ap-beijing.myqcloud.com/lineorder_flat.tar.bz2

解压数据集：
```
tar -jxvf lineorder_flat.tar.bz2
```
使用 Docker 启动 MatrixOne，启动时将存放了数据文件的目录 ~/tmp/docker_loaddata_demo/ 挂载到容器的某个目录下，这里容器目录以 /ssb-dbgen-path 为例：
```
sudo docker run --name matrixone --privileged -d -p 6001:6001 -v ~/tmp/docker_loaddata_demo/:/ssb-dbgen-path:rw matrixorigin/matrixone:1.2.4
```
连接 MatrixOne 服务：
```
mysql -h 127.0.0.1 -P 6001 -uroot -p111
```
Note: 如果你的数据文件与 MatrixOne 服务器在不同的机器上，即数据文件在你所使用的客户端机器上时，那么你连接 MatrixOne 服务主机需要使用命令行：mysql -h <mo-host-ip> -P 6001 -uroot -p111 --local-infile；并且导入的命令行需要使用 LOAD DATA LOCAL INFILE 语法。

在 MatrixOne 中新建表 lineorder_flat，并且将数据集导入至 MatriOne：

mysql> create database if not exists ssb;
mysql> use ssb;
mysql> drop table if exists lineorder_flat;
mysql> CREATE TABLE lineorder_flat(
  LO_ORDERKEY bigint key,
  LO_LINENUMBER int,
  LO_CUSTKEY int,
  LO_PARTKEY int,
  LO_SUPPKEY int,
  LO_ORDERDATE date,
  LO_ORDERPRIORITY char(15),
  LO_SHIPPRIORITY tinyint,
  LO_QUANTITY double,
  LO_EXTENDEDPRICE double,
  LO_ORDTOTALPRICE double,
  LO_DISCOUNT double,
  LO_REVENUE int unsigned,
  LO_SUPPLYCOST int unsigned,
  LO_TAX double,
  LO_COMMITDATE date,
  LO_SHIPMODE char(10),
  C_NAME varchar(25),
  C_ADDRESS varchar(25),
  C_CITY char(10),
  C_NATION char(15),
  C_REGION char(12),
  C_PHONE char(15),
  C_MKTSEGMENT char(10),
  S_NAME char(25),
  S_ADDRESS varchar(25),
  S_CITY char(10),
  S_NATION char(15),
  S_REGION char(12),
  S_PHONE char(15),
  P_NAME varchar(22),
  P_MFGR char(6),
  P_CATEGORY char(7),
  P_BRAND char(9),
  P_COLOR varchar(11),
  P_TYPE varchar(25),
  P_SIZE int,
  P_CONTAINER char(10)
);
mysql> load data infile '/ssb-dbgen-path/lineorder_flat.tbl' into table lineorder_flat FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n';

导入成功后，可以使用 SQL 语句查看导入数据的行数：

select count(*) from lineorder_flat;
/*
    expected results:
 */
+----------+
| count(*) |
+----------+
| 10272594 |
+----------+

限制

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

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