Apache Phoenix是构建在HBase上的SQL中间层。Phoenix引擎支持使用SQL进行HBase数据的查询。
背景信息
已创建集群,并且选择了Phoenix服务。
创建集群详情,请参见创建集群。
使用Phoenix
- 使用SSH方式连接集群,详情请参见使用SSH连接主节点。
- 执行以下命令,切换为hadoop用户。
- 执行以下命令,进入bin目录。
cd /usr/lib/phoenix-current/bin
- 执行以下命令,使用Phoenix的命令行工具。
sqlline.py
返回信息下图所示:

- 您可以使用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;