R语言引擎读取mysql并进行计算分析

hadoop | 2020-10-15 09:09:51

1.安装R环境

下载地址,下载后安装-选择生成桌面快捷图标-会生成R x64 和32位的图标。

2.编写代码

打开安装的R编辑器,这个默认编辑器不是很好用,R studio好用些,可以继续安装这个,但我只做简单的测试

2.1 加载RMySQL

install.packages("RMySQL")
library(RMySQL)

2.2读取mysql表到数据框

con <- dbConnect(MySQL(), host="10.10.22.154",port=3306, dbname="datacenter_quest_score", user="root", password="znxunzhi")
res<-dbReadTable(con,"t_project_cb38")

2.3 进行分组求和计算

result<-aggregate(res$QUEST_SCORE, res[,c("STUDENT_ID","SUBJECT_ID")],sum) 
print(result)

2.4关闭连接

关闭连接后数据框的数据应该还在,R是基于内存计算的,读取表的时候就把数据读取到了内存中,也就是数据框

dbClearResult(res)
dbDisconnect(con)

参考:http://bcxw.net/article/701.html

登录后即可回复 登录 | 注册
    
关注编程学问公众号