HBase SQL(Phoenix) 入门

Phoenix 入门

本篇介绍简单的Phoenix使用方法，进行初步的数据查询。

在开始之前，请先确认您已经准备好了Phoenix的运行环境，若还没有，请参考这里

快速开始

1. 创建一个us_population表

   CREATE TABLE IF NOT EXISTS us_population (
      state CHAR(2) NOT NULL,
      city VARCHAR NOT NULL,
      population BIGINT
      CONSTRAINT my_pk PRIMARY KEY (state, city));

2. 写入数据

   UPSERT INTO us_population VALUES('NY','New York',8143197);
   UPSERT INTO us_population VALUES('CA','Los Angeles',3844829);
   UPSERT INTO us_population VALUES('IL','Chicago',2842518);
   UPSERT INTO us_population VALUES('TX','Houston',2016582);
   UPSERT INTO us_population VALUES('PA','Philadelphia',1463281);
   UPSERT INTO us_population VALUES('AZ','Phoenix',1461575);
   UPSERT INTO us_population VALUES('TX','San Antonio',1256509);
   UPSERT INTO us_population VALUES('CA','San Diego',1255540);
   UPSERT INTO us_population VALUES('TX','Dallas',1213825);
   UPSERT INTO us_population VALUES('CA','San Jose',912332);

3. 查询SQL

   SELECT state as "State",count(city) as "City Count",sum(population) as "Population Sum"
   FROM us_population
   GROUP BY state
   ORDER BY sum(population) DESC;

4. 结果验证

   

API访问Phoenix JDBC

Phoenix 5.x SDK maven依赖

<dependency>
  <groupId>com.aliyun.phoenix</groupId>
  <artifactId>ali-phoenix-queryserver-client</artifactId>
  <version>5.2.1-HBase-2.x</version>
</dependency>

Phoenix 4.x SDK maven依赖

<dependency>
    <groupId>com.aliyun.phoenix</groupId>
    <artifactId>ali-phoenix-core</artifactId>
    <version>${参考FAQ中最新版本说明}</version>
</dependency>

代码示例请参考：云HBase Demo