R/data-lahman.r

In jimhester/dplyrJDBC: Extends dplyr to use JDBC SQL drivers.

#' @export
lahman_JDBC <- function(driver_location, ...) {
  cache_JDBC_postgres(driver_location, ...)
}


cache_JDBC_postgres = function(driver_location, ...) {
  cache_name <- "lahman_JDBC_postgres"
  if (dplyr:::is_cached(cache_name)) return(get_cache(cache_name))

  src <- src_JDBC(JDBC("org.postgresql.Driver", driver_location),
                  "jdbc:postgresql://localhost/lahman_jdbc", identifier.quote="'", ...)

  tables <- setdiff(dplyr:::lahman_tables(), src_tbls(src))

  # Create missing tables
  for(table in tables) {
    df <- getExportedValue("Lahman", table)
    message("Creating table: ", table)

    ids <- as.list(names(df)[grepl("ID$", names(df))])
    copy_to(src, df, table, indexes = ids, temporary = FALSE)
  }

  dplyr:::set_cache(cache_name, src)
}