R语言之连接mysql数据库

学习笔记
PS:写这个Blog的初衷是，心血来潮考古自己的Blog,看到3年前写的同一主题Blog,差点气到吐血，就重新写一遍了，顺便加一点R语言读取数据的其他方式。

R语言之连接mysql数据库

从mysql中读取数据

在用R连接mysql之前，我添加一个数据源：

注意，添加mysql数据源时，要填写数据源名称，用户名，密码和要使用的数据库！

如果不添加数据源，可能会报以下错误：

Warning messages:
1: In RODBC::odbcDriverConnect("DSN=mysql;UID=root;PWD=19970928") :[RODBC] ERROR: state IM002, code 0, message [Microsoft][ODBC 驱动程序管理器] 未发现数据源名称并且未指定默认驱动程序
2: In RODBC::odbcDriverConnect("DSN=mysql;UID=root;PWD=19970928") :ODBC connection failed

如果没有指定要使用的数据库，将无法进行查询/添加/删除等一系列操作(可能通过别的方法可以进行这些操作，但是现在我不知道，所以假装无法操作)，因为R不知道操纵哪个数据库，在用sqlTables方法时，可能会出现以下情况：

[1] TABLE_CAT   TABLE_SCHEM TABLE_NAME  TABLE_TYPE  REMARKS
<0 行> (或0-长度的row.names)

没错，啥表都查不到，这不是因为数据库里真的没有表，而是因为没有指定要使用的数据库！

好做完这一切后，开始我们的实验。

导包，并创建数据库连接

library(RODBC)
#建立数据库连接
channel <- odbcConnect("R4mysql", uid="root", pwd="19970928")
#要连接的数据源名称为R4mysql，用户名urrot, 密码19970928

显示数据库中的表

#显示stu数据库中的表
sqlTables(channel)

控制台输出：

  TABLE_CAT TABLE_SCHEM TABLE_NAME TABLE_TYPE REMARKS
1       stu                 images      TABLE
2       stu               interest      TABLE
3       stu             my_class_1      TABLE
4       stu             test_table      TABLE

获取数据库中的表

#将数据库中的interest表读到数据框中
df <- sqlFetch(channel,"interest")
print(df)

控制台输出：

  id  name hobby grade   price      comment
1  2 Bunny  sing     B 8888.88     小黄唧唧
2  3   Ada  draw     A 9999.99 小黄的铲屎官
3  6   Bai dance     A 8769.43     jijijiji

查询及插入记录

#查询语句
query = 'SELECT * FROM interest WHERE price > 9000'
#向数据库发送查询结果
my_select <- sqlQuery(channel,query)
print(my_select)#添加记录语句
query = 'insert into interest values(8, "Add", "sing", "B", 3456.32, "不想说话")'
#向数据库添加记录
sqlQuery(channel,query)

控制台输出：

  id name hobby grade   price      comment
1  3  Ada  draw     A 9999.99 小黄的铲屎官

查看mysql数据库中interest数据表的情况：

# id, name, hobby, grade, price, comment
'2', 'Bunny', 'sing', 'B', '8888.88', '小黄唧唧'
'3', 'Ada', 'draw', 'A', '9999.99', '小黄的铲屎官'
'6', 'Bai', 'dance', 'A', '8769.43', 'jijijiji'
'8', 'Add', 'sing', 'B', '3456.32', '不想说话'

记录成功添加！

写入/更新一个数据表

#将数据框写入或更新(append=TRUE)到数据库的某个表中
r_df <- data.frame(x  = seq(0, 8, 2), y = letters[1:5])
sqlSave(channel,  # 创建的数据连接r_df, #R数据框名称tablename = "r_sql_data", # 数据库表名rownames = FALSE, # 不存储数据框的行名append = F) r_df <- data.frame(x  = seq(0, 8, 2), y = letters[1:5])
sqlSave(channel,  # 创建的数据连接r_df, #R数据框名称tablename = "r_sql_data2", # 数据库表名rownames = T, # 存储数据框的行名append = F)

查看mysql数据库中，表r_sql_data和表r_sql_data2是否被写入:

# Tables_in_stu
'images'
'interest'
'my_class_1'
'r_sql_data'
'r_sql_data2'
'test_table'

嗯！成功写入了。

再看看分别看看两个数据表中的数据。

表r_sql_data:

# x, y
'0', 'a'
'2', 'b'
'4', 'c'
'6', 'd'
'8', 'e'

表r_sql_data2：

# rownames, x, y
'1', '0', 'a'
'2', '2', 'b'
'3', '4', 'c'
'4', '6', 'd'
'5', '8', 'e'

可以看到，r_sql_data2表相对于r_sql_data表多了一个行名，这是因为我们在构建r_sql_data2时，将参数rownames设置为TRUE。

删除数据库中的表

#删除数据库中的r_sql_data表和r_sql_data2表
sqlDrop(channel,'r_sql_data')
sqlDrop(channel,'r_sql_data2')

关闭连接

#关闭连接
close(channel)

其他导入方式

##直接从剪切板读取文件
r <- read.table("clipboard",head = TRUE)##读取csv、txt文件
r <- read.csv("shuju.csv", head = TRUE)
#设置stringsAsFactors = F 可以不让字符串变成因子
r <- read.table("shuju.txt", head = TRUE)##读取xlsx文件
library(readxl)
r <- read_excel("shuju.xlsx", sheet = 1)##以及各种其他文件
library(foreign)
#STATA
r <- read.dta("shuju.dta")
#SAS
r <- read.xport('shuju.xpt')
#SPSS
r <- read.spss('shuju.sav')

这里就不对其他导入方式的语法进行详述了。