ruut/R/db_connect.R

#' Connect to database
#'
#' Andmebaasiga ühenduse looomine.
#' @param conf A list() of configuration variables. Default values \code{\link[ruut]{get_config}}.
#' #' @return Connection to the database.
#' @keywords database, schema
#' @export
#' @examples
#' \dontrun{
#'
#' config <- get_config()
#' conn <- db_connect(conf = config)
#'
#' }
db_connect <- function(conf = NULL) {
  if (is.null(conf)) {
    config <- ruut::get_config()
  } else {
    config <- conf
  }
  # DBI::dbDisconnect(conn)
  if (all(c("dbname", "host", "port", "user", "password") %in% names(config))) {
    try(conn <- DBI::dbConnect(RPostgreSQL::PostgreSQL(),
      dbname = config$dbname, host = config$host,
      user = config$user, password = config$password,
      port = config$port
    ))
  } else {
    conn <- NULL
    print("Andmebaasiga \U00FChendamise parameetrid puudulikud. Palun kontrolli konfiguratsiooni faili.")
    return()
  }
  # ## Andmebaasiga ühenduse kontroll
  # if (exists("conn") && !inherits(conn, "try-error")) {
  #   print("Connection exist")
  # } else {
  #   print("Connection error")
  # }
  return(conn)
}
# dbDisconnect(conn)
# Disconnect
# lapply(DBI::dbListConnections(RPostgreSQL::PostgreSQL()), DBI::dbDisconnect)