前提條件

已創建選擇了Phoenix和HBase服務的DataServing或Custom類型的集群，詳情請參見創建集群。

使用Phoenix客戶端

1. 使用SSH方式連接集群，詳情請參見登錄集群。

2. 執行以下命令，切換為hadoop用戶。

   su - hadoop

3. 執行以下命令，使用Phoenix的命令行工具。

   /opt/apps/PHOENIX/phoenix-current/bin/sqlline.py

4. 您可以使用SQL進行數據查詢。常見操作如下：

   • 創建表

     CREATE TABLE IF NOT EXISTS example(
         my_pk bigint not null,
         m.first_name varchar(50),
         m.last_name varchar(50) 
         CONSTRAINT pk PRIMARY KEY (my_pk)
     );

   • 插入數據

     UPSERT INTO example(my_pk,m.first_name,m.last_name) VALUES(100,'Jack','Ben');
     UPSERT INTO example(my_pk,m.first_name,m.last_name) VALUES(200,'Jack3','Ben3');

   • 查詢數據

     SELECT * FROM example;

     返回信息如下所示。

     +--------+-------------+------------+
     | MY_PK  | FIRST_NAME  | LAST_NAME  |
     +--------+-------------+------------+
     | 100    | Jack        | Ben        |
     | 200    | Jack3       | Ben3       |
     +--------+-------------+------------+

   • 刪除表

     DROP TABLE IF EXISTS example;

使用Phoenix JDBC

配置Maven依賴

<dependency>
     <groupId>org.apache.phoenix</groupId>
     <artifactId>phoenix-core</artifactId>
     <version>${phoenix.version}</version>
</dependency>

其中，${phoenix.version}須與集群中的Phoenix版本保持一致。

代碼示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import java.sql.Statement;

public class TestPhoenixJdbc {

    public static void main(String[] args) throws SQLException {
        Statement stmt = null;
        ResultSet rset = null;

        Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
        Connection con = DriverManager.getConnection("jdbc:phoenix:[zookeeper quorum hosts]");
        stmt = con.createStatement();

        stmt.executeUpdate("create table test (mykey integer not null primary key, mycolumn varchar)");
        stmt.executeUpdate("upsert into test values (1,'Hello')");
        stmt.executeUpdate("upsert into test values (2,'World!')");
        con.commit();

        PreparedStatement statement = con.prepareStatement("select * from test");
        rset = statement.executeQuery();
        while (rset.next()) {
            System.out.println(rset.getString("mycolumn"));
        }
        statement.close();
        con.close();
    }
}

其中，JDBC URL語法為jdbc:phoenix:[comma-separated ZooKeeper Quorum Hosts[: ZK port [:hbase root znode [:kerberos_principal [:path to kerberos keytab] ] ] ]。

相關文檔

Phoenix更多信息可以參見官方文檔：

• Phoenix優化

• Phoenix二級索引