全部版块 我的主页
论坛 数据科学与人工智能 数据分析与数据科学 SQL及关系型数据库数据分析
1129 0
2018-10-29

1、数据的读取可以采用函数 pg.spi.exec,并把数据写入本地
CREATE OR REPLACE FUNCTION cheek_up.distance_1()
  RETURNS integer AS
$BODY$
data=pg.spi.exec('select * from  cheek_up.cbr_cost')  /*数据的读入*/
da1=data
write.csv(da1,"/data3/wbdata/distance.csv",row.names=FALSE)   /*数据写入本地*/
return(1)
$BODY$
  LANGUAGE plr VOLATILE;
ALTER FUNCTION cheek_up.distance_1() OWNER TO gpadmin;
2、采用copy得到表
CREATE OR REPLACE FUNCTION cheek_up.distance_2()
  RETURNS integer AS
$BODY$
begin
delete from cheek_up.distance;
perform cheek_up.distance_1();      //注意是perform
copy cheek_up.distance from '/data3/wbdata/distance.csv' header delimiter ',';  /*数据写了表中*/
return 1;
end;
$BODY$
  LANGUAGE plpgsql VOLATILE;
ALTER FUNCTION cheek_up.distance_2() OWNER TO gpadmin;

二维码

扫码加我 拉你入群

请注明:姓名-公司-职位

以便审核进群资格,未注明则拒绝

相关推荐
栏目导航
热门文章
推荐文章

说点什么

分享

扫码加好友,拉您进群
各岗位、行业、专业交流群