diff options
| -rw-r--r-- | R/build_portfolios.R | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/R/build_portfolios.R b/R/build_portfolios.R index 1b49a287..3a38b0bd 100644 --- a/R/build_portfolios.R +++ b/R/build_portfolios.R @@ -101,20 +101,21 @@ for(deal.name in dealnames){ deal.portfolio$stale,
deal.name,
as.Date(workdate))
- dbGetQuery(dbCon, sqlstring)
+ dbSendQuery(dbCon, sqlstring)
}else{
- sqlstring <- sprintf(paste0("INSERT INTO et_deal_model_numbers ",
- "VALUES('%s', %s, %s, %s, %s, '%s', '%s')"),
+ sqlstring <- sprintf(paste0("INSERT INTO et_deal_model_numbers",
+ "(dealname, cdopercentage, stalepercentage,",
+ "dealspread5y, marketvalue, updatedate, dealspread) ",
+ "VALUES('%s', %s, %s, %s, %s, '%s', %s)"),
deal.name,
deal.portfolio$cdopercentage,
deal.portfolio$stale,
deal.spread5y,
crossprod(deal.portfolio$notional, deal.portfolio$price)/100,
workdate,
- NULL,
deal.spreadatmaturity
)
- dbGetQuery(dbCon, sqlstring)
+ dbSendQuery(dbCon, sqlstring)
currdealnames <- c(currdealnames, deal.name)
}
}
|