R/SQL_loader.R

Defines functions SQL_loader

Documented in SQL_loader

#' @title SQL Loader
#'
#' @description
#' Description
#'
#' @param f_pg Project enviorment option
#' @param f_db Project enviorment option
#' @param f_tb_name Project enviorment option
#' @param f_data Project enviorment option
#' @param b_append Project enviorment option
#' @param b_overwrite Project enviorment option
#'
#' @return
#' Return
#'
#' @importFrom magrittr %<>%
#' @export

SQL_loader <- function(

	f_pg,
	f_db,
	f_tb_name,
	f_data,
	b_append,
	b_overwrite
) {

	# Reformat table name & colnames
	f_tb_name %<>% tolower()
	colnames(f_data) %<>% tolower()

	# Open PostgreSQL connection
	f_con <- DBI::dbConnect(
		drv = f_pg,
		user = "drivas",
		password = "",
		host = "localhost",
		port = 5432,
		dbname = f_db
	)

	# Close PostgreSQL connection when process is done
	on.exit(
		DBI::dbDisconnect(f_con)
	)

	# Write to PostgreSQL table
	DBI::dbWriteTable(
		conn = f_con,
		name = f_tb_name,
		value = f_data,
		row.names = FALSE,
		append = b_append,
		overwrite = b_overwrite
	)
}
DanielRivasMD/Rpack.chlSab documentation built on Nov. 18, 2019, 12:01 a.m.