1. hbase协处理器问题  (1) 协处理器的代码逻辑异常，可能导致hbase的regionserver瘫痪。       解决方案：关闭hbase所有的守护过程，进入zookeeper里删除相应的表元数据，再启动hbase,删除相应的表。修改代码逻辑后，重新维护。  (2) 代码没问题，hbase缺乏集群设置。如...DoNotReTRYException:could not...Set hbase.table.sanity.checks to false...        解决方案：在hbase-site.xml里设置hbase.table.sanity.checks属性的值为false   

1. phoenix是apache组织其产品。相当于java中间件，可以相似jdbc访问RDBMS同样，来访HBase 2. phoenix可以运行hbase上的一个sql层。可以对hbase增删改查和管理数据。 3. phoenix的sql语句将在底层翻译成hbase的api，比如scan/get操作 4. phoenix适用于离线批处理(OLAP)操作不适合实时分析(OLTP) 

phoenix虽然是建在的hbase但由于以下特点，不会影响查询性能，反而会提高性能

- 编译SQL查询为原生HBase的scan语句 - 检测scan句子最好的开始和结束key - 精心安排你的scan让他们并行执行句子 - 让计算接近数据 - 推送你的WHERE从服务端过滤器处理到服务端 - 通过服务端钩(称为协同处理器)执行聚合查询 

phoenix还提供了一些优化性能的提升

- 实现了二级索引来提升非主键字段查询的性能 - 统计相关数据，提高并行化水平，帮助选择最佳优化方案 - 跳过扫描过滤器优化IN，LIKE，OR查询 - 优化主键均匀分布写压力 

phoenix不能做的事

- 不支持事务处理 - 不支持复杂的条件 

1. jdk1.8.0以上 2. hadoop2.7.6 3. zookeeper-3.4.10 4. hbase-1.2.1 

安装phoenix，相当于在机器上安装navicat工具。 

1)上传、解压、更名、配置环境变量、生效

[root@qianfeng01 ~]# tar -zxvf apache-phoenix-4.13.1-HBase-1.2-bin.tar.gz -C /usr/local/ [root@qianfeng01 ~]# cd /usr/local/ [root@qianfeng01 local]# mv apache-phoenix-4.13.1-HBase-1.2-bin/ phoenix [root@qianfeng01 local]# vim /etc/profile [root@qianfeng01 local]# source /etc/profile 验证是否能补全相关指令，    输入psq然后按tab键 

2）拷贝phoenix的两个jar包(core和client)到hbase在所有服务端的相关目录下(hbase的lib目录)

[root@qianfeng01 phoenix]# cp phoenix-4.13.1-HBase-1.2-client.jar phoenix-core-4.13.1-HBase-1.2.jar /usr/local/hbase/lib/ [root@qianfeng01 phoenix]# scp phoenix-4.13.1-HBase-1.2-client.jar phoenix-core-4.13.1-HBase-1.2.jar qianfeng02:/usr/local/hbase/lib/ [root@qianfeng01 phoenix]# scp phoenix-4.13.1-HBase-1.2-client.jar phoenix-core-4.13.1-HBase-1.2.jar qianfeng03:/usr/local/hbase/lib/ 

3）配置三台hbase的hbase-site.xml文件

<property>      <name>phoenix.schema.isNamespaceMappingEnabled</name>      <value>true</value>  </property>  <property>      <name>phoenix.schema.mapSystemTablesToNamespace</name> <value>true</value> </property> <property> <name>hbase.table.sanity.checks</name> <value>false</value> </property> 

4）拷贝hbase的hbase-site.xml到phoenix的bin目录下，覆盖自带的文件

[root@qianfeng01 phoenix]# cp /usr/local/hbase/conf/hbase-site.xml ./bin

1. 先启动hdfs和zookeeper  （phoenix是通过zookeeper连接hbase）
2. 再启动hbase(注意：如果在配置phoenix前已经启动了hbase，需要重启)，(hbase里的新配置会跟着生效)
3. 启动phoenix客户端
	[root@qianfeng01 phoenix]# sqlline.py
	

可以使用help查看常用指令，也可以使用！table查看是否有四张系统表。

注意：在启动时可能报以下错误

Traceback (most recent call last):
File "./sqlline.py", line 27, in <module>
import argparse
<font color=red>ImportError: No module named argparse</font>

解决办法：

在安装phoenix的服务器上安装该模块。

[root@qianfeng01 phoenix]# yum ‐y install python‐argparse #(不报错可以不用安装)
0: jdbc:phoenix:qianfeng01:2181> !tables   #列出所有表

