Просмотр исходного текста страницы Репликация. Проблемы с PEOPLE ADDR

== Причина возникновения ==

== Порядок действий ==
=== 1. Оцениваем масштабы бедствия ===
<source lang="SQL">
SELECT *
  FROM mis.buffer_transfer_log a
 WHERE a.ERROR_TEXT LIKE '%MIS.FK_PEOPLE_ADDR$PEOPLE%'
       OR a.ERROR_TEXT LIKE '%MIS.FK_PEOPLE_ADDR$ADDR%'
</source>

=== 2. Заравниваем таблицы на ADDR и PEOPLE_ADDR на всех подстанция ===

<source lang="sql">
-- Внимание реплицирует все застрявщие записи по PEOPLE_ADDR
-- для одной записи временя выполнянения порядка 20 сек, поэтому общее время может быть большим
DECLARE
    v_buffer_transfer_id   NUMBER;
    v_addr_id              NUMBER;
    v_people_id            NUMBER;
    v_people_addr          NUMBER;
    v_action               VARCHAR2 (250);
BEGIN
    FOR cur_bt_id
        IN (SELECT buffer_transfer_id
              FROM mis.buffer_transfer_log a
             WHERE a.ERROR_TEXT LIKE '%MIS.FK_PEOPLE_ADDR$PEOPLE%'
                   OR a.ERROR_TEXT LIKE '%MIS.FK_PEOPLE_ADDR$ADDR%')
    LOOP
        v_buffer_transfer_id := cur_bt_id.buffer_transfer_id;

        -- получитим значения  PEOPLE_ADDR
        SELECT key_field_value, action
          INTO v_people_addr, v_action
          FROM mis.buffer_transfer
         WHERE table_name = 'PEOPLE_ADDR' AND id = v_buffer_transfer_id;

        -- Получим значения из таблиц MIS.ADDR и MIS.PEOPLE
        SELECT addr_id, people_id
          INTO v_addr_id, v_people_id
          FROM mis.people_addr
         WHERE id = v_people_addr;

        FOR c
            IN (SELECT db_link, id /* получаем список всех подстанций куда нужно отнести запись*/
                  FROM mis.station
                 WHERE ( (id <> 1 AND 1 = mis.cn_station_main
                          AND id NOT IN
                                  (SELECT ERROR_TEXT
                                     FROM mis.buffer_transfer_log
                                    WHERE step =
                                              'PROPAGATE_DICTIONARY_TABLE_STATION_SEND'
                                          AND buffer_transfer_id =
                                                  v_buffer_transfer_id))
                        OR ( (id = mis.cn_station_main
                              AND 1 <> mis.cn_station_main)))
                       AND db_link IS NOT NULL)
        LOOP
            mis.pkg_replication.merge_table ('ADDR', c.db_link, v_addr_id);
            mis.pkg_replication.merge_table ('PEOPLE',
                                             c.db_link,
                                             v_people_id);
            COMMIT;
            DBMS_OUTPUT.put_line (
                TO_CHAR (v_buffer_transfer_id) || '::' || c.db_link);
        END LOOP;                                                  -- for c in
    END LOOP;                                               --   FOR cur_BT_ID
-- После этого нужно дождаться вызова (раз в пять минут)
--    PROPAGATE_BT_DICTIONARY_INFO
END;

</source>

=== Дождаться выполнения PROPAGATE_BT_DICTIONARY_INFO ===
Выполняется раз в пять минут


== Проблема с MIS.FK_CALL_ADDR$CALL ==
Существует также проблема с передачей адреса вызова, т.е. адрес есть а вызова нет, происходит если вызов был передан на другую подстанцию

[[Категория:Скорая помощь]]