用R语言做数据分析时，常常需要从多种数据源取数据，其中数据库是非常常见的数据源。用R操作MySQL数据库，可以说是数据分析师必备的技能了，本文介绍RMySQL包，可以在R语言中对数据库进行增删改查的操作。
install.packages('RMySQL')
用dbConnect函数创建连接，驱动类型设置为MySQL()，用户名user、密码password、主机host、端口port、数据库dbname这些参数需要根据实际情况修改，其中端口port默认值是3306。
# 加载包
library(RMySQL)
# 创建连接
con <- dbConnect(MySQL(),
user="root",
password="xxx",
host="192.168.1.244",
port=3306,
dbname="test")
还可以通过一些命令，查看连接的相关信息。
# 连接概述 summary(con)
## <MySQLConnection:0,5> ## User: root ## Host: 192.168.1.244 ## Dbname: test ## Connection type: 192.168.1.244 via TCP/IP ## ## Results:
# 连接详情 dbGetInfo(con)
## $host ## [1] "192.168.1.244" ## ## $user ## [1] "root" ## ## $dbname ## [1] "test" ## ## $conType ## [1] "192.168.1.244 via TCP/IP" ## ## $serverVersion ## [1] "5.7.23" ## ## $protocolVersion ## [1] 10 ## ## $threadId ## [1] 465075 ## ## $rsId ## list()
# 列出连接下所有表 dbListTables(con)
## [1] "city" "result" ## [3] "t_json" "tb_newChiller"
dbCreateTable函数创建表
# 方法1：字符向量
dbCreateTable(con,'table1',fields =c("id"='int',"value"="float"))
# 方法2：数据框
dbCreateTable(con,'table2',fields = mtcars)
注意点：
运行dbSendQuery函数，调用sql语句创建表,该函数返回一个RMySQLResult类。该方法可以重复运行，不会报错。
# 方法3：sql语句 dbSendQuery(con,'create table if not exists table3(id int,value float)')
## <MySQLResult:11,5,3>
dbReadTable函数读取表
# 先设置编码（windows） dbSendQuery(con,'set names gbk') ## <MySQLResult:11,5,4>
# 读取完整表 dbReadTable(con,'city') ## id name city_code ## 1 1 北京 000001 ## 2 4 南京 000002 ## 3 7 广州 000003 ## 4 10 上海 000004 ## 5 11 深圳 000005 ## 6 13 苏州 000006
注意点：
通过运行dbGetQuery或dbSendQuery函数，调用sql语句读取表。
dbGetQuery函数运行sql语句，返回data.frame。可以在sql语句中编写筛选语句。
# 读取完整表 dbGetQuery(con,'select * from city') ## id name city_code ## 1 1 北京 000001 ## 2 4 南京 000002 ## 3 7 广州 000003 ## 4 10 上海 000004 ## 5 11 深圳 000005 ## 6 13 苏州 000006
# 读取筛选的表 dbGetQuery(con,'select id,name from city where id > 10') ## id name ## 1 11 深圳 ## 2 13 苏州
dbSendQuery函数运行sql语句，返回MySQLResult类。对该类使用dbFetch函数，可以筛选行，返回data.frame。用完后需要用dbClearResult函数清理结果。
# 筛选前3行数据 res <- dbSendQuery(con,'select * from city') dbFetch(res,3) ## id name city_code ## 1 1 北京 000001 ## 2 4 南京 000002 ## 3 7 广州 000003
dbClearResult(res) ## [1] TRUE
dbWriteTable函数写入表
# 写入表 dbWriteTable(con,"iris",iris,row.names=FALSE,append=TRUE)
## [1] TRUE
注意点：
| 参数设置 | 解释 |
|---|---|
| append=TRUE | 追加写入，新数据在原数据行末添加 |
| overwrite=TRUE | 覆盖写入，新数据覆盖原数据 |
| row.names=FALSE | 不写入数据框的行名 |
运行dbSendStatment函数，调用sql语句插入数据。
dbSendStatement(con,'insert into table1 values(1,12)') ## <MySQLResult:1701147206,5,12>
注意点：
用dbRemoveTable函数删除表。
# 删除表 dbRemoveTable(con,'table1') ## [1] TRUE dbRemoveTable(con,'table2') ## [1] TRUE dbRemoveTable(con,'table3') ## [1] TRUE dbRemoveTable(con,'iris') ## [1] TRUE
完成所有的操作后，需要关闭连接。
# 关闭连接 dbDisconnect(con) ## [1] TRUE
到此这篇关于R语言实现操作MySQL数据库的文章就介绍到这了,更多相关R语言操作MySQL内容请搜索呐喊教程以前的文章或继续浏览下面的相关文章希望大家以后多多支持呐喊教程！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：notice#nhooo.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。