Ora2pg之管道函数转换

oracle管道函数

--create type strsplit_type_wj is table of varchar2(200);

create or replace function strsplit_wj(p_value varchar2,  p_split varchar2 := ',')
--usage: select * from table(strsplit('1,2,3,4,5'))
 return strsplit_type_wj
  pipelined is
  v_idx       integer;
  v_str       varchar2(500);
  v_strs_last varchar2(4000) := p_value;
begin
  loop
    v_idx := instr(v_strs_last, p_split);
    exit when v_idx = 0;
    v_str       := substr(v_strs_last, 1, v_idx - 1);
    v_strs_last := substr(v_strs_last, v_idx + 1);
    pipe row(v_str);  ---表示返回一行值
  end loop;
  pipe row(v_strs_last); ---表示返回一行值
  return;  --表示记录集返回结束
end strsplit_wj;

Postgresql:返回值类型表示结果集中子元素类型，也就是oracle中定义数组的子元素类， setof表示返回可变结果集

create or replace function strsplit_wj(p_value  varchar ,p_split  varchar DEFAULT ',') returns setof  varchar as 
$$
DECLARE
	v_idx numeric ;
	v_str varchar ;
	v_strs_last varchar :=p_value;
BEGIN
	LOOP
v_idx:=dbms_lob.instr(v_strs_last,p_split);
EXIT WHEN v_idx=0;
v_str:=public.substr(v_strs_last::text,1::int4,(v_idx - 1)::int4);
v_strs_last:=hh_catalog.substr(v_strs_last::text,(v_idx + 1)::int4);
	RETURN  NEXT  v_str;  ---表示返回一行值
END LOOP;
	RETURN   NEXT v_strs_last;  ---表示返回一行值
END 
$$
language plpgsql   ;