java phoenix是什么，讓我們一起了解一下？

使用java代碼，連接phoenix，從而實(shí)現(xiàn)phbase數(shù)據(jù)庫(kù)的增刪改查。phoenix定位為OLTP和操作型分析（operational analytics），大多用于在線業(yè)務(wù)，穩(wěn)定性要求第一位。

Phoenix核心能力是什么？

1、SQL引擎層：支持標(biāo)準(zhǔn)SQL 92，轉(zhuǎn)為SQL為HBase API，算子、過(guò)濾條件下推到Server端，并行執(zhí)行，輕量級(jí)事務(wù)、二級(jí)索引，動(dòng)態(tài)列、分頁(yè)查詢等多種SQL層能力。

2、JDBCDriver

3、Metadata管理

4、集成Spark、Hive、Pig、Flume和MapReduce

Java連接Phoenix有什么方式？

Phoenix JDBC Driver有兩種：

1、Thick Driver。直接連接zookeeper和hbase，包名 phoenix-

2、Thin Driver。構(gòu)建在http服務(wù)之上的jdbc驅(qū)動(dòng)，包名 phoenix-

連接HBase測(cè)試源碼如下：

public?static?void?main(String[]?args)?throws?Throwable?{
try?{
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
//這里配置zookeeper的地址，可單個(gè)，多個(gè)(用","分隔)可以是域名或者ip
String?url?=?"jdbc:phoenix:master,slave1,slave2,slave3:2181";
Connection?conn?=?DriverManager.getConnection(url);
Statement?statement?=?conn.createStatement();
long?time?=?System.currentTimeMillis();
ResultSet?rs?=?statement.executeQuery("select?*?from?test");
while?(rs.next())?{
String?myName?=?rs.getString("name");?//表中的列名
System.out.println("myName="?+?myName);
}
long?timeUsed?=?System.currentTimeMillis()?-?time;
System.out.println("time?"?+?timeUsed?+?"mm");
//?關(guān)閉連接
rs.close();
statement.close();
conn.close();
}?catch?(Exception?e)?{
e.printStackTrace();
}
}

以上就是小編今天的分享了，希望可以幫助到大家。