Postgres Funktionen mit Parametern und dblink

Question

Ich bitte um Ihre Hilfe mit einer Funktion, an die ich Suchparameter senden muss. Aber das Problem ist, dass die Funktion über einen DBlink ausgeführt wird, und ich muss 2 Werte als Suchparameter übergeben, und bei der Ausführung werden die Werte nicht gesendet.

Dies ist die Funktion ohne dblink:

---

`CREATE OR REPLACE FUNCTION sp_get_afil(i_pers_codigo VARCHAR, i_empr_codigo 
VARCHAR) RETURNS VARCHAR AS $$ 
DECLARE 
    v_pers_codigo VARCHAR; 
BEGIN 
    select ro.pers_codigo 
    into v_pers_codigo 
    from unv_roles_personas ro, unv_personas p1, unv_personas p 
    where ro.rope_vigente = 'S' 
    and ro.empr_codigo = p1.empr_codigo 
    and ro.tiro_codigo = 'AFIL' 
    and ro.pers_codigo = p1.pers_codigo 
    and p1.empr_codigo = p.empr_codigo 
    and p1.pers_estado_cae = p.pers_estado_cae 
    and p1.pers_numero_cae = p.pers_numero_cae 
    and p.empr_codigo = i_empr_codigo 
    and p.pers_codigo = i_pers_codigo; 

    RETURN v_pers_codigo; 

END; 
$$ LANGUAGE plpgsql;` 

---

Es funktioniert ohne Probleme, und hier ist die gleiche Funktion, aber mit dblink, die nicht funktioniert:

---

`CREATE OR REPLACE FUNCTION sp_get_afil(i_pers_codigo VARCHAR, i_empr_codigo 
VARCHAR) RETURNS VARCHAR AS $$ 
DECLARE 
    v_pers_codigo VARCHAR; 
    v_empr_codigo VARCHAR; 
    vr_pers_codigo VARCHAR; 
BEGIN 
    select t1.rop_codigo 
    into vr_pers_codigo 
    from dblink('dbname = usuarios host=100.1.1.138 port=5432 ', 
       'select ro.pers_codigo 
       from unv_roles_personas ro, unv_personas p1, unv_personas p 
       where ro.rope_vigente = ''S'' 
       and ro.empr_codigo = p1.empr_codigo 
       and ro.tiro_codigo = ''AFIL'' 
       and ro.pers_codigo = p1.pers_codigo 
       and p1.empr_codigo = p.empr_codigo 
       and p1.pers_estado_cae = p.pers_estado_cae 
       and p1.pers_numero_cae = p.pers_numero_cae 
       and p.empr_codigo = '||quote_literal ($1)||' 
       and p.pers_codigo = '||quote_literal ($2)||'') 
    as t1 (rop_codigo character varying); 

    RETURN vr_pers_codigo; 

END; 
$$ LANGUAGE plpgsql;` 

---

Bei der Ausführung gibt es einen Nullwert zurück, und dies generiert nicht die Ansicht, die ich brauche. Mir geht es schlecht, ich habe nachgeforscht, aber ich bin schon in einer Sackgasse.

Answer 1

versuchen Sie dies:

CREATE OR REPLACE FUNCTION sp_get_afil(i_pers_codigo VARCHAR, i_empr_codigo 
VARCHAR) RETURNS VARCHAR AS $$ 
DECLARE 
    v_pers_codigo VARCHAR; 
    v_empr_codigo VARCHAR; 
    vr_pers_codigo VARCHAR; 
BEGIN 
    select t1.rop_codigo 
    into vr_pers_codigo 
    from dblink('dbname = usuarios host=100.1.1.138 port=5432 ', 
       format('select ro.pers_codigo 
       from unv_roles_personas ro, unv_personas p1, unv_personas p 
       where ro.rope_vigente = ''S'' 
       and ro.empr_codigo = p1.empr_codigo 
       and ro.tiro_codigo = ''AFIL'' 
       and ro.pers_codigo = p1.pers_codigo 
       and p1.empr_codigo = p.empr_codigo 
       and p1.pers_estado_cae = p.pers_estado_cae 
       and p1.pers_numero_cae = p.pers_numero_cae 
       and p.empr_codigo = %L 
       and p.pers_codigo = %L',i_pers_codigo,i_empr_codigo)) 
    as t1 (rop_codigo character varying); 

    RETURN vr_pers_codigo; 

END; 
$$ LANGUAGE plpgsql; 

Answer 2

Dank Vao Tsun, die Perspektive wechseln und die Funktion auf der Seite der Datenbank, auf die ich zugreifen auszutauschen.

enter code here 

`select t1.a_ctac_correlativo, 
    t1.a_pers_codigo_socadm, 
    b.pers_codigo_scd, 
    b.pers_sigla, 
    b.pers_nombre_completo nombre_soc, 
    t1.recl_correlativo, 
    d.pers_codigo, 
    d.pers_nombre_completo, 
    d.pers_nombre_fantasia, 
    d.pers_sigla edit_sigla,  
    t1.monto, 
    e.tiro_codigo,  
    t1.a_titu_codigo, 
    t1.a_ajuc_correlativo 
from dblink('dbname = liquidaciones host=100.1.1.138 port=5432 ', 
     'select a.ctac_correlativo a_ctac_correlativo, 
       a.pers_codigo_socadm a_pers_codigo_socadm, 
       (case when a.ctac_correlativo = 1213 then 48 else 
a.ctac_correlativo end) recl_correlativo, 
       sum(redi_monto) monto, 
       a.titu_codigo a_titu_codigo, 
       a.ajuc_correlativo a_ajuc_correlativo, 
       a.pers_codigo a_pers_codigo, 
       a.empr_codigo a_empr_codigo 
     from redit a 
     where a.redi_liquidado =''S'' 
     and a.redi_correlativo_padre is null 
     group by a.ctac_correlativo, 
     a.pers_codigo_socadm, 
     recl_correlativo, 
     a.titu_codigo, 
     a.ajuc_correlativo, 
     a.pers_codigo, 
     a.empr_codigo') 
     as t1 (a_ctac_correlativo character varying, 
       a_pers_codigo_socadm character varying, 
       recl_correlativo character varying, 
       monto character varying, 
       a_titu_codigo character varying, 
       a_ajuc_correlativo character varying, 
       a_pers_codigo character varying, 
       a_empr_codigo character varying), 
    unv_personas b, 
    unv_roles_personas e, 
    unv_personas d 
where b.pers_codigo = t1.a_pers_codigo_socadm 
and e.empr_codigo = d.empr_codigo 
and e.pers_codigo = d.pers_codigo 
and e.tiro_codigo = 'EDIT' 
and b.pers_codigo = (select sp_get_afil(CASE WHEN t1.a_pers_codigo = 
'10010407' THEN '10010436' ELSE t1.a_pers_codigo END, t1.a_empr_codigo)) 
and t1.a_pers_codigo in (select pers_codigo from unv_roles_personas where 
tiro_codigo = 'MANDAT' 
        INTERSECT 
        select pers_codigo from unv_roles_personas where 
tiro_codigo = 'EDIT') 
group by t1.a_ctac_correlativo, 
    t1.a_pers_codigo_socadm, 
    b.pers_codigo_scd, 
    b.pers_sigla, 
    nombre_soc, 
    t1.recl_correlativo, 
    d.pers_codigo, 
    d.pers_nombre_completo, 
    d.pers_nombre_fantasia, 
    edit_sigla,  
    t1.monto, 
    e.tiro_codigo,  
    t1.a_titu_codigo, 
    t1.a_ajuc_correlativo;`