ZqF4EDS1

1SET search_path TO ifd_test, test;
2SHOW search_path;
3CREATE SCHEMA IF NOT EXISTS test;
4
5DROP TABLE IF EXISTS esb_out_a_report;
6CREATE TABLE IF NOT EXISTS esb_out_a_report (
7  message_id            SERIAL    NOT NULL PRIMARY KEY,
8  operation_code        INT                DEFAULT NULL,
9  message_dt            TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
10  entity_id             VARCHAR(250)       DEFAULT NULL,
11  receiver_id           INT                DEFAULT NULL,
12  maintenance_flg       INT       NOT NULL,
13  business_data_int     INT                DEFAULT NULL,
14  business_data_varchar VARCHAR(250)       DEFAULT NULL,
15  business_data_date    DATE               DEFAULT NULL
16);
17
18COMMENT ON COLUMN esb_out_a_report.message_id
19IS 'Последовательная техническая нумерация сообщений. Генерируется автоматически на уровне DB (автоинкремент).';
20COMMENT ON COLUMN esb_out_a_report.operation_code
21IS 'Тип операции в системе-источнике, заполняется при наличии требований. Заполняется источником: 0 – Вставка, 1 – Обновление, 2 – Удаление';
22COMMENT ON COLUMN esb_out_a_report.message_dt
23IS 'Timestamp (дата и время) возникновения записи в таблице. Заполняется автоматически, используется для расследования инцидентов. Заполняется источником. Заполняется автоматически на уровне БД.';
24COMMENT ON COLUMN esb_out_a_report.entity_id
25IS 'ID сущности используемый в системе. Используется для расследования инцидентов. Заполняется на стороне источника. Для составного ключа используется разделитель «;».';
26COMMENT ON COLUMN esb_out_a_report.receiver_id
27IS 'Содержит дополнительный признак в случае повторных и корректирующих выгрузок, указывающий, какой из потоков является получателем этих сообщений:
28null – все потоки являются получателем этого сообщения
29UID потока – только поток с соответствующим UID должен осуществить доставку. Другие потоки игнорируют эти сообщения, прокручивая счетчик очереди соответствующим образом
30При регламентной публикации сообщений: Система-источник заполняет поле значением null
31При повторной выгрузке: Шина заполняет поле значением UID потока для которого предназначается выгрузка, либо null, если выгрузка предназначена всем получателям
32При корректирующей выгрузке:
33Система-источник заполняет поле значением UID потока, запросившего корректирующую выгрузку (поле receiver_id в таблице запроса корректирующей выгрузки).';
34COMMENT ON COLUMN esb_out_a_report.maintenance_flg
35IS 'Флаг с признаком корректирующей выгрузки.:
360 – Регламентная публикация пакетных данных
371 – Корректирующая выгрузка пакетных данных
38Заполняется системой-источником';
39COMMENT ON COLUMN esb_out_a_report.business_data_int
40IS 'Бизнес данные в формате integer';
41COMMENT ON COLUMN esb_out_a_report.business_data_varchar
42IS 'Бизнес данные в формате varchar';
43COMMENT ON COLUMN esb_out_a_report.business_data_date
44IS 'Бизнес данные в формате date';
45
46
47TRUNCATE TABLE esb_out_a_report; -- из ->
48
49CREATE TEMPORARY SEQUENCE IF NOT EXISTS seq
50  START 1;
51CREATE TEMPORARY SEQUENCE IF NOT EXISTS seq_2
52  INCREMENT BY 5
53  START 5;
54
55INSERT INTO esb_out_a_report(message_id,
56                             entity_id,
57                             maintenance_flg,
58                             operation_code,
59                             receiver_id,
60                             business_data_date,
61                             message_dt,
62                             business_data_int,
63                             business_data_varchar)
64SELECT seq,
65       CONCAT('id #', seq),
66       seq,
67       RANDOM() * 666,
68       NULL,
69       NOW(),
70       CURRENT_TIMESTAMP,
71       2147483647,
72       (SELECT MD5(RANDOM() :: TEXT))
73FROM generate_series(1, 500) AS seq;