R通過RJDBC連接外部數據庫

1、 連接hive

library(RJDBC)

drv<-JDBC(“org.apache.hive.jdbc.HiveDriver”,list.files(“/home/hadoop/impala-jdbc-0.5.2”,pattern=”jar$”,full.names=TRUE,recursive=TRUE))

conn<-dbConnect(drv,sprint(‘jdbc:hive2://%s:%s/default’,'xxx.xxx.xxx.xxx’,'xxxxx’))#注釋：后面兩個分別為IP和端口

2、 連接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”)

3、 連接sas的spds

library(RJDBC)

drv<-JDBC("com.sas.rio.MVADriver",c("C:/sasjdbc/sas.core.jar","C:/sasjdbc/sas.oma.joma.jar","C:/sasjdbc/sas.oma.joma.rmt.jar","C:/sasjdbc/sas.oma.omi.jar","C:/sasjdbc/sas.security.sspi.jar","C:/sasjdbc/sas.svc.connection.jar"),identifier.quote="\"")

conn <- dbConnect(drv, "jdbc:sasiom://127.0.0.1:8580", "sasdemo", "q123","'SASSPDS'  'demoschema' USER='demo' PASSWORD='{sas001}ZM0'  Serv='50000'  HOST='127.0.0.1")

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)#關閉連接

4、 連接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)

5、 連接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)

RJDBC常用函數：

1、 JDBC(驅動,jar包,分隔符)：加載數據庫驅動

2、 dbConnect(驅動參數,url,用戶名,密碼,其他)：連接數據庫

3、 dbListTables(conn)：顯示連接中的所有表

4、 dbWriteTable(conn, "iris", iris, overwrite=TRUE)：將數據框iris寫入表iris中，overwrite覆蓋原表

（append=TRUE追加,dbWriteTable(conn, "IRIS", d, overwrite=FALSE,append=TRUE)且d要與表iris的結構一致。）

5、 dbGetQuery(conn, "select count(*) from iris")：查詢語句

6、 dbSendUpdate(conn,”sql語句”)：執行任何非查詢sql語句

7、 dbReadTable(conn, "iris")：讀取表中數據

8、 dbDisconnect(conn)：關閉連接

9、 dbExistsTable(conn,”iris”)：是否存在表iris

10、 dbRemoveTable(conn,”iris”)：刪除表iris