help:   查看所有指令的帮助信息
!table  |  !tables   查看所有的表
!describe ：查看的表的描述信息
!index:  查询表的所有索引信息
使用 !history可以查看执行的历史SQL
使用 !dbinfo 可以查看Phoenix所有的属性配置

phoenix支持的数据类型

tinyint
smallint
integer
bigint
float
double
boolean
varchar
char
time
date
timestamp

就是使用sqlline.py脚本直接连接phoenix.
语法如下：
sqlline.py  [zkServer:port]
解析：zkServer 指的是zookeeper的服务端的主机名或者是ip地址
port:是zookeeper服务端的端口号，2181

[root@qianfeng01 ~]# sqlline.py 
或者
[root@qianfeng01 ~]# sqlline.py qianfeng03:2181


连接后，可以建表，可以进行增删改查操作
建表：
create table t1(id integer primary key,name varchar(1));
select * from system.catalog;

需要使用psql.py批处理脚本来执行sql脚本

1）创建一个建表语句的脚本

首先创建createtable.sql文件，里面添加l两个建表语句，表名分别是us_population和ak_population

[root@qianfeng01 phoenix]# vi ./sql/createtable.sql

CREATE TABLE IF NOT EXISTS us_population (
state CHAR(2) NOT NULL,
city VARCHAR NOT NULL,
population BIGINT
CONSTRAINT my_pk PRIMARY KEY (state, city)
);


CREATE TABLE IF NOT EXISTS ak_population (
state CHAR(2) NOT NULL,
city VARCHAR NOT NULL,
population BIGINT
CONSTRAINT my_pk PRIMARY KEY (state, city)
);

2）维护一个us_population表的数据文件us_population.csv

[root@qianfeng01 phoenix]# vi ./data/us_population.csv

NY,New York,8143197
CA,Los Angeles,3844829
IL,Chicago,2842518
TX,Houston,2016582
PA,Philadelphia,1463281
AZ,Phoenix,1461575
TX,San Antonio,1256509
CA,San Diego,1255540
TX,Dallas,1213825
CA,San Jose,912332

3）维护一个ak_population表的数据文件ak.csv

[root@qianfeng01 phoenix]# vi ./sql/ak.csv

AK,kenai,450283
AK,haines,370283
AK,fairbanks,390283

4）使用psql.py来运行脚本

执行命令为：psql.py [zkserver:port] filepath……

-- 可以使用批处理命令，来执行多个文件
[root@qianfeng01 phoenix]# psql.py ./sql/createtable.sql ./sql/us_population.csv 


-- 会出现异常，因为在导入数据时，文件名必须要和表名一致。
[root@qianfeng01 phoenix]# psql.py ./sql/ak.csv
java.lang.IllegalArgumentException: Table AK not found
   
-- 更名后，再次导入 
[root@qianfeng01 phoenix]# mv ./sql/ak.csv ./sql/ak_population.csv
[root@qianfeng01 phoenix]# psql.py ./sql/ak_population.csv

--在phoenix命令行上检查表的数据
select * from us_population;
select * from ak_population;

小贴士：

1、通过Phoenix建的表都会自动转成大写，如果需要使用小写的表，请使用create table "tablename" 

2、安装了Phoenix之后，系统会自动生成四张系统表

3、在Phoenix中创建的表同时会在HBase中创建一张表与之对应，并且需要使用psql.py脚本加载数据

4、能将建表语句写入脚本，那么一定可以将查询语句写入脚本

1）配置pom.xml

<dependencies>
    <dependency>
        <groupId>org.apache.phoenix</groupId>
        <artifactId>phoenix-core</artifactId>
        <version>4.13.1-HBase-1.2</version>
    </dependency>
</dependencies>

2）编写代码（回顾jdbc的连接步骤）

1. 加载驱动
	phoenix的驱动类名：  org.apache.phoenix.jdbc.PhoenixDriver 
2. 获取连接对象:
	Properties pro = new Properties();
    pro.setProperty("phoenix.schema.isNamespaceMappingEnabled","true");
	Connection conn = DriverManager.getConnection("jdbc:phoenix:qianfeng01,qianfeng02,qianfeng03:2181",Properties prop)
3. 获取预编译执行对象
4. 发送sql语句，获取结果集
5. 处理结果集
6. 关闭连接

忽略，参考文档

phoenix的建表语句，必须要有一个主键约束,表名会默认变大写，如果想要小写的表名，需要加双引号。

--建表语句案例：
create table student(
id integer primary key,
name varchar(20),
age integer,
salary double
);

create table teacher(
id integer not null,
name varchar(20) not null,
age integer,
salary double,
constraint pk_id_name primary key(id,name)
)

