使用Phoenix连接Hbase

想要使用SQL语句对Hbase进行查询，需要使用Apache的开源框架Phoenix。
演示环境：Phoenix 4.9.0-Hbase-1.1 + Hbase 1.1.9

1 本地安装Phoenix

1.1 下载Phoenix

从Apache下载Phoenix（下载链接），从4.8.0到4.10.0各版本都有，本地安装的Hbase版本为1.1.9，所以选择对应Hbase是1.1版本的下载。这里我下载的是4.9.0版本，资源包 apache-phoenix-4.9.0-HBase-1.1-bin.tar.gz

(Hbase 1.1.9版本下载链接)

1.2 配置

首先，将下载的资源包解压到本地，将phoenix-4.9.0-HBase-1.1-client.jar和phoenix-core-4.9.0-HBase-1.1.jar两个jar包拷贝至Hbase的/lib文件夹。另外，将Hbase的配置文件base-site.xml拷贝至Phoenix根目录中的/bin文件夹下到此就完成了配置。

1.3 启动

首先启动Hadoop，然后启动Hbase，在Phoenix文件夹下执行：

bin/sqlline.py master

进入Phoenix命令行，执行

！tables

即可查看所有Hbase中的所有数据表。

1.4 增删查改操作
创建表格示例：

create table person(id varchar primary key, name varchar);

插入数据示例：

upsert into person values ('111','jone');

这里的upsert既有插入也有更新的功能，兼SQL中的insert和update功能，更新时按主键更新。

删除数据示例：

delete from person where id='222';

查询示例：

select * from person;

2 在Java项目中集成Phoenix

在Java项目中实现Phoenix操作Hbase，maven引入Phoenix的依赖包：

<dependency>
<groupId>org.apache.phoenix</groupId>
<artifactId>phoenix-core</artifactId>
<version>4.9.0-HBase-1.1</version>
</dependency>

但是引入这个包是不够的，还需要另外引入一个依赖包phoenix-4.9.0-HBase-1.1-client.jar，这个依赖包可以在Phoenix文件中找到，也可以通过下载Phoenix源码，自行编译后导入，自此就可以通过java的JDBC访问操作Hbase。
java测试的源码如下：

public static void main(String args[]) {
    Connection connection = null;
    Statement statement = null;
try {
        Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
        connection = DriverManager.getConnection("jdbc:phoenix:master:2181","","");
        statement = connection.createStatement();
        statement.execute("upsert into yinxiang_note values (3, 'note of huhong')");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
try {
                connection.close();
                statement.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }