mimeo

pig build pkg mimeo;		# build rpm

pig repo add pgsql -u   # add both repo and update cache

pig install mimeo;		# install via package name, for the active PG version

pig install mimeo -v 18;   # install for PG 18
pig install mimeo -v 17;   # install for PG 17
pig install mimeo -v 16;   # install for PG 16
pig install mimeo -v 15;   # install for PG 15
pig install mimeo -v 14;   # install for PG 14

CREATE EXTENSION mimeo CASCADE; -- requires dblink

CREATE SCHEMA mimeo;
CREATE EXTENSION mimeo SCHEMA mimeo;

-- Create a dblink connection to the source database
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  -- from dblink_mapping
);

-- Refresh the snapshot
SELECT mimeo.refresh_snap('public.my_table');

SELECT mimeo.inserter_maker(
    p_src_table := 'public.events',
    p_control := 'created_at',  -- timestamp column
    p_dblink_id := 1
);

-- Refresh incrementally
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');