Skip to content

Commit

Permalink
fix(data/indicateurs): Fix insertion de la parentalité entre indicate…
Browse files Browse the repository at this point in the history 
…urs après la refonte des indicateurs
  • Loading branch information
@dthib
dthib committed Sep 18, 2024
1 parent 7cf1fd6 commit 58104bd
Show file tree
Hide file tree
Showing 4 changed files with 302 additions and 0 deletions.
147 changes: 147 additions & 0 deletions data_layer/sqitch/deploy/indicateur/fix_json_upsert.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,147 @@
-- Deploy tet:indicateurs/fix_json_upsert to pg

BEGIN;

create or replace function
private.upsert_indicateurs_after_json_insert()
returns trigger
as
$$
declare
indicateur jsonb;
id_courant integer;
begin
for indicateur in select * from jsonb_array_elements(new.indicateurs)
loop
insert into indicateur_definition(identifiant_referentiel,
titre,
titre_long,
description,
unite,
participation_score,
sans_valeur_utilisateur,
modified_at)
values (indicateur ->> 'id',
indicateur ->> 'nom',
indicateur ->> 'titre_long',
indicateur ->> 'description',
indicateur ->> 'unite',
(indicateur -> 'participation_score')::bool,
(indicateur -> 'sans_valeur')::bool,
now()
)
on conflict (identifiant_referentiel) do update
set identifiant_referentiel = excluded.identifiant_referentiel,
titre = excluded.titre,
titre_long = excluded.titre_long,
description = excluded.description,
unite = excluded.unite,
participation_score = excluded.participation_score,
sans_valeur_utilisateur = excluded.sans_valeur_utilisateur,
modified_at = excluded.modified_at
returning id into id_courant;

--- Enlève les tags TeT s'ils existent déjà
delete
from indicateur_categorie_tag ict
where ict.indicateur_id = id_courant
and ict.categorie_tag_id in (
select id
from categorie_tag
where collectivite_id is null and groupement_id is null);
--- Met les tags TeT
-- selection
if (indicateur -> 'selection')::bool then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = 'prioritaire'
and collectivite_id is null and groupement_id is null
limit 1);
end if;
-- type
if indicateur -> 'type' != 'null' and (indicateur -> 'type')::text in ('resultat','impact') then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = (indicateur -> 'type')::text
and collectivite_id is null and groupement_id is null
limit 1);
end if;
-- programmes
if indicateur -> 'programmes' != 'null' then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = pg::text
and collectivite_id is null and groupement_id is null
limit 1)
from jsonb_array_elements_text(indicateur -> 'programmes') as pg
where pg::text in (select nom from categorie_tag where collectivite_id is null);
end if;

-- actions
if indicateur -> 'action_ids' != 'null' then
--- insert les liens
insert into indicateur_action (indicateur_id, action_id)
select id_courant, id::action_id
from jsonb_array_elements_text(indicateur -> 'action_ids') as id
on conflict (indicateur_id, action_id) do nothing;
--- enlève les liens qui n'existent plus
delete
from indicateur_action ia
where ia.indicateur_id = id_courant
and ia.action_id not in
(select id::action_id from jsonb_array_elements_text(indicateur -> 'action_ids') as id);
end if;

-- thematiques
--- enlève les thématiques déjà existante
delete
from indicateur_thematique ia
where ia.indicateur_id = id_courant;
if indicateur -> 'thematiques' != 'null' then
--- insert les nouvelles thématiques
insert into indicateur_thematique (indicateur_id, thematique_id)
select id_courant, (select id
from thematique
where md_id = th
limit 1)
from jsonb_array_elements_text(indicateur -> 'thematiques') as th
where th in (
select distinct md_id
from thematique
)
on conflict (indicateur_id, thematique_id) do nothing;
end if;

-- Supprime les liens de parentés qu'on recréera dans une autre itération
delete
from indicateur_groupe
where enfant = id_courant;
end loop;

-- parent
for indicateur in select * from jsonb_array_elements(new.indicateurs)
loop
if indicateur -> 'parent' != 'null'
and (select count(*)>0
from indicateur_definition
where identifiant_referentiel = indicateur ->> 'parent') then
insert into indicateur_groupe (parent, enfant)
values ((select id
from indicateur_definition
where identifiant_referentiel = indicateur ->> 'parent'
limit 1),
(select id
from indicateur_definition
where identifiant_referentiel = indicateur ->> 'id'
limit 1));
end if;
end loop;

return new;
end;
$$ language plpgsql;

COMMIT;
147 changes: 147 additions & 0 deletions data_layer/sqitch/revert/indicateur/fix_json_upsert.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,147 @@
-- Revert tet:indicateurs/fix_json_upsert from pg

BEGIN;

