R/sql.R

In vegdata: Access Vegetation Databases and Treat Taxonomy

#' Query and get data back into a data.frame
#'
#' @export
#' @param src (src) An `src` object, result of calling [src_germansl()],
#' [src_eurosl()]
#' @param query (character) A SQL query
#' @param ... further args passed on to [dplyr::tbl()]
#' @details we run [dplyr::tbl()], then [dplyr::collect()]
#' @examples \dontrun{
#' src <- src_germansl()
#' sql_collect(src, "select * from GermanSL limit 5")
#' ## or pipe the src to sql_collect
#' src %>% sql_collect("select * from GermanSL limit 5")
#' }
sql_collect <- function(src, query, ...) {
  dplyr::tbl(src, dplyr::sql(query), ...) %>% dplyr::collect()
}