R/createPool.R

In chasemc/tempRepo: Protein and small molecule analysis of bacteria by MALDI-TOF MS

#' Create a pool connecton, given file names and a path
#' If there is no existing database by that name, create one.
#' 
#'   Note: Need both name and path due to how users select
#' @param fileName filename of sqlite database
#' @param filePath path of the location of sqlite database, sans filename
#'
#' @return a list of pool connections
#' @export
#' 
createPool <- function(fileName,
                       filePath){
  
  
  if (length(fileName) != length(filePath)) {
    warning("createPool: Length of fileName and filePath are different")
    
  } else { 
    
    fileName <- tools::file_path_sans_ext(fileName)
    fileName <- paste0(fileName, ".sqlite")
    
    filePaths <- file.path(filePath, fileName)
    names(filePaths) <- tools::file_path_sans_ext(fileName)
    
    # If no current database by that name exists, create it, 
    # otherwise make a connection to the existing one.
    if(length(filePaths) == 0){
      con <- pool::dbPool(drv = RSQLite::SQLite(),
                          dbname = base::file.path(filePath, fileName))
      tried <- try(DBI::dbListTables(con), silent = TRUE)
      req(class(tried) != "try-error")
      
    } else {
      con <- lapply(filePaths, function(x) pool::dbPool(drv = RSQLite::SQLite(),
                                                        dbname = x))
      tried <- try(DBI::dbListTables(con[[1]]), silent = TRUE)
      req(class(tried) != "try-error")
      
    }
    
    return(con)
  }
  
}






#----
#' Create New, Empty SQLite Database
#'
#' @param newExperimentName name for the sqlite DB
#' @param sqlDirectory directory to which the sqlite DB will be written into
#'
#' @return pool connection
#' @export
#'
createNewSQLITEdb <- function(newExperimentName,
                              sqlDirectory){
  # This pool is used when creating an entirely new "experiment" .sqlite db
  name <- tempRepo::path_sanitize(newExperimentName)
  name <- gsub(" ", "", name)
  
  # max 50 character file length
  name <-  base::substr(name, 1, 50)
  
  pool <- tempRepo::createPool(name,
                               sqlDirectory)
  return(pool)
}