示例说明

最近更新时间: 2026-03-13 09:03:00

  • 启动客户端
    切换成 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;