大数据系列03-基于已有Hbase集群部署phoenix的queryserver

一 直接在hbase安装的机器上下载phoenix

wget http://mirrors.tuna.tsinghua.edu.cn/apache/phoenix/apache-phoenix-5.0.0-HBase-2.0/bin/apache-phoenix-5.0.0-HBase-2.0-bin.tar.gz
tar -zxvf apache-phoenix-5.0.0-HBase-2.0-bin.tar.gz

# 部署位置
mkdir /usr/local/hbase/phoenix-queryserver
mv apache-phoenix-5.0.0-HBase-2.0-bin /usr/local/hbase/phoenix-queryserver/apache-phoenix-5.0.0-HBase-2.0-bin

二 直接启动phoenix queryserver

cd /usr/local/hbase/phoenix-queryserver/apache-phoenix-5.0.0-HBase-2.0-bin/bin
./queryserver.py start

# 查看日志看是否正常启动
cat /tmp/phoenix/phoenix-root-queryserver.log

# 如果看到以下两行信息说明已正常启动
2019-11-21 01:30:27,548 INFO org.apache.phoenix.shaded.org.eclipse.jetty.server.Server: Started @2206ms
2019-11-21 01:30:27,548 INFO org.apache.calcite.avatica.server.HttpServer: Service listening on port 8765.

三 通过轻量级客户端连接queryserver

cd /usr/local/hbase/phoenix-queryserver/apache-phoenix-5.0.0-HBase-2.0-bin/bin
./sqlline-thin.py

# 进入之后 通过命令查看表结构
!tables
+------------+--------------+-------------+---------------+----------+------------+----------------------------+-----------------+--------------+-----------------+---------------+---------------+---------------+
| TABLE_CAT  | TABLE_SCHEM  | TABLE_NAME  |  TABLE_TYPE   | REMARKS  | TYPE_NAME  | SELF_REFERENCING_COL_NAME  | REF_GENERATION  | INDEX_STATE  | IMMUTABLE_ROWS  | SALT_BUCKETS  | MULTI_TENANT  | VIEW_STATEMEN |
+------------+--------------+-------------+---------------+----------+------------+----------------------------+-----------------+--------------+-----------------+---------------+---------------+---------------+
|            | SYSTEM       | CATALOG     | SYSTEM TABLE  |          |            |                            |                 |              | false           | null          | false         |               |
|            | SYSTEM       | FUNCTION    | SYSTEM TABLE  |          |            |                            |                 |              | false           | null          | false         |               |
|            | SYSTEM       | LOG         | SYSTEM TABLE  |          |            |                            |                 |              | true            | 32            | false         |               |
|            | SYSTEM       | SEQUENCE    | SYSTEM TABLE  |          |            |                            |                 |              | false           | null          | false         |               |
|            | SYSTEM       | STATS       | SYSTEM TABLE  |          |            |                            |                 |              | false           | null          | false         |               |
|            |              | CROWD_ITEM  | TABLE         |          |            |                            |                 |              | false           | null          | false         |               |
+------------+--------------+-------------+---------------+----------+------------+----------------------------+-----------------+--------------+-----------------+---------------+---------------+---------------+

# 通过命令建表
CREATE TABLE IF NOT EXISTS CROWD_ITEM (
  crowd_id VARCHAR,
  serial_number VARCHAR,
  account_id VARCHAR,
  buy_user_id VARCHAR,
  mobile_phone VARCHAR,
  CONSTRAINT PK PRIMARY KEY (crowd_id, account_id)
);

select * from crowd_item;
+-----------+----------------+-------------+--------------+---------------+
| CROWD_ID  | SERIAL_NUMBER  | ACCOUNT_ID  | BUY_USER_ID  | MOBILE_PHONE  |
+-----------+----------------+-------------+--------------+---------------+
+-----------+----------------+-------------+--------------+---------------+