synchronisieren Sie zwei pg-Datenbanken

Ich habe eine postgresql-server-Prozess jeder läuft in meinem desktop und dem laptop.

Beide Server haben eine Datenbank namens MG mit genau dem gleichen Schema/layout. Jetzt habe ich die Eingabe der Daten in ähnlichen Tabellen, aber zu unterschiedlichen Zeiten.

Ich in der Regel halten die primären Tasten getrennt, so dass Sie nicht aneinander geraten. eg: oddnumber pkey für laptop und sogar Reihe für desktop.

Nun, wie synchronisiere ich die Daten zwischen der desktop-und laptop sauber?

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

SCHREIBTISCH verwendet pkeys wie 1001... für Einsätze

LAP nutzt pkeys wie 2001... für Einsätze

Muss ich sowohl das update für die geänderten Datensätze, und legen Sie für neue Rekorde. Aber wie?

InformationsquelleAutor yjfuk | 2009-08-18
  1. 4

    Sieht es aus wie rubyrep für Sie arbeiten würde.

    InformationsquelleAutor Tometzky
  2. 1

    Die einfachste Weise sein würde zu schreiben ein eigenes Skript/Programm. Es ist nicht schwierig, und Sie werden definitiv wissen und verstehen wie es funktioniert, damit die Erweiterung wird es trivial sein.

    • würden Sie mir einige Prinzip, wie es funktioniert?
    • Gut, es wird so funktionieren, wie Sie es schreiben. In der Regel alles hängt davon ab, was Ihre Anwendungen mit der Datenbank. Vereinfachter Ansatz: überprüfen Sie neueste id repliziert werden, um eine andere Datenbank und kopiere alle neuen.
    • und was ist mit geänderten Daten? ich kann nicht herausfinden, wie zu synchronisieren, es in einem vereinfachten Ansatz
    • add "zuletzt geändert" - Zeitstempel setzen von trigger auf "jetzt()", und du bist fertig. jetzt nur statt vergleichen ids, vergleichen Sie die maximale last_modified
    InformationsquelleAutor
  3. 1

    Verwenden Slony-I zu tun, postgreSQL, Synchronisierung.

    • Slony-I unterstützt keine multi-master-Replikation, so wird es nicht funktionieren hier.
    InformationsquelleAutor nont
  4. 0

    Entnehmen Sie bitte der PostgreSQL-Dokumentation für Hohe Verfügbarkeit, Load Balancing und Replikation

    InformationsquelleAutor Space
  5. 0

    Hinzufügen user80168 Antwort, hier ist ein potentieller Tisch Fusion:

    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;
    }

}
    InformationsquelleAutor Motes
Schreibe einen Kommentar