replay_event

DECLARE

  query text;

BEGIN

    with

    event as (

        select * from lizsync.logged_actions where event_id = pevent_id

    )

    -- get primary key names

    , where_pks as (

        select array_to_string(array_agg(uid_column || '=' || quote_literal(row_data->uid_column)), ' AND ') as where_clause

          from lizsync.logged_relations r

          join event on relation_name = (schema_name || '.' || table_name)

    )

    select into query

        case

            when action = 'I' then

                'INSERT INTO ' || schema_name || '.' || table_name ||

                ' ('||(select string_agg(key, ',') from each(row_data))||') VALUES ' ||

                '('||(select string_agg(case when value is null then 'null' else quote_literal(value) end, ',') from each(row_data))||')'

            when action = 'D' then

                'DELETE FROM ' || schema_name || '.' || table_name ||

                ' WHERE ' || where_clause

            when action = 'U' then

                'UPDATE ' || schema_name || '.' || table_name ||

                ' SET ' || (select string_agg(key || '=' || case when value is null then 'null' else quote_literal(value) end, ',') from each(changed_fields)) ||

                ' WHERE ' || where_clause

        end

    from

        event, where_pks

    ;

​

    execute query;

END;

​