--删除表
drop table [if exists] student1;

--自己测试是否支持修改表结构 已经验证：支持
语法：alter table tableName add colName type;


注意事项： 
	（1）建表语句必须有主键约束，hbase会将带有主键约束的字段映射成rowkey字段
	（2）如果是联合主键，那么字段后面要有非空约束。
    （3）如果不指定schame，会将表映射到hbase的default命名空间下

两种方式：

第一种：可以使用psql.py批处理脚本进行加载数据
第二种：可以在phoenix的命令行上使用以下方式来插入数据

phoenix的插入关键语句是 upsert into 或者upsert into……. select ………….

案例演示：
upsert into student values(1001,'zhangsan',23,1000.0);
upsert into student (id,name,age)values(1002,'lisi',24);
upsert into student (id,name,age,salary)values(1003,'wangwu',25,1100.0);
upsert into student (id,name,age,salary)values(1004,'zhaoliu',25,1100.0);

案例演示：要插入的数据来源于另外一张表
create table student1(
id integer primary key,
name varchar(20),
age integer,
salary double
);
upsert into student1 select * from student;
upsert into student1(id,name,age) select id,name,age from student where id>1002;

注意事项：
	主键约束的字段一定要有值。
	多次插入操作，如果主键字段的值相同，其实是hbase的覆盖操作。

因为phoenix是在建立hbase之上的，所以phoenix的修改就是upsert into  对应hbase的插入和修改都是put.

案例演示：修改id为1003的姓名为wangwu1，年龄为20
upsert into student1 (id,name,age) values(1003,'wangwu1',20);

使用delete关键字，和mysql语法一致。

在phoenix4.8版本以后，引入了Schema概念，映射的是Hbase的namespace. 当然如果想要生效，那么必须在hbase框架和phoenix框架中的hbase-site.xml中配置以下两个属性：
phoenix.schema.isNamespaceMappingEnabled = true
hoenix.schema.mapSystemTablesToNamespace = true

-- 创建一个schema
create schema  schemaName     <--- schemaName，要么加双引号，要么不加，不加会自动转为大写。

create schema "ns2"
create schema ns2     ns2和“ns2”是两个schema，在hbase中对应两个namespace,也证明了hbase中的标识符，比如表名，namespace的名字，都是区分大小写。


-- 在schema下创建表:   在ns2下创建表名为小写的s1的表。
create table ns2."s1"(
id integer primary key,
name varchar(20)
);
create table ns2.s1(
id integer primary key,
name varchar(20)
);
create table "ns2".S1(
id integer primary key,
name varchar(20)
);
create table "ns2"."s1"(
id integer primary key,
name varchar(20)
);

注意：如果没有指定列族名，那么在hbase中对应的列族名为0. 建表时可以指定列族名

--在schema下创建表，同时指定列族名

create table "ns2".s2(
id integer primary key,
base.name varchar(20)
);

upsert into "ns2".s2 values(1001,'zhangsan');


create table "ns2"."s2"(
id integer primary key,
"base".name varchar(20)
);
upsert into "ns2"."s2" values(1001,'zhangsan');



create schema "ns2";
create table "ns2"."s3"(
id integer primary key,
"base".name varchar(20),
"base"."age" INTEGER,
"f1"."province" varchar(20),
"f1"."city" varchar(20)
)
column_encoded_bytes=0;

upsert into "ns2"."s3" values(1001,'zhangsan',23,'guangdong','深圳');

注意：建表时带上column_encoded_bytes=0,在hbase中可以将key解析成字符串。

以上操作都是先在phoenix上创建schema，table。会自动映射到hbase中的namespace以及table。

指先在hbase中创建的表，Phoenix中是看不到的，如果想要在phoenix看到，那么必须做映射关系操作。

如何映射表？？？？？？？？？？？
在phoenix中创建一张表
（1）表名必须相同，如果有命名空间，那么在phoenix中必须要有schema与之映射
（2）表中必须要有主键，rowkey会自动与主键字段进行映射，主键字段名可以是row,也可以是其他名称
（3）表的列名前必须要有列族名与hbase的列族名一致。
（4）字段的类型,建议使用varcharl。
（5）高版本虽然可以不加此属性column_encoded_bytes=0，但是建议在做映射时，要加上。


drop table "mydb"."student";
create table "mydb"."student"(
id varchar(10) primary key,
"f1"."name" varchar(8),
"f1"."age" integer,
"f1"."gender" varchar(10),
"f1"."birth" varchar(20),
"f3"."province" varchar(20),
"f3"."city" varchar(20)
)
column_encoded_bytes=0;