diff options
| -rw-r--r-- | R/load_cf.R | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/R/load_cf.R b/R/load_cf.R index 23a78825..6d6c4116 100644 --- a/R/load_cf.R +++ b/R/load_cf.R @@ -326,10 +326,10 @@ for(cusip in names(cusipdata)){ "delta=$4, mvoc=$5, mvcoverage=$6 WHERE cusip=$7 and updatedate=$8")
}else{
- sqlstring <- paste0("INSERT INTO et_cusip_model_numbers ",
- "VALUES($1, $2, $3, $4, $5, $6, $7, $8)")
- params <- c(cusip, values, as.character(tradedate))
-
+ params <- c(list(cusip=cusip, updatedate=as.character(tradedate)), values)
+ sqlstring <- sprintf("INSERT INTO et_cusip_model_numbers(%s) VALUES(%s)",
+ paste(names(params), collapse=","),
+ paste(paste0("$", 1:length(params)), collapse=","))
}
r <- dbSendQuery(etdb, sqlstring, params=params)
if(dbHasCompleted(r)){
|