-------------------------------------------------
--функция для проведения репликации одной таблицы
-------------------------------------------------
CREATE OR REPLACE FUNCTION table_insr() 
returns integer AS
$body$
declare 
	count integer <img class="ccfilter smileys" src="https://pgdocs.ru/sites/all/modules/ccfilter/smileys/ai.gif" alt="=0" title="=0" />;
	myrec record;
begin
	--коннект к базе
	perform dblink_connect('host=127.0.0.1 dbname=slave user=postgres password=zzcz2com');
              --тут надо наложить блок на таблицу tab_slave и tab_1
	--синхронизирую вставки
	FOR myrec IN SELECT * FROM inserted LOOP
 
	IF ((SELECT * FROM dblink('host=127.0.0.1 dbname=slave user=postgres password=zzcz2com',
	'select tm from time_rep limit 1') AS t (time timestamp without time zone)) < myrec.time) 
	then
 
	perform dblink_exec('insert into tab_slave select * from dblink('|| chr(39) ||'host=127.0.0.1 dbname=test user=postgres password=zzcz2com'||
	chr(39)|| ',' || chr(39) || 'select * from tab_1 where id =' || myrec.id || chr(39) ||') as t (id integer, name varchar(20))');
 
	count = count+1;
	end IF;
	end loop;
 
	--синхронизирую удаления
	FOR myrec IN SELECT * FROM deleted LOOP
 
	IF ((SELECT * FROM dblink('host=127.0.0.1 dbname=slave user=postgres password=zzcz2com',
	'select tm from time_rep limit 1') AS t (time timestamp without time zone)) < myrec.time) 
	then
 
	perform dblink_exec('delete from tab_slave where id =' || myrec.id);
 
	count = count+1;
	end IF;
	end loop;
 
	--синхронизирую
	FOR myrec IN SELECT * FROM updated LOOP
 
	IF ((SELECT * FROM dblink('host=127.0.0.1 dbname=slave user=postgres password=zzcz2com',
	'select tm from time_rep limit 1') AS t (time timestamp without time zone)) < myrec.time) 
	then
 
	perform dblink_exec('delete from tab_slave where id =' || myrec.id);
 
	perform dblink_exec('insert into tab_slave select * from dblink('|| chr(39) ||'host=127.0.0.1 dbname=test user=postgres password=zzcz2com'||
	chr(39)|| ',' || chr(39) || 'select * from tab_1 where id =' || myrec.id || chr(39) ||') as t (id integer, name varchar(20))');
 
	count = count+1;
	end IF;
	end loop;
 
	--обновляем время проведенной синхронизации в удаленной бд
	perform dblink_exec('update time_rep set tm=' || quote_literal((now()))); 
 
             --снять блокировки
	--диссконект
	perform dblink_disconnect();
	RETURN count;
end;
$body$
  LANGUAGE 'plpgsql' VOLATILE
  COST 100;
ALTER FUNCTION table_insr() OWNER TO postgres;