教程:使用GDS从远端服务器导入数据 创建外表 1.使用SQL客户端工具连接DWS数据库。 2.创建如下外表: 注意 LOCATION:请替换成实际的GDS地址和端口。 DROP FOREIGN TABLE IF EXISTS productinfoext; CREATE FOREIGN TABLE productinfoext ( productprice integer not null, productid char(30) not null, producttime date , productlevel char(10) , productname varchar(200) , producttype1 varchar(20) , producttype2 char(10) , productmonthlysalescnt integer , productcommenttime date , productcommentnum integer , productcommentcontent varchar(200) ) SERVER gsmppserver OPTIONS( LOCATION 'gsfs://192.168.0.90:5000/', FORMAT 'CSV' , DELIMITER ',', ENCODING 'utf8', HEADER 'false', FILLMISSINGFIELDS 'true', IGNOREEXTRADATA 'true' ) READ ONLY LOG INTO productinfoerr PER NODE REJECT LIMIT 'unlimited'; 返回如下信息表示创建成功: CREATE FOREIGN TABLE 导入数据 1.使用如下语句在DWS中创建目标表productinfo,用于存储导入的数据。 DROP TABLE IF EXISTS productinfo; CREATE TABLE productinfo ( productprice integer not null, productid char(30) not null, producttime date , productlevel char(10) , productname varchar(200) , producttype1 varchar(20) , producttype2 char(10) , productmonthlysalescnt integer , productcommenttime date , productcommentnum integer , productcommentcontent varchar(200) ) WITH ( orientation column, compressionmiddle ) DISTRIBUTE BY hash (productid); 2.将数据源文件中的数据通过外表“productinfoext”导入到表“productinfo”中。 INSERT INTO productinfo SELECT FROM productinfoext ; 出现以下信息,说明数据导入成功。 INSERT 0 20 3.执行SELECT命令查询目标表productinfo,查看导入到DWS中的数据。 SELECT count() FROM productinfo; 查询结果显示结果如下,表示导入成功。 count 20 (1 row) 4.对表productinfo执行VACUUM FULL。 VACUUM FULL productinfo 5.更新表productinfo的统计信息。 ANALYZE productinfo;