Apache Phoenix是构建在HBase上的SQL中间层。Phoenix引擎支持使用SQL进行HBase数据的查询。

背景信息

已创建集群,并且选择了Phoenix服务。

创建集群详情,请参见创建集群

使用Phoenix

  1. 使用SSH方式连接集群,详情请参见使用SSH连接主节点
  2. 执行以下命令,切换为hadoop用户。
    su hadoop
  3. 执行以下命令,进入bin目录。
    cd /usr/lib/phoenix-current/bin
  4. 执行以下命令,使用Phoenix的命令行工具。
    sqlline.py
    返回信息下图所示:Phoenix
  5. 您可以使用SQL进行数据查询,常见操作如下:
    • 创建表
      CREATE TABLE 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 example;