PostgresSQL copiando entradas mais recentes de uma tabela em um banco de dados para uma tabela em um banco de dados em uma máquina remota

Usando dblink, você pode copiar registros de um servidor para outro. Eu instalei o dblink, usando este guia de instalação . Os bancos de dados são os mesmos e possuem a mesma tabela chamada sometable. Isso é semelhante a tabelas federadas no MySQL e openquery no SQL Server.

O servidor antigo está escutando na porta 5432 e o novo servidor está escutando na porta 5433. Instalei apenas o dblink no novo servidor. A extensão dblink foi adicionada apenas ao banco de dados de recebimento no novo servidor. No meu exemplo, não incluí o host porque os dois servidores postgresql estão na mesma máquina.

Aqui estão as etapas básicas que segui usando um 9.1 em um servidor CentOS 6

Instalar dblink

-- vá para o diretório postgresl_source. Se você instalou via yum ou apt-get terá que instalar os pacotes postgresql_source

cd /postgresql_source_directory/contrib/dblink

-- instalar os binários do dblink

make install

-- Conecte-se a 9.1 ouvindo em 5433

psql -p5433

-- Conecte-se ao banco de dados que receberá os dados

\connect somedatabase

-- Adicione a extensão dblink

CREATE EXTENSION dblink;

-- Verifique se a extensão existe

\dx
dblink  | 1.0     | public     | connect to other PostgreSQL databases from within a database

Copie os dados para o novo servidor

Estou usando uma tabela de armazenamento temporário, porque facilitou o uso de uma instrução EXISTS ao copiar novos registros.

-- trunca a tabela de armazenamento temporário no novo servidor

truncate table sometable_2;

-- copia os registros para a tabela de armazenamento temporário no novo servidor

insert into sometable_2 select * from dblink('port=5432 dbname=somedatabase', 'select * from sometable') as t1(t int);

Se o seu servidor estiver em um endereço IP diferente, você executaria isso

insert into sometable_2 select * from dblink('port=5432 dbname=somedatabase host=some.remote.ip.address', 'select * from sometable') as t1(t int);

-- Copiar apenas novos registros para a nova sometable

insert into sometable select * from sometable_2 st2 where not exists(select * from sometable st where st.t = st2.t);
INSERT 0 5

Se eu executar as mesmas consultas novamente, apenas novos registros serão copiados. Isso ocorre porque a subconsulta correlacionada (selecione * de alguma tabela st onde st.t = st2.t) recupera apenas registros que ainda não existem na tabela " sometable" no novo servidor.