WIP

R/cogifier_mil.R

+# 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

_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)
     )
 )