PostgreSQL - insertart registro a otra base de dato por dblink

Buenos dias Colegas, estoy tratando de crear un cursor en postgresql, para asi insertar esos registro en otro servidor por dblink, la funcion corre bien pero cuando ejecuto mi funcion me dice que la tabla a la que voy a insertar no existe donde quiero insertar (esto lo estoy haciendo desde un servidor cliente que va a insertar la data al principal):

create or replace function public.insertar_reg(
)
returns void
language 'plpgsql'
cost 100
volatile parallel UNSAFE
as $BODY$
declare
v_id prueba_1%rowtype;
v_found_error varchar(30):='no data found';
prueba_cursor cursor for
select * from prueba_1;
begin
open prueba_cursor;
loop
fetch prueba_cursor into v_id;
insert into central
select * from dblink('dbname=center port=5432 host=192.168.56.3 user=postgres password=123', '
select compania,nombre,fecha,estatus from central')
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
where not exists (select compania from central
where compania=compania
group by compania);
end loop;

update central
set estatus='C'
where fecha between '01-feb-2022' and '02-feb-2022'
and fecha <= now() - interval '7 day';
exception
when no_data_found then
raise exception 'film % not found', v_found_error;
end;
$BODY$;

========================
este es el error que presenta cuando ejecuto la function


ERROR: relation "central" does not exist
LINE 1: insert into central
^
QUERY: insert into central
select * from dblink('dbname=center port=5432 host=192.168.56.3 user=postgres password=123', '
select compania,nombre,fecha,estatus from central')
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
where not exists (select compania from central
where compania=compania
group by compania)
CONTEXT: PL/pgSQL function insertar_reg() line 11 at SQL statement
SQL state: 42P01

Hola

No puedes usar dblink para hacer un insert, para eso debes usar dblink_exec


https://www.postgresql.org/docs/13/contrib-dblink-exec.html

Saludos

aun sigue presentando el mismo error con el dblink_exec



create or replace function public.insertar_reg(
)
returns void
language 'plpgsql'
cost 100
volatile parallel UNSAFE
as $BODY$
declare
v_id prueba_1%rowtype;
v_found_error varchar(30):='no data found';
prueba_cursor cursor for
select * from prueba_1;
begin
open prueba_cursor;
loop
fetch prueba_cursor into v_id;
insert into central
select * from dblink_exec('dbname=center port=5432 host=192.168.56.3 user=postgres password=123', '
select compania,nombre,fecha,estatus from central')
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
where not exists (select compania from central
where compania=compania
group by compania);
end loop;

update central
set estatus='C'
where fecha between '01-feb-2022' and '02-feb-2022'
and fecha <= now() - interval '7 day';
exception
when no_data_found then
raise exception 'film % not found', v_found_error;
end;
$BODY$;
============

CREATE FUNCTION

Query returned successfully in 121 msec.

=========

select insertar_reg()
muestra el mismo error :

===========

ERROR: relation "central" does not exist
LINE 1: insert into central
^
QUERY: insert into central
select * from dblink_exec('dbname=center port=5432 host=192.168.56.3 user=postgres password=123', '
select compania,nombre,fecha,estatus from central')
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
where not exists (select compania from central
where compania=compania
group by compania)
CONTEXT: PL/pgSQL function insertar_reg() line 11 at SQL statement
SQL state: 42P01

Hola

Aqui te lo dice


No existe la tabla central

Si lo que quieres es crear la tabla al "vuelo" entonces


Saludos

buenas gracias por responder, el detalle es que dice eso porque la conexion no se establece cuando dice que (ERROR: relation "central" does not exist), porque la table si existe en el otro servidor que quiero copiar los registro del otro servidor, con este me funciona me inserta los registro en el otro servidor,
----------------------------

create or replace function insert_update_reg(
)
RETURNS void AS
$BODY$
declare
begin
select * from dblink_exec
(
'dbname=master port=5432 host=192.168.56.102 user=postgres password=123',
'insert into master
select compania,nombre,fecha,estatus
from dblink
(
''dbname=slave port=5432 host=192.168.56.101 user=postgres password=123'',
''SELECT compania,nombre,fecha,estatus FROM slave''
)
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
WHERE not exists(select compania from master
where compania=compania
group by compania );');

end;
$BODY$
LANGUAGE 'plpgsql' VOLATILE
COST 100;
---------------------------------------
pero apesar de que copia los registro me presenta esto.(copio los registro del slave para copiarlo al master)

ERROR: query has no destination for result data
HINT: If you want to discard the results of a SELECT, use PERFORM instead.
CONTEXT: PL/pgSQL function insert_update_reg() line 4 at SQL statement
SQL state: 42601

pero me inserta los registro, como puedo tener un update en esta misma function. se lo agradeceria saber como hacerlo

gracias por las repuestas ya resolvi con el update

create or replace function insert_update_reg(
)
returns void as
$BODY$
declare
begin
perform dblink(
'dbname=master port=5432 host=192.168.56.102 user=postgres password=123','
insert into master
select compania,nombre,fecha,estatus
from dblink
(
''dbname=slave port=5432 host=192.168.56.101 user=postgres password=123'',
''select compania,nombre,fecha,estatus FROM slave''

)
as cust (compania integer, nombre varchar(30),fecha date,estatus varchar(5))
where not exists(select compania from master
where compania=compania
group by compania)');

perform dblink(
'dbname=master port=5432 host=192.168.56.102 user=postgres password=123','
update master set estatus =''C''
where fecha between ''01-feb-2022'' and ''05-feb-2022'' ');
end;
$BODY$
language 'plpgsql' volatile
cost 100;