caca的程式之路

因為整個連結過程說難不難 說簡單又很容易打結

所以想留點紀錄避免其他人在走一次

前置作業 : 

          首先要先開好架設於Hadoop, HBase, 上的Phoenix

          我的實驗環境是以VM ware開好 Phoenix叢集  再以windows 下的R Studio執行指令

          測試環境為Hadoop2-6-0

          HBase 1.0.0

          Phoenix 4.4.0

          R3.1.3

R 語言部分:

>library("RJDBC")

>jdbctest <- JDBC("org.apache.phoenix.jdbc.PhoenixDriver","C:/phoenix-4.2.2-client.jar")

>#這時會多一個jdbctest變數 可以確認有無成功

> conn <- dbConnect(jdbctest, "jdbc:phoenix:192.168.58.199", port="2181")

>#寫資料的格是如下

>dbSendUpdate(conn,"create table if not exist rtest (id Integer primary key,k integer) ")

>dbSendUpdate(conn,"upsert into rtest values(1,3)")

>dbSendUpdate(conn,"upsert into rtest values(2,5)")

>dbSendUpdate(conn,"upsert into rtest values(3,6)")

>#注意要dbcommit常會更新到phoenix中!

>dbCommit(conn)

>#注意格式是否正確

>dbGetQuery(conn, "select * from rtest")

>#會從已經創好的rtest table中選出所有的資料 並存成data.frame的架構

>#相關指令可以在R的 RJDBC package 文件中找到

 >