diff options
Diffstat (limited to 'R/cusip_numbers.R')
| -rw-r--r-- | R/cusip_numbers.R | 30 |
1 files changed, 21 insertions, 9 deletions
diff --git a/R/cusip_numbers.R b/R/cusip_numbers.R index a65795a4..b7491b38 100644 --- a/R/cusip_numbers.R +++ b/R/cusip_numbers.R @@ -9,18 +9,30 @@ getdealdata <- function(dealnames){ return( dbGetQuery(dbCon, sqlstring) )
}
-workdate <- "2013-01-16"
+workdate <- "2013-01-22"
-dealnames <- listdealnames()
files <- list.files(path=file.path(root.dir, "Scenarios", paste("Portfolios", workdate, sep="_")), pattern="*.RData")
for(file in files){
load(file.path(root.dir, "Scenarios", paste("Portfolios", workdate, sep="_"), file))
- sqlstring <- sprintf(paste0("UPDATE et_dealname_model_numbers SET spread = %s, cdopercentage = %s,",
- "stale= %s WHERE dealname= '%s'"),
- deal.spread,
- deal.portfolio$cdopercentage,
- deal.portfolio$stale,
- strsplit(file, "\\.")[[1]][1])
- dbGetQuery(dbCon, sqlstring)
+ currdealnames <- dbGetQuery(dbCon, "select dealname from et_deal_model_numbers")$dealname
+ dealname <- strsplit(file, "\\.")[[1]][1]
+ if(dealname %in% currdealnames){
+ sqlstring <- sprintf(paste0("UPDATE et_deal_model_numbers SET dealspread = %s, cdopercentage = %s,",
+ "stalepercentage= %s WHERE dealname= '%s'"),
+ deal.spread,
+ deal.portfolio$cdopercentage,
+ deal.portfolio$stale,
+ dealname)
+ dbGetQuery(dbCon, sqlstring)
+ }else{
+ sqlstring <- sprintf(paste0("INSERT INTO et_deal_model_numbers ",
+ "VALUES('%s', %s, %s, %s)"),
+ dealname,
+ deal.portfolio$cdopercentage,
+ deal.portfolio$stale,
+ deal.spread)
+ dbGetQuery(dbCon, sqlstring)
+ currdealnames <- c(currdealnames, dealname)
+ }
}
|