Репликация. Проблемы с PEOPLE ADDR - История изменений

Admin в 08:09, 3 апреля 2013

2013-04-03T08:09:31Z

Admin: /* 1. Получаем проблемный ID */

2012-09-19T06:40:13Z

‎1. Получаем проблемный ID

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

2012-09-19T06:39:41Z

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

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

2012-09-19T06:18:13Z

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

Admin: /* 2. Заравниваем таблиц на ADDR и PEOPLE_ADDR на всех подстанция */

2012-09-18T10:47:10Z

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

Admin: Новая страница: «== Причина возникновения == == Порядок действий == === 1. Получаем проблемный ID === SEL...»

2012-09-18T10:46:24Z

Новая страница: «== Причина возникновения == == Порядок действий == === 1. Получаем проблемный ID === <source lang="SQL"> SEL...»

Новая страница

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

== Порядок действий ==
=== 1. Получаем проблемный ID ===
<source lang="SQL">
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%'
</source>

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

<source lang="sql">
DECLARE
v_buffer_transfer_id NUMBER;
v_addr_id NUMBER;
v_people_id NUMBER;
v_people_addr NUMBER;
v_action NUMBER;
BEGIN
v_buffer_transfer_id := 167981000;

-- получитим значения 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 <> cur_station_id
AND cur_station_id = 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 = cur_bt_id))
OR ( (id = mis.cn_station_main
AND cur_station_id <> mis.cn_station_main)))
AND db_link IS NOT NULL)
LOOP
mis.pkg_replication.merge_table ('ADDR', c.dblink, v_addr_id);
mis.pkg_replication.merge_table ('PEOPLE', c.dblink, v_people_id);
commit;
END LOOP;
-- После этого нужно дождаться вызова (раз в пять минут)
-- PROPAGATE_BT_DICTIONARY_INFO
END;
</source>

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

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

← Предыдущая		Версия 08:09, 3 апреля 2013
Строка 75:		Строка 75:
	Выполняется раз в пять минут		Выполняется раз в пять минут

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

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

@@ Строка 2: / Строка 2: @@
 == Порядок действий ==
-=== 1. Получаем проблемный ID ===
+=== 1. Оцениваем масштабы бедствия ===
 <source lang="SQL">
-SELECT buffer_transfer_id
+SELECT *
    FROM mis.buffer_transfer_log a
   WHERE a.ERROR_TEXT LIKE '%MIS.FK_PEOPLE_ADDR$PEOPLE%'

@@ Строка 11: / Строка 11: @@
 === 2. Заравниваем таблицы на ADDR и PEOPLE_ADDR на всех подстанция ===
 <source lang="sql">
 DECLARE
      v_buffer_transfer_id   NUMBER;
@@ Строка 21: / Строка 22: @@
      v_action               VARCHAR2 (250);
 BEGIN
-     v_buffer_transfer_id := 167981000;
+     FOR cur_bt_id
-    -- получитим значения  PEOPLE_ADDR
+        -- получитим значения  PEOPLE_ADDR
-    SELECT key_field_value, action
+        SELECT key_field_value, action
-      INTO v_people_addr, v_action
+          INTO v_people_addr, v_action
-      FROM mis.buffer_transfer
+          FROM mis.buffer_transfer
-     WHERE table_name = 'PEOPLE_ADDR' AND id = v_buffer_transfer_id;
+         WHERE table_name = 'PEOPLE_ADDR' AND id = v_buffer_transfer_id;
-    -- Получим значения из таблиц MIS.ADDR и MIS.PEOPLE
+        -- Получим значения из таблиц MIS.ADDR и MIS.PEOPLE
-    SELECT addr_id, people_id
+        SELECT addr_id, people_id
-      INTO v_addr_id, v_people_id
+          INTO v_addr_id, v_people_id
-      FROM mis.people_addr
+          FROM mis.people_addr
-     WHERE id = v_people_addr;
+         WHERE id = v_people_addr;
-    FOR c
+        FOR c
-        IN (SELECT db_link, id /* получаем список всех подстанций куда нужно отнести запись*/
+            IN (SELECT db_link, id /* получаем список всех подстанций куда нужно отнести запись*/
-              FROM mis.station
+                  FROM mis.station
-             WHERE ( (id <> 1 AND 1 = mis.cn_station_main
+                 WHERE ( (id <> 1 AND 1 = mis.cn_station_main
-                      AND id NOT IN
+                          AND id NOT IN
-                              (SELECT ERROR_TEXT
+                                  (SELECT ERROR_TEXT
-                                 FROM mis.buffer_transfer_log
+                                     FROM mis.buffer_transfer_log
-                                WHERE step =
+                                    WHERE step =
-                                          'PROPAGATE_DICTIONARY_TABLE_STATION_SEND'
+                                              'PROPAGATE_DICTIONARY_TABLE_STATION_SEND'
-                                      AND buffer_transfer_id =
+                                          AND buffer_transfer_id =
-                                              v_buffer_transfer_id))
+                                                  v_buffer_transfer_id))
-                    OR ( (id = mis.cn_station_main
+                        OR ( (id = mis.cn_station_main
-                          AND 1 <> mis.cn_station_main)))
+                              AND 1 <> mis.cn_station_main)))
-                   AND db_link IS NOT NULL)
+                       AND db_link IS NOT NULL)
-    LOOP
+        LOOP
-        mis.pkg_replication.merge_table ('ADDR', c.db_link, v_addr_id);
+            mis.pkg_replication.merge_table ('ADDR', c.db_link, v_addr_id);
-        mis.pkg_replication.merge_table ('PEOPLE', c.db_link, v_people_id);
+            mis.pkg_replication.merge_table ('PEOPLE',
-        COMMIT;
+                                             c.db_link,
-        DBMS_OUTPUT.put_line (
+                                             v_people_id);
-            TO_CHAR (v_buffer_transfer_id) || '::' || c.db_link);
+            COMMIT;
-     END LOOP;
+            DBMS_OUTPUT.put_line (
 -- После этого нужно дождаться вызова (раз в пять минут)
 --    PROPAGATE_BT_DICTIONARY_INFO
 END;
 </source>

@@ Строка 10: / Строка 10: @@
 </source>
-=== 2. Заравниваем таблиц на ADDR и PEOPLE_ADDR на всех подстанция ===
+=== 2. Заравниваем таблицы на ADDR и PEOPLE_ADDR на всех подстанция ===
 В теле скрипта не забыть поменять v_buffer_transfer_id :=.