ApsaraDB for HBase:HBase SQL (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>${See release notes for the latest version in FAQ}</version>
  </dependency>

参照

コード例については、例 をご参照ください。