############################################################################################ ###################### 行業數據 ############################################# ############################################################################################ create table stock_industry_wind (stock_id varchar(10) -- 股票代碼 ,DATETIME date -- 數據日期 ,STOCK_name varchar(50) -- 公司名 ,START_DATE DATE -- 上市日期 ,CONCEPT VARCHAR(500) -- 概念板塊 ,industry_gics VARCHAR(150) -- WIND行業名稱 11種分類 ,industry_gicscode INT -- WIND行業代碼 11種分類 ,industry_CSRC12 VARCHAR(150) -- 證監會行業名稱 19種分類 ) ############################################################################################ ############### 循環加載交易數據 ################## ############################################################################################ library(RCurl) library(RMySQL) # 載入RMySQL包 library(WindR) w.start()table_name <- "stock_industry_wind" flag <- ".SH" date_dt <- '20170320' filepath <- "E:/.../數據源/" security <- readLines(paste(filepath,'滬市代碼list.txt',sep = '')) filename <- paste(filepath,table_name,"_",date_dt,'.txt',sep = '') code <- vector(length = length(security)) listingdate <- vector(length = length(security)) security.tab <- data.frame(code, listingdate, stringsAsFactors=FALSE) for (i in 1 : length(security)) { security.tab[i,] = do.call(cbind,(strsplit(security[i],"\t"))) }for (i in 1 : length(security)) {code <- paste(security.tab$code[i],flag,sep="")cat(i,"\t---",code,"\t---","\n")w_wsd_data<-w.wss(code,'sec_name,ipo_date,concept,industry_gics,industry_gicscode,industry_CSRC12',tradeDate=date_dt,'industryType=1')data_df1<-w_wsd_data$Datadata_df1<-cbind(data_df1[,1],'2017-03-20',data_df1[,2:length(data_df1)])data_df1$IPO_DATE<-as.Date('1899-12-30')+data_df1$IPO_DATEif (i==1) { data_df2<-data_df1 }else { data_df2<-rbind(data_df1,data_df2) } }conn <- dbConnect(MySQL(),dbname = "gushi",username = "root") #建立數據庫連接dbSendQuery(conn, "SET @@sql_mode=ANSI;") # 啟動非嚴格模式dbSendQuery(conn, "SET NAMES GBK") # win7環境下如果漢字亂碼，就運行這條命令write.table(data_df2,file=filename,sep="\t",quote=FALSE,row.name=FALSE, col.names = FALSE)strSQL <- paste('load data infile \'',filename,'\' into table ',table_name,' character set GBK fields terminated by \'\t\' lines terminated by \'\n\'',sep="")res1 <-dbSendQuery(conn, strSQL)#dbWriteTable(conn,table_name,data_df1,append=T,row.names=F) ## 存在中文的話會不顯示#dbReadTable(conn,table_name)dbDisconnect(conn)

總結

以上是生活随笔為你收集整理的R语言-股票数据库(4)-股票行业和概念板块数据-Wind的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。