mimeo

pig build pkg mimeo         # 构建 RPM 包

pig repo add pgsql -u          # 添加仓库并更新缓存

CREATE EXTENSION mimeo CASCADE;  -- 依赖: dblink

CREATE SCHEMA mimeo;
CREATE EXTENSION mimeo SCHEMA mimeo;

-- 创建到源数据库的 dblink 连接
SELECT mimeo.dblink_mapping_create(
    p_mapping_name := 'source_db',
    p_data_source := 'host=sourcehost dbname=sourcedb user=replicator password=secret',
    p_superuser := true
);

SELECT mimeo.snapshot_maker(
    p_src_table := 'public.my_table',
    p_dblink_id := 1  -- 来自 dblink_mapping
);

-- 刷新快照
SELECT mimeo.refresh_snap('public.my_table');

SELECT mimeo.inserter_maker(
    p_src_table := 'public.events',
    p_control := 'created_at',  -- 时间戳列
    p_dblink_id := 1
);

-- 增量刷新
SELECT mimeo.refresh_inserter('public.events');

SELECT mimeo.updater_maker(
    p_src_table := 'public.orders',
    p_control := 'updated_at',
    p_dblink_id := 1
);

SELECT mimeo.refresh_updater('public.orders');

SELECT mimeo.dml_maker(
    p_src_table := 'public.accounts',
    p_dblink_id := 1
);

SELECT mimeo.refresh_dml('public.accounts');