本篇介绍简单的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>

相关参考

代码示例请参考:参考示例