small fixes
This commit is contained in:
parent
de196866b7
commit
8da584ac4f
7 changed files with 848 additions and 1 deletions
96
сonfig-data-executor/config-examples/arangorequest.xml
Normal file
96
сonfig-data-executor/config-examples/arangorequest.xml
Normal file
|
|
@ -0,0 +1,96 @@
|
|||
<Requests>
|
||||
<AqlRequest>
|
||||
<RequestArgument>
|
||||
<Id>edges</Id>
|
||||
<AqlCollectionReads>
|
||||
<AqlCollectionRead>applications</AqlCollectionRead>
|
||||
<AqlCollectionRead>subject</AqlCollectionRead>
|
||||
<AqlCollectionRead>history</AqlCollectionRead>
|
||||
<AqlCollectionRead>edges</AqlCollectionRead>
|
||||
</AqlCollectionReads>
|
||||
</RequestArgument>
|
||||
<AqlConnectionParams>
|
||||
<Host>localhost</Host>
|
||||
<Port>8529</Port>
|
||||
<Username>userAQL1</Username>
|
||||
<Password>passwordAQL1</Password>
|
||||
<Database>databaseAQL1</Database>
|
||||
</AqlConnectionParams>
|
||||
</AqlRequest>
|
||||
|
||||
<AqlRequest>
|
||||
<RequestArgument>
|
||||
<Id>applications</Id>
|
||||
<AqlCollectionReads>
|
||||
<AqlCollectionRead>applications</AqlCollectionRead>
|
||||
<AqlCollectionRead>subject</AqlCollectionRead>
|
||||
<AqlCollectionRead>history</AqlCollectionRead>
|
||||
<AqlCollectionRead>edges</AqlCollectionRead>
|
||||
</AqlCollectionReads>
|
||||
</RequestArgument>
|
||||
<AqlConnectionParams>
|
||||
<Host>localhost</Host>
|
||||
<Port>8529</Port>
|
||||
<Username>userAQL1</Username>
|
||||
<Password>passwordAQL1</Password>
|
||||
<Database>databaseAQL1</Database>
|
||||
</AqlConnectionParams>
|
||||
</AqlRequest>
|
||||
|
||||
<AqlRequest>
|
||||
<RequestArgument>
|
||||
<Id>subject</Id>
|
||||
<AqlCollectionReads>
|
||||
<AqlCollectionRead>applications</AqlCollectionRead>
|
||||
<AqlCollectionRead>subject</AqlCollectionRead>
|
||||
<AqlCollectionRead>history</AqlCollectionRead>
|
||||
<AqlCollectionRead>edges</AqlCollectionRead>
|
||||
</AqlCollectionReads>
|
||||
</RequestArgument>
|
||||
<AqlConnectionParams>
|
||||
<Host>localhost</Host>
|
||||
<Port>8529</Port>
|
||||
<Username>userAQL1</Username>
|
||||
<Password>passwordAQL1</Password>
|
||||
<Database>databaseAQL1</Database>
|
||||
</AqlConnectionParams>
|
||||
</AqlRequest>
|
||||
|
||||
<AqlRequest>
|
||||
<RequestArgument>
|
||||
<Id>history</Id>
|
||||
<AqlCollectionReads>
|
||||
<AqlCollectionRead>applications</AqlCollectionRead>
|
||||
<AqlCollectionRead>subject</AqlCollectionRead>
|
||||
<AqlCollectionRead>history</AqlCollectionRead>
|
||||
<AqlCollectionRead>edges</AqlCollectionRead>
|
||||
</AqlCollectionReads>
|
||||
</RequestArgument>
|
||||
<AqlConnectionParams>
|
||||
<Host>localhost</Host>
|
||||
<Port>8529</Port>
|
||||
<Username>userAQL1</Username>
|
||||
<Password>passwordAQL1</Password>
|
||||
<Database>databaseAQL1</Database>
|
||||
</AqlConnectionParams>
|
||||
</AqlRequest>
|
||||
|
||||
<AqlRequest>
|
||||
<RequestArgument>
|
||||
<Id>interdepreq</Id>
|
||||
<AqlCollectionReads>
|
||||
<AqlCollectionRead>applications</AqlCollectionRead>
|
||||
<AqlCollectionRead>subject</AqlCollectionRead>
|
||||
<AqlCollectionRead>history</AqlCollectionRead>
|
||||
<AqlCollectionRead>edges</AqlCollectionRead>
|
||||
</AqlCollectionReads>
|
||||
</RequestArgument>
|
||||
<AqlConnectionParams>
|
||||
<Host>localhost</Host>
|
||||
<Port>8529</Port>
|
||||
<Username>userAQL1</Username>
|
||||
<Password>passwordAQL1</Password>
|
||||
<Database>databaseAQL1</Database>
|
||||
</AqlConnectionParams>
|
||||
</AqlRequest>
|
||||
</Requests>
|
||||
183
сonfig-data-executor/config-examples/block.xml
Normal file
183
сonfig-data-executor/config-examples/block.xml
Normal file
|
|
@ -0,0 +1,183 @@
|
|||
<Requests>
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
begin
|
||||
update recruits
|
||||
set current_recruitment_id = 'ИДЕНТИФИКАТОР ТЕСТОВОГО ВК'
|
||||
,target_recruitment_id = 'ИДЕНТИФИКАТОР ТЕСТОВОГО ВК'
|
||||
,department_id_old = 'ИДЕНТИФИКАТОР ТЕСТОВОГО ВК'
|
||||
,system_pgs_status = '13'
|
||||
,extra_info = jsonb_set(coalesce(extra_info,'{}'::jsonb), '{blocked}',
|
||||
('{"cur":'|| coalesce('"'||current_recruitment_id::text||'"','null')||
|
||||
',"trg":'|| coalesce('"'||target_recruitment_id::text||'"','null')||
|
||||
',"dio":'|| coalesce('"'||department_id_old::text||'"','null')||
|
||||
',"st":'|| coalesce('"'||system_pgs_status::text||'"','null')||'}')::jsonb
|
||||
)
|
||||
where ${clause};
|
||||
end
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM subpoena_history where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena_appearance where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena_send_info where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
|
||||
DELETE FROM notification_item where restriction_document_item_id in (
|
||||
select id from restriction_document_item where restriction_document_create_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause})));
|
||||
DELETE FROM notification_item where restriction_document_item_id in (
|
||||
select id from restriction_document_item where restriction_document_cancel_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause})));
|
||||
|
||||
DELETE FROM restriction_document_item where restriction_document_create_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause}));
|
||||
DELETE FROM restriction_document_item where restriction_document_cancel_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause}));
|
||||
DELETE FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE
|
||||
FROM incident_history
|
||||
where incident_id in (select id from incident where ${clause});
|
||||
DELETE FROM incident where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM notifications where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
DECLARE
|
||||
recruitIds uuid[] := '{${ids}}';
|
||||
importIds uuid[] := ARRAY(SELECT import_id
|
||||
FROM import_results
|
||||
WHERE recruit_id = ANY (recruitIds));
|
||||
BEGIN
|
||||
WITH ImportDeletes AS (DELETE FROM import_journal_start WHERE import_id = ANY (importIds) RETURNING journal_id)
|
||||
DELETE
|
||||
FROM journal
|
||||
WHERE id IN (SELECT journal_id FROM ImportDeletes);
|
||||
|
||||
DELETE FROM import_journal_finish WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_events_journal WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_validation_errors WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_results WHERE import_id = ANY (importIds);
|
||||
DELETE FROM uploaded_files WHERE extra_info ->> 'importId' = ANY (importIds::text[]);
|
||||
DELETE FROM object_history WHERE object_id = ANY (recruitIds);
|
||||
DELETE FROM object_versions WHERE object_id = ANY (recruitIds);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
</Requests>
|
||||
67
сonfig-data-executor/config-examples/removeFromCallList.xml
Normal file
67
сonfig-data-executor/config-examples/removeFromCallList.xml
Normal file
|
|
@ -0,0 +1,67 @@
|
|||
<Requests>
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM summoned_list where ${clause};
|
||||
DELETE FROM recruit_active_list where ${clause};
|
||||
DELETE FROM documents where ${clause};
|
||||
DELETE FROM subpoena where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
begin
|
||||
update recruits
|
||||
set current_recruitment_id = jsonb_extract_path_text(extra_info,'blocked','cur')::uuid
|
||||
,target_recruitment_id = jsonb_extract_path_text(extra_info,'blocked','trg')::uuid
|
||||
,department_id_old = jsonb_extract_path_text(extra_info,'blocked','dio')::uuid
|
||||
,system_pgs_status = '1.2'
|
||||
,conscription = null
|
||||
,extra_info = extra_info - ('blocked')
|
||||
where ${clause};
|
||||
end
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
</Requests>
|
||||
456
сonfig-data-executor/config-examples/removeFromSystem.xml
Normal file
456
сonfig-data-executor/config-examples/removeFromSystem.xml
Normal file
|
|
@ -0,0 +1,456 @@
|
|||
<Requests>
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM subpoena_history where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena_appearance where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena_send_info where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
|
||||
DELETE FROM notification_item where restriction_document_item_id in (
|
||||
select id from restriction_document_item where restriction_document_create_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause})));
|
||||
DELETE FROM notification_item where restriction_document_item_id in (
|
||||
select id from restriction_document_item where restriction_document_cancel_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause})));
|
||||
|
||||
DELETE FROM restriction_document_item_history WHERE ${clause};
|
||||
DELETE FROM restriction_document_item where restriction_document_create_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause}));
|
||||
DELETE FROM restriction_document_item where restriction_document_cancel_id in (
|
||||
select id FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause}));
|
||||
DELETE FROM restriction_document where subpoena_id in (select id FROM subpoena where ${clause});
|
||||
DELETE FROM subpoena where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- last sql from 002_2-ervu_subpoena_registry_delete_all_with_recruit -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruits WHERE ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM decision where ${clause};
|
||||
DELETE FROM foreign_decision where ${clause};
|
||||
DELETE FROM infringement where ${clause};
|
||||
DELETE FROM system_document where attachment_id in (SELECT id FROM attachment where ${clause}) ;
|
||||
DELETE FROM attachment where ${clause};
|
||||
DELETE FROM recruit where id = any (var1);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- last sql from 005-ervu_decision_document-delete-recruit -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruit where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- FIX -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
DECLARE
|
||||
recruitIds uuid[] := '{${ids}}';
|
||||
importIds uuid[] := ARRAY(SELECT import_id
|
||||
FROM import_results
|
||||
WHERE recruit_id = ANY (recruitIds));
|
||||
BEGIN
|
||||
WITH ImportDeletes AS (DELETE FROM import_journal_start WHERE import_id = ANY (importIds) RETURNING journal_id)
|
||||
DELETE
|
||||
FROM journal
|
||||
WHERE id IN (SELECT journal_id FROM ImportDeletes);
|
||||
|
||||
DELETE FROM import_journal_finish WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_events_journal WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_validation_errors WHERE import_id = ANY (importIds);
|
||||
DELETE FROM import_results WHERE import_id = ANY (importIds);
|
||||
DELETE FROM uploaded_files WHERE extra_info ->> 'importId' = ANY (importIds::text[]);
|
||||
DELETE FROM object_history WHERE object_id = ANY (recruitIds);
|
||||
DELETE FROM object_versions WHERE object_id = ANY (recruitIds);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM notifications where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE
|
||||
FROM incident_history
|
||||
where incident_id in (select id from incident where ${clause});
|
||||
DELETE FROM incident where ${clause};
|
||||
DELETE FROM recruits where id = any (var1);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- last sql from 007_2-ervu_incidents-delete-all_of_recruit -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruits where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruits_info where ${clause};
|
||||
DELETE FROM recruit_xml_data where ${clause};
|
||||
DELETE FROM recruits_history where ${clause};
|
||||
DELETE FROM application where ${clause};
|
||||
DELETE FROM department_history where ${clause};
|
||||
DELETE FROM documents where ${clause};
|
||||
DELETE FROM decision where ${clause};
|
||||
DELETE FROM personal_documents where ${clause};
|
||||
DELETE FROM recruit_private_file where ${clause};
|
||||
DELETE FROM system_documents where ${clause};
|
||||
DELETE FROM system_document_dto where ${clause};
|
||||
DELETE FROM subpoena_dto where ${clause};
|
||||
DELETE FROM attachments where ${clause};
|
||||
DELETE FROM summoned_list where ${clause};
|
||||
DELETE FROM recruits where id = any (var1);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- last sql from 001-ervu_person_registry-delete-recruit -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruits where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM appeal_document where ${clause};
|
||||
DELETE FROM recruit where id = any (var1);
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<!-- last sql from 009_1-ervu_appeal_document-delete-appeal-with-recruit -->
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
DELETE FROM recruit where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
delete from cruit_extract where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
BEGIN
|
||||
delete from application_info where ${clause};
|
||||
END
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<RequestArguments>
|
||||
<RequestArgument>
|
||||
<Id>recruit_id</Id>
|
||||
</RequestArgument>
|
||||
</RequestArguments>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
</Requests>
|
||||
13
сonfig-data-executor/config-examples/s3request.xml
Normal file
13
сonfig-data-executor/config-examples/s3request.xml
Normal file
|
|
@ -0,0 +1,13 @@
|
|||
<Requests>
|
||||
<S3Request>
|
||||
<S3ConnectionParams>
|
||||
<S3Key>minioadmin</S3Key>
|
||||
<S3Secret>minioadmin</S3Secret>
|
||||
<Host>127.0.0.1</Host>
|
||||
<Port>9000</Port>
|
||||
<ContentType>application/octet-stream</ContentType>
|
||||
<Method>DELETE</Method>
|
||||
<Body></Body>
|
||||
</S3ConnectionParams>
|
||||
</S3Request>
|
||||
</Requests>
|
||||
32
сonfig-data-executor/config-examples/unblock.xml
Normal file
32
сonfig-data-executor/config-examples/unblock.xml
Normal file
|
|
@ -0,0 +1,32 @@
|
|||
<Requests>
|
||||
<SqlRequest>
|
||||
<RequestURL>
|
||||
<![CDATA[
|
||||
DO
|
||||
$$
|
||||
begin
|
||||
update recruits
|
||||
set current_recruitment_id = jsonb_extract_path_text(extra_info,'blocked','cur')::uuid
|
||||
,target_recruitment_id = jsonb_extract_path_text(extra_info,'blocked','trg')::uuid
|
||||
,department_id_old = jsonb_extract_path_text(extra_info,'blocked','dio')::uuid
|
||||
,system_pgs_status = '1.2'
|
||||
,conscription = null
|
||||
,extra_info = extra_info - ('blocked')
|
||||
where ${clause};
|
||||
end
|
||||
$$;
|
||||
]]>
|
||||
</RequestURL>
|
||||
<SqlConnectionParams>
|
||||
<JdbcHost>localhost</JdbcHost>
|
||||
<JdbcPort>5432</JdbcPort>
|
||||
<JdbcUsername>sqlUser</JdbcUsername>
|
||||
<JdbcPassword>sqlPassword</JdbcPassword>
|
||||
<JdbcDriverClassName>org.postgresql.Driver</JdbcDriverClassName>
|
||||
<JdbcXaDataSourceClassName>org.postgresql.xa.PGXADataSource</JdbcXaDataSourceClassName>
|
||||
<JdbcXaDataSourcePoolSize>15</JdbcXaDataSourcePoolSize>
|
||||
<JdbcDatabase>mainDatabase</JdbcDatabase>
|
||||
</SqlConnectionParams>
|
||||
</SqlRequest>
|
||||
|
||||
</Requests>
|
||||
|
|
@ -1,3 +1,3 @@
|
|||
configDirectory: /Users/maksim/Projects/Micord/configs
|
||||
configDirectory: /opt/execute-configs
|
||||
server:
|
||||
port: 8090
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue