1.mysql_helper.R
# 使用RMySQL操作数据库# 载入DBI和RMySQL包library(DBI)library(RMySQL)mysql_con <- function(){ # 创建数据库连接 con <- dbConnect(MySQL(),host ="localhost",dbname="cars",user="root",password="123456") #说明用什么字符集来获取数据库字段 dbGetQuery(con, "SET NAMES gbk") # 返回连接状态 return(con) # 验证连接 #print(summary(con)) }#关闭数据库mysql_close <- function(con){ # 断开连接 dbDisconnect(con) }# ======================================================================# 查询mysql_find <- function(sql){ # 连接数据库 con <- mysql_con() # SQL查询 results <- dbGetQuery(con,sql) # 关闭数据库 mysql_close(con) # 返回结果集 return(results)}# 增删改mysql_cud <- function(sql){ # 连接数据库 con <- mysql_con() # 执行SQL dbExecute(con,sql) # 关闭数据库 mysql_close(con)}