同步两个pg数据库

Question

我有一个 postgresql 服务器进程，分别在我的台式机和笔记本电脑上运行。

两台服务器都有一个名为 MG 的数据库，其方案/布局完全相同。现在，我将数据输入到类似的表中，但时间不同。

我通常将主键分开，这样它们就不会相互冲突。例如：笔记本电脑的奇数 pkey 和台式机的偶数 pkey。

现在如何干净地同步台式机和笔记本电脑之间的数据？

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

DESK 使用像 1001 这样的 pkeys...用于插入
LAP 使用像 2001 这样的 pkeys... 对于插入，

我需要更新已修改的记录并插入新记录。但如何呢？

Answer 1

看起来 rubyrep 适合你。

Answer 2

最简单的方法是编写自定义脚本/程序。这并不困难，而且您肯定会知道并理解它是如何工作的，因此扩展它将是微不足道的。

Answer 3

使用 Slony-I 进行 postgreSQL 同步。

Answer 4

请参阅 PostgreSQL 文档，了解高可用性、负载平衡和复制

Answer 5

为了添加到 user80168 的答案，这里是一个潜在的表合并：

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

}