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 ;