phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

简介

原生的HBaseAPI使用起来真的比较麻烦,当然公司有架构师做一层封装,提供给开发人员使用应该还不错。如果么有架构师怎么办?Apache出的Phoenix就是干了架构师的工作,提供了jdbc接口对HBase表进行操作。

Phoenix安装

1.下载

打开网址http://mirror.bit.edu.cn/apache/phoenix/,可以看到如下类似的页面。phoenix对hbase版本有严格的要求,因此在使用的时候要格外小心,如果公司的hbase升级后,使用phoenix编写的代码也需要更新jar,甚至修改代码(这个有点蛋疼,不知道会不会因为这一点导致其很难广泛被使用)

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

我自己的hbase是0.98,所以我下的第一个

2.上传解压

tar -xf apache-phoenix-4.13.1-HBase-0.98.tar.gz

3.复制如下两个jar包到hbase\lib目录下

hbase集群中的所有机器都要执行

cp apache-phoenix-4.13.1-HBase-0.98/phoenix-4.13.1-HBase-0.98-server.jar hbase-0.98.17-hadoop2/lib/phoenix-4.13.1-HBase-0.98-server.jar

cp apache-phoenix-4.13.1-HBase-0.98/phoenix-4.13.1-HBase-0.98-client.jar hbase-0.98.17-hadoop2/lib/phoenix-4.13.1-HBase-0.98-client.jar

4.配置环境变量

####################### hbase ##########################
export HBASE_HOME=/home/hadoop/proc/hbase-0.98.17-hadoop2
PATH=$PATH:$HBASE_HOME/bin
export PATH

5.启动测试

启hadoop\zk\hbase

启动phoenix

在phoenix\bin目录下执行

sqlline.py hadoop01,hadoop02,hadoop03:2181

--hadoop01,hadoop02,hadoop03:2181是zk集群地址串

命令行操作

**创建表**

create table ph_test(id integer primary key,name varchar);

**查询表**

select * from ph_test;

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

创建的表字段虽然给的小写,但表的元信息其实默认是大写的,如果要想字段名是小写,可以在创建表的时候用双引号将列包含起来。

phoenix中创建的表实际上就是在hbase上创建了一张表,类似于hive中创建表在hdfs上创建了一个文件夹一样

phoenix表中的主键会成为hbase表的行键

如果不声明phoenix表中的普通列会成为hbase表中默认列族(名字叫0)中的普通列,也可以使用语法指定列族的名字(一般没什么必要,几乎设计的表都是一个列族)

注:如果hbase中有一张存在的表,而phoenix中没有,则只需要创建一个表名一样,列数一样的表即可。

**插入数据**

upsert into ph_test(id) values(123);

upsert into ph_test(id,name) values(123,'Messi');

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

upsert表示插入和更新是同一个命令,因为id是行键,不允许不指定id的值

**删除数据**

delete from ph_test where id=124;

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

删除表

drop table ph_test;

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

API操作

1.新建一个maven工程

2.在pom文件中加入

<dependencies>
<dependency>
<groupId>org.apache.phoenix</groupId>
<artifactId>phoenix-core</artifactId>
<version>4.13.0-HBase-0.98</version>
</dependency>
<dependency>
<groupId>jdk.tools</groupId>
<artifactId>jdk.tools</artifactId>
<version>1.8</version>
<scope>system</scope>
<systemPath>C:\Users\jionsvolk\.m2\repository\jdk\tools\jdk.tools\1.8\jdk.tools-1.8.jar</systemPath>
</dependency>
</dependencies>

jdk.tools自动下载总是不成功,就我自己本机的jdk目录中把tools.jar复制到Maven本地仓库对应的目录下,文件名修改为jdk.tools-1.8.jar

3.写代码

package com.jv.phoenixm;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class TestPhoenix {
public static void main(String[] args) throws Exception {
Connection conn = DriverManager.getConnection("jdbc:phoenix:hadoop01,hadoop02,hadoop03:2181");
Statement stat = conn.createStatement();
ResultSet rs = stat.executeQuery("select * from ph_test");
while(rs.next()){
String v1 = rs.getString("ID");
System.out.println(v1);
String v2 = rs.getString("NAME");
System.out.println(v2);
}
stat.close();
conn.close();
}
}

执行输出结果

phoenix jdbc驱动下载,Phoenix安装与JDBC连接Phoenix

更多的增删改操作和jdbc一样,随便看看以前的jdbc的insert update delete就可以咯

发表评论

0