micord/ervu-dashboard-etl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ERVU-505: fixes to normal table

Browse source
This commit is contained in:
adel.ka 2025-07-28 14:43:14 +03:00
parent fa1b7899c7
commit d019dfe0dd
13 changed files with 1006 additions and 961 deletions
Download patch file Download diff file Expand all files Collapse all files

181
mappings_new/info_recruits/citizen_tables/child/delta_child.hpl
View file

@ -31,6 +31,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>768</xloc>
<yloc>224</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -155,7 +242,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -184,7 +275,6 @@ SELECT
FROM ervu_dashboard.citizen r
JOIN child ON r.recruit_id = child.recruit_id;
</sql>
<variables_active>Y</variables_active>
<attributes/>
@ -193,93 +283,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>352</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>768</xloc>
<yloc>224</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

184
mappings_new/info_recruits/citizen_tables/child/parallel/child_flow1.hpl
View file

@ -42,6 +42,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>592</xloc>
<yloc>144</yloc>
</GUI>
</transform>
<transform>
<name>Get variables</name>
<type>GetVariable</type>
@ -230,7 +317,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -267,97 +358,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>288</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<delete_field/>
<execute_each_row>Y</execute_each_row>
<insert_field/>
<quoteString>N</quoteString>
<read_field/>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<update_field/>
<attributes/>
<GUI>
<xloc>592</xloc>
<yloc>144</yloc>
</GUI>
</transform>
<transform_error_handling>
<error>
<source_transform>Select values 4 2</source_transform>

180
mappings_new/info_recruits/citizen_tables/child/parallel/child_flow2.hpl
View file

@ -31,6 +31,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>704</xloc>
<yloc>128</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -155,7 +242,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -192,93 +283,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>288</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>704</xloc>
<yloc>128</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

180
mappings_new/info_recruits/citizen_tables/child/parallel/child_flow3.hpl
View file

@ -31,6 +31,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>800</xloc>
<yloc>208</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -155,7 +242,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -192,93 +283,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>352</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>800</xloc>
<yloc>208</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

180
mappings_new/info_recruits/citizen_tables/child/parallel/child_flow4.hpl
View file

@ -31,6 +31,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>624</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -155,7 +242,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -192,93 +283,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>320</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>624</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

180
mappings_new/info_recruits/citizen_tables/child/parallel/child_flow5.hpl
View file

@ -31,6 +31,93 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>688</xloc>
<yloc>224</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -155,7 +242,11 @@ SELECT
r.recruit_id::uuid AS recruit_id,
ch->>'id' AS child_external_id,
NULLIF(ch->>'idERN', '') AS child_id_ern,
ch->>'naimRodstvSvyazReb' AS kinship_type,
CASE NULLIF(ch->>'rodstvSvyazReb', '')::int
WHEN 1 THEN 3
WHEN 2 THEN 4
ELSE NULL
END AS kinship_type,
ch->'svedFLBS'->'fio'->>'familiya' AS last_name,
ch->'svedFLBS'->'fio'->>'imya' AS first_name,
@ -192,93 +283,6 @@ JOIN child ON r.recruit_id = child.recruit_id;
<yloc>368</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>child_external_id</name>
</argument>
<argument>
<name>child_id_ern</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>birth_az_number</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_child (
recruit_id,
child_external_id,
child_id_ern,
kinship_type,
last_name,
first_name,
middle_name,
full_name,
birth_date,
death_date,
death_az_number,
birth_az_number
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, child_external_id)
DO UPDATE SET
child_id_ern = EXCLUDED.child_id_ern,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
first_name = EXCLUDED.first_name,
middle_name = EXCLUDED.middle_name,
full_name = EXCLUDED.full_name,
birth_date = EXCLUDED.birth_date,
death_date = EXCLUDED.death_date,
death_az_number = EXCLUDED.death_az_number,
birth_az_number = EXCLUDED.birth_az_number;</sql>
<attributes/>
<GUI>
<xloc>688</xloc>
<yloc>224</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

2
mappings_new/info_recruits/citizen_tables/citizen_spouse/delta_citizen_spouse.hpl
View file

@ -285,7 +285,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,

50
mappings_new/info_recruits/citizen_tables/citizen_spouse/job_citizen_spouse.hwf
View file

@ -108,13 +108,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow1.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F1</name>
<stream_name>IDM_FLOW1</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -138,13 +141,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow2.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F2</name>
<stream_name>IDM_FLOW2</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -168,13 +174,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow3.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F3</name>
<stream_name>IDM_FLOW3</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -198,13 +207,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow4.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F4</name>
<stream_name>IDM_FLOW4</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -228,13 +240,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow5.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F5</name>
<stream_name>IDM_FLOW5</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -672,13 +687,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow1.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F1</name>
<stream_name>IDM_FLOW1</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -702,13 +720,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow2.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F2</name>
<stream_name>IDM_FLOW2</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -732,13 +753,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow3.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F3</name>
<stream_name>IDM_FLOW3</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -762,13 +786,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow4.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F4</name>
<stream_name>IDM_FLOW4</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
@ -792,13 +819,16 @@
<clear_files>N</clear_files>
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<exec_per_row>Y</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow5.hpl</filename>
<logext/>
<logfile/>
<loglevel>Basic</loglevel>
<parameters>
<parameter>
<name>ID_F5</name>
<stream_name>IDM_FLOW5</stream_name>
<value/>
</parameter>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>

