phoenix java

<link rel="stylesheet" href="https://js.how234.com/third-party/SyntaxHighlighter/shCoreDefault.css" type="text/css" /><script type="text/javascript" src="https://js.how234.com/third-party/SyntaxHighlighter/shCore.js"></script><script type="text/javascript"> SyntaxHighlighter.all(); </script>

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的地址，可單個，多個(用","分隔)可以是域名或者ipString 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();}}