diff options
| -rw-r--r-- | R/load_cf.R | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/R/load_cf.R b/R/load_cf.R index 380e87c7..85da3852 100644 --- a/R/load_cf.R +++ b/R/load_cf.R @@ -336,16 +336,17 @@ for(cusip in names(cusipdata)){ identifier <- if(nrow(identifier)>0) identifier$identifier else NULL
if(!is.null(identifier)){
if(nrow(sqldata) && (tradedate %in% as.Date(sqldata$updatedate))){
- params <- c(values, identifier, as.character(tradedate))
+ params <- c(values[1:4], identifier, as.character(tradedate))
sqlstring <- paste0("UPDATE risk_numbers SET model_price=$1, wal=$2, duration=$3,",
- "index_delta='HY',delta=$4 WHERE identifier=$5 and date=$6")
+ "index_delta='HY',delta=$4 WHERE identifier=$5 and date=$6")
}else{
sqlstring <- paste0("INSERT INTO risk_numbers(identifier, date, index_delta,",
"model_price, wal, duration, delta) ",
"VALUES($1, $2, $3, $4, $5, $6, $7)")
- params <- c(identifier, as.character(tradedate), 'HY', values)
+ params <- c(identifier, as.character(tradedate), 'HY', values[1:4])
}
r <- dbSendQuery(dawndb, sqlstring, params=params)
dbClearResult(r)
}
}
+dbDisconnect(dawndb)
|