R/helpers.R

#' @importFrom odbc dbExistsTable dbRemoveTable
#' @importFrom DBI dbSendQuery
remove_if_exists <- function(con, name) {

  if(dbExistsTable(conn = con, name = name)) {
    message("removing ", name)
    dbRemoveTable(conn = con, name = name)
  }

}

create_name <- function(data, prefix = "sbif") {

  sprintf(
    "%s_proceso_%s_ruts_%s_pers_%s",
    prefix,
    format(Sys.time(), "%Y%m%d"),
    data %>% select(1) %>% pull() %>% unique() %>% length(),
    data %>% select(2) %>% pull() %>% unique() %>% length()
  )

}

upload_data <- function(con, data, tblname = NULL){

  remove_if_exists(con, tblname)

  message("uploading ", tblname)
  odbc::dbWriteTable(conn = con, name = tblname, value = data)

  tbl(con, tblname)

}

add_year_month <- function(data) {
  data %>%
    mutate(
      YEAR = as.integer(PERIODO/100),
      MONTH =  PERIODO - 100 * as.integer(PERIODO/100)
    )
}

add_year_month2 <- function(data) {
  data %>%
    mutate(
      YEAR = as.integer(as.integer(mes_matriz)/100),
      MONTH = as.integer(as.integer(mes_matriz) - 100 * as.integer(as.integer(mes_matriz)/100))
    )
}
jbkunst/modflblla documentation built on June 21, 2019, 12:53 p.m.