6
mappings_new/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow1.hpl
View file

@ -101,11 +101,8 @@
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<delete_field/>
<execute_each_row>Y</execute_each_row>
<insert_field/>
<quoteString>N</quoteString>
<read_field/>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
@ -141,7 +138,6 @@ DO UPDATE SET
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<update_field/>
<attributes/>
<GUI>
<xloc>704</xloc>
@ -363,7 +359,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,

206
mappings_new/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow2.hpl
View file

@ -31,6 +31,108 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>720</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -182,7 +284,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,
@ -212,108 +314,6 @@ FROM ervu_dashboard.citizen r
<yloc>288</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>720</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

206
mappings_new/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow3.hpl
View file

@ -31,6 +31,108 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>848</xloc>
<yloc>208</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -182,7 +284,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,
@ -212,108 +314,6 @@ FROM ervu_dashboard.citizen r
<yloc>352</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>848</xloc>
<yloc>208</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

206
mappings_new/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow4.hpl
View file

@ -31,6 +31,108 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>688</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -182,7 +284,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,
@ -212,108 +314,6 @@ FROM ervu_dashboard.citizen r
<yloc>320</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>688</xloc>
<yloc>176</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>

206
mappings_new/info_recruits/citizen_tables/citizen_spouse/parallel/citizen_spouse_flow5.hpl
View file

@ -31,6 +31,108 @@
<enabled>Y</enabled>
</hop>
</order>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>736</xloc>
<yloc>192</yloc>
</GUI>
</transform>
<transform>
<name>Insert / update</name>
<type>InsertUpdate</type>
@ -182,7 +284,7 @@ SELECT
r.recruit_id,
supr.spouse_external_id,
supr.spouse_id_ern,
supr.supr->>'rodstvSvyazSuprugNaim' AS kinship_type,
NULLIF(supr.supr->>'rodstvSvyazSuprug', '')::int AS kinship_type,
supr.supr->'svedFLBS'->'fio'->>'familiya' AS last_name,
supr.supr->'svedFLBS'->'fio'->>'imya' AS first_name,
supr.supr->'svedFLBS'->'fio'->>'otchestvo' AS middle_name,
@ -212,108 +314,6 @@ FROM ervu_dashboard.citizen r
<yloc>368</yloc>
</GUI>
</transform>
<transform>
<name>Execute SQL script</name>
<type>ExecSql</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<arguments>
<argument>
<name>recruit_id</name>
</argument>
<argument>
<name>birth_date</name>
</argument>
<argument>
<name>death_az_number</name>
</argument>
<argument>
<name>death_date</name>
</argument>
<argument>
<name>divorce_az_number</name>
</argument>
<argument>
<name>first_name</name>
</argument>
<argument>
<name>full_name</name>
</argument>
<argument>
<name>information_excluded</name>
</argument>
<argument>
<name>kinship_type</name>
</argument>
<argument>
<name>last_name</name>
</argument>
<argument>
<name>marriage_az_number</name>
</argument>
<argument>
<name>marriage_date</name>
</argument>
<argument>
<name>middle_name</name>
</argument>
<argument>
<name>spouse_external_id</name>
</argument>
<argument>
<name>spouse_id_ern</name>
</argument>
</arguments>
<connection>ervu-dashboard</connection>
<execute_each_row>Y</execute_each_row>
<quoteString>N</quoteString>
<replace_variables>N</replace_variables>
<set_params>Y</set_params>
<single_statement>N</single_statement>
<sql>INSERT INTO ervu_dashboard.citizen_spouse (
recruit_id,
birth_date,
death_az_number,
death_date,
divorce_az_number,
first_name,
full_name,
information_excluded,
kinship_type,
last_name,
marriage_az_number,
marriage_date,
middle_name,
spouse_external_id,
spouse_id_ern
) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
ON CONFLICT (recruit_id, spouse_external_id)
DO UPDATE SET
birth_date = EXCLUDED.birth_date,
death_az_number = EXCLUDED.death_az_number,
death_date = EXCLUDED.death_date,
divorce_az_number = EXCLUDED.divorce_az_number,
first_name = EXCLUDED.first_name,
full_name = EXCLUDED.full_name,
information_excluded = EXCLUDED.information_excluded,
kinship_type = EXCLUDED.kinship_type,
last_name = EXCLUDED.last_name,
marriage_az_number = EXCLUDED.marriage_az_number,
marriage_date = EXCLUDED.marriage_date,
middle_name = EXCLUDED.middle_name,
spouse_id_ern = EXCLUDED.spouse_id_ern;</sql>
<attributes/>
<GUI>
<xloc>736</xloc>
<yloc>192</yloc>
</GUI>
</transform>
<transform_error_handling>
</transform_error_handling>
<attributes/>