R/get_data.R

In Rapporteket/soreg: soreg at Rapporteket

#' Get SoReg data
#'
#' Functions used to get data from SoReg database
#'
#' @param registry_name Character string providing the registry name
#' @param RESH character vector for choice of hospital
#' @param tabs Character vector where each element represents a database
#' table
#'
#' @return A data frame of registry data
#' @name get_data
#' @aliases data_years get_allevarnum get_arsrp data_sh
#' @importFrom rapbase loadRegData
NULL

#' @rdname get_data
#' @export
data_years <- function(registry_name) {

  query <- "
SELECT
  YEAR(o_dato_op) AS year
FROM
  AlleVarNum
GROUP BY
  YEAR(o_dato_op);"

  rapbase::loadRegData(registry_name, query)
}

#' @rdname get_data
#' @export
get_allevarnum <- function(registry_name) {

  query <- "
SELECT
  *
FROM
  AlleVarNum;"

  rapbase::loadRegData(registry_name, query)
}

#' @rdname get_data
#' @export
get_arsrp <- function(registry_name) {

  query <- "
SELECT
  *
FROM
  DatadumpArsrapport;"

  rapbase::loadRegData(registry_name, query)
}

#' @rdname get_data
#' @export
data_sh <- function(registry_name, RESH) {

  query <- "
SELECT
  *
FROM
  DatadumpArsrapport
WHERE OpererendeRESH = RESH;"

  rapbase::loadRegData(registry_name, query)
}



#' @rdname get_data
#' @export
describe_db <- function(registry_name, tabs = c()) {

  query_tab <- "SHOW TABLES;"
  query_desc <- "DESCRIBE "

  desc <- list()

  if (length(tabs) == 0) {
    tabs <- rapbase::loadRegData(registryName = registry_name,
                                 query = query_tab)[[1]]
  }

  for (tab in tabs) {
    query <- paste0(query_desc, tab, ";")
    desc[[tab]] <- rapbase::loadRegData(registryName = registry_name,
                                        query)
  }

  desc
}