R使用jdbc连接数据库,首先要安装java环境,再下载jdbc驱动包,然后安装RJDBC库,install.packages(“RJDBC”,dep=TRUE)
1、 连接MySQL
library(RJDBC)
drv<-JDBC("com.mysql.jdbc.Driver","/etc/jdbc/mysql-connector-Java-3.1.14-bin.jar",identifier.quote="`")
conn<-dbConnect(drv,"jdbc:mysql://localhost/test","user","pwd")
dbSendUpdate(conn,"LIBNAME DEMO SASSPDS schema='demoschema' USER='demo' PASSWORD='{sas001}ZM0' HOST='127.0.0.1' Serv='5000'") #注释:dbSendUpdate可以执行所有的sql语句,包括建表、查询、增删改等。
dbGetQuery(conn,"select * from DEMO.TEST WHERE DATE_CODE= '201211'") #注释:dbGetQuery()函数只能执行select语句
d<-dbReadTable(conn,"DEMO.TEST")#查看表的内容
dbDisconnect(conn)#关闭连接
2、 连接oracle
library(RJDBC)
drv<-JDBC("oracle.jdbc.driver.OracleDriver","E:/oracle/jdbc/lib/ojdbc14.jar", identifier.quote="\"") #注释:identifier.quote用来作写入数据库中表的列名的分隔符,与names(数据框)中显示的相一致
conn <- dbConnect(drv, "jdbc:oracle:thin:@127.0.0.1:1521:demo","demo","demo")
data(iris)
dbWriteTable(conn, "iris", iris, overwrite=TRUE)
3、 连接DB2
library(RJDBC)
drv<-JDBC("com.ibm.db2.jcc.DB2Driver","E:/IBM/SQLLIB/java/db2jcc.jar",identifier.quote="\"")
conn <- dbConnect(drv, "jdbc:db2://127.0.0.1:1521/demo","test","test")
data(iris)
dbWriteTable(conn, "iris", iris, overwrite=TRUE)
4、 连接hive
library(RJDBC)
drv<-JDBC("org.apache.hive.jdbc.HiveDriver",list.files("/home/Hadoop/hive/lib",pattern="jar$",full.names=TRUE,recursive=TRUE))
conn<-dbConnect(drv,sprint('jdbc:hive2://${IP}:${port}/default'),'username','passwd')
5.RJDBC常用函数:
JDBC(驱动,jar包,分隔符):加载数据库驱动
dbConnect(驱动参数,url,用户名,密码,其他):连接数据库
dbListTables(conn):显示连接中的所有表
dbWriteTable(conn, "iris", iris, overwrite=TRUE):将数据框iris写入表iris中,overwrite覆盖原表(append=TRUE追加,dbWriteTable(conn, "IRIS", d, overwrite=FALSE,append=TRUE)且d要与表iris的结构一致。)
dbGetQuery(conn, "select count(*) from iris"):查询语句
dbSendUpdate(conn,”sql语句”):执行任何非查询sql语句
dbReadTable(conn, "iris"):读取表中数据
dbDisconnect(conn):关闭连接
dbExistsTable(conn,”iris”):是否存在表iris
dbRemoveTable(conn,”iris”):删除表iris