# 使用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)
}