Ajout de la fermeture de la connexion à la base de données

R/modify_column_type.R

@@ -16,8 +16,7 @@
 #' @return Retourne TRUE si la modification a été effectuée avec succès.
 #'
 #' @importFrom datalibaba connect_to_db
-#' @importFrom RPostgreSQL dbConnect dbDisconnect
-#' @importFrom DBI dbExecute
+#' @importFrom DBI dbExecute dbDisconnect
 #'
 #' @export
 #' @examples
@@ -61,10 +60,10 @@ modify_column_type <- function(host, database, schema, table, column_name,
                         " USING ", column_name, "::", column_type)
 
   # Exécuter la requête ALTER TABLE
-  dbExecute(connexion, alter_query)
+  DBI::dbExecute(connexion, alter_query)
 
   # Fermer la connexion à la base de données
-  dbDisconnect(connexion)
+  DBI::dbDisconnect(connexion)
 
   return(TRUE)
 }

R/schema_exists.R

@@ -12,6 +12,7 @@
 #' @return TRUE si le schéma existe, sinon FALSE
 #'
 #' @importFrom datalibaba list_schemas
+#' @importFrom DBI dbDisconnect
 #'
 #' @export
 #' @examples
@@ -35,5 +36,8 @@ schema_exists <- function(host, database, schema, role) {
   schemas <- datalibaba::list_schemas(connexion)
   schema_exists <- schema %in% schemas
 
+  # Fermer la connexion à la base de données
+  DBI::dbDisconnect(connexion)
+
   return(schema_exists)
 }

R/table_exists.R

@@ -13,6 +13,7 @@
 #' @return TRUE si la table existe, sinon FALSE
 #'
 #' @importFrom datalibaba list_tables
+#' @importFrom DBI dbDisconnect
 #'
 #' @export
 #' @examples
@@ -37,5 +38,8 @@ table_exists <- function(host, database, schema, table, role) {
   tables <- datalibaba::list_tables(connexion, schema = schema, db = database)
   table_exists <- table %in% tables
 
+  # Fermer la connexion à la base de données
+  DBI::dbDisconnect(connexion)
+
   return(table_exists)
 }