一、准备工作

由于笔者的HBase版本为2.1.0而Phoenix的5.x版本都高于本版本，所以读者可以直接采用2.4.0的SDK。同时对于
Phoenix则使用如下的依赖（其中compat需要根据实际HBase的版本进行选择）。 

  1. <dependencies>
  2.   <dependency>
  3.     <groupId>org.apache.phoenix</groupId>
  4.     <artifactId>phoenix-core</artifactId>
  5.     <version>5.1.0</version>
  6.   </dependency>
  7.   <dependency>
  8.     <groupId>org.apache.phoenix</groupId>
  9.     <artifactId>phoenix-hbase-compat-2.4.0</artifactId>
  10.     <version>5.1.0</version>
  11.   </dependency>
  12. </dependencies>

完成以上依赖后我们就可以利用JDBC进行语句执行操作，具体代码示例如下。 

  1. public static Connection getConnection() {
  2.     Connection con;
  3.     try {
  4.         Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
  5.         con = DriverManager.getConnection("jdbc:phoenix:localhost:2181");
  6.         return con;
  7.     } catch (Exception e) {
  8.         e.printStackTrace();
  9.         return null;
  10.     }
  11. }
  13. @Test
  14. public void query() throws SQLException {
  15.     String sql = "select * from db1";
  17.     Connection con = getConnection();
  18.     Statement stmt = con.createStatement();
  20.     // 执行查询
  21.     ResultSet rs = stmt.executeQuery(sql);
  23.     // 获取元数据信息
  24.     ResultSetMetaData rsmd = rs.getMetaData();
  25.     int columnCount = rsmd.getColumnCount();
  27.     // 获取列名
  28.     StringBuilder sb = new StringBuilder();
  30.     for (int i = 1; i <= columnCount; i++) {
  31.         String columnName = rsmd.getColumnLabel(i);
  32.         sb.append(columnName + "\t");
  33.     }
  35.     if (sb.length() > 0) {
  36.         sb.setLength(sb.length() - 1);
  37.         System.out.println(sb.toString());
  38.         // 查询结果
  39.         while (rs.next()) {
  40.             sb = new StringBuilder();
  41.             for (int i = 1; i <= columnCount; i++) {
  42.                 sb.append(rs.getString(i) + "\t");
  43.             }
  45.             if (sb.length() > 0) {
  46.                 sb.setLength(sb.length() - 1);
  47.                 System.out.println(sb.toString());
  48.             }
  49.         }
  50.     }
  51.     con.close();
  52. }

如果读者期望在Spring Boot中利用Mybatis使用Phoenix来操作HBase可以参考本文档