R语言实现操作MySQL数据库

install.packages('RMySQL')

# 加载包
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"

# 方法1：字符向量
dbCreateTable(con,'table1',fields =c("id"='int',"value"="float"))
# 方法2：数据框
dbCreateTable(con,'table2',fields = mtcars)

# 方法3：sql语句
dbSendQuery(con,'create table if not exists table3(id int,value float)')

## <MySQLResult:11,5,3>

# 先设置编码（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(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 苏州

# 筛选前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(con,"iris",iris,row.names=FALSE,append=TRUE)

## [1] TRUE

dbSendStatement(con,'insert into table1 values(1,12)')
## <MySQLResult:1701147206,5,12>

# 删除表
dbRemoveTable(con,'table1')
## [1] TRUE

dbRemoveTable(con,'table2')
## [1] TRUE

dbRemoveTable(con,'table3')
## [1] TRUE

dbRemoveTable(con,'iris')
## [1] TRUE

# 关闭连接
dbDisconnect(con)


## [1] TRUE