PostgreSQL实现数据表跨库同步的四种方案

-- 源库执行

CREATE EXTENSION IF NOT EXISTS dblink;

CREATE OR REPLACE FUNCTION sync_table_func()

RETURNS TRIGGER AS $$

BEGIN

  -- 连接目标库：替换为你的目标库信息

  PERFORM dblink_connect(

    'dbname=目标库名 host=目标IP port=5432 user=账号 password=密码'

  );

-- INSERT 同步

  IF (TG_OP = 'INSERT') THEN

    PERFORM dblink_exec(

      'INSERT INTO 目标表名 VALUES ($1.*)', NEW

    );

  -- UPDATE 同步

  ELSIF (TG_OP = 'UPDATE') THEN

    PERFORM dblink_exec(

      'UPDATE 目标表名 SET 字段1=$1,字段2=$2 WHERE id=$3',

      NEW.字段1, NEW.字段2, OLD.id

    );

  -- DELETE 同步

  ELSIF (TG_OP = 'DELETE') THEN

    PERFORM dblink_exec(

      'DELETE FROM 目标表名 WHERE id=$1', OLD.id

    );

  END IF;

PERFORM dblink_disconnect();

  RETURN COALESCE(NEW, OLD);

END;

$$ LANGUAGE plpgsql;

CREATE TRIGGER trigger_sync_table

AFTER INSERT OR UPDATE OR DELETE ON 源表名

FOR EACH ROW EXECUTE FUNCTION sync_table_func();

wal_level = logical  # 必须修改
max_replication_slots = 10
max_wal_senders = 10

-- 创建发布（同步指定表）

CREATE PUBLICATION pub_target FOR TABLE 表1, 表2;

-- 授权复制权限

ALTER ROLE 账号 REPLICATION;

3、目标库创建订阅端

sql

-- 创建订阅，自动同步数据

CREATE SUBSCRIPTION sub_source

CONNECTION 'host=源IP port=5432 dbname=源库 user=账号 password=密码'

PUBLICATION pub_target;

pg_dump -h 源IP -U 用户 -d 库 -t 表 -F c -f dumpfile

pg_restore -h 目标IP -U 用户 -d 库 -t 表 dumpfile