dws
步骤3：执行数据导入
更新时间：2021/02/18 GMT+08:00
- 在GaussDB(DWS)数据库中，创建一个名为product_info的表，用于存储从OBS导入的数据。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
DROP TABLE IF EXISTS product_info; CREATE TABLE product_info ( product_price integer not null, product_id char(30) not null, product_time date , product_level char(10) , product_name varchar(200) , product_type1 varchar(20) , product_type2 char(10) , product_monthly_sales_cnt integer , product_comment_time date , product_comment_num integer , product_comment_content varchar(200) ) WITH ( orientation = column, compression=middle ) DISTRIBUTE BY hash (product_id);
- 执行INSERT命令，通过外表product_info_ext将OBS上的数据导入到目标表product_info 中：
1
INSERT INTO product_info SELECT * FROM product_info_ext;
- 若出现以下类似信息，说明数据导入成功。请查询错误表，查看是否存在数据格式错误，详细操作请参见步骤4：分析和处理错误表中的错误信息。
1
INSERT 0 20
- 若出现数据导入错误，请参见步骤4：分析和处理错误表中的错误信息，并重新执行数据导入。
- 若出现以下类似信息，说明数据导入成功。请查询错误表，查看是否存在数据格式错误，详细操作请参见步骤4：分析和处理错误表中的错误信息。
- 执行SELECT命令查询目标表product_info，查看从OBS导入到GaussDB(DWS)中的数据。
1
SELECT * FROM product_info;
查询结果显示如准备数据文件中所示的数据，表示导入成功。查询结果的结尾将显示以下信息：
(20 rows)
父主题： 教程：从OBS导入数据到集群
