inst/examples/load_inputs.R

In ashiklom/dbhelpers: Helper functions for working with database connections

library(PEcAn.DB)
library(dplyr)
library(dbhelpers)

db <- src_postgres(dbname = 'bety', user = 'bety', password = 'bety')

# Create inputs
site_id <- 676          # Willow Creek (US-WCr)
format_id <- 1073       # ED site/css/pss file
machine_id <- 77
file_path <- normalizePath('ed-inputs/sites/US-WCr/rtm/1cohort/dbh20/early_hardwood')

new_inputs_vec <- c('EDR_test.1cohort.cohort',
                    'EDR_test.1cohort.patch',
                    'EDR_test.1cohort.site')

file_prefix <- 'early_hardwood.lat45.5lon-90.5'

new_inputs <- tibble(name = new_inputs_vec) %>%
  mutate(site_id = site_id,
         format_id = case_when(grepl('\\.site$', .$name) ~ 10,
                               grepl('\\.patch$', .$name) ~ 15,
                               grepl('\\.cohort$', .$name) ~ 11),
         file_name = case_when(format_id == 10 ~ paste0(file_prefix, '.site'),
                               format_id == 15 ~ paste0(file_prefix, '.pss'),
                               format_id == 11 ~ paste0(file_prefix, '.css')),
         container_type = 'Input',
         machine_id = 77,
         file_path = file_path)

inputs <- db_merge_into(db = db,
                        table = 'inputs',
                        values = new_inputs,
                        by = 'name',
                        id_colname = 'id') 

dbfiles <- db_merge_into(db = db,
                         table = 'dbfiles',
                         values = new_inputs,
                         by = c('file_name', 'file_path'),
                         id_colname = 'id')

#insert <- insert_dbfile(file_path = file1_path,
                        #file_prefix = file1_prefix,
                        #siteid = siteid,
                        #startdate = startdate,
                        #enddate = enddate,
                        #machineid = machineid,
                        #db = db,
                        #hostname = hostname)