Oi. Acredito que isso pode ser resolvido mais ou menos assim:
var pg = require('pg');
//bancoA
var conString = "postgres://username:password@localhost/database";
var client1 = new pg.Client(conString);
//bancoB
var conString = "postgres://username:password@localhost/database";
var client2 = new pg.Client(conString);
Agora você tem conexão aos dois bancos.
Para retornar todos os registros de A:
var query = client1.query('select * from table');
//Acho que isso teria que ser feito tabela por tabela
var rows = [];
query.on('row', function(row) {
rows.push(row);
});
//Esse codigo precisa ser testado.
//Nao tenho absoluta certeza de que isso funciona dessa forma.
//Teoricamente a variavel rows estaria com todos os registros
//que o postgres tinha na tabela.
A partir desse ponto, temos que definir qual vai ser a logica que vamos usar para definirmos quais valores serão inseridos no banco B,visto que serão apenas os registros ainda não presentes.
Acredito que a melhor forma de fazer isso é fazer o mesmo select no client2
. A partir daí teríamos um valor para a variável rows
com os valores já inseridos na tabela do BancoB. E aí seria necessária só uma lógica simples para deletar os valores de rowsDeA
que já existem em rowsDeB
.
Vale lembrar de que, dependendo do tamanho das tabelas e a periodicidade que isso vai acontecer, esse código pode ser extremamente custoso. Se a ideia é fazer disso um run contínuo(para manter um servidor de backup, ou qualquer coisa do tipo), talvez seja melhor criar uma lógica que insira os valores no BancoB ao mesmo tempo que no BancoA.
Mais um disclaimer: Não tenho certeza de que isso vai funcionar, mas vale o teste :)