zsynchronizować dwie bazy danych pg

Question

Mam proces serwera PostgreSQL każdego uruchomiony w moim pulpit i laptopa.

Oba serwery mają bazę danych o nazwie MG z dokładnie tym samym schematem/układem. Teraz wprowadzam dane do podobnych tabel, ale w różnym czasie.

Ogólnie klucze główne przechowuję oddzielnie, aby nie kolidowały ze sobą. np.: klucz nieparzysty na laptopa, a nawet numer na pulpicie.

Jak mogę teraz zsynchronizować dane między komputerem stacjonarnym a laptopem?

DESK:ADDRESS ----- LAP:ADDRESS 
DESK:TO_DO ----- LAP:TO_DO 

DESK wykorzystuje pkeys jak 1001 ... dla wkładek
LAP wykorzystuje pkeys jak 2001 ... dla wkładek

muszę zarówno aktualizacji dla zmodyfikowanych zapisów i wstawić nowych rekordów. Ale jak?

Answer 1

Wygląda na to, że rubyrep będzie działać dla Ciebie.

Answer 2

Najprostszym sposobem byłoby napisanie niestandardowego skryptu/programu. Nie jest to trudne, a na pewno będziesz wiedział i rozumiesz, jak to działa, więc rozszerzenie to będzie banalne.

Answer 3

Proszę odnieść się do dokumentacji PostgreSQL dla High Availability, Load Balancing, and Replication

Answer 4

Korzystając Slony-I zrobić synchronizację PostgreSQL.

Answer 5

Aby dodać odpowiedź user80168, oto jest potencjalnym stół fuzja:

package merge.tables; 

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.ResultSet; 
import java.sql.ResultSetMetaData; 
import java.sql.SQLException; 
import java.sql.Statement; 

public class PostgreTableMerger { 

    private static String dbOrigin = "jdbc:postgresql://server1:5432/DB"; 
    private static String dbDest = "jdbc:postgresql://server2:5432/DB"; 
    private static String tableToMerge = "important_results"; 

    public static void main(String[] args) throws Exception { 

     Connection dbConnOrigin = DriverManager.getConnection(dbOrigin, "pgadmin", "pgadmin"); 
     Statement dbOriginStat = dbConnOrigin.createStatement(); 

     Connection dbConnDest = DriverManager.getConnection(dbDest, "pgadmin", "pgadmin"); 
     Statement dbDestStat = dbConnDest.createStatement(); 

     String sqlToExecute = "SELECT * FROM " + tableToMerge; 
     ResultSet assets = dbOriginStat.executeQuery(sqlToExecute); 
     ResultSetMetaData rsMeta = assets.getMetaData(); 


     while(assets.next()){ 
      String insertSQL = "INSERT INTO " + tableToMerge + " VALUES("; 

      for(int i = 1; i <= rsMeta.getColumnCount(); i++){ 
       String value = assets.getString(i); 
       if(assets.wasNull()){ 
        insertSQL += "NULL,"; 
       }else{ 
        insertSQL += "'" + value + "',"; 
       }    
      } 
      insertSQL =insertSQL.substring(0, insertSQL.length()-1) + ")"; 

      try{ 
       dbDestStat.executeUpdate(insertSQL); 
      }catch(SQLException e){ 
       //TODO: attempt to update the row in the event of duplicate key 
      } 


     } 
     return; 
    } 

}