R/hydro.R

In einarhjorleifsson/mar: dplyr backend to the MRI Oracle database

#' @export
hydro_hitamaelar <- function(con) {
  tbl_mar(con,"hydro.hitamaelar") %>%
    dplyr::select(-c(snt:sbn)) %>%
    dplyr::mutate(ar = to_number(to_char(timi, "YYYY")))
}
#' @export
hydro_stadir <- function(con) {
  tbl_mar(con, "hydro.stadir") %>%
    dplyr::select(-c(snt:sbn))
}
#' @export
hydro_stodvanofn <- function(con) {
  tbl_mar(con, "hydro.stodvanofn") %>%
    dplyr::mutate(lengd = -lengd * 100,
           breidd = breidd * 100) %>%
    mar:::geoconvert()
}
#' @export
hydro_observation <- function(con) {
  tbl_mar(con, "hydro.observation") %>%
    dplyr::select(-c(snt:sbn))
}
#' @export
hydro_trolltog <- function(con) {
  tbl_mar(con, "hydro.trolltog") %>%
    dplyr::select(-c(snt:sbn))
}
#' @export
hydro_station <- function(con) {
  tbl_mar(con, "hydro.station") %>%
    dplyr::select(-c(snt:sbn)) %>%
    dplyr::mutate(lon =   as.integer(longitude) * 100 + ifelse(is.na(la_sec), 0, as.integer(lo_sec)),
           lat =   as.integer(latitude)  * 100 + ifelse(is.na(lo_sec), 0, as.integer(la_sec))) %>%
    mar:::geoconvert(col.names = c("lon", "lat")) %>%
    dplyr::mutate(lon = ifelse(lo_id == "W", -lon,  lon),
           lat = ifelse(la_id == "N",  lat, -lat)) %>%
    dplyr::select(t_id:id, lon, lat, q_cont:name)
}
#' @export
hydro_sonda <- function(con) {
  tbl_mar(con, "hydro.sonda") %>%
    dplyr::select(-c(snt:sbg))
}