testDB=# select * from public.test001_ext

10.3 COPY命令

使用COPY命令可以实现将文件导出和导入，但是要通过Master，效率没有外部表高，但是在数据量比较小的情况下，COPY命令比外部表要方面很多。

COPY table [(colum [, ...]) ] FROM {'file'|STDIN}

[ [WITH]

  [OIDS]

  [HEADER]

  [DELIMITER [AS] 'delimeter']

  [NULL [AS] 'null string']

  [ESCAPE [AS] 'escape' | 'OFF']

    [NEWLINE [AS] 'LF'|'CR'|'CRLF']

  [CSV [QUOTE [AS] 'quote']

    [FORCE NOT NULL column [,...]]

  [FILL MISSING FIELDS]

  [ [LOG ERRORS INTO error_table] [KEEP]

     SEGMENT REJECT LIMIT count [ROWS|PERCENT]]

COPY {table [(column [,...])] |(query) } TO {'file'|STDOUT}

  [ [WITH]

    [OIDS]

    [HEADER]

    [DELIMIETER [AS] 'delimeter']

    [NULL [AS] 'null string']

    [ESCAPE [AS] 'escape'|'OFF']

    [CSV [QUOTE [AS] 'quote']

         [FORCE QUOTE column [,...]]]

copy public.number_fdata0_1_prt_p30001231 from '/home/gpadmin/member_his_init.dat' with delimiter ',';

Greenplum 4.x中引入了可写外部表，在导出数据的时候可以用可写外部表并发导出，性能很好。但在Greeplum3.x版本中，导出数据只能通过COPY命令实现，数据在Master上汇总导出。
如果需要将数据远程导出到其他机器上，可以使用copy to stdout，远程执行psql连接到数据库上，然后通过管道将数据重定向成文件。

11 GP的存储过程
Greenplum支持SQL/PYTHON/PERL/C语言构建函数，以下着重介绍SQL 存储过程。 一个存储过程就是一个事务，包括对子过程的调用都在一个事务内

存储过程结构模板1：

CREATE FUNCTION somefunc() RETURNS integer AS $$

DECLARE

    quantity integer := 30;

BEGIN

 

    RETURN ....;

END;

$$ LANGUAGE plpgsql;

• 存储过程结构模板2：

create or replace function 存储过程名称(in 参数1 参数类型,in 参数2 参数类型,in 参数3 参数类型 )
returns 返回类型 as $$ 
begin
存储过程语句
end;
$$ language plpgsql;


create or replace function prc_test(in par1 text,in par2 numeric,in par3 integer)
returns void as $$ 
begin
insert into table1 values(par1,par2,par3);
end;
$$ language plpgsql;

CREATE OR REPLACE FUNCTION dws.p_function()
 RETURNS void
 LANGUAGE plpgsql
AS $function$ 
begin

end;
$function$
;

EXCEPTION WHEN unique_violation 

THEN 

-- do nothing 

END;

忽略错误：

EXCEPTION  WHEN OTHERS THEN

            RAISE NOTICE 'an EXCEPTION is about to be raised';

            RAISE EXCEPTION 'NUM:%, DETAILS:%', SQLSTATE, SQLERRM;

END;

• 错误和消息

RAISE level 'format' [, expression [, ...]];
	
	Level:
	
	Info:信息输入
	
    Notice:信息提示
	
	Exception:产生一个例外，将退出存储过程
	
	Example: RAISE NOTICE 'Calling cs_create_job(%)', v_job_id;