Vous n'êtes pas identifié(e).
Pages : 1
Super, j'ai mieux compris le fonctionnement des CTE et je vais essayer comme ça. Merci beaucoup
Il manque donc la requête finale. Par exemple
WITH s AS (SELECT...) SELECT * FROM s;
D'accord merci. Donc si j'ai bien compris, il n'y a pas de façon de créer les tables que j'ai voulu créer pour pouvoir les utiliser plus haut dans le code ? En tout cas pas de cette manière. Car je n'ai pas besoin de faire une requête finale derrière, mon but était juste d'alléger le code et de ne pas refaire cette table intermédiaire plusieurs fois. D'où mon idée de la faire une seule fois, de lui donner un nom et de l'appeler ensuite.
Comme disait Julien dans son premier commentaire, il manque un point virgule à la fin de la dernière requête ("group by i.id)").
Merci. Je l'ai rajouté mais j'ai toujours une erreur :
Error occurred during SQL query execution
Motif:
SQL Error [42601]: ERREUR: erreur de syntaxe à la fin de l'entrée
Position : 4020Quand j'enlève les tables CTE et que je les recréé à chaque fois que j'en ai besoin ça fonctionne, mais je suis pas sûre que ce soit le plus efficace et lisible comme code...
Désolée, je pensais que ça suffisait comme infos. Les CTE sont utilisées plus haut. Voici le code complet :
-- creation d'une fonction qui met à jour les données si elles sont valables et plus récentes
drop function if exists public.maj_lea_agbio_op_identification();
create function public.maj_lea_agbio_op_identification()
returns varchar as $maj_lea_agbio_op_identification$
begin
------------------- LISTE DES ACTIONS A REALISER ---------------
-------------------------- UPDATE DU NOUVEAU SIRET SI IL EST DIFFERENT ET VALIDE ------------------
-- verifie s'il y a un siret dans la table op_identification qui est different du siret valide le plus recent
if exists (select distinct siret_rec.id, siret_rec.siret, translate(siret_rec.siret,'0123456789','@@@@@@@@@@')
from siret_rec
left join lea_agbio_operateur_identification on siret_rec.id = lea_agbio_operateur_identification.id_operateur
and lea_agbio_operateur_identification.siret = siret_rec.siret
where lea_agbio_operateur_identification.id_operateur is null)
-- si oui, alors mise a jour
then update lea_agbio_operateur_identification
set siret = j.siret
from
export_br_oper
left join (select distinct siret_rec.id, siret_rec.siret
from export_br_oper
left join lea_agbio_operateur_identification on export_br_oper.id = lea_agbio_operateur_identification.id_operateur and lea_agbio_operateur_identification.siret = export_br_oper.siret
left join siret_rec on export_br_oper.id = siret_rec.id
where translate(export_br_oper.siret,'0123456789','@@@@@@@@@@')='@@@@@@@@@@@@@@'
and export_br_oper.siret<>'00000000000000'
and lea_agbio_operateur_identification.id_operateur is null
and export_br_oper.id = siret_rec.id
) j on export_br_oper.id = j.id
where j.id = lea_agbio_operateur_identification.id_operateur ;
end if;
---------------------- UPDATE DU NOUVEAU RS SI IL EST DIFFERENT ------------------
-- verifie s'il y a un rs dans la table op_identification qui est different du rs valide le plus recent
if exists (select distinct rs_rec.id, rs_rec.rs
from rs_rec
left join lea_agbio_operateur_identification on rs_rec.id = lea_agbio_operateur_identification.id_operateur
and lea_agbio_operateur_identification.rs = rs_rec.rs
where lea_agbio_operateur_identification.id_operateur is null)
-- si oui, alors mise a jour
then update lea_agbio_operateur_identification
set rs = j.rs
from
export_br_oper
left join (select distinct rs_rec.id, rs_rec.rs
from export_br_oper
left join lea_agbio_operateur_identification on export_br_oper.id = lea_agbio_operateur_identification.id_operateur and lea_agbio_operateur_identification.rs = export_br_oper.rs
left join rs_rec on export_br_oper.id = rs_rec.id
where lea_agbio_operateur_identification.id_operateur is null
and export_br_oper.id = rs_rec.id
) j on export_br_oper.id = j.id
where j.id = lea_agbio_operateur_identification.id_operateur ;
end if;
return null;
------------ LISTE DES TABLES AVEC LES INFOS VALIDES ET PLUS RECENTES --------
-- enregistre dans une "table" provisoire le siret valide le plus récent
with siret_rec as(
select i.id,
max(i.annee) as "annee",
max(case
when i.row_no = 1 then i.siret
end) as "siret"
from ( select export_br_oper.id, export_br_oper.annee, export_br_oper.siret,
row_number() over (partition by id order by annee desc) as "row_no"
from export_br_oper
where translate(export_br_oper.siret,'0123456789','@@@@@@@@@@')='@@@@@@@@@@@@@@'
and export_br_oper.siret<>'00000000000000') i
group by i.id),
-- enregistre dans une "table" provisoire le rs valide le plus récent
rs_rec as(
select i.id,
max(i.annee) as "annee",
max(case
when i.row_no = 1 then i.rs
end) as "rs"
from ( select export_br_oper.id, export_br_oper.annee, export_br_oper.rs,
row_number() over (partition by id order by annee desc) as "row_no"
from export_br_oper
where rs is not null) i
group by i.id)
end;
$maj_lea_agbio_op_identification$ language plpgsql;Bonjour,
J'ai créé une fonction qui est comme ceci:
-- creation d'une fonction qui met à jour les données si elles sont valables et plus récentes
drop function if exists public.maj_lea_agbio_op_identification();
create function public.maj_lea_agbio_op_identification()
returns varchar as $maj_lea_agbio_op_identification$
begin
------------------- LISTE DES ACTIONS A REALISER ---------------
--------------------------- UPDATE DU NOUVEAU SIRET SI IL EST DIFFERENT ET VALIDE ------------------
-- verifie s'il y a un siret dans la table op_identification qui est different du siret valide le plus recent
if exists (select distinct ... from ... where ...)
-- si oui, alors mise a jour
then update lea_agbio_operateur_identification
set siret = j.siret
from ... where ... ;
end if;
---------------------- UPDATE DU NOUVEAU RS SI IL EST DIFFERENT ------------------
-- verifie s'il y a un rs dans la table op_identification qui est different du siret valide le plus recent
if exists (select distinct ... from ... where ...)
-- si oui, alors mise a jour
then update lea_agbio_operateur_identification
set rs= j.rs
from ... where ... ;
end if;
return null;
------------ LISTE DES TABLES AVEC LES INFOS VALIDES ET PLUS RECENTES --------
-- enregistre dans une "table" provisoire le siret valide le plus récent
with siret_rec as(select ... from ... group by ...),
-- enregistre dans une "table" provisoire le rs valide le plus récent
rs_rec as(select ... from ... group by ...)
end;
$maj_lea_agbio_op_identification$ language plpgsql;J'ai vu sur un forum qu'il fallait écrire la partie with... as () après le "return", ce qui m'a permis de corriger des erreurs que j'avais avant. Cependant j'ai encore cette erreur que je n'arrive pas à régler :
Error occurred during SQL script execution
Motif:
SQL Error [42601]: ERREUR: erreur de syntaxe sur ou près de « end »
Position : 4061 Il s'agit du dernier end, juste avant $maj_lea_agbio_op_identification$ language plpgsql;
Je suis sur DBeaver.
Pages : 1