diff options
| -rw-r--r-- | R/new_index_series.R | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/R/new_index_series.R b/R/new_index_series.R index 4c4c4163..1b113c84 100644 --- a/R/new_index_series.R +++ b/R/new_index_series.R @@ -60,13 +60,14 @@ newcurves <- function(indextype, series, basketid){ data.frame(ticker=ticker, bds(paste(ticker, "Curncy"), "CDS_CURVE_INFO"))) } + temp <- aggregate(Ticker~ticker, data=cdscurves, FUN=sqlArray) + colnames(temp) <- c("curve_ticker", "cds_curve") + prep.data <- merge(prep.data, temp) + prep.data$doc_clause <- gsub("-", " ", prep.data$doc_clause) - prep.data$cds_curve <- aggregate(Ticker~ticker, data=cdscurves, FUN=sqlArray)$Ticker - df$doc_clause <- gsub("-", " ", df$doc_clause) sqlstr <- paste0("INSERT INTO bbg_issuers", "(name, company_id, ticker, currency, seniority, doc_clause, cds_curve)", "VALUES($1, $2, $3, $4, $5, $6, $7)") - with(prep.data, for(i in 1:nrow(prep.data)){ r <- dbSendQuery(serenitasdb, sqlstr, |