create or replace function
private.upsert_indicateurs_after_json_insert()
returns trigger
as
$$
declare
indicateur jsonb;
id_courant integer;
begin
for indicateur in select * from jsonb_array_elements(new.indicateurs)
loop
insert into indicateur_definition(identifiant_referentiel,
titre,
titre_long,
description,
unite,
participation_score,
sans_valeur_utilisateur,
modified_at)
values (indicateur ->> 'id',
indicateur ->> 'nom',
indicateur ->> 'titre_long',
indicateur ->> 'description',
indicateur ->> 'unite',
(indicateur -> 'participation_score')::bool,
(indicateur -> 'sans_valeur')::bool,
now()
)
on conflict (identifiant_referentiel) do update
set identifiant_referentiel = excluded.identifiant_referentiel,
titre = excluded.titre,
titre_long = excluded.titre_long,
description = excluded.description,
unite = excluded.unite,
participation_score = excluded.participation_score,
sans_valeur_utilisateur = excluded.sans_valeur_utilisateur,
modified_at = excluded.modified_at
returning id into id_courant;

--- Enlève les tags TeT s'ils existent déjà
delete
from indicateur_categorie_tag ict
where ict.indicateur_id = id_courant
and ict.categorie_tag_id in (
select id
from categorie_tag
where collectivite_id is null and groupement_id is null);
--- Met les tags TeT
-- selection
if (indicateur -> 'selection')::bool then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = 'prioritaire'
and collectivite_id is null and groupement_id is null
limit 1);
end if;
-- type
if indicateur -> 'type' != 'null' and (indicateur -> 'type')::text in ('resultat','impact') then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = (indicateur -> 'type')::text
and collectivite_id is null and groupement_id is null
limit 1);
end if;
-- programmes
if indicateur -> 'programmes' != 'null' then
insert into indicateur_categorie_tag (indicateur_id, categorie_tag_id)
select id_courant, (select id
from categorie_tag
where nom = pg::text
and collectivite_id is null and groupement_id is null
limit 1)
from jsonb_array_elements_text(indicateur -> 'programmes') as pg
where pg::text in (select nom from categorie_tag where collectivite_id is null);
end if;

-- actions
if indicateur -> 'action_ids' != 'null' then
--- insert les liens
insert into indicateur_action (indicateur_id, action_id)
select id_courant, id::action_id
from jsonb_array_elements_text(indicateur -> 'action_ids') as id
on conflict (indicateur_id, action_id) do nothing;
--- enlève les liens qui n'existent plus
delete
from indicateur_action ia
where ia.indicateur_id = id_courant
and ia.action_id not in
(select id::action_id from jsonb_array_elements_text(indicateur -> 'action_ids') as id);
end if;

-- thematiques
--- enlève les thématiques déjà existante
delete
from indicateur_thematique ia
where ia.indicateur_id = id_courant;
if indicateur -> 'thematiques' != 'null' then
--- insert les nouvelles thématiques
insert into indicateur_thematique (indicateur_id, thematique_id)
select id_courant, (select id
from thematique
where md_id = th
limit 1)
from jsonb_array_elements_text(indicateur -> 'thematiques') as th
where th in (
select distinct md_id
from thematique
)
on conflict (indicateur_id, thematique_id) do nothing;
end if;

-- Supprime les liens de parentés qu'on recréera dans une autre itération
delete
from indicateur_groupe
where enfant = id_courant;
end loop;

-- parent
for indicateur in select * from jsonb_array_elements(new.indicateurs)
loop
if indicateur -> 'parent' != 'null'
and (select count(*)>0
from indicateur_definition
where identifiant_referentiel = (indicateur -> 'parent')::text) then
insert into indicateur_groupe (parent, enfant)
values ((select id
from indicateur_definition
where identifiant_referentiel = (indicateur -> 'parent')::text
limit 1),
(select id
from indicateur_definition
where identifiant_referentiel = (indicateur -> 'id')::text
limit 1));
end if;
end loop;

return new;
end;
$$ language plpgsql;

COMMIT;
1 change: 1 addition & 0 deletions data_layer/sqitch/sqitch.plan
View file
Original file line number Diff line number Diff line change
Expand Up @@ -710,3 +710,4 @@ indicateur/indicateurs_gaz_effet_serre 2024-09-03T15:35:34Z Marc Rutkowski <marc
taxonomie/thematique [taxonomie/[email protected]] 2024-08-21T09:51:00Z System Administrator <[email protected]> # Ajout de la thematique Agriculture et alimentation
indicateur/trajectoire 2024-09-03T14:57:42Z System Administrator <[email protected]> # Création d'un groupement pour les nouveaux indicateurs de la trajectoire
indicateur/fusion [indicateur/[email protected]] 2024-09-03T15:37:11Z System Administrator <[email protected]> # modified_by trigger est optionnel
indicateur/fix_json_upsert 2024-09-11T12:49:34Z System Administrator <[email protected]> # Fix insertion de la parentalité entre indicateurs après la refonte des indicateurs
7 changes: 7 additions & 0 deletions data_layer/sqitch/verify/indicateur/fix_json_upsert.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
-- Verify tet:indicateurs/fix_json_upsert on pg

BEGIN;

-- XXX Add verifications here.

ROLLBACK;

0 comments on commit 58104bd

Please sign in to comment.