ajout d'arguments de sélection des tables pour la fonction imp_importer_aspe_idg()

Author: PascalIrz

DESCRIPTION

@@ -1,8 +1,8 @@
 Package: aspe
 Type: Package
 Title: An R Package to Analyse and Visualise River Fish Data in France
-Version: 0.5.1
-Date: 2025-10-16
+Version: 0.5.2
+Date: 2025-11-04
 Authors@R: c(
     person(given = "Pascal",
            family = "Irz", 

NAMESPACE

@@ -24,7 +24,9 @@ export(gg_temp_ipr_pc_bon)
 export(gg_temp_metriq)
 export(gg_temp_metriq_grille)
 export(gg_temp_peuplement)
+export(imp_connecter_aspe_idg)
 export(imp_corres_aspe_taxref)
+export(imp_deconnecter_aspe_idg)
 export(imp_extraire_noms_tables)
 export(imp_extraire_noms_tables2)
 export(imp_importer_aspe_idg)
@@ -79,8 +81,6 @@ export(mef_ssech_esp_env)
 export(misc_charger_donnees_test)
 export(misc_derniere_date)
 export(misc_nom_dernier_fichier)
-export(start_connexion_aspe_idg)
-export(stop_connexion_aspe_idg)
 import(dplyr)
 import(utils)
 importFrom(DBI,Id)

R/imp_importer_aspe_idg.R

@@ -1,6 +1,9 @@
-#' Importer les tables ASPE à partir de la BDD IDG (OFB)
+#' Importer les tables ASPE à partir de la BDD IDG (OFB).
+#' Par défaut elles le sont toutes.
 #'
 #' @param conn connexion à la BDD
+#' @param tab_excl Vecteur caractère indiquant les éventuelles tables à ne pas importer.
+#' @param tab_select Vecteur caractère indiquant les tables à importer. Prime sur tab_excl.
 #' @param ... autre
 #'
 #' @returns Les dataframes correspondant à chacune des tables de la base (sauf celles expurgées au préalable)
@@ -13,14 +16,14 @@
 #'
 #' @examples
 #' \dontrun{
-#' bdd_aspe <- start_connexion_aspe_idg()
+#' bdd_aspe <- imp_connecter_aspe_idg()
 #'
 #' imp_importer_aspe_idg(conn = bdd_aspe)
 #'
-#' stop_connexion_aspe_idg(conn = bdd_aspe)
+#' imp_deconnecter_aspe_idg(conn = bdd_aspe)
 #' }
 
-imp_importer_aspe_idg <- function(conn, ...){
+imp_importer_aspe_idg <- function(conn, tab_excl = NA, tab_select = NA, ...){
 
   table_names <-
     conn %>%
@@ -33,6 +36,16 @@ imp_importer_aspe_idg <- function(conn, ...){
   table_names <-
     table_names[!grepl('batch_', table_names)]
 
+  if (is.character(tab_select)) {
+    table_names <-
+      table_names[table_names %in% tab_select]
+  } else {
+    if (is.character(tab_excl)) {
+      table_names <-
+        table_names[!table_names %in% tab_excl]
+    }
+  }
+
   for (table_name in table_names) {
     id <- cli::cli_process_start("table {.val {table_name}}")
     tryCatch({

R/utils-connexion-idg.R

@@ -13,12 +13,12 @@
 #'
 #' @examples
 #' \dontrun{
-#' bdd_aspe <- start_connexion_aspe_idg()
+#' bdd_aspe <- imp_connecter_aspe_idg()
 #'
 #' }
 #'
 
-start_connexion_aspe_idg <- function() {
+imp_connecter_aspe_idg <- function() {
   required_vars <- c(
     'BDD_IDG_HOST',
     'BDD_IDG_PORT',
@@ -89,12 +89,12 @@ start_connexion_aspe_idg <- function() {
 #'
 #' @examples
 #' \dontrun{
-#' bdd_aspe <- start_connexion_aspe_idg()
+#' bdd_aspe <- imp_connecter_aspe_idg()
 #'
-#' stop_connexion_aspe_idg(conn = bdd_aspe)
+#' imp_deconnecter_aspe_idg(conn = bdd_aspe)
 #' }
 
 #' @importFrom DBI dbDisconnect
-stop_connexion_aspe_idg <- function(conn) {
+imp_deconnecter_aspe_idg <- function(conn) {
   DBI::dbDisconnect(conn)
 }