Sql scripts max

Surfrider-RecurringJobs/SqlScripts/100_fetch_old_campaign_for_new_rivers.sql

@@ -0,0 +1,16 @@
+SELECT id_ref_campaign_fk
+FROM bi.campaign_river
+WHERE river_name IN 
+	(
+	SELECT DISTINCT A.river_name
+	FROM bi_temp.campaign_river A
+	INNER JOIN bi_temp.pipelines B
+	ON A.id_ref_campaign_fk = B.campaign_id
+	-- WHERE A.pipeline_id = [?current_id?]  // comment on récup cet id_pipeline et sous quel format ?
+	) 
+	;
+
+
+-- NEXT => aller copier pour toutes ces campaign_id les data du schéma bi dans le schéma bi_temp ? 
+-- Sur quel périmètre ? 
+

Surfrider-RecurringJobs/SqlScripts/101_fetch_correctly_processed_campaigns.sql

@@ -0,0 +1,7 @@
+SELECT campaign_id
+FROM bi_temp.pipelines
+WHERE campaign_has_been_computed = True 
+AND river_has_been_computed = True 
+; 
+
+-- Puis copier pour ces campaign_id les data du schéma bi_temp dans le schéma bi (inverse du T100) ? 

Surfrider-RecurringJobs/SqlScripts/99_insert_id_campaign_to_process.sql

@@ -0,0 +1,2 @@
+INSERT INTO bi_temp.pipelines (campaign_id) 
+SELECT id FROM campaign.campaign WHERE has_been_computed = Null;