R/database.R

In tobiasziegler/aecfeedr: Retrieve Australian Federal Election Information and Results

#' Write data processed from a feed into a database
#'
#' Specify the parameters of the election feed you would like to access, and
#' this function will provide the URL for the corresponding FTP site and
#' directory.
#'
#' @param conn A `DBIConnection`` object, as returned by `dbConnect()`
#' @param data A list of tibbles containing data from an AEC feed
#' @param ... Other parameters passed on to the `dbWriteTable` method
#'
#' @return Invisibly returns `data`
#' @export
write_db_tables <- function(conn, data, ...) {
  if (!requireNamespace("DBI", quietly = TRUE)) {
    stop("Package \"DBI\" needed for this function to work. Please install it.",
      call. = FALSE
    )
  }

  purrr::iwalk(
    data,
    ~ DBI::dbWriteTable(
      conn = conn,
      name = .y,
      value = .x,
      ...
    ),
    conn,
    ...
  )
}