Первинне завантаження даних реєстру (Initial load)

CREATE OR REPLACE PROCEDURE p_load_table_from_csv(
  p_table_name text,
  p_file_name text,
  p_table_columns text[],
  p_target_table_columns text[] DEFAULT NULL::text[]
);

<databaseChangeLog
	xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:ext="http://www.liquibase.org/xml/ns/dbchangelog-ext"
        xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.2.xsd
        http://www.liquibase.org/xml/ns/dbchangelog-ext http://www.liquibase.org/xml/ns/dbchangelog-ext.xsd">
	<property  name="dataLoadPath"  value="D:\PostgreSQL\csv\"/>
	<changeSet author="registry owner" id="load data to dictionaries">
		<sql dbms="postgresql" endDelimiter=";" splitStatements="true" stripComments="true">
            CALL p_load_table_from_csv('research','${dataLoadPath}01-Typy doslidgen.csv', array['code','research_type'], array['research_type']);
            CALL p_load_table_from_csv('refusal_reason','${dataLoadPath}02-Prichiny vidmov.csv', array['code','document_type','name','constant_code'], array['document_type','name','constant_code']);
            CALL p_load_table_from_csv('kopfg','${dataLoadPath}05-kopfg.csv', array['code','name']);
            CALL p_load_table_from_csv('solution_type','${dataLoadPath}06-Typy rishen.csv', array['id','name','constant_code'], array['name','constant_code']);
            CALL p_load_table_from_csv('factor','${dataLoadPath}14-Himichni_factory_OBRV.csv', array['code','name','col3','col4'], array['name','factor_type::''Хімічний: ОБРВ''']);
            CALL p_load_table_from_csv('factor','${dataLoadPath}15-Himichni factory dovilni.csv', array['code','name'], array['name','factor_type::''Хімічний: довільні''']);
        </sql>
	</changeSet>
</databaseChangeLog>

-- Створення тимчасової проміжної таблиці, яка відповідає структурі CSV-файлу
CREATE TABLE account_csv_stage (username text, bank_number text);
-- Завантаження даних з CSV-файлу в проміжну таблицю
COPY account_csv_stage (username, bank_number)
FROM
  '${dataLoadPath}account.csv' WITH (HEADER, FORMAT CSV);
-- Вставка даних з проміжної таблиці в основну та історичну таблиці з одночасним заповненням метаданих
WITH main_table_cte AS (
  INSERT INTO account (
    username, bank_number, ddm_created_by,
    ddm_updated_by
  )
  SELECT
    username,
    bank_number,
    'admin',
    'admin'
  FROM
    account_csv_stage RETURNING *
) INSERT INTO account_hst (
  id, username, bank_number, ddm_created_by,
  ddm_created_at, ddm_dml_op, ddm_system_id,
  ddm_application_id, ddm_business_process_id
)
SELECT
  id,
  username,
  bank_number,
  ddm_created_by,
  CURRENT_TIMESTAMP,
  'I' as ddm_dml_op,
  (
    SELECT
      ss.system_id
    FROM
      ddm_source_system ss
    WHERE
      ss.system_name = 'initial load'
  ) ddm_system_id,
  (
    SELECT
      sa.application_id
    FROM
      ddm_source_application sa
    WHERE
      sa.application_name = 'initial load'
  ) ddm_application_id,
  (
    SELECT
      sb.business_process_id
    FROM
      ddm_source_business_process sb
    WHERE
      sb.business_process_name = 'initial load process'
  ) ddm_business_process_id
FROM
  main_table_cte;
-- Видалення тимчасової проміжної таблиці після завершення операцій
DROP
  TABLE account_csv_stage;