java phoenix

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

使用java代碼，連接phoenix，從而實現phbase數據庫的增刪改查。phoenix定位為OLTP和操作型分析（operational analytics），大多用于在線業務，穩定性要求第一位。

Phoenix核心能力是什么？

1、SQL引擎層：支持標準SQL 92，轉為SQL為HBase API，算子、過濾條件下推到Server端，并行執行，輕量級事務、二級索引，動態列、分頁查詢等多種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。構建在http服務之上的jdbc驅動，包名 phoenix-

連接HBase測試源碼如下：

public?static?void?main(String[]?args)?throws?Throwable?{
try?{
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
//這里配置zookeeper的地址，可單個，多個(用","分隔)可以是域名或者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");
//?關閉連接
rs.close();
statement.close();
conn.close();
}?catch?(Exception?e)?{
e.printStackTrace();
}
}

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