From b10528a8eb0ba12676a0a46e068506e0dda849c4 Mon Sep 17 00:00:00 2001
From: Juliette Engelaere-Lefebvre
 <juliette.engelaere@developpement-durable.gouv.fr>
Date: Thu, 28 Oct 2021 10:59:15 +0200
Subject: [PATCH] WIP

---
 R/cogifier_mil.R |  7 +++++++
 _targets.R       | 43 +++++++++++++++----------------------------
 2 files changed, 22 insertions(+), 28 deletions(-)
 create mode 100644 R/cogifier_mil.R

diff --git a/R/cogifier_mil.R b/R/cogifier_mil.R
new file mode 100644
index 0000000..06ba680
--- /dev/null
+++ b/R/cogifier_mil.R
@@ -0,0 +1,7 @@
+# cogifier mil : ajout d'un paramètre mil à la fonction cogifier de COGiter 
+# pour pouvoir mettre à jour toutes les tables cogifiées dès lors que le paramètre de millésime bouge
+
+
+cogifier_mil <- function(mil, ...) {
+  COGiter::cogifier(...)
+}
\ No newline at end of file
diff --git a/_targets.R b/_targets.R
index c2c9540..2c30696 100644
--- a/_targets.R
+++ b/_targets.R
@@ -9,10 +9,10 @@ tar_option_set(packages = packages)
 
 source("R/load_agri.R", encoding = "UTF-8")
 source("R/load_ecln.R", encoding = "UTF-8")
-
-con <- datalibaba::connect_to_db()
+source("R/cogifier_mil.R", encoding = "UTF-8")
 
 root <- "X:/SCTE/DOES/IT/"
+mil_cog <- "2022"
 
 list(
     tar_target(
@@ -27,25 +27,18 @@ list(
       ),
     tar_target(
       post_agri,#Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "agri",
-                                overwrite = TRUE)
-    ),
+      datalibaba::post_data_pg(data = raw_data_agri,  #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "agri", schema = "public", db = "datamart", user = "does", overwrite = TRUE)),
     tar_target(
       cogifier_agri,#Nom de l'étape
-      cogifier(raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
-               code_commune = depcom),
+      cogifier_mil(raw_data_agri, #Nom de l'étape de laquelle est produit la lecture des données
+                  code_commune = depcom, mil = mil_cog),
       format = "feather" # Requires that the return value is a data frame
     ),
     tar_target(
       post_cogifier_agri, #Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = cogifier_agri, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "cogifiee_agri",
-                                overwrite = TRUE)
+      datalibaba::post_data_pg(data = cogifier_agri, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "cogifiee_agri", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     ),
     tar_target(
       raw_data_file_ecln, #Nom de l'étape
@@ -58,24 +51,18 @@ list(
     ),
     tar_target(
       post_ecln, #Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "ecln",
-                                overwrite = TRUE)
+      datalibaba::post_data_pg(data = raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "ecln", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     ),
     tar_target(
       cogifier_ecln, #Nom de l'étape
-      cogifier(raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-               code_commune = depcom),
+      cogifier_mil(raw_data_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                   code_commune = depcom, mil = mil_cog),
       format = "feather" # Requires that the return value is a data frame
     ),
     tar_target(
-      post_cogifier_ecln,#Nom de l'étape
-      datalibaba::post_data(con = con,
-                                data = cogifier_ecln, #Nom de l'étape de laquelle est produit la lecture des données
-                                schema = "public",
-                                table = "cogifiee_ecln",
-                                overwrite = TRUE)
+      post_cogifier_ecln, #Nom de l'étape
+      datalibaba::post_data_pg(data = cogifier_ecln, #Nom de l'étape de laquelle est produit la lecture des données
+                               table = "cogifiee_ecln", schema = "public", db = "datamart", user = "does", overwrite = TRUE)
     )
 )
-- 
GitLab