- 启动客户端
切换成 hadoop 用户,进入/usr/local/service/hbase/phoenix-client/bin 目录,使用 Phoenix 的 Python 命令行工具:
./sqlline.py
执行成功后显示:
Phoenix 引擎支持使用 SQL 进行数据查询,一些常见操作如下:
- 创建表
0: jdbc:phoenix:> CREATE TABLE IF NOT EXISTS TEST (
host char(50) not null,
txn_count bigint
CONSTRAINT pk PRIMARY KEY (host)
);
- 插入数据
0: jdbc:phoenix:>UPSERT INTO TEST(host,txn_count) VALUES('192.168.1.1',1);
0: jdbc:phoenix:>UPSERT INTO TEST(host,txn_count) VALUES('192.168.1.2',2);
- 查询数据
0: jdbc:phoenix:>SELECT * FROM TEST;
- 删除数据表
0: jdbc:phoenix:>DROP TABLE IF EXISTS